增加ID生成

performance-web/src/main/java/com/clx/performance/component/IdGenerateSnowFlake.java

@@ -15,7 +15,6 @@ import java.util.concurrent.atomic.AtomicLong;
  * datacenterId：根据服务的ip地址区分，当前最多支持32太机器
  * channelConfTypeId： 用于区分不同渠道的消息标示 用了6位的二进制位标示
  * 从17位~23位 可看当前消息类型
- * channelConfType ： 1:充值  2：外呼 3:push
  */
 @Component
 public class IdGenerateSnowFlake implements InitializingBean {
@@ -156,9 +155,9 @@ public class IdGenerateSnowFlake implements InitializingBean {
      */
     @Override
     public void afterPropertiesSet() throws Exception {
-        //Map<Object, Object> msgSnowFlake = redisTemplate.opsForHash().entries(RedisConstants.ID_SNOWFLAKE);
+        Map<Object, Object> msgSnowFlake = redisTemplate.opsForHash().entries(RedisConstants.ID_SNOWFLAKE);
         String ip = nacosDiscoveryProperties.getIp();
-        //datacenterId = msgSnowFlake.size() % 32;
-        //redisTemplate.opsForHash().put(RedisConstants.ID_SNOWFLAKE, ip, String.valueOf(msgSnowFlake.size() + 1));
+        datacenterId = msgSnowFlake.size() % 32;
+        redisTemplate.opsForHash().put(RedisConstants.ID_SNOWFLAKE, ip, String.valueOf(msgSnowFlake.size() + 1));
     }
 }
\ No newline at end of file

performance-web/src/main/java/com/clx/performance/constant/RedisConstants.java

@@ -26,4 +26,9 @@ public class RedisConstants {
 
     public static final String ORDER_GOODS_TRUCK_RECORD = "clx:order:goods:truck:record:";
     public static final String ORDER_GOODS_RECORD = "clx:order:goods:record:";
+
+    /**
+     * 雪花
+     */
+    public static final String ID_SNOWFLAKE = "clx-performance:idsnowflake";
 }