| | |
|---|
| | | // 获取当前登录用户 |
|---|
| | | CtUserDTO loginUser = custClient.clientGetUserAll(userId); |
|---|
| | | Date now = DateUtils.getNowDate(); |
|---|
| | | caseAssistApply.setApplyStatus(AuditBaseConsts.AUDIT_STATUS_1); |
|---|
| | | caseAssistApply.setAuditUserId(loginUser.getId()); |
|---|
| | | caseAssistApply.setAuditUserName(loginUser.getTrueName()); |
|---|
| | | caseAssistApply.setAuditTime(now); |
|---|
| | | caseAssistApply.setUpdateTime(now); |
|---|
| | | mapper.updateCaseAssistApply(caseAssistApply); |
|---|
| | | CaseAssistApply caseAssistApplyPO = mapper.selectById(caseAssistApply.getId()); |
|---|
| | | caseAssistApplyPO.setAuditResult(caseAssistApply.getAuditResult()); |
|---|
| | | caseAssistApplyPO.setAuditResultName(caseAssistApply.getAuditResultName()); |
|---|
| | | caseAssistApplyPO.setAuditContent(caseAssistApply.getAuditContent()); |
|---|
| | | caseAssistApplyPO.setApplyStatus(AuditBaseConsts.AUDIT_STATUS_1); |
|---|
| | | caseAssistApplyPO.setAuditUserId(loginUser.getId()); |
|---|
| | | caseAssistApplyPO.setAuditUserName(loginUser.getTrueName()); |
|---|
| | | caseAssistApplyPO.setAuditTime(now); |
|---|
| | | caseAssistApplyPO.setUpdateTime(now); |
|---|
| | | mapper.updateCaseAssistApply(caseAssistApplyPO); |
|---|
| | | // 审核通过，就启动联合处置工作流 |
|---|
| | | if (AuditBaseConstsEnum.AUDIT_RESULT_1.getIndex().equals(caseAssistApply.getAuditResult())) { |
|---|
| | | String[] unitIds = caseAssistApply.getApplyAssistUnitId().split(BaseConsts.COMMA); |
|---|
| | | if (AuditBaseConstsEnum.AUDIT_RESULT_1.getIndex().equals(caseAssistApplyPO.getAuditResult())) { |
|---|
| | | String[] unitIds = caseAssistApplyPO.getApplyAssistUnitId().split(BaseConsts.COMMA); |
|---|
| | | for (String unitId: unitIds) { |
|---|
| | | // 启动联合处置工作流 |
|---|
| | | FlowNode firstFlowNode = flowInfoService.startFlow(FlowableConsts.FLOWABLE_ID_LHCZ, caseAssistApply.getCaseId()); |
|---|
| | | FlowNode dfpFlowNode = flowInfoService.startFlow(FlowableConsts.FLOWABLE_ID_LHCZ, caseAssistApplyPO.getCaseId()); |
|---|
| | | // 新建并完成配合部门待分派任务 |
|---|
| | | CaseTask dfpCaseTask = new CaseTask(); |
|---|
| | | dfpCaseTask.setId(utilsClient.getNewTimeId()); |
|---|
| | | dfpCaseTask.setCaseId(caseAssistApplyPO.getCaseId()); |
|---|
| | | dfpCaseTask.setFlowableId(dfpFlowNode.getFlowableId()); |
|---|
| | | dfpCaseTask.setProcessInstanceId(dfpFlowNode.getProcessInstanceId()); |
|---|
| | | dfpCaseTask.setProcessTaskId(dfpFlowNode.getProcessTaskId()); |
|---|
| | | dfpCaseTask.setTaskType(CaseTaskConsts.TASK_TYPE_1); |
|---|
| | | dfpCaseTask.setNodeType(dfpFlowNode.getNodeType()); |
|---|
| | | dfpCaseTask.setNodeId(dfpFlowNode.getNodeId()); |
|---|
| | | dfpCaseTask.setNodeName(dfpFlowNode.getNodeName()); |
|---|
| | | dfpCaseTask.setFlowId(dfpFlowNode.getFlowId()); |
|---|
| | | dfpCaseTask.setNodeShowName(dfpFlowNode.getNodeShowName()); |
|---|
| | | dfpCaseTask.setCaseTaskType(CaseTaskConsts.CASE_TASK_TYPE_2); |
|---|
| | | // 通过调度的，任务候选执行者类型是上一步骤选择 |
|---|
| | | dfpCaseTask.setCandeType(CaseTaskConsts.CANDE_TYPE_1); |
|---|
| | | dfpCaseTask.setCandeUnitId(loginUser.getUnitId()); |
|---|
| | | dfpCaseTask.setCandeUnitName(loginUser.getUnitName()); |
|---|
| | | // 不需要签收 |
|---|
| | | dfpCaseTask.setSignStatus(CaseTaskConsts.SIGN_STATUS_0); |
|---|
| | | dfpCaseTask.setStatus(CaseTaskConsts.TASK_STATUS_2); |
|---|
| | | dfpCaseTask.setHandleUnitId(loginUser.getUnitId()); |
|---|
| | | dfpCaseTask.setHandleUnitName(loginUser.getUnitName()); |
|---|
| | | dfpCaseTask.setHandleUserId(loginUser.getId()); |
|---|
| | | dfpCaseTask.setHandleUserName(loginUser.getTrueName()); |
|---|
| | | dfpCaseTask.setHandleContent(caseAssistApplyPO.getAuditContent()); |
|---|
| | | dfpCaseTask.setHandleIllust("交办至："+caseAssistApplyPO.getApplyAssistUnitName()); |
|---|
| | | // 任务处理时限 |
|---|
| | | if (dfpFlowNode.getExpire() != 0) { |
|---|
| | | dfpCaseTask.setExpireTime(DateUtils.addDay(now, dfpFlowNode.getExpire())); |
|---|
| | | } |
|---|
| | | dfpCaseTask.setDeleteStatus(BaseConsts.DELETE_STATUS_0); |
|---|
| | | dfpCaseTask.setCustId(caseAssistApplyPO.getCustId()); |
|---|
| | | dfpCaseTask.setCreateTime(now); |
|---|
| | | dfpCaseTask.setUpdateTime(now); |
|---|
| | | caseTaskService.save(dfpCaseTask); |
|---|
| | | // 完成待分派任务 |
|---|
| | | FlowNode dslFlowNode = flowInfoService.completeTask(dfpCaseTask.getFlowableId(), dfpCaseTask.getProcessTaskId(), |
|---|
| | | FlowableConsts.OPERATION_forward, loginUser.getId()); |
|---|
| | | // 创建配合部门待受理任务 |
|---|
| | | CaseTask dslCaseTask = new CaseTask(); |
|---|
| | | dslCaseTask.setId(utilsClient.getNewTimeId()); |
|---|
| | | dslCaseTask.setCaseId(caseAssistApply.getCaseId()); |
|---|
| | | dslCaseTask.setFlowableId(firstFlowNode.getFlowableId()); |
|---|
| | | dslCaseTask.setProcessInstanceId(firstFlowNode.getProcessInstanceId()); |
|---|
| | | dslCaseTask.setProcessTaskId(firstFlowNode.getProcessTaskId()); |
|---|
| | | dslCaseTask.setCaseId(caseAssistApplyPO.getCaseId()); |
|---|
| | | dslCaseTask.setFlowableId(dslFlowNode.getFlowableId()); |
|---|
| | | dslCaseTask.setProcessInstanceId(dslFlowNode.getProcessInstanceId()); |
|---|
| | | dslCaseTask.setProcessTaskId(dslFlowNode.getProcessTaskId()); |
|---|
| | | dslCaseTask.setTaskType(CaseTaskConsts.TASK_TYPE_1); |
|---|
| | | dslCaseTask.setNodeType(firstFlowNode.getNodeType()); |
|---|
| | | dslCaseTask.setNodeId(firstFlowNode.getNodeId()); |
|---|
| | | dslCaseTask.setNodeName(firstFlowNode.getNodeName()); |
|---|
| | | dslCaseTask.setFlowId(firstFlowNode.getFlowId()); |
|---|
| | | dslCaseTask.setNodeShowName(firstFlowNode.getNodeShowName()); |
|---|
| | | dslCaseTask.setNodeType(dslFlowNode.getNodeType()); |
|---|
| | | dslCaseTask.setNodeId(dslFlowNode.getNodeId()); |
|---|
| | | dslCaseTask.setNodeName(dslFlowNode.getNodeName()); |
|---|
| | | dslCaseTask.setFlowId(dslFlowNode.getFlowId()); |
|---|
| | | dslCaseTask.setNodeShowName(dslFlowNode.getNodeShowName()); |
|---|
| | | dslCaseTask.setCaseTaskType(CaseTaskConsts.CASE_TASK_TYPE_2); |
|---|
| | | // 通过调度的，任务候选执行者类型是上一步骤选择 |
|---|
| | | dslCaseTask.setCandeType(CaseTaskConsts.CANDE_TYPE_1); |
|---|
| | |
|---|
| | | dslCaseTask.setSignStatus(CaseTaskConsts.SIGN_STATUS_1); |
|---|
| | | dslCaseTask.setStatus(CaseTaskConsts.TASK_STATUS_1); |
|---|
| | | // 任务处理时限 |
|---|
| | | if (firstFlowNode.getExpire() != 0) { |
|---|
| | | dslCaseTask.setExpireTime(DateUtils.addDay(now, firstFlowNode.getExpire())); |
|---|
| | | if (dslFlowNode.getExpire() != 0) { |
|---|
| | | dslCaseTask.setExpireTime(DateUtils.addDay(now, dslFlowNode.getExpire())); |
|---|
| | | } |
|---|
| | | dslCaseTask.setDeleteStatus(BaseConsts.DELETE_STATUS_0); |
|---|
| | | dslCaseTask.setCustId(caseAssistApply.getCustId()); |
|---|
| | | dslCaseTask.setCustId(caseAssistApplyPO.getCustId()); |
|---|
| | | dslCaseTask.setCreateTime(now); |
|---|
| | | dslCaseTask.setUpdateTime(now); |
|---|
| | | caseTaskService.save(dslCaseTask); |
|---|
| | | } |
|---|
| | | // 更新纠纷扩展信息 |
|---|
| | | CaseInfoUnfold caseInfoUnfoldPO = new CaseInfoUnfold(); |
|---|
| | | caseInfoUnfoldPO.setId(caseAssistApply.getCaseId()); |
|---|
| | | caseInfoUnfoldPO.setAssistUnitId(caseAssistApply.getApplyAssistUnitId()); |
|---|
| | | caseInfoUnfoldPO.setAssistUnitName(caseAssistApply.getApplyAssistUnitName()); |
|---|
| | | caseInfoUnfoldPO.setId(caseAssistApplyPO.getCaseId()); |
|---|
| | | caseInfoUnfoldPO.setAssistUnitId(caseAssistApplyPO.getApplyAssistUnitId()); |
|---|
| | | caseInfoUnfoldPO.setAssistUnitName(caseAssistApplyPO.getApplyAssistUnitName()); |
|---|
| | | caseInfoUnfoldService.updateCaseInfoUnfold(caseInfoUnfoldPO); |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
