From 1a7d5952a941639367db363deacf0477e0894262 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 11 Aug 2022 18:55:38 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java | 19 ++++++++++++++++--- 1 files changed, 16 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 cc5afdb..03cba6d 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.getAmount().multiply(flow.getNewestPrice())) == 0) { + if (amount.compareTo(flow.getAmount().multiply(flow.getNewestPrice()).setScale(4, RoundingMode.HALF_UP)) == 0) { hasFlow = true; fundFlow = flow; fundFlow.setFromHash(e.log.getTransactionHash()); @@ -120,6 +120,12 @@ OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_ONLINE, "USDT"); return; } + } + + // 激活卡牌 + if (fundFlow.getType() == 8) { + + return; } OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_APPLICATION, "USDT"); @@ -142,7 +148,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 +157,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 +175,9 @@ // 发送购买奖励消息 chainProducer.sendUserBuyReward(fundFlow.getId()); + + // 发送盲盒消息 + chainProducer.sendNftBoxMsg(fundFlow.getId()); } } } -- Gitblit v1.9.1