| | |
| | | DappFundFlowEntity fundFlow = new DappFundFlowEntity(refererMember.getId(), memberLevelProfit, 4, 1, BigDecimal.ZERO,null,dappSystemProfit.getId()); |
| | | dappFundFlowDao.insert(fundFlow); |
| | | //发送转币消息 |
| | | // chainProducer.sendBnbTransferMsg(fundFlow.getId()); |
| | | chainProducer.sendBnbTransferMsg(fundFlow.getId()); |
| | | systemProfitTotal = systemProfitTotal.add(memberLevelProfit); |
| | | } |
| | | } |
| | |
| | | DappFundFlowEntity fundFlow = new DappFundFlowEntity(2L, avaProfit, 5, 1, BigDecimal.ZERO,null,dappSystemProfit.getId()); |
| | | dappFundFlowDao.insert(fundFlow); |
| | | //发送转币消息 |
| | | // chainProducer.sendBnbTransferMsg(fundFlow.getId()); |
| | | chainProducer.sendBnbTransferMsg(fundFlow.getId()); |
| | | } |
| | | |
| | | dappSystemProfitDao.updateLevelProfitById(DappSystemProfit.ENUM_YES,dappSystemProfit.getId()); |
| | |
| | | DappSystemProfit dappSystemProfitNow = dappSystemProfitDao.selectByIdForUpdate(dappSystemProfit.getId(),DappSystemProfit.STATE_IN); |
| | | dappSystemProfitDao.updateStateById(DappSystemProfit.STATE_OUT,dappSystemProfitNow.getId()); |
| | | |
| | | //todo 直接拿走0.95ge |
| | | // 直接拿走0.95ge |
| | | |
| | | DataDictionaryCustom investAmountProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.INVEST_AMOUNT_PROFIT.getType(), DataDictionaryEnum.INVEST_AMOUNT_PROFIT.getCode()); |
| | | BigDecimal investAmountProfit = new BigDecimal(investAmountProfitSet.getValue()); |