增加运行日志信息

byit-myth-admin/src/main/java/com/byit/api/ApiNodeController.java

@@ -2,6 +2,7 @@ package com.byit.api;
 
 import com.byit.dto.web.ResponseResult;
 import com.byit.model.JobTaskRunLog;
+import com.byit.model.JobTaskRunLogWithBLOBs;
 import com.byit.service.ApiNodeService;
 import io.swagger.annotations.Api;
 import lombok.extern.slf4j.Slf4j;
@@ -43,7 +44,7 @@ public class ApiNodeController {
 
     @PostMapping("runHistory")
     public ResponseResult runHistory(String nodeId){
-        List<JobTaskRunLog> jobTaskRunLogList = apiNodeService.runHistory(nodeId);
+        List<JobTaskRunLogWithBLOBs> jobTaskRunLogList = apiNodeService.runHistory(nodeId);
         return ResponseResult.ok(jobTaskRunLogList);
     }
 

byit-myth-admin/src/main/java/com/byit/service/ApiNodeService.java

 package com.byit.service;
 
 import com.byit.model.JobTaskRunLog;
+import com.byit.model.JobTaskRunLogWithBLOBs;
 
 import java.text.ParseException;
 import java.util.List;
@@ -24,7 +25,7 @@ public interface ApiNodeService {
      * @param nodeId
      * @return
      */
-    List<JobTaskRunLog> runHistory(String nodeId);
+    List<JobTaskRunLogWithBLOBs> runHistory(String nodeId);
 
     /**
      * 功能描述 自动发布任务的接口

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

@@ -151,12 +151,12 @@ public class ApiNodeServiceImpl implements ApiNodeService {
     }
 
     @Override
-    public List<JobTaskRunLog> runHistory(String nodeId) {
+    public List<JobTaskRunLogWithBLOBs> runHistory(String nodeId) {
         ValidationUtil.dataNotBank(nodeId, "nodeId不允许为空！");
 
         String runId = "REAL:EXEC:" + nodeId;
 
-        List<JobTaskRunLog> jobTaskRunLogList = jobTaskRunLogMapper.findByRunId(runId);
+        List<JobTaskRunLogWithBLOBs> jobTaskRunLogList = jobTaskRunLogMapper.findByRunId(runId);
 
         return jobTaskRunLogList;
     }
@@ -220,6 +220,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
         JavaTask oldJavaTask = javaTaskMapper.findByJobName(javaTask.getJobName());
         ValidationUtil.dataNotNull(oldJavaTask,javaTask.getJobName() + "的任务不存在！");
         javaTask.setUpdateTime(new Date());
+
         javaTaskMapper.updateByJobName(javaTask);
     }
 

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

@@ -117,7 +117,7 @@ public interface JobTaskRunLogMapper {
      * @param runId
      * @return
      */
-    List<JobTaskRunLog> findByRunId(String runId);
+    List<JobTaskRunLogWithBLOBs> findByRunId(String runId);
 
     /**
      * 查询运行汇总

byit-myth-core/myth-admin-core/src/main/java/com/byit/model/JobTaskRunLog.java

@@ -169,6 +169,11 @@ public class JobTaskRunLog implements Serializable {
     private String logFileName;
 
     /**
+     * 运行数据
+     */
+    private String runMsg;
+
+    /**
      * 是否上级运行成功时运行（0 是  1 否）
      */
     @ApiModelProperty("是否上级运行成功时运行（0 是  1 否）")

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

@@ -121,8 +121,10 @@
     where run_id = #{runId} and flow_name = #{flowName}
   </select>
 
-  <select id="findByRunId" resultMap="BaseResultMap">
+  <select id="findByRunId" resultMap="ResultMapWithBLOBs">
     select <include refid="Base_Column_List"/>
+    ,
+    <include refid="Blob_Column_List" />
     from job_task_run_log
     where run_id = #{runId}
     order by trigger_time desc