Merge pull request #170 from stelin/1.x

Openjob API

openjob-common/pom.xml

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

openjob-common/src/test/java/io/openjob/common/util/DateUtilTest.java

@@ -15,7 +15,7 @@
 public class DateUtilTest {
     @Test
     public void testFormatDateByTimestamp() {
-        Integer dateTime = DateUtil.formatDateByTimestamp(DateUtil.timestamp());
+        Integer dateTime = DateUtil.formatDateByTimestamp(DateUtil.timestamp()* 1000);
         Integer HourTime = DateUtil.formatHourByTimestamp(DateUtil.timestamp());
 
         Assertions.assertNotNull(dateTime);

openjob-server/openjob-server-admin/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>openjob-server</artifactId>
         <groupId>io.openjob</groupId>
-        <version>1.0.7</version>
+        <version>1.0.8</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>openjob-server-admin</artifactId>

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/request/job/DeleteJobRequest.java

@@ -6,7 +6,7 @@
 import javax.validation.constraints.NotNull;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Data

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/request/job/ListJobRequest.java

@@ -9,7 +9,7 @@
 import javax.validation.constraints.NotNull;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Data

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/request/job/UpdateJobStatusRequest.java

@@ -6,7 +6,7 @@
 import javax.validation.constraints.NotNull;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Data

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/service/JobService.java

@@ -17,7 +17,7 @@
 import io.openjob.server.common.vo.PageVO;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 public interface JobService {

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/service/impl/AppServiceImpl.java

@@ -34,7 +34,7 @@
 import java.util.stream.Collectors;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Service

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/service/impl/JobServiceImpl.java

@@ -66,7 +66,7 @@
 import java.util.stream.Collectors;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Slf4j

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/vo/job/ListJobVO.java

@@ -4,7 +4,7 @@
 import lombok.Data;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Data

openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/vo/job/UpdateJobStatusVO.java

@@ -3,7 +3,7 @@
 import lombok.Data;
 
 /**
- * @author zhenghongyang <[email protected]>
+ * @author zhenghongyang [email protected]
  * @since 1.0.0
  */
 @Data

openjob-server/openjob-server-alarm/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>openjob-server</artifactId>
         <groupId>io.openjob</groupId>
-        <version>1.0.7</version>
+        <version>1.0.8</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>openjob-server-alarm</artifactId>

openjob-server/openjob-server-cluster/pom.xml

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

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/ClusterServer.java

@@ -8,7 +8,7 @@
 import akka.routing.RoundRobinPool;
 import com.typesafe.config.Config;
 import io.openjob.common.constant.AkkaConstant;
-import io.openjob.server.cluster.manager.FailManager;
+import io.openjob.server.cluster.common.FailCommon;
 import io.openjob.server.cluster.service.ClusterService;
 import io.openjob.server.cluster.service.JoinService;
 import io.openjob.server.common.ClusterContext;
@@ -29,16 +29,16 @@ public class ClusterServer {
     private final ActorSystem actorSystem;
     private final SchedulerProperties schedulerProperties;
     private final JoinService joinService;
-    private final FailManager failManager;
+    private final FailCommon failCommon;
     private final ClusterService clusterService;
 
     @Autowired
-    public ClusterServer(ActorSystem actorSystem, SchedulerProperties schedulerProperties, JoinService joinService, FailManager failManager, ClusterService clusterService) {
+    public ClusterServer(ActorSystem actorSystem, SchedulerProperties schedulerProperties, JoinService joinService, FailCommon failCommon, ClusterService clusterService) {
         this.actorSystem = actorSystem;
         this.schedulerProperties = schedulerProperties;
         this.joinService = joinService;
 
-        this.failManager = failManager;
+        this.failCommon = failCommon;
         this.clusterService = clusterService;
     }
 
@@ -148,7 +148,7 @@ private void registerCoordinatedShutdown() {
                 .addTask(CoordinatedShutdown.PhaseServiceUnbind(),
                         "coordinated-shutdown-hook",
                         () -> {
-                            this.failManager.shutdown(ClusterContext.getCurrentNode());
+                            this.failCommon.shutdown(ClusterContext.getCurrentNode());
                             return Future.successful(Done.done());
                         });
     }

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/manager/FailManager.java → openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/common/FailCommon.java

@@ -1,4 +1,4 @@
-package io.openjob.server.cluster.manager;
+package io.openjob.server.cluster.common;
 
 import com.google.common.collect.Maps;
 import io.openjob.common.OpenjobSpringContext;
@@ -33,15 +33,15 @@
  */
 @Slf4j
 @Component
-public class FailManager {
+public class FailCommon {
     private final ServerDAO serverDAO;
     private final JobSlotsDAO jobSlotsDAO;
     private final ClusterProperties clusterProperties;
     private final RefreshData refreshData;
     private final Scheduler scheduler;
 
     @Autowired
-    public FailManager(ServerDAO serverDAO, JobSlotsDAO jobSlotsDAO, ClusterProperties clusterProperties, RefreshData refreshData, Scheduler scheduler) {
+    public FailCommon(ServerDAO serverDAO, JobSlotsDAO jobSlotsDAO, ClusterProperties clusterProperties, RefreshData refreshData, Scheduler scheduler) {
         this.serverDAO = serverDAO;
         this.jobSlotsDAO = jobSlotsDAO;
         this.clusterProperties = clusterProperties;

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/manager/JoinManager.java → openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/common/JoinCommon.java

@@ -1,4 +1,4 @@
-package io.openjob.server.cluster.manager;
+package io.openjob.server.cluster.common;
 
 import com.google.common.collect.Maps;
 import io.openjob.common.OpenjobSpringContext;
@@ -29,7 +29,7 @@
  */
 @Slf4j
 @Component
-public class JoinManager {
+public class JoinCommon {
     private final ServerDAO serverDAO;
     private final JobSlotsDAO jobSlotsDAO;
     private final RefreshData refreshData;
@@ -39,7 +39,7 @@ public class JoinManager {
      * Refresh status.
      */
     @Autowired
-    public JoinManager(ServerDAO serverDAO, JobSlotsDAO jobSlotsDAO, RefreshData refreshData, ClusterProperties clusterProperties) {
+    public JoinCommon(ServerDAO serverDAO, JobSlotsDAO jobSlotsDAO, RefreshData refreshData, ClusterProperties clusterProperties) {
         this.serverDAO = serverDAO;
         this.jobSlotsDAO = jobSlotsDAO;
         this.refreshData = refreshData;

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/dto/WorkerHeartbeatReqDTO.java

@@ -0,0 +1,25 @@
+package io.openjob.server.cluster.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class WorkerHeartbeatReqDTO {
+    private Long appId;
+
+    private String appName;
+
+    private String address;
+
+    private String version;
+
+    /**
+     * Running job instance ids.
+     */
+    private List<Long> runningJobInstanceIds;
+}

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/dto/WorkerHeartbeatRespDTO.java

@@ -0,0 +1,28 @@
+package io.openjob.server.cluster.dto;
+
+import lombok.Data;
+
+import java.util.Set;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class WorkerHeartbeatRespDTO {
+
+    /**
+     * Worker address list.
+     */
+    private Set<String> workerAddressList;
+
+    /**
+     * Cluster version
+     */
+    private Long clusterVersion;
+
+    /**
+     * Cluster delay version
+     */
+    private Long clusterDelayVersion;
+}

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/dto/WorkerJobInstanceStatusReqDTO.java

@@ -0,0 +1,47 @@
+package io.openjob.server.cluster.dto;
+
+import io.openjob.common.constant.FailStatusEnum;
+import io.openjob.common.constant.InstanceStatusEnum;
+import lombok.Data;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class WorkerJobInstanceStatusReqDTO {
+    /**
+     * Job id.
+     */
+    private Long jobId;
+
+    /**
+     * Job instance id.
+     */
+    private Long jobInstanceId;
+
+    /**
+     * Current circleId.
+     * Only for second delay task.
+     */
+    private Long circleId;
+
+    /**
+     * Job instance status.
+     *
+     * @see InstanceStatusEnum
+     */
+    private Integer status;
+
+    /**
+     * Fail status
+     *
+     * @see FailStatusEnum#getStatus()
+     */
+    private Integer failStatus;
+
+    /**
+     * Result
+     */
+    private String result;
+}

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/dto/WorkerJobInstanceStatusRespDTO.java

@@ -0,0 +1,11 @@
+package io.openjob.server.cluster.dto;
+
+import lombok.Data;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class WorkerJobInstanceStatusRespDTO {
+}

openjob-server/openjob-server-cluster/src/main/java/io/openjob/server/cluster/dto/WorkerJobInstanceTaskBatchReqDTO.java

@@ -0,0 +1,80 @@
+package io.openjob.server.cluster.dto;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class WorkerJobInstanceTaskBatchReqDTO {
+    private List<WorkerJobInstanceTaskReqDTO> taskRequestList;
+
+    @Data
+    public static class WorkerJobInstanceTaskReqDTO {
+        /**
+         * Job id.
+         */
+        private Long jobId;
+
+        /**
+         * Job instance id.
+         */
+        private Long jobInstanceId;
+
+        /**
+         * Dispatch version
+         */
+        private Long dispatchVersion;
+
+        /**
+         * Only for second delay task.
+         */
+        private Long circleId;
+
+        /**
+         * Task unique id.
+         * like 'jobId_instanceId_taskId_circleId'
+         */
+        private String taskId;
+
+        /**
+         * Task parent unique id.
+         * like 'jobId_instanceId_taskId_circleId'
+         */
+        private String parentTaskId;
+
+        /**
+         * Task name.
+         * Only for map reduce task.
+         */
+        private String taskName;
+
+        /**
+         * Task status.
+         */
+        private Integer status;
+
+        /**
+         * Task result.
+         */
+        private String result;
+
+        /**
+         * Task worker address
+         */
+        private String workerAddress;
+
+        /**
+         * Task create time.
+         */
+        private Long createTime;
+
+        /**
+         * Task update time.
+         */
+        private Long updateTime;
+    }
+}