|
@@ -50,8 +50,10 @@ public class MqttListener {
|
|
|
}else if (topic.equals("mh/water/alert")){
|
|
|
oneCardApi.callAlarmApi(map);
|
|
|
}else if (topic.equals("mh/water/statistics")){
|
|
|
+ log.info("城运对接数据------开始");
|
|
|
WaterAj waterAj = JsonUtils.fromJson(payload, WaterAj.class);
|
|
|
waterAjService.saveOrUpdate(waterAj);
|
|
|
+ log.info("城运对接数据------结束");
|
|
|
}
|
|
|
}
|
|
|
};
|