diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/mapper/xml/CameraInfoMapper.xml b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/mapper/xml/CameraInfoMapper.xml index b77e1725..2a4154a2 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/mapper/xml/CameraInfoMapper.xml +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tplink/camera/mapper/xml/CameraInfoMapper.xml @@ -282,13 +282,13 @@ diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml index ed6d543b..493e826b 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/mapper/xml/ElectricityMeterMapper.xml @@ -86,7 +86,7 @@ set ele_value = #{eleValue}, relay_state = #{relayState}, - remark = #{remark}, + read_time = #{readTime}, update_time = now() where sn = #{sn} diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java index bac9f9a5..47df7fdf 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java @@ -89,10 +89,18 @@ public class ElectricityMeterServiceImpl extends ServiceImpl eleReset(ElectricityMeter electricityMeter) { + ElectricityMeter entity = baseMapper.getElectricityMeter(electricityMeter); String deviceId = electricityMeter.getSn(); MqttMessageHandler.DownlinkMessage message = mqttPublisherParams.getResetParams(deviceId); try { mqttMessageHandler.publishDownlinkMessage(deviceId,message); + TqApiLog tqApiLog = new TqApiLog(); + tqApiLog.setCid(deviceId); + tqApiLog.setType(9); + tqApiLog.setRequestValue(entity.getEleValue()); + tqApiLog.setRequestTime(DateUtil.now()); + tqApiLog.setRequestStatus("清零中"); + logService.insert(tqApiLog); } catch (Exception e) { e.printStackTrace(); } @@ -124,17 +132,23 @@ public class ElectricityMeterServiceImpl extends ServiceImpl eleRead(ElectricityMeter electricityMeter) { + ElectricityMeter entity = baseMapper.getElectricityMeter(electricityMeter); String deviceId = electricityMeter.getSn(); MqttMessageHandler.DownlinkMessage message = mqttPublisherParams.getReadingParams(deviceId); try { mqttMessageHandler.publishDownlinkMessage(deviceId,message); + TqApiLog tqApiLog = new TqApiLog(); + tqApiLog.setCid(deviceId); + tqApiLog.setType(3); + tqApiLog.setRequestValue(entity.getEleValue()); + tqApiLog.setRequestTime(DateUtil.now()); + tqApiLog.setRequestStatus("抄表中"); + logService.insert(tqApiLog); } catch (Exception e) { e.printStackTrace(); } @@ -342,6 +370,19 @@ public class ElectricityMeterServiceImpl extends ServiceImpl - update nu_iot_tq_electricity_meter + update nu_iot_ds_electricity_meter set nu_id = null where nu_id = #{nuId}