From ae50866f34212c007643c1744f78426676885c08 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 09 Aug 2022 16:18:08 +0800 Subject: [PATCH] fix:chainEnum and ChainListenerJob --- src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java | 11 +++++++++-- 1 files changed, 9 insertions(+), 2 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 4e2b52d..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 @@ -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