监听单独处理

2023-05-12 13:26:36 +08:00
parent f7a26a7b7c
commit 400be33a2c
1 changed files with 7 additions and 3 deletions
@@ -403,8 +403,9 @@ public class ProcessStep4After implements TaskListener {
                        String nowTaskInfo = listGk.get(0).getName();
                        if ("技术标准起草".equals(nowTaskInfo)) {
                            // 删除正在运行中的流程根据流程实例ID
-                            runtimeService.deleteProcessInstance(prcIdGk, "");
-
+                            if(StringUtils.isNotBlank(prcIdGk)){
+                              runtimeService.deleteProcessInstance(prcIdGk, "");
+                            }
                            String OVERTIME = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
                            QueryWrapper queryWrapperGk = new QueryWrapper();
                            queryWrapperGk.eq("PRC_ID", prcIdGk);
@@ -413,13 +414,16 @@ public class ProcessStep4After implements TaskListener {
                                one.setOverTime(OVERTIME);
                                busProcessNameService.saveOrUpdate(one);
                            }
+
                        }
                    } else {
                        String prcId = esPrcRelationList.get(0).getPrcId();
                        List<Task> list = taskService.createTaskQuery().processInstanceId(prcId).active().list();
                        if (list != null && !list.isEmpty()) {
                            // 删除正在运行中的流程根据流程实例ID
-                            runtimeService.deleteProcessInstance(prcId, "");
+                            if(StringUtils.isNotBlank(prcId)) {
+                                runtimeService.deleteProcessInstance(prcId, "");
+                            }
                        }
                    }
                }