| | |
| | | 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.*; |
| | |
| | | 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); |
| | | //令牌 可用减少,冻结增加 |
| | |
| | | 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(); |
| | | } |