From 8f090c91e2e2b0536d0900b935948e77a5f0979d Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 09 Jun 2022 15:08:43 +0800 Subject: [PATCH] fix some problem --- src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java | 7 ++++--- 1 files changed, 4 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 365e962..be83b99 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 @@ -64,15 +64,13 @@ // 如果得到触发,则休眠10秒。 因为此处监听器触发可能优先于前端调用transfer接口 try { - Thread.sleep(5000); + Thread.sleep(10000); } catch (InterruptedException ex) { ex.printStackTrace(); } ContractChainService sourceUsdtInstance = ChainService.getInstance(ChainEnum.BSC_USDT.name()); int decimals = sourceUsdtInstance.decimals(); - int tfcDecimals = ChainService.getInstance(ChainEnum.BSC_TFC.name()).decimals(); - if (e.from.equals("0xaa25aa7a19f9c426e07dee59b12f944f4d9f1dd3")) { return; } @@ -155,6 +153,9 @@ // 发送转账消息 chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map)); + + // 发送购买奖励消息 + chainProducer.sendUserBuyReward(fundFlow.getId()); } } } -- Gitblit v1.9.1