This commit is contained in:
77
2024-04-21 01:31:10 +08:00
parent 96411407b8
commit bb3852ff76
11 changed files with 192 additions and 11 deletions

View File

@@ -10,11 +10,15 @@ import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.helper.LoginHelper;
import com.ruoyi.common.utils.BeanConvertUtil;
import com.ruoyi.xq.domain.UserBankCard;
import com.ruoyi.xq.domain.WithdrawSetting;
import com.ruoyi.xq.dto.app.account.UpdateAliReq;
import com.ruoyi.xq.dto.app.account.WithdrawReq;
import com.ruoyi.xq.dto.app.common.IdReq;
import com.ruoyi.xq.dto.app.setting.WithdrawSettingVo;
import com.ruoyi.xq.dto.app.withdraw.WithdrawListAppVo;
import com.ruoyi.xq.dto.app.withdraw.WithdrawListPageQuery;
import com.ruoyi.xq.service.UserBankCardService;
import com.ruoyi.xq.service.UserWithdrawService;
import com.ruoyi.xq.service.WithdrawSettingService;
import io.swagger.v3.oas.annotations.Operation;
@@ -33,6 +37,8 @@ public class WithdrawAppController {
private WithdrawSettingService withdrawSettingService;
@Autowired
private UserWithdrawService userWithdrawService;
@Autowired
private UserBankCardService userBankCardService;
@GetMapping("/setting")
@Operation(summary = "获取提现配置")
@@ -45,11 +51,21 @@ public class WithdrawAppController {
return R.ok(result);
}
@PostMapping("/ali/card")
@Operation(summary = "修改支付宝信息")
@Log(title = "修改支付宝信息", businessType = BusinessType.OTHER, isSaveDb = false)
public R<Void> updateAliCard(@RequestBody UpdateAliReq req){
req.setUserId(LoginHelper.getUserId());
userBankCardService.updateAli(req);
return R.ok();
}
@PostMapping("/save")
@Operation(summary = "申请提现")
@Log(title = "申请提现", businessType = BusinessType.OTHER, isSaveDb = false)
public R<Void> save(@RequestBody IdReq req){
userWithdrawService.saveWithdraw(LoginHelper.getUserId(),req.getId());
public R<Void> save(@RequestBody WithdrawReq req){
req.setUserId(LoginHelper.getUserId());
userWithdrawService.saveWithdraw(req);
return R.ok();
}

View File

@@ -2,6 +2,7 @@ package com.ruoyi.xq.domain;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.io.Serializable;
@@ -33,6 +34,17 @@ public class UserWithdraw implements Serializable {
* 用户号
*/
private String usercode;
@Schema(description = "提现方式 1-支付宝 2-微信")
private Integer withdrawType;
/**
* 提现账户/openId
*/
private String card;
/**
* 提现名称/微信名称
*/
private String name;
/**
* 跟踪ID
*/

View File

@@ -0,0 +1,20 @@
package com.ruoyi.xq.dto.app.account;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@Data
public class UpdateAliReq {
private Long userId;
/**
* 支付宝-姓名
*/
@Schema(description = "支付宝-姓名")
private String aliName;
/**
* 支付宝-账号
*/
@Schema(description = "支付宝-账户")
private String aliCard;
}

View File

@@ -0,0 +1,20 @@
package com.ruoyi.xq.dto.app.account;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@Data
public class WithdrawReq {
@Schema(hidden = true)
private Long userId;
@Schema(description = "提现ID")
private Long id;
@Schema(description = "提现方式 1-支付宝 2-微信")
private Integer withdrawType;
@Schema(description = "支付宝-姓名")
private String aliName;
@Schema(description = "支付宝-账户")
private String aliCard;
@Schema(description = "微信-openId")
private String openId;
}

View File

@@ -31,6 +31,19 @@ public class WithdrawListAppVo {
*/
@Schema(description = "提现金额")
private BigDecimal withdrawMoney;
@Schema(description = "提现方式 1-支付宝 2-微信")
private Integer withdrawType;
/**
* 提现账户/openId
*/
@Schema(description = "提现账户/openId")
private String card;
/**
* 提现名称/微信名称
*/
@Schema(description = "提现名称/微信名称")
private String name;
/**
* 1-待审核 2-审核成功 3-审核失败
*/

View File

@@ -0,0 +1,21 @@
package com.ruoyi.xq.enums.account;
import lombok.Getter;
/**
*
* @author duet
*/
@Getter
public enum WithdrawTypeEnum {
ALI(1,"支付宝"),
WX(2,"微信"),
;
private final Integer code;
private final String text;
WithdrawTypeEnum(Integer code, String text) {
this.code = code;
this.text = text;
}
}

View File

@@ -14,6 +14,7 @@ public class LockKey {
public static final String LOCK_VIDEO_SETTLE_REDIS = RedisHttpConstant.REDIS_P + "lock:videoSettle:%s";
public static final String LOCK_ONLINE_LOGIN_NOTICE_REDIS = RedisHttpConstant.REDIS_P + "lockHand:loginFansNotice:%s";
public static final String LOCK_USER_INFO_AUDIT_REDIS = RedisHttpConstant.REDIS_P + "lock:userInfoAudit:%s";
public static final String LOCK_USER_BANK_CARD_REDIS = RedisHttpConstant.REDIS_P + "lock:userBankCard:%s";
public static final String LOCK_USER_VISITOR_ADD_REDIS = RedisHttpConstant.REDIS_P + "lock:userVisitorAdd:%s-%s";
public static String getRegisterLockKey(String mobile){
@@ -55,4 +56,8 @@ public class LockKey {
public static String getUserInfoAuditLock(Long userId) {
return String.format(LOCK_USER_INFO_AUDIT_REDIS,userId);
}
public static String getUserBankCard(Long userId) {
return String.format(LOCK_USER_BANK_CARD_REDIS,userId);
}
}

View File

@@ -2,6 +2,7 @@ package com.ruoyi.xq.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.xq.domain.UserBankCard;
import com.ruoyi.xq.dto.app.account.UpdateAliReq;
/**
* 用户银行卡Service接口
@@ -11,4 +12,7 @@ import com.ruoyi.xq.domain.UserBankCard;
*/
public interface UserBankCardService extends IService<UserBankCard> {
void updateAli(UpdateAliReq req);
UserBankCard getByUserId(Long userId);
}

View File

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
import com.ruoyi.common.core.domain.PageQuery;
import com.ruoyi.xq.domain.UserWithdraw;
import com.ruoyi.xq.dto.admin.withdraw.UserWithdrawAdminVo;
import com.ruoyi.xq.dto.app.account.WithdrawReq;
import com.ruoyi.xq.dto.app.withdraw.WithdrawListAppVo;
import com.ruoyi.xq.dto.app.withdraw.WithdrawListPageQuery;
@@ -16,7 +17,7 @@ import com.ruoyi.xq.dto.app.withdraw.WithdrawListPageQuery;
*/
public interface UserWithdrawService extends IService<UserWithdraw> {
void saveWithdraw(Long userId, Long withdrawSettingId);
void saveWithdraw(WithdrawReq req);
Page<WithdrawListAppVo> pageApp(PageQuery pageQuery, WithdrawListPageQuery query);

View File

@@ -1,10 +1,18 @@
package com.ruoyi.xq.service.impl;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.xq.domain.UserBankCard;
import com.ruoyi.xq.dto.app.account.UpdateAliReq;
import com.ruoyi.xq.dto.common.user.MinUser;
import com.ruoyi.xq.lock.LockKey;
import com.ruoyi.xq.mapper.UserBankCardMapper;
import com.ruoyi.xq.service.UserBankCardService;
import com.ruoyi.xq.service.UserService;
import lombok.RequiredArgsConstructor;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
@@ -16,5 +24,50 @@ import org.springframework.stereotype.Service;
@RequiredArgsConstructor
@Service
public class UserBankCardServiceImpl extends ServiceImpl<UserBankCardMapper,UserBankCard> implements UserBankCardService {
@Autowired
private RedissonClient redissonClient;
@Autowired
private UserService userService;
@Override
public void updateAli(UpdateAliReq req) {
checkData(req.getUserId());
this.update(Wrappers.lambdaUpdate(UserBankCard.class)
.set(UserBankCard::getAliCard,req.getAliCard())
.set(UserBankCard::getAliName, req.getAliName())
.eq(UserBankCard::getUserId, req.getUserId()));
}
private void checkData(Long userId){
UserBankCard one = this.getByUserId(userId);
if(one != null){
return;
}
String key = LockKey.getUserBankCard(userId);
RLock lock = redissonClient.getLock(key);
try {
lock.lock();
one = this.getByUserId(userId);
if(one != null){
return;
}
MinUser minUser = userService.getMinUserById(userId);
UserBankCard card = new UserBankCard();
card.setUserId(userId);
card.setUsercode(minUser.getUsercode());
this.save(card);
}finally {
try {
lock.unlock();
}catch (Exception e){
//
}
}
}
@Override
public UserBankCard getByUserId(Long userId){
return this.getOne(Wrappers.lambdaQuery(UserBankCard.class).eq(UserBankCard::getUserId, userId).last("limit 1"));
}
}

View File

@@ -7,20 +7,20 @@ import com.ruoyi.common.core.domain.PageQuery;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.helper.LoginHelper;
import com.ruoyi.common.utils.ServletUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.xq.domain.*;
import com.ruoyi.xq.dto.admin.withdraw.UserWithdrawAdminVo;
import com.ruoyi.xq.dto.app.account.WithdrawReq;
import com.ruoyi.xq.dto.app.withdraw.WithdrawListAppVo;
import com.ruoyi.xq.dto.app.withdraw.WithdrawListPageQuery;
import com.ruoyi.xq.enums.account.WithdrawTypeEnum;
import com.ruoyi.xq.enums.common.AuditEnum;
import com.ruoyi.xq.enums.common.OrderTypeEnum;
import com.ruoyi.xq.enums.common.TraceIdEnum;
import com.ruoyi.xq.manager.OrderNoUtil;
import com.ruoyi.xq.manager.TraceIdManager;
import com.ruoyi.xq.mapper.UserWithdrawMapper;
import com.ruoyi.xq.service.UserExtendService;
import com.ruoyi.xq.service.UserService;
import com.ruoyi.xq.service.UserWithdrawService;
import com.ruoyi.xq.service.WithdrawSettingService;
import com.ruoyi.xq.service.*;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -45,17 +45,30 @@ public class UserWithdrawServiceImpl extends ServiceImpl<UserWithdrawMapper,User
private UserExtendService userExtendService;
@Autowired
private UserService userService;
@Autowired
private UserBankCardService userBankCardService;
@Override
@Transactional(rollbackFor = Exception.class)
public void saveWithdraw(Long userId, Long withdrawSettingId) {
User user = userService.getById(userId);
WithdrawSetting withdrawSetting = withdrawSettingService.getById(withdrawSettingId);
public void saveWithdraw(WithdrawReq req) {
User user = userService.getById(req.getUserId());
WithdrawSetting withdrawSetting = withdrawSettingService.getById(req.getId());
if(withdrawSetting == null){
throw new ServiceException("提现参数错误");
}
UserBankCard userBankCard = userBankCardService.getByUserId(req.getUserId());
if(userBankCard == null){
throw new ServiceException("提现失败,请补充账户信息");
}
if(WithdrawTypeEnum.ALI.getCode().equals(req.getWithdrawType())){
if(StringUtils.isEmpty(userBankCard.getAliCard()) || StringUtils.isEmpty(userBankCard.getAliName())){
throw new ServiceException("提现失败,请补充支付宝账户信息");
}
} else {
throw new ServiceException("提现失败,请选择提现方式");
}
String traceId = TraceIdManager.gen(TraceIdEnum.WITHDRAW);
boolean withdraw = userExtendService.withdraw(userId, withdrawSetting.getMoney(),traceId);
boolean withdraw = userExtendService.withdraw(req.getUserId(), withdrawSetting.getMoney(),traceId);
if(!withdraw){
throw new ServiceException("提现失败,余额不足");
}
@@ -65,6 +78,9 @@ public class UserWithdrawServiceImpl extends ServiceImpl<UserWithdrawMapper,User
userWithdraw.setUsercode(user.getUsercode());
userWithdraw.setTraceId(traceId);
userWithdraw.setOrderNo(orderNo);
userWithdraw.setWithdrawType(req.getWithdrawType());
userWithdraw.setCard(userBankCard.getAliCard());
userWithdraw.setName(userBankCard.getAliName());
userWithdraw.setWithdrawMoney(withdrawSetting.getMoney());
userWithdraw.setRealWithdrawMoney(withdrawSetting.getMoney());
userWithdraw.setWithdrawFees(BigDecimal.ZERO);