From 0a22a881f09abd830fd0c8c7cb094e3ea23796a5 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 29 Apr 2024 00:12:35 +0800
Subject: [PATCH] 测试环境新版

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java |   12 ++++++++++++
 1 files changed, 12 insertions(+), 0 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 76cfc62..c51913d 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
@@ -139,6 +139,9 @@
 
                 // 发送转账消息
                 chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
+
+                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());
 
@@ -155,6 +158,15 @@
         }
     }
 
+    @Override
+    public void coinReward(EthUsdtContract.CoinRewardEventResponse e) {
+        if (e.adr == null) {
+            return;
+        }
+
+        log.info("本地无交易USDT:{}", e.log.getTransactionHash());
+    }
+
     public static void main(String[] args) {
         System.out.println(ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf("0x9DDE1834683D642D4D077498DC7fbdb8CF70E8FE"));
     }

--
Gitblit v1.9.1