diff --git a/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java b/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java index b3548f1..8523751 100644 --- a/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java +++ b/psdc-business/src/main/java/com/psdc/mqtt/MyMQTTCallback.java @@ -83,7 +83,7 @@ public class MyMQTTCallback implements MqttCallback { log.info("实时数据,开始入库!"); // 更新实时数据,历史数据 dataAndPowerSaveBean.saveDevRtData(jsonObject); - } else if ("resulta".equals(str)) { + } else if ("result".equals(str)) { log.info("控制结果数据,开始入库!"); controlResultSave.saveDevRtData(jsonObject); }