fixbug: 工单提交

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

@@ -127,6 +127,7 @@ public class ChangeFlowBiz {
         }
 
         NodeSubmitReqDTO nodeSubmitReqDTO = new NodeSubmitReqDTO();
+        nodeSubmitReqDTO.setFlowId(flowId);
         nodeSubmitReqDTO.setNodeId(flowDataDTO.getFlowMeta().getCurrNodeDataList().get(0).getNodeId());
         nodeSubmitReqDTO.setUid(flowCreateReqDTO.getUid());
         nodeSubmitReqDTO.setUserName(flowCreateReqDTO.getUserName());
@@ -134,9 +135,10 @@ public class ChangeFlowBiz {
         nodeSubmitReqDTO.setTopoId(flowCreateReqDTO.getTopoId());
         nodeSubmitReqDTO.setContent(flowCreateReqDTO.getContent());
         nodeSubmitReqDTO.setOperateResult(FlowxOperationEnum.SUBMIT.getName());
+        nodeSubmitReqDTO.setCreateTime(System.currentTimeMillis());
         List<String> nextNodeIdList;
         // 提交工单
-        AjaxResponse<List<String>> submitResponse = flowRpcService.submit(CommonConstants.FLOWX_PRODUCT, flowId);
+        AjaxResponse<List<String>> submitResponse = flowRpcService.submit(CommonConstants.FLOWX_PRODUCT, nodeSubmitReqDTO);
         if (ResponseCodeEnum.SUCCESS.getCode() == flowDetailResponse.getCode()) {
             nextNodeIdList = submitResponse.getData();
             log.info("[createAndSubmitFlow] nextNodeIdList={}", JSON.toJSONString(nextNodeIdList));

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

@@ -17,6 +17,7 @@ import org.springframework.web.bind.annotation.PostMapping;
 import com.netease.yanxuan.flowx.sdk.meta.controller.communal.AjaxResponse;
 import com.netease.yanxuan.flowx.sdk.meta.dto.base.FlowDataDTO;
 import com.netease.yanxuan.flowx.sdk.meta.dto.flow.FlowCreateReqDTO;
+import com.netease.yanxuan.flowx.sdk.meta.dto.flow.NodeSubmitReqDTO;
 import com.netease.yanxuan.missa.client.annotation.MissaClient;
 
 /**
@@ -41,6 +42,12 @@ public interface FlowRpcService {
     AjaxResponse<FlowDataDTO> getDetail(@PathVariable("product") String flowxProduct,
         @PathVariable("flowId") String flowId);
 
+    /**
+     * 工单提交
+     * @param flowxProduct
+     * @param nodeSubmitReqDTO
+     * @return
+     */
     @PostMapping(value = "/{product}/workOrderFlow/v1/submit")
-    AjaxResponse<List<String>> submit(@PathVariable("product") String flowxProduct, String flowId);
+    AjaxResponse<List<String>> submit(@PathVariable("product") String flowxProduct, NodeSubmitReqDTO nodeSubmitReqDTO);
 }