diff --git a/ems-admin/src/main/java/com/xzzn/web/controller/ems/MqttMessageController.java b/ems-admin/src/main/java/com/xzzn/web/controller/ems/MqttMessageController.java
index 437a6c0..734a155 100644
--- a/ems-admin/src/main/java/com/xzzn/web/controller/ems/MqttMessageController.java
+++ b/ems-admin/src/main/java/com/xzzn/web/controller/ems/MqttMessageController.java
@@ -61,15 +61,8 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
         System.out.println("[SYSTEM] Status update: " + payload);
 
         try {
-            // 业务处理逻辑
-            EmsMqttMessage mqttMessage = new EmsMqttMessage();
-            mqttMessage.setMqttTopic(topic);
-            mqttMessage.setMqttMessage(payload);
-            mqttMessage.setCreateTime(new java.util.Date());
-            mqttMessage.setUpdateTime(new java.util.Date());
-            mqttMessage.setCreateBy("system");
-            mqttMessage.setUpdateBy("system");
-            emsMqttMessageService.insertEmsMqttMessage(mqttMessage);
+            emsMqttMessageService.insertMqttOriginalMessage(topic,payload);
+
         } catch (Exception e) {
             log.error("Failed to process system status message: " + e.getMessage(), e);
         }
@@ -87,15 +80,7 @@ public class MqttMessageController implements MqttPublisher, MqttSubscriber {
                 fXXDataProcessService.handleFxData(payload);
             }
 
-
-            EmsMqttMessage mqttMessage = new EmsMqttMessage();
-            mqttMessage.setMqttTopic(topic);
-            mqttMessage.setMqttMessage(payload);
-            mqttMessage.setCreateTime(new java.util.Date());
-            mqttMessage.setUpdateTime(new java.util.Date());
-            mqttMessage.setCreateBy("system");
-            mqttMessage.setUpdateBy("system");
-            emsMqttMessageService.insertEmsMqttMessage(mqttMessage);
+            emsMqttMessageService.insertMqttOriginalMessage(topic,payload);
         } catch (Exception e) {
             log.error("Failed to process system status message: " + e.getMessage(), e);
         }
diff --git a/ems-system/src/main/java/com/xzzn/ems/service/IEmsMqttMessageService.java b/ems-system/src/main/java/com/xzzn/ems/service/IEmsMqttMessageService.java
index c7355cb..5979855 100644
--- a/ems-system/src/main/java/com/xzzn/ems/service/IEmsMqttMessageService.java
+++ b/ems-system/src/main/java/com/xzzn/ems/service/IEmsMqttMessageService.java
@@ -59,4 +59,13 @@ public interface IEmsMqttMessageService
      * @return 结果
      */
     public int deleteEmsMqttMessageById(Long id);
+
+    /**
+     * 新增【请填写功能名称】
+     *
+     * @param topic 【请填写功能名称】
+     * @param message 【请填写功能名称】
+     * @return 结果
+     */
+    public int insertMqttOriginalMessage(String topic, String message);
 }
diff --git a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsMqttMessageServiceImpl.java b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsMqttMessageServiceImpl.java
index 8c6e158..10ae7c7 100644
--- a/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsMqttMessageServiceImpl.java
+++ b/ems-system/src/main/java/com/xzzn/ems/service/impl/EmsMqttMessageServiceImpl.java
@@ -93,4 +93,17 @@ public class EmsMqttMessageServiceImpl implements IEmsMqttMessageService
     {
         return emsMqttMessageMapper.deleteEmsMqttMessageById(id);
     }
+
+    @Override
+    public int insertMqttOriginalMessage(String topic, String message) {
+        EmsMqttMessage mqttMessage = new EmsMqttMessage();
+        mqttMessage.setMqttTopic(topic);
+        mqttMessage.setMqttMessage(message);
+        mqttMessage.setCreateTime(new java.util.Date());
+        mqttMessage.setUpdateTime(new java.util.Date());
+        mqttMessage.setCreateBy("system");
+        mqttMessage.setUpdateBy("system");
+        mqttMessage.setUpdateTime(DateUtils.getNowDate());
+        return emsMqttMessageMapper.updateEmsMqttMessage(mqttMessage);
+    }
 }