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 10ae7c7..83f0b46 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
@@ -104,6 +104,6 @@ public class EmsMqttMessageServiceImpl implements IEmsMqttMessageService
         mqttMessage.setCreateBy("system");
         mqttMessage.setUpdateBy("system");
         mqttMessage.setUpdateTime(DateUtils.getNowDate());
-        return emsMqttMessageMapper.updateEmsMqttMessage(mqttMessage);
+        return emsMqttMessageMapper.insertEmsMqttMessage(mqttMessage);
     }
 }