fix test case

Author: ponfee

disjob-admin/ruoyi-common/src/main/java/com/ruoyi/common/constant/ScheduleConstants.java

@@ -37,8 +37,6 @@
 /**
  * Worker for execute task(JVM instance)
  *
- * <p>Also instance of use: @JsonCreator + @JsonProperty("group")
- *
  * @author Ponfee
  * @see com.fasterxml.jackson.annotation.JsonCreator
  * @see com.fasterxml.jackson.annotation.JsonProperty
@@ -200,11 +198,21 @@ private Current(String group, String workerId, String host, int port) {
             SingletonClassConstraint.constrain(Current.class);
         }
 
+        /**
+         * 返回http headers，用于Worker远程调用Supervisor RPC接口的授权信息
+         *
+         * @return map of authenticate http headers
+         */
         public abstract Map<String, String> authenticateHeaders();
 
+        /**
+         * 认证Supervisor远程调用Worker RPC接口的授权信息
+         *
+         * @param param authentication param
+         */
         public abstract void authenticate(AuthenticationParam param);
 
-        // need to use reflection do set
+        // need do reflection call
         // use synchronized modify for help multiple thread read reference(write to main memory)
         private static synchronized Current create(String group, String workerId, String host, int port,
                                                    String workerToken, String supervisorToken0) {

disjob-core/src/main/java/cn/ponfee/disjob/core/base/Worker.java

@@ -213,9 +213,11 @@ private String obtainJobHandler() {
                 Assert.hasText(job.getJobHandler(), () -> "General job handler cannot be null: " + job.getJobId());
                 return job.getJobHandler();
             }
-            Assert.hasText(instance.getAttach(), () -> "Workflow node instance attach cannot be null: " + instance.getInstanceId());
+
             InstanceAttach attach = Jsons.fromJson(instance.getAttach(), InstanceAttach.class);
-            return DAGNode.fromString(attach.getCurNode()).getName();
+            String curNode = DAGNode.fromString(attach.getCurNode()).getName();
+            Assert.hasText(curNode, () -> "Workflow instance attach cur node cannot be null: " + instance.getInstanceId());
+            return curNode;
         }
     }
 

disjob-dispatch/disjob-dispatch-api/src/main/java/cn/ponfee/disjob/dispatch/ExecuteTaskParam.java

@@ -83,7 +83,7 @@ public void test() {
         String[] array = new String[ThreadLocalRandom.current().nextInt(17) + 3];
         array[0] = key;
         for (int i = 1; i < array.length; i++) {
-            array[i] = RandomStringUtils.randomAlphanumeric(ThreadLocalRandom.current().nextInt(5) + 1);
+            array[i] = RandomStringUtils.randomAlphanumeric(ThreadLocalRandom.current().nextInt(5) + 2);
         }
         List<String> workers = Arrays.asList(array);
         Collections.shuffle(workers);

disjob-dispatch/disjob-dispatch-api/src/test/java/cn/ponfee/disjob/dispatch/route/ConsistentHashExecutionRouterTest.java

@@ -51,11 +51,11 @@
  *
  * <pre>
  * /snowflake/{bizTag}
- * ├── tag
+ * ├── tag (children are EPHEMERAL node)
  * │   ├── serverTag-a   data=workerId-1
  * │   ├── serverTag-b   data=workerId-2
  * │   └── serverTag-c   data=workerId-3
- * └── id
+ * └── id (children are EPHEMERAL node)
  *     ├── workerId-1    data=lastHeartbeatTime
  *     ├── workerId-2    data=lastHeartbeatTime
  *     └── workerId-3    data=lastHeartbeatTime

disjob-id/src/main/java/cn/ponfee/disjob/id/snowflake/zk/ZkDistributedSnowflake.java

@@ -0,0 +1,40 @@
+///* __________              _____                                                *\
+//** \______   \____   _____/ ____\____   ____    Copyright (c) 2017-2023 Ponfee  **
+//**  |     ___/  _ \ /    \   __\/ __ \_/ __ \   http://www.ponfee.cn            **
+//**  |    |  (  <_> )   |  \  | \  ___/\  ___/   Apache License Version 2.0      **
+//**  |____|   \____/|___|  /__|  \___  >\___  >  http://www.apache.org/licenses/ **
+//**                      \/          \/     \/                                   **
+//\*                                                                              */
+//
+//package cn.ponfee.disjob.supervisor.config;
+//
+//import cn.ponfee.disjob.core.param.worker.AuthenticationParam;
+//import org.apache.commons.lang3.ArrayUtils;
+//import org.aspectj.lang.JoinPoint;
+//import org.aspectj.lang.annotation.Aspect;
+//import org.aspectj.lang.annotation.Before;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * Aspect test
+// *
+// * @author Ponfee
+// */
+//@Aspect
+//@Component
+//public class AuthenticationCallWorker {
+//
+//    @Before("execution(* cn.ponfee.disjob..*.*(..,cn.ponfee.disjob.core.param.worker.AuthenticationParam+,..))")
+//    public void doBefore(JoinPoint point) {
+//        Object[] args = point.getArgs();
+//        if (ArrayUtils.isEmpty(args)) {
+//            return;
+//        }
+//        for (Object arg : args) {
+//            if (arg instanceof AuthenticationParam) {
+//                ((AuthenticationParam) arg).setSupervisorToken("xxxxx");
+//            }
+//        }
+//    }
+//
+//}