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 10:17:17 +08:00
parent bc34078089
commit 9fe7cc2a1c
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -301,7 +301,7 @@ public class DeviceOtherMsgConsumer {
} }
// userIrrigationRecord.setDeptId(deptId); // userIrrigationRecord.setDeptId(deptId);
//添加一条灌溉记录
DateTime currentTime=DateTime.now();//获取当前时间作为开阀时间 DateTime currentTime=DateTime.now();//获取当前时间作为开阀时间
userIrrigationRecord.setStartTime(currentTime);//开阀时间 userIrrigationRecord.setStartTime(currentTime);//开阀时间
System.err.println("currentTime"+currentTime); System.err.println("currentTime"+currentTime);
@ -377,9 +377,18 @@ public class DeviceOtherMsgConsumer {
{ {
log.error("设备{}灌溉记录修改失败",serialNumber); log.error("设备{}灌溉记录修改失败",serialNumber);
} }
//同步购水卡余额-----------------------------------
String areaCode=dataJson.getStr("areaCode");
boolean update = new LambdaUpdateChainWrapper<>(userRechargeCardsMapper)
.set(UserRechargeCards::getBalance, userBalance)
.eq(UserRechargeCards::getCardNumber, cardNumber)
.eq(UserRechargeCards::getAreaCode, areaCode)
.update();
if(!update){
log.error("设备{}关阀报文同步购水卡{}余额失败",serialNumber,cardNumber);
}
//添加一条刷卡记录 //添加一条刷卡记录
String areaCode=dataJson.getStr("areaCode");
// UserRechargeCards cardInfo=userRechargeCardsMapper.selectUserRechargeCardsByCardNumberAndAreaCode(cardNumber,areaCode);//查询卡号+区域号信息 // UserRechargeCards cardInfo=userRechargeCardsMapper.selectUserRechargeCardsByCardNumberAndAreaCode(cardNumber,areaCode);//查询卡号+区域号信息
NgCardSwipeRecords ngCardSwipeRecords=new NgCardSwipeRecords(); NgCardSwipeRecords ngCardSwipeRecords=new NgCardSwipeRecords();