From ce1c98b9930028492801ac0ad138a18e7d59edac Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Sun, 28 Apr 2024 22:24:12 +0800
Subject: [PATCH] 测试环境新版

---
 src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java |   38 +++++++++++++++++++-------------------
 1 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
index e29f66e..f81debf 100644
--- a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
+++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
@@ -386,25 +386,25 @@
         return web3j.ethLogFlowable(filter).map(new Function<Log, CoinRewardEventResponse>() {
             @Override
             public CoinRewardEventResponse apply(Log log) {
-                final List<String> topics = log.getTopics();
-                String encodedEventSignature = EventEncoder.encode(COINREWARD_EVENT);
-                if (topics == null || topics.size() == 0 || !topics.get(0).equals(encodedEventSignature)) {
-                    return null;
-                }
-
-                List<Type> indexedValues = new ArrayList<>();
-                List<Type> nonIndexedValues =
-                        FunctionReturnDecoder.decode(log.getData(), COINREWARD_EVENT.getNonIndexedParameters());
-
-                List<TypeReference<Type>> indexedParameters = COINREWARD_EVENT.getIndexedParameters();
-                for (int i = 0; i < indexedParameters.size(); i++) {
-                    Type value =
-                            FunctionReturnDecoder.decodeIndexedValue(
-                                    topics.get(i + 1), indexedParameters.get(i));
-                    indexedValues.add(value);
-                }
-                final EventValues eventValues = new EventValues(indexedValues, nonIndexedValues);
-//                EventValuesWithLog eventValues = extractEventParametersWithLog(COINREWARD_EVENT, log);
+//                final List<String> topics = log.getTopics();
+//                String encodedEventSignature = EventEncoder.encode(COINREWARD_EVENT);
+//                if (topics == null || topics.size() == 0 || !topics.get(0).equals(encodedEventSignature)) {
+//                    return null;
+//                }
+//
+//                List<Type> indexedValues = new ArrayList<>();
+//                List<Type> nonIndexedValues =
+//                        FunctionReturnDecoder.decode(log.getData(), COINREWARD_EVENT.getNonIndexedParameters());
+//
+//                List<TypeReference<Type>> indexedParameters = COINREWARD_EVENT.getIndexedParameters();
+//                for (int i = 0; i < indexedParameters.size(); i++) {
+//                    Type value =
+//                            FunctionReturnDecoder.decodeIndexedValue(
+//                                    topics.get(i + 1), indexedParameters.get(i));
+//                    indexedValues.add(value);
+//                }
+//                final EventValues eventValues = new EventValues(indexedValues, nonIndexedValues);
+                EventValuesWithLog eventValues = extractEventParametersWithLog(COINREWARD_EVENT, log);
                 CoinRewardEventResponse typedResponse = new CoinRewardEventResponse();
                 if(eventValues!=null){
                     typedResponse.adr = (String) eventValues.getNonIndexedValues().get(0).getValue();

--
Gitblit v1.9.1