feat:通过审批节点的 nodeId 查询 taskId

system/src/main/java/com/sdm/system/controller/SystemApproveController.java

@@ -56,6 +56,11 @@ public class SystemApproveController implements IApproveFeignClient {
         return  approveServer.queryNewApproveFlowStatus(flowId);
     }
 
+    @GetMapping("getTaskIdByNodeId")
+    public SdmResponse getTaskIdByNodeId(@RequestParam("processInstanceId") String processInstanceId, @RequestParam("nodeId") String nodeId) {
+        return  approveServer.getTaskIdByNodeId(processInstanceId, nodeId);
+    }
+
     /**
      * 根据flowId批量查询审批详情
      * @param flowIds

system/src/main/java/com/sdm/system/service/ISimulatinoApprovalService.java

@@ -61,6 +61,8 @@ public interface ISimulatinoApprovalService {
 
     SdmResponse queryNewApproveFlowStatus(String flowId);
 
+    SdmResponse getTaskIdByNodeId(String processInstanceId, String nodeId);
+
     SdmResponse queryBatchApproveFlowStatus(List<String> flowIds);
 
     /**

system/src/main/java/com/sdm/system/service/impl/SimulationApproveServiceImpl.java

@@ -57,6 +57,9 @@ public class SimulationApproveServiceImpl implements ISimulatinoApprovalService
     @Value("${cid.flow.queryNewApproveDetail}")
     private String queryNewApproveDetail;
 
+    @Value("${cid.flow.getTaskIdByNodeId}")
+    private String getTaskIdByNodeId;
+
     @Value("${cid.flow.stopApproveFlow}")
     private String stopFlowPath;
 
@@ -332,6 +335,30 @@ public class SimulationApproveServiceImpl implements ISimulatinoApprovalService
         return sdmResponse;
     }
 
+    @Override
+    public SdmResponse getTaskIdByNodeId(String processInstanceId, String nodeId) {
+        JSONObject paramJson = new JSONObject();
+        paramJson.put("nodeId",nodeId);
+        paramJson.put("processInstanceId",processInstanceId);
+//        paramJson.put("tenantId",tenantId);
+        String url = cidUrl + getTaskIdByNodeId;
+
+        try {
+            String resultString = httpClientUtil.doPostJson(url, paramJson.toJSONString());
+            if (resultString != null && !resultString.isEmpty()) {
+                JSONObject resultJson = JSONObject.parseObject(resultString);
+                if (resultJson != null && resultJson.containsKey("success")) {
+                    if (resultJson.getBoolean("success")) {
+                        return SdmResponse.success(resultJson.get("data"));
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return SdmResponse.failed("根据nodeId查不到taskId");
+    }
+
     @Override
     public SdmResponse queryBatchApproveFlowStatus(List<String> flowIds) {
         SdmResponse  sdmResponse ;

system/src/main/resources/application-dev-190.yml

@@ -165,6 +165,7 @@ cid:
     queryFlowTemplate: /spdm-flow/listProcessByGroup
     queryApproveDetail: /spdm-flow/queryFlowNodeDetail
     queryNewApproveDetail: /spdm-flow/queryNewFlowNodeDetail
+    getTaskIdByNodeId: /spdm-flow/getTaskIdByNodeId
     stopApproveFlow: /spdm-flow/stopFlow
     group: SPDM
     # 单次批量查询cid审批流详情的条数

system/src/main/resources/application-dev-65.yml

@@ -165,6 +165,7 @@ cid:
     queryFlowTemplate: /spdm-flow/listProcessByGroup
     queryApproveDetail: /spdm-flow/queryFlowNodeDetail
     queryNewApproveDetail: /spdm-flow/queryNewFlowNodeDetail
+    getTaskIdByNodeId: /spdm-flow/getTaskIdByNodeId
     stopApproveFlow: /spdm-flow/stopFlow
     group: SPDM
     # 单次批量查询cid审批流详情的条数

system/src/main/resources/application-local.yml

@@ -165,6 +165,7 @@ cid:
     queryFlowTemplate: /spdm-flow/listProcessByGroup
     queryApproveDetail: /spdm-flow/queryFlowNodeDetail
     queryNewApproveDetail: /spdm-flow/queryNewFlowNodeDetail
+    getTaskIdByNodeId: /spdm-flow/getTaskIdByNodeId
     stopApproveFlow: /spdm-flow/stopFlow
     group: SPDM
     # 单次批量查询cid审批流详情的条数

system/src/main/resources/application-lyric.yml

@@ -165,6 +165,7 @@ cid:
     queryFlowTemplate: /spdm-flow/listProcessByGroup
     queryApproveDetail: /spdm-flow/queryFlowNodeDetail
     queryNewApproveDetail: /spdm-flow/queryNewFlowNodeDetail
+    getTaskIdByNodeId: /spdm-flow/getTaskIdByNodeId
     stopApproveFlow: /spdm-flow/stopFlow
     group: SPDM
     # 单次批量查询cid审批流详情的条数