package cc.mrbird.febs.mall.service.impl; import cc.mrbird.febs.common.enumerates.DataDictionaryEnum; import cc.mrbird.febs.common.enumerates.FlowTypeEnum; import cc.mrbird.febs.common.enumerates.GreenScoreEnum; import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum; import cc.mrbird.febs.common.exception.FebsException; import cc.mrbird.febs.common.utils.AppContants; import cc.mrbird.febs.common.utils.LoginUserUtil; import cc.mrbird.febs.common.utils.MallUtils; import cc.mrbird.febs.mall.dto.WithdrawalBalanceDto; import cc.mrbird.febs.mall.dto.WithdrawalDto; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.IApiMallMemberService; import cc.mrbird.febs.mall.service.IApiMallMemberWalletService; import cc.mrbird.febs.mall.service.IMallMemberWithdrawService; import cc.mrbird.febs.mall.service.MallMemberService; import cc.mrbird.febs.mall.vo.CashOutSettingVo; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.crypto.SecureUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.util.Date; import java.util.List; /** * @author wzy * @date 2022-05-05 **/ @Slf4j @Service @RequiredArgsConstructor public class MallMemberWithdrawServiceImpl extends ServiceImpl implements IMallMemberWithdrawService { private final IApiMallMemberService mallMemberService; private final MallMoneyFlowMapper mallMoneyFlowMapper; private final MallMemberWalletMapper mallMemberWalletMapper; private final IApiMallMemberWalletService walletService; private final MallMemberPaymentMapper mallMemberPaymentMapper; private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final MallMemberBankMapper mallMemberBankMapper; private final MallMemberAmountMapper mallMemberAmountMapper; @Override @Transactional(rollbackFor = Exception.class) public void withdrawal(WithdrawalDto withdrawalDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = mallMemberService.getById(memberId); Integer outsideWith = mallMember.getOutsideWith() == null ? 2 :mallMember.getOutsideWith(); if (1 != outsideWith) { throw new FebsException("功能升级中"); } if (StrUtil.isBlank(mallMember.getTradePassword())) { throw new FebsException("未设置支付密码"); } if (!mallMember.getTradePassword().equals(SecureUtil.md5(withdrawalDto.getTradePwd()))) { throw new FebsException("支付密码错误"); } CashOutSettingVo cashOutSettingVo = new CashOutSettingVo(); DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.CASHOUT_SETTING.getType(), DataDictionaryEnum.CASHOUT_SETTING.getCode()); if (dic != null) { cashOutSettingVo = JSONObject.parseObject(dic.getValue(), CashOutSettingVo.class); } //每日提现额度上限 BigDecimal allCashOut = cashOutSettingVo.getAllCashOut(); if(withdrawalDto.getAmount().compareTo(allCashOut) > 0){ throw new FebsException("每日限额为"+cashOutSettingVo.getAllCashOut().setScale(2,BigDecimal.ROUND_DOWN)); } List mallMemberWithdrawListDone = this.baseMapper.selectListByMemberIdAndDate(memberId,new Date()); if(CollUtil.isNotEmpty(mallMemberWithdrawListDone)){ BigDecimal amountTCAll = mallMemberWithdrawListDone.stream().map(MallMemberWithdraw::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add); amountTCAll = amountTCAll.add(withdrawalDto.getAmount()); if (amountTCAll.compareTo(allCashOut) > 0) { throw new FebsException("每日限额为"+cashOutSettingVo.getAllCashOut().setScale(2,BigDecimal.ROUND_DOWN)); } } if (withdrawalDto.getAmount().compareTo(cashOutSettingVo.getMinCashOut()) < 0) { throw new FebsException("最小提现金额为"+cashOutSettingVo.getMinCashOut().setScale(2,BigDecimal.ROUND_DOWN)); } MallMemberBank mallMemberBank = mallMemberBankMapper.selectById(withdrawalDto.getBankId()); if(ObjectUtil.isEmpty(mallMemberBank)){ throw new FebsException("未找到银行卡信息"); } if(ObjectUtil.isEmpty(mallMemberBank.getBankName())){ throw new FebsException("请填写所属银行"); } if(ObjectUtil.isEmpty(mallMemberBank.getSubbranchName())){ throw new FebsException("请填写所属支行"); } // if(ObjectUtil.isEmpty(mallMemberBank.getDigitalNo())){ // throw new FebsException("请填写数字货币账号"); // } MallMemberWallet wallet = mallMemberWalletMapper.selectWalletByMemberId(memberId); // 可提现 BigDecimal canMoney = wallet.getBalance(); if(withdrawalDto.getAmount().compareTo(canMoney) > 0) { throw new FebsException("提现金额不足"); } BigDecimal serviceFeePercent = cashOutSettingVo.getServiceFee().multiply(BigDecimal.valueOf(0.01)); BigDecimal serviceFee = serviceFeePercent.multiply(withdrawalDto.getAmount()); String remark = AppContants.MEMBER_WITHDRAW_NORMAL; DataDictionaryCustom voucherOnOffDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( GreenScoreEnum.VOUCHER_ON_OFF.getType(), GreenScoreEnum.VOUCHER_ON_OFF.getCode() ); if(ObjectUtil.isNotEmpty(voucherOnOffDic)){ String voucherOnOff = voucherOnOffDic.getValue(); /** * 绿色凭证提现开关 1:开启 2：关闭 * 验证账户凭证数量 * 不需要手续费 * 减少用户的凭证数量 */ if("1".equals(voucherOnOff)){ BigDecimal voucherCntDto = withdrawalDto.getVoucherCnt(); if(voucherCntDto.compareTo(BigDecimal.ZERO) <= 0){ throw new FebsException("能量不足"); } //提现需要的凭证数量 = 提现金额 * 余额提现需要绿色凭证比例 DataDictionaryCustom voucherPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( GreenScoreEnum.VOUCHER_PERCENT.getType(), GreenScoreEnum.VOUCHER_PERCENT.getCode() ); BigDecimal voucherPercent = new BigDecimal(voucherPercentDic.getValue() == null ? "0" : voucherPercentDic.getValue()).multiply(new BigDecimal(0.01)); BigDecimal voucherPercentNeed = withdrawalDto.getAmount().multiply(voucherPercent).setScale(2,BigDecimal.ROUND_DOWN); DataDictionaryCustom scorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( GreenScoreEnum.SCORE_PRICE.getType(), GreenScoreEnum.SCORE_PRICE.getCode()); BigDecimal scorePrice = new BigDecimal(scorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); voucherPercentNeed = voucherPercentNeed.divide(scorePrice,2,BigDecimal.ROUND_DOWN); // BigDecimal voucherCnt = wallet.getVoucherCnt(); BigDecimal voucherFireCnt = wallet.getVoucherFireCnt(); if(voucherFireCnt.compareTo(voucherPercentNeed) < 0){ throw new FebsException("能量不足"); } // walletService.reduce(voucherCntDto, memberId, "voucherCnt"); walletService.reduce(voucherCntDto, memberId, "voucherFireCnt"); serviceFee = voucherCntDto; remark = AppContants.MEMBER_WITHDRAW_VOUCHER; } } walletService.reduce(withdrawalDto.getAmount(), memberId, "balance"); String orderNo = MallUtils.getOrderNum("W"); MallMemberWithdraw withdraw = new MallMemberWithdraw(); withdraw.setWithdrawNo(orderNo); withdraw.setMemberId(memberId); withdraw.setAmount(withdrawalDto.getAmount()); withdraw.setStatus(1); withdraw.setAmountFee(serviceFee); withdraw.setRemark(remark); withdraw.setWtihdrawTypeId(mallMemberBank.getId()); this.baseMapper.insert(withdraw); mallMemberService.addMoneyFlow(memberId, withdrawalDto.getAmount().negate(), MoneyFlowTypeEnum.WITHDRAWAL.getValue(), orderNo, null, null, null, 1, FlowTypeEnum.BALANCE.getValue()); } @Override public void withdrawalBalance(WithdrawalBalanceDto withdrawalBalanceDto) { Long memberId = LoginUserUtil.getLoginUser().getId(); MallMember mallMember = mallMemberService.getById(memberId); if (StrUtil.isBlank(mallMember.getTradePassword())) { throw new FebsException("未设置支付密码"); } if (!mallMember.getTradePassword().equals(SecureUtil.md5(withdrawalBalanceDto.getTradePwd()))) { throw new FebsException("支付密码错误"); } DataDictionaryCustom withdrawAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.WITHDRAW_AMOUNT.getType(), DataDictionaryEnum.WITHDRAW_AMOUNT.getCode() ); BigDecimal amount = withdrawalBalanceDto.getAmount(); BigDecimal withdrawAmount = new BigDecimal(withdrawAmountDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN); if(withdrawAmount.compareTo(amount) > 0){ throw new FebsException("至少为"+withdrawAmount); } // boolean b = Integer.parseInt(amount.toString()) % Integer.parseInt(withdrawAmount.toString()) == 0; boolean b = amount.remainder(withdrawAmount).compareTo(BigDecimal.ZERO) == 0; if(!b){ throw new FebsException("金额必须为"+withdrawAmount+"的整数倍"); } MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId); mallMemberAmount.setFcmCntAva(mallMemberAmount.getFcmCntAva().subtract(amount)); mallMemberAmountMapper.updateFcmCntAvaById(mallMemberAmount); String orderNo = MallUtils.getOrderNum("W"); MallMemberWithdraw withdraw = new MallMemberWithdraw(); withdraw.setWithdrawNo(orderNo); withdraw.setMemberId(memberId); withdraw.setAmount(amount.negate()); withdraw.setStatus(1); withdraw.setAmountFee(BigDecimal.ZERO); withdraw.setRemark(withdrawalBalanceDto.getAddress()); this.baseMapper.insert(withdraw); } }