/* * Copyright 2017-2020 吴学文 and java110 team. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.java110.common.cmd.workflow; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.core.factory.GenerateCodeFactory; import com.java110.core.log.LoggerFactory; import com.java110.dto.oaWorkflow.WorkflowDto; import com.java110.dto.oaWorkflow.WorkflowStepDto; import com.java110.dto.oaWorkflow.WorkflowStepStaffDto; import com.java110.intf.common.*; import com.java110.po.oaWorkflow.WorkflowPo; import com.java110.po.oaWorkflow.WorkflowStepPo; import com.java110.po.oaWorkflow.WorkflowStepStaffPo; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.StringUtil; import com.java110.vo.ResultVo; import org.slf4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import java.util.ArrayList; import java.util.List; /** * 类表述：更新 * 服务编码：workflow.updateWorkflow * 请求路劲：/app/workflow.UpdateWorkflow * add by 吴学文 at 2021-09-18 13:35:13 mail: 928255095@qq.com * open source address: https://gitee.com/wuxw7/MicroCommunity * 官网：http://www.homecommunity.cn * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下 * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行 */ @Java110Cmd(serviceCode = "workflow.updateWorkflow") public class UpdateWorkflowCmd extends Cmd { private static Logger logger = LoggerFactory.getLogger(UpdateWorkflowCmd.class); @Autowired private IWorkflowV1InnerServiceSMO workflowV1InnerServiceSMOImpl; @Autowired private IWorkflowStepStaffInnerServiceSMO workflowStepStaffInnerServiceSMOImpl; @Autowired private IWorkflowStepStaffV1InnerServiceSMO workflowStepStaffV1InnerServiceSMOImpl; @Autowired private IWorkflowStepV1InnerServiceSMO workflowStepV1InnerServiceSMOImpl; @Autowired private IWorkflowStepInnerServiceSMO workflowStepInnerServiceSMOImpl; @Autowired private IWorkflowInnerServiceSMO workflowInnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { Assert.hasKeyAndValue(reqJson, "flowId", "flowId不能为空"); Assert.hasKeyAndValue(reqJson, "flowName", "请求报文中未包含flowName"); Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId"); Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含商户ID"); JSONArray steps = reqJson.getJSONArray("steps"); if (steps == null || steps.size() < 1) { //throw new IllegalArgumentException("未包含步骤"); return; } JSONObject step = null; JSONObject subStaff = null; for (int stepIndex = 0; stepIndex < steps.size(); stepIndex++) { step = steps.getJSONObject(stepIndex); Assert.hasKeyAndValue(step, "staffId", "步骤中未包含员工"); Assert.hasKeyAndValue(step, "staffName", "步骤中未包含员工"); Assert.hasKeyAndValue(step, "type", "步骤中类型会签还是正常流程"); //正常流程 if (WorkflowStepDto.TYPE_NORMAL.equals(step.getString("type"))) { continue; } //会签流程 if (!step.containsKey("subStaff")) { throw new IllegalArgumentException("未包含会签员工信息"); } JSONArray subStaffs = step.getJSONArray("subStaff"); if (subStaffs == null || subStaffs.size() < 1) { throw new IllegalArgumentException("未包含会签员工信息"); } for (int subStaffIndex = 0; subStaffIndex < subStaffs.size(); subStaffIndex++) { subStaff = subStaffs.getJSONObject(subStaffIndex); Assert.hasKeyAndValue(subStaff, "staffId", "会签中未包含员工"); Assert.hasKeyAndValue(subStaff, "staffName", "会签中未包含员工"); } } } @Override @Java110Transactional public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { logger.debug("进入修改工作流cmd>>>>>>>>>>>>>>>>>>>>>>>>>>>>>"); if (reqJson.containsKey("flowType")) { String flowType = reqJson.getString("flowType"); if (WorkflowDto.FLOW_TYPE_PURCHASE.equals(flowType) || WorkflowDto.FLOW_TYPE_CONTRACT_CHANGE.equals(flowType) || WorkflowDto.FLOW_TYPE_ALLOCATION_STOREHOUSE.equals(flowType) || WorkflowDto.FLOW_TYPE_CONTRACT_APPLY.equals(flowType)) { reqJson.put("communityId", "9999"); } } WorkflowStepDto workflowStepDto = new WorkflowStepDto(); workflowStepDto.setFlowId(reqJson.getString("flowId")); workflowStepDto.setCommunityId(reqJson.getString("communityId")); List workflowStepDtos = workflowStepInnerServiceSMOImpl.queryWorkflowSteps(workflowStepDto); if (workflowStepDtos != null) { for (WorkflowStepDto tmpWorkflowStepDto : workflowStepDtos) { deleteWorkflowStepAndStaff(cmdDataFlowContext, reqJson, tmpWorkflowStepDto); } } //修改 工作流程 WorkflowPo workflowPo = new WorkflowPo(); workflowPo.setFlowId(reqJson.getString("flowId")); workflowPo.setFlowName(reqJson.getString("flowName")); workflowPo.setCommunityId(reqJson.getString("communityId")); workflowPo.setStartNodeFinish(reqJson.getString("startNodeFinish")); workflowPo.setDescrible(reqJson.getString("describle")); //保存 工作流程步骤 JSONArray steps = reqJson.getJSONArray("steps"); String processDefinitionKey = ""; int flag = 0; if (steps != null && steps.size() > 0) { // 有步骤 JSONObject step = null; JSONObject subStaff = null; WorkflowStepStaffPo workflowStepStaffPo = null; List tmpWorkflowStepDtos = new ArrayList<>(); for (int stepIndex = 0; stepIndex < steps.size(); stepIndex++) { step = steps.getJSONObject(stepIndex); WorkflowStepPo workflowStepPo = new WorkflowStepPo(); workflowStepPo.setStepId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_flowId)); workflowStepPo.setCommunityId(workflowPo.getCommunityId()); workflowStepPo.setFlowId(workflowPo.getFlowId()); workflowStepPo.setSeq((stepIndex + 1) + ""); workflowStepPo.setType(step.getString("type")); workflowStepPo.setStoreId(reqJson.getString("storeId")); flag = workflowStepV1InnerServiceSMOImpl.saveWorkflowStep(workflowStepPo); if (flag < 1) { throw new CmdException("保存步骤失败"); } WorkflowStepDto tmpWorkflowStepDto = BeanConvertUtil.covertBean(workflowStepPo, WorkflowStepDto.class); //正常流程 List workflowStepStaffDtos = new ArrayList<>(); workflowStepStaffPo = new WorkflowStepStaffPo(); workflowStepStaffPo.setWssId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_wssId)); workflowStepStaffPo.setCommunityId(workflowPo.getCommunityId()); workflowStepStaffPo.setStaffId(step.getString("staffId")); workflowStepStaffPo.setStaffName(step.getString("staffName")); workflowStepStaffPo.setStepId(workflowStepPo.getStepId()); workflowStepStaffPo.setFlowType(reqJson.getString("flowType")); workflowStepStaffPo.setStaffRole(StringUtil.isEmpty(step.getString("staffRole")) ? "1001" : step.getString("staffRole")); if (!"1001".equals(workflowStepStaffPo.getStaffRole()) && workflowStepStaffPo.getStaffRole().startsWith("${")) { throw new IllegalArgumentException("采购人员或者物品领用人员必须指定人，不能是动态指定"); } flag = workflowStepStaffV1InnerServiceSMOImpl.saveWorkflowStepStaff(workflowStepStaffPo); if (flag < 1) { throw new CmdException("保存步骤失败"); } workflowStepStaffDtos.add(BeanConvertUtil.covertBean(workflowStepStaffPo, WorkflowStepStaffDto.class)); //会签流程 JSONArray subStaffs = step.getJSONArray("subStaff"); if (subStaffs != null && subStaffs.size() > 0) { for (int subStaffIndex = 0; subStaffIndex < subStaffs.size(); subStaffIndex++) { subStaff = subStaffs.getJSONObject(subStaffIndex); workflowStepStaffPo = new WorkflowStepStaffPo(); workflowStepStaffPo.setWssId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_wssId)); workflowStepStaffPo.setCommunityId(workflowPo.getCommunityId()); workflowStepStaffPo.setStaffId(subStaff.getString("staffId")); workflowStepStaffPo.setStaffName(subStaff.getString("staffName")); workflowStepStaffPo.setStepId(workflowStepPo.getStepId()); workflowStepStaffPo.setStaffRole(StringUtil.isEmpty(subStaff.getString("staffRole")) ? "1001" : subStaff.getString("staffRole")); flag = workflowStepStaffV1InnerServiceSMOImpl.saveWorkflowStepStaff(workflowStepStaffPo); if (flag < 1) { throw new CmdException("保存步骤失败"); } workflowStepStaffDtos.add(BeanConvertUtil.covertBean(workflowStepStaffPo, WorkflowStepStaffDto.class)); } } tmpWorkflowStepDto.setWorkflowStepStaffs(workflowStepStaffDtos); tmpWorkflowStepDtos.add(tmpWorkflowStepDto); } WorkflowDto workflowDto = BeanConvertUtil.covertBean(workflowPo, WorkflowDto.class); workflowDto.setWorkflowSteps(tmpWorkflowStepDtos); WorkflowDto tmpWorkflowDto = workflowInnerServiceSMOImpl.addFlowDeployment(workflowDto); processDefinitionKey = tmpWorkflowDto.getProcessDefinitionKey(); } else { processDefinitionKey = "-1"; } workflowPo.setProcessDefinitionKey(processDefinitionKey); flag = workflowV1InnerServiceSMOImpl.updateWorkflow(workflowPo); if (flag < 1) { throw new CmdException("保存步骤失败"); } cmdDataFlowContext.setResponseEntity(ResultVo.success()); } private void deleteWorkflowStepAndStaff(ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson, WorkflowStepDto workflowStepDto) { WorkflowStepStaffDto workflowStepStaffDto = new WorkflowStepStaffDto(); workflowStepStaffDto.setStepId(workflowStepDto.getStepId()); workflowStepStaffDto.setCommunityId(workflowStepDto.getCommunityId()); List workflowStepStaffDtos = workflowStepStaffInnerServiceSMOImpl.queryWorkflowStepStaffs(workflowStepStaffDto); WorkflowStepPo workflowStepPo = new WorkflowStepPo(); workflowStepPo.setCommunityId(workflowStepDto.getCommunityId()); workflowStepPo.setStepId(workflowStepDto.getStepId()); int flag = workflowStepV1InnerServiceSMOImpl.deleteWorkflowStep(workflowStepPo); if (flag < 1) { throw new CmdException("保存步骤失败"); } if (workflowStepStaffDtos == null) { return; } for (WorkflowStepStaffDto tmpWorkflowStepStaffDto : workflowStepStaffDtos) { WorkflowStepStaffPo workflowStepStaffPo = new WorkflowStepStaffPo(); workflowStepStaffPo.setCommunityId(workflowStepDto.getCommunityId()); workflowStepStaffPo.setWssId(tmpWorkflowStepStaffDto.getWssId()); flag = workflowStepStaffV1InnerServiceSMOImpl.deleteWorkflowStepStaff(workflowStepStaffPo); if (flag < 1) { throw new CmdException("保存步骤失败"); } } } }