package com.vci.server.workflow.server.template;
|
|
import java.sql.Connection;
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.sql.Statement;
|
import java.util.List;
|
|
import org.hibernate.HibernateException;
|
import org.hibernate.Query;
|
import org.hibernate.Session;
|
import org.jbpm.api.ProcessEngine;
|
import org.jbpm.api.ProcessInstance;
|
import org.jbpm.api.history.HistoryProcessInstance;
|
|
import com.vci.common.log.ServerWithLog4j;
|
import com.vci.common.objects.UserEntity;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.workflow.data.FlowInstanceInfo;
|
import com.vci.server.base.persistence.dao.BaseService;
|
import com.vci.server.base.persistence.dao.HibernateCallback;
|
import com.vci.server.base.persistence.dao.HibernateSessionFactory;
|
import com.vci.server.base.persistence.dao.HibernateTemplate;
|
import com.vci.server.workflow.dao.FlowInstanceDaoImpl;
|
import com.vci.server.workflow.dao.ProcessCategoryDaoImpl;
|
import com.vci.server.workflow.objects.FlowInstance;
|
import com.vci.server.workflow.objects.ProcessCategory;
|
import com.vci.server.workflow.server.JbpmEngine;
|
|
public class ProcessCustomService extends BaseService {
|
|
public ProcessCustomService(UserEntity userEntity) {
|
super(userEntity);
|
}
|
|
public ProcessCustomService() {
|
}
|
|
public boolean saveProcessCategory(final ProcessCategory object){
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
ProcessCategoryDaoImpl impl = new ProcessCategoryDaoImpl();
|
object.setUserEntity(userEntity);
|
impl.saveOrUpdate(object);
|
return true;
|
}
|
});
|
}
|
|
@SuppressWarnings("unchecked")
|
public List<ProcessCategory> getProcessCategories(final String parentId){
|
// try {
|
// String[] curCandidates = new ProcessTemplateService().getCurCandidates("", "", "");
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
return (List<ProcessCategory>)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
ProcessCategoryDaoImpl impl = new ProcessCategoryDaoImpl();
|
String hql = "from ProcessCategory t where t.parentId = ?";
|
return impl.createQueryList(hql, new Object[]{parentId});
|
}
|
});
|
}
|
/**
|
* 模板分类定义分页
|
* @param parentId
|
* @param pageSize
|
* @param pageIndex
|
* @return
|
*/
|
@SuppressWarnings("unchecked")
|
public List<ProcessCategory> getProcessCategoriesByPage(final String parentId,final int pageSize,final int pageIndex){
|
return (List<ProcessCategory>)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
int start = 0;
|
if(pageIndex<0){
|
start=1;
|
}else{
|
start = pageIndex;
|
}
|
ProcessCategoryDaoImpl impl = new ProcessCategoryDaoImpl();
|
String hql = "from ProcessCategory t where t.parentId = ?";
|
return impl.findEntites(hql,(start-1)*pageSize ,pageSize,new Object[]{parentId});
|
}
|
});
|
}
|
public boolean updateProcessCategory(final ProcessCategory object){
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
ProcessCategoryDaoImpl impl = new ProcessCategoryDaoImpl();
|
object.setUserEntity(userEntity);
|
ProcessCategory objGet = impl.getById(object.getId());
|
if(objGet == null){
|
impl.saveOrUpdate(object);
|
}else{
|
objGet.setUserEntity(userEntity);
|
objGet.setId(object.getId());
|
objGet.setParentId(object.getParentId());
|
objGet.setName(object.getName());
|
objGet.setDesc(object.getDesc());
|
objGet.setIcon(object.getIcon());
|
objGet.setModifyTime(object.getModifyTime());
|
objGet.setModifyUser(object.getModifyUser());
|
objGet.setModifyRole(object.getModifyRole());
|
objGet.setModifyOrg(object.getModifyOrg());
|
impl.saveOrUpdate(objGet);
|
}
|
return true;
|
}
|
});
|
}
|
|
public boolean existProcessCategory(String id, String name) {
|
Session session = null;
|
try {
|
session = HibernateSessionFactory.getSession();
|
StringBuilder hql = new StringBuilder("select count(*) from ProcessCategory p where p.name = :name");
|
boolean hasIdValue = (id != null && id.trim().length() > 0);
|
if(hasIdValue){
|
hql.append(" and p.id <> :id");
|
}
|
Query query = session.createQuery(hql.toString());
|
query.setString("name", name);
|
if(hasIdValue){
|
query.setString("id", id);
|
}
|
Long count = (Long)query.uniqueResult();
|
if(count != null && ((Long)count).longValue() > 0){
|
return true;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
ServerWithLog4j.logger.error(e);
|
throw new RuntimeException(e);
|
}
|
return false;
|
}
|
|
public boolean deleteProcessCategory(final String id) {
|
return (Boolean)new HibernateTemplate().run(new HibernateCallback(){
|
public Object execute() throws HibernateException {
|
ProcessCategoryDaoImpl impl = new ProcessCategoryDaoImpl();
|
String hql = "delete ProcessCategory p where p.id = ?";
|
// impl.deleteQueryObject(hql, new String[]{id}, userEntity);
|
impl.createQuery(hql, new String[]{id});
|
return true;
|
}
|
});
|
}
|
|
/**
|
* 移动流程定义模板
|
* @param deploymentId 流程部署id
|
* @param categoryId 流程分类Id
|
* @return
|
*/
|
public boolean moveDefinition( String deploymentId , String categoryId){
|
Session session = HibernateSessionFactory.getSession();
|
try {
|
String sql = "update PLPROCESSTEMPLATE a set a.plcategoryoid = '"+categoryId+"' where a.pljbpmdeploymentid = '"+deploymentId+"'";
|
session.createSQLQuery(sql).executeUpdate();
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
return false;
|
}
|
return true;
|
}
|
|
public boolean deleteProcessDefinition(final String deployId, final String pdId) throws VCIError {
|
ProcessEngine processEngine = JbpmEngine.getProcessEngine();
|
|
// StringBuilder sql = new StringBuilder();
|
// sql.append("select count(*) from PLRMTEMPLATEPROCESS where PLJBPMDEPLOYMENTID = ?");
|
|
Session session = HibernateSessionFactory.getSession();
|
String messCode = "";
|
//Connection conn = null;
|
//PreparedStatement pstmt = null;
|
//ResultSet rs = null;
|
//ConnectionProvider cp = ((SessionFactoryImplementor) session.getSessionFactory()).getConnectionProvider();
|
try {
|
// Query query = session.createSQLQuery(sql.toString());
|
// query.setString(0, deployId);
|
// int count = Integer.parseInt( query.list().get(0).toString() );
|
// if(count > 0) {
|
// messCode = "410113";
|
// throw new VCIError("410113", new String[] {});
|
// }
|
|
Query query;
|
|
List<ProcessInstance> pds = processEngine.getExecutionService().createProcessInstanceQuery().processDefinitionId(pdId).list();
|
if(pds.size() > 0) {
|
messCode = "410114";
|
throw new VCIError("410114", new String[] {});
|
}
|
List<HistoryProcessInstance> historyPds = processEngine.getHistoryService().createHistoryProcessInstanceQuery().processDefinitionId(pdId).list();
|
if(historyPds.size() > 0) {
|
messCode = "410114";
|
throw new VCIError("410114", new String[] {});
|
}
|
|
|
//删除任务描述信息表
|
String deleteTaskDescSql = "delete from pltaskdesc a where a.pljbpmdeploymentid = ?";
|
query = session.createSQLQuery(deleteTaskDescSql);
|
query.setString(0, deployId);
|
query.executeUpdate();
|
|
//删除PLPROCESSTEMPLATE中的数据
|
String deleteSql = "delete from PLPROCESSTEMPLATE WHERE PLJBPMDEPLOYMENTID = ?";
|
query = session.createSQLQuery(deleteSql);
|
query.setString(0,deployId);
|
query.executeUpdate();
|
|
//删除PLPROCESSTASKPROPERTY中的数据
|
deleteSql = "delete from PLPROCESSTASKPROPERTY p where p.PLTASKPROPERTY in (select t.PLTASKTYPEPROPERTY from PLPROCESSTASK t WHERE PLTASKTYPEPROPERTY is not null and t.PLJBPMDEPLOYMENTID = ?)";
|
query = session.createSQLQuery(deleteSql);
|
query.setString(0,deployId);
|
query.executeUpdate();
|
|
//删除PLPROCESSTASK中的数据
|
deleteSql = "delete from PLPROCESSTASK WHERE PLJBPMDEPLOYMENTID = ?";
|
query = session.createSQLQuery(deleteSql);
|
query.setString(0,deployId);
|
query.executeUpdate();
|
|
processEngine.getRepositoryService().deleteDeploymentCascade(deployId);//删除流程定义
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
throw new VCIError(messCode, new String[] {});
|
} finally {
|
}
|
|
return true;
|
}
|
|
public FlowInstanceInfo getFlowInstanceInfo(String executionid) {
|
FlowInstanceDaoImpl impl = new FlowInstanceDaoImpl();
|
String hql = "from FlowInstance t where t.executionid = ?";
|
FlowInstance flowInstance = (FlowInstance)impl.findEntity(hql, new Object[]{executionid});
|
|
FlowInstanceInfo flowInstanceInfo = new FlowInstanceInfo();
|
flowInstanceInfo.id = flowInstance.getId() == null ? "" : flowInstance.getId();
|
flowInstanceInfo.executionid = flowInstance.getExecutionid() == null ? "" : flowInstance.getExecutionid();
|
flowInstanceInfo.applicant = flowInstance.getApplicant() == null ? "" : flowInstance.getApplicant();
|
flowInstanceInfo.creator = flowInstance.getCreator() == null ? "" : flowInstance.getCreator();
|
flowInstanceInfo.templatePuid = flowInstance.getTemplatePuid() == null ? "" : flowInstance.getTemplatePuid();
|
flowInstanceInfo.templateName = flowInstance.getTemplateName() == null ? "" : flowInstance.getTemplateName();
|
flowInstanceInfo.clsfOid = flowInstance.getClsfOid() == null ? "" : flowInstance.getClsfOid();
|
flowInstanceInfo.tableName = flowInstance.getTableName() == null ? "" : flowInstance.getTableName();
|
flowInstanceInfo.desc = flowInstance.getDesc() == null ? "" : flowInstance.getDesc();
|
flowInstanceInfo.processType = flowInstance.getProcessType() == null ? "" : flowInstance.getProcessType();
|
flowInstanceInfo.taskType = flowInstance.getTaskType() == null ? "" : flowInstance.getTaskType();
|
|
return flowInstanceInfo;
|
}
|
|
private static void close(Connection conn) {
|
if (conn != null) {
|
try {
|
conn.close();
|
} catch (SQLException e) {
|
}
|
}
|
}
|
|
private static void close(Statement stmt) {
|
if (stmt != null) {
|
try {
|
stmt.close();
|
} catch (SQLException e) {
|
}
|
}
|
}
|
|
private static void close(ResultSet rs) {
|
if (rs != null) {
|
try {
|
rs.close();
|
} catch (SQLException e) {
|
}
|
}
|
}
|
|
}
|
