查询运行实例时增加一个操作人

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

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
 import com.byit.dto.api.JavaCallbackLogDto;
 import com.byit.dto.executor.PluginBeanJobInfo;
 import com.byit.dto.plugin.*;
+import com.byit.dto.recording.LoadScheduleCondition;
 import com.byit.dto.recording.SelectRecordingStatusCondition;
 import com.byit.dto.specials.RepairFlow;
 import com.byit.dto.specials.SpecialJobParam;
@@ -569,23 +570,11 @@ public class JobUtils {
     /**
      * 获取运行实例接口
      *
-     * @param startTime      开始时间   毫秒级别时间
-     * @param endTime        结束时间   毫秒级别时间
-     * @param workspaceName  工作空间名称
-     * @param flowName       工作流名称
-     * @param scheduleStatus 调度状态  1 未开始  2运行中  3暂停  4完成   多个以“,”隔开
-     * @param executeStatus  执行结果   1 成功  2 失败  3 补批成功  4 补批失败 5.kill   多个以“,”隔开
-     * @return
+     * @param loadScheduleCondition 查询条件
+     * @return 对应的数据
      */
-    public static ResponseResult loadScheduleResult(Long startTime, Long endTime, String workspaceName, String flowName, String scheduleStatus, String executeStatus) {
-        Map<String, Object> param = new HashMap<>();
-        param.put("startTime", startTime);
-        param.put("endTime", endTime);
-        param.put("workspaceName", workspaceName);
-        param.put("flowName", flowName);
-        param.put("scheduleStatus", scheduleStatus);
-        param.put("executeStatus", executeStatus);
-        String response = createHttpRequest(REQUEST_LOADSCHEDULE, "param=" + JSON.toJSONString(param));
+    public static ResponseResult loadScheduleResult(LoadScheduleCondition loadScheduleCondition) {
+        String response = createHttpRequest(REQUEST_LOADSCHEDULE, JSON.toJSONString(loadScheduleCondition, WriteClassName));
         log.debug("--------------------获取运行实例接口调用成功，结果为：{}------------------------", response);
         return JSON.parseObject(response, ResponseResult.class);
     }