From 5bfa0cc6597421f4581a16d8242db9b28c3a8284 Mon Sep 17 00:00:00 2001 From: tongliran Date: Mon, 6 Jan 2025 12:35:56 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=85=85=E5=80=BC=E6=9C=BA?= =?UTF-8?q?=E5=85=85=E5=80=BC=EF=BC=8C=E5=BD=93=E5=8D=A1=E5=8F=B7=E4=B8=8D?= =?UTF-8?q?=E5=AD=98=E5=9C=A8=E6=97=B6=E6=96=B0=E5=BB=BA=E5=8D=A1=E4=BF=A1?= =?UTF-8?q?=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/UserRechargeCardsServiceImpl.java | 20 ++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) diff --git a/fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/impl/UserRechargeCardsServiceImpl.java b/fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/impl/UserRechargeCardsServiceImpl.java index 74a949f..64caebd 100644 --- a/fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/impl/UserRechargeCardsServiceImpl.java +++ b/fastbee-service/fastbee-rechargecard-service/src/main/java/com/fastbee/rechargecard/service/impl/UserRechargeCardsServiceImpl.java @@ -228,6 +228,16 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService // 如果没有找到对应的记录，返回0或者一个错误码 throw new ServiceException("卡号不存在！"); }*/ + UserRechargeCards info = userRechargeCardsMapper.selectUserRechargeCardsByCardnumber(String.valueOf(rechargecardUser.getCardnumber())); + if (info == null) { + // 如果没有找到对应的记录，返回0或者一个错误码 + //throw new ServiceException("卡号不存在！"); + UserRechargeCards userRechargeCards=new UserRechargeCards(); + userRechargeCards.setAreaCode(String.valueOf(rechargecardUser.getAreacode())); + userRechargeCards.setCardNumber(String.valueOf(rechargecardUser.getCardnumber())); + userRechargeCardsMapper.insertUserRechargeCards(userRechargeCards);//如果没有该卡号则新建一条 + info = userRechargeCardsMapper.selectUserRechargeCardsByCardnumber(String.valueOf(rechargecardUser.getCardnumber())); + } // UserConsumptionDetails userConsumptionDetails=new UserConsumptionDetails(); // userConsumptionDetails.setUserId(info.getUserId()); @@ -271,7 +281,7 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService ngUserRechargeRecords.setSerialNumber(rechargecardUser.getDeviceNumber()); // ngUserRechargeRecords.setDeptId(info.getDeptId()); // 计算新的余额 - // BigDecimal newBalance = rechargecardUser.getAmount().add(info.getBalance()); + BigDecimal newBalance = rechargecardUser.getAmount().add(info.getBalance()); /* userConsumptionDetails.setCreateTime(DateUtils.getNowDate()); NgUserRechargeRecords ngUserRechargeRecords = NgUserRechargeRecords.builder() @@ -284,9 +294,9 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService .areaCode(rechargecardUser.getAreacode()) .build();*/ userRechargeRecordsMapper.insertNgUserRechargeRecords(ngUserRechargeRecords); - // userConsumptionDetailsMapper.insertUserConsumptionDetails(userConsumptionDetails); - // // 更新用户充值卡信息，包括新的余额 - // info.setBalance(newBalance); + //userConsumptionDetailsMapper.insertUserConsumptionDetails(userConsumptionDetails); + // 更新用户充值卡信息，包括新的余额 + info.setBalance(newBalance); // info.setUpdateTime(DateUtils.getNowDate()); // info.setAreaCode(String.valueOf(rechargecardUser.getAreacode())); @@ -305,7 +315,7 @@ public class UserRechargeCardsServiceImpl implements IUserRechargeCardsService // // param.put("data",data); // pubMqttClient.publish(1,true,topic, JSONUtil.toJsonStr(param)); - // int i = userRechargeCardsMapper.updateUserRechargeCards(info); + int i = userRechargeCardsMapper.updateUserRechargeCards(info); return 1; } }