解决虚节点不支持多实例无法运行的BUG

byit-myth-admin/src/test/java/com/byit/FastDfsFileSystemTest.java

+package com.byit;
+
+import com.byit.filesystem.FastDfsFileSystem;
+import com.github.tobato.fastdfs.service.FastFileStorageClient;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.io.ByteArrayInputStream;
+import java.util.HashMap;
+
+@SpringBootTest(classes = AdminApplication.class)
+@RunWith(SpringRunner.class)
+public class FastDfsFileSystemTest {
+
+    @Autowired
+    private FastFileStorageClient fastFileStorageClient;
+
+    @Test
+    public void test(){
+        HashMap<String, String> stringStringHashMap = new HashMap<>();
+        stringStringHashMap.put("filename","hahah");
+        byte[] bytes = "nihao".getBytes();
+        ByteArrayInputStream byteInput = new ByteArrayInputStream(bytes);
+        System.out.println(fastFileStorageClient.uploadFile(byteInput,bytes.length, ".txt",null).getFullPath());
+    }
+}

byit-myth-core/myth-admin-core/src/main/java/com/byit/service/mapservice/impl/RunRecordingAndJobTaskServiceImpl.java

@@ -86,10 +86,15 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
         String hasManyInstance = flowExtendedConfiguration.getHasManyInstance();
         //如果虚节点设置为不支持多实例
         if (FlowPropertyEnum.NOT_MANY_INSTANCE.getCode().equals(hasManyInstance)) {
-            log.info("不支持多实例{}",virFlow);
+            log.info("不支持多实例{},查询对应的工作流是否处于运行中的状态",virFlow);
+            //查找是否有工作流正在运行中  true有  false没有
+            boolean runRecordingIsRunning = runRecordingService.findRunRecordingIsRunning(virFlow.getFlowId());
+            if(runRecordingIsRunning){
                 return;
             }
 
+        }
+
         virFlow.setScanMark("2");
         RunRecording mainRecording = runRecordingService.findRunRecordingByFlowIdAndRunId(jobTask.getFlowId(), jobTask.getRunId());
 

byit-myth-core/myth-core-common/src/main/java/com/byit/filesystem/FastDfsFileSystem.java

@@ -4,6 +4,7 @@ import com.github.tobato.fastdfs.FdfsClientConfig;
 import com.github.tobato.fastdfs.domain.MateData;
 import com.github.tobato.fastdfs.domain.StorePath;
 import com.github.tobato.fastdfs.proto.storage.DownloadByteArray;
+import com.github.tobato.fastdfs.service.DefaultFastFileStorageClient;
 import com.github.tobato.fastdfs.service.FastFileStorageClient;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.context.annotation.Import;
@@ -77,6 +78,8 @@ public class FastDfsFileSystem implements FileSystem {
     }
 
     public static void main(String[] args) {
+        FastFileStorageClient fastFileStorageClient = new DefaultFastFileStorageClient();
+
         System.out.println(getPath("ddmp/M00/00/09/CgB4Al6mSVSAHi-rAAAABhCiqmE437.log"));
     }
 }

byit-myth-executor/myth-executor-plugin/src/main/java/com/byit/utils/JobUtils.java

@@ -439,11 +439,7 @@ public class JobUtils {
         return JSON.parseObject(response, ResponseResult.class);
     }
 
-    public static void main(String[] args) {
-        JobUtils.setTOKEN("huangfu");
-        JobUtils.setRequestUrl("http://10.0.120.208:8998/myth-job-admin");
-        System.out.println(stopFlow("皇甫", "科星"));
-    }
+
 
     /**
      * 删除工作流
@@ -690,6 +686,12 @@ public class JobUtils {
         return JSON.parseObject(response, ResponseResult.class);
     }
 
+    public static void main(String[] args) {
+        JobUtils.setTOKEN("huangfu");
+        JobUtils.setRequestUrl("http://10.0.120.208:8998/myth-job-admin");
+        System.out.println(existWorkspace("test_0827_prod0000"));
+    }
+
     /**
      * 立即运行节点
      *