启用停用修改

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgEnableDisableServiceImpl.java

@@ -88,102 +88,97 @@ public class JgEnableDisableServiceImpl extends BaseService<JgEnableDisableDto,
     @Transactional(rollbackFor = Exception.class)
     public void saveOrUpdate(JSONObject map, ReginParams reginParams) {
         JgEnableDisable jgEnableDisable = new JgEnableDisable();
-        if(!"null".equals(String.valueOf(map.get("sequenceNbr")))){
+        if (!"null".equals(String.valueOf(map.get("sequenceNbr")))) {
             jgEnableDisable = this.baseMapper.selectById(String.valueOf(map.get("sequenceNbr")));
+        } else {
+            // 获取申请编号
+            ResponseModel<List<String>> listResponseModel = tzsServiceFeignClient.applicationFormCode(ApplicationFormTypeEnum.getCode.get(String.valueOf(map.get("businessCode"))), 1);
+            jgEnableDisable.setApplyNo(listResponseModel.getResult().get(0));
         }
         jgEnableDisable.setCreateDate(new Date());
         String submit = String.valueOf(map.get("submit"));
         String pageType = String.valueOf(map.get("formType"));
         String record = String.valueOf(map.get("record"));
-        String businessCode = String.valueOf(map.get("businessCode"));
+        String businessCode = ObjectUtils.isEmpty(map.get("applyType"))?String.valueOf(map.get("businessCode")):String.valueOf(map.get("applyType"));
         // 接收机构
         String[] receiveOrgCode = String.valueOf(map.getString("receiveOrgCode")).split("_");
         List<WorkflowResultDto> workflowResultList = new ArrayList<>();
 
-        ProcessTaskDTO processTaskDTO = new ProcessTaskDTO();
         WorkflowResultDto workflowResultDto = new WorkflowResultDto();
+        List<ProcessTaskDTO> processTaskDTOS = new ArrayList<>();
 
         String instanceId = "";
-        if (map.containsKey("instanceId")) {
-            // 只调用执行API，返回下个节点信息，用于填充业务字段
-            //组装信息
-            TaskResultDTO dto = new TaskResultDTO();
-            dto.setResultCode("approvalStatus");
-            dto.setTaskId(jgEnableDisable.getNextTaskId());
-            HashMap<String, Object> commMap = new HashMap<>();
-            if (FlowStatusEnum.REJECTED.getName().equals(jgEnableDisable.getAuditStatus()) || FlowStatusEnum.ROLLBACK.getName().equals(jgEnableDisable.getAuditStatus())) {
-                commMap.put("approvalStatus", "提交");
-                //下一节点执行人单位（下节点接收机构code）
-                dto.setNextExecuteUserCompanyCode(jgEnableDisable.getUseUnitCreditCode());
-            } else {
-                commMap.put("approvalStatus", submit);
-                //下一节点执行人单位（下节点接收机构code）
-                dto.setNextExecuteUserCompanyCode(jgEnableDisable.getReceiveCompanyCode());
-            }
-
-            dto.setVariable(commMap);
-            processTaskDTO = iCmWorkflowService.complete(jgEnableDisable.getNextTaskId(), dto);
-            // 提取节点等信息
-            workflowResultDto = commonService.buildWorkFlowInfo(Collections.singletonList(processTaskDTO)).get(0);
+        if (SUBMIT_TYPE_FLOW.equals(submit)) {
+            if (map.containsKey("instanceId") && !ObjectUtils.isEmpty(map.get("instanceId"))){
+                // 只调用执行API，返回下个节点信息，用于填充业务字段
+                //组装信息
+                TaskResultDTO dto = new TaskResultDTO();
+                dto.setResultCode("approvalStatus");
+                dto.setTaskId(jgEnableDisable.getNextTaskId());
+                HashMap<String, Object> commMap = new HashMap<>();
+                if (FlowStatusEnum.REJECTED.getName().equals(jgEnableDisable.getAuditStatus()) || FlowStatusEnum.ROLLBACK.getName().equals(jgEnableDisable.getAuditStatus())) {
+                    commMap.put("approvalStatus", "提交");
+                    //下一节点执行人单位（下节点接收机构code）
+                    dto.setNextExecuteUserCompanyCode(jgEnableDisable.getReceiveCompanyCode());
+                } else {
+                    commMap.put("approvalStatus", submit);
+                    //下一节点执行人单位（下节点接收机构code）
+                    dto.setNextExecuteUserCompanyCode(jgEnableDisable.getUseUnitCreditCode());
+                }
 
-            if (!ObjectUtils.isEmpty(jgEnableDisable.getExecuteSequence())) {
-                jgEnableDisable.setExecuteSequence(jgEnableDisable.getExecuteSequence() + "," + workflowResultDto.getNextExecutorRoleIds());
-            } else {
-                jgEnableDisable.setExecuteSequence(workflowResultDto.getNextExecutorRoleIds());
-            }
-            jgEnableDisable.setEquList("null".equals(record) ? "null" : map.get("equListDesc").toString());
-            jgEnableDisable.setSupervisoryCode("null".equals(record) ? "null" : map.get("supervisoryCode").toString());
-            jgEnableDisable.setPromoter(RequestContext.getExeUserId());
-            jgEnableDisable.setNextExecutorIds(String.join(",", workflowResultDto.getNextExecutorRoleIds()));
-            jgEnableDisable.setAuditStatus(String.valueOf(FlowStatusEnum.TO_BE_PROCESSED.getName()));
-            jgEnableDisable.setNextTaskId(workflowResultDto.getNextTaskId());
-            jgEnableDisable.setNextExecuteUserIds(workflowResultDto.getNextExecutorUserIds());
-            this.baseMapper.updateById(jgEnableDisable);
-            // 上个代办改为已办
-            HashMap<String, Object> map1 = new HashMap<>();
-            map1.put("taskStatus", FlowStatusEnum.TO_BE_PROCESSED.getCode());
-            map1.put("taskStatusLabel", FlowStatusEnum.TO_BE_PROCESSED.getName());
-            map1.put("relationId", jgEnableDisable.getInstanceId());
-            map1.put("flowStatus", FlowStatusEnum.TO_BE_PROCESSED.getCode());
-            map1.put("flowStatusLabel", FlowStatusEnum.TO_BE_PROCESSED.getName());
-            TaskV2Model taskV2Model = commonService.updateTaskModel(map1);
-            if (ObjectUtils.isEmpty(taskV2Model)) {
-                // 如果为保存并提交，则创建代办
-                buildTask(Collections.singletonList(jgEnableDisable), businessCode, Collections.singletonList(workflowResultDto),Boolean.TRUE);
+                dto.setVariable(commMap);
+                ProcessTaskDTO processTaskDTO = iCmWorkflowService.complete(jgEnableDisable.getNextTaskId(), dto);
+                processTaskDTOS.add(processTaskDTO);
+                // 提取节点等信息
+                workflowResultDto = commonService.buildWorkFlowInfo(Collections.singletonList(processTaskDTO)).get(0);
+                workflowResultList.add(workflowResultDto);
+                if (!ObjectUtils.isEmpty(jgEnableDisable.getExecuteSequence())) {
+                    jgEnableDisable.setExecuteSequence(jgEnableDisable.getExecuteSequence() + "," + workflowResultDto.getNextExecutorRoleIds());
+                } else {
+                    jgEnableDisable.setExecuteSequence(workflowResultDto.getNextExecutorRoleIds());
+                }
+                jgEnableDisable.setEquList("null".equals(record) ? "null" : map.get("equListDesc").toString());
+                jgEnableDisable.setSupervisoryCode("null".equals(record) ? "null" : map.get("supervisoryCode").toString());
+                jgEnableDisable.setPromoter(RequestContext.getExeUserId());
+                jgEnableDisable.setNextExecutorIds(String.join(",", workflowResultDto.getNextExecutorRoleIds()));
+                jgEnableDisable.setAuditStatus(String.valueOf(FlowStatusEnum.TO_BE_PROCESSED.getName()));
+                jgEnableDisable.setNextTaskId(workflowResultDto.getNextTaskId());
+                jgEnableDisable.setNextExecuteUserIds(workflowResultDto.getNextExecutorUserIds());
+                this.baseMapper.updateById(jgEnableDisable);
+                // 上个代办改为已办
+                HashMap<String, Object> map1 = new HashMap<>();
+                map1.put("taskStatus", FlowStatusEnum.TO_BE_PROCESSED.getCode());
+                map1.put("taskStatusLabel", FlowStatusEnum.TO_BE_PROCESSED.getName());
+                map1.put("relationId", jgEnableDisable.getInstanceId());
+                map1.put("flowStatus", FlowStatusEnum.TO_BE_PROCESSED.getCode());
+                map1.put("flowStatusLabel", FlowStatusEnum.TO_BE_PROCESSED.getName());
+                TaskV2Model taskV2Model = commonService.updateTaskModel(map1);
+                if (ObjectUtils.isEmpty(taskV2Model)) {
+                    TaskModelDto taskModelDto = new TaskModelDto();
+                    BeanUtils.copyProperties(taskV2Model, taskModelDto);
+                    // 创建新的代办
+                    TaskMessageDto taskMessageDto = new TaskMessageDto();
+                    BeanUtils.copyProperties(jgEnableDisable, taskMessageDto);
+                    taskModelDto.setModel(taskMessageDto);
+                    taskModelDto.setTaskName(workflowResultDto.getNextTaskName());
+                    taskModelDto.setExecuteUserIds(workflowResultDto.getNextExecutorUserIds());
+                    taskModelDto.setFlowStatus(FlowStatusEnum.TO_BE_PROCESSED.getCode());
+                    taskModelDto.setFlowStatusLabel(FlowStatusEnum.TO_BE_PROCESSED.getName());
+                    taskModelDto.setFlowCode(jgEnableDisable.getNextTaskId());
+                    taskModelDto.setNextExecuteUser(workflowResultDto.getNextExecutorRoleIds());
+                    commonService.buildTaskModel(Collections.singletonList(taskModelDto));
+                }
             } else {
-                TaskModelDto taskModelDto = new TaskModelDto();
-                BeanUtils.copyProperties(taskV2Model, taskModelDto);
-                // 创建新的代办
-                TaskMessageDto taskMessageDto = new TaskMessageDto();
-                BeanUtils.copyProperties(jgEnableDisable, taskMessageDto);
-                taskModelDto.setModel(taskMessageDto);
-                taskModelDto.setTaskName(workflowResultDto.getNextTaskName());
-                taskModelDto.setExecuteUserIds(workflowResultDto.getNextExecutorUserIds());
-                taskModelDto.setFlowStatus(FlowStatusEnum.TO_BE_PROCESSED.getCode());
-                taskModelDto.setFlowStatusLabel(FlowStatusEnum.TO_BE_PROCESSED.getName());
-                taskModelDto.setFlowCode(jgEnableDisable.getNextTaskId());
-                taskModelDto.setNextExecuteUser(workflowResultDto.getNextExecutorRoleIds());
-                commonService.buildTaskModel(Collections.singletonList(taskModelDto));
+                // 启动工作流并返回信息
+                workflowResultList = workFlowInfo(submit, record,receiveOrgCode[0]);
+                //业务数据组装等
+                businessData(submit, reginParams, jgEnableDisable, map, workflowResultList);
             }
-        } else {
-            // 获取申请编号
-            ResponseModel<List<String>> listResponseModel = tzsServiceFeignClient.applicationFormCode(ApplicationFormTypeEnum.getCode.get(String.valueOf(map.get("businessCode"))), 1);
-            jgEnableDisable.setApplyNo(listResponseModel.getResult().get(0));
-            // 启动工作流并返回信息
-            workflowResultList = workFlowInfo(submit, record,receiveOrgCode[0]);
-            //业务数据组装等
-            businessData(submit, reginParams, jgEnableDisable, map, workflowResultList);
         }
-
-
         // 仅保存
+        this.saveOrUpdate(jgEnableDisable);
         if ("add".equals(pageType)) {
-            this.save(jgEnableDisable);
             buildTask(Arrays.asList(jgEnableDisable), businessCode, workflowResultList, Boolean.FALSE);
-            if(!SUBMIT_TYPE_FLOW.equals(submit)){
-                // 暂存任务
-                buildTaskDraft(jgEnableDisable);
-            }
         } else {
             // 编辑
             jgEnableDisable.setSequenceNbr(Long.valueOf(String.valueOf(map.get("sequenceNbr"))));
@@ -192,12 +187,18 @@ public class JgEnableDisableServiceImpl extends BaseService<JgEnableDisableDto,
             lambda.eq(JgEnableDisableEq::getEnableDisableApplyId, String.valueOf(map.get("sequenceNbr")));
             jgEnableDisableEqService.getBaseMapper().delete(lambda);
         }
+        if(!SUBMIT_TYPE_FLOW.equals(submit)){
+            // 暂存任务
+            buildTaskDraft(jgEnableDisable);
+        } else {
+            buildTask(Arrays.asList(jgEnableDisable), businessCode, workflowResultList, Boolean.TRUE);
+        }
         if(!"null".equals(record)){
             // 关联设备表
             JgEnableDisableEq jgEnableDisableEq = new JgEnableDisableEq();
             jgEnableDisableEq.setEquId(record);
             jgEnableDisableEq.setEnableDisableApplyId(jgEnableDisable.getSequenceNbr().toString());
-            jgEnableDisableEqService.save(jgEnableDisableEq);
+            jgEnableDisableEqService.saveOrUpdate(jgEnableDisableEq);
         }
 
     }
@@ -497,6 +498,8 @@ public class JgEnableDisableServiceImpl extends BaseService<JgEnableDisableDto,
         JSONObject jsonObject = JSONObject.parseObject(JSONObject.toJSONString(jgEnableDisable));
         jsonObject.put("nextExecuteUser", jgEnableDisable.getNextExecutorIds());
         jsonObject.put("taskType", BusinessTypeEnum.JG_MAINTENANCE_NOTIFICATION.getCode());
+        jsonObject.put("flowStatusLabel", FlowStatusEnum.ROLLBACK.getName());
+        jsonObject.put("flowStatus", FlowStatusEnum.ROLLBACK.getCode());
         commonService.rollbackTask(jgEnableDisable.getInstanceId(), jsonObject);
     }