fix: 各部门主动上报流程第三个节点报错

This commit is contained in:
2023-12-12 09:48:36 +08:00
parent e0f8351df5
commit c5dee34d47
@@ -151,9 +151,10 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
String taskName = task.getName();
String processInstanceId = actFlowCommonService.getProcessInstanceIdByTaskId(taskId);
ProcessEsAnnualReport annualReport;
switch (taskName) {
case CONTACT_USER_DISTRIBUTE:
ProcessEsAnnualReport annualReport = annualReportDataVO.getDataList().get(0);
annualReport = annualReportDataVO.getDataList().get(0);
boolean distribute = annualReport.getDistributeFlag().equals("1");
String contactUserLeaderLeader = annualReport.getContactUserLeaderLeader();
taskService.setVariable(taskId, "distribute", distribute);
@@ -178,16 +179,18 @@ public class ProcessEsAnnualReportServiceImpl extends ServiceImpl<ProcessEsAnnua
}
break;
case WORK_GROUP_COLLECT:
annualReport = annualReportDataVO.getDataList().get(0);
String collectUserLeader = annualReport.getCollectUserLeader();
String executionId = task.getExecutionId();
String contactUser = (String) runtimeService.getVariable(executionId, "contactUser");
dataList.forEach(data -> data.setContactUser(contactUser));
dataList.forEach(data -> data.setExecutionId(executionId));
// 保存收集联络人主管级领导
dataList.forEach(data -> data.setCollectUserLeader((String) flowUserVO.get("collectUserLeader")));
dataList.forEach(data -> data.setCollectUserLeader(collectUserLeader));
dataList.forEach(data -> data.setWorkGroupUser(UserUtils.getUserId()));
saveBatch(dataList);
// 设置下一个节点的审批人流程变量
taskService.setVariableLocal(taskId, "collectUserLeader", flowUserVO.get("collectUserLeader"));
taskService.setVariable(taskId, "collectUserLeader", collectUserLeader);
break;
case CONTACT_USER_COLLECT:
// 先删后增