工作流运行实例增加开始时间和结束时间

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/ClosingExampleThreadRunHelper.java

@@ -17,6 +17,7 @@ import org.springframework.context.ApplicationEventPublisherAware;
 import org.springframework.stereotype.Component;
 
 import javax.sql.DataSource;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -67,6 +68,7 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
                 runRecording.setFlowRunResult(runCode);
                 log.debug("----------------扫描到有完结的运行实例{},{}-------------",runCode, RunRecordingEnum.FLOW_STATUS_IS_END.getCode());
                 runRecording.setFlowStatus(RunRecordingEnum.FLOW_STATUS_IS_END.getCode());
+                runRecording.setEndTime(new Date());
                 runRecordingService.updateRunRecordingById(runRecording);
                 applicationEventPublisher.publishEvent(new EndFlowEvent(this,flowId));
             }

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/TaskThreadRunHelper.java

@@ -24,6 +24,7 @@ import org.springframework.stereotype.Component;
 
 import javax.sql.DataSource;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -190,6 +191,7 @@ public class TaskThreadRunHelper extends BaseThreadRunHelper {
         Integer flowId = thisJobTask.getFlowId();
         RunRecording runRecordingByFlowIdAndRunId = runRecordingService.findRunRecordingByFlowIdAndRunId(flowId, runId);
         runRecordingByFlowIdAndRunId.setFlowStatus(FlowPropertyEnum.FLOW_RUN_ING.getCode());
+        runRecordingByFlowIdAndRunId.setStartTime(new Date());
         runRecordingService.updateRunRecordingById(runRecordingByFlowIdAndRunId);
     }
 

byit-myth-rpc/src/main/java/com/byit/rpc/registry/impl/RegistryServiceRegistry.java

@@ -60,6 +60,20 @@ public class RegistryServiceRegistry extends ServiceRegistry {
         return registryClient.registry(registryDataList);
     }
 
+    public static void main(String[] args) throws InterruptedException {
+        /*for (int i = 0; i < 10; i++) {
+            Thread.sleep(1000);*/
+            RegistryClient registryClient = new RegistryClient("http://localhost:8080/myth-register", null, "myth-job", "test");
+            List<RegistryDataParamVO> registryDataList = new ArrayList<>();
+            RegistryDataParamVO registryDataParamVO = new RegistryDataParamVO("testRun","127.0.0.1:8989");
+            RegistryDataParamVO registryDataParamVO1 = new RegistryDataParamVO("testRun","127.0.0.1:8975");
+            registryDataList.add(registryDataParamVO);
+            registryDataList.add(registryDataParamVO1);
+            registryClient.registry(registryDataList);
+        //}
+
+    }
+
     @Override
     public boolean remove(Set<String> keys, String value) {
         if (keys==null || keys.size() == 0 || value == null) {