细节调整
This commit is contained in:
@ -81,7 +81,7 @@ public class DeviceOtherMsgConsumer {
|
||||
try {
|
||||
//处理emq订阅的非 property/post 属性上报的消息 ,因为其他消息量小,放在一起处理
|
||||
Long productId;//产品id,设备所属产品
|
||||
Long packetId;//包号
|
||||
Long pacSn;//包号
|
||||
byte[] data = bo.getData();//数据
|
||||
String topic=bo.getTopicName();//主题
|
||||
//从主题中解析出产品id
|
||||
@ -128,6 +128,9 @@ public class DeviceOtherMsgConsumer {
|
||||
if(runStatus!=null){
|
||||
new LambdaUpdateChainWrapper<>(deviceReportInfoMapper).set(DeviceReportInfo::getRunStatus,runStatus).eq(DeviceReportInfo::getSerialNumber,serialNumber).update();
|
||||
}
|
||||
//获取流量计累计用水量/瞬时流量
|
||||
Float meterSum = data1.getFloat("meterSum");
|
||||
Float meterIns = data1.getFloat("meterIns");
|
||||
}
|
||||
//收到关阀时定时报文
|
||||
else if(JSONUtil.parseObj(data1).get("action").equals("safeMsg")){
|
||||
|
Reference in New Issue
Block a user