设备列表导出优化

common-lib/src/main/java/com/mortals/xhx/queue/kafka/AbstractTbQueueConsumerTemplate.java

@@ -41,7 +41,6 @@ public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> i
 
     @Override
     public void subscribe() {
-
         if (stopped) {
             log.error("consumer 线程已停止 topic {}", topic);
             return;

common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java

@@ -60,8 +60,6 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
         List<GetResponse> result = queues.stream()
                 .map(queue -> {
                     try {
-                        //AMQP.Queue.DeclareOk declareOk = channel.queueDeclarePassive(queue);
-                        //log.info("declareOk:{}",JSON.toJSONString(declareOk));
                         GetResponse getResponse = channel.basicGet(queue, true);
                         return getResponse;
                     } catch (IOException e) {
@@ -89,6 +87,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
         queues = partitions.stream()
                 .map(TopicPartitionInfo::getFullTopicName)
                 .collect(Collectors.toSet());
+        log.info("doSubscribe:{}", JSON.toJSONString(queues));
     }
 
     @Override

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceMsgComsumerStartedService.java

@@ -154,7 +154,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
             if (Objects.nonNull(messages)) {
                 try {
                     for (TbQueueMsg queueMsg : messages) {
-                        log.info("[WRITE MESSAGE] ->message:{}", JSON.toJSONString(queueMsg));
+                        log.debug("[WRITE MESSAGE] ->message:{}", JSON.toJSONString(queueMsg));
                         //做相应业务,做日志操作
                         // TODO: 2022/7/12 设备来源从设备编码中获取，内容不做处理
                         String deviceCode = queueMsg.getHeaders().get("deviceCode");

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -391,8 +391,6 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
                 }
             }
         }
-
-
         if (!ObjectUtils.isEmpty(entity.getPlatformCode())) {
             PlatformEntity platformEntity = platformService.selectOne(new PlatformQuery().platformSn(entity.getPlatformCode()));
             if (!ObjectUtils.isEmpty(platformEntity)) {