package com.vci.server.framework.volume.delegate;
|
|
import java.io.File;
|
import java.util.ArrayList;
|
import java.util.List;
|
import org.apache.commons.lang3.StringUtils;
|
|
import com.vci.common.objects.UserEntity;
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.common.data.UserEntityInfo;
|
import com.vci.corba.framework.data.PvolumeInfo;
|
import com.vci.corba.log.data.LogType;
|
import com.vci.server.base.delegate.BaseDelegate;
|
import com.vci.server.base.delegate.UserEntityDelegate;
|
import com.vci.server.base.utility.LogRecordUtil;
|
import com.vci.server.cache.VolumeCacheProvider;
|
import com.vci.server.framework.cache.VolumeCatch;
|
import com.vci.server.framework.volume.dao.Pvolume;
|
import com.vci.server.framework.volume.service.PvolumeService;
|
|
public class PvolumeDelegate extends BaseDelegate {
|
|
private PvolumeService pvoSer = new PvolumeService();
|
|
public PvolumeDelegate(UserEntityInfo userEntityInfo){
|
super(userEntityInfo);
|
}
|
public PvolumeDelegate(){
|
|
}
|
|
/**
|
* 卷创�?
|
* @param pvolumeInfo
|
* @param userEntityInfo
|
* @return
|
*/
|
public String savePvolume(PvolumeInfo pvolumeInfo,UserEntityInfo userEntityInfo)throws VCIError{
|
|
UserEntityDelegate.setUserEntityToService(pvoSer, userEntityInfo);
|
|
if (StringUtils.isBlank(pvolumeInfo.id)) {
|
String id = ObjectUtility.getNewObjectID36();
|
pvolumeInfo.id = id;
|
}
|
|
Pvolume pvolume = changePvolumeInfoToPvolume(pvolumeInfo);
|
//UserEntity userEntity = changeUserEntityInfoToUserEntity(userEntityInfo);
|
try {
|
//createFileCabinet(pvolume.getPath());
|
boolean success = pvoSer.savePvolume(pvolume);
|
if (success) {
|
VolumeCatch.setVolume(pvolumeInfo);
|
}
|
LogRecordUtil.writeLog(userEntityInfo, "添加", success ? "添加成功" : "添加失败", pvolume.getLogInfo(),LogType.General,pvolume.getId());
|
} catch (Exception e) {
|
throw new VCIError("310100",new String[0]);
|
}
|
|
|
return pvolume.getId();
|
|
}
|
|
/**
|
* 读取所有卷
|
* @return
|
* @throws VCIError
|
*/
|
public PvolumeInfo[] getAllPvolumes() throws VCIError{
|
return VolumeCacheProvider.getAllVolumes();
|
// List<Pvolume> list = null;
|
// try {
|
// list = pvoSer.getAllPvolumes();
|
// } catch (Exception e) {
|
// throw new VCIError("310101",new String[0]); //获取卷信息出错，请重新获取�?
|
// }
|
// int size = list.size();
|
// PvolumeInfo[] infos = new PvolumeInfo[size];
|
// for (int i = 0; i < size; i++) {
|
// infos[i] = changePvolumeToPvolumeInfo(list.get(i));
|
// }
|
// return infos;
|
|
}
|
//分页读取数据
|
public PvolumeInfo[] getPvolumesPage(int pageSize, int pageIndex)throws VCIError{
|
List<Pvolume> list = null;
|
try {
|
list = pvoSer.getPvolumesPage(pageSize,pageIndex);
|
} catch (Exception e) {
|
throw new VCIError("310101",new String[0]); //获取卷信息出错，请重新获取�?
|
}
|
int size = list.size();
|
PvolumeInfo[] infos = new PvolumeInfo[size];
|
for (int i = 0; i < size; i++) {
|
infos[i] = changePvolumeToPvolumeInfo(list.get(i));
|
}
|
return infos;
|
}
|
|
// public PvolumeInfo getDocumentVolumn(String id) throws VCIError {
|
// PvolumeInfo info = null;
|
// try {
|
// Pvolume pvolume = pvoSer.getDocumentVolumn(id);
|
// info = changePvolumeToPvolumeInfo(pvolume);
|
// } catch (Exception e) {
|
// throw new VCIError("310102",new String[0]);
|
// }
|
//
|
// return info;
|
// }
|
|
public PvolumeInfo getVolumnByName(String name) throws VCIError {
|
return VolumeCacheProvider.getVolume(name);
|
// Pvolume pvolume = null;
|
// try {
|
// pvolume = pvoSer.getVolumnByName(name);
|
//
|
// return changePvolumeToPvolumeInfo(pvolume);
|
// } catch (Exception e) {
|
// throw new VCIError("310102",new String[0]);
|
// }
|
}
|
|
/**
|
* 修改�?
|
* @param pvoInfo
|
* @param userEntityInfo
|
* @return
|
* @throws VCIError
|
*/
|
public boolean updatePvolume(PvolumeInfo pvoInfo,UserEntityInfo userEntityInfo) throws VCIError{
|
|
UserEntityDelegate.setUserEntityToService(pvoSer, userEntityInfo);
|
Pvolume pvolume = changePvolumeInfoToPvolume(pvoInfo);
|
//UserEntity userEntity = changeUserEntityInfoToUserEntity(userEntityInfo);
|
try{
|
Pvolume pvolumeBefore = pvoSer.getProlumeById(pvolume.getId());
|
boolean success = pvoSer.updatePvolume(pvolume);
|
if (success) {
|
VolumeCatch.setVolume(pvoInfo);
|
}
|
StringBuilder logres = new StringBuilder();
|
logres.append("更新前："+pvolumeBefore.getLogInfo());
|
logres.append("更新后："+pvolume.getLogInfo());
|
LogRecordUtil.writeLog(userEntityInfo, "更新", success ? "修改成功" : "修改失败", logres.toString(), LogType.General,pvolumeBefore.getId());
|
}catch(Exception e){
|
LogRecordUtil.writeLog(userEntityInfo, "更新", "修改失败", e.getMessage(), LogType.General, pvoInfo.id);
|
throw new VCIError("310103", new String[0]);
|
}
|
|
return true;
|
}
|
|
/**
|
* 卷的删除
|
* @param id
|
* @param userEntityInfo
|
* @return
|
* @throws VCIError
|
*/
|
public boolean deletePvolume(String[] ids, UserEntityInfo userEntityInfo) throws VCIError {
|
UserEntityDelegate.setUserEntityToService(pvoSer, userEntityInfo);
|
//UserEntity userEntity = changeUserEntityInfoToUserEntity(userEntityInfo);
|
try {
|
|
List<Pvolume> list = new ArrayList<Pvolume>();
|
for (String id : ids) {
|
Pvolume pvolume = pvoSer.getProlumeById(id);
|
list.add(pvolume);
|
}
|
pvoSer.deletePvolume(ids);
|
//Iterator it = map.();
|
for (Pvolume vol : list) {
|
String volId = vol.getId();
|
VolumeCatch.delVolume(vol.getName());
|
LogRecordUtil.writeLog(userEntityInfo, "删除", "删除成功", volId, LogType.General, vol.getLogInfo());
|
}
|
} catch (Exception e) {
|
throw new VCIError("310104", new String[0]);
|
}
|
return true;
|
}
|
/**
|
* 将其他卷更改为非首选路�?0
|
* @param userEntityInfo
|
* @throws VCIError
|
*/
|
public void updatePvolumeInvalid(UserEntityInfo userEntityInfo)throws VCIError{
|
|
UserEntityDelegate.setUserEntityToService(pvoSer, userEntityInfo);
|
//UserEntity userEntity = changeUserEntityInfoToUserEntity(userEntityInfo);
|
Pvolume pvo = pvoSer.getIsvalidVolumeName();
|
try{
|
|
|
if (pvo.getId() != null && pvo.getId() != ""){
|
pvoSer.updatePvolumeInvalid();
|
StringBuilder logres = new StringBuilder();
|
logres.append("更新前："+pvo.getLogInfo()+"为首选路径！");
|
pvo.setIsvalid(false);
|
logres.append(" 更新后:"+pvo.getLogInfo()+"不为首选路径");
|
LogRecordUtil.writeLog(userEntityInfo, "更新", "修改成功", logres.toString(), LogType.General,pvo.getId());
|
}
|
}catch(Exception e){
|
LogRecordUtil.writeLog(userEntityInfo, "更新", "修改失败", e.getMessage(), LogType.General,pvo.getId());
|
throw new VCIError("310105", new String[0]);
|
}
|
}
|
|
/**
|
* 查看卷是否被引用
|
* @param ids
|
* @return
|
* @throws VCIError
|
*/
|
public int fetchVolumnInfoByIds(String id) throws VCIError{
|
int count = 0;
|
try {
|
count = pvoSer.fetchVolumnInfoByIds(id);
|
} catch (Exception e) {
|
throw new VCIError("310106",new String[0]); //获取卷信息出错，请重新获取�?
|
}
|
|
return count;
|
}
|
|
/**
|
* 检查要删除的卷是否为首选路�?
|
* @param id
|
* @return
|
* @throws VCIError
|
*/
|
public boolean checkDelIsvalid(String id) throws VCIError{
|
boolean res = false;
|
try {
|
res = pvoSer.checkDelIsvalid(id);
|
} catch (Exception e) {
|
throw new VCIError("310106",new String[0]); //获取卷信息出错，请重新获取�?
|
}
|
return res;
|
}
|
|
public PvolumeInfo getIsvalidVolumeName() throws VCIError{
|
PvolumeInfo info = null;
|
try {
|
Pvolume pvolume = pvoSer.getIsvalidVolumeName();
|
info = this.changePvolumeToPvolumeInfo(pvolume);
|
} catch (Exception e) {
|
throw new VCIError("310106",new String[0]); //获取卷信息出错，请重新获取�?
|
}
|
return info;
|
}
|
/**
|
* 返回一个在服务器端有效的卷对象
|
* <p>此卷对象只有卷路径值，其它值均为空，其卷路径值是 ${user.dir}\attachments\</p>
|
* <p>其中${user.dir}将用System.getProperty("user.dir")的值替�?/p>
|
* <p>Description: </p>
|
* @author xchao
|
* @time 2013-8-6
|
* @return
|
* @throws VCIError
|
*/
|
public PvolumeInfo getIsvalidVolumeNameInServerEnv() throws VCIError{
|
PvolumeInfo info = null;
|
try {
|
Pvolume pvolume = pvoSer.getIsvalidVolumeNameInServerEnv();
|
info = this.changePvolumeToPvolumeInfo(pvolume);
|
} catch (Exception e) {
|
throw new VCIError("310106",new String[0]); //获取卷信息出错，请重新获取�?
|
}
|
return info;
|
}
|
|
/***
|
* 卷对象从corba对象到业务对�?
|
* @param pvolumeInfo
|
* @return
|
*/
|
public Pvolume changePvolumeInfoToPvolume (PvolumeInfo pvolumeInfo) {
|
Pvolume pvolume = new Pvolume();
|
pvolume.setId(pvolumeInfo.id == "" ? null : pvolumeInfo.id);
|
pvolume.setName(pvolumeInfo.name == "" ? null : pvolumeInfo.name);
|
pvolume.setService(pvolumeInfo.service == "" ? null : pvolumeInfo.service);
|
pvolume.setHost(pvolumeInfo.host == "" ? null : pvolumeInfo.host);
|
pvolume.setType(pvolumeInfo.type == 0 ? 0 : 1 );
|
pvolume.setPath(pvolumeInfo.path == "" ? null : pvolumeInfo.path);
|
pvolume.setIsvalid(pvolumeInfo.isvalid);
|
return pvolume;
|
}
|
|
private PvolumeInfo changePvolumeToPvolumeInfo(Pvolume pvolume) {
|
PvolumeInfo pvoInfo = new PvolumeInfo();
|
pvoInfo.id = pvolume.getId() == null ? "" : pvolume.getId();
|
pvoInfo.name = pvolume.getName() == null ? "" : pvolume.getName();
|
pvoInfo.service = pvolume.getService() == null ? "" : pvolume.getService();
|
pvoInfo.host = pvolume.getHost() == null ? "" : pvolume.getHost();
|
pvoInfo.type = (short)(pvolume.getType() == 0 ? 0 : 1);
|
pvoInfo.path = pvolume.getPath() == null ? "" : pvolume.getPath();
|
pvoInfo.isvalid = pvolume.getIsvalid();
|
return pvoInfo;
|
}
|
|
public UserEntity changeUserEntityInfoToUserEntity(UserEntityInfo info){
|
UserEntity entity = new UserEntity();
|
entity.setModule(info.modules);
|
entity.setIp(info.ip);
|
entity.setUserName(info.userName);
|
return entity;
|
}
|
|
// public void createFileCabinet(String levelDirectory){
|
// String temp1Child = null;
|
// for (int level1 = 0; level1 < 256; level1++) {
|
// String temp1 = TransformDelegate.sl(16, level1);
|
// if (temp1.length() <= 1) {
|
// temp1 = "0" + temp1;
|
//
|
// }
|
// temp1 = levelDirectory + "/" + temp1;
|
// createDir(temp1);
|
// // 创建二级子目�?
|
// for (int level1Child = 0; level1Child < 100; level1Child++) {
|
// if (level1Child < 10) {
|
// temp1Child = "0" + level1Child;
|
// } else {
|
// temp1Child = level1Child + "";
|
// }
|
// temp1Child = temp1 + "/" + temp1Child;
|
// createDir(temp1Child);
|
// }
|
// }
|
// }
|
|
/**
|
* 创建目录
|
* @param destDirName 目标目录�?
|
* @return 目录创建成功返回true，否则返回false
|
*/
|
public boolean createDir(String destDirName) {
|
File dir = new File(destDirName);
|
if(dir.exists()) {
|
// System.out.println("创建目录" + destDirName + "失败，目标目录已存在�?);
|
return false;
|
}
|
if(!destDirName.endsWith(File.separator))
|
destDirName = destDirName + File.separator;
|
// 创建单个目录
|
if(dir.mkdirs()) {
|
// System.out.println("创建目录" + destDirName + "成功�?);
|
return true;
|
} else {
|
// System.out.println("创建目录" + destDirName + "成功�?);
|
return false;
|
}
|
}
|
|
}
|
