feat:

传输设备信息

nb-admin/src/main/resources/application-dev.yml

@@ -30,9 +30,9 @@ spring:
   datasource:
     type: com.alibaba.druid.pool.DruidDataSource
     driverClassName: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://192.168.100.32:3307/nbnetpump?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true
+    url: jdbc:mysql://192.168.103.82:7001/nbnetpump?createDatabaseIfNotExist=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true
     username: root
-    password: 123456
+    password: Tuoren123.
     druid:
       # 初始连接数
       initialSize: 5

nb-service/iot-service/src/main/java/com/nb/aliyun/service/distribute/MasterDistributeQueueConfig.java

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Component;
  * @Author : LF
  * @Date: 2023年07月31日
  */
-@Component
+//@Component
 @AllArgsConstructor
 public class MasterDistributeQueueConfig {
     @Bean

nb-service/iot-service/src/main/java/com/nb/aliyun/service/distribute/SlaveDistributeMsgListener.java

@@ -18,10 +18,14 @@ import org.springframework.stereotype.Component;
  */
 @Slf4j
 @Component
-@AllArgsConstructor
 @AutoConfigureAfter(SlaveDistributeQueueConfig.class)
 public class SlaveDistributeMsgListener {
     private final DeviceMsgHandler deviceMsgHandler;
+
+    public SlaveDistributeMsgListener(DeviceMsgHandler deviceMsgHandler) {
+        this.deviceMsgHandler = deviceMsgHandler;
+    }
+
     @RabbitHandler
     @RabbitListener(queues = "${hospital.code}")
     public void handleMsg(AliIotMessagePojo  msg){