dianliang/oil-station
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
wangh 2024-01-30 09:55:14 +08:00
parent 58e5f81d8b
commit c1d80d6e15
2 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
fuintBackend/fuint-application/src/main/java/com/fuint/business/userManager/service/UserBalanceService.java
View File

@ -2,6 +2,7 @@ package com.fuint.business.userManager.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.fuint.business.userManager.entity.UserBalance; import com.fuint.business.userManager.entity.UserBalance;
import com.fuint.business.userManager.vo.UserBalanceVo;
import java.util.List; import java.util.List;
@ -61,4 +62,6 @@ public interface UserBalanceService extends IService<UserBalance> {
int initBalance(Integer userId , Integer chainStoreId); int initBalance(Integer userId , Integer chainStoreId);
int subtractUserBalanceByLock(UserBalanceVo balance);
} }

1
fuintBackend/fuint-application/src/main/java/com/fuint/business/userManager/service/impl/UserBalanceServiceImpl.java
View File

@ -67,6 +67,7 @@ public class UserBalanceServiceImpl extends ServiceImpl<UserBalanceMapper, UserB
@Resource @Resource
RedisLock redisLock; RedisLock redisLock;
@Override
public int subtractUserBalanceByLock(UserBalanceVo balance) { public int subtractUserBalanceByLock(UserBalanceVo balance) {
String lockKey = "userChangeBalance"+balance.getMtUserId()+balance.getChainStoreId(); String lockKey = "userChangeBalance"+balance.getMtUserId()+balance.getChainStoreId();
Boolean flag = redisLock.tryLock(lockKey, 5001, 5000, TimeUnit.MILLISECONDS); Boolean flag = redisLock.tryLock(lockKey, 5001, 5000, TimeUnit.MILLISECONDS);