From 3154a08c8f114291b59ee44074d6af95026eba32 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 11 Aug 2022 18:18:28 +0800 Subject: [PATCH] fix:add active nft --- src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java | 13 ++++++++++--- 1 files changed, 10 insertions(+), 3 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java index 2664c27..955211f 100644 --- a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java +++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java @@ -107,7 +107,7 @@ boolean hasFlow = false; for (DappFundFlowEntity flow : flows) { if (flow.getStatus() == 1) { - if (amount.compareTo(flow.getTargetAmount()) == 0) { + if (amount.compareTo(flow.getAmount().multiply(flow.getNewestPrice()).setScale(4, RoundingMode.HALF_UP)) == 0) { hasFlow = true; fundFlow = flow; fundFlow.setFromHash(e.log.getTransactionHash()); @@ -142,7 +142,7 @@ // 如果系统会开启,则使用自动打款 if (!"start".equals(hasStart)) { - OnlineTransferUtil.addTransfer(e.from, fundFlow.getAmount(), 1, 1, ChainEnum.BSC_TFC_MAKE.name(), "BSC", fundFlow.getId().toString()); + OnlineTransferUtil.addTransfer(e.from, fundFlow.getAmount(), 1, 1, ChainEnum.BSC_TFC.name(), "BSC", fundFlow.getId().toString()); Map<String, String> map = new HashMap<>(); map.put("batchNo", fundFlow.getId().toString()); @@ -151,10 +151,14 @@ // 发送转账消息 chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map)); + // 发送盲盒消息 + chainProducer.sendNftBoxMsg(fundFlow.getId()); + fromMember.setMakerType(1); dappMemberService.updateById(fromMember); } else { - OnlineTransferUtil.addTransfer(e.from, fundFlow.getAmount(), 1, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, fundFlow.getId().toString()); + // 买入收手续费,到账币数量减去手续费 + OnlineTransferUtil.addTransfer(e.from, fundFlow.getAmount().subtract(fundFlow.getFee()), 1, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, fundFlow.getId().toString()); Map<String, String> map = new HashMap<>(); map.put("batchNo", fundFlow.getId().toString()); @@ -165,6 +169,9 @@ // 发送购买奖励消息 chainProducer.sendUserBuyReward(fundFlow.getId()); + + // 发送盲盒消息 + chainProducer.sendNftBoxMsg(fundFlow.getId()); } } } -- Gitblit v1.9.1