From 84b0106cc79130a46ebd669c92a75c27f41311f8 Mon Sep 17 00:00:00 2001
From: cbs <18617195505@163.com>
Date: Thu, 12 Jun 2025 16:17:47 +0800
Subject: [PATCH] =?UTF-8?q?MQTT=E6=B6=88=E8=B4=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yudao/module/mqtt/api/common/CommonApiImpl.java       | 8 ++++----
 .../yudao/module/mqtt/service/RobotStatusServiceImpl.java | 2 +-
 .../yudao/module/system/api/robot/RobotStatusApiImpl.java | 2 +-
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/api/common/CommonApiImpl.java b/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/api/common/CommonApiImpl.java
index 4ce25ce8b..e47489ebe 100644
--- a/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/api/common/CommonApiImpl.java
+++ b/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/api/common/CommonApiImpl.java
@@ -23,11 +23,11 @@ public class CommonApiImpl implements CommonApi {
         try {
             String str = JSON.toJSONString(obj);
             mqttUtils.pub(topic, JSON.toJSONString(obj));
-            if (str.length() > 510) {
+            /*if (str.length() > 510) {
                 log.info("MQTT消息发送成功topic :{}, 内容 :{}",topic, str.substring(0, 500));
             }else {
                 log.info("MQTT消息发送成功topic :{}, 内容 :{}",topic, str);
-            }
+            }*/
         } catch (MqttException e) {
             log.info("MQTT消息发送异常 :{}",e);
         }
@@ -37,11 +37,11 @@ public class CommonApiImpl implements CommonApi {
     public void commonMethodStr(String str, String topic) {
         try {
             mqttUtils.pub(topic, str);
-            if (str.length() > 510) {
+            /*if (str.length() > 510) {
                 log.info("MQTT消息发送成功topic :{}, 内容 :{}",topic, str.substring(0, 500));
             }else {
                 log.info("MQTT消息发送成功topic :{}, 内容 :{}",topic, str);
-            }
+            }*/
         } catch (MqttException e) {
             log.info("MQTT消息发送异常 :{}",e);
         }
diff --git a/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/service/RobotStatusServiceImpl.java b/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/service/RobotStatusServiceImpl.java
index bcb25c607..2eb8a125b 100644
--- a/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/service/RobotStatusServiceImpl.java
+++ b/yudao-module-mqtt/yudao-module-mqtt-biz/src/main/java/cn/iododer/yudao/module/mqtt/service/RobotStatusServiceImpl.java
@@ -22,7 +22,7 @@ public class RobotStatusServiceImpl implements MqttService {
      */
     @Override
     public void analysisMessage(String message) {
-        log.info("处理RobotStatusServiceImpl的消息 :{}", message);
+//        log.info("处理RobotStatusServiceImpl的消息 :{}", message);
         RobotPoseStatusDTO robotStatusData = JSON.parseObject(message, RobotPoseStatusDTO.class);
         robotStatusApi.robotStatusUpdate(robotStatusData);
     }
diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotStatusApiImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotStatusApiImpl.java
index a06ef9e99..e38f9e876 100644
--- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotStatusApiImpl.java
+++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/api/robot/RobotStatusApiImpl.java
@@ -47,7 +47,7 @@ public class RobotStatusApiImpl implements RobotStatusApi {
     @Resource
     private RequestProcessor processor;
 
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(20);
+    private static final ExecutorService executorService = Executors.newFixedThreadPool(50);
 
     @Resource
     private CommonApi commonApi;