diff --git a/jeecg-boot-module-system/src/main/java/org/jeecg/modules/userCode/service/impl/PayServiceImpl.java b/jeecg-boot-module-system/src/main/java/org/jeecg/modules/userCode/service/impl/PayServiceImpl.java index 7b4253e..0f028cb 100644 --- a/jeecg-boot-module-system/src/main/java/org/jeecg/modules/userCode/service/impl/PayServiceImpl.java +++ b/jeecg-boot-module-system/src/main/java/org/jeecg/modules/userCode/service/impl/PayServiceImpl.java @@ -370,7 +370,7 @@ public class PayServiceImpl implements IPayService { /** - * 车主端-充值金额回调 + * 充值金额回调 * * @param payResponse * @return @@ -391,8 +391,8 @@ public class PayServiceImpl implements IPayService { log.error("未找到日志订单号"); return null; } - HanHaiMember carOwner = hanHaiMemberService.getById(rechargeInfoLog.getMemberId()); - if (carOwner == null) { + HanHaiMember user= hanHaiMemberService.getById(rechargeInfoLog.getMemberId()); + if (user == null) { return Result.error("该用户不存在"); } @@ -406,11 +406,11 @@ public class PayServiceImpl implements IPayService { log.error("支付回调----修改充值日志出错"); throw new JeecgBootException("系统错误"); } - HanHaiMember cmMemberAccount1 = new HanHaiMember(); - cmMemberAccount1.setId(carOwner.getId()); - cmMemberAccount1.setPrice(carOwner.getPrice().add(rechargeInfoLog.getMoney())); - boolean update1 = hanHaiMemberService.updateById(cmMemberAccount1); - if (!update1) { + UpdateWrapper updateWrapper = new UpdateWrapper<>(); + updateWrapper.setSql("price = price + " + rechargeInfoLog.getMoney()); + updateWrapper.eq("id", user.getId()); + int update1 = hanHaiMemberMappere.update(null, updateWrapper); + if (update1<1) { log.error("支付回调----修改用户数据出错"); throw new JeecgBootException("系统错误"); }