不是暂停的实例也能开始暂停

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

@@ -1685,15 +1685,12 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         String flowName = stopFlowParam.getFlowName();
         ValidationUtil.dataNotBank(flowName, "工作流名称不允许为空！");
 
-        List<String> runIdList = Arrays.asList(runIds.split(","));
+        String[] runIdList = runIds.split(",");
         for (String runId : runIdList) {
-            List<RunRecording> runRecordList = runRecordingMapper.findStopRunCordByRunId(runId);
+            List<RunRecording> runRecordList = runRecordingMapper.findStopRunCordByRunId(runId,flowName);
+
+            ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(runRecordList), "该工作流不是暂停状态！");
 
-            //ValidationUtil.isTrueValidation(CollectionUtil.isEmpty(runRecordList), "该工作流不是暂停状态！");
-            if (CollectionUtil.isEmpty(runRecordList)) {
-                log.warn("---------运行记录{}，不存在暂停记录中！---", runId);
-                return;
-            }
             RunRecording mainRunRecording = runRecordList.stream().filter(runRecording -> flowName.equals(runRecording.getFlowName())).findFirst().orElse(null);
             Integer stopCount;
             if (mainRunRecording != null) {

byit-myth-core/myth-admin-core/src/main/java/com/byit/mapper/RunRecordingMapper.java

@@ -198,7 +198,7 @@ public interface RunRecordingMapper {
      * @param runId
      * @return
      */
-    List<RunRecording> findStopRunCordByRunId(String runId);
+    List<RunRecording> findStopRunCordByRunId(@Param("runId") String runId, @Param("flowName")String flowName);
 
     /**
      * 根据runid和flowid杀死运行实例

byit-myth-core/myth-admin-core/src/main/resources/mapper/RunRecordingMapper.xml

@@ -207,7 +207,7 @@
     select
     <include refid="Base_Column_List" />
     from run_recording
-    where run_id = #{runId,jdbcType=VARCHAR}
+    where run_id = #{runId,jdbcType=VARCHAR} and flow_name = #{flowName}
         and  schedule_type != 4
   </select>