2023-3-1 一体机推送加日志。

zd-modules/zd-modules-laboratory/src/main/java/com/zd/laboratory/mqtt/service/impl/SubMessageSendManager.java

@@ -122,17 +122,20 @@ public class SubMessageSendManager {
             return;
         }
         MessageBody messageBody = getMessageBody(subFunction);
+        logger.error("消息推送一体机开始");
         //仅发送一次
 //        commonSend.send(getFunctionSubTopic(subId), messageBody, SendMode.ONCE);
         int count = 0;
         List<SensorFunctionStatus> sensorFunctionStatusList = subFunction.getFunctionStatuses();
         for (SensorFunctionStatus sensorFunc : sensorFunctionStatusList) {
             if (redisService.getCacheObject(sensorFunc.getFunNum()+""+sensorFunc.getDescribe())==null){
+                logger.error("消息推送funNum存入redis:::"+sensorFunc.getFunNum()+""+sensorFunc.getDescribe());
                 redisService.setCacheObject(sensorFunc.getFunNum()+""+sensorFunc.getDescribe(),sensorFunc.getFunNum(),15L, TimeUnit.SECONDS);
                 count++;
             }
         }
         if(count>0){
+            logger.error("消息推送中.......");
             commonSend.send(getFunctionSubTopic(subId), messageBody, SendMode.ONCE);
         }
     }