add:工单创建

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/biz/ChangeFlowBiz.java

@@ -62,7 +62,7 @@ public class ChangeFlowBiz {
     @Autowired
     private FlowRpcService flowRpcService;
 
-    public Boolean createAndSubmit(ChangeFlowCreateReq changeFlowCreateReq) {
+    public List<String> createAndSubmit(ChangeFlowCreateReq changeFlowCreateReq) {
         // String uid = RequestLocalBean.getUid();
         String uid = "1";
         // String name = RequestLocalBean.getName();
@@ -98,11 +98,11 @@ public class ChangeFlowBiz {
         // 查询工单详情
         FlowDataDTO flowDataDTO = detailFlow(flowId);
         String nodeId = flowDataDTO.getFlowMeta().getCurrNodeDataList().get(0).getNodeId();
-        // 提交工单
-        // submitFlow(flowId, nodeId, flowCreateReqDTO);
         // 保存工单数据
         ChangeRecord changeRecord = buildRecord(flowId, nodeId, changeFlowCreateReq);
-        return changeFlowService.saveRecord(changeRecord);
+        changeFlowService.saveRecord(changeRecord);
+        // 如果发起人=变更负责人
+        return submitFlow(flowId, nodeId, flowCreateReqDTO);
     }
 
     private FlowDataDTO detailFlow(String flowId) {
@@ -130,7 +130,7 @@ public class ChangeFlowBiz {
         return flowCreateReqDTO;
     }
 
-    private String submitFlow(String flowId, String nodeId, FlowCreateReqDTO flowCreateReqDTO) {
+    private List<String> submitFlow(String flowId, String nodeId, FlowCreateReqDTO flowCreateReqDTO) {
         NodeSubmitReqDTO nodeSubmitReqDTO = new NodeSubmitReqDTO();
         nodeSubmitReqDTO.setFlowId(flowId);
         nodeSubmitReqDTO.setNodeId(nodeId);
@@ -153,7 +153,7 @@ public class ChangeFlowBiz {
                     submitResponse.getErrorMsg());
             throw ExceptionFactory.createBiz(ResponseCode.SUBMIT_FLOW_ERROR, submitResponse.getErrorMsg());
         }
-        return nextNodeIdList.get(0);
+        return nextNodeIdList;
     }
 
     private String createFlow(FlowCreateReqDTO flowCreateReqDTO) {

yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/flow/FlowxSubmitDTO.java

+/**
+ * @(#)WorkflowApproveDTO.java, 2021年1月19日.
+ *
+ * Copyright 2021 Netease, Inc. All rights reserved.
+ * NETEASE PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
+ */
+package com.netease.mail.yanxuan.change.integration.flow;
+
+import java.util.Map;
+
+public class FlowxSubmitDTO {
+
+    private String topoId;
+
+    /**
+     * 流程id
+     */
+    private String flowId;
+
+    /**
+     * 当前节点
+     */
+    private String currentNodeId;
+
+    /**
+     * 审核节点时是审核通过与否，自动执行节点时是执行成功与否
+     */
+    private boolean approved;
+
+    /**
+     * 用户id
+     */
+    private String uid;
+
+    /**
+     * 用户名
+     */
+    private String userName;
+
+    /**
+     * 业务数据
+     */
+    private String content;
+
+    /**
+     * 网关使用的判断条件传入
+     */
+    private Map<String, Object> paramMap;
+
+    /**
+     * 审核节点时是不通过理由，自动执行节点时是执行结果描述
+     */
+    private String rejectReason;
+
+    private String extension;
+
+    /**
+     * 操作结果
+     */
+    private String operateResult;
+
+    private String approveFormExtensionInfo;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    public String getApproveFormExtensionInfo() {
+        return approveFormExtensionInfo;
+    }
+
+    public void setApproveFormExtensionInfo(String approveFormExtensionInfo) {
+        this.approveFormExtensionInfo = approveFormExtensionInfo;
+    }
+
+    public String getOperateResult() {
+        return operateResult;
+    }
+
+    public void setOperateResult(String operateResult) {
+        this.operateResult = operateResult;
+    }
+
+    public String getTopoId() {
+        return topoId;
+    }
+
+    public void setTopoId(String topoId) {
+        this.topoId = topoId;
+    }
+
+    public String getFlowId() {
+        return flowId;
+    }
+
+    public void setFlowId(String flowId) {
+        this.flowId = flowId;
+    }
+
+    public String getCurrentNodeId() {
+        return currentNodeId;
+    }
+
+    public void setCurrentNodeId(String currentNodeId) {
+        this.currentNodeId = currentNodeId;
+    }
+
+    public boolean isApproved() {
+        return approved;
+    }
+
+    public void setApproved(boolean approved) {
+        this.approved = approved;
+    }
+
+    public String getRejectReason() {
+        return rejectReason;
+    }
+
+    public void setRejectReason(String rejectReason) {
+        this.rejectReason = rejectReason;
+    }
+
+    public String getExtension() {
+        return extension;
+    }
+
+    public void setExtension(String extension) {
+        this.extension = extension;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public Map<String, Object> getParamMap() {
+        return paramMap;
+    }
+
+    public void setParamMap(Map<String, Object> paramMap) {
+        this.paramMap = paramMap;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public void setContent(String content) {
+        this.content = content;
+    }
+
+    public String getUid() {
+        return uid;
+    }
+
+    public void setUid(String uid) {
+        this.uid = uid;
+    }
+
+    public String getUserName() {
+        return userName;
+    }
+
+    public void setUserName(String userName) {
+        this.userName = userName;
+    }
+}

yanxuan-qc-change-system-web/src/main/java/com/netease/mail/yanxuan/change/web/controller/ChangeFlowController.java

@@ -6,6 +6,8 @@
  */
 package com.netease.mail.yanxuan.change.web.controller;
 
+import java.util.List;
+
 import javax.validation.Valid;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -73,7 +75,7 @@ public class ChangeFlowController {
      * @return
      */
     @PostMapping("/create")
-    public AjaxResult<Boolean> createAndSubmit(@RequestBody @Valid ChangeFlowCreateReq changeFlowCreateReq) {
+    public AjaxResult<List<String>> createAndSubmit(@RequestBody @Valid ChangeFlowCreateReq changeFlowCreateReq) {
         log.info("[createAndSubmit] createAndSubmit req={}", JSON.toJSONString(changeFlowCreateReq));
         return AjaxResult.success(changeFlowBiz.createAndSubmit(changeFlowCreateReq));
     }