1.0.7

openjob-common/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>openjob</artifactId>
         <groupId>io.openjob</groupId>
-        <version>1.0.6</version>
+        <version>1.0.7</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>openjob-common</artifactId>

openjob-common/src/main/java/io/openjob/common/constant/HttpMethodEnum.java

@@ -0,0 +1,25 @@
+package io.openjob.common.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Getter
+@AllArgsConstructor
+public enum HttpMethodEnum {
+    /**
+     * GET
+     */
+    FORM("GET"),
+
+    /**
+     * POST
+     */
+    JSON("POST"),
+    ;
+
+    private final String type;
+}

openjob-common/src/main/java/io/openjob/common/constant/InstanceStatusEnum.java

@@ -49,6 +49,16 @@ public enum InstanceStatusEnum {
     private final Integer status;
     private final String message;
 
+    /**
+     * Complete status.
+     */
+    public static final List<Integer> COMPLETE = Arrays.asList(
+            SUCCESS.getStatus(),
+            FAIL.getStatus(),
+            STOP.getStatus(),
+            CANCEL.getStatus()
+    );
+
     /**
      * Not complete status.
      */

openjob-common/src/main/java/io/openjob/common/constant/LogFieldConstant.java

@@ -21,6 +21,8 @@ public class LogFieldConstant {
 
     public static final String JOB_INSTANCE_TASK_ID = "job_instance_task_id";
 
+    public static final String JOB_DISPATCH_VERSION = "job_dispatch_version";
+
     public static final String TASK_ID = "job_instance_taskId";
 
     public static final String CIRCLE_ID = "circle_id";

openjob-common/src/main/java/io/openjob/common/constant/MediaTypeEnum.java

@@ -0,0 +1,25 @@
+package io.openjob.common.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@AllArgsConstructor
+@Getter
+public enum MediaTypeEnum {
+    /**
+     * Form
+     */
+    FORM("application/x-www-form-urlencoded"),
+
+    /**
+     * JSON
+     */
+    JSON("application/json"),
+    ;
+
+    private final String type;
+}

openjob-common/src/main/java/io/openjob/common/constant/RequestTypeEnum.java

@@ -0,0 +1,25 @@
+package io.openjob.common.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Getter
+@AllArgsConstructor
+public enum RequestTypeEnum {
+    /**
+     * Server
+     */
+    SERVER("server"),
+
+    /**
+     * Agent
+     */
+    AGENT("agent"),
+    ;
+
+    private final String type;
+}

openjob-common/src/main/java/io/openjob/common/constant/ResponseModeEnum.java

@@ -0,0 +1,60 @@
+package io.openjob.common.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Getter
+@AllArgsConstructor
+public enum ResponseModeEnum {
+    /**
+     * Http status
+     */
+    HTTP_STATUS("status"),
+
+    /**
+     * Json
+     */
+    HTTP_JSON("json"),
+
+    /**
+     * String
+     */
+    HTTP_STRING("string"),
+    ;
+
+    private final String mode;
+
+    /**
+     * Whether is status
+     *
+     * @param mode mode
+     * @return Boolean
+     */
+    public static Boolean isStatus(String mode) {
+        return HTTP_STATUS.getMode().equals(mode);
+    }
+
+    /**
+     * Whether is json
+     *
+     * @param mode mode
+     * @return Boolean
+     */
+    public static Boolean isJson(String mode) {
+        return HTTP_JSON.getMode().equals(mode);
+    }
+
+    /**
+     * Whether is string
+     *
+     * @param mode mode
+     * @return Boolean
+     */
+    public static Boolean isString(String mode) {
+        return HTTP_STRING.getMode().equals(mode);
+    }
+}

openjob-common/src/main/java/io/openjob/common/constant/TaskConstant.java

@@ -5,5 +5,34 @@
  * @since 1.0.0
  */
 public class TaskConstant {
-    public static final String REDUCE_PARENT_TASK_NAME = "reduce";
+
+    /**
+     * MR root task name
+     */
+    public static final String MAP_TASK_ROOT_NAME = "MR_TASK_ROOT";
+
+    /**
+     * MR reduce task name
+     */
+    public static final String MAP_TASK_REDUCE_NAME = "MR_TASK_REDUCE";
+
+    /**
+     * Broadcast task name
+     */
+    public static final String BROADCAST_NAME = "BROADCAST";
+
+    /**
+     * Sharding task name
+     */
+    public static final String SHARDING_NAME = "SHARDING";
+
+    /**
+     * Default parent task id
+     */
+    public static final String DEFAULT_PARENT_ID = "0_0_0_0_0";
+
+    /**
+     * Default circle id
+     */
+    public static final Long DEFAULT_CIRCLE_ID = 1L;
 }

openjob-common/src/main/java/io/openjob/common/constant/TimeExpressionTypeEnum.java

@@ -48,6 +48,10 @@ public static Boolean isCron(String type) {
         return CRON.getType().equals(type);
     }
 
+    public static Boolean isFixedRate(String type) {
+        return FIXED_RATE.getType().equals(type);
+    }
+
     public static Boolean isSecondDelay(String type) {
         return SECOND_DELAY.getType().equals(type);
     }

openjob-common/src/main/java/io/openjob/common/dto/HttpProcessorDTO.java

@@ -0,0 +1,73 @@
+package io.openjob.common.dto;
+
+import io.openjob.common.constant.HttpMethodEnum;
+import io.openjob.common.constant.MediaTypeEnum;
+import io.openjob.common.constant.RequestTypeEnum;
+import io.openjob.common.constant.ResponseModeEnum;
+import lombok.Data;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Data
+public class HttpProcessorDTO {
+
+    /**
+     * Http url
+     */
+    private String url;
+
+    /**
+     * Http method
+     *
+     * @see HttpMethodEnum#getType()
+     */
+    private String method;
+
+    /**
+     * Timeout(ms)
+     */
+    private Long timeout;
+
+    /**
+     * Content Type
+     *
+     * @see MediaTypeEnum#getType()
+     */
+    private String contentType;
+
+    /**
+     * Body
+     */
+    private String body;
+
+    /**
+     * Cookie
+     */
+    private String cookie;
+
+    /**
+     * Response mode
+     *
+     * @see ResponseModeEnum#getMode()
+     */
+    private String responseMode;
+
+    /**
+     * JSON => key
+     */
+    private String key;
+
+    /**
+     * JSON => value or string
+     */
+    private String value;
+
+    /**
+     * Request type
+     *
+     * @see RequestTypeEnum#getType()
+     */
+    private String requestType;
+}

openjob-common/src/main/java/io/openjob/common/request/ServerInstanceTaskChildListPullRequest.java

@@ -0,0 +1,35 @@
+package io.openjob.common.request;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * Second delay to pull the child instance task by task id
+ *
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Data
+public class ServerInstanceTaskChildListPullRequest implements Serializable {
+
+    /**
+     * Job instance id
+     */
+    private Long jobInstanceId;
+
+    /**
+     * Job dispatch version
+     */
+    private Long dispatchVersion;
+
+    /**
+     * Circle id
+     */
+    private Long circleId;
+
+    /**
+     * Task id
+     */
+    private String taskId;
+}

openjob-common/src/main/java/io/openjob/common/request/ServerInstanceTaskListPullRequest.java

@@ -0,0 +1,30 @@
+package io.openjob.common.request;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * Second delay to pull the latest instance task
+ *
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Data
+public class ServerInstanceTaskListPullRequest implements Serializable {
+
+    /**
+     * Job instance id
+     */
+    private Long jobInstanceId;
+
+    /**
+     * Job dispatch version
+     */
+    private Long dispatchVersion;
+
+    /**
+     * Circle id
+     */
+    private Long circleId;
+}

openjob-common/src/main/java/io/openjob/common/request/ServerStopInstanceTaskRequest.java

@@ -0,0 +1,32 @@
+package io.openjob.common.request;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.7
+ */
+@Data
+public class ServerStopInstanceTaskRequest implements Serializable {
+    /**
+     * Job instance id
+     */
+    private Long jobInstanceId;
+
+    /**
+     * Job dispatch version
+     */
+    private Long dispatchVersion;
+
+    /**
+     * Circle id
+     */
+    private Long circleId;
+
+    /**
+     * Task id
+     */
+    private String taskId;
+}