style: optimize server's packafe

powerjob-server/pom.xml

@@ -11,7 +11,13 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-server</artifactId>
     <version>3.4.6</version>
-    <packaging>jar</packaging>
+    <modules>
+        <module>powerjob-server-common</module>
+        <module>powerjob-server-remote</module>
+        <module>powerjob-server-persistence</module>
+        <module>powerjob-server-starter</module>
+    </modules>
+    <packaging>pom</packaging>
 
     <properties>
         <swagger.version>2.9.2</swagger.version>
@@ -220,7 +226,7 @@
                 <artifactId>spring-boot-maven-plugin</artifactId>
                 <version>${springboot.version}</version>
                 <configuration>
-                    <mainClass>com.github.kfcfans.powerjob.server.OhMyApplication</mainClass>
+                    <mainClass>tech.powerjob.server.OhMyApplication</mainClass>
                 </configuration>
                 <executions>
                     <execution>

powerjob-server/powerjob-server-common/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>powerjob-server</artifactId>
+        <groupId>com.github.kfcfans</groupId>
+        <version>3.4.6</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>tech.powerjob</groupId>
+    <artifactId>powerjob-server-common</artifactId>
+    <version>1.0.0</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>

powerjob-server/powerjob-server-persistence/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>powerjob-server</artifactId>
+        <groupId>com.github.kfcfans</groupId>
+        <version>3.4.6</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>tech.powerjob</groupId>
+    <artifactId>powerjob-server-persistence</artifactId>
+    <version>1.0.0</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>

powerjob-server/powerjob-server-remote/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>powerjob-server</artifactId>
+        <groupId>com.github.kfcfans</groupId>
+        <version>3.4.6</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>tech.powerjob</groupId>
+    <artifactId>powerjob-server-remote</artifactId>
+    <version>1.0.0</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>

powerjob-server/powerjob-server-starter/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>powerjob-server</artifactId>
+        <groupId>com.github.kfcfans</groupId>
+        <version>3.4.6</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>tech.powerjob</groupId>
+    <artifactId>powerjob-server-starter</artifactId>
+    <version>1.0.0</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/OhMyApplication.java

@@ -1,8 +1,8 @@
-package com.github.kfcfans.powerjob.server;
+package tech.powerjob.server;
 
-import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.VertXStarter;
+import tech.powerjob.server.common.utils.PropertyUtils;
+import tech.powerjob.server.remote.transport.starter.AkkaStarter;
+import tech.powerjob.server.remote.transport.starter.VertXStarter;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/PowerJobServerConfigKey.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common;
+package tech.powerjob.server.common;
 
 /**
  * 配置文件 key

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/RejectedExecutionHandlerFactory.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common;
+package tech.powerjob.server.common;
 
 import lombok.extern.slf4j.Slf4j;
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/SJ.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common;
+package tech.powerjob.server.common;
 
 import com.google.common.base.Joiner;
 import com.google.common.base.Splitter;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/config/OmsEndpointConfigure.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.config;
+package tech.powerjob.server.common.config;
 
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/config/SwaggerConfig.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.common.config;
+package tech.powerjob.server.common.config;
 
-import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey;
+import tech.powerjob.server.common.PowerJobServerConfigKey;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/config/ThreadPoolConfig.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.common.config;
+package tech.powerjob.server.common.config;
 
-import com.github.kfcfans.powerjob.server.common.RejectedExecutionHandlerFactory;
+import tech.powerjob.server.common.RejectedExecutionHandlerFactory;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/config/WebConfig.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.config;
+package tech.powerjob.server.common.config;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/constants/ContainerSourceType.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.constants;
+package tech.powerjob.server.common.constants;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/constants/InstanceType.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.constants;
+package tech.powerjob.server.common.constants;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/constants/SwitchableStatus.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.constants;
+package tech.powerjob.server.common.constants;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/AOPUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.exception.ExceptionUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/ContainerTemplateGenerator.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import com.github.kfcfans.powerjob.common.ContainerConstant;
 import net.lingala.zip4j.ZipFile;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/CronExpression.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 /*
 Copyright [2020] [PowerJob]
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/DingTalkUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import com.dingtalk.api.DefaultDingTalkClient;
 import com.dingtalk.api.DingTalkClient;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/OmsFileUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import com.github.kfcfans.powerjob.common.utils.CommonUtils;
 import org.apache.commons.lang3.exception.ExceptionUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/PropertyUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.exception.ExceptionUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/QueryConvertUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import com.alibaba.fastjson.JSONArray;
 import com.github.kfcfans.powerjob.common.PowerJobException;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/SpringUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/TimeUtils.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import com.github.kfcfans.powerjob.common.RemoteConstant;
 import com.google.common.collect.Lists;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/WorkflowDAGUtils.java

@@ -1,11 +1,11 @@
-package com.github.kfcfans.powerjob.server.common.utils;
+package tech.powerjob.server.common.utils;
 
 import com.github.kfcfans.powerjob.common.InstanceStatus;
 import com.github.kfcfans.powerjob.common.PowerJobException;
 import com.github.kfcfans.powerjob.common.SystemInstanceResult;
 import com.github.kfcfans.powerjob.common.model.PEWorkflowDAG;
 import com.github.kfcfans.powerjob.common.utils.JsonUtils;
-import com.github.kfcfans.powerjob.server.model.WorkflowDAG;
+import tech.powerjob.server.model.WorkflowDAG;
 import com.google.common.collect.*;
 
 import java.util.*;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/timewheel/HashedWheelTimer.java

@@ -1,7 +1,7 @@
-package com.github.kfcfans.powerjob.server.common.utils.timewheel;
+package tech.powerjob.server.common.utils.timewheel;
 
 import com.github.kfcfans.powerjob.common.utils.CommonUtils;
-import com.github.kfcfans.powerjob.server.common.RejectedExecutionHandlerFactory;
+import tech.powerjob.server.common.RejectedExecutionHandlerFactory;
 import com.google.common.collect.Queues;
 import com.google.common.collect.Sets;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/timewheel/Timer.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils.timewheel;
+package tech.powerjob.server.common.utils.timewheel;
 
 import java.util.Set;
 import java.util.concurrent.TimeUnit;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/timewheel/TimerFuture.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils.timewheel;
+package tech.powerjob.server.common.utils.timewheel;
 
 /**
  * TimerFuture

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/common/utils/timewheel/TimerTask.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.common.utils.timewheel;
+package tech.powerjob.server.common.utils.timewheel;
 
 /**
  * 时间任务接口

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/extension/Alarmable.java

@@ -1,8 +1,8 @@
-package com.github.kfcfans.powerjob.server.extension;
+package tech.powerjob.server.extension;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.UserInfoDO;
-import com.github.kfcfans.powerjob.server.service.alarm.Alarm;
-import com.github.kfcfans.powerjob.server.service.alarm.AlarmCenter;
+import tech.powerjob.server.persistence.core.model.UserInfoDO;
+import tech.powerjob.server.service.alarm.Alarm;
+import tech.powerjob.server.service.alarm.AlarmCenter;
 import org.springframework.beans.factory.InitializingBean;
 
 import java.util.List;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/extension/LockService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.extension;
+package tech.powerjob.server.extension;
 
 /**
  * 锁服务，所有方法都不允许抛出任何异常！

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/extension/ServerElectionService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.extension;
+package tech.powerjob.server.extension;
 
 /**
  * 调度服务器选举服务，默认实现为先到先得，可自行接入 Zookeeper 等实现"负载均衡"策略

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/extension/WorkerFilter.java

@@ -1,7 +1,7 @@
-package com.github.kfcfans.powerjob.server.extension;
+package tech.powerjob.server.extension;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
 
 /**
  * filter worker by system metrics or other info

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/model/WorkflowDAG.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.model;
+package tech.powerjob.server.model;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/PageResult.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence;
+package tech.powerjob.server.persistence;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/StringPage.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence;
+package tech.powerjob.server.persistence;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/config/CoreJpaConfig.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.config;
+package tech.powerjob.server.persistence.config;
 
 import org.springframework.boot.autoconfigure.orm.jpa.HibernateProperties;
 import org.springframework.boot.autoconfigure.orm.jpa.HibernateSettings;
@@ -39,7 +39,7 @@ public class CoreJpaConfig {
     @Resource(name = "omsCoreDatasource")
     private DataSource omsCoreDatasource;
 
-    public static final String CORE_PACKAGES = "com.github.kfcfans.powerjob.server.persistence.core";
+    public static final String CORE_PACKAGES = "tech.powerjob.server.persistence.core";
 
     /**
      * 生成配置文件，包括 JPA配置文件和Hibernate配置文件，相当于一下三个配置

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/config/LocalJpaConfig.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.config;
+package tech.powerjob.server.persistence.config;
 
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.autoconfigure.orm.jpa.HibernateProperties;
@@ -41,7 +41,7 @@ public class LocalJpaConfig {
     @Resource(name = "omsLocalDatasource")
     private DataSource omsLocalDatasource;
 
-    public static final String LOCAL_PACKAGES = "com.github.kfcfans.powerjob.server.persistence.local";
+    public static final String LOCAL_PACKAGES = "tech.powerjob.server.persistence.local";
 
     private static Map<String, Object> genDatasourceProperties() {
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/config/MultiDatasourceConfig.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.config;
+package tech.powerjob.server.persistence.config;
 
-import com.github.kfcfans.powerjob.server.common.utils.OmsFileUtils;
+import tech.powerjob.server.common.utils.OmsFileUtils;
 import com.zaxxer.hikari.HikariConfig;
 import com.zaxxer.hikari.HikariDataSource;
 import org.apache.commons.io.FileUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/config/PowerJobPhysicalNamingStrategy.java

@@ -1,7 +1,7 @@
-package com.github.kfcfans.powerjob.server.persistence.config;
+package tech.powerjob.server.persistence.config;
 
-import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey;
-import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils;
+import tech.powerjob.server.common.PowerJobServerConfigKey;
+import tech.powerjob.server.common.utils.PropertyUtils;
 import org.hibernate.boot.model.naming.Identifier;
 import org.hibernate.engine.jdbc.env.spi.JdbcEnvironment;
 import org.springframework.boot.orm.jpa.hibernate.SpringPhysicalNamingStrategy;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/AppInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.Data;
 import org.hibernate.annotations.GenericGenerator;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/ContainerInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.Data;
 import org.hibernate.annotations.GenericGenerator;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/InstanceInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import com.github.kfcfans.powerjob.common.InstanceStatus;
 import lombok.AllArgsConstructor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/JobInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 
 import lombok.AllArgsConstructor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/OmsLockDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/ServerInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.Data;
 import lombok.NoArgsConstructor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/UserInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.Data;
 import org.hibernate.annotations.GenericGenerator;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/WorkflowInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/WorkflowInstanceInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/model/WorkflowNodeInfoDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.core.model;
+package tech.powerjob.server.persistence.core.model;
 
 
 import lombok.AllArgsConstructor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/package-info.java

@@ -5,4 +5,4 @@
  * @author tjq
  * @since 2020/6/3
  */
-package com.github.kfcfans.powerjob.server.persistence.core;
+package tech.powerjob.server.persistence.core;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/AppInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO;
+import tech.powerjob.server.persistence.core.model.AppInfoDO;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/ContainerInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.ContainerInfoDO;
+import tech.powerjob.server.persistence.core.model.ContainerInfoDO;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/InstanceInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO;
+import tech.powerjob.server.persistence.core.model.InstanceInfoDO;
 import com.google.errorprone.annotations.CanIgnoreReturnValue;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/JobInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/OmsLockRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.OmsLockDO;
+import tech.powerjob.server.persistence.core.model.OmsLockDO;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/ServerInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.ServerInfoDO;
+import tech.powerjob.server.persistence.core.model.ServerInfoDO;
 import com.google.errorprone.annotations.CanIgnoreReturnValue;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Modifying;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/UserInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.UserInfoDO;
+import tech.powerjob.server.persistence.core.model.UserInfoDO;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/WorkflowInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.WorkflowInfoDO;
+import tech.powerjob.server.persistence.core.model.WorkflowInfoDO;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.JpaRepository;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/WorkflowInstanceInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.WorkflowInstanceInfoDO;
+import tech.powerjob.server.persistence.core.model.WorkflowInstanceInfoDO;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/core/repository/WorkflowNodeInfoRepository.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.core.repository;
+package tech.powerjob.server.persistence.core.repository;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.WorkflowNodeInfoDO;
+import tech.powerjob.server.persistence.core.model.WorkflowNodeInfoDO;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 import java.util.List;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/local/LocalInstanceLogDO.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.local;
+package tech.powerjob.server.persistence.local;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/local/LocalInstanceLogRepository.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.persistence.local;
+package tech.powerjob.server.persistence.local;
 
 import com.google.errorprone.annotations.CanIgnoreReturnValue;
 import org.springframework.data.jpa.repository.JpaRepository;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/persistence/mongodb/GridFsManager.java

@@ -1,6 +1,6 @@
-package com.github.kfcfans.powerjob.server.persistence.mongodb;
+package tech.powerjob.server.persistence.mongodb;
 
-import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey;
+import tech.powerjob.server.common.PowerJobServerConfigKey;
 import com.google.common.base.Stopwatch;
 import com.google.common.collect.Maps;
 import com.mongodb.client.MongoDatabase;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/DispatchService.java

@@ -1,17 +1,17 @@
-package com.github.kfcfans.powerjob.server.remote;
+package tech.powerjob.server.remote;
 
 import com.github.kfcfans.powerjob.common.*;
 import com.github.kfcfans.powerjob.common.request.ServerScheduleJobReq;
 import com.github.kfcfans.powerjob.common.DispatchStrategy;
-import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.InstanceInfoRepository;
-import com.github.kfcfans.powerjob.server.remote.transport.TransportService;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterQueryService;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
-import com.github.kfcfans.powerjob.server.service.instance.InstanceManager;
-import com.github.kfcfans.powerjob.server.service.instance.InstanceMetadataService;
-import com.github.kfcfans.powerjob.server.service.lock.local.UseSegmentLock;
+import tech.powerjob.server.persistence.core.model.InstanceInfoDO;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.persistence.core.repository.InstanceInfoRepository;
+import tech.powerjob.server.remote.transport.TransportService;
+import tech.powerjob.server.remote.worker.cluster.WorkerClusterQueryService;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.service.instance.InstanceManager;
+import tech.powerjob.server.service.instance.InstanceMetadataService;
+import tech.powerjob.server.service.lock.local.UseSegmentLock;
 import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/FriendRequestHandler.java

@@ -1,12 +1,12 @@
-package com.github.kfcfans.powerjob.server.remote.server;
+package tech.powerjob.server.remote.server;
 
 import akka.actor.AbstractActor;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
 import com.github.kfcfans.powerjob.common.utils.JsonUtils;
-import com.github.kfcfans.powerjob.server.remote.server.election.Ping;
-import com.github.kfcfans.powerjob.server.remote.server.redirector.RemoteProcessReq;
-import com.github.kfcfans.powerjob.server.remote.server.redirector.RemoteRequestProcessor;
-import com.github.kfcfans.powerjob.server.remote.transport.TransportService;
+import tech.powerjob.server.remote.server.election.Ping;
+import tech.powerjob.server.remote.server.redirector.RemoteProcessReq;
+import tech.powerjob.server.remote.server.redirector.RemoteRequestProcessor;
+import tech.powerjob.server.remote.transport.TransportService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.exception.ExceptionUtils;
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/ServerInfoService.java

@@ -1,11 +1,11 @@
-package com.github.kfcfans.powerjob.server.remote.server;
+package tech.powerjob.server.remote.server;
 
 import com.github.kfcfans.powerjob.common.PowerJobException;
 import com.github.kfcfans.powerjob.common.utils.CommonUtils;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
-import com.github.kfcfans.powerjob.server.extension.LockService;
-import com.github.kfcfans.powerjob.server.persistence.core.model.ServerInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.ServerInfoRepository;
+import tech.powerjob.server.extension.LockService;
+import tech.powerjob.server.persistence.core.model.ServerInfoDO;
+import tech.powerjob.server.persistence.core.repository.ServerInfoRepository;
 import com.google.common.base.Stopwatch;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.time.DateUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/election/DefaultServerElectionService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.server.election;
+package tech.powerjob.server.remote.server.election;
 
 import akka.actor.ActorSelection;
 import akka.pattern.Patterns;
@@ -7,12 +7,12 @@ import com.github.kfcfans.powerjob.common.PowerJobException;
 import com.github.kfcfans.powerjob.common.Protocol;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
 import com.github.kfcfans.powerjob.common.utils.JsonUtils;
-import com.github.kfcfans.powerjob.server.extension.LockService;
-import com.github.kfcfans.powerjob.server.extension.ServerElectionService;
-import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository;
-import com.github.kfcfans.powerjob.server.remote.transport.TransportService;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter;
+import tech.powerjob.server.extension.LockService;
+import tech.powerjob.server.extension.ServerElectionService;
+import tech.powerjob.server.persistence.core.model.AppInfoDO;
+import tech.powerjob.server.persistence.core.repository.AppInfoRepository;
+import tech.powerjob.server.remote.transport.TransportService;
+import tech.powerjob.server.remote.transport.starter.AkkaStarter;
 import com.google.common.collect.Sets;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/election/Ping.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.server.election;
+package tech.powerjob.server.remote.server.election;
 
 import com.github.kfcfans.powerjob.common.OmsSerializable;
 import lombok.Data;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/redirector/DesignateServer.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.server.redirector;
+package tech.powerjob.server.remote.server.redirector;
 
 import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/redirector/DesignateServerAspect.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.server.redirector;
+package tech.powerjob.server.remote.server.redirector;
 
 import akka.pattern.Patterns;
 import com.fasterxml.jackson.databind.JavaType;
@@ -7,9 +7,9 @@ import com.fasterxml.jackson.databind.type.TypeFactory;
 import com.github.kfcfans.powerjob.common.PowerJobException;
 import com.github.kfcfans.powerjob.common.RemoteConstant;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
-import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter;
+import tech.powerjob.server.persistence.core.model.AppInfoDO;
+import tech.powerjob.server.persistence.core.repository.AppInfoRepository;
+import tech.powerjob.server.remote.transport.starter.AkkaStarter;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.aspectj.lang.ProceedingJoinPoint;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/redirector/RemoteProcessReq.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.server.redirector;
+package tech.powerjob.server.remote.server.redirector;
 
 import com.github.kfcfans.powerjob.common.OmsSerializable;
 import lombok.Getter;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/server/redirector/RemoteRequestProcessor.java

@@ -1,7 +1,7 @@
-package com.github.kfcfans.powerjob.server.remote.server.redirector;
+package tech.powerjob.server.remote.server.redirector;
 
 import com.alibaba.fastjson.JSONObject;
-import com.github.kfcfans.powerjob.server.common.utils.SpringUtils;
+import tech.powerjob.server.common.utils.SpringUtils;
 import org.springframework.util.ReflectionUtils;
 
 import java.lang.reflect.Method;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/transport/TransportService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.transport;
+package tech.powerjob.server.remote.transport;
 
 import com.github.kfcfans.powerjob.common.OmsSerializable;
 import com.github.kfcfans.powerjob.common.Protocol;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/transport/Transporter.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.transport;
+package tech.powerjob.server.remote.transport;
 
 import com.github.kfcfans.powerjob.common.OmsSerializable;
 import com.github.kfcfans.powerjob.common.Protocol;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/transport/impl/AkkaTransporter.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.transport.impl;
+package tech.powerjob.server.remote.transport.impl;
 
 import akka.actor.ActorSelection;
 import akka.pattern.Patterns;
@@ -6,8 +6,8 @@ import com.github.kfcfans.powerjob.common.OmsSerializable;
 import com.github.kfcfans.powerjob.common.Protocol;
 import com.github.kfcfans.powerjob.common.RemoteConstant;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
-import com.github.kfcfans.powerjob.server.remote.transport.Transporter;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter;
+import tech.powerjob.server.remote.transport.Transporter;
+import tech.powerjob.server.remote.transport.starter.AkkaStarter;
 import org.springframework.stereotype.Service;
 
 import java.time.Duration;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/transport/impl/HttpTransporter.java

@@ -1,12 +1,12 @@
-package com.github.kfcfans.powerjob.server.remote.transport.impl;
+package tech.powerjob.server.remote.transport.impl;
 
 import com.github.kfcfans.powerjob.common.OmsSerializable;
 import com.github.kfcfans.powerjob.common.Protocol;
 import com.github.kfcfans.powerjob.common.RemoteConstant;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
-import com.github.kfcfans.powerjob.server.remote.transport.Transporter;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.VertXStarter;
+import tech.powerjob.server.remote.transport.Transporter;
+import tech.powerjob.server.remote.transport.starter.VertXStarter;
 import io.vertx.core.Future;
 import io.vertx.core.Vertx;
 import io.vertx.core.buffer.Buffer;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/transport/starter/AkkaStarter.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.transport.starter;
+package tech.powerjob.server.remote.transport.starter;
 
 import akka.actor.ActorSelection;
 import akka.actor.ActorSystem;
@@ -10,10 +10,10 @@ import com.github.kfcfans.powerjob.common.PowerJobException;
 import com.github.kfcfans.powerjob.common.RemoteConstant;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
-import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey;
-import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils;
-import com.github.kfcfans.powerjob.server.remote.server.FriendRequestHandler;
-import com.github.kfcfans.powerjob.server.remote.worker.handler.impl.WorkerRequestAkkaHandler;
+import tech.powerjob.server.common.PowerJobServerConfigKey;
+import tech.powerjob.server.common.utils.PropertyUtils;
+import tech.powerjob.server.remote.server.FriendRequestHandler;
+import tech.powerjob.server.remote.worker.handler.impl.WorkerRequestAkkaHandler;
 import com.google.common.base.Stopwatch;
 import com.google.common.collect.Maps;
 import com.typesafe.config.Config;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/transport/starter/VertXStarter.java

@@ -1,10 +1,10 @@
-package com.github.kfcfans.powerjob.server.remote.transport.starter;
+package tech.powerjob.server.remote.transport.starter;
 
 import com.github.kfcfans.powerjob.common.OmsConstant;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
-import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey;
-import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils;
-import com.github.kfcfans.powerjob.server.remote.worker.handler.impl.WorkerRequestHttpHandler;
+import tech.powerjob.server.common.PowerJobServerConfigKey;
+import tech.powerjob.server.common.utils.PropertyUtils;
+import tech.powerjob.server.remote.worker.handler.impl.WorkerRequestHttpHandler;
 import com.google.common.base.Stopwatch;
 import io.vertx.core.Vertx;
 import lombok.Getter;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/ClusterStatusHolder.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster;
+package tech.powerjob.server.remote.worker.cluster;
 
 import com.github.kfcfans.powerjob.common.model.DeployedContainerInfo;
 import com.github.kfcfans.powerjob.common.request.WorkerHeartbeat;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/WorkerClusterManagerService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster;
+package tech.powerjob.server.remote.worker.cluster;
 
 import com.github.kfcfans.powerjob.common.request.WorkerHeartbeat;
 import com.google.common.collect.Maps;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/WorkerClusterQueryService.java

@@ -1,9 +1,9 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster;
+package tech.powerjob.server.remote.worker.cluster;
 
 import com.github.kfcfans.powerjob.common.model.DeployedContainerInfo;
-import com.github.kfcfans.powerjob.server.extension.WorkerFilter;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer;
+import tech.powerjob.server.extension.WorkerFilter;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.remote.server.redirector.DesignateServer;
 import com.google.common.collect.Lists;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/WorkerInfo.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster;
+package tech.powerjob.server.remote.worker.cluster;
 
 import com.github.kfcfans.powerjob.common.model.DeployedContainerInfo;
 import com.github.kfcfans.powerjob.common.model.SystemMetrics;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/filter/DesignatedWorkerFilter.java

@@ -1,9 +1,9 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster.filter;
+package tech.powerjob.server.remote.worker.cluster.filter;
 
-import com.github.kfcfans.powerjob.server.common.SJ;
-import com.github.kfcfans.powerjob.server.extension.WorkerFilter;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.common.SJ;
+import tech.powerjob.server.extension.WorkerFilter;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
 import com.google.common.collect.Sets;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/filter/DisconnectedWorkerFilter.java

@@ -1,8 +1,8 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster.filter;
+package tech.powerjob.server.remote.worker.cluster.filter;
 
-import com.github.kfcfans.powerjob.server.extension.WorkerFilter;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.extension.WorkerFilter;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/cluster/filter/SystemMetricsWorkerFilter.java

@@ -1,9 +1,9 @@
-package com.github.kfcfans.powerjob.server.remote.worker.cluster.filter;
+package tech.powerjob.server.remote.worker.cluster.filter;
 
 import com.github.kfcfans.powerjob.common.model.SystemMetrics;
-import com.github.kfcfans.powerjob.server.extension.WorkerFilter;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.extension.WorkerFilter;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/handler/WorkerRequestHandler.java

@@ -1,22 +1,22 @@
-package com.github.kfcfans.powerjob.server.remote.worker.handler;
+package tech.powerjob.server.remote.worker.handler;
 
 import com.github.kfcfans.powerjob.common.InstanceStatus;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterQueryService;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.remote.worker.cluster.WorkerClusterQueryService;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
 import com.github.kfcfans.powerjob.common.request.*;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
 import com.github.kfcfans.powerjob.common.utils.JsonUtils;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
-import com.github.kfcfans.powerjob.server.common.constants.SwitchableStatus;
-import com.github.kfcfans.powerjob.server.common.utils.SpringUtils;
-import com.github.kfcfans.powerjob.server.persistence.core.model.ContainerInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.ContainerInfoRepository;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.JobInfoRepository;
-import com.github.kfcfans.powerjob.server.service.InstanceLogService;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterManagerService;
-import com.github.kfcfans.powerjob.server.service.instance.InstanceManager;
-import com.github.kfcfans.powerjob.server.service.workflow.WorkflowInstanceManager;
+import tech.powerjob.server.common.constants.SwitchableStatus;
+import tech.powerjob.server.common.utils.SpringUtils;
+import tech.powerjob.server.persistence.core.model.ContainerInfoDO;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.persistence.core.repository.ContainerInfoRepository;
+import tech.powerjob.server.persistence.core.repository.JobInfoRepository;
+import tech.powerjob.server.service.InstanceLogService;
+import tech.powerjob.server.remote.worker.cluster.WorkerClusterManagerService;
+import tech.powerjob.server.service.instance.InstanceManager;
+import tech.powerjob.server.service.workflow.WorkflowInstanceManager;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.core.env.Environment;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/handler/impl/WorkerRequestAkkaHandler.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.worker.handler.impl;
+package tech.powerjob.server.remote.worker.handler.impl;
 
 import akka.actor.AbstractActor;
 import com.github.kfcfans.powerjob.common.request.*;
@@ -7,7 +7,7 @@ import lombok.extern.slf4j.Slf4j;
 
 import java.util.Optional;
 
-import static com.github.kfcfans.powerjob.server.remote.worker.handler.WorkerRequestHandler.getWorkerRequestHandler;
+import static tech.powerjob.server.remote.worker.handler.WorkerRequestHandler.getWorkerRequestHandler;
 
 /**
  * 处理 Worker 请求

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/remote/worker/handler/impl/WorkerRequestHttpHandler.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.remote.worker.handler.impl;
+package tech.powerjob.server.remote.worker.handler.impl;
 
 import com.github.kfcfans.powerjob.common.OmsConstant;
 import com.github.kfcfans.powerjob.common.ProtocolConstant;
@@ -7,8 +7,8 @@ import com.github.kfcfans.powerjob.common.request.WorkerHeartbeat;
 import com.github.kfcfans.powerjob.common.request.WorkerLogReportReq;
 import com.github.kfcfans.powerjob.common.response.AskResponse;
 import com.github.kfcfans.powerjob.common.response.ResultDTO;
-import com.github.kfcfans.powerjob.server.common.PowerJobServerConfigKey;
-import com.github.kfcfans.powerjob.server.common.utils.PropertyUtils;
+import tech.powerjob.server.common.PowerJobServerConfigKey;
+import tech.powerjob.server.common.utils.PropertyUtils;
 import io.vertx.core.AbstractVerticle;
 import io.vertx.core.http.HttpServer;
 import io.vertx.core.http.HttpServerOptions;
@@ -21,7 +21,7 @@ import org.apache.commons.lang3.exception.ExceptionUtils;
 
 import java.util.Properties;
 
-import static com.github.kfcfans.powerjob.server.remote.worker.handler.WorkerRequestHandler.getWorkerRequestHandler;
+import static tech.powerjob.server.remote.worker.handler.WorkerRequestHandler.getWorkerRequestHandler;
 
 /**
  * WorkerRequestHandler

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/AppInfoService.java

@@ -1,8 +1,8 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
 import com.github.kfcfans.powerjob.common.PowerJobException;
-import com.github.kfcfans.powerjob.server.persistence.core.model.AppInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.AppInfoRepository;
+import tech.powerjob.server.persistence.core.model.AppInfoDO;
+import tech.powerjob.server.persistence.core.repository.AppInfoRepository;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/CacheService.java

@@ -1,11 +1,11 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.model.WorkflowInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.InstanceInfoRepository;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.JobInfoRepository;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.WorkflowInfoRepository;
+import tech.powerjob.server.persistence.core.model.InstanceInfoDO;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.persistence.core.model.WorkflowInfoDO;
+import tech.powerjob.server.persistence.core.repository.InstanceInfoRepository;
+import tech.powerjob.server.persistence.core.repository.JobInfoRepository;
+import tech.powerjob.server.persistence.core.repository.WorkflowInfoRepository;
 import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
 import lombok.extern.slf4j.Slf4j;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/ContainerService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
 import akka.actor.ActorSelection;
 import com.github.kfcfans.powerjob.common.OmsConstant;
@@ -10,17 +10,17 @@ import com.github.kfcfans.powerjob.common.utils.CommonUtils;
 import com.github.kfcfans.powerjob.common.utils.JsonUtils;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
 import com.github.kfcfans.powerjob.common.utils.SegmentLock;
-import com.github.kfcfans.powerjob.server.common.constants.ContainerSourceType;
-import com.github.kfcfans.powerjob.server.common.constants.SwitchableStatus;
-import com.github.kfcfans.powerjob.server.common.utils.OmsFileUtils;
-import com.github.kfcfans.powerjob.server.extension.LockService;
-import com.github.kfcfans.powerjob.server.persistence.core.model.ContainerInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.ContainerInfoRepository;
-import com.github.kfcfans.powerjob.server.persistence.mongodb.GridFsManager;
-import com.github.kfcfans.powerjob.server.remote.transport.starter.AkkaStarter;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerClusterQueryService;
-import com.github.kfcfans.powerjob.server.remote.worker.cluster.WorkerInfo;
-import com.github.kfcfans.powerjob.server.web.request.SaveContainerInfoRequest;
+import tech.powerjob.server.common.constants.ContainerSourceType;
+import tech.powerjob.server.common.constants.SwitchableStatus;
+import tech.powerjob.server.common.utils.OmsFileUtils;
+import tech.powerjob.server.extension.LockService;
+import tech.powerjob.server.persistence.core.model.ContainerInfoDO;
+import tech.powerjob.server.persistence.core.repository.ContainerInfoRepository;
+import tech.powerjob.server.persistence.mongodb.GridFsManager;
+import tech.powerjob.server.remote.transport.starter.AkkaStarter;
+import tech.powerjob.server.remote.worker.cluster.WorkerClusterQueryService;
+import tech.powerjob.server.remote.worker.cluster.WorkerInfo;
+import tech.powerjob.server.web.request.SaveContainerInfoRequest;
 import com.google.common.collect.ArrayListMultimap;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Multimap;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/InstanceLogService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
 import com.github.kfcfans.powerjob.common.LogLevel;
 import com.github.kfcfans.powerjob.common.OmsConstant;
@@ -7,14 +7,14 @@ import com.github.kfcfans.powerjob.common.model.InstanceLogContent;
 import com.github.kfcfans.powerjob.common.utils.CommonUtils;
 import com.github.kfcfans.powerjob.common.utils.NetUtils;
 import com.github.kfcfans.powerjob.common.utils.SegmentLock;
-import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer;
-import com.github.kfcfans.powerjob.server.common.utils.OmsFileUtils;
-import com.github.kfcfans.powerjob.server.persistence.StringPage;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.local.LocalInstanceLogDO;
-import com.github.kfcfans.powerjob.server.persistence.local.LocalInstanceLogRepository;
-import com.github.kfcfans.powerjob.server.persistence.mongodb.GridFsManager;
-import com.github.kfcfans.powerjob.server.service.instance.InstanceMetadataService;
+import tech.powerjob.server.remote.server.redirector.DesignateServer;
+import tech.powerjob.server.common.utils.OmsFileUtils;
+import tech.powerjob.server.persistence.StringPage;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.persistence.local.LocalInstanceLogDO;
+import tech.powerjob.server.persistence.local.LocalInstanceLogRepository;
+import tech.powerjob.server.persistence.mongodb.GridFsManager;
+import tech.powerjob.server.service.instance.InstanceMetadataService;
 import com.google.common.base.Stopwatch;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/JobService.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
 import com.github.kfcfans.powerjob.common.InstanceStatus;
 import com.github.kfcfans.powerjob.common.PowerJobException;
@@ -6,18 +6,18 @@ import com.github.kfcfans.powerjob.common.PowerQuery;
 import com.github.kfcfans.powerjob.common.TimeExpressionType;
 import com.github.kfcfans.powerjob.common.request.http.SaveJobInfoRequest;
 import com.github.kfcfans.powerjob.common.response.JobInfoDTO;
-import com.github.kfcfans.powerjob.server.common.SJ;
-import com.github.kfcfans.powerjob.server.common.constants.SwitchableStatus;
-import com.github.kfcfans.powerjob.server.common.utils.CronExpression;
-import com.github.kfcfans.powerjob.server.common.utils.QueryConvertUtils;
-import com.github.kfcfans.powerjob.server.persistence.core.model.InstanceInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.model.JobInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.InstanceInfoRepository;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.JobInfoRepository;
-import com.github.kfcfans.powerjob.server.remote.DispatchService;
-import com.github.kfcfans.powerjob.server.remote.server.redirector.DesignateServer;
-import com.github.kfcfans.powerjob.server.service.instance.InstanceService;
-import com.github.kfcfans.powerjob.server.service.instance.InstanceTimeWheelService;
+import tech.powerjob.server.common.SJ;
+import tech.powerjob.server.common.constants.SwitchableStatus;
+import tech.powerjob.server.common.utils.CronExpression;
+import tech.powerjob.server.common.utils.QueryConvertUtils;
+import tech.powerjob.server.persistence.core.model.InstanceInfoDO;
+import tech.powerjob.server.persistence.core.model.JobInfoDO;
+import tech.powerjob.server.persistence.core.repository.InstanceInfoRepository;
+import tech.powerjob.server.persistence.core.repository.JobInfoRepository;
+import tech.powerjob.server.remote.DispatchService;
+import tech.powerjob.server.remote.server.redirector.DesignateServer;
+import tech.powerjob.server.service.instance.InstanceService;
+import tech.powerjob.server.service.instance.InstanceTimeWheelService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.data.jpa.domain.Specification;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/UserService.java

@@ -1,8 +1,8 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
-import com.github.kfcfans.powerjob.server.persistence.core.model.UserInfoDO;
-import com.github.kfcfans.powerjob.server.persistence.core.repository.UserInfoRepository;
-import com.github.kfcfans.powerjob.server.web.request.ModifyUserInfoRequest;
+import tech.powerjob.server.persistence.core.model.UserInfoDO;
+import tech.powerjob.server.persistence.core.repository.UserInfoRepository;
+import tech.powerjob.server.web.request.ModifyUserInfoRequest;
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import org.springframework.beans.BeanUtils;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/ValidateService.java

@@ -1,8 +1,8 @@
-package com.github.kfcfans.powerjob.server.service;
+package tech.powerjob.server.service;
 
 import com.github.kfcfans.powerjob.common.OmsConstant;
 import com.github.kfcfans.powerjob.common.TimeExpressionType;
-import com.github.kfcfans.powerjob.server.common.utils.CronExpression;
+import tech.powerjob.server.common.utils.CronExpression;
 import com.google.common.collect.Lists;
 import org.apache.commons.lang3.time.DateFormatUtils;
 

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/alarm/Alarm.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.service.alarm;
+package tech.powerjob.server.service.alarm;
 
 import com.alibaba.fastjson.JSONObject;
 import com.github.kfcfans.powerjob.common.OmsConstant;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/alarm/AlarmCenter.java

@@ -1,7 +1,7 @@
-package com.github.kfcfans.powerjob.server.service.alarm;
+package tech.powerjob.server.service.alarm;
 
-import com.github.kfcfans.powerjob.server.extension.Alarmable;
-import com.github.kfcfans.powerjob.server.persistence.core.model.UserInfoDO;
+import tech.powerjob.server.extension.Alarmable;
+import tech.powerjob.server.persistence.core.model.UserInfoDO;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Queues;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;

powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/service/alarm/JobInstanceAlarm.java

@@ -1,4 +1,4 @@
-package com.github.kfcfans.powerjob.server.service.alarm;
+package tech.powerjob.server.service.alarm;
 
 import lombok.Data;