节点读取超时异常处理

alive-api/src/main/java/com/alive/server/api/TestController.java

@@ -1,27 +1,14 @@
 package com.alive.server.api;
 
-import com.alive.db.entity.Vo.RecommendVo;
-import com.alive.server.config.TwitterConfig;
 import com.alive.server.oss.AliyunOssUtils;
-import com.alive.server.oss.MultipartFileToFileUtil;
-import com.alive.server.service.TwitterService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Isolation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.BufferedReader;
 import java.io.File;
-import java.io.InputStreamReader;
-import java.net.HttpURLConnection;
-import java.net.URL;
-import java.net.URLEncoder;
 import java.text.SimpleDateFormat;
-import java.util.Base64;
 import java.util.Date;
 import java.util.UUID;
 
@@ -38,14 +25,9 @@ import java.util.UUID;
 @Transactional(isolation = Isolation.READ_COMMITTED)
 public class TestController
 {
-    @Autowired
-    private TwitterService twitterService;
-
 
     /**
      * 上传文件（阿里OSS）
-     *
-     * @param file 文件对象
      * @return
      */
     @ApiOperation("上传文件")

alive-api/src/main/java/com/alive/server/service/CrowdfundingService.java

@@ -291,8 +291,13 @@ public class CrowdfundingService extends BaseComponent {
         try {
             send = this.getBscWsWeb3j().ethGetLogs(filter).send();
         } catch (IOException e) {
-            e.printStackTrace();
-            throw new RuntimeException(e.getMessage());
+            String msg = e.getMessage();
+            if(msg.equals("timeout")){
+                log.error("节点读取超时------------------");
+            }else{
+                e.printStackTrace();
+                throw new RuntimeException(e.getMessage());
+            }
         }
         if(send.getError() != null && send.getError().getMessage() != null){
             log.info("扫描块失败(检查节点是否被限制) out {} ,{}, {}", startBlock, endBlock, send.getError().getMessage());

alive-api/src/main/java/com/alive/server/service/NodeSettingService.java

@@ -50,13 +50,6 @@ public class NodeSettingService extends BaseComponent {
     @Autowired
     private DSLContext dslContext;
 
-    @Resource
-    private MemberService tMemberService;
-
-    @Autowired
-    private Web3jServer web3jServer;
-
-
     public boolean buyNode() {
         int memberId = Integer.parseInt(RequestUtil.getCurrentAccount());
         Integer code = dslContext.selectCount().from(NODE_BUY_LOG).where(NODE_BUY_LOG.USER_ID.eq(memberId).and(NODE_BUY_LOG.STATUS.eq(3))).fetchAnyInto(Integer.class);