修改redis 过期事件通知

device-manager/src/main/java/com/mortals/xhx/busiz/web/DeviceApiController.java

@@ -248,7 +248,6 @@ public class DeviceApiController {
      * @return
      */
     @PostMapping("upload")
-    //@DeviceAuth
     public String upload(@RequestBody UploadDeviceReq req) {
         log.info("【设备数据上报】【请求体】-->  " + JSONObject.toJSONString(req));
         ApiResp<String> rsp = new ApiResp<>();
@@ -271,7 +270,7 @@ public class DeviceApiController {
                 }
                 String exchangeName = platformEntity.getPlatformSn() + Constant.EXCHANGE_SPLIT + productEntity.getProductCode();
 
-                TopicPartitionInfo info = TopicPartitionInfo.builder().exchangeName(exchangeName).topic(Constant.UPLOAD_TOPIC + deviceEntity.getDeviceMac()).build();
+                TopicPartitionInfo info = TopicPartitionInfo.builder().exchangeName(exchangeName).topic(Constant.UPLOAD_TOPIC + deviceEntity.getDeviceCode()).build();
                 TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
                 header.put(MessageHeader.MESSAGETYPE, Constant.MESSAGETYPE_HEARTBEAT);
                 for (int i = 0; i < 10; i++) {

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

@@ -163,7 +163,7 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
             if (Objects.nonNull(messages)) {
                 try {
                     for (TbQueueMsg queueMsg : messages) {
-                        log.debug("[WRITE MESSAGE] ->message:{}", JSON.toJSONString(queueMsg));
+                        log.info("[WRITE MESSAGE] ->message:{}", JSON.toJSONString(queueMsg));
                         //做相应业务,做日志操作
                         DeviceReq deviceReq = JSON.parseObject(new String(queueMsg.getData()), DeviceReq.class);
                         boolean bool = false;