|
|
@ -83,7 +83,7 @@ public class MyMQTTCallback implements MqttCallback { |
|
|
|
log.info("实时数据,开始入库!"); |
|
|
|
log.info("实时数据,开始入库!"); |
|
|
|
// 更新实时数据,历史数据
|
|
|
|
// 更新实时数据,历史数据
|
|
|
|
dataAndPowerSaveBean.saveDevRtData(jsonObject); |
|
|
|
dataAndPowerSaveBean.saveDevRtData(jsonObject); |
|
|
|
} else if ("resulta".equals(str)) { |
|
|
|
} else if ("result".equals(str)) { |
|
|
|
log.info("控制结果数据,开始入库!"); |
|
|
|
log.info("控制结果数据,开始入库!"); |
|
|
|
controlResultSave.saveDevRtData(jsonObject); |
|
|
|
controlResultSave.saveDevRtData(jsonObject); |
|
|
|
} |
|
|
|
} |
|
|
|