增加回调参数，增加JOBuTIL的接口

byit-myth-core/myth-admin-core/src/main/java/com/byit/task/JavaNodeExecutorTask.java

@@ -83,6 +83,11 @@ public class JavaNodeExecutorTask  implements TimerTask {
 
             request.setCallbackUrl(JSON.toJSONString(callUrlList));
             CommunicationParam communicationParam = new CommunicationParam();
+
+            communicationParam.setFlowId(mythJobTaskSchedule.getFlowId());
+            communicationParam.setHasMakeUp(mythJobTaskSchedule.getScheduleType()+"");
+            communicationParam.setRunId(mythJobTaskSchedule.getRunId());
+
             communicationParam.setExpand1("REAL:EXEC:"+jobTaskRunLogById.getLogId());
             communicationParam.setLogId(jobTaskRunLogById.getLogId()+"");
             communicationParam.setCallbackUrl(JSON.toJSONString(callUrlList));

byit-myth-core/myth-admin-core/src/main/java/com/byit/task/JavaTaskJobTask.java

@@ -55,6 +55,8 @@ public class JavaTaskJobTask implements TimerTask {
 
         request.setCallbackUrl(JSON.toJSONString(callUrlList));
         CommunicationParam communicationParam = new CommunicationParam();
+        communicationParam.setHasMakeUp(javaTask.getScheduleType()+"");
+
         communicationParam.setLogId(logId+"");
         communicationParam.setCallbackUrl(JSON.toJSONString(callUrlList));
         communicationParam.setBody(javaTask.getParam());

byit-myth-core/myth-dto-core/src/main/java/com/byit/dto/plugin/QualityCheckVo.java

+package com.byit.dto.plugin;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 数据质量审核专用DTO
+ *
+ * @author huangfu
+ * @date 2020年9月15日10:04:40
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class QualityCheckVo {
+
+    private String workspaceName;
+
+    private String flowName;
+}

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

@@ -210,6 +210,28 @@ public class JobUtils {
         return response;
     }
 
+    /**
+     * 基于工作空间和工作流名称暂停工作流
+     * @param qualityCheckVo
+     * @return
+     */
+    public static ResponseResult pauseTaskByFlowName(QualityCheckVo qualityCheckVo){
+        log.debug("-------------基于工作流名称暂停：{}----------------------",qualityCheckVo);
+        return null;
+    }
+
+
+    /**
+     * 基于工作空间和工作流名称开始工作流
+     * @param qualityCheckVo
+     * @return
+     */
+    public static ResponseResult startTaskByFlowName(QualityCheckVo qualityCheckVo){
+        log.debug("-------------基于工作流名称开始：{}----------------------",qualityCheckVo);
+        return null;
+    }
+
+
     public static ResponseResult findFlowResult(List<JobStatusDto> jobStatusDtos){
         log.debug("-------------查询对应工作流的运行状态----------------------");
         String response = createHttpRequest(FIND_FLOW_RESULT, "param=" + JSON.toJSONString(jobStatusDtos, WriteClassName));

byit-plugin-core/byit-plugin-rpc-common/src/main/java/com/byit/param/CommunicationParam.java

@@ -31,11 +31,18 @@ public class CommunicationParam implements Serializable {
      */
     private String expand2;
     /**
-     * 扩展字段3
+     * 扩展字段3  本次执行任务的runId  当该java任务在工作流的时候
      */
-    private String expand3;
+    private String runId;
     /**
-     * 扩展字段4
+     * 扩展字段4  本次任务是不是补批  1 正常跑批   2 重跑   3  补批  4  插件端立即运行  5  类quartz任务执行
      */
-    private String expand4;
+    private String hasMakeUp;
+
+
+    /**
+     * 工作流ID
+     */
+    private Integer flowId;
+
 }