package com.vci.server.workflow.server.event;
|
|
import java.io.BufferedReader;
|
import java.io.ByteArrayInputStream;
|
import java.io.ByteArrayOutputStream;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.lang.reflect.InvocationTargetException;
|
import java.sql.Connection;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
import org.dom4j.Attribute;
|
import org.dom4j.Document;
|
import org.dom4j.Element;
|
import org.dom4j.io.SAXReader;
|
import org.jbpm.api.ProcessEngine;
|
import org.jbpm.api.RepositoryService;
|
import org.jbpm.api.TaskService;
|
import org.jbpm.api.cmd.Command;
|
import org.jbpm.api.cmd.Environment;
|
import org.jbpm.api.task.Task;
|
|
import com.vci.common.resource.CommonProperties;
|
import com.vci.corba.common.VCIError;
|
import com.vci.server.base.persistence.dao.HibernateTemplate;
|
import com.vci.server.workflow.common.FlowConstants;
|
import com.vci.server.workflow.dao.PlflowapproveopinionDaoImpl;
|
import com.vci.server.workflow.server.JbpmEngine;
|
import com.vci.server.workflow.server.interfaces.PLMWorkItemInterface;
|
|
public class Sign implements Command<Boolean>{
|
|
private static final long serialVersionUID = 1L;
|
public static String VAR_SIGN="sign";
|
|
/**
|
* 会签的处理意见
|
*/
|
private static final String VAR_OUTCOME_IN_COUNTER = "outComeInCounter";
|
|
/**
|
* 会签结果
|
*/
|
public static final String VAR_SIGN_RESULT = "resultInCounter";
|
private String outcom;
|
private String parentTaskId;
|
private Task parentTask;
|
private Task joinTask;
|
String pid;
|
String deploymentId;
|
private String userName = "";
|
|
public Sign(String parentTaskId,Task joinTask,String outcom,String userName,String deploymentId){
|
this.parentTaskId=parentTaskId;
|
this.outcom=outcom;
|
this.userName=userName;
|
this.joinTask=joinTask;
|
this.deploymentId=deploymentId;
|
}
|
|
public String getPid(){
|
return pid;
|
}
|
|
|
private static byte[] InputStreamToByte(InputStream is) throws IOException {
|
ByteArrayOutputStream bytestream = new ByteArrayOutputStream();
|
int ch;
|
while ((ch = is.read()) != -1) {
|
bytestream.write(ch);
|
}
|
byte imgdata[] = bytestream.toByteArray();
|
bytestream.close();
|
return imgdata;
|
}
|
public byte[] getProcessResource(String jbpmDeploymentId, String resourceType) throws Exception {
|
ProcessEngine processEngine = JbpmEngine.getProcessEngine();
|
RepositoryService repositoryService = processEngine.getRepositoryService();
|
Set<String> resourceNames = repositoryService.getResourceNames(jbpmDeploymentId);
|
for (String resourceName : resourceNames) {
|
if (resourceName.endsWith(resourceType)) {
|
InputStream is = repositoryService.getResourceAsStream(jbpmDeploymentId, resourceName);
|
byte[] result = InputStreamToByte(is);
|
return result;
|
}
|
}
|
return new byte[0];
|
}
|
|
/**
|
* 获取会签的比例
|
* @return 没有设置的时候返回null
|
* @throws Exception
|
*/
|
private Integer getVotePercent(String parentTakName) throws Exception{
|
byte[] processXml;
|
InputStream in = null;
|
try {
|
processXml = getProcessResource(this.deploymentId, ".xml");
|
in = new ByteArrayInputStream(processXml);
|
BufferedReader reader = new BufferedReader(new InputStreamReader(in, "utf-8"));
|
|
SAXReader saxr = new SAXReader();
|
Document doc = saxr.read(reader);
|
Element root = doc.getRootElement();
|
|
for (Iterator<?> a = root.elementIterator(); a.hasNext();) {
|
Element element = (Element) a.next();
|
String cellType = element.getName();
|
String cellName = element.attributeValue(FlowConstants.XMLNAME);
|
if (FlowConstants.XMLTASK.equals(cellType) && cellName.equals(parentTakName)) {// 任务节点
|
Attribute at = element.attribute(FlowConstants.SIGN_VOTE_PRCENT);
|
if(at!=null){
|
return Integer.valueOf(at.getValue());
|
}
|
break;
|
}
|
}
|
}catch(Throwable w){
|
w.printStackTrace();
|
throw new Exception("获取流程模板中配置的会签比例出错了，请联系管理员检查");
|
|
}finally{
|
if (in != null)
|
in.close();
|
}
|
return null;
|
}
|
|
public Boolean execute(Environment environment) throws Exception {
|
TaskService taskService=environment.get(TaskService.class);
|
parentTask=taskService.getTask(parentTaskId);
|
pid=parentTask.getExecutionId();
|
|
String sign=(String)taskService.getVariable(joinTask.getId(), VAR_SIGN);
|
String delPartSql = "update jbpm4_task set ASSIGNEE_ = '' where dbid_='"+parentTaskId+"'";
|
Connection conn = new HibernateTemplate().getSessionConnection();
|
new PlflowapproveopinionDaoImpl().deleteEntityBySQL(conn, delPartSql, new String[]{});
|
Integer vote = getVotePercent(parentTask.getActivityName());
|
if(vote == null || vote == 0){
|
if(sign!=null&&sign.equals("不同意")){
|
//Map<String, Object> map = new HashMap<String, Object>();
|
//map.put("OUTCOME", outcom);
|
taskService.completeTask(joinTask.getId());
|
List<Task> subTasks = taskService.getSubTasks(parentTaskId);
|
for(Task subTask : subTasks){
|
taskService.completeTask(subTask.getId());
|
}
|
for(Task s : subTasks){
|
deleteForkTask(s.getExecutionId());
|
}
|
return true;
|
} else if(sign!=null&&sign.equals("同意")){
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("OUTCOME", outcom);
|
taskService.setVariables(joinTask.getId(),map);
|
System.out.println("joinTask.completeTask开始！");
|
taskService.completeTask(joinTask.getId());
|
System.out.println("joinTask.completeTask开始！");
|
//将当前的用户的协作关系清掉 避免待办任务里继续出现
|
String delSql = "delete jbpm4_participation where task_='"+parentTaskId+"' and userid_=(select t.assignee_ from jbpm4_task t where t.dbid_='"+joinTask.getId()+"' )";
|
new PlflowapproveopinionDaoImpl().deleteEntityBySQL(conn, delSql, new String[]{});
|
}
|
String updateSupperTaskSql = "update jbpm4_hist_task t set t.supertask_ = '" + parentTaskId + "' where execution_ ='" + joinTask.getExecutionId() + "'";
|
new PlflowapproveopinionDaoImpl().deleteEntityBySQL(conn, updateSupperTaskSql, new String[]{});
|
if(taskService.getSubTasks(parentTaskId).size()==0){
|
return true;
|
}
|
return false;
|
}else{
|
//设置了会签的比例的，我们要等到全部都执行完成了后判断
|
taskService.completeTask(joinTask.getId());
|
//modify by weidy@2022-05-06
|
//执行任务后，子任务的历史上没有supertask_的值，所以这里手动加一下
|
String updateSupperTaskSql = "update jbpm4_hist_task t set t.supertask_ = '" + parentTaskId + "' where execution_ ='" + joinTask.getExecutionId() + "'";
|
new PlflowapproveopinionDaoImpl().deleteEntityBySQL(conn, updateSupperTaskSql, new String[]{});
|
String delSql = "delete jbpm4_participation where task_='"+parentTaskId+"' and userid_=(select t.assignee_ from jbpm4_task t where t.dbid_='"+joinTask.getId()+"' )";
|
new PlflowapproveopinionDaoImpl().deleteEntityBySQL(conn, delSql, new String[]{});
|
List<String> outcomeList = (List<String>)taskService.getVariable(parentTask.getId(), VAR_OUTCOME_IN_COUNTER);
|
if(outcomeList == null){
|
outcomeList = new ArrayList<String>();
|
}
|
outcomeList.add(sign);
|
Map<String,Object> varMap = new HashMap<String, Object>();
|
varMap.put(VAR_OUTCOME_IN_COUNTER,outcomeList);
|
taskService.setVariables(parentTask.getId(), varMap);
|
if(taskService.getSubTasks(parentTaskId).size()==0){
|
//已经完成了，我们需要判断是同意还是不同意
|
//必须要清除，否则被退回后再执行到这里的时候，会把以前结果也读取到了
|
varMap.put(VAR_OUTCOME_IN_COUNTER,new ArrayList<String>());
|
taskService.setVariables(parentTask.getId(), varMap);
|
int allowCount = 0;
|
for(int i = 0 ; i < outcomeList.size(); i++){
|
if(!outcomeList.get(i).equalsIgnoreCase("不同意")){
|
allowCount ++;
|
}
|
}
|
boolean passFlag = ((float)allowCount/(float)outcomeList.size())*100>=vote;
|
varMap.clear();
|
varMap.put(VAR_SIGN_RESULT, passFlag?"同意":"不同意");
|
taskService.setVariables(parentTask.getId(), varMap);
|
return true;
|
}
|
return false;
|
|
}
|
}
|
|
private void deleteForkTask(String excutionid) throws VCIError, IllegalArgumentException, IllegalAccessException, InvocationTargetException, SecurityException, NoSuchMethodException, ClassNotFoundException, InstantiationException {
|
String workitemClass = CommonProperties.getStringProperty("workflow.plmworkitem");
|
if(workitemClass!=null&&!"".equals(workitemClass)){
|
PLMWorkItemInterface pwService = (PLMWorkItemInterface) (Class.forName(workitemClass).newInstance());
|
pwService.deleteForkTask(excutionid);
|
}
|
}
|
}
|
