逻辑

KKSU

2024-08-06 609d2e5f259aeb07b9579fb0ea0c01dd36b482d0

 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;
    }
}