充值修改sql

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<HanHaiMember> 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("系统错误");
             }