将源码打包进jar包

yzg-util-redis/src/main/java/com.yanzuoguang.redis/service/PlanRegister.java

@@ -6,6 +6,8 @@ import com.yanzuoguang.redis.def.PlanNameDefault;
 import com.yanzuoguang.redis.def.PlanStartDefault;
 import com.yanzuoguang.redis.vo.PlanConfigVo;
 import com.yanzuoguang.redis.vo.PlanLevelType;
+import com.yanzuoguang.util.exception.CodeException;
+import com.yanzuoguang.util.helper.StringHelper;
 import com.yanzuoguang.util.log.Log;
 import org.springframework.stereotype.Component;
 
@@ -34,14 +36,7 @@ public class PlanRegister {
 
     public PlanRegister(Optional<List<Plan>> plans, List<PlanLevelNamespaceDefault> planLevelNamespaceDefaults) {
         // 先注册默认命名空间处理
-        planLevelNamespaceDefaults.forEach(k -> {
-            PlanLevelType level = k.getLevel();
-            if (mapLevelTypeNamespaceDefault.containsKey(level)) {
-                Log.error(PlanRegister.class, "默认命名级别处理%s已经存在!", level.getName());
-                return;
-            }
-            mapLevelTypeNamespaceDefault.put(level, k);
-        });
+        planLevelNamespaceDefaults.forEach(this::registerNamespaceDefault);
         // 再注册所有任务
         plans.ifPresent(planList -> planList.forEach(this::register));
     }
@@ -65,12 +60,29 @@ public class PlanRegister {
         return mapPlan.get(key);
     }
 
+    /**
+     * 任务命名级别
+     *
+     * @param planLevelNamespaceDefault 默认任务命名级别命名空间
+     */
+    public void registerNamespaceDefault(PlanLevelNamespaceDefault planLevelNamespaceDefault) {
+        if (planLevelNamespaceDefault == null) {
+            return;
+        }
+        PlanLevelType level = planLevelNamespaceDefault.getLevel();
+        if (mapLevelTypeNamespaceDefault.containsKey(level)) {
+            Log.error(PlanRegister.class, "默认命名级别处理%s已经存在!", level.getName());
+            return;
+        }
+        mapLevelTypeNamespaceDefault.put(level, planLevelNamespaceDefault);
+    }
+
     /**
      * 注册任务
      *
      * @param plan 待注册的任务
      */
-    private void register(Plan plan) {
+    public void register(Plan plan) {
         if (plan == null) {
             return;
         }
@@ -86,9 +98,30 @@ public class PlanRegister {
         // 任务关键字
         PlanName planName = getPlanName(plan);
         // 任务配置信息
-        PlanConfigVo planConfigVo = new PlanConfigVo(plan, planName, planStart, planLevelNamespace);
+        PlanConfigVo planConfig = new PlanConfigVo(plan, planName, planStart, planLevelNamespace);
+        // 任务配置
+        register(planConfig);
+    }
+
+    /**
+     * 注册中心
+     *
+     * @param planConfig 任务配置
+     */
+    public void register(PlanConfigVo planConfig) {
+        if (planConfig == null) {
+            return;
+        }
+        if (planConfig.getPlan() == null
+                || planConfig.getPlanStart() == null
+                || planConfig.getPlanName() == null
+                || planConfig.getPlanLevelNamespace() == null
+                || StringHelper.isEmpty(planConfig.getPlanName().getPlanKey())
+        ) {
+            throw new CodeException("注册任务失败,参数不能为空");
+        }
         // 任务配置
-        mapPlan.put(planName.getPlanKey(), planConfigVo);
+        mapPlan.put(planConfig.getPlanName().getPlanKey(), planConfig);
     }
 
     /**