From 7f7a1b01527843ffb178d015a044380acbde4fe2 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 02 Jul 2024 16:23:25 +0800
Subject: [PATCH] 逻辑
---
src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java | 33 +++++++++++++++++++++++++++++++++
1 files changed, 33 insertions(+), 0 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 955f75d..d0e23d4 100644
--- a/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
+++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthUsdtContract.java
@@ -127,6 +127,8 @@
public static final String FUNC_TOUZHU = "touzhu";
+ public static final String FUNC_CUNCHU = "received";
+
public static final String FUNC_TRANSFER = "transfer";
public static final String FUNC_TRANSFERFROM = "transferFrom";
@@ -146,6 +148,10 @@
public static final Event TRANSFER_EVENT = new Event("Transfer",
Arrays.<TypeReference<?>>asList(new TypeReference<Address>(true) {}, new TypeReference<Address>(true) {}, new TypeReference<Uint256>() {}));
+ ;
+
+ public static final Event CUNCHU_EVENT = new Event("received",
+ Arrays.<TypeReference<?>>asList(new TypeReference<Address>(true) {}, new TypeReference<Uint256>() {}, new TypeReference<Utf8String>() {}));
;
@Deprecated
@@ -308,6 +314,25 @@
typedResponse.tokens = (BigInteger) eventValues.getNonIndexedValues().get(0).getValue();
}
+ return typedResponse;
+ }
+ });
+ }
+
+
+
+ public Flowable<ReceivePeopleEventResponse> receivePeopleEventFlowable(EthFilter filter) {
+ return web3j.ethLogFlowable(filter).map(new Function<Log, ReceivePeopleEventResponse>() {
+ @Override
+ public ReceivePeopleEventResponse apply(Log log) {
+ EventValuesWithLog eventValues = extractEventParametersWithLog(CUNCHU_EVENT, log);
+ ReceivePeopleEventResponse typedResponse = new ReceivePeopleEventResponse();
+ if(eventValues!=null){
+ typedResponse.log = log;
+ typedResponse.from = (String) eventValues.getIndexedValues().get(0).getValue();
+ typedResponse.tokens = (BigInteger) eventValues.getNonIndexedValues().get(0).getValue();
+ typedResponse.regFlow = (String) eventValues.getNonIndexedValues().get(1).getValue();
+ }
return typedResponse;
}
});
@@ -735,4 +760,12 @@
public BigInteger tokens;
}
+
+ public static class ReceivePeopleEventResponse extends BaseEventResponse {
+ public String from;
+
+ public BigInteger tokens;
+
+ public String regFlow;
+ }
}
--
Gitblit v1.9.1