修改生产环境配置

Pu Zhibing

2025-06-19 a05b419384e148fc950c77553816a2d05144f4ae

 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/util/mqtt/MqttReceiverMessageHandler.java

@@ -25,7 +25,7 @@
   @Override
   public void handleMessage(Message<?> message) throws MessagingException {
      MessageHeaders headers = message.getHeaders();
      log.info("线程名称：{}，收到消息，主题：{}，消息：{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload());
      log.error("线程名称：{}，收到消息，主题：{}，消息：{}", Thread.currentThread().getName(), headers.get("mqtt_receivedTopic").toString(), message.getPayload());
      // log.info("收到消息主题：{}", headers.get("mqtt_receivedTopic").toString());
      // log.info("收到消息：{}", message.getPayload());
      String s = message.getPayload().toString();
@@ -36,9 +36,6 @@
      switch (ability){
         case "event_msa_alarm":
            warnMsgService.saveWarnMsgService(jsonObject);
            break;
         case "event_msa_pic":
            warnMsgService.saveWarnMsgPicService(jsonObject);
            break;
      }
   }