⚡add delay

openjob-server/openjob-server-openapi/src/main/java/io/openjob/server/openapi/request/DelayInstanceStatusRequest.java

@@ -0,0 +1,66 @@
+package io.openjob.server.openapi.request;
+
+import io.openjob.common.constant.FailStatusEnum;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class DelayInstanceStatusRequest {
+
+    private List<DelayInstanceTaskRequest> list;
+
+    @Data
+    public static class DelayInstanceTaskRequest {
+        /**
+         * Topic
+         */
+        private String topic;
+
+        /**
+         * Delay id.
+         */
+        private Long delayId;
+
+        /**
+         * Delay pid
+         */
+        private Long delayPid;
+
+        /**
+         * Task id.
+         */
+        private String taskId;
+
+        /**
+         * Task status.
+         */
+        private Integer status;
+
+        /**
+         * Fail status
+         *
+         * @see FailStatusEnum#getStatus()
+         */
+        private Integer failStatus;
+
+        /**
+         * Task result.
+         */
+        private String result;
+
+        /**
+         * Worker address
+         */
+        private String workerAddress;
+
+        /**
+         * Complete time
+         */
+        private Long completeTime;
+    }
+}

openjob-server/openjob-server-openapi/src/main/java/io/openjob/server/openapi/request/DelayPullInstanceRequest.java

@@ -0,0 +1,21 @@
+package io.openjob.server.openapi.request;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class DelayPullInstanceRequest {
+    private String workerAddress;
+    private List<DelayPullTopicItemRequest> list;
+
+    @Data
+    public static class DelayPullTopicItemRequest {
+        private String topic;
+        private Integer size;
+    }
+}

openjob-server/openjob-server-openapi/src/main/java/io/openjob/server/openapi/request/DelayPullTopicRequest.java

@@ -0,0 +1,12 @@
+package io.openjob.server.openapi.request;
+
+import lombok.Data;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class DelayPullTopicRequest {
+    private String appName;
+}

openjob-server/openjob-server-openapi/src/main/java/io/openjob/server/openapi/vo/DelayInstanceStatusVO.java

@@ -0,0 +1,8 @@
+package io.openjob.server.openapi.vo;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+public class DelayInstanceStatusVO {
+}

openjob-server/openjob-server-openapi/src/main/java/io/openjob/server/openapi/vo/DelayPullInstanceVO.java

@@ -0,0 +1,32 @@
+package io.openjob.server.openapi.vo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class DelayPullInstanceVO {
+    private List<DelayPullInstanceItemVO> list;
+
+    @Data
+    public static class DelayPullInstanceItemVO {
+        private String topic;
+        private String taskId;
+        private Long delayId;
+        private Long delayPid;
+        private String delayParams;
+        private String delayExtra;
+        private String processorInfo;
+        private Integer failRetryTimes;
+        private Integer failRetryInterval;
+        private Integer executeTimeout;
+        private Integer blockingSize;
+        private Integer concurrency;
+        private Integer failTopicEnable;
+        private Integer failTopicConcurrency;
+    }
+}

openjob-server/openjob-server-openapi/src/main/java/io/openjob/server/openapi/vo/DelayPullTopicVO.java

@@ -0,0 +1,28 @@
+package io.openjob.server.openapi.vo;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author stelin [email protected]
+ * @since 1.0.8
+ */
+@Data
+public class DelayPullTopicVO {
+    private List<DelayTopicVO> topicList;
+
+    @Data
+    public static class DelayTopicVO {
+        private Long id;
+        private Long pid;
+        private String topic;
+        private String processorInfo;
+        private Integer failRetryTimes;
+        private Integer failRetryInterval;
+        private Integer executeTimeout;
+        private Integer concurrency;
+        private Integer failTopicEnable;
+        private Integer failTopicConcurrency;
+    }
+}