查看运行日志接口开发

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

 package com.byit.api;
 
+import com.byit.model.vo.RunRecordingVo;
 import com.byit.service.ApiFlowService;
 import com.byit.service.FlowService;
 import io.swagger.annotations.Api;
@@ -10,6 +11,7 @@ import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
 import java.text.ParseException;
+import java.util.List;
 
 /**
  * @description: 工作流操作的API接口
@@ -104,4 +106,19 @@ public class ApiFlowController {
         return "SUCCESS";
     }
 
+    /**
+     *
+     * @param param  startTime
+     *               endTime
+     *               flowName
+     *               workspaceName
+     * @return
+     */
+    @PostMapping("loadScheduleResult")
+    @ApiOperation("加载运行记录")
+    public List<RunRecordingVo> loadScheduleResult(String param){
+        List<RunRecordingVo> result = apiFlowService.loadScheduleResult(param);
+        return result;
+    }
+
 }

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

 package com.byit.service;
 
 import com.byit.job.dto.plugin.PluginFlow;
+import com.byit.model.vo.RunRecordingVo;
 
 import java.text.ParseException;
+import java.util.List;
 
 /**
  * @description: 工作流的api请求业务处理接口
@@ -50,4 +52,11 @@ public interface ApiFlowService {
      * @param param
      */
     void reRunFlow(String param);
+
+    /**
+     * 加载运行记录
+     * @param param
+     * @return
+     */
+    List<RunRecordingVo> loadScheduleResult(String param);
 }

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

@@ -13,6 +13,7 @@ import com.byit.job.enums.plugin.PluginNodeTypeEnum;
 import com.byit.job.utils.CronExpression;
 import com.byit.mapper.*;
 import com.byit.model.*;
+import com.byit.model.vo.RunRecordingVo;
 import com.byit.service.ApiFlowService;
 import com.byit.util.ApiFlowDagCheck;
 import com.byit.utils.ValidationUtil;
@@ -590,6 +591,27 @@ public class ApiFlowServiceImpl implements ApiFlowService {
         jobTaskRunLogMapper.updateJobTaskRunLog(jobTaskRunLog);
     }
 
+    @Override
+    public List<RunRecordingVo> loadScheduleResult(String param){
+        ValidationUtil.dataNotBank(param, "请求参数不允许为空！");
+        JSONObject jsonObject = JSON.parseObject(param);
+        Long startTime = jsonObject.getLong("startTime");
+        ValidationUtil.dataNotNull(startTime, "开始时间不允许为空！");
+        Long endTime = jsonObject.getLong("endTime");
+        ValidationUtil.dataNotNull(endTime, "结束时间不允许为空！");
+
+        //TODO 最长不能超过60天
+
+        //获取工作空间名称
+        String workspaceName = jsonObject.getString("workspaceName");
+        ValidationUtil.dataNotBank(workspaceName, "工作空间名称不允许为空！");
+        //获取工作流名称
+        String flowName = jsonObject.getString("flowName");
+        ValidationUtil.dataNotBank(flowName, "工作流名称不允许为空！");
+        return null;
+    }
+
+
     /**
      * 工作流生成新版本
      * @param flow

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

+package com.byit.model.vo;
+
+import com.byit.model.JobTaskRunLog;
+import com.byit.model.RunRecording;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @description: 运行实例记录VO类
+ * @author: gml
+ * @create: 2020/2/28
+ */
+@Data
+public class RunRecordingVo extends RunRecording {
+
+    @ApiModelProperty("运行实例下的运行任务日志")
+    private List<JobTaskRunLog> jobTaskRunLogList;
+
+}