package com.vci.server.framework.volume.service;
|
|
import java.io.File;
|
import java.sql.Connection;
|
import java.sql.PreparedStatement;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.type.Type;
|
|
import com.vci.server.base.persistence.dao.BaseService;
|
import com.vci.server.base.persistence.dao.HibernateCallback;
|
import com.vci.server.base.persistence.dao.HibernateCallbackExt;
|
import com.vci.server.base.persistence.dao.HibernateTemplate;
|
import com.vci.server.framework.volume.dao.Pvolume;
|
import com.vci.server.framework.volume.dao.PvolumeDaoImp;
|
|
public class PvolumeService extends BaseService {
|
|
/**
|
* 添加 卷
|
* @param pvolume
|
* @return
|
*/
|
public boolean savePvolume(final Pvolume pvolume){
|
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
pvolume.setUserEntity(userEntity);
|
impl.save(pvolume);
|
return true;
|
}
|
});
|
}
|
|
/**
|
* 读取所有 卷
|
* @return
|
*/
|
/*public List getRoleList(){
|
return (List)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hsql = "from Pvolume p order by p.name";
|
String sql = getPageSql(hsql);
|
return impl.findEntities(sql);
|
}
|
});
|
|
}*/
|
//读取所有的卷条数
|
// public List getAllPvolumes() {
|
// return VolumeCatch.getInstance().getAllPvolumes();
|
// }
|
|
// @SuppressWarnings("unchecked")
|
// private List<Pvolume> getPvolumes() {
|
// return (List<Pvolume>) new HibernateTemplate().run(new HibernateCallback() {
|
// public Object execute() throws HibernateException {
|
// PvolumeDaoImp impl = new PvolumeDaoImp();
|
// String hsql = "from Pvolume p order by p.name";
|
// return impl.findEntities(hsql);
|
// }
|
// });
|
// }
|
|
//分页读取数据
|
|
public List getPvolumesPage( final int pageIndex, final int pageSize){
|
return (List<?>)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hsql = "select * from PLVOLUME p order by p.plname";
|
String sql = getPageSQL(hsql,pageSize,pageIndex);
|
Object [] o = {};
|
return impl.findEntites(sql,o, "", Pvolume.class);
|
}
|
});
|
}
|
// public Pvolume getDocumentVolumn(final String id) {
|
// return (Pvolume)new HibernateTemplate().run(new HibernateCallback() {
|
// public Object execute() throws HibernateException {
|
// PvolumeDaoImp impl = new PvolumeDaoImp();
|
// String sql = "select {p.*} from pvolume p inner join pedmobj pedm on p.puid = pedm.pvolumeid where pedm.puid = ?";
|
// String[] values = new String[1];
|
// values[0] = id;
|
// List<?> list = impl.findEntites(sql, values, "p", Pvolume.class);
|
// int size = list.size();
|
// if (size == 0) {
|
// return null;
|
// } else {
|
// return list.get(0);
|
// }
|
// }
|
// });
|
// }
|
|
// public Pvolume getVolumnByName(final String name) {
|
// return VolumeCatch.getInstance().getVolumnByName(name);
|
//
|
//// return (Pvolume)new HibernateTemplate().run(new HibernateCallback() {
|
//// public Object execute() throws HibernateException {
|
//// PvolumeDaoImp impl = new PvolumeDaoImp();
|
//// String sql = "select * from PLVOLUME p where p.plname = ?";
|
//// String[] values = new String[1];
|
//// values[0] = name;
|
////
|
//// List<Pvolume> list = impl.findEntites(sql, values, "", Pvolume.class);
|
//// int size = list.size();
|
//// if (size == 0) {
|
//// return null;
|
//// } else {
|
//// return list.get(0);
|
//// }
|
//// }
|
//// });
|
// }
|
|
/**
|
* 修改卷
|
* @param pvolume
|
*/
|
public boolean updatePvolume(final Pvolume pvolume){
|
//VolumeCatch.getInstance().clearCatch();
|
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
Pvolume pvo = impl.getById(pvolume.getId());
|
if (pvo == null) {
|
pvolume.setUserEntity(userEntity);
|
impl.save(pvolume);
|
return true;
|
} else {
|
pvo.setService(pvolume.getService());
|
pvo.setHost(pvolume.getHost());
|
pvo.setName(pvolume.getName());
|
pvo.setPath(pvolume.getPath());
|
pvo.setType(pvolume.getType());
|
pvo.setIsvalid(pvolume.getIsvalid());
|
pvo.setUserEntity(userEntity);
|
impl.saveOrUpdate(pvo);
|
return true;
|
}
|
}
|
});
|
}
|
|
/**
|
* 卷的删除
|
* @param id
|
* @return
|
*/
|
public boolean deletePvolume(final String[] ids ){
|
//VolumeCatch.getInstance().clearCatch();
|
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hql = "delete Pvolume p where p.id in (";
|
int len = ids.length;
|
for (int i = 0; i < len; i++) {
|
hql += "?";
|
if (i != len - 1) {
|
hql += ",";
|
}
|
}
|
hql += ")";
|
impl.deleteQueryObject(hql, ids, userEntity);
|
return true;
|
}
|
});
|
}
|
|
public void updatePvolumeInvalid(){
|
new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hql = "update Pvolume p set p.isvalid = 0 where p.isvalid = 1";
|
impl.createQuery(hql);
|
return null;
|
}});
|
}
|
|
/**
|
* 查看卷是否被引用
|
* @return
|
*/
|
public int fetchVolumnInfoByIds(final String id ){
|
return (Integer)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
int count = 0;
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hsql = " select count(*) from plvolumefile pfile where pfile.PLVOLUMEOID = '"+id+"'";
|
List<?> list = new ArrayList();
|
Object[] values = new Object[0];
|
Map<String,Type> map = new HashMap<String,Type>();
|
list = impl.findEntitesBySQL(hsql, values,map);
|
if (list != null){
|
count = Integer.valueOf(String.valueOf(list.get(0))).intValue();
|
}
|
return count;
|
}
|
});
|
}
|
/**
|
* 检查要删除的卷是否为首选路径
|
* @param id
|
* @return
|
*/
|
public boolean checkDelIsvalid(final String id ){
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
boolean res = false;
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hsql = "select p.* from plvolume p where p.ploid = '"+id+"' and p.plisvalid = 1";
|
List<?> list = new ArrayList();
|
Object[] values = new Object[0];
|
Map<String,Type> map = new HashMap<String,Type>();
|
list = impl.findEntitesBySQL(hsql, values,map);
|
if (list.size() != 0){
|
res = true;
|
}else {
|
res = false;
|
}
|
return res;
|
}
|
});
|
}
|
|
public Pvolume getIsvalidVolumeName(){
|
return (Pvolume)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
String volumepath = "";
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
Pvolume pvolume = new Pvolume();
|
List<?> list = new ArrayList();
|
String sql = " from Pvolume p where p.isvalid = 1";
|
|
list = impl.findEntities(sql);
|
if (list != null && list.size() > 0){
|
pvolume = (Pvolume)list.get(0);
|
}
|
return pvolume;
|
}
|
});
|
|
}
|
/**
|
* 返回一个在服务器端有效的卷对象
|
* <p>此卷对象只有卷路径值，其它值均为空，其卷路径值是 ${user.dir}\attachments\</p>
|
* <p>其中${user.dir}将用System.getProperty("user.dir")的值替换</p>
|
* <p>Description: </p>
|
* @author xchao
|
* @time 2013-8-6
|
* @return
|
*/
|
public Pvolume getIsvalidVolumeNameInServerEnv(){
|
String userDir = System.getProperty("user.dir");
|
String fileSeparator = System.getProperty("file.separator");
|
Pvolume res = new Pvolume();
|
res.setPath(userDir + fileSeparator + "attachments" + fileSeparator);
|
File f = new File(res.getPath());
|
if(!f.exists()){
|
f.mkdirs();
|
}
|
return res;
|
}
|
public Pvolume getProlumeById(final String id){
|
return (Pvolume)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
return impl.getById(id);
|
}
|
});
|
|
}
|
|
//分页查询
|
public String getPageSQL(String sql, int pageSize, int pageIndex ){
|
if(pageIndex <= 0){
|
pageIndex = 1;
|
}
|
int startRownum = (pageIndex - 1) * pageSize + 1;
|
int endRownum = pageIndex * pageSize;
|
String partionSql = "" +
|
"SELECT * FROM( " +
|
" SELECT A.*,ROWNUM RN FROM( " +
|
sql +
|
" ) A " +
|
") WHERE RN <= " + String.valueOf(endRownum) + " AND RN >= " + String.valueOf(startRownum);
|
return partionSql;
|
}
|
|
public boolean savePvolumUser(final String pvolumeId , final String[] userIds ){
|
return (Boolean)new HibernateTemplate().runExt(new HibernateCallbackExt() {
|
public Object execute(Connection conn) throws HibernateException,
|
SQLException {
|
|
String sql = "delete pluserpvolume up where up.plpvolumeuid = ? ";
|
PreparedStatement pstmt = null;
|
PreparedStatement pstmt1 = null;
|
try {
|
pstmt = conn.prepareStatement(sql);
|
pstmt.setString(1, pvolumeId);
|
pstmt.execute();
|
} catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt != null){
|
pstmt.close();
|
}
|
}
|
try {
|
for (int i = 0 ; i < userIds.length ; i ++){
|
String hql = "insert into pluserpvolume values (? , ?)";
|
pstmt1 = conn.prepareStatement(hql);
|
pstmt1.setString(1, userIds[i]);
|
pstmt1.setString(2, pvolumeId);
|
pstmt1.execute();
|
}
|
}catch (SQLException e1) {
|
e1.printStackTrace();
|
} finally {
|
if (pstmt1 != null){
|
pstmt1.close();
|
}
|
}
|
return true;
|
}
|
});
|
}
|
|
public Pvolume selectPvolume(final String id) {
|
return (Pvolume)new HibernateTemplate().run(new HibernateCallback() {
|
public Object execute() throws HibernateException {
|
PvolumeDaoImp impl = new PvolumeDaoImp();
|
String hsql = "from Pvolume plvolume where plvolume.id = :id";
|
return impl.findEntity(hsql, "id", id);
|
}
|
});
|
}
|
|
}
|
