使用工作流名称开启工作流

byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowOperatingServiceImpl.java

@@ -132,7 +132,7 @@ public class ApiFlowOperatingServiceImpl implements ApiFlowOperatingService {
             List<WaitingRecord> waitingRecords = buildWaitingRecordList(flowByName, runId, nodeRelyDtoSet.size(), operator, repairTimeList);
             waitingRecords.forEach(waitingRecordMapper::insertSelective);
             List<RunRecording> runRecordings = buildRunRecordingList(waitingRecords);
-            List<WaitingTask> waitingTaskList = buildWaitingTaskResult(waitingRecords, nodeRelyDtoSet, paramCarrier);
+            List<WaitingTask> waitingTaskList = buildWaitingTaskResult(waitingRecords, nodeRelyDtoSet,specialJobParam.getPublicParam());
             runRecordings.forEach(runRecordingMapper::saveRunRecording);
             waitingTaskList.forEach(waitingTaskMapper::insertSelective);
         }
@@ -172,11 +172,13 @@ public class ApiFlowOperatingServiceImpl implements ApiFlowOperatingService {
                 log.error("补批日期不符合规范，例：20200101");
                 ValidationUtil.isTrueValidation(true, "补批日期不符合规范，例：20200101");
             }
-            RunParamWrapped runParamWrapped = JSON.parseObject(node.getRunParam(), RunParamWrapped.class);
+            RunParamWrapped runParamWrapped = JSON.parseObject(waitingTask.getRunParam(), RunParamWrapped.class);
             runParamWrapped.setPublicParamMap(publicParam);
             //补批只替换不是java的节点
             if (!NodeTypeEnum.JAVA.getCode().equals(waitingTask.getJobType())) {
                 if (StringUtils.isNotEmpty(waitingTask.getRunParam())) {
+
+
                     String param = PlaceholderUtils.paramPlaceholder(runParamWrapped.getPrivateParam(), repeatTime);
                     //设置替换完成后的参数
                     runParamWrapped.setPrivateParam(param);
@@ -200,10 +202,10 @@ public class ApiFlowOperatingServiceImpl implements ApiFlowOperatingService {
      * @param nodeRelyDtoSet 节点集合
      * @return 全部的节点信息
      */
-    private List<WaitingTask> buildWaitingTaskResult(List<WaitingRecord> waitingRecords, Set<NodeRelyDto> nodeRelyDtoSet, Map<String,String> publicParam) {
+    private List<WaitingTask> buildWaitingTaskResult(List<WaitingRecord> waitingRecords, Set<NodeRelyDto> nodeRelyDtoSet,Map<String,String> publicPram) {
         List<WaitingTask> waitingTaskListResult = new ArrayList<>(8);
         waitingRecords.forEach(waitingRecord -> {
-            List<WaitingTask> waitingTaskList = buildWaitingTask(waitingRecord, nodeRelyDtoSet,publicParam);
+            List<WaitingTask> waitingTaskList = buildWaitingTask(waitingRecord, nodeRelyDtoSet,publicPram);
             waitingTaskListResult.addAll(waitingTaskList);
         });
         return waitingTaskListResult;