修改充值机充值,当卡号不存在时新建卡信息

This commit is contained in:
童丽然 2025-01-06 12:35:56 +08:00
parent 882190f4e9
commit 5bfa0cc659

View File

@ -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;
}
}