From aaf36b1773da67f6cef44d5f5958fafa1ec799fa Mon Sep 17 00:00:00 2001
From: zhou-hao <i@hsweb.me>
Date: Sun, 19 Aug 2018 22:58:38 +0800
Subject: [PATCH] add task module

---
 hsweb-task/hsweb-task-cluster/pom.xml         | 15 ++++++
 hsweb-task/hsweb-task-core/pom.xml            | 15 ++++++
 .../hswebframework/web/task/JobDetail.java    | 28 ++++++++++
 .../web/task/JobRepository.java               | 18 +++++++
 .../org/hswebframework/web/task/Task.java     | 54 +++++++++++++++++++
 .../hswebframework/web/task/TaskExecutor.java | 16 ++++++
 .../web/task/TaskOperationResult.java         | 21 ++++++++
 .../web/task/enums/TaskExecuteStatus.java     | 10 ++++
 .../web/task/events/TaskCreatedEvent.java     | 12 +++++
 .../task/events/TaskExecuteAfterEvent.java    | 14 +++++
 .../task/events/TaskExecuteBeforeEvent.java   | 14 +++++
 .../web/task/events/TaskFailedEvent.java      | 14 +++++
 .../task/events/TaskStatusChangedEvent.java   | 17 ++++++
 hsweb-task/hsweb-task-local/pom.xml           | 22 ++++++++
 hsweb-task/pom.xml                            | 21 ++++++++
 pom.xml                                       |  1 +
 16 files changed, 292 insertions(+)
 create mode 100644 hsweb-task/hsweb-task-cluster/pom.xml
 create mode 100644 hsweb-task/hsweb-task-core/pom.xml
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobDetail.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobRepository.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/Task.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskExecutor.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskOperationResult.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/enums/TaskExecuteStatus.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskCreatedEvent.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteAfterEvent.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteBeforeEvent.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskFailedEvent.java
 create mode 100644 hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskStatusChangedEvent.java
 create mode 100644 hsweb-task/hsweb-task-local/pom.xml
 create mode 100644 hsweb-task/pom.xml

diff --git a/hsweb-task/hsweb-task-cluster/pom.xml b/hsweb-task/hsweb-task-cluster/pom.xml
new file mode 100644
index 000000000..b27d557b2
--- /dev/null
+++ b/hsweb-task/hsweb-task-cluster/pom.xml
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hsweb-task</artifactId>
+        <groupId>org.hswebframework.web</groupId>
+        <version>3.0.0-RC-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>hsweb-task-cluster</artifactId>
+
+
+</project>
\ No newline at end of file
diff --git a/hsweb-task/hsweb-task-core/pom.xml b/hsweb-task/hsweb-task-core/pom.xml
new file mode 100644
index 000000000..ffe8866b6
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/pom.xml
@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hsweb-task</artifactId>
+        <groupId>org.hswebframework.web</groupId>
+        <version>3.0.0-RC-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>hsweb-task-core</artifactId>
+
+
+</project>
\ No newline at end of file
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobDetail.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobDetail.java
new file mode 100644
index 000000000..c0a6aa51c
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobDetail.java
@@ -0,0 +1,28 @@
+package org.hswebframework.web.task;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+public class JobDetail {
+
+    private String id;
+
+    private String name;
+
+    private String description;
+
+    private String type;
+
+    private long executeTimeOut;
+
+    private long retryTimes;
+
+    private long retryInterval;
+
+    private boolean parallel;
+
+    private String content;
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobRepository.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobRepository.java
new file mode 100644
index 000000000..4a583a623
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/JobRepository.java
@@ -0,0 +1,18 @@
+package org.hswebframework.web.task;
+
+public interface JobRepository {
+
+
+    JobDetail findById(String id);
+
+    JobDetail save(JobDetail detail);
+
+    JobDetail update(JobDetail detail);
+
+    JobDetail delete(JobDetail detail);
+
+    void enable(String id);
+
+    void disable(String id);
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/Task.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/Task.java
new file mode 100644
index 000000000..b130cf82f
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/Task.java
@@ -0,0 +1,54 @@
+package org.hswebframework.web.task;
+
+import lombok.SneakyThrows;
+import org.hswebframework.web.task.enums.TaskExecuteStatus;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicReference;
+import java.util.function.Consumer;
+
+public interface Task {
+
+    String getId();
+
+    String getJobId();
+
+    JobDetail getJob();
+
+    long getLastExecuteTime();
+
+    long getCreateTime();
+
+    TaskExecuteStatus getStatus();
+
+    String getCreator();
+
+    String getSubmitor();
+
+    long getTimeout();
+
+    @SneakyThrows
+    default TaskOperationResult execute() {
+        CountDownLatch latch = new CountDownLatch(1);
+        AtomicReference<TaskOperationResult> reference = new AtomicReference<>();
+        execute(result -> {
+            reference.set(result);
+            latch.countDown();
+        });
+        latch.await(getTimeout(), TimeUnit.MILLISECONDS);
+        return reference.get();
+
+    }
+
+    void execute(Consumer<TaskOperationResult> onExecute);
+
+    void cancel(Consumer<TaskOperationResult> onExecute);
+
+    void suspend(Consumer<TaskOperationResult> onExecute);
+
+    void interrupt(Consumer<TaskOperationResult> onExecute);
+
+    void start(Consumer<TaskOperationResult> onExecute);
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskExecutor.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskExecutor.java
new file mode 100644
index 000000000..f54199f11
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskExecutor.java
@@ -0,0 +1,16 @@
+package org.hswebframework.web.task;
+
+import java.util.List;
+
+public interface TaskExecutor {
+
+    List<Task> findAll();
+
+    long total();
+
+    Task createTask(String jobId);
+
+    Task createTask(JobDetail jobDetail);
+
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskOperationResult.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskOperationResult.java
new file mode 100644
index 000000000..fceae38f0
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/TaskOperationResult.java
@@ -0,0 +1,21 @@
+package org.hswebframework.web.task;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.hswebframework.web.task.enums.TaskExecuteStatus;
+
+@Getter
+@Setter
+public class TaskOperationResult {
+    private String taskId;
+
+    private String jobId;
+
+    private TaskExecuteStatus status;
+
+    private boolean success;
+
+    private Throwable cause;
+
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/enums/TaskExecuteStatus.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/enums/TaskExecuteStatus.java
new file mode 100644
index 000000000..169454be3
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/enums/TaskExecuteStatus.java
@@ -0,0 +1,10 @@
+package org.hswebframework.web.task.enums;
+
+public enum TaskExecuteStatus {
+    success,
+    failed,
+    running,
+    suspend,
+    interrupt,
+    starting;
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskCreatedEvent.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskCreatedEvent.java
new file mode 100644
index 000000000..ee7f1bfe6
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskCreatedEvent.java
@@ -0,0 +1,12 @@
+package org.hswebframework.web.task.events;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.hswebframework.web.task.Task;
+
+@AllArgsConstructor
+@Getter
+public class TaskCreatedEvent {
+    private Task task;
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteAfterEvent.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteAfterEvent.java
new file mode 100644
index 000000000..07bb9fc37
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteAfterEvent.java
@@ -0,0 +1,14 @@
+package org.hswebframework.web.task.events;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.hswebframework.web.task.Task;
+
+@AllArgsConstructor
+@Getter
+public class TaskExecuteAfterEvent {
+    private Task task;
+
+    private String executionId;
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteBeforeEvent.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteBeforeEvent.java
new file mode 100644
index 000000000..30c6ce215
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskExecuteBeforeEvent.java
@@ -0,0 +1,14 @@
+package org.hswebframework.web.task.events;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.hswebframework.web.task.Task;
+
+@AllArgsConstructor
+@Getter
+public class TaskExecuteBeforeEvent {
+    private Task task;
+
+    private String executionId;
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskFailedEvent.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskFailedEvent.java
new file mode 100644
index 000000000..47f3d33e5
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskFailedEvent.java
@@ -0,0 +1,14 @@
+package org.hswebframework.web.task.events;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.hswebframework.web.task.Task;
+
+@AllArgsConstructor
+@Getter
+public class TaskFailedEvent {
+    private Task task;
+
+    protected Throwable cause;
+
+}
diff --git a/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskStatusChangedEvent.java b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskStatusChangedEvent.java
new file mode 100644
index 000000000..567effa6e
--- /dev/null
+++ b/hsweb-task/hsweb-task-core/src/main/java/org/hswebframework/web/task/events/TaskStatusChangedEvent.java
@@ -0,0 +1,17 @@
+package org.hswebframework.web.task.events;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.hswebframework.web.task.Task;
+import org.hswebframework.web.task.enums.TaskExecuteStatus;
+
+@AllArgsConstructor
+@Getter
+public class TaskStatusChangedEvent {
+
+    private TaskExecuteStatus before;
+
+    private TaskExecuteStatus after;
+
+    private Task task;
+}
diff --git a/hsweb-task/hsweb-task-local/pom.xml b/hsweb-task/hsweb-task-local/pom.xml
new file mode 100644
index 000000000..e248f8c78
--- /dev/null
+++ b/hsweb-task/hsweb-task-local/pom.xml
@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hsweb-task</artifactId>
+        <groupId>org.hswebframework.web</groupId>
+        <version>3.0.0-RC-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>hsweb-task-local</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.hswebframework.web</groupId>
+            <artifactId>hsweb-task-core</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+    </dependencies>
+
+</project>
\ No newline at end of file
diff --git a/hsweb-task/pom.xml b/hsweb-task/pom.xml
new file mode 100644
index 000000000..c178c9cdc
--- /dev/null
+++ b/hsweb-task/pom.xml
@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>hsweb-framework</artifactId>
+        <groupId>org.hswebframework.web</groupId>
+        <version>3.0.0-RC-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>hsweb-task</artifactId>
+    <packaging>pom</packaging>
+    <modules>
+        <module>hsweb-task-core</module>
+        <module>hsweb-task-cluster</module>
+        <module>hsweb-task-local</module>
+    </modules>
+
+
+</project>
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 6853d46e5..b0c323332 100644
--- a/pom.xml
+++ b/pom.xml
@@ -39,6 +39,7 @@
         <module>hsweb-examples</module>
         <module>hsweb-boost</module>
         <module>hsweb-thirdparty</module>
+        <module>hsweb-task</module>
     </modules>
 
     <packaging>pom</packaging>