人员档案提交后审核人丢失问题处理

ibps-bpmn-root/modules/bpmn-biz/src/main/java/com/lc/ibps/bpmn/service/impl/BpmTaskActionServiceImpl.java

@@ -228,43 +228,6 @@ public class BpmTaskActionServiceImpl implements BpmTaskActionService{
 					StopWatchUtil.stopAndStartNewLocal(localId, step, "multipleInstancesRejectAdjust");
 					BpmExecUtil.multipleInstancesRejectAdjust(rejectAfterExecutionId.toString());
 				}
-				if(("Process_0v35zf8".equals(bpmTask.getProcDefKey()) || "Process_08xwabfNEW".equals(bpmTask.getProcDefKey())) && ("Activity_15dfo83".equals(bpmTask.getNodeId()) || "Activity_1iu1clq".equals(bpmTask.getNodeId())) ){ //人员档案流程的处理单独处理
-					String createBy = cmd.getCurUser();
-					String sql = "SELECT ID_,TASK_ID_,PROC_INST_ID_,EXECUTOR_ FROM IBPS_BPM_TASK_ASSIGN WHERE PROC_INST_ID_ IN('" + taskCmd.getInstId() + "')";
-					String rsms = "SELECT DISTINCT e.id_ AS employee_id,e.name_ " +
-							"FROM ibps_party_employee e " +
-							"INNER JOIN ibps_party_user_role ur ON ur.user_id_ = e.id_ " +
-							"INNER JOIN ibps_party_role r ON ur.role_id_ = r.id_ " +
-							"WHERE r.ROLE_ALIAS_ = 'rsms' " +
-							"  AND EXISTS ( " +
-							"      SELECT 1 " +
-							"      FROM ibps_party_employee e_a " +
-							"      INNER JOIN ibps_party_entity ee_a_pos " +
-							"          ON ee_a_pos.party_type_ = 'position' " +
-							"          AND FIND_IN_SET(ee_a_pos.id_, e_a.positions_) > 0 " +
-							"      CROSS JOIN ibps_party_entity ee_pos " +
-							"      WHERE e_a.id_ = '"+ createBy + "' " +
-							"        AND ee_pos.party_type_ = 'position' " +
-							"        AND FIND_IN_SET(ee_pos.id_, e.positions_) > 0 " +
-							"        AND ( " +
-							"            ee_pos.path_ LIKE CONCAT(ee_a_pos.path_, '%') " +
-							"            OR  " +
-							"            ee_a_pos.path_ LIKE CONCAT(ee_pos.path_, '%') " +
-							"        ) " +
-							"  )";
-					List<Map<String, Object>> list = (List<Map<String, Object>>) commonDao.query(sql); //原来的处理人
-					List<Map<String, Object>> rsList = (List<Map<String, Object>>) commonDao.query(rsms); //正确的处理人
-					List<Map<String, Object>> delList = list.stream() //需要删除多余的处理人
-							.filter(map -> rsList.stream().noneMatch(bMap -> bMap.get("employee_id").equals(map.get("EXECUTOR_"))))
-							.collect(Collectors.toList());
-					String idStr = delList.stream()
-							.map(map -> String.valueOf(map.get("ID_"))) // 提取值并转为字符串
-							.filter(s -> s != null && !s.equals("null")) // 过滤空值
-							.collect(Collectors.joining(","));
-
-					String delSql = "delete from IBPS_BPM_TASK_ASSIGN where FIND_IN_SET(id_,'"+idStr+"')";
-					commonDao.execute(delSql);
-				}
 				if(("Process_0v35zf8".equals(bpmTask.getProcDefKey()) || "Process_08xwabfNEW".equals(bpmTask.getProcDefKey())) && ("Activity_15dfo83".equals(bpmTask.getNodeId()) || "Activity_1iu1clq".equals(bpmTask.getNodeId())) ){ //人员档案流程的处理单独处理
 					String createBy = cmd.getCurUser();
 					//String sql = "SELECT ID_,TASK_ID_,PROC_INST_ID_,EXECUTOR_ FROM IBPS_BPM_TASK_ASSIGN WHERE PROC_INST_ID_ IN('" + taskCmd.getInstId() + "')";

ibps-provider-root/modules/provider-bpmn/src/main/java/com/lc/ibps/bpmn/provider/BpmInstProvider.java

@@ -595,44 +595,6 @@ public class BpmInstProvider extends GenericProvider implements IBpmInstService,
 			IbpsProcInstCmd cmd = this.getStartCmd(request);
 			IBpmProcInst inst = bpmProcInstService.startProcInst(cmd);
 			result.setMessage(I18nUtil.getMessage("com.lc.ibps.bpmn.provider.BpmInstProvider.start"));
-             if("Process_0v35zf8".equals(cmd.getFlowKey()) || "Process_08xwabfNEW".equals(cmd.getFlowKey()) ){ //人员档案流程的处理单独处理
-				  String createBy = inst.getCreateBy();
-                  String sql = "SELECT ID_,TASK_ID_,PROC_INST_ID_,EXECUTOR_ FROM IBPS_BPM_TASK_ASSIGN WHERE PROC_INST_ID_ IN('" + inst.getId() + "')";
-				  String rsms = "SELECT DISTINCT e.id_ AS employee_id,e.name_ " +
-						 "FROM ibps_party_employee e " +
-						 "INNER JOIN ibps_party_user_role ur ON ur.user_id_ = e.id_ " +
-						 "INNER JOIN ibps_party_role r ON ur.role_id_ = r.id_ " +
-						 "WHERE r.ROLE_ALIAS_ = 'rsms' " +
-						 "  AND EXISTS ( " +
-						 "      SELECT 1 " +
-						 "      FROM ibps_party_employee e_a " +
-						 "      INNER JOIN ibps_party_entity ee_a_pos " +
-						 "          ON ee_a_pos.party_type_ = 'position' " +
-						 "          AND FIND_IN_SET(ee_a_pos.id_, e_a.positions_) > 0 " +
-						 "      CROSS JOIN ibps_party_entity ee_pos " +
-						 "      WHERE e_a.id_ = '"+ createBy + "' " +
-						 "        AND ee_pos.party_type_ = 'position' " +
-						 "        AND FIND_IN_SET(ee_pos.id_, e.positions_) > 0 " +
-						 "        AND ( " +
-						 "            ee_pos.path_ LIKE CONCAT(ee_a_pos.path_, '%') " +
-						 "            OR  " +
-						 "            ee_a_pos.path_ LIKE CONCAT(ee_pos.path_, '%') " +
-						 "        ) " +
-						 "  )";
-				 List<Map<String, Object>> list = (List<Map<String, Object>>) commonDao.query(sql); //原来的处理人
-				 List<Map<String, Object>> rsList = (List<Map<String, Object>>) commonDao.query(rsms); //正确的处理人
-				 List<Map<String, Object>> delList = list.stream() //需要删除多余的处理人
-						 .filter(map -> rsList.stream().noneMatch(bMap -> bMap.get("employee_id").equals(map.get("EXECUTOR_"))))
-						 .collect(Collectors.toList());
-				 String idStr = delList.stream()
-						 .map(map -> String.valueOf(map.get("ID_"))) // 提取值并转为字符串
-						 .filter(s -> s != null && !s.equals("null")) // 过滤空值
-						 .collect(Collectors.joining(","));
-
-				 String delSql = "delete from IBPS_BPM_TASK_ASSIGN where FIND_IN_SET(id_,'"+idStr+"')";
-				 commonDao.execute(delSql);
-			 }
-
              if("Process_0v35zf8".equals(cmd.getFlowKey()) || "Process_08xwabfNEW".equals(cmd.getFlowKey()) ){ //人员档案流程的处理单独处理
 				  String createBy = inst.getCreateBy();
                   //String sql = "SELECT ID_,TASK_ID_,PROC_INST_ID_,EXECUTOR_ FROM IBPS_BPM_TASK_ASSIGN WHERE PROC_INST_ID_ IN('" + inst.getId() + "')";