This commit is contained in:
zt
2025-04-09 14:32:13 +08:00
parent cfceb96394
commit a33ad65c94
2 changed files with 6 additions and 3 deletions

View File

@ -120,4 +120,9 @@ public interface MemberUserMapper extends BaseMapperX<MemberUserDO> {
@Update("update user_face set phone = #{phone} ,name = #{name} where sys_user_id = #{userId}") @Update("update user_face set phone = #{phone} ,name = #{name} where sys_user_id = #{userId}")
void updateFace(@Param("userId") Long userId, @Param("phone")String phone,@Param("name")String name); void updateFace(@Param("userId") Long userId, @Param("phone")String phone,@Param("name")String name);
@Select("select * from member_user where id = #{userId} for update")
MemberUserDO selectByIdForUpdate(@Param("userId") Long userId);
} }

View File

@ -2,13 +2,11 @@ package cn.iocoder.yudao.module.member.service.amount;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.math.Money;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.json.JSONUtil; import cn.hutool.json.JSONUtil;
import cn.iocoder.yudao.module.member.controller.app.user.vo.AppUserInfoCardVO; import cn.iocoder.yudao.module.member.controller.app.user.vo.AppUserInfoCardVO;
import cn.iocoder.yudao.module.member.dal.dataobject.card.CardDO; import cn.iocoder.yudao.module.member.dal.dataobject.card.CardDO;
import cn.iocoder.yudao.module.member.dal.dataobject.group.MemberGroupDO; import cn.iocoder.yudao.module.member.dal.dataobject.group.MemberGroupDO;
import cn.iocoder.yudao.module.member.dal.dataobject.money.MoneyDO;
import cn.iocoder.yudao.module.member.dal.dataobject.order.DishOrderDO; import cn.iocoder.yudao.module.member.dal.dataobject.order.DishOrderDO;
import cn.iocoder.yudao.module.member.dal.dataobject.refund.RefundDO; import cn.iocoder.yudao.module.member.dal.dataobject.refund.RefundDO;
import cn.iocoder.yudao.module.member.dal.dataobject.user.MemberUserDO; import cn.iocoder.yudao.module.member.dal.dataobject.user.MemberUserDO;
@ -78,7 +76,7 @@ public class CashRechargeServiceImpl implements CashRechargeService {
String name; String name;
synchronized (getUserLock(userId)) { synchronized (getUserLock(userId)) {
MemberUserDO memberUserDO = userMapper.selectById(userId); MemberUserDO memberUserDO = userMapper.selectByIdForUpdate(userId);
//金额变动 //金额变动
BigDecimal oldMoney = memberUserDO.getMoney(); BigDecimal oldMoney = memberUserDO.getMoney();
newMoney = oldMoney.add(money); newMoney = oldMoney.add(money);