工作流自定义启动

凯特-聂程林

启动是流程走到第一个节点，发起是流程跳过第一个申请节点，走到第二个节点
通过接口发起流程

1. /**
   
2.      * 发起
   
3.      * userId 用户id
   
4.      * id 业务bean主键id
   
5.      */
   
6.     @RequestMapping(value = "sponsorProcess", method = RequestMethod.POST, produces = "application/json; charset=utf-8")
   
7.     public BaseRespResult sponsorProcess(String userId, String id) {
   
8.         //查找表单数据
   
9.         DynaBean bean = metaService.selectOneByPk(TABLE_CODE, id);
   
10.         if (bean == null) {
    
11.             return BaseRespResult.errorResult("未找到记录！");
    
12.         }
    
13. 
    
14.         if (!"NOSTATUS".equals(bean.getStr("SY_AUDFLAG"))) {
    
15.             return BaseRespResult.errorResult("流程已发起！");
    
16.         }
    
17. 
    
18.         //封装流程发起对象
    
19.         TaskSubmitInfo taskInfo = new TaskSubmitInfo();
    
20.         //设置主键
    
21.         taskInfo.setBeanId(id);
    
22.         //提交动作，默认 to_submit
    
23.         taskInfo.setSubmitType("to_submit");
    
24.         //提交意见
    
25.         taskInfo.setSubmitComments("提交工单");
    
26.         //默认为[]
    
27.         taskInfo.setCommentDetails("[]");
    
28.         //发起的节点名称，也就是第二个节点
    
29.         taskInfo.setTargerTaskName("客服人员");
    
30. 
    
31.         //根据工作流引擎中，流程key，查询当前流程版本pdid  taskInfo.setPdid("kehugongdan_20112516-1");
    
32.         List<Map<String, Object>> maps = metaService.selectSql("SELECT STRINGVAL_ from jbpm4_deployprop where  OBJNAME_='kehugongdan_20112516' and key_ = 'pdid'");
    
33.         Object stringval;
    
34.         if (maps == null || maps.isEmpty() || (stringval = maps.get(0).get("STRINGVAL_")) == null) {
    
35.             return BaseRespResult.errorResult("流程版本信息查找失败！");
    
36.         }
    
37.         taskInfo.setPdid(String.valueOf(stringval));
    
38. 
    
39.         //流程下一步的人信息
    
40.         StringBuilder assigeeId = new StringBuilder();
    
41.         StringBuilder assigeeCode = new StringBuilder();
    
42.         StringBuilder assigeeName = new StringBuilder();
    
43.         // 查询角色下所有人
    
44.         List<DynaBean> users = buildRoleUser();
    
45.         if (users.isEmpty()) {
    
46.             return BaseRespResult.errorResult("未找到客服人员！");
    
47.         }
    
48.         for (DynaBean user : users) {
    
49.             assigeeId.append(user.getStr("USERID")).append(",");
    
50.             assigeeCode.append(user.getStr("USERCODE")).append(",");
    
51.             assigeeName.append(user.getStr("USERCODE")).append(",");
    
52.         }
    
53.         assigeeId.setLength(assigeeId.length() - 1);
    
54.         assigeeCode.setLength(assigeeCode.length() - 1);
    
55.         assigeeName.setLength(assigeeName.length() - 1);
    
56.         taskInfo.setAssigeeId(assigeeId.toString());
    
57.         taskInfo.setAssigeeCode(assigeeCode.toString());
    
58.         taskInfo.setAssigeeName(assigeeName.toString());
    
59. 
    
60.         //模拟流程发起，调用doSponsor方法发起流程
    
61.         JSONObject returnObj = new JSONObject();
    
62.         wfProcessManager.doSponsor(taskInfo, taskInfo.getBeanId(), SecurityUserHolder.getCurrentUser(), returnObj, true);
    
63.         if (returnObj.containsKey("error")) {
    
64.             return BaseRespResult.errorResult(returnObj.getString("error"));
    
65.         }
    
66. 
    
67.         return BaseRespResult.successResult("发起成功");
    
68.     }
    
69. 
    
70.     /**
    
71.      * 查找客户角色人
    
72.      * 这里是写死的一个角色code去获取角色中的人员，如果想动态获取需要手动解析流程示例,
    
73.      * 根据流程key查询JE_CORE_PROCESSINFO这张表中的PROCESSINFO_TASKJSON字段信息，该字段信息是json字符串，里      * 面的assgineConfig字段是处理人信息
    
74.      */
    
75.     private List<DynaBean> buildRoleUser() {
    
76.         //TODO 查询角色下所有人
    
77.         return metaService.select("JE_CORE_ENDUSER", ConditionsWrapper.builder()
    
78.                 .like("ROLECODES", "ROLE_2020110518")
    
79.                 .eq("VALID", "1")
    
80.                 .eq("ZHID", ZH_ID)
    
81.         );
    
82.     }

复制代码