test和数据库连接

KKSU

2024-08-29 b6be66a34281cc6a72d544a92244bcc876a2c773

 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java

@@ -66,6 +66,7 @@
    private final MallProductBuyRecordMapper mallProductBuyRecordMapper;
    private final MallProductBuyMapper mallProductBuyMapper;
    private final MallMemberSpeakMapper mallMemberSpeakMapper;
    private final MallMemberChargeMapper mallMemberChargeMapper;


    @Value("${spring.profiles.active}")
@@ -276,7 +277,7 @@
        DataDictionaryCustom fcmPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.FCM_PRICE.getType(),
                DataDictionaryEnum.FCM_PRICE.getCode());
        mallMemberVo.setFcmPrice(ObjectUtil.isEmpty(fcmPriceDic) ? new BigDecimal(2) : new BigDecimal(fcmPriceDic.getValue()));
        mallMemberVo.setFcmPrice(ObjectUtil.isEmpty(fcmPriceDic) ? new BigDecimal(8) : new BigDecimal(fcmPriceDic.getValue()));

        DataDictionaryCustom outFcmFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.OUT_FCM_FEE.getType(),
@@ -341,6 +342,44 @@
                DataDictionaryEnum.FCM_INSIDE_NFT_PERCENT.getCode()
        );
        mallMemberVo.setInsideNFTPercent(insideNFTPercentDic.getValue());

        DataDictionaryCustom chargeAddressDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.CHARGE_ADDRESS.getType(),
                DataDictionaryEnum.CHARGE_ADDRESS.getCode()
        );
        mallMemberVo.setChargeAddress(chargeAddressDic.getValue());

        DataDictionaryCustom withdrawAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.WITHDRAW_AMOUNT.getType(),
                DataDictionaryEnum.WITHDRAW_AMOUNT.getCode()
        );
        BigDecimal withdrawAmount = new BigDecimal(withdrawAmountDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
        mallMemberVo.setWithdrawAmount(withdrawAmount);

        DataDictionaryCustom usdtPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.USDT_PRICE.getType(),
                DataDictionaryEnum.USDT_PRICE.getCode()
        );
        BigDecimal usdtPrice = new BigDecimal(usdtPriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
        mallMemberVo.setUsdtPrice(usdtPrice);

        DataDictionaryCustom cardChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.CARD_CHANGE.getType(),
                DataDictionaryEnum.CARD_CHANGE.getCode()
        );
        mallMemberVo.setAroundType(Integer.parseInt(StrUtil.isEmpty(cardChangeDic.getValue()) ? "1" : cardChangeDic.getValue()));

        DataDictionaryCustom coinChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.COIN_CHANGE.getType(),
                DataDictionaryEnum.COIN_CHANGE.getCode()
        );
        mallMemberVo.setChangeType(Integer.parseInt(StrUtil.isEmpty(coinChangeDic.getValue()) ? "1" : coinChangeDic.getValue()));

        DataDictionaryCustom coinInsideChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.COIN_INSIDE_CHANGE.getType(),
                DataDictionaryEnum.COIN_INSIDE_CHANGE.getCode()
        );
        mallMemberVo.setAroundCoinType(Integer.parseInt(StrUtil.isEmpty(coinInsideChangeDic.getValue()) ? "1" : coinInsideChangeDic.getValue()));
        return new FebsResponse().success().data(mallMemberVo);
    }

@@ -521,6 +560,22 @@

        if(1 != type && 2 != type && 3 != type){
            throw new FebsException("请选择互转类型");
        }
        if(1 == type){
            DataDictionaryCustom coinChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                    DataDictionaryEnum.COIN_INSIDE_CHANGE.getType(),
                    DataDictionaryEnum.COIN_INSIDE_CHANGE.getCode());
            if(!"1".equals(coinChangeDic.getValue())){
                throw new FebsException("暂未开放");
            }
        }
        if(3 == type){
            DataDictionaryCustom coinChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                    DataDictionaryEnum.CARD_CHANGE.getType(),
                    DataDictionaryEnum.CARD_CHANGE.getCode());
            if(!"1".equals(coinChangeDic.getValue())){
                throw new FebsException("暂未开放");
            }
        }
        Integer insideWith = loginMember.getInsideWith() == null ? 2 :loginMember.getInsideWith();
        if (1 != insideWith) {
@@ -937,7 +992,7 @@

        MallMemberPayment mallMemberPayment = mallMemberPaymentMapper.selectByMemberId(memberId);
        mallMemberPayment.setWxQrcode(updatePaymentDto.getWxQrcode());
//        mallMemberPayment.setAliQrcode(updatePaymentDto.getAliQrcode());
        mallMemberPayment.setAliQrcode(updatePaymentDto.getAliQrcode());
        mallMemberPayment.setBankName(updatePaymentDto.getBankName());
//        mallMemberPayment.setBankNo(updatePaymentDto.getBankNo());
//        mallMemberPayment.setBank(updatePaymentDto.getBank());
@@ -1023,6 +1078,38 @@
        return new FebsResponse().success().data(pages);
    }

    @Override
    public FebsResponse chargeBalance(ApiChargeBalanceDto apiChargeBalanceDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        MallMember mallMember = this.baseMapper.selectById(memberId);
        BigDecimal amount = apiChargeBalanceDto.getAmount();
        DataDictionaryCustom chargeAmountDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.CHARGE_AMOUNT.getType(),
                DataDictionaryEnum.CHARGE_AMOUNT.getCode()
        );
        BigDecimal chargeAmount = new BigDecimal(chargeAmountDic.getValue()).setScale(2,BigDecimal.ROUND_DOWN);
        if(chargeAmount.compareTo(amount) > 0){
            throw new FebsException("充值金额需要大于"+chargeAmount);
        }

        if (StrUtil.isBlank(mallMember.getTradePassword())) {
            throw new FebsException("请设置交易密码");
        }

        if (!mallMember.getTradePassword().equals(SecureUtil.md5(apiChargeBalanceDto.getTradePassword()))) {
            throw new FebsException("交易密码错误");
        }
        MallMemberCharge mallMemberCharge = new MallMemberCharge();
        mallMemberCharge.setMemberId(memberId);
        mallMemberCharge.setAmount(amount);
        mallMemberCharge.setAddress(apiChargeBalanceDto.getAddress());
        mallMemberCharge.setState(1);
        mallMemberChargeMapper.insert(mallMemberCharge);


        return new FebsResponse().success().message("操作成功");
    }

//    public static void main(String[] args) {
//        Set<String> objectsAccount = new HashSet<>();
//        Set<String> objects = new HashSet<>();