From 9aa194420539e907fc2ef52f80ffc4852b6e7e34 Mon Sep 17 00:00:00 2001 From: tongliran Date: Mon, 6 Jan 2025 17:21:57 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9C=A8=E5=BC=80=E5=85=B3=E9=98=80=E6=97=B6?= =?UTF-8?q?=E5=88=B7=E5=8D=A1=E8=AE=B0=E5=BD=95=E4=B8=AD=E6=B7=BB=E5=8A=A0?= =?UTF-8?q?=E7=94=A8=E6=88=B7=E4=BD=99=E9=A2=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mq/redischannel/consumer/DeviceOtherMsgConsumer.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fastbee-gateway/fastbee-mq/src/main/java/com/fastbee/mq/redischannel/consumer/DeviceOtherMsgConsumer.java b/fastbee-gateway/fastbee-mq/src/main/java/com/fastbee/mq/redischannel/consumer/DeviceOtherMsgConsumer.java index 84fe149..a07a9a0 100644 --- a/fastbee-gateway/fastbee-mq/src/main/java/com/fastbee/mq/redischannel/consumer/DeviceOtherMsgConsumer.java +++ b/fastbee-gateway/fastbee-mq/src/main/java/com/fastbee/mq/redischannel/consumer/DeviceOtherMsgConsumer.java @@ -301,12 +301,14 @@ public class DeviceOtherMsgConsumer { log.error("设备{}灌溉记录添加失败",serialNumber); } //添加一条刷卡记录 + BigDecimal userBalance=dataJson.getBigDecimal("userBalance");//用户余额 NgCardSwipeRecords ngCardSwipeRecords=new NgCardSwipeRecords(); ngCardSwipeRecords.setCardNumber(cardNumber);//卡号 ngCardSwipeRecords.setDeviceNumber(serialNumber);//设备编码 ngCardSwipeRecords.setAreaCode(areaCode);//区域号 ngCardSwipeRecords.setCardSwipeType(0);//开阀 ngCardSwipeRecords.setCardSwipeTime(DateUtils.getNowDate());//刷卡时间 + ngCardSwipeRecords.setAmountDue(userBalance);//开阀时用户余额 if(cardInfo!=null && cardInfo.getUserId()!=null){ ngCardSwipeRecords.setUserId(cardInfo.getUserId());//用户id } @@ -382,6 +384,8 @@ public class DeviceOtherMsgConsumer { ngCardSwipeRecords.setAreaCode(areaCode);//区域号 ngCardSwipeRecords.setCardSwipeType(1);//关阀 ngCardSwipeRecords.setCardSwipeTime(DateUtils.getNowDate());//刷卡时间 + ngCardSwipeRecords.setAmountDue(userBalance);//关阀时用户余额 + if(cardInfo!=null && cardInfo.getUserId()!=null){ ngCardSwipeRecords.setUserId(cardInfo.getUserId());//用户id }