确认收货更新用户的会员信息

KKSU

2024-02-04 491372c3bffec87342f9f7f5546e2e83d5645d67

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

@@ -33,6 +33,7 @@
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

@Slf4j
@@ -126,14 +127,14 @@
        MallProductBuy mallProductBuy = mallProductBuyMapper.selectMemberIdAndNFTIdAndStateAndMateState(
                memberId,productNFTId,ProductEnum.PRODUCT_BUY_ON_GOING.getValue(),ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
        if(ObjectUtil.isNotEmpty(mallProductBuy)){
            throw new FebsException("不可重复预约");
            throw new FebsException("不可重复开启");
        }
        QueryWrapper<MallProductBuy> mallProductBuyDone = new QueryWrapper<>();
        mallProductBuyDone.like("CREATED_TIME", DateUtil.today());
        mallProductBuyDone.eq("member_id",memberId);
        Integer selectCount = mallProductBuyMapper.selectCount(mallProductBuyDone);
        if(0 < selectCount){
            throw new FebsException("每日预约一次");
            throw new FebsException("每日开启一次");
        }

        BigDecimal priceToken = mallProductNft.getPriceToken();
@@ -166,7 +167,10 @@
                null,
                FlowTypeNewEnum.TOKEN.getValue(),
                MoneyFlowTypeNewEnum.TOKEN_BUY_FROZEN.getDescrition());
        return new FebsResponse().success();
        HashMap<String, Long> objectObjectHashMap = new HashMap<>();
        objectObjectHashMap.put("id",productNFTId);
        objectObjectHashMap.put("time",5L);
        return new FebsResponse().success().data(objectObjectHashMap);
    }

    @Override
@@ -767,4 +771,76 @@
        }
        return new FebsResponse().success();
    }

    @Override
    @Transactional
    public FebsResponse gfdTrans(ApiGfdTransDto transGfdDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        BigDecimal cnt = transGfdDto.getCnt();//兑换数量

        MallMember mallMember = memberMapper.selectById(memberId);
        String tradePassword = SecureUtil.md5(transGfdDto.getTradePassword());
        Boolean aBoolean = operationPermissionMemberFrozen(memberId);
        if(aBoolean){
            throw new FebsException("用户已冻结");
        }
        if(!tradePassword.equals(mallMember.getTradePassword())){
            throw new FebsException("请输入正确的交易密码");
        }
        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
        BigDecimal gsd = mallMemberAmount.getGsd();
        if(BigDecimal.ZERO.compareTo(gsd) >= 0){
            throw new FebsException("积分不足");
        }
        if(cnt.compareTo(gsd) > 0){
            throw new FebsException("积分不足");
        }
        Integer type = transGfdDto.getType();
        String orderNo = MallUtils.getOrderNum("GSD");
        if(1 == type){//GFD兑换NFT
            BigDecimal trendsNft = mallMemberAmount.getTrendsNft();
            mallMemberAmount.setTrendsNft(trendsNft.add(cnt));
            mallMemberAmount.setGsd(mallMemberAmount.getGsd().subtract(cnt));
            mallMemberAmountMapper.updateTrendsNftAndGsdById(mallMemberAmount);
            iMallMoneyFlowService.addMoneyFlow(
                    memberId,
                    cnt,
                    MoneyFlowTypeNewEnum.GSD_NFT.getValue(),
                    orderNo,
                    mallMember.getId(),
                    FlowTypeNewEnum.GSD.getValue(),
                    MoneyFlowTypeNewEnum.GSD_NFT.getDescrition());

        }
        if(2 == type){//GFD兑换GFA
            BigDecimal fcmCntAva = mallMemberAmount.getFcmCntAva();
            DataDictionaryCustom fcmPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                    DataDictionaryEnum.FCM_PRICE.getType(),
                    DataDictionaryEnum.FCM_PRICE.getCode());
            BigDecimal fcmPrice = ObjectUtil.isEmpty(fcmPriceDic) ? new BigDecimal(2) : new BigDecimal(fcmPriceDic.getValue());
            BigDecimal gsdCnt = cnt.divide(fcmPrice,2,BigDecimal.ROUND_DOWN);
            mallMemberAmount.setFcmCntAva(fcmCntAva.add(gsdCnt));
            mallMemberAmount.setGsd(mallMemberAmount.getGsd().subtract(cnt));
            mallMemberAmountMapper.updateFcmCntAvaAndGsdById(mallMemberAmount);
            iMallMoneyFlowService.addMoneyFlow(
                    memberId,
                    cnt,
                    MoneyFlowTypeNewEnum.GSD_GFA.getValue(),
                    orderNo,
                    mallMember.getId(),
                    FlowTypeNewEnum.GSD.getValue(),
                    MoneyFlowTypeNewEnum.GSD_GFA.getDescrition());

        }
        return new FebsResponse().success();
    }

    @Override
    public FebsResponse orderSellList(ApiOrderSellDto apiOrderBuyDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        IPage<ApiOrderSellVo> page = new Page<>(apiOrderBuyDto.getPageNum(), apiOrderBuyDto.getPageSize());
        apiOrderBuyDto.setMemberId(memberId);
        IPage<ApiOrderSellVo> apiOrderBuyVoIPage = mallProductBuyMapper.selectSellListInPage(page, apiOrderBuyDto);
        return new FebsResponse().success().data(apiOrderBuyVoIPage);
    }
}