云端与库端数据同步；

src/main/java/com/unissoft/basic/controller/BasicEnumController.java

@@ -4,6 +4,8 @@ package com.unissoft.basic.controller;
 import java.util.Date;
 import java.util.List;
 
+import com.unissoft.common.*;
+import com.unissoft.mqProducer.Producer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -16,9 +18,6 @@ import org.springframework.web.bind.annotation.RestController;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.basic.model.BasicEnum;
 import com.unissoft.basic.service.BasicEnumService;
-import com.unissoft.common.PageParam;
-import com.unissoft.common.ResultView;
-import com.unissoft.common.SystemLog;
 import com.unissoft.parameter.model.HardwareParameter;
 
 import io.swagger.annotations.ApiOperation;
@@ -34,6 +33,8 @@ import io.swagger.annotations.ApiOperation;
 @RestController
 @RequestMapping("/basic-enum")
 public class BasicEnumController {
+    @Autowired
+    private Producer producer;
 
 	private BasicEnumService enumService;
 
@@ -56,7 +57,7 @@ public class BasicEnumController {
 
     /**
      * 新增
-     * @param hdParameter
+     * @param basicEnum
      * @return
      */
     @SystemLog(operModul = "参数设置", operType = "数据字典", operDesc = "数据字典新增")
@@ -66,16 +67,18 @@ public class BasicEnumController {
     	basicEnum.setCreateTime(date);
     	basicEnum.setUpdateTime(date);
         boolean save = enumService.save(basicEnum);
-        if (save)
+        if (save) {
+            producer.send(basicEnum, MessageEnum.SAVE, ServiceEnum.BASIC_ENUM);
             return ResultView.success();
-        else
+        }else {
             return ResultView.error();
+        }
     }
     
     
     /**
      * 修改
-     * @param hdParameter
+     * @param basicEnum
      * @return
      */
     @SystemLog(operModul = "参数设置", operType = "数据字典", operDesc = "数据字典修改")
@@ -83,10 +86,13 @@ public class BasicEnumController {
     public ResultView update(@RequestBody BasicEnum basicEnum) {
     	basicEnum.setUpdateTime(new Date());
         boolean b = enumService.updateById(basicEnum);
-        if (b)
+        if (b) {
+            //发送消息
+            producer.send(basicEnum, MessageEnum.UPDATE,ServiceEnum.BASIC_ENUM);
             return ResultView.success();
-        else
+        }else {
             return ResultView.error();
+        }
     }
     
     

src/main/java/com/unissoft/basic/model/BasicEnum.java

@@ -30,8 +30,8 @@ public class BasicEnum implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "字典表")
-    @TableId(value = "id", type = IdType.AUTO)
-    private Integer id;
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private Long id;
 
     @ApiModelProperty(value = "编码")
     @TableField("enum_code")
@@ -43,7 +43,7 @@ public class BasicEnum implements Serializable {
 
     @ApiModelProperty(value = "父节点id")
     @TableField("parent_id")
-    private Integer parentId;
+    private Long parentId;
 
     @ApiModelProperty(value = "创建时间")
     @TableField("create_time")
@@ -73,11 +73,11 @@ public class BasicEnum implements Serializable {
 	}
 	
 
-	public Integer getId() {
+	public Long getId() {
 		return id;
 	}
 
-	public void setId(Integer id) {
+	public void setId(Long id) {
 		this.id = id;
 	}
 
@@ -97,11 +97,11 @@ public class BasicEnum implements Serializable {
 		this.enumName = enumName;
 	}
 
-	public Integer getParentId() {
+	public Long getParentId() {
 		return parentId;
 	}
 
-	public void setParentId(Integer parentId) {
+	public void setParentId(Long parentId) {
 		this.parentId = parentId;
 	}
 

src/main/java/com/unissoft/basic/service/impl/BasicEnumServiceImpl.java

@@ -70,12 +70,12 @@ public class BasicEnumServiceImpl extends ServiceImpl<BasicEnumMapper, BasicEnum
         }*/
 		ew.orderByAsc("parent_id");
 		List<BasicEnum> list = enumMapper.selectList(ew); //查询到满足条件所有的数据
-		List<BasicEnum> firstlist = this.getChildren(list, 0,condition);
+		List<BasicEnum> firstlist = this.getChildren(list, 0L,condition);
 		this.fillTree(list, firstlist);
 		return firstlist;
 	}
 	
-	private List<BasicEnum> getChildren(List<BasicEnum> list, Integer parentId,String condition) {
+	private List<BasicEnum> getChildren(List<BasicEnum> list, Long parentId,String condition) {
         String  enumName = null;
         String  enumCode = null;
 		if (!StringUtils.isEmpty(condition)) {

src/main/java/com/unissoft/common/MessageEnum.java

@@ -0,0 +1,21 @@
+package com.unissoft.common;
+
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Map;
+
+/**
+ * ClassName: MessageTypeEnum
+ * Package: com.unissoft.common
+ * Description: MQ传递消息类型
+ *
+ * @Author zlq
+ * @Create 2023/3/6 10:37
+ * @Version 1.0
+ */
+public enum MessageEnum {
+    SAVE,UPDATE,DELETE;
+
+    private Map Param;
+
+}

src/main/java/com/unissoft/common/ServiceEnum.java

@@ -0,0 +1,33 @@
+package com.unissoft.common;
+
+import com.unissoft.parameter.model.HardwareParameter;
+
+/**
+ * ClassName: ServiceEnum
+ * Package: com.unissoft.common
+ * Description:
+ *
+ * @Author zlq
+ * @Create 2023/3/6 14:38
+ * @Version 1.0
+ */
+public enum ServiceEnum {
+    HD_PARAMETER(1),
+    BASIC_ENUM(2),
+    NBASIC_EDGE(3),
+    ROLE_INFO(4),
+    ORG_INFO(5),
+    STOREHOUSE_CLXX(6),
+    USER_INFO(7);
+
+
+
+    private int code;
+
+    ServiceEnum(int code) {
+        this.code = code;
+    }
+    public int getCode(){
+        return code;
+    }
+}

src/main/java/com/unissoft/config/IdGenerator16Bit.java

@@ -0,0 +1,109 @@
+package com.unissoft.config;
+
+import java.util.Date;
+import java.util.UUID;
+
+/**
+ * ClassName: IdGenerator16Bit
+ * Package: com.unissoft.config
+ * Description:
+ *
+ * @Author zlq
+ * @Create 2023/3/3 17:56
+ * @Version 1.0
+ */
+public class IdGenerator16Bit {
+    private static IdGenerator16Bit instance = new IdGenerator16Bit(0);
+
+    public static IdGenerator16Bit initDefaultInstance(int machineId) {
+        instance = new IdGenerator16Bit(machineId);
+        return instance;
+    }
+
+    public static IdGenerator16Bit getInstance() {
+        return instance;
+    }
+
+    public static long generateId() {
+        return instance.nextId();
+    }
+
+    // total bits=53(max 2^53-1：9007199254740992-1)
+
+    // private final static long TIME_BIT = 40; // max: 2318-06-04
+    private final static long MACHINE_BIT = 5; // max 31
+    private final static long SEQUENCE_BIT = 8; // 256/10ms
+
+    /**
+     * mask/max value
+     */
+    private final static long MAX_MACHINE_NUM = -1L ^ (-1L << MACHINE_BIT);
+    private final static long MAX_SEQUENCE = -1L ^ (-1L << SEQUENCE_BIT);
+
+    private final static long MACHINE_LEFT = SEQUENCE_BIT;
+    private final static long TIMESTMP_LEFT = MACHINE_BIT + SEQUENCE_BIT;
+
+    private long machineId;
+    private long sequence = 0L;
+    private long lastStmp = -1L;
+
+    private IdGenerator16Bit(long machineId) {
+        if (machineId > MAX_MACHINE_NUM || machineId < 0) {
+            throw new IllegalArgumentException(
+                    "machineId can't be greater than " + MAX_MACHINE_NUM + " or less than 0");
+        }
+        this.machineId = machineId;
+    }
+
+    /**
+     * generate new ID
+     *
+     * @return
+     */
+    public synchronized long nextId() {
+        long currStmp = getTimestamp();
+        if (currStmp < lastStmp) {
+            throw new RuntimeException("Clock moved backwards.  Refusing to generate id");
+        }
+
+        if (currStmp == lastStmp) {
+            sequence = (sequence + 1) & MAX_SEQUENCE;
+            if (sequence == 0L) {
+                currStmp = getNextTimestamp();
+            }
+        } else {
+            sequence = 0L;
+        }
+
+        lastStmp = currStmp;
+
+        return currStmp << TIMESTMP_LEFT //
+                | machineId << MACHINE_LEFT //
+                | sequence;
+    }
+
+    private long getNextTimestamp() {
+        long mill = getTimestamp();
+        while (mill <= lastStmp) {
+            mill = getTimestamp();
+        }
+        return mill;
+    }
+
+    private long getTimestamp() {
+        // per 10ms
+        return System.currentTimeMillis() / 10;// 10ms
+    }
+
+    public static Date parseIdTimestamp(long id) {
+        return new Date((id >>> TIMESTMP_LEFT) * 10);
+    }
+
+    public static String uuid() {
+        return UUID.randomUUID().toString().replaceAll("-", "");
+    }
+}
+
+
+
+

src/main/java/com/unissoft/mqConsumer/Consumer.java

@@ -0,0 +1,82 @@
+package com.unissoft.mqConsumer;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.unissoft.mqConsumer.Manager.ServiceManager;
+import com.unissoft.parameter.model.HardwareParameter;
+import com.unissoft.parameter.service.HardwareParameterService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
+import org.apache.rocketmq.spring.core.RocketMQListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+
+/**
+ * ClassName: HardwareParameterConsumer
+ * Package: com.unissoft.mqConsumer
+ * Description: 硬件参数 消息消费者
+ *
+ * @Author zlq
+ * @Create 2023/3/3 10:42
+ * @Version 1.0
+ */
+@Slf4j
+@Component
+public class Consumer {
+    @Autowired
+    private ServiceManager serviceManager;
+
+
+    private final String topic = "TOPIC_LOCAL";
+    //库端TOPIK，云端使用
+    private final String topicLocal="TOPIC_LOCAL";
+    //云端topic,库端使用
+    private final String topicCloud="TOPIC_CLOUD";
+
+    private final String consumerGroup = "consumerGroup";
+
+    @Component
+    @RocketMQMessageListener(topic = topicLocal,consumerGroup = "local")
+    public class HPSave implements RocketMQListener<String>{
+        @Override
+        public void onMessage(String message) {
+            if (message == null) {
+                log.info("消息为空：｛｝",message);
+                return;
+            }
+            log.info("接收到的消息：{}",message);
+            JSONObject message1 = JSON.parseObject(message);
+            JSONObject headers = message1.getJSONObject("headers");
+
+            String type = headers.getString("type");
+            String payload = message1.getString("payload");
+            //获取消息所在业务
+            String service = headers.getString("service");
+
+            switch (service){
+                case "HD_PARAMETER":
+                    serviceManager.HDManager(payload,type);
+                    break;
+                case "BASIC_ENUM":
+                    serviceManager.BasicEnumManager(payload,type);
+                    break;
+                case "NBASIC_EDGE":
+                    serviceManager.NBasicEdgeManager(payload,type);
+                    break;
+                case "ROLE_INFO":
+                    serviceManager.RoleInfoManager(payload,type);
+                    break;
+                case "USER_INFO":
+                    serviceManager.UserInfoManager(payload,type);
+                    break;
+                case "ORG_INFO":
+                    serviceManager.OrgInfoManager(payload,type);
+                    break;
+                default:
+                    log.info("没有可用的业务类型！！");
+            }
+        }
+    }
+
+}

src/main/java/com/unissoft/mqConsumer/Manager/ServiceManager.java

@@ -0,0 +1,188 @@
+package com.unissoft.mqConsumer.Manager;
+
+import com.alibaba.fastjson.JSON;
+import com.unissoft.basic.model.BasicEnum;
+import com.unissoft.basic.service.BasicEnumService;
+import com.unissoft.parameter.model.HardwareParameter;
+import com.unissoft.parameter.service.HardwareParameterService;
+import com.unissoft.systemManage.model.*;
+import com.unissoft.systemManage.service.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * ClassName: HDManager
+ * Package: com.unissoft.mqConsumer.Manager
+ * Description: 接收处理业务数据
+ *
+ * @Author zlq
+ * @Create 2023/3/6 15:08
+ * @Version 1.0
+ */
+@Slf4j
+@Component
+public class ServiceManager {
+    @Resource
+    private RoleInfoService roleInfoService;
+    @Resource
+    private NBasicEdgeService nBasicEdgeService;
+    @Autowired
+    private BasicEnumService basicEnumService;
+
+    @Autowired
+    private HardwareParameterService hardwareParameterService;
+
+    /**
+     * 硬件参数
+     * @param payload
+     * @param type
+     */
+    public void HDManager(String payload,String type){
+        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
+        switch (type){
+            case "SAVE":
+                //获取硬件参数对象
+                HardwareParameter hardwareParameter = JSON.parseObject(payload, HardwareParameter.class);
+                //新增硬件数据
+                    boolean save = hardwareParameterService.save(hardwareParameter);
+                log.info("新增硬件信息{},是否成功：{}",payload,save);
+                break;
+            case "UPDATE":
+                //获取硬件参数对象
+
+                HardwareParameter hardwareParameter1 = JSON.parseObject(payload, HardwareParameter.class);
+                    boolean b1 = hardwareParameterService.updateById(hardwareParameter1);
+                log.info("修改硬件信息{},是否成功：{}",payload,b1);
+                break;
+            case "DELETE":
+                    boolean b2 = hardwareParameterService.removeById(payload);
+                log.info("删除硬件id{},是否成功：{}",payload,b2);
+                break;
+        }
+    }
+
+    /**
+     * 字典
+     * @param payload
+     * @param type
+     */
+    public void BasicEnumManager(String payload,String type){
+        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
+        switch (type){
+            case "SAVE":
+                BasicEnum basicEnum = JSON.parseObject(payload, BasicEnum.class);
+                boolean save = basicEnumService.save(basicEnum);
+                log.info("新增字典{},是否成功：{}",payload,save);
+                break;
+            case "UPDATE":
+                BasicEnum basicEnum1 = JSON.parseObject(payload, BasicEnum.class);
+                boolean b = basicEnumService.updateById(basicEnum1);
+                log.info("修改字典信息{},是否成功：{}",payload,b);
+                break;
+        }
+    }
+
+    /**
+     *打点的数据查询表
+     * @param payload
+     * @param type
+     */
+    public void NBasicEdgeManager(String payload,String type){
+        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
+        switch (type){
+            case "SAVE":
+                NBasicEdge nBasicEdge = JSON.parseObject(payload, NBasicEdge.class);
+                boolean save = nBasicEdgeService.save(nBasicEdge);
+                log.info("新增打点的数据信息{},是否成功：{}",payload,save);
+                break;
+            case "UPDATE":
+                NBasicEdge nBasicEdge1 = JSON.parseObject(payload, NBasicEdge.class);
+                boolean b = nBasicEdgeService.updateById(nBasicEdge1);
+                log.info("修改打点的数据信息{},是否成功：{}",payload,b);
+                break;
+        }
+    }
+
+
+    /**
+     *用户角色消息
+     * @param payload
+     * @param type
+     */
+    public void RoleInfoManager(String payload,String type){
+        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
+        switch (type){
+            case "SAVE":
+                RoleInfo roleInfo = JSON.parseObject(payload, RoleInfo.class);
+                boolean save = roleInfoService.save(roleInfo);
+                log.info("新增角色消息{},是否成功：{}",payload,save);
+                break;
+            case "UPDATE":
+                RoleInfo roleInfo1 = JSON.parseObject(payload, RoleInfo.class);
+                boolean b = roleInfoService.updateById(roleInfo1);
+                log.info("修改角色消息{},是否成功：{}",payload,b);
+                break;
+            case "DELETE":
+                boolean b2 = roleInfoService.removeById(payload);
+                log.info("删除角色id{},是否成功：{}",payload,b2);
+                break;
+        }
+    }
+
+    @Resource
+    private UserInfoService userInfoService;
+
+    /**
+     *用户消息
+     * @param payload
+     * @param type
+     */
+    public void UserInfoManager(String payload,String type){
+        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
+        switch (type){
+            case "SAVE":
+                UserInfo userInfo = JSON.parseObject(payload, UserInfo.class);
+                boolean save = userInfoService.save(userInfo);
+                log.info("新增用户{},是否成功：{}",payload,save);
+                break;
+            case "UPDATE":
+                UserInfo userInfo1 = JSON.parseObject(payload, UserInfo.class);
+                boolean b = userInfoService.updateById(userInfo1);
+                log.info("修改用户{},是否成功：{}",payload,b);
+                break;
+            case "DELETE":
+                boolean b2 = userInfoService.removeById(payload);
+                log.info("删除用户{},是否成功：{}",payload,b2);
+                break;
+        }
+    }
+    @Resource
+    private OrgInfoService orgInfoService;
+    /**
+     *组织机构消息
+     * @param payload
+     * @param type
+     */
+    public void OrgInfoManager(String payload,String type){
+        //对不同的业务操作进行处理：SAVE,UPDATE,DELETE;
+        switch (type){
+            case "SAVE":
+                OrgInfo orgInfo = JSON.parseObject(payload, OrgInfo.class);
+                boolean save = orgInfoService.save(orgInfo);
+                log.info("新增组织机构{},是否成功：{}",payload,save);
+                break;
+            case "UPDATE":
+                OrgInfo orgInfo1 = JSON.parseObject(payload, OrgInfo.class);
+                boolean b = orgInfoService.updateById(orgInfo1);
+                log.info("修改组织机构信息{},是否成功：{}",payload,b);
+                break;
+            case "DELETE":
+                boolean b2 = orgInfoService.removeById(payload);
+                log.info("删除组织机构id{},是否成功：{}",payload,b2);
+                break;
+        }
+    }
+}

src/main/java/com/unissoft/mqConsumer/TeDataConsumer.java

@@ -1,53 +0,0 @@
-package com.unissoft.mqConsumer;
-
-import com.alibaba.fastjson.JSON;
-import com.unissoft.interaction.entity.TeData;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.common.TopicConfig;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.springframework.stereotype.Component;
-import org.springframework.stereotype.Service;
-
-/**
- * ClassName: ConService
- * Package: com.unissoft.mqConsumer
- * Description:新增，修改，删除
- *
- * @Author zlq
- * @Create 2023/3/2 10:36
- * @Version 1.0
- */
-@Slf4j
-@Component
-public class TeDataConsumer{
-
-    @Component
-    @RocketMQMessageListener(topic = "TOPIC_LOCAL",consumerGroup = "${rocketmq.consumer.group}",selectorExpression = "TD_SAVE")
-    public class TDSave implements RocketMQListener<TeData>{
-        /**
-         * 新增tedata
-         * @param teData 接收到的数据
-         */
-        @Override
-        public void onMessage(TeData teData) {
-            System.out.println("接收到的消息"+teData.toString());
-        }
-    }
-
-//
-//    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
-//    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
-//    @Service
-//    @RocketMQMessageListener(topic = "TOPIC_1", selectorExpression = "tag1", consumerGroup = "Con_Group_One")
-//    public class ConsumerSend implements RocketMQListener<TeData> {
-//
-//        // 监听到消息就会执行此方法
-//        @Override
-//        public void onMessage(TeData teData) {
-//            System.out.println("接收到的消息"+teData.toString());
-//            log.info("监听到消息：user={}", JSON.toJSONString(teData));
-//        }
-//    }
-
-}

src/main/java/com/unissoft/mqConsumer/UserInfoConsumer.java

@@ -1,44 +0,0 @@
-package com.unissoft.mqConsumer;
-
-import com.alibaba.fastjson.JSON;
-import com.unissoft.interaction.entity.TeData;
-import com.unissoft.systemManage.model.UserInfo;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.springframework.stereotype.Component;
-
-/**
- * ClassName: ConService
- * Package: com.unissoft.mqConsumer
- * Description:
- *
- * @Author zlq
- * @Create 2023/3/2 10:36
- * @Version 1.0
- */
-@Slf4j
-@Component
-@RocketMQMessageListener(topic = "TOPIC_LOCAL",consumerGroup = "${rocketmq.consumer.group}",selectorExpression = "userInfo")
-public class UserInfoConsumer implements RocketMQListener<UserInfo> {
-
-    @Override
-    public void onMessage(UserInfo s) {
-        log.info("监听到消息：user={}", JSON.toJSONString(s));
-    }
-//
-//    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
-//    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息
-//    @Service
-//    @RocketMQMessageListener(topic = "TOPIC_1", selectorExpression = "tag1", consumerGroup = "Con_Group_One")
-//    public class ConsumerSend implements RocketMQListener<TeData> {
-//
-//        // 监听到消息就会执行此方法
-//        @Override
-//        public void onMessage(TeData teData) {
-//            System.out.println("接收到的消息"+teData.toString());
-//            log.info("监听到消息：user={}", JSON.toJSONString(teData));
-//        }
-//    }
-
-}

src/main/java/com/unissoft/mqProducer/Producer.java

@@ -1,14 +1,20 @@
 package com.unissoft.mqProducer;
 
 
-import com.unissoft.interaction.entity.TeData;
+import com.unissoft.common.MessageEnum;
+import com.unissoft.common.ServiceEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.producer.SendResult;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.messaging.MessageHeaders;
 import org.springframework.messaging.support.MessageBuilder;
 import org.springframework.stereotype.Component;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * ClassName: ProService
  * Package: com.unissoft.mqProducer
@@ -21,29 +27,36 @@ import org.springframework.stereotype.Component;
 @Slf4j
 @Component("producer")
 public class Producer {
-    //topic名称
-    private final String topic="TOPIC_LOCAL:";
+    //库端TOPIK，库端使用
+    private final String topicLocal="TOPIC_LOCAL";
+    //云端topic，云端使用
+    private final String topicCloud="TOPIC_CLOUD";
 
     @Autowired
     private RocketMQTemplate rocketMQTemplate;
 
     /**
      *
-     * @param msgBody 消息内容
-     * @param tag  消息类型
+     * @param body 消息内容
+     * @param type  消息属性
      */
-    public void send(Object msgBody, String tag){
-        rocketMQTemplate.convertAndSend(topic+tag,msgBody);
+    public void send(Object body, MessageEnum type, ServiceEnum ser){
+        Map<String, Object> map = new HashMap<>();
+        map.put("type",type);
+        map.put("service",ser);
+        org.springframework.messaging.Message<Object> message = MessageBuilder.createMessage(body, new MessageHeaders(map));
+        rocketMQTemplate.convertAndSend(topicCloud,message);
+        log.info("发送消息：{}",message);
     }
 
     /**
      *
-     * @param msgBody  需要发送的消息
+     * @param msgBody  同步发送的消息
      * @param tag  消息类型
      * @return
      */
     public SendResult sendMsg(String msgBody,String tag) {
-        SendResult sendResult = rocketMQTemplate.syncSend(topic+tag, MessageBuilder.withPayload(msgBody).build());
+        SendResult sendResult = rocketMQTemplate.syncSend(topicLocal+tag, MessageBuilder.withPayload(msgBody).build());
         return sendResult;
     }
 

src/main/java/com/unissoft/parameter/controller/HardwareParameterController.java

@@ -2,18 +2,14 @@ package com.unissoft.parameter.controller;
 
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.unissoft.common.PageParam;
-import com.unissoft.common.ResultView;
-import com.unissoft.common.SystemLog;
+import com.unissoft.common.*;
 import com.unissoft.mqProducer.Producer;
 import com.unissoft.parameter.model.HardwareParameter;
 import com.unissoft.parameter.service.HardwareParameterService;
 
 import io.swagger.annotations.ApiOperation;
 
-import java.math.BigDecimal;
 import java.util.Date;
-import java.util.Random;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -66,7 +62,7 @@ public class HardwareParameterController {
     	hdParameter.setCreateTime(new Date());
         boolean save = hdService.save(hdParameter);
         if (save) {
-            producer.send(hdParameter, "HP_SAVE");
+            producer.send(hdParameter, MessageEnum.SAVE, ServiceEnum.HD_PARAMETER);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -82,7 +78,7 @@ public class HardwareParameterController {
     public ResultView updateUser(@RequestBody HardwareParameter hdParameter) {
         boolean b = hdService.updateById(hdParameter);
         if (b) {
-            producer.send(hdParameter, "HP_UPDATE");
+            producer.send(hdParameter, MessageEnum.UPDATE,ServiceEnum.HD_PARAMETER);
             return ResultView.success();
         }else
             return ResultView.error();
@@ -99,18 +95,11 @@ public class HardwareParameterController {
     @DeleteMapping("/deleteById/{id}")
     public ResultView deleteById(@PathVariable String id) {
     	boolean b = hdService.removeById(id);
-        int i = hdService.deleteHarParamer(id);
-        if(i>0){
-            producer.send(id, "HP_DELETE");
+        if (b) {
+            producer.send(id, MessageEnum.DELETE,ServiceEnum.HD_PARAMETER);
             return ResultView.success();
-        }else {
+        }else
             return ResultView.error();
-        }
-//        if (b) {
-//            producer.send(id, "HP_DELETE");
-//            return ResultView.success();
-//        }else
-//            return ResultView.error();
     }
     
 }

src/main/java/com/unissoft/parameter/service/impl/HardwareParameterServiceImpl.java

@@ -48,7 +48,7 @@ public class HardwareParameterServiceImpl extends ServiceImpl<HardwareParameterM
     		String deviceName = jsStr.getString("deviceName");//设备名称
     		Integer houseId = jsStr.getInteger("houseId");
     		if(!StringUtils.isEmpty(houseId.toString())){
-    			ew.ge("house_id", houseId);
+    			ew.eq("house_id", houseId);
     		}
     		if (!StringUtils.isEmpty(deviceName)) {
                 ew.like("device_name", deviceName);

src/main/java/com/unissoft/systemManage/controller/NBasicEdgeController.java

@@ -2,10 +2,8 @@ package com.unissoft.systemManage.controller;
 
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.unissoft.common.DateUtils;
-import com.unissoft.common.PageParam;
-import com.unissoft.common.ResultView;
-import com.unissoft.common.SystemLog;
+import com.unissoft.common.*;
+import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.LogOperation;
 import com.unissoft.systemManage.model.NBasicEdge;
 import com.unissoft.systemManage.model.RoleInfo;
@@ -42,6 +40,8 @@ import javax.servlet.http.HttpServletResponse;
 @RestController
 @RequestMapping("/n-basic-edge")
 public class NBasicEdgeController {
+    @Autowired
+    private Producer producer;
 
     private NBasicEdgeService nBasicEdgeService;
 
@@ -79,20 +79,24 @@ public class NBasicEdgeController {
     @PostMapping("/basic/saveNBasicEdge")
     public ResultView saveRoleInfo(@RequestBody NBasicEdge nBasicEdge) {
         boolean save = nBasicEdgeService.save(nBasicEdge);
-        if (save)
+        if (save) {
+            producer.send(nBasicEdge, MessageEnum.SAVE, ServiceEnum.NBASIC_EDGE);
             return ResultView.success();
-        else
+        }else {
             return ResultView.error();
+        }
     }
 
     @ApiOperation(value = "修改扫描规则", notes = "")
     @PostMapping("/basic/updateNBasicEdge")
     public ResultView updateRoleInfo(@RequestBody NBasicEdge nBasicEdge) {
         boolean b = nBasicEdgeService.updateById(nBasicEdge);
-        if (b)
+        if (b) {
+            producer.send(nBasicEdge, MessageEnum.UPDATE, ServiceEnum.NBASIC_EDGE);
             return ResultView.success();
-        else
+        }else {
             return ResultView.error();
+        }
     }
     
     

src/main/java/com/unissoft/systemManage/controller/OrgInfoController.java

@@ -3,10 +3,8 @@ package com.unissoft.systemManage.controller;
 
 import com.alibaba.fastjson.JSON;
 import com.unissoft.basic.model.BasicEnum;
-import com.unissoft.common.DateUtils;
-import com.unissoft.common.MyConstant;
-import com.unissoft.common.ResultView;
-import com.unissoft.common.SystemLog;
+import com.unissoft.common.*;
+import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.OrgInfo;
 import com.unissoft.systemManage.model.OrgInfoChildren;
 import com.unissoft.systemManage.service.OrgInfoService;
@@ -29,6 +27,8 @@ import java.util.stream.Collectors;
 @RestController
 @RequestMapping("/orgInfo")
 public class OrgInfoController {
+    @Autowired
+    private Producer producer;
 
     private OrgInfoService orgInfoService;
 
@@ -54,9 +54,10 @@ public class OrgInfoController {
     public ResultView save(@RequestBody OrgInfo orgInfo) {
         orgInfo.setBuildTime(DateUtils.getDate());
         boolean save = orgInfoService.save(orgInfo);
-        if (save)
+        if (save) {
+            producer.send(orgInfo, MessageEnum.SAVE, ServiceEnum.ORG_INFO);
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
@@ -65,9 +66,10 @@ public class OrgInfoController {
     public ResultView update(@RequestBody OrgInfo orgInfo) {
         orgInfo.setBuildTime(DateUtils.getDate());
         boolean b = orgInfoService.updateById(orgInfo);
-        if (b)
+        if (b) {
+            producer.send(orgInfo, MessageEnum.UPDATE, ServiceEnum.ORG_INFO);
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
@@ -87,6 +89,7 @@ public class OrgInfoController {
     @GetMapping("/authority/getByIdDelete/{id}")
     public ResultView getByIdDelete(@PathVariable String id) {
         if (orgInfoService.removeById(id)) {
+            producer.send(id, MessageEnum.DELETE, ServiceEnum.ORG_INFO);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);
@@ -100,7 +103,7 @@ public class OrgInfoController {
     @GetMapping("/authority/getListMap")
     public ResultView getListMap(@PathParam("orgId") String orgId) {
         List<OrgInfo> list = orgInfoService.getOrgMap(orgId);
-        Map<Integer, String> collect = list.stream().collect(Collectors.toMap(OrgInfo::getId, OrgInfo::getOrgName));
+        Map<Long, String> collect = list.stream().collect(Collectors.toMap(OrgInfo::getId, OrgInfo::getOrgName));
         return ResultView.success(collect);
     }
 

src/main/java/com/unissoft/systemManage/controller/RoleInfoController.java

@@ -3,12 +3,15 @@ package com.unissoft.systemManage.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.unissoft.common.*;
+import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.model.RoleInfo;
 import com.unissoft.systemManage.model.UserInfo;
 import com.unissoft.systemManage.service.RoleInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Resource;
+
 /**
  * <p>
  * 用户角色表 前端控制器
@@ -20,6 +23,8 @@ import org.springframework.web.bind.annotation.*;
 @RestController
 @RequestMapping("/roleInfo")
 public class RoleInfoController {
+    @Resource
+    private Producer producer;
 
     private RoleInfoService roleInfoService;
 
@@ -45,9 +50,10 @@ public class RoleInfoController {
     public ResultView saveRoleInfo(@RequestBody RoleInfo roleInfo) {
         roleInfo.setBulidTime(DateUtils.getDate());
         boolean save = roleInfoService.save(roleInfo);
-        if (save)
+        if (save) {
+            producer.send(roleInfo, MessageEnum.SAVE, ServiceEnum.ROLE_INFO);
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
@@ -56,16 +62,19 @@ public class RoleInfoController {
     public ResultView updateRoleInfo(@RequestBody RoleInfo roleInfo) {
         roleInfo.setBulidTime(DateUtils.getDate());
         boolean b = roleInfoService.updateById(roleInfo);
-        if (b)
+        if (b) {
+            producer.send(roleInfo, MessageEnum.UPDATE, ServiceEnum.ROLE_INFO);
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
     @SystemLog(operModul = "系统管理", operType = "角色管理", operDesc = "删除角色信息")
     @GetMapping("/authority/getByIdDeleteRoleInfo/{id}")
     public ResultView getByIdDeleteRoleInfo(@PathVariable String id) {
-        if (roleInfoService.removeById(id)) {
+        boolean  b= roleInfoService.removeById(id);
+        if (b) {
+            producer.send(id, MessageEnum.DELETE, ServiceEnum.ROLE_INFO);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/controller/UserInfoController.java

@@ -73,13 +73,13 @@ public class UserInfoController {
     public ResultView saveUser(@RequestBody UserInfo userInfo) {
         userInfo.setBuildTime(DateUtils.getDate());
         userInfo.setUserPassword(MD5Util.getMD5(userInfo.getUserPassword()));
-        String s = UUID.randomUUID().toString().trim().replaceAll("_", "");
+        String s = UuidUtils.getCode();
         userInfo.setUserId(s);
-        producer.send(userInfo,"userInfo");
         boolean save = userInfoService.save(userInfo);
-        if (save)
+        if (save) {
+            producer.send(userInfo, MessageEnum.SAVE, ServiceEnum.USER_INFO);
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
@@ -89,9 +89,10 @@ public class UserInfoController {
         userInfo.setBuildTime(DateUtils.getDate());
         userInfo.setUserPassword(MD5Util.getMD5(userInfo.getUserPassword()));
         boolean b = userInfoService.updateById(userInfo);
-        if (b)
+        if (b) {
+            producer.send(userInfo, MessageEnum.UPDATE, ServiceEnum.USER_INFO);
             return ResultView.success();
-        else
+        }else
             return ResultView.error();
     }
 
@@ -99,6 +100,7 @@ public class UserInfoController {
     @GetMapping("/authority/deleteById/{id}")
     public ResultView getByIdForUserDelete(@PathVariable String id) {
         if (userInfoService.removeById(id)) {
+            producer.send(id, MessageEnum.DELETE, ServiceEnum.USER_INFO);
             return ResultView.success();
         }
         return ResultView.error(MyConstant.ID_NULL);

src/main/java/com/unissoft/systemManage/mapper/OrgInfoMapper.java

@@ -21,7 +21,7 @@ import java.util.Map;
 @Repository
 public interface OrgInfoMapper extends BaseMapper<OrgInfo> {
 
-    Page<List<Map<String, Object>>> getStorehouse(IPage<List<Map<String, Object>>> page, @Param("id") Integer param);
+    Page<List<Map<String, Object>>> getStorehouse(IPage<List<Map<String, Object>>> page, @Param("id") Long param);
 
     List<OrgInfo> getOrgMap(@Param("orgId") String orgId);
 

src/main/java/com/unissoft/systemManage/model/OrgInfo.java

@@ -32,8 +32,8 @@ public class OrgInfo implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "主键id")
-    @TableId(value = "id", type = IdType.AUTO)
-    private Integer id;
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private Long id;
 
     @ApiModelProperty(value = "组织机构名称(仓房名称)")
     @TableField("org_name")
@@ -53,7 +53,7 @@ public class OrgInfo implements Serializable {
 
     @ApiModelProperty(value = "父级ID(默认值为0,0表示顶级机构)")
     @TableField("parent_id")
-    private Integer parentId;
+    private Long parentId;
 
     @ApiModelProperty(value = "创建时间")
     @TableField("build_time")

src/main/java/com/unissoft/systemManage/model/PointData.java

@@ -33,7 +33,7 @@ public class PointData implements Serializable {
 
     @ApiModelProperty(value = "仓房id")
     @TableField("house_id")
-    private Integer houseId;
+    private Long houseId;
 
     @ApiModelProperty(value = "高")
     @JsonProperty("LKHeight")

src/main/java/com/unissoft/systemManage/model/RoleInfo.java

@@ -28,12 +28,12 @@ public class RoleInfo implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "主键")
-    @TableId(value = "id", type = IdType.AUTO)
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
     private Integer id;
 
     @ApiModelProperty(value = "组织机构编码")
     @TableField("org_id")
-    private Integer orgId;
+    private Long orgId;
 
     @ApiModelProperty(value = "角色编码")
     @TableField("role_code")

src/main/java/com/unissoft/systemManage/model/StorehouseClxx.java

@@ -36,7 +36,7 @@ public class StorehouseClxx implements Serializable {
 
     @ApiModelProperty(value = "关联org_info的主键ID")
     @TableField("main_id")
-    private Integer mainId;
+    private Long mainId;
 
     @ApiModelProperty(value = "组织机构ID")
     @TableField("org_id")

src/main/java/com/unissoft/systemManage/model/UserInfo.java

@@ -28,8 +28,8 @@ public class UserInfo implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "id主键")
-    @TableId(value = "id", type = IdType.AUTO)
-    private Integer id;
+    @TableId(value = "id", type = IdType.ASSIGN_ID)
+    private Long id;
 
     @ApiModelProperty(value = "用户ID")
     @TableField("user_id")

src/main/java/com/unissoft/systemManage/service/impl/NBasicEdgeServiceImpl.java

@@ -7,7 +7,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.unissoft.common.MessageEnum;
 import com.unissoft.common.PageParam;
+import com.unissoft.common.ServiceEnum;
+import com.unissoft.mqProducer.Producer;
 import com.unissoft.systemManage.mapper.NBasicEdgeMapper;
 import com.unissoft.systemManage.mapper.PointDataMapper;
 import com.unissoft.systemManage.model.LogOperation;
@@ -15,6 +18,7 @@ import com.unissoft.systemManage.model.NBasicEdge;
 import com.unissoft.systemManage.model.PointData;
 import com.unissoft.systemManage.model.SyncV2xyz;
 import com.unissoft.systemManage.service.NBasicEdgeService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.StringUtils;
 
@@ -39,6 +43,8 @@ import java.util.List;
  */
 @Service
 public class NBasicEdgeServiceImpl extends ServiceImpl<NBasicEdgeMapper, NBasicEdge> implements NBasicEdgeService  {
+	@Resource
+	private Producer producer;
 
     @Resource
     private NBasicEdgeMapper nBasicEdgeMapper;
@@ -140,9 +146,13 @@ public class NBasicEdgeServiceImpl extends ServiceImpl<NBasicEdgeMapper, NBasicE
 		nBasicEdge.setHouseId("44");
 		nBasicEdge.setCron("0 0 0 */1 * ?");
 		nBasicEdge.setEquiName("3号筒仓");
-		
-		
-		return nBasicEdgeMapper.insert(nBasicEdge);
+
+
+		int i = nBasicEdgeMapper.insert(nBasicEdge);
+		if (i>=0){
+			producer.send(nBasicEdge, MessageEnum.SAVE, ServiceEnum.NBASIC_EDGE);
+		}
+		return i;
 	}
 
 
@@ -207,7 +217,7 @@ public class NBasicEdgeServiceImpl extends ServiceImpl<NBasicEdgeMapper, NBasicE
 		 nBasicEdgeMapper.insert(nBasicEdge);
 		
 		PointData ponitData = new PointData();
-		ponitData.setHouseId(44);
+		ponitData.setHouseId(44L);
 		ponitData.setCreateTime(date);
 		ponitData.setPoints(xyz);
 		

src/main/java/com/unissoft/systemManage/service/impl/OrgInfoServiceImpl.java

@@ -50,7 +50,7 @@ public class OrgInfoServiceImpl extends ServiceImpl<OrgInfoMapper, OrgInfo> impl
         QueryWrapper<OrgInfo> queryWrapper = new QueryWrapper<>();
         if (orgInfo != null) {
             Integer storeTypeCode = orgInfo.getStoreTypeCode();
-            Integer parentId = orgInfo.getParentId();
+            Long parentId = orgInfo.getParentId();
             if (storeTypeCode != null) {
                 queryWrapper.eq("store_type_code", storeTypeCode);
             }
@@ -75,7 +75,7 @@ public class OrgInfoServiceImpl extends ServiceImpl<OrgInfoMapper, OrgInfo> impl
         if (!StringUtils.isEmpty(condition)) {
             OrgInfo orgInfo = JSON.parseObject(condition, OrgInfo.class);
             // 获取查询条件
-            Integer cf_id = orgInfo.getId();
+            Long cf_id = orgInfo.getId();
             //param.put("id", cf_id);
             Page<List<Map<String, Object>>> a = orgInfoMapper.getStorehouse(page, cf_id);
             return a;
@@ -91,18 +91,18 @@ public class OrgInfoServiceImpl extends ServiceImpl<OrgInfoMapper, OrgInfo> impl
         List<OrgInfoChildren> orgInfoChildren;
         String s;
         List<OrgInfo> orgInfoS;
-        Integer parentId = MyConstant.ZERO;
+        Long parentId = 0L;
         // 没有搜索条件时
         if (!StringUtils.isEmpty(orgName)) {
             queryWrapper.like("org_name", orgName);
             List<OrgInfo> orgInfoList1 = orgInfoMapper.selectList(queryWrapper);
             // 二次查询list
-            ArrayList<Integer> ids = Lists.newArrayList(); // id缓存区
+            ArrayList<Long> ids = Lists.newArrayList(); // id缓存区
             for (OrgInfo orgInfo : orgInfoList1) {
                 ids.add(orgInfo.getId());
             }
             // 获取最顶级父id
-            Optional<OrgInfo> min = orgInfoList1.stream().min(Comparator.comparingInt(OrgInfo::getParentId));
+            Optional<OrgInfo> min = orgInfoList1.stream().min(Comparator.comparingLong(OrgInfo::getParentId));
             if (min.isPresent()) {
                 parentId = min.get().getParentId();
             }
@@ -117,7 +117,7 @@ public class OrgInfoServiceImpl extends ServiceImpl<OrgInfoMapper, OrgInfo> impl
             s = JSON.toJSONString(orgInfoS);
             orgInfoChildren = JSON.parseArray(s, OrgInfoChildren.class);
         }
-        return buildTree(orgInfoChildren, parentId);
+        return buildTree(orgInfoChildren, (long) parentId);
     }
 
     @Override
@@ -133,8 +133,8 @@ public class OrgInfoServiceImpl extends ServiceImpl<OrgInfoMapper, OrgInfo> impl
         if (!StringUtils.isEmpty(condition)) {
             OrgInfo orgInfo = JSON.parseObject(condition, OrgInfo.class);
             // 获取查询条件
-            Integer org_id = orgInfo.getParentId();
-            Integer cf_id = orgInfo.getId();
+            Long org_id = orgInfo.getParentId();
+            Long cf_id = orgInfo.getId();
             if (!StringUtils.isEmpty(org_id)) {
                 queryWrapper.eq("parent_id", org_id);
             }
@@ -200,15 +200,15 @@ public class OrgInfoServiceImpl extends ServiceImpl<OrgInfoMapper, OrgInfo> impl
      * @param parentId  用于获取key 为最顶级 parentId
      * @return tree 结构 数据
      */
-    private List<OrgInfoChildren> buildTree(List<OrgInfoChildren> listParam, Integer parentId) {
+    private List<OrgInfoChildren> buildTree(List<OrgInfoChildren> listParam, Long parentId) {
         // 接收参数非空判断
         if (CollectionUtils.isEmpty(listParam)) {
             return Collections.emptyList();
         }
         // id 为key list 转map
-        Map<Integer, OrgInfoChildren> idMap = listParam.parallelStream().collect(Collectors.toMap(OrgInfoChildren::getId, p -> p));
+        Map<Long, OrgInfoChildren> idMap = listParam.parallelStream().collect(Collectors.toMap(OrgInfoChildren::getId, p -> p));
         // 数据根据ParentId分组
-        Map<Integer, List<OrgInfoChildren>> pidGroupRolesMap = listParam.parallelStream().collect(Collectors.groupingBy(OrgInfoChildren::getParentId));
+        Map<Long, List<OrgInfoChildren>> pidGroupRolesMap = listParam.parallelStream().collect(Collectors.groupingBy(OrgInfoChildren::getParentId));
         // set children 值
         pidGroupRolesMap.forEach((k, v) -> {
             // 获取parent id key

src/main/java/com/unissoft/systemManage/service/impl/RoleInfoServiceImpl.java

@@ -42,7 +42,7 @@ public class RoleInfoServiceImpl extends ServiceImpl<RoleInfoMapper, RoleInfo> i
             // 查询条件转Java对象
             RoleInfo roleInfo = JSON.parseObject(condition, RoleInfo.class);
             // 获取查询条件
-            Integer orgId = roleInfo.getOrgId();
+            Long orgId = roleInfo.getOrgId();
             String roleName = roleInfo.getRoleName();
             if (!StringUtils.isEmpty(orgId))
                 queryWrapper.eq("org_id", roleInfo.getOrgId());

src/main/java/com/unissoft/utils/idUtils.java

@@ -0,0 +1,29 @@
+package com.unissoft.utils;
+
+import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator;
+import com.unissoft.config.IdGenerator16Bit;
+import org.springframework.expression.spel.ast.Identifier;
+import org.springframework.stereotype.Component;
+import org.springframework.util.IdGenerator;
+
+import java.util.Date;
+import java.util.UUID;
+
+/**
+ * ClassName: idUtils
+ * Package: com.unissoft.utils
+ * Description: 自定义ID生成长度为16位
+ *
+ * @Author zlq
+ * @Create 2023/3/3 17:36
+ * @Version 1.0
+ */
+@Component
+public class idUtils  implements IdentifierGenerator {
+    @Override
+    public Long nextId(Object esntity) {
+        // 填充自己的Id生成器，
+        return IdGenerator16Bit.generateId();
+    }
+
+}

src/main/resources/bootstrap.yml

@@ -13,12 +13,14 @@ spring:
     driver-class-name: com.mysql.cj.jdbc.Driver
     #username: root
     #password: 123456
-#    url: jdbc:mysql://127.0.0.1:3306/numberec?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
+    url: jdbc:mysql://127.0.0.1:3306/numberec?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
+#    url: jdbc:mysql://192.168.8.101:3306/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
     username: root
+#    password: 123456
     password: 123456
     # 06 to 02 可外网访问，不必vpn。
 #    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
-    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
+#    url: jdbc:mysql://101.36.160.140:31004/numberEC?characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
 
     # Hikari pool https://github.com/brettwooldridge/HikariCP
     type: com.zaxxer.hikari.HikariDataSource
@@ -65,10 +67,8 @@ version: 20121021
 
 rocketmq:
   name-server: 192.168.8.142:9876 # 访问地址
-  consumer:
-    group: consumer_number
   producer:
-    group: Group_local # 必须指定group
+    group: Grouplocal # 必须指定group
     send-message-timeout: 3000 # 消息发送超时时长，默认3s
     retry-times-when-send-failed: 3 # 同步发送消息失败重试次数，默认2
     retry-times-when-send-async-failed: 3 # 异步发送消息失败重试次数，默认2