luhaojie/agricultural-monitoring-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

瞬时流量，累计流量单位换算

Browse Source
This commit is contained in:
mi9688 2025-01-08 17:00:36 +08:00
parent 74c08db0d7
commit 8b6616ae2b
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
fastbee-gateway/fastbee-mq/src/main/java/com/fastbee/mq/redischannel/consumer/DeviceOtherMsgConsumer.java
View File

@ -120,8 +120,8 @@ public class DeviceOtherMsgConsumer {
LambdaUpdateChainWrapper<DeviceReportInfo> up = new LambdaUpdateChainWrapper<>(deviceReportInfoMapper) LambdaUpdateChainWrapper<DeviceReportInfo> up = new LambdaUpdateChainWrapper<>(deviceReportInfoMapper)
.eq(DeviceReportInfo::getSerialNumber, serialNumber); .eq(DeviceReportInfo::getSerialNumber, serialNumber);
//获取流量计累计用水量/瞬时流量 //获取流量计累计用水量/瞬时流量
Float meterSum = data1.getFloat("meterSum"); BigDecimal meterSum = data1.getBigDecimal("meterSum");
Float meterIns = data1.getFloat("meterIns"); BigDecimal meterIns = data1.getBigDecimal("meterIns");
//获取瞬时功率/累计电量 //获取瞬时功率/累计电量
Float insPower = data1.getFloat("insPower"); Float insPower = data1.getFloat("insPower");
@ -155,10 +155,10 @@ public class DeviceOtherMsgConsumer {
up.set(DeviceReportInfo::getWaterFree,waterFees.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP)); up.set(DeviceReportInfo::getWaterFree,waterFees.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP));
} }
if(meterIns!=null){ if(meterIns!=null){
up.set(DeviceReportInfo::getInsFlow,meterIns); up.set(DeviceReportInfo::getInsFlow,meterIns.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP));
} }
if(meterSum!=null){ if(meterSum!=null){
up.set(DeviceReportInfo::getSumFlow,meterSum); up.set(DeviceReportInfo::getSumFlow,meterSum.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP));
} }
//同步数据 //同步数据
up.update(); up.update();
@ -186,8 +186,8 @@ public class DeviceOtherMsgConsumer {
LambdaUpdateChainWrapper<DeviceReportInfo> up = new LambdaUpdateChainWrapper<>(deviceReportInfoMapper) LambdaUpdateChainWrapper<DeviceReportInfo> up = new LambdaUpdateChainWrapper<>(deviceReportInfoMapper)
.eq(DeviceReportInfo::getSerialNumber, serialNumber); .eq(DeviceReportInfo::getSerialNumber, serialNumber);
//获取流量计累计用水量/瞬时流量 //获取流量计累计用水量/瞬时流量
Float meterSum = data1.getFloat("meterSum"); BigDecimal meterSum = data1.getBigDecimal("meterSum");
Float meterIns = data1.getFloat("meterIns"); BigDecimal meterIns = data1.getBigDecimal("meterIns");
//获取瞬时功率/累计电量 //获取瞬时功率/累计电量
Float insPower = data1.getFloat("insPower"); Float insPower = data1.getFloat("insPower");
Float sumEle = data1.getFloat("sumEle"); Float sumEle = data1.getFloat("sumEle");
@ -219,10 +219,10 @@ public class DeviceOtherMsgConsumer {
up.set(DeviceReportInfo::getWaterFree,waterFees.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP)); up.set(DeviceReportInfo::getWaterFree,waterFees.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP));
} }
if(meterIns!=null){ if(meterIns!=null){
up.set(DeviceReportInfo::getInsFlow,meterIns); up.set(DeviceReportInfo::getInsFlow,meterIns.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP));
} }
if(meterSum!=null){ if(meterSum!=null){
up.set(DeviceReportInfo::getSumFlow,meterSum); up.set(DeviceReportInfo::getSumFlow,meterSum.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_UP));
} }
//同步数据 //同步数据
up.update(); up.update();