activiti并发多实例子流程任务处理详解编程语言

SELECT T.SERIAL_NUMBER, 
(SELECT Q.DO_USERNAME FROM  ACT_HI_TASKREMARK Q WHERE Q.P_ID=T.PROC_INST_ID_ AND Q.TASK_ID IS NULL AND ROWNUM <2 ) AS  CREAT_USER, 
T.ID_ AS ID, 
T.PROC_INST_ID_ AS PID, 
T.EXECUTION_ID_ AS EID, 
P.NAME_ AS TASKTYPE, 
T.NAME_ AS FLOWNAME, 
TO_CHAR(T.CREATE_TIME_, 'YYYY-MM-DD HH24:MI:SS') AS CREATE_TIME, 
TIMEHEADER((REPLACE(SUBSTR(TO_CHAR(NUMTODSINTERVAL((SELECT CEIL((TO_DATE(TO_CHAR(SYSDATE, 'YYYY-MM-DD HH24:MI:SS'),'YYYY-MM-DD HH24:MI:SS') - 
TO_DATE(TO_CHAR(T.CREATE_TIME_, 'YYYY-MM-DD HH24:MI:SS'), 
'YYYY-MM-DD HH24:MI:SS')) * 24 * 60) 
FROM DUAL),'MINUTE')),'12','5'),':','小时')||'分' )) STAY_TIME, 
DECODE((SELECT V.TEXT_ FROM ACT_RU_VARIABLE V WHERE V.PROC_INST_ID_ = T.PROC_INST_ID_ AND V.NAME_ = 'IS_URGENCY'),'2','<FONT COLOR="RED">【紧急】</FONT>','3','<FONT COLOR="PURPLE">【特急】</FONT>','<FONT COLOR="GREEN">【常规】</FONT>')||(SELECT V.TEXT_ FROM ACT_RU_VARIABLE V WHERE V.PROC_INST_ID_ = T.PROC_INST_ID_ AND V.NAME_ = 'TASKNAME') TASKNAME, 
(SELECT V.TEXT_ FROM ACT_RU_VARIABLE V WHERE V.PROC_INST_ID_ = T.PROC_INST_ID_ AND V.NAME_ = 'DEADLINE') DEADLINE, 
(SELECT COUNT(1) FROM  CT_PURSUE C WHERE C.TASKID = T.ID_) URGE_TIME 
FROM ACT_RU_TASK T, ACT_RU_IDENTITYLINK F, ACT_RE_PROCDEF P 
WHERE T.ID_ = F.TASK_ID_(+) 
AND T.PROC_DEF_ID_ = P.ID_ 
AND ('当前登录用户名' IN (SELECT U.USERNAME FROM PERM_ROLE_FUNC R, PERM_USERS U WHERE U.ROLE LIKE '%' || R.ROLEID || '%' AND R.FUNCCODE IN (F.GROUP_ID_) GROUP BY U.USERNAME)   
OR '科室code' IN (T.DESCRIPTION_)) 
AND 1=1 
AND 1=1  
AND (NVL(T.DESCRIPTION_,'1')='1' OR T.DESCRIPTION_ ='科室code')

 //工作流 
String targetFilePath =  ServletActionContext.getRequest().getSession().getServletContext() 
.getRealPath("/") + IcmisModels.TEMP_FOLD+ "/";//获取项目临时文件目录 
//得到当前系统用户对象 
UserView u = (UserView) ServletActionContext.getRequest().getSession().getAttribute(FrameConstant.SESSION_USERVIEW); 
Map<String, Object> map=new HashMap<String, Object>();//要在启动流程中存的流程变量map 
map.put(WorkFlowConstant.START_USER, u.getUsername());//设置发起人 
List<String> candiateUserList=new ArrayList<String>();//创建多个子流程用的集合 
//获取从前台传过来的科室code，并将其解析出来存入集合 
if(result.getAddinfoDep()!=null&&!"".equals(result.getAddinfoDep())){ 
String strs[]=result.getAddinfoDep().split(",");//将1,2,3,4..拼接的科室code字符串解析到数组里 
for (String s : strs) { 
candiateUserList.add(s);//将科室code存入集合中         
            } 
}else{ 
candiateUserList.add("流程错误，无效任务");    //纯粹扯淡，这种情况根本不存在 
        } 
map.put("candiateUserList", candiateUserList);//多个子流程集合 
map.put(WorkFlowConstant.TASK_NAME, result.getProjectName()+"设备清单填报");//任务名称 
map.put(WorkFlowConstant.DEADLINE,IcmisUnit.date2str(result.getDepDeadline()));//任务截止时间 
map.put(WorkFlowConstant.IS_URGENCY,result.getTaskUrgency());//任务紧急度 
//发起流程 
String piId=wfservice.getWorkflowBaseService().startProcess("bpApply", map,targetFilePath);

public String startProcess(String processDefinitionKey, 
Map<String, Object> vMap,String targetFilePath) { 
RuntimeService rs = this.processEngine.getRuntimeService();        //得到运行时的service 
//设置发起人，这个方法是通过线程判断是一个了流程实例的 
this.processEngine.getIdentityService().setAuthenticatedUserId(vMap.get(WorkFlowConstant.START_USER).toString()); 
//根据传入的用户名得到工作流内置的用户表对象 
User user = this.processEngine.getIdentityService().createUserQuery() 
.userId(vMap.get(WorkFlowConstant.START_USER).toString()) 
.singleResult(); 
vMap.put("ac", processDefinitionKey);//设置流程定义key，存到流程变量中 
//根据流程定义key得到流程定义对象 
ProcessDefinition processDefinition = this.getProcessDefinitionByKey(processDefinitionKey); 
//vMap.put(WorkFlowConstant.VIEW_URL, processDefinition.getDescription()); 
Map<String,Object> map=getSeqFlowByBpmn(processDefinition.getDeploymentId(),targetFilePath);//得到所有连线驳回的任务节点的map 
vMap.put(WorkFlowConstant.SEQUENCEFLOW, map);//将连线驳回的任务节点map存入流程变量中 
// 保存日志 
ProcessInstance instance = rs.startProcessInstanceByKey( 
processDefinitionKey, vMap); 
TaskMarkModel taskMarkModel = new TaskMarkModel(); 
taskMarkModel.setAuditRemark("发起任务"); 
//排序使用 
taskMarkModel.setCreateDate(new Date(new Date().getTime()-100000)); 
taskMarkModel.setDoDate(new Date(new Date().getTime()-100000)); 
taskMarkModel.setDoResult("发起任务"); 
taskMarkModel.setDoUserName(user.getFirstName()); 
taskMarkModel.setPid(instance.getProcessInstanceId()); 
taskMarkModel.setpName(processDefinition.getName()); 
taskMarkModel.setTaskName("发起任务"); 
this.saveTaskMark(taskMarkModel); 
// 保存日志结束 
return instance.getProcessInstanceId(); 
}

        /** 
* 获取每个任务的连线. 
* 
* @Title: getSeqFlowByBpmn 
* @author [email protected] 
* @param deploymentid 部署id 
* @param targetFilePath 路径 
* @return 
*/ 
public Map getSeqFlowByBpmn(String deploymentid,String targetFilePath){ 
Map<String,List<String>> map=new HashMap<String, List<String>>(); 
Map<String,String> taskmap=new HashMap<String, String>(); 
Map allmap=new HashMap(); 
try { 
InputStream in=null; 
List<String> list = getProcessEngine().getRepositoryService()// 
                    .getDeploymentResourceNames(deploymentid); 
//定义图片资源的名称 
String resourceName = ""; 
if(list!=null && list.size()>0){ 
for(String name:list){ 
if(name.indexOf(".bpmn")>=0){ 
resourceName = name; 
} 
} 
} 
//获取数据库里部署的bpmn文件 
in = getProcessEngine().getRepositoryService() 
.getResourceAsStream(deploymentid, resourceName); 
//将bpmn文件另存到本地并写入xml文件 
String fileName=resourceName.substring(0,resourceName.indexOf("."))+".xml"; 
File file = new File(targetFilePath+fileName); 
//    if(file.exists()){//判断文件是否存在 
            System.out.println(targetFilePath); 
file.delete();//如果存在则先删除 
file.createNewFile();  //创建文件 
OutputStream output = new FileOutputStream(file); 
BufferedOutputStream bufferedOutput = new BufferedOutputStream(output); 
bufferedOutput.write(IcmisUnit.toByteArray(in)); 
bufferedOutput.flush(); 
//    } 
//获取dom工厂得到dom对象 
DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();//步骤1 
DocumentBuilder builder = factory.newDocumentBuilder();//步骤2 
//将保存的xml解析成dom树 
Document doc = builder.parse(file);//步骤3 
//获取连线的所有node 
NodeList sequenceFlow = doc.getElementsByTagName("sequenceFlow"); 
//获取网关的所有node 
NodeList exclusiveGateway = doc.getElementsByTagName("exclusiveGateway"); 
//获取任务的所有node 
NodeList userTask = doc.getElementsByTagName("userTask"); 
//循环任务节点 
for (int i = 0; i < userTask.getLength(); i++) { 
//获取任务节点的id属性 
String id=userTask.item(i).getAttributes().getNamedItem("id").getNodeValue(); 
//获取任务节点的name属性 
String name=userTask.item(i).getAttributes().getNamedItem("name").getNodeValue(); 
taskmap.put(id, name); 
} 
//循环连线节点 
for (int i = 0; i < sequenceFlow.getLength(); i++) { 
//获取连线的起始节点 
String sourceTask=sequenceFlow.item(i).getAttributes().getNamedItem("sourceRef").getNodeValue(); 
//获取连线的目标节点 
String targetTask=sequenceFlow.item(i).getAttributes().getNamedItem("targetRef").getNodeValue(); 
boolean bool=true;//用来判断是否是通过的连线，下面的操作是为了过滤描述通过的连线 
//获取连线节点下的配置信息节点，一个连线应该只有一个配置节点 
NodeList  nl=  sequenceFlow.item(i).getChildNodes(); 
for (int j = 0; j <nl.getLength(); j++) { 
if(nl.item(j).getNodeType()==Node.ELEMENT_NODE){ 
//找到配置节点，并得到配置的值 
if("conditionExpression".equals(nl.item(j).getNodeName())){   
//这里要注意一下：配置通过的连线一定要写成${flag=='1'}或"${flag==/"1/"} 
String flag=Util.nulltostr(nl.item(j).getFirstChild().getNodeValue()); 
if("${flag=='1'}".equals(flag)||"${flag==/"1/"}".equals(flag)){ 
//表示是通过的连线，如果是通过的连线则不做处理，这里用到了上面的boolean变量，通过变量来控制过滤节点 
bool=false; 
} 
} 
} 
} 
//通过变量过滤已通过的连线节点 
if(bool){     
//存连线的开始任务 
if(map.containsKey(sourceTask)){ 
//表示存在 
                        map.get(sourceTask).add(targetTask); 
}else{ 
//表示不存在 
List<String> targetlist=new ArrayList<String>(); 
targetlist.add(targetTask); 
map.put(sourceTask, targetlist); 
} 
} 
} 
//默认取出来的连线针对网关记录的是网关的节点，但是实际操作中想要得到网关的节点id是不可能的，所以加了一步处理，获取连接网关的上个节点 
//这里要说明一下，连接到网关的连线  也就是targetRef肯定是只有一条连线，所以顺藤摸瓜找到了连接网关的任务节点，这样在实际项目中 
//通过任务节点即可找到驳回连线的targetRef任务节点，即可展示到前台让客户去选择驳回的连线啦 
//循环网关node  
for (int i = 0; i < exclusiveGateway.getLength(); i++) { 
//得到网关id 
String exclusiveGatewayid=exclusiveGateway.item(i).getAttributes().getNamedItem("id").getNodeValue(); 
//通过循环所有的连线，比对得到那条唯一连接网关的连线将数据重新防止到map当中 
for (String key : map.keySet()) { 
for (String target : map.get(key)) { 
if(exclusiveGatewayid.equals(target)){ 
map.put(key, map.get(exclusiveGatewayid)); 
} 
} 
} 
} 
} catch (Exception e) { 
e.printStackTrace(); 
} 
allmap.put(WorkFlowConstant.SEQ, map); 
allmap.put(WorkFlowConstant.USERTASK, taskmap); 
return allmap; 
}