分组更新设备

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

@@ -17,9 +17,7 @@ import com.mortals.xhx.common.model.DefaultTbQueueMsgHeaders;
 import com.mortals.xhx.common.model.MessageHeader;
 import com.mortals.xhx.module.device.model.DeviceEntity;
 import com.mortals.xhx.module.device.service.DeviceService;
-import com.mortals.xhx.module.platform.model.PlatformEntity;
 import com.mortals.xhx.module.platform.service.PlatformService;
-import com.mortals.xhx.module.product.model.ProductEntity;
 import com.mortals.xhx.module.product.service.ProductService;
 import com.mortals.xhx.queue.*;
 import com.mortals.xhx.queue.provider.TbCoreQueueProducerProvider;
@@ -155,6 +153,7 @@ public class DemoApiController {
             if (!ObjectUtils.isEmpty(deviceEntity)) {
                 //将上报信息转发到mq中
 
+/*
                 PlatformEntity platformEntity = platformService.getCache(deviceEntity.getPlatformId().toString());
                 if (ObjectUtils.isEmpty(platformEntity)) {
                     throw new AppException("当前设备未配置所属系统平台，请在后台配置后再激活！");
@@ -165,6 +164,7 @@ public class DemoApiController {
                     throw new AppException("当前设备未配置所属产品，请在后台配置后再激活！");
                 }
                 String exchangeName = platformEntity.getPlatformSn() + Constant.EXCHANGE_SPLIT + productEntity.getProductCode();
+*/
 
        /*         TopicPartitionInfo info = TopicPartitionInfo.builder().exchangeName(exchangeName).topic(Constant.UPLOAD_TOPIC + deviceEntity.getDeviceMac()).build();
                 TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
@@ -182,7 +182,7 @@ public class DemoApiController {
                 // header.put(MessageHeader.TIMESTAMP, );
 
                 TbQueueMsg queueMsg = new DefaultTbQueueMsg(IdUtil.fastUUID(), "w==", header);
-                messageProducer.sendMsg(QueueKey.DEFAULT_EXCHANGE, Constant.DOWN_TOPIC + deviceEntity.getDeviceCode(), JSON.toJSONString(queueMsg));
+                messageProducer.sendMsg(QueueKey.DEFAULT_EXCHANGE, Constant.UPLOAD_TOPIC + deviceEntity.getDeviceCode(), JSON.toJSONString(queueMsg));
 
 
             }