修改重跑时运行实例状态

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

@@ -591,6 +591,12 @@ public class ApiFlowServiceImpl implements ApiFlowService {
             //生成运行实例
             RunRecording newRunRecording = buildRunRecording(runRecording, triggerTime, reRunId, flow, userName);
 
+            runRecording.setFlowStatus(RunRecordingEnum.FLOW_STATUS_RUN_ING.getCode());
+            runRecording.setFlowRunResult(null);
+            runRecordingMapper.updateState(runRecording);
+            //将工作流下的节点改为运行中
+            jobTaskRunLogMapper.updateByFlowIdAndRunId(flow.getFlowId(), runInfo.getRunId());
+
             //生成新的工作流实例
             runRecordingMapper.saveRunRecording(newRunRecording);
             jobTaskMapper.saveJobTasks(jobTaskList);
@@ -616,6 +622,9 @@ public class ApiFlowServiceImpl implements ApiFlowService {
             if (dependNodeIdList != null && dependNodeIdList.size() > 0){
                 jobTask.setNodeDepend(Joiner.on(",").join(dependNodeIdList));
             }
+            //将节点对应的日志改为运行中
+            jobTaskRunLog.setRunCode(NodeRunStatusPropertyEnum.RUN_ING.getCode());
+            jobTaskRunLogMapper.updateJobTaskRunLog(jobTaskRunLog);
             jobTaskList.add(jobTask);
             //查询依赖于当前节点的下级节点
             List<Integer> childNodeIdList = nodeDependencyMapper.findSubNodeList(childNodeId);

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

@@ -152,4 +152,6 @@ public interface JobTaskRunLogMapper {
     List<JobTaskRunLog> findJavaTaskByTaskName(@Param("nodeIdList")List<Integer> nodeIdList, @Param("startTime")Date startTime, @Param("endTime")Date endTime);
 
     JobTaskRunLog findNewJavaTaskByJobName(Integer javaTaskId);
+
+    int updateByFlowIdAndRunId(@Param("flowId")Integer flowId, @Param("runId")String runId);
 }
\ No newline at end of file

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

@@ -636,4 +636,8 @@
     </set>
     where log_id = #{logId,jdbcType=INTEGER}
   </update>
+  <update id="updateByFlowIdAndRunId">
+    update job_task_run_log set run_code = '0'
+    where flow_id = #{flowId} and run_id = #{runId}
+  </update>
 </mapper>
\ No newline at end of file