diff --git a/README-zh.md b/README-zh.md
index 2e78a63d..3afef454 100644
--- a/README-zh.md
+++ b/README-zh.md
@@ -1,30 +1,62 @@
+
+
+
+
+
+
+
+ 一款分布式高性能任务调度框架
+
+
## 介绍
-Openjob 是一款分布式高性能任务调度框架,支持多种定时任务和延时任务,采用无中心化设计,支持无线扩容。
+Openjob 是一款分布式高性能任务调度框架,支持多种定时任务、延时任务、工作流设计,采用无中心化架构,底层使用一致性分片算法,支持无线扩容。
## 特性
##### 高可靠
-分布式无状态设计,Master/Worker 架构,只依赖一种数据库(MySQL/PostgreSQL/Oracle)
+分布式无状态设计,采用 Master/Worker 架构,只依赖一种数据库(MySQL/PostgreSQL/Oracle)
##### 高性能
-任务调度精确到秒级别,支持轻量级分布式计算,任务采用分片算法,支持无限扩容。
+任务调度精确到秒级别,支持轻量级分布式计算,底层使用一致性分片算法,支持无限扩容。
##### 定时调度
支持分布式定时任务、固定频率任务、高性能秒级任务、一次性任务定时调度。
##### 分布式计算
支持单机、广播、Map、MapReduce 和分片多种分布式编程模型,轻松实现大数据分布式计算。
##### 工作流
-内置工作流调度引擎,支持可视化 DAG,方便高效实现复杂任务调度。
+内置工作流调度引擎,支持可视化 DAG 设计,简单高效实现复杂任务调度。
##### 延时任务
-基于 Redis 实现高性能延时任务,同时支持延时任务多级存储、丰富的任务管理。
+基于 Redis 高性能延时任务,底层任务多级存储,提供丰富的任务管理。
##### 跨语言
-官方提供 Java/Go/PHP 多余支持,以及Spring Boot、Gin、Swoft 等常见框架整合。
+支持 Java/Go/PHP/Python 多语言 ,以及Spring Boot、Gin、Swoft 常见框架整合。
##### 权限管理
-命名空间设计,支持丰富的权限管理,精确到按钮级别。
+命名空间设计,丰富的按钮级别权限管理,。
##### 报警监控
全面的监控指标,丰富及时的报警方式,便于运维人员快速定位和解决线上问题。
+
+## 依赖
+
+```xml
+1.0.0
+
+ io.openjob.worker
+ openjob-worker-core
+ ${openjob.worker.version}
+
+
+
+
+ io.openjob.worker
+ openjob-worker-spring-boot-starter
+ ${openjob.worker.version}
+
+```
+
## 文档
-- 官网([https://openjob.io](https://openjob.io))
-- 文档([https://openjob.io/docs](https://openjob.io/docs/intro))
-- 体验([https://demo.openjob.io](https://demo.openjob.io))
- - openjob/123456
-## 交流
+- [官网](https://openjob.io)
+- [文档](https://openjob.io/docs/intro)
+- [试用](https://demo.openjob.io)
+## 联系
+* Mail list:
+ * swoft@qq.com
+- Online chat:
+ - [Gitter](https://gitter.im/openjob/openjob)
## 协议
-Please see [LICENSE](LICENSE)
+Openjob is under the Apache 2.0 license. See the [LICENSE](LICENSE) file for details.
diff --git a/README.md b/README.md
index 2019470b..6b76ba7a 100644
--- a/README.md
+++ b/README.md
@@ -50,12 +50,22 @@
- [Official documentation](https://openjob.io/docs/intro)
## Live demo
- Find the [live demo](https://demo.openjob.io) on our website.
+ - username: openjob
+ - password: openjob.io
## Contact
* Mail list:
- * openjob@vip.qq.com
* swoft@qq.com
- Online chat:
+## Openjob ecosystem
+- [Openjob Website](https://github.com/open-job/openjob-website) - Openjob official website
+- [Openjob UI](https://github.com/open-job/openjob-ui) - UI for Openjob
+- [Openjob Samples](https://github.com/open-job/openjob-samples) - Samples for Openjob
+- [Openjob Docker](https://github.com/open-job/openjob-docker) - Openjob integration with docker
+
+## Contributors
+This project exists thanks to all the people who contribute. [[Contributors](https://github.com/open-job/openjob/graphs/contributors)].
+
## License
Openjob is under the Apache 2.0 license. See the [LICENSE](LICENSE) file for details.
diff --git a/openjob-common/pom.xml b/openjob-common/pom.xml
index bec64ab9..f9d79f98 100644
--- a/openjob-common/pom.xml
+++ b/openjob-common/pom.xml
@@ -10,6 +10,10 @@
4.0.0
openjob-common
+
+ 5.3.0
+
+
org.springframework
@@ -19,7 +23,7 @@
com.esotericsoftware.kryo
kryo5
- 5.3.0
+ ${kryo.version}
diff --git a/openjob-common/src/main/java/io/openjob/common/SpringContext.java b/openjob-common/src/main/java/io/openjob/common/SpringContext.java
index e7c47fb6..58da8f01 100644
--- a/openjob-common/src/main/java/io/openjob/common/SpringContext.java
+++ b/openjob-common/src/main/java/io/openjob/common/SpringContext.java
@@ -7,7 +7,7 @@
import org.springframework.lang.Nullable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class SpringContext implements ApplicationContextAware {
@@ -26,13 +26,14 @@ public static T getBean(String name, Class type) {
return applicationContext.getBean(name, type);
}
+ public static Object getBean(String name) {
+ return applicationContext.getBean(name);
+ }
+
public static Boolean containsBean(String name) {
return applicationContext.containsBean(name);
}
- public static Object getBean(String name) {
- return applicationContext.getBean(name);
- }
public static String[] getBeanNamesForType(@Nullable Class> type, boolean includeNonSingletons, boolean allowEagerInit) {
return applicationContext.getBeanNamesForType(type, includeNonSingletons, allowEagerInit);
diff --git a/openjob-common/src/main/java/io/openjob/common/actor/BaseActor.java b/openjob-common/src/main/java/io/openjob/common/actor/BaseActor.java
index bbb2e854..00c4e2cc 100644
--- a/openjob-common/src/main/java/io/openjob/common/actor/BaseActor.java
+++ b/openjob-common/src/main/java/io/openjob/common/actor/BaseActor.java
@@ -7,7 +7,7 @@
import scala.runtime.BoxedUnit;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Slf4j
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/AkkaConstant.java b/openjob-common/src/main/java/io/openjob/common/constant/AkkaConstant.java
index 85f97171..71bf8ca9 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/AkkaConstant.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/AkkaConstant.java
@@ -1,7 +1,7 @@
package io.openjob.common.constant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class AkkaConstant {
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/BoolIntEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/BoolIntEnum.java
index c6aebc1e..d247c206 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/BoolIntEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/BoolIntEnum.java
@@ -4,7 +4,7 @@
import lombok.Getter;
/**
- * @author inhere
+ * @author inhere in.798@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/CommonConstant.java b/openjob-common/src/main/java/io/openjob/common/constant/CommonConstant.java
index 369e398b..abb1c9d8 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/CommonConstant.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/CommonConstant.java
@@ -1,7 +1,7 @@
package io.openjob.common.constant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class CommonConstant {
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/DelayConstant.java b/openjob-common/src/main/java/io/openjob/common/constant/DelayConstant.java
index 0e154237..0adc833e 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/DelayConstant.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/DelayConstant.java
@@ -1,7 +1,7 @@
package io.openjob.common.constant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class DelayConstant {
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/ExecuteTypeEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/ExecuteTypeEnum.java
index 2be3f244..c3114853 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/ExecuteTypeEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/ExecuteTypeEnum.java
@@ -4,7 +4,7 @@
import lombok.Getter;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/InstanceStatusEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/InstanceStatusEnum.java
index bc385321..b7fc2e65 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/InstanceStatusEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/InstanceStatusEnum.java
@@ -8,7 +8,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/LogFieldConstant.java b/openjob-common/src/main/java/io/openjob/common/constant/LogFieldConstant.java
index b912b2ce..725c2053 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/LogFieldConstant.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/LogFieldConstant.java
@@ -1,7 +1,7 @@
package io.openjob.common.constant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class LogFieldConstant {
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/ProcessorTypeEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/ProcessorTypeEnum.java
index 3a23ddc5..ef86b929 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/ProcessorTypeEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/ProcessorTypeEnum.java
@@ -4,7 +4,7 @@
import lombok.Getter;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/ProtocolTypeEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/ProtocolTypeEnum.java
index 4ff6d901..f081f85d 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/ProtocolTypeEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/ProtocolTypeEnum.java
@@ -4,7 +4,7 @@
import lombok.Getter;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/StatusEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/StatusEnum.java
index e9ee8507..409d0e08 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/StatusEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/StatusEnum.java
@@ -4,7 +4,7 @@
import lombok.Getter;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@AllArgsConstructor
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/TaskConstant.java b/openjob-common/src/main/java/io/openjob/common/constant/TaskConstant.java
index b9a5b31f..d960065f 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/TaskConstant.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/TaskConstant.java
@@ -1,7 +1,7 @@
package io.openjob.common.constant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class TaskConstant {
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/TaskStatusEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/TaskStatusEnum.java
index 6e6ae802..bb02a6a2 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/TaskStatusEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/TaskStatusEnum.java
@@ -8,7 +8,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/constant/TimeExpressionTypeEnum.java b/openjob-common/src/main/java/io/openjob/common/constant/TimeExpressionTypeEnum.java
index 36828f92..e06c6d10 100644
--- a/openjob-common/src/main/java/io/openjob/common/constant/TimeExpressionTypeEnum.java
+++ b/openjob-common/src/main/java/io/openjob/common/constant/TimeExpressionTypeEnum.java
@@ -7,7 +7,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-common/src/main/java/io/openjob/common/context/Node.java b/openjob-common/src/main/java/io/openjob/common/context/Node.java
index 60c1d3f0..af36fbe0 100644
--- a/openjob-common/src/main/java/io/openjob/common/context/Node.java
+++ b/openjob-common/src/main/java/io/openjob/common/context/Node.java
@@ -3,7 +3,7 @@
import lombok.Data;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/context/Slots.java b/openjob-common/src/main/java/io/openjob/common/context/Slots.java
index 0ac4698d..a6d8f057 100644
--- a/openjob-common/src/main/java/io/openjob/common/context/Slots.java
+++ b/openjob-common/src/main/java/io/openjob/common/context/Slots.java
@@ -5,7 +5,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/dto/JobInstanceDTO.java b/openjob-common/src/main/java/io/openjob/common/dto/JobInstanceDTO.java
index 1b84ee6e..61f08785 100644
--- a/openjob-common/src/main/java/io/openjob/common/dto/JobInstanceDTO.java
+++ b/openjob-common/src/main/java/io/openjob/common/dto/JobInstanceDTO.java
@@ -3,7 +3,7 @@
import lombok.Data;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/kryo/KryoSerializer.java b/openjob-common/src/main/java/io/openjob/common/kryo/KryoSerializer.java
index 7976c77c..98065907 100644
--- a/openjob-common/src/main/java/io/openjob/common/kryo/KryoSerializer.java
+++ b/openjob-common/src/main/java/io/openjob/common/kryo/KryoSerializer.java
@@ -4,7 +4,7 @@
import io.openjob.common.util.KryoUtil;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @see akka https://doc.akka.io/docs/akka/current/serialization.html
* @since 1.0.0
*/
diff --git a/openjob-common/src/main/java/io/openjob/common/request/ServerCheckTaskMasterRequest.java b/openjob-common/src/main/java/io/openjob/common/request/ServerCheckTaskMasterRequest.java
index 340be6fb..d56fd68d 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/ServerCheckTaskMasterRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/ServerCheckTaskMasterRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/ServerDelayInstanceStopRequest.java b/openjob-common/src/main/java/io/openjob/common/request/ServerDelayInstanceStopRequest.java
index 5495c977..6d12f92a 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/ServerDelayInstanceStopRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/ServerDelayInstanceStopRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/ServerStopJobInstanceRequest.java b/openjob-common/src/main/java/io/openjob/common/request/ServerStopJobInstanceRequest.java
index e72cb868..18305810 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/ServerStopJobInstanceRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/ServerStopJobInstanceRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/ServerSubmitJobInstanceRequest.java b/openjob-common/src/main/java/io/openjob/common/request/ServerSubmitJobInstanceRequest.java
index e3d354a1..94266892 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/ServerSubmitJobInstanceRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/ServerSubmitJobInstanceRequest.java
@@ -6,14 +6,17 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
public class ServerSubmitJobInstanceRequest implements Serializable {
private Long jobId;
private Long jobInstanceId;
+ private String jobParamType;
private String jobParams;
+ private String jobExtendParamsType;
+ private String jobExtendParams;
private Long workflowId;
private String processorType;
private String processorInfo;
diff --git a/openjob-common/src/main/java/io/openjob/common/request/ServerWorkerHeartbeatRequest.java b/openjob-common/src/main/java/io/openjob/common/request/ServerWorkerHeartbeatRequest.java
index 4dc75ad9..03501b47 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/ServerWorkerHeartbeatRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/ServerWorkerHeartbeatRequest.java
@@ -3,7 +3,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class ServerWorkerHeartbeatRequest implements Serializable {
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayAddRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayAddRequest.java
index cc57c770..83e931f9 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayAddRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayAddRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
@@ -16,11 +16,6 @@ public class WorkerDelayAddRequest implements Serializable {
*/
private Long deliveryId;
- /**
- * Namespace id.
- */
- private Long namespaceId;
-
/**
* Delay task unique id.
* If is null or blank, will to auto generate.
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayItemPullRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayItemPullRequest.java
index 29d2d9e4..7d4c44f5 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayItemPullRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayItemPullRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayPullRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayPullRequest.java
index 077b36f3..a3c8d2d9 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayPullRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayPullRequest.java
@@ -6,7 +6,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayStatusRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayStatusRequest.java
index e31fba18..6e932b8e 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayStatusRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayStatusRequest.java
@@ -6,7 +6,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTaskRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTaskRequest.java
index 05187d81..fa138d9d 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTaskRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTaskRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTopicPullRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTopicPullRequest.java
index 7f4e751b..3885426e 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTopicPullRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerDelayTopicPullRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerHeartbeatRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerHeartbeatRequest.java
index 56f83530..e47d614f 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerHeartbeatRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerHeartbeatRequest.java
@@ -6,7 +6,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceLogRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceLogRequest.java
index 3eb5b5db..aaa7796c 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceLogRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceLogRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceStatusRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceStatusRequest.java
index 6273eab4..b1fd012e 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceStatusRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceStatusRequest.java
@@ -8,7 +8,7 @@
import io.openjob.common.constant.InstanceStatusEnum;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogFieldRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogFieldRequest.java
index 5d1a392b..0fff5622 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogFieldRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogFieldRequest.java
@@ -6,7 +6,7 @@
import java.util.Map;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogRequest.java
index 588a06fa..9512fe63 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskLogRequest.java
@@ -6,7 +6,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskRequest.java
index 87e47387..709157d2 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerJobInstanceTaskRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerStartRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerStartRequest.java
index bd44a40d..fcb1c7d6 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerStartRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerStartRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/request/WorkerStopRequest.java b/openjob-common/src/main/java/io/openjob/common/request/WorkerStopRequest.java
index d75e8786..328a4ae2 100644
--- a/openjob-common/src/main/java/io/openjob/common/request/WorkerStopRequest.java
+++ b/openjob-common/src/main/java/io/openjob/common/request/WorkerStopRequest.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/Result.java b/openjob-common/src/main/java/io/openjob/common/response/Result.java
index 309ce20f..f7e3d180 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/Result.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/Result.java
@@ -7,7 +7,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayAddResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayAddResponse.java
index 8c6710e5..668af9a0 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayAddResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayAddResponse.java
@@ -3,21 +3,18 @@
import lombok.Data;
import lombok.EqualsAndHashCode;
+import java.io.Serializable;
+
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
-@EqualsAndHashCode(callSuper = true)
-public class ServerDelayAddResponse extends ServerResponse {
+public class ServerDelayAddResponse implements Serializable {
/**
* Delay task unique id.
* If is null or blank, will to auto generate.
*/
private String taskId;
-
- public ServerDelayAddResponse(Long deliveryId) {
- super(deliveryId);
- }
}
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayInstanceResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayInstanceResponse.java
index 1346a8f6..a36aa12f 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayInstanceResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayInstanceResponse.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayPullResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayPullResponse.java
index 0273154e..6fd88422 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayPullResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayPullResponse.java
@@ -6,7 +6,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicPullResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicPullResponse.java
index 9bfe4c3c..ffaa41f6 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicPullResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicPullResponse.java
@@ -6,7 +6,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicResponse.java
index 7e2a1a14..eb32fb72 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerDelayTopicResponse.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatResponse.java
index 5208f3c0..4ac71012 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatResponse.java
@@ -7,7 +7,7 @@
import java.util.Set;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatSystemResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatSystemResponse.java
index b3c53356..9ddc92c8 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatSystemResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerHeartbeatSystemResponse.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerResponse.java
index 042ae578..7fb7c754 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerResponse.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/ServerWorkerStartResponse.java b/openjob-common/src/main/java/io/openjob/common/response/ServerWorkerStartResponse.java
index f770689d..30c9ba67 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/ServerWorkerStartResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/ServerWorkerStartResponse.java
@@ -6,7 +6,7 @@
import java.util.Set;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/response/WorkerResponse.java b/openjob-common/src/main/java/io/openjob/common/response/WorkerResponse.java
index 4c8e9628..df208af4 100644
--- a/openjob-common/src/main/java/io/openjob/common/response/WorkerResponse.java
+++ b/openjob-common/src/main/java/io/openjob/common/response/WorkerResponse.java
@@ -5,7 +5,7 @@
import java.io.Serializable;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/main/java/io/openjob/common/util/CommonUtil.java b/openjob-common/src/main/java/io/openjob/common/util/CommonUtil.java
index f026eeaa..60e5ed05 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/CommonUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/CommonUtil.java
@@ -5,7 +5,7 @@
import java.util.Objects;
/**
- * @author inhere
+ * @author inhere in.798@qq.com
* @since 1.0.0
*/
public class CommonUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/DateUtil.java b/openjob-common/src/main/java/io/openjob/common/util/DateUtil.java
index 412b3b36..cae29262 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/DateUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/DateUtil.java
@@ -4,7 +4,7 @@
import java.time.Instant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class DateUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/DelayUtil.java b/openjob-common/src/main/java/io/openjob/common/util/DelayUtil.java
index ffaf7321..a14418ce 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/DelayUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/DelayUtil.java
@@ -3,7 +3,7 @@
import io.openjob.common.constant.DelayConstant;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class DelayUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/FutureUtil.java b/openjob-common/src/main/java/io/openjob/common/util/FutureUtil.java
index db0a7738..870a7f5e 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/FutureUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/FutureUtil.java
@@ -11,7 +11,7 @@
import java.util.concurrent.TimeUnit;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class FutureUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/IpUtil.java b/openjob-common/src/main/java/io/openjob/common/util/IpUtil.java
index 513cc779..7e934d7b 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/IpUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/IpUtil.java
@@ -11,7 +11,7 @@
import java.util.Objects;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class IpUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/KryoUtil.java b/openjob-common/src/main/java/io/openjob/common/util/KryoUtil.java
index a97743de..619af115 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/KryoUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/KryoUtil.java
@@ -8,7 +8,7 @@
import java.io.ByteArrayOutputStream;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class KryoUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/ResultUtil.java b/openjob-common/src/main/java/io/openjob/common/util/ResultUtil.java
index 4c1cf3b3..be04b9b6 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/ResultUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/ResultUtil.java
@@ -4,7 +4,7 @@
import io.openjob.common.response.Result;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class ResultUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/RuntimeUtil.java b/openjob-common/src/main/java/io/openjob/common/util/RuntimeUtil.java
index a87add41..95bf6dae 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/RuntimeUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/RuntimeUtil.java
@@ -1,7 +1,7 @@
package io.openjob.common.util;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class RuntimeUtil {
diff --git a/openjob-common/src/main/java/io/openjob/common/util/TaskUtil.java b/openjob-common/src/main/java/io/openjob/common/util/TaskUtil.java
index 879076b1..f727536f 100644
--- a/openjob-common/src/main/java/io/openjob/common/util/TaskUtil.java
+++ b/openjob-common/src/main/java/io/openjob/common/util/TaskUtil.java
@@ -5,7 +5,7 @@
import java.util.UUID;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class TaskUtil {
diff --git a/openjob-common/src/test/java/io/openjob/common/dto/ChildDTO.java b/openjob-common/src/test/java/io/openjob/common/dto/ChildDTO.java
index 2800a7a5..26ef9cfb 100644
--- a/openjob-common/src/test/java/io/openjob/common/dto/ChildDTO.java
+++ b/openjob-common/src/test/java/io/openjob/common/dto/ChildDTO.java
@@ -4,7 +4,7 @@
import lombok.Data;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/test/java/io/openjob/common/dto/OneDTO.java b/openjob-common/src/test/java/io/openjob/common/dto/OneDTO.java
index 56ff02eb..89d32f59 100644
--- a/openjob-common/src/test/java/io/openjob/common/dto/OneDTO.java
+++ b/openjob-common/src/test/java/io/openjob/common/dto/OneDTO.java
@@ -5,7 +5,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/test/java/io/openjob/common/dto/TwoDTO.java b/openjob-common/src/test/java/io/openjob/common/dto/TwoDTO.java
index b3dfcdc6..7346fde3 100644
--- a/openjob-common/src/test/java/io/openjob/common/dto/TwoDTO.java
+++ b/openjob-common/src/test/java/io/openjob/common/dto/TwoDTO.java
@@ -5,7 +5,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Data
diff --git a/openjob-common/src/test/java/io/openjob/common/mapper/TestMapper.java b/openjob-common/src/test/java/io/openjob/common/mapper/TestMapper.java
index b72fdc34..850388a8 100644
--- a/openjob-common/src/test/java/io/openjob/common/mapper/TestMapper.java
+++ b/openjob-common/src/test/java/io/openjob/common/mapper/TestMapper.java
@@ -8,7 +8,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Mapper
diff --git a/openjob-common/src/test/java/io/openjob/common/util/IpUtilTest.java b/openjob-common/src/test/java/io/openjob/common/util/IpUtilTest.java
index 6a7d4392..990fa7f3 100644
--- a/openjob-common/src/test/java/io/openjob/common/util/IpUtilTest.java
+++ b/openjob-common/src/test/java/io/openjob/common/util/IpUtilTest.java
@@ -4,7 +4,7 @@
import org.junit.jupiter.api.Test;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class IpUtilTest {
diff --git a/openjob-common/src/test/java/io/openjob/common/util/KryoUtilTest.java b/openjob-common/src/test/java/io/openjob/common/util/KryoUtilTest.java
index 073b453f..7bdbfdc8 100644
--- a/openjob-common/src/test/java/io/openjob/common/util/KryoUtilTest.java
+++ b/openjob-common/src/test/java/io/openjob/common/util/KryoUtilTest.java
@@ -7,7 +7,7 @@
import org.junit.jupiter.api.Test;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class KryoUtilTest {
diff --git a/openjob-common/src/test/java/io/openjob/common/util/MapperTest.java b/openjob-common/src/test/java/io/openjob/common/util/MapperTest.java
index 6d4823d9..8fd39aad 100644
--- a/openjob-common/src/test/java/io/openjob/common/util/MapperTest.java
+++ b/openjob-common/src/test/java/io/openjob/common/util/MapperTest.java
@@ -11,7 +11,7 @@
import java.util.List;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
diff --git a/openjob-common/src/test/java/io/openjob/common/util/TaskUtilTest.java b/openjob-common/src/test/java/io/openjob/common/util/TaskUtilTest.java
index bfbf7b88..2d65db2f 100644
--- a/openjob-common/src/test/java/io/openjob/common/util/TaskUtilTest.java
+++ b/openjob-common/src/test/java/io/openjob/common/util/TaskUtilTest.java
@@ -4,7 +4,7 @@
import org.junit.jupiter.api.Test;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
public class TaskUtilTest {
diff --git a/openjob-server/openjob-server-admin/pom.xml b/openjob-server/openjob-server-admin/pom.xml
index 101f50ec..af814ef9 100644
--- a/openjob-server/openjob-server-admin/pom.xml
+++ b/openjob-server/openjob-server-admin/pom.xml
@@ -25,11 +25,5 @@
io.openjob
openjob-server-log
-
-
- com.github.ben-manes.caffeine
- caffeine
- 2.9.2
-
\ No newline at end of file
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminAutoConfiguration.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminAutoConfiguration.java
index b088b02d..58a6b027 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminAutoConfiguration.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminAutoConfiguration.java
@@ -1,44 +1,12 @@
package io.openjob.server.admin.autoconfigure;
-import com.github.benmanes.caffeine.cache.Cache;
-import com.github.benmanes.caffeine.cache.Caffeine;
-import io.openjob.server.admin.constant.AdminConstant;
-import io.openjob.server.admin.dto.AdminUserSessionDTO;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
-import java.util.concurrent.TimeUnit;
-
/**
* @author inhere
*/
@Configuration
@EnableConfigurationProperties(AdminUserProperties.class)
public class AdminAutoConfiguration {
-
- private final AdminUserProperties userProperties;
-
- public AdminAutoConfiguration(AdminUserProperties userProperties) {
- this.userProperties = userProperties;
- }
-
- /**
- * make loginCache bean
- *
- * @return bean
- */
- @Bean
- public Cache loginCache() {
- return Caffeine.newBuilder()
- // cache的初始容量
- .initialCapacity(userProperties.getCacheInitSize())
- // cache最大缓存数
- .maximumSize(userProperties.getCacheMaxSize())
- // 设置写缓存后n秒钟过期
- .expireAfterWrite(AdminConstant.LOGIN_EXPIRE_TIME, TimeUnit.SECONDS)
- // 设置读写缓存后n秒钟过期,实际很少用到,类似于expireAfterWrite
- //.expireAfterAccess(17, TimeUnit.SECONDS)
- .build();
- }
}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminUserProperties.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminUserProperties.java
index 28b448fb..b82c05b7 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminUserProperties.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminUserProperties.java
@@ -14,9 +14,4 @@ public class AdminUserProperties {
* passwd salt
*/
private String passwdSalt;
-
- private Integer cacheInitSize;
-
- private Long cacheMaxSize;
-
}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminInterceptorConfig.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/WebAdminConfigurer.java
similarity index 82%
rename from openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminInterceptorConfig.java
rename to openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/WebAdminConfigurer.java
index 4c228cdb..5d860888 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/AdminInterceptorConfig.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/autoconfigure/WebAdminConfigurer.java
@@ -10,12 +10,12 @@
* @author inhere
*/
@Configuration
-public class AdminInterceptorConfig implements WebMvcConfigurer {
+public class WebAdminConfigurer implements WebMvcConfigurer {
private final AccessInterceptor accessInterceptor;
- @Autowired
- public AdminInterceptorConfig(AccessInterceptor accessInterceptor) {
+ @Autowired()
+ public WebAdminConfigurer(AccessInterceptor accessInterceptor) {
this.accessInterceptor = accessInterceptor;
}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminCodeEnum.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminCodeEnum.java
deleted file mode 100644
index 765ddac6..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminCodeEnum.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package io.openjob.server.admin.constant;
-
-import io.openjob.server.common.exception.CodeExceptionAssert;
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-
-/**
- * @author stelin
- * @since 1.0.0
- */
-@Getter
-@AllArgsConstructor
-public enum AdminCodeEnum implements CodeExceptionAssert {
-
- /**
- * Test
- */
- TEST(1, "TEST");
-
- /**
- * Value
- */
- private final Integer value;
-
- /**
- * Message
- */
- private final String message;
-}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminConstant.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminConstant.java
index d2442bac..7ecbcaef 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminConstant.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminConstant.java
@@ -5,35 +5,22 @@
*/
public class AdminConstant {
/**
- * login expire time, default is 30min
+ * Login expire time, default is 30min
*/
public static final Integer LOGIN_EXPIRE_TIME = 1800;
/**
- * user login session key name in headers
- * "session: session_key"
+ * User login session key name in headers
*/
public static final String HEADER_SESSION_KEY = "session";
- /**
- * user api token header name in headers
- * "token: user_token"
- */
- public static final String HEADER_TOKEN_KEY = "token";
-
/**
* Request uid key.
*/
public static final String REQUEST_UID_KEY = "uid";
-
- /**
- * mark is permission data
- */
- public static final Integer MENU_TYPE_PERM = 2;
-
/**
- * mark is admin menu data
+ * Max time expression
*/
- public static final Integer MENU_TYPE_MENU = 1;
+ public static final Integer MAX_TIME_EXPRESSION = 7;
}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminHttpStatusEnum.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminHttpStatusEnum.java
index 62a54dbc..9628e179 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminHttpStatusEnum.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/AdminHttpStatusEnum.java
@@ -5,7 +5,7 @@
import lombok.Getter;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/CodeEnum.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/CodeEnum.java
index 15c3d9f6..6e51161a 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/CodeEnum.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/constant/CodeEnum.java
@@ -5,13 +5,16 @@
import lombok.Getter;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Getter
@AllArgsConstructor
public enum CodeEnum implements CodeExceptionAssert {
+ /**
+ * App name not exist
+ */
NAME_EXIST(100, "App name must be globally unique!");
/**
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AdminController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AdminController.java
index f2612df0..e2df5c6a 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AdminController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AdminController.java
@@ -38,20 +38,16 @@ public AdminController(AdminLoginService adminLoginService) {
this.adminLoginService = adminLoginService;
}
- @ApiOperation("admin user login")
+ @ApiOperation("User login")
@PostMapping("/login")
public Result login(@Valid @RequestBody AdminUserLoginRequest request) {
return Result.success(this.adminLoginService.login(request));
}
/**
- * login user info, menus, perms
- *
- * @param request request
- * @param headers headers
- * @return vo
+ * Login user info
*/
- @ApiOperation("login user info, menus, perms")
+ @ApiOperation("Login user")
@GetMapping("/user-info")
public Result loginUserInfo(@RequestBody LoginUserInfoRequest request, @RequestHeader HttpHeaders headers) {
String sessKey = headers.getFirst(AdminConstant.HEADER_SESSION_KEY);
@@ -60,13 +56,9 @@ public Result loginUserInfo(@RequestBody LoginUserInfoRequest r
}
/**
- * admin user logout
- *
- * @param request request
- * @param headers headers
- * @return vo
+ * Login out
*/
- @ApiOperation("admin user logout")
+ @ApiOperation("User logout")
@PostMapping("/logout")
public Result logout(@RequestBody(required = false) AdminUserLogoutRequest request, @RequestHeader HttpHeaders headers) {
String sessKey = headers.getFirst(AdminConstant.HEADER_SESSION_KEY);
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AppController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AppController.java
index 2670599c..269d4fc5 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AppController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/AppController.java
@@ -24,7 +24,7 @@
import javax.validation.Valid;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Api(value = "App", tags = "App")
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ContactController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ContactController.java
deleted file mode 100644
index 93c9e123..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ContactController.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package io.openjob.server.admin.controller;
-
-import io.openjob.common.response.Result;
-import io.openjob.server.admin.request.notify.NotifyContactAddRequest;
-import io.openjob.server.admin.request.notify.NotifyContactDeleteRequest;
-import io.openjob.server.admin.request.notify.NotifyContactListRequest;
-import io.openjob.server.admin.request.notify.NotifyContactQueryRequest;
-import io.openjob.server.admin.request.notify.NotifyContactUpdateRequest;
-import io.openjob.server.admin.service.NotifyContactService;
-import io.openjob.server.admin.vo.notify.NotifyContactAddVO;
-import io.openjob.server.admin.vo.notify.NotifyContactQueryVO;
-import io.openjob.server.admin.vo.notify.NotifyContactUpdateVO;
-import io.openjob.server.common.dto.PageDTO;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-
-/**
- * @author inhere
- * @since 1.0.0
- */
-@Api(value = "NotifyContact", tags = "NotifyContact")
-@RestController
-@RequestMapping("/admin/notify-contacts")
-public class ContactController {
-
- private final NotifyContactService notifyContactService;
-
- @Autowired
- public ContactController(NotifyContactService notifyContactService) {
- this.notifyContactService = notifyContactService;
- }
-
- @ApiOperation("Add a notifyContact")
- @PostMapping("/add")
- public Result add(@Valid @RequestBody NotifyContactAddRequest addRequest) {
- return Result.success(this.notifyContactService.add(addRequest));
- }
-
- @ApiOperation("Update a notifyContact")
- @PostMapping("/update")
- public Result update(@Valid @RequestBody NotifyContactUpdateRequest updateRequest) {
- return Result.success(this.notifyContactService.update(updateRequest));
- }
-
- @ApiOperation("Delete a notifyContact")
- @PostMapping("/delete")
- public Result delete(@Valid @RequestBody NotifyContactDeleteRequest deleteRequest) {
- return Result.success(this.notifyContactService.delete(deleteRequest));
- }
-
- @ApiOperation("Get a notifyContact")
- @GetMapping("/get")
- public Result query(@Valid NotifyContactQueryRequest getRequest) {
- return Result.success(this.notifyContactService.query(getRequest));
- }
-
- @ApiOperation("List notifyContact by page")
- @GetMapping("/list")
- public Result> list(@Valid NotifyContactListRequest listRequest) {
- return Result.success(this.notifyContactService.getPageList(listRequest));
- }
-}
-
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayController.java
index 36806e55..246870a6 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayController.java
@@ -24,7 +24,7 @@
import javax.validation.Valid;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Api(value = "Delay", tags = "Delay")
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayInstanceController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayInstanceController.java
index 1484f65b..e44c2e80 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayInstanceController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/DelayInstanceController.java
@@ -25,7 +25,7 @@
import javax.validation.Valid;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Api(value = "Delay Instance", tags = "Delay Instance")
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobController.java
index 01c401a7..06147b50 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobController.java
@@ -30,7 +30,7 @@
import javax.validation.Valid;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Api(value = "Job", tags = "Job")
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobInstanceController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobInstanceController.java
index cec59132..f9c37221 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobInstanceController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/JobInstanceController.java
@@ -24,7 +24,7 @@
import javax.validation.Valid;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Api(value = "JobInstance", tags = "JobInstance")
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NamespaceController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NamespaceController.java
index 8f11f145..6fbf8c6a 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NamespaceController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NamespaceController.java
@@ -24,7 +24,7 @@
import javax.validation.Valid;
/**
- * @author stelin
+ * @author stelin swoft@qq.com
* @since 1.0.0
*/
@Api(value = "Namespace", tags = "Namespace")
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NotifyGroupController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NotifyGroupController.java
deleted file mode 100644
index 13539730..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/NotifyGroupController.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package io.openjob.server.admin.controller;
-
-import io.openjob.common.response.Result;
-import io.openjob.server.admin.request.notify.NotifyGroupAddRequest;
-import io.openjob.server.admin.request.notify.NotifyGroupDeleteRequest;
-import io.openjob.server.admin.request.notify.NotifyGroupListRequest;
-import io.openjob.server.admin.request.notify.NotifyGroupQueryRequest;
-import io.openjob.server.admin.request.notify.NotifyGroupUpdateRequest;
-import io.openjob.server.admin.service.NotifyGroupService;
-import io.openjob.server.admin.vo.notify.NotifyGroupAddVO;
-import io.openjob.server.admin.vo.notify.NotifyGroupQueryVO;
-import io.openjob.server.admin.vo.notify.NotifyGroupUpdateVO;
-import io.openjob.server.common.dto.PageDTO;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-
-/**
- * @author inhere
- * @since 1.0.0
- */
-@Api(value = "NotifyGroup", tags = "NotifyGroup")
-@RestController
-@RequestMapping("/admin/notify-groups")
-public class NotifyGroupController {
-
- private final NotifyGroupService notifyGroupService;
-
- @Autowired
- public NotifyGroupController(NotifyGroupService notifyGroupService) {
- this.notifyGroupService = notifyGroupService;
- }
-
- @ApiOperation("Add a notifyGroup")
- @PostMapping("/add")
- public Result add(@Valid @RequestBody NotifyGroupAddRequest addRequest) {
- return Result.success(this.notifyGroupService.add(addRequest));
- }
-
- @ApiOperation("Update a notifyGroup")
- @PostMapping("/update")
- public Result update(@Valid @RequestBody NotifyGroupUpdateRequest updateRequest) {
- return Result.success(this.notifyGroupService.update(updateRequest));
- }
-
- @ApiOperation("Delete a notifyGroup")
- @PostMapping("/delete")
- public Result delete(@Valid @RequestBody NotifyGroupDeleteRequest deleteRequest) {
- return Result.success(this.notifyGroupService.delete(deleteRequest));
- }
-
- @ApiOperation("Get a notifyGroup")
- @GetMapping("/get")
- public Result query(@Valid NotifyGroupQueryRequest getRequest) {
- return Result.success(this.notifyGroupService.query(getRequest));
- }
-
- @ApiOperation("List notifyGroup by page")
- @GetMapping("/list")
- public Result> list(@Valid NotifyGroupListRequest listRequest) {
- return Result.success(this.notifyGroupService.getPageList(listRequest));
- }
-}
-
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/PermController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/PermController.java
index 2ee0dee1..7f93aab4 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/PermController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/PermController.java
@@ -2,25 +2,14 @@
import io.openjob.common.response.Result;
import io.openjob.server.admin.constant.AdminConstant;
-import io.openjob.server.admin.request.perm.AdminPermAddRequest;
-import io.openjob.server.admin.request.perm.AdminPermDeleteRequest;
-import io.openjob.server.admin.request.perm.AdminPermListRequest;
-import io.openjob.server.admin.request.perm.AdminPermQueryRequest;
-import io.openjob.server.admin.request.perm.AdminPermUpdateRequest;
import io.openjob.server.admin.request.perm.AdminPermissionMenusRequest;
import io.openjob.server.admin.service.AdminPermService;
-import io.openjob.server.admin.vo.perm.AdminPermAddVO;
-import io.openjob.server.admin.vo.perm.AdminPermQueryVO;
-import io.openjob.server.admin.vo.perm.AdminPermUpdateVO;
import io.openjob.server.admin.vo.perm.AdminPermissionMenusVO;
-import io.openjob.server.common.dto.PageDTO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -43,36 +32,6 @@ public PermController(AdminPermService adminPermService) {
this.adminPermService = adminPermService;
}
- @ApiOperation("Add adminPerm")
- @PostMapping("/add")
- public Result add(@Valid @RequestBody AdminPermAddRequest addRequest) {
- return Result.success(this.adminPermService.add(addRequest));
- }
-
- @ApiOperation("Update adminPerm")
- @PostMapping("/update")
- public Result update(@Valid @RequestBody AdminPermUpdateRequest updateRequest) {
- return Result.success(this.adminPermService.update(updateRequest));
- }
-
- @ApiOperation("Delete a adminPerm")
- @PostMapping("/delete")
- public Result delete(@Valid @RequestBody AdminPermDeleteRequest deleteRequest) {
- return Result.success(this.adminPermService.delete(deleteRequest));
- }
-
- @ApiOperation("Get a adminPerm")
- @GetMapping("/get")
- public Result query(@Valid @ModelAttribute AdminPermQueryRequest getRequest) {
- return Result.success(this.adminPermService.query(getRequest));
- }
-
- @ApiOperation("List adminPerm")
- @GetMapping("/list")
- public Result> list(@Valid @ModelAttribute AdminPermListRequest listRequest) {
- return Result.success(this.adminPermService.getPageList(listRequest));
- }
-
@ApiOperation("List menus")
@GetMapping("/menus")
public Result menus(@Valid @ModelAttribute AdminPermissionMenusRequest listRequest, HttpServletRequest request) {
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/RoleController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/RoleController.java
deleted file mode 100644
index c492f2e1..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/RoleController.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package io.openjob.server.admin.controller;
-
-import io.openjob.common.response.Result;
-import io.openjob.server.admin.request.user.AdminRoleAddRequest;
-import io.openjob.server.admin.request.user.AdminRoleDeleteRequest;
-import io.openjob.server.admin.request.user.AdminRoleListRequest;
-import io.openjob.server.admin.request.user.AdminRoleQueryRequest;
-import io.openjob.server.admin.request.user.AdminRoleUpdateRequest;
-import io.openjob.server.admin.service.AdminRoleService;
-import io.openjob.server.admin.vo.user.AdminRoleAddVO;
-import io.openjob.server.admin.vo.user.AdminRoleQueryVO;
-import io.openjob.server.admin.vo.user.AdminRoleUpdateVO;
-import io.openjob.server.common.dto.PageDTO;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-
-/**
- * @author inhere
- * @since 1.0.0
- */
-@Api(value = "AdminRole", tags = "AdminRole")
-@RestController
-@RequestMapping("/admin/roles")
-public class RoleController {
-
- private final AdminRoleService adminRoleService;
-
- @Autowired
- public RoleController(AdminRoleService adminRoleService) {
- this.adminRoleService = adminRoleService;
- }
-
- @ApiOperation("Add a adminRole")
- @PostMapping("/add")
- public Result add(@Valid @RequestBody AdminRoleAddRequest addRequest) {
- return Result.success(this.adminRoleService.add(addRequest));
- }
-
- @ApiOperation("Update a adminRole")
- @PostMapping("/update")
- public Result update(@Valid @RequestBody AdminRoleUpdateRequest updateRequest) {
- return Result.success(this.adminRoleService.update(updateRequest));
- }
-
- @ApiOperation("Delete a adminRole")
- @PostMapping("/delete")
- public Result delete(@Valid @RequestBody AdminRoleDeleteRequest deleteRequest) {
- return Result.success(this.adminRoleService.delete(deleteRequest));
- }
-
- @ApiOperation("Get a adminRole")
- @GetMapping("/get")
- public Result query(@Valid AdminRoleQueryRequest getRequest) {
- return Result.success(this.adminRoleService.query(getRequest));
- }
-
- @ApiOperation("List adminRole by page")
- @GetMapping("/list")
- public Result> list(@Valid AdminRoleListRequest listRequest) {
- return Result.success(this.adminRoleService.getPageList(listRequest));
- }
-}
-
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ServerController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ServerController.java
index 001f58cf..2e6fce55 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ServerController.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/ServerController.java
@@ -9,6 +9,7 @@
import io.openjob.server.common.vo.PageVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -27,6 +28,7 @@ public class ServerController {
private final ServerService serverService;
+ @Autowired
public ServerController(ServerService serverService) {
this.serverService = serverService;
}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/TemplateController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/TemplateController.java
deleted file mode 100644
index 2b98c588..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/TemplateController.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package io.openjob.server.admin.controller;
-
-import io.openjob.common.response.Result;
-import io.openjob.server.admin.request.notify.NotifyTemplateAddRequest;
-import io.openjob.server.admin.request.notify.NotifyTemplateDeleteRequest;
-import io.openjob.server.admin.request.notify.NotifyTemplateListRequest;
-import io.openjob.server.admin.request.notify.NotifyTemplateQueryRequest;
-import io.openjob.server.admin.request.notify.NotifyTemplateUpdateRequest;
-import io.openjob.server.admin.service.NotifyTemplateService;
-import io.openjob.server.admin.vo.notify.NotifyTemplateAddVO;
-import io.openjob.server.admin.vo.notify.NotifyTemplateQueryVO;
-import io.openjob.server.admin.vo.notify.NotifyTemplateUpdateVO;
-import io.openjob.server.common.dto.PageDTO;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-
-/**
- * @author inhere
- * @since 1.0.0
- */
-@Api(value = "NotifyTemplate", tags = "NotifyTemplate")
-@RestController
-@RequestMapping("/admin/notify-templates")
-public class TemplateController {
-
- private final NotifyTemplateService notifyTemplateService;
-
- @Autowired
- public TemplateController(NotifyTemplateService notifyTemplateService) {
- this.notifyTemplateService = notifyTemplateService;
- }
-
- @ApiOperation("Add a notifyTemplate")
- @PostMapping("/add")
- public Result add(@Valid @RequestBody NotifyTemplateAddRequest addRequest) {
- return Result.success(this.notifyTemplateService.add(addRequest));
- }
-
- @ApiOperation("Update a notifyTemplate")
- @PostMapping("/update")
- public Result update(@Valid @RequestBody NotifyTemplateUpdateRequest updateRequest) {
- return Result.success(this.notifyTemplateService.update(updateRequest));
- }
-
- @ApiOperation("Delete a notifyTemplate")
- @PostMapping("/delete")
- public Result delete(@Valid @RequestBody NotifyTemplateDeleteRequest deleteRequest) {
- return Result.success(this.notifyTemplateService.delete(deleteRequest));
- }
-
- @ApiOperation("Get a notifyTemplate")
- @GetMapping("/get")
- public Result query(@Valid NotifyTemplateQueryRequest getRequest) {
- return Result.success(this.notifyTemplateService.query(getRequest));
- }
-
- @ApiOperation("List notifyTemplate by page")
- @GetMapping("/list")
- public Result> list(@Valid NotifyTemplateListRequest listRequest) {
- return Result.success(this.notifyTemplateService.getPageList(listRequest));
- }
-}
-
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/UserController.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/UserController.java
deleted file mode 100644
index 2d32d095..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/controller/UserController.java
+++ /dev/null
@@ -1,72 +0,0 @@
-package io.openjob.server.admin.controller;
-
-import io.openjob.common.response.Result;
-import io.openjob.server.admin.request.user.AdminUserAddRequest;
-import io.openjob.server.admin.request.user.AdminUserDeleteRequest;
-import io.openjob.server.admin.request.user.AdminUserListRequest;
-import io.openjob.server.admin.request.user.AdminUserQueryRequest;
-import io.openjob.server.admin.request.user.AdminUserUpdateRequest;
-import io.openjob.server.admin.service.AdminUserService;
-import io.openjob.server.admin.vo.user.AdminUserAddVO;
-import io.openjob.server.admin.vo.user.AdminUserQueryVO;
-import io.openjob.server.admin.vo.user.AdminUserUpdateVO;
-import io.openjob.server.common.dto.PageDTO;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.validation.Valid;
-
-/**
- * @author inhere
- * @since 1.0.0
- */
-@Api(value = "AdminUser", tags = "AdminUser")
-@RestController
-@RequestMapping("/admin/users")
-public class UserController {
-
- private final AdminUserService adminUserService;
-
- @Autowired
- public UserController(AdminUserService adminUserService) {
- this.adminUserService = adminUserService;
- }
-
- @ApiOperation("Add AdminUser")
- @PostMapping("/add")
- public Result add(@Valid @RequestBody AdminUserAddRequest addRequest) {
- return Result.success(this.adminUserService.add(addRequest));
- }
-
- @ApiOperation("Update a AdminUser")
- @PostMapping("/update")
- public Result update(@Valid @RequestBody AdminUserUpdateRequest updateRequest) {
- return Result.success(this.adminUserService.update(updateRequest));
- }
-
- @ApiOperation("Delete a AdminUser")
- @PostMapping("/delete")
- public Result delete(@Valid @RequestBody AdminUserDeleteRequest deleteRequest) {
- return Result.success(this.adminUserService.delete(deleteRequest));
- }
-
- @ApiOperation("Get a AdminUser")
- @GetMapping("/get")
- public Result query(@Valid AdminUserQueryRequest getRequest) {
- return Result.success(this.adminUserService.query(getRequest));
- }
-
- @ApiOperation("List AdminUser by page")
- @GetMapping("/list")
- public Result> list(@Valid AdminUserListRequest listRequest) {
- return Result.success(this.adminUserService.getPageList(listRequest));
- }
-
-}
-
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/dto/AdminUserSessionDTO.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/dto/AdminUserSessionDTO.java
deleted file mode 100644
index 4be49e7c..00000000
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/dto/AdminUserSessionDTO.java
+++ /dev/null
@@ -1,57 +0,0 @@
-package io.openjob.server.admin.dto;
-
-import io.openjob.server.admin.vo.part.MenuItemVO;
-import io.openjob.server.admin.vo.part.PermItemVO;
-import lombok.Builder;
-import lombok.Data;
-
-import java.util.List;
-
-/**
- * @author inhere
- */
-@Data
-@Builder
-public class AdminUserSessionDTO {
-
- /**
- * PK admin_user.id
- */
- private Long id;
-
- /**
- * user is supper admin
- */
- private Boolean supperAdmin;
-
- /**
- * User name
- */
- private String username;
-
- /**
- * Nickname
- */
- private String nickname;
-
- /**
- * Api auth token
- */
- private String token;
-
- /**
- * Web auth key
- */
- private String sessionKey;
-
- /**
- * menus for current user.
- */
- private List menus;
-
- /**
- * perms for current user.
- */
- private List perms;
-
-}
diff --git a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/interceptor/AccessInterceptor.java b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/interceptor/AccessInterceptor.java
index 1d8ba11d..e8afadf8 100644
--- a/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/interceptor/AccessInterceptor.java
+++ b/openjob-server/openjob-server-admin/src/main/java/io/openjob/server/admin/interceptor/AccessInterceptor.java
@@ -5,9 +5,7 @@
import io.openjob.common.response.Result;
import io.openjob.server.admin.constant.AdminConstant;
import io.openjob.server.admin.constant.AdminHttpStatusEnum;
-import io.openjob.server.admin.dto.AdminUserSessionDTO;
import io.openjob.server.admin.service.AdminUserService;
-import io.openjob.server.admin.vo.part.PermItemVO;
import io.openjob.server.repository.entity.AdminUser;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -16,15 +14,14 @@
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
-import org.springframework.util.CollectionUtils;
import org.springframework.web.servlet.HandlerInterceptor;
+import javax.annotation.Nonnull;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
-import java.util.Objects;
/**
* 请求访问拦截器
@@ -37,19 +34,12 @@ public class AccessInterceptor implements HandlerInterceptor {
private static final String MAX_AGE = "18000L";
private final AdminUserService adminUserService;
-
private final List noLoginRoutes;
-
private final List noLoginPrefixes;
- /**
- * can access after login, not need config perms.
- * - eg: logout
- */
- private final List notAuthRoutes;
-
@Autowired
public AccessInterceptor(AdminUserService adminUserService) {
+ // No login routes
noLoginRoutes = new ArrayList<>();
noLoginRoutes.add("/");
noLoginRoutes.add("/csrf");
@@ -58,20 +48,17 @@ public AccessInterceptor(AdminUserService adminUserService) {
noLoginRoutes.add("/favicon.ico");
noLoginRoutes.add("/swagger-ui.html");
+ // No login prefix
noLoginPrefixes = new ArrayList<>();
noLoginPrefixes.add("/webjars/");
noLoginPrefixes.add("/swagger-resources");
noLoginPrefixes.add("/null/swagger-resources");
- notAuthRoutes = new ArrayList<>();
- notAuthRoutes.add("/admin/logout");
- notAuthRoutes.add("/admin/user-info");
-
this.adminUserService = adminUserService;
}
/**
- * 前置处理器
+ * Pre handle
*
* @param request request
* @param response response
@@ -79,26 +66,27 @@ public AccessInterceptor(AdminUserService adminUserService) {
* @return bool
*/
@Override
- public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws IOException {
+ public boolean preHandle(HttpServletRequest request, HttpServletResponse response, @Nonnull Object handler) throws IOException {
String route = request.getRequestURI();
- // 跨域设置
+ // Cross domain
response.addHeader(HttpHeaders.ACCESS_CONTROL_MAX_AGE, MAX_AGE);
response.addHeader(HttpHeaders.ACCESS_CONTROL_ALLOW_ORIGIN, "*");
response.addHeader(HttpHeaders.ACCESS_CONTROL_ALLOW_HEADERS, "*");
response.addHeader(HttpHeaders.ACCESS_CONTROL_ALLOW_CREDENTIALS, "true");
response.addHeader(HttpHeaders.ACCESS_CONTROL_EXPOSE_HEADERS, "*");
+ // Options method
if (HttpMethod.OPTIONS.name().equals(request.getMethod())) {
response.setStatus(HttpStatus.NO_CONTENT.value());
return false;
}
- // web login
+ // Login
if (!isNoLoginRoute(route)) {
String sessKey = request.getHeader(AdminConstant.HEADER_SESSION_KEY);
if (StringUtils.isEmpty(sessKey)) {
- returnJson(response, AdminHttpStatusEnum.UNAUTHORIZED);
+ AdminHttpStatusEnum.UNAUTHORIZED.throwException();
return false;
}
@@ -110,7 +98,7 @@ public boolean preHandle(HttpServletRequest request, HttpServletResponse respons
}
/**
- * is no login required route path.
+ * Whether is no login
*
* @param route route path
* @return bool
@@ -128,38 +116,4 @@ private Boolean isNoLoginRoute(String route) {
return false;
}
-
- private Boolean checkUserPerm(String route, AdminUserSessionDTO user) {
- if (Objects.isNull(user)) {
- AdminHttpStatusEnum.FORBIDDEN.throwException();
- }
-
- if (user.getSupperAdmin() || notAuthRoutes.contains(route)) {
- return true;
- }
-
- if (CollectionUtils.isEmpty(user.getPerms())) {
- return false;
- }
-
- // match by route path.
- PermItemVO perm = user.getPerms()
- .stream()
- .filter(item -> Objects.equals(item.getPath(), route))
- .findAny()
- .orElse(null);
-
- return Objects.nonNull(perm);
- }
-
- private void returnJson(HttpServletResponse response, AdminHttpStatusEnum statusEnum) throws IOException {
- ObjectMapper mapper = new ObjectMapper();
- mapper.configure(SerializationFeature.FAIL_ON_EMPTY_BEANS, false);
-
- Result