fix(企标稽查计划): 79365

This commit is contained in:
yjz
2023-12-18 14:08:43 +08:00
parent 07b654522d
commit 1d82e9e15f
2 changed files with 14 additions and 5 deletions
@@ -9,8 +9,11 @@ import com.jero.common.system.vo.LoginUser;
import com.jero.common.util.MessageUtils; import com.jero.common.util.MessageUtils;
import com.jero.modules.activiti.entity.ProcessAll; import com.jero.modules.activiti.entity.ProcessAll;
import com.jero.modules.activiti.entity.ProcessApprovalRecord; import com.jero.modules.activiti.entity.ProcessApprovalRecord;
import com.jero.modules.activiti.enums.CommitFlagEnum;
import com.jero.modules.activiti.enums.FinishFlagEnum;
import com.jero.modules.activiti.process.esinspectplan.common.EsInspectPlanCommon; import com.jero.modules.activiti.process.esinspectplan.common.EsInspectPlanCommon;
import com.jero.modules.activiti.service.ProcessApprovalRecordService; import com.jero.modules.activiti.service.ProcessApprovalRecordService;
import com.jero.modules.activiti.service.ProcessNodeLinkService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.activiti.bpmn.model.Process; import org.activiti.bpmn.model.Process;
import org.activiti.bpmn.model.UserTask; import org.activiti.bpmn.model.UserTask;
@@ -51,6 +54,8 @@ public class ProcessAspect {
private RepositoryService repositoryService; private RepositoryService repositoryService;
@Resource @Resource
private ProcessApprovalRecordService processApprovalRecordService; private ProcessApprovalRecordService processApprovalRecordService;
@Resource
private ProcessNodeLinkService processNodeLinkService;
private static final String PROCESS_ALL = "processAll"; private static final String PROCESS_ALL = "processAll";
private static final List<String> SPECIAL_NODE = Arrays.asList(EsInspectPlanCommon.PROCESS_NODE_3); private static final List<String> SPECIAL_NODE = Arrays.asList(EsInspectPlanCommon.PROCESS_NODE_3);
@@ -113,12 +118,16 @@ public class ProcessAspect {
// 所有会签人数 // 所有会签人数
Integer all = (Integer) taskService.getVariable(processAll.getTaskId(), "nrOfInstances"); Integer all = (Integer) taskService.getVariable(processAll.getTaskId(), "nrOfInstances");
taskService.setVariable(processAll.getTaskId(), "nrOfCompletedInstances", all); taskService.setVariable(processAll.getTaskId(), "nrOfCompletedInstances", all);
// 删除其他会签人员待办 // 其他会签人员审批信息,更新状态为未处理
processApprovalRecordService.remove( processApprovalRecordService.update(
new LambdaQueryWrapper<ProcessApprovalRecord>() new LambdaUpdateWrapper<ProcessApprovalRecord>()
.eq(ProcessApprovalRecord::getProcessInstanceId, processAll.getProcessInstanceId()) .eq(ProcessApprovalRecord::getProcessInstanceId, processAll.getProcessInstanceId())
.eq(ProcessApprovalRecord::getNodeId, processAll.getNodeId()) .eq(ProcessApprovalRecord::getNodeId, processAll.getNodeId())
.ne(ProcessApprovalRecord::getTaskId, processAll.getTaskId())); .isNull(ProcessApprovalRecord::getEndTime)
.ne(ProcessApprovalRecord::getTaskId, processAll.getTaskId())
.set(ProcessApprovalRecord::getCommitFlag, CommitFlagEnum.UNDISPOSED.getValue())
.set(ProcessApprovalRecord::getFinishFlag, FinishFlagEnum.SUSPEND.getValue()));
} }
} }
log.info("==========流程会签节点驳回一票否决前置方法结束=========="); log.info("==========流程会签节点驳回一票否决前置方法结束==========");
@@ -359,7 +359,7 @@ public class EsInspectPlanFlowServiceImpl implements IEsInspectPlanFlowService {
.eq(ProcessNodeLink::getProcessDefinitionId, processAll.getProcessDefinitionId()) .eq(ProcessNodeLink::getProcessDefinitionId, processAll.getProcessDefinitionId())
.eq(ProcessNodeLink::getProcessInstanceId, processAll.getProcessInstanceId()) .eq(ProcessNodeLink::getProcessInstanceId, processAll.getProcessInstanceId())
.eq(ProcessNodeLink::getProcessNodeId, processNode.getId()) .eq(ProcessNodeLink::getProcessNodeId, processNode.getId())
.set(ProcessNodeLink::getUserId, "")); .set(ProcessNodeLink::getUserId, null));
} }
// 判断是否是最后一个节点 // 判断是否是最后一个节点
if (isLastNode(processAll.getProcessInstanceId()) if (isLastNode(processAll.getProcessInstanceId())