用户留言

KKSU

2023-12-11 b6ad0f29932c0a4f6053a765723aa4d80adcc706

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

@@ -46,6 +46,7 @@
    private final MallProductSellMapper mallProductSellMapper;
    private final MallProductSellRecordMapper mallProductSellRecordMapper;
    private final MallProductBuyRecordMapper mallProductBuyRecordMapper;
    private final MallMemberSpeakMapper mallMemberSpeakMapper;

    @Override
    public List<ApiMallProductNftVo> productNFTList() {
@@ -89,9 +90,9 @@
         * 预约，验证交易密码、预约产品是否开启状态、该产品是否已经预约、token是否足够
         * 冻结对应的令牌数量、生成预约记录、生成流水记录
         */
        Integer isFrozen = mallMember.getIsFrozen();
        if(ProductEnum.MEMBER_UNFROZEN.getValue() != isFrozen){
            throw new FebsException("账户无法预约");
        Boolean aBoolean = operationPermissionMemberFrozen(memberId);
        if(aBoolean){
            throw new FebsException("用户已冻结");
        }

        DateTime nowTime = DateUtil.parseTime(DateUtil.formatTime(DateUtil.date()));
@@ -169,6 +170,11 @@
         * 计算手续费、减少用户的fcm余额
         * 增加流水
         */

        Boolean aBoolean = operationPermissionMemberFrozen(memberId);
        if(aBoolean){
            throw new FebsException("用户已冻结");
        }
        if(!tradePassword.equals(mallMember.getTradePassword())){
            throw new FebsException("请输入正确的交易密码");
        }
@@ -249,6 +255,11 @@
         * 计算手续费、减少动态NFT、增加冻结NFT
         * 增加流水
         */

        Boolean aBoolean = operationPermissionMemberFrozen(memberId);
        if(aBoolean){
            throw new FebsException("用户已冻结");
        }
        if(!tradePassword.equals(mallMember.getTradePassword())){
            throw new FebsException("请输入正确的交易密码");
        }
@@ -271,21 +282,23 @@
        BigDecimal nftFeePercent = ObjectUtil.isEmpty(nftFeeDic) ? new BigDecimal(20) : new BigDecimal(nftFeeDic.getValue());
        nftFeePercent = nftFeePercent.divide(new BigDecimal(100),4,BigDecimal.ROUND_DOWN);
        BigDecimal nftFee = nftCnt.multiply(nftFeePercent);
        BigDecimal nftCntAva = nftCnt.subtract(nftFee);

        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 fcmFeeCnt = nftFee.divide(fcmPrice, 2, BigDecimal.ROUND_DOWN);
        if(BigDecimal.ZERO.compareTo(mallMemberAmount.getTrendsNft()) >= 0
            || fcmFeeCnt.compareTo(mallMemberAmount.getFcmCntAva()) > 0){
            throw new FebsException("手续费不足");
        }

        String orderNo = MallUtils.getOrderNum("NFT");
        MallProductSell mallProductSell = new MallProductSell();
        mallProductSell.setMemberId(memberId);
        mallProductSell.setOrderNo(orderNo);
        mallProductSell.setNftTotal(nftCnt);
        mallProductSell.setNftCnt(nftCntAva);
        mallProductSell.setNftCntAva(nftCntAva);
        mallProductSell.setNftCnt(nftCnt);
        mallProductSell.setNftCntAva(nftCnt);
        mallProductSell.setNftFee(nftFee);
        mallProductSell.setFcmFee(fcmFeeCnt);
        mallProductSell.setState(ProductEnum.PRODUCT_SELL_ON_GOING.getValue());
@@ -299,7 +312,7 @@
        mallMemberAmountMapper.updateFcmCntAvaById(mallMemberAmountFcm);

        MallMemberAmount mallMemberAmountFrozenNFT = mallMemberAmountMapper.selectByMemberId(memberId);
        mallMemberAmountFrozenNFT.setFrozenNft(mallMemberAmountFrozenNFT.getFrozenNft().add(nftCntAva));
        mallMemberAmountFrozenNFT.setFrozenNft(mallMemberAmountFrozenNFT.getFrozenNft().add(nftCnt));
        mallMemberAmountMapper.updateFrozenNftById(mallMemberAmountFrozenNFT);
        iMallMoneyFlowService.addMoneyFlow(
                memberId,
@@ -317,15 +330,6 @@
                mallMember.getId(),
                FlowTypeNewEnum.FCM_COIN.getValue(),
                MoneyFlowTypeNewEnum.NFT_OUT_FEE_FCM.getDescrition());
        iMallMoneyFlowService.addMoneyFlow(
                memberId,
                nftFee.negate(),
                MoneyFlowTypeNewEnum.NFT_OUT_FEE.getValue(),
                orderNo,
                mallMember.getId(),
                FlowTypeNewEnum.NFT.getValue(),
                MoneyFlowTypeNewEnum.NFT_OUT_FEE.getDescrition());

        agentProducer.sendFcmNFTExchangeMsg(fcmFeeCnt.toString());
        return new FebsResponse().success();
    }
@@ -428,6 +432,11 @@
         * 更新卖单状态
         * 生成流水信息
         */

        Boolean aBoolean = operationPermissionMemberFrozen(memberId);
        if(aBoolean){
            throw new FebsException("用户已冻结");
        }
        if(!tradePassword.equals(mallMember.getTradePassword())){
            throw new FebsException("请输入正确的交易密码");
        }
@@ -486,6 +495,11 @@
         * 更新卖单状态
         * 生成流水信息
         */

        Boolean aBoolean = operationPermissionMemberFrozen(memberId);
        if(aBoolean){
            throw new FebsException("用户已冻结");
        }
        if(!tradePassword.equals(mallMember.getTradePassword())){
            throw new FebsException("请输入正确的交易密码");
        }
@@ -516,4 +530,52 @@
        agentProducer.sendFcmOrderSellInsureMsg(sellRecordId);
        return new FebsResponse().success();
    }

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

    @Override
    public Boolean operationPermissionMemberFrozen(Long memberId) {
        MallMember mallMember = memberMapper.selectById(memberId);
        if(ProductEnum.MEMBER_FROZEN.getValue() == mallMember.getIsFrozen()){
            return true;
        }
        return false;
    }

    @Override
    public FebsResponse orderSellComplain(ApiOrderSellComplainDto apiOrderSellComplainDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        Long sellRecordId = apiOrderSellComplainDto.getSellRecordId();
        MallProductSellRecord mallProductSellRecord = mallProductSellRecordMapper.selectById(sellRecordId);
        if(ObjectUtil.isEmpty(mallProductSellRecord)){
            throw new FebsException("记录不存在");
        }

        MallProductBuyRecord mallProductBuyRecord = mallProductBuyRecordMapper.selectById(mallProductSellRecord.getBuyRecordId());
        if(ObjectUtil.isEmpty(mallProductBuyRecord)){
            throw new FebsException("记录不存在");
        }

        mallProductBuyRecord.setState(ProductEnum.PRODUCT_MATE_STATE_COMPLAIN.getValue());
        mallProductBuyRecordMapper.updateById(mallProductBuyRecord);

        mallProductSellRecord.setState(ProductEnum.PRODUCT_MATE_STATE_COMPLAIN.getValue());
        mallProductSellRecordMapper.updateById(mallProductSellRecord);

        MallMemberSpeak mallMemberSpeak = new MallMemberSpeak();
        mallMemberSpeak.setMemberId(memberId);
        mallMemberSpeak.setState(ProductEnum.SPEAK_NO_DEAL.getValue());
        String description = apiOrderSellComplainDto.getDescription();
        String buyOrderNo = mallProductBuyRecord.getBuyOrderNo();
        mallMemberSpeak.setDescription("编号："+buyOrderNo+","+description);
        mallMemberSpeakMapper.insert(mallMemberSpeak);
        return new FebsResponse().success();
    }
}