KKSU
2024-04-01 163b165c77239a8e9a3bb76be6cbe5d606d0697e
src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallProductServiceImpl.java
@@ -6,6 +6,7 @@
import cc.mrbird.febs.common.enumerates.MoneyFlowTypeNewEnum;
import cc.mrbird.febs.common.enumerates.ProductEnum;
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.*;
@@ -153,6 +154,8 @@
        mallProductBuy.setMateState(ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
        mallProductBuy.setNftTotal(mallProductNft.getPriceNft());
        mallProductBuy.setNftAva(mallProductNft.getPriceNft());
        mallProductBuy.setCycle(mallProductBuy.getCycle());
        mallProductBuy.setProfit(mallProductNft.getProfit());
//        mallProductBuy.setNftAva(BigDecimal.ZERO);
        mallProductBuyMapper.insert(mallProductBuy);
        //令牌 可用减少,冻结增加
@@ -573,6 +576,25 @@
        mallProductSellRecord.setState(ProductEnum.PRODUCT_MATE_STATE_CONFIRM.getValue());
        mallProductSellRecordMapper.updateById(mallProductSellRecord);
        DataDictionaryCustom gsdInDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.FCM_GSD_IN.getType(),
                DataDictionaryEnum.FCM_GSD_IN.getCode()
        );
        BigDecimal gsdInPercent = new BigDecimal(gsdInDic.getValue()).multiply(AppContants.BASIC_PERCENT);
        BigDecimal gsdIn = gsdInPercent.multiply(mallProductSellRecord.getNftCnt()).setScale(2,BigDecimal.ROUND_DOWN);
        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
        mallMemberAmount.setGsd(mallMemberAmount.getGsd().add(gsdIn));
        mallMemberAmountMapper.updateGsdById(mallMemberAmount);
        iMallMoneyFlowService.addMoneyFlow(
                memberId,
                gsdIn,
                MoneyFlowTypeNewEnum.NFT_TRANS_GFD.getValue(),
                null,
                mallMember.getId(),
                FlowTypeNewEnum.GSD.getValue(),
                MoneyFlowTypeNewEnum.NFT_TRANS_GFD.getDescrition());
        agentProducer.sendFcmOrderSellInsureMsg(sellRecordId);
        return new FebsResponse().success();
    }