龚成明 3 år sedan
förälder
incheckning
a955ed6b59
1 ändrade filer med 5 tillägg och 3 borttagningar
  1. 5 3
      src/main/java/controller/EthMevController.java

+ 5 - 3
src/main/java/controller/EthMevController.java

@@ -164,7 +164,7 @@ public class EthMevController extends Controller {
          * 为什么要在服务器进行数据处理:
          * 服务器内存大,CPU好,而且网站客户少,当然要充分压榨服务器性能了
          */
-        String findHashSql = "select * from t_ethereum_mev_v1 where block=? and hash=?";
+        String findHashSql = "select * from t_ethereum_mev_v1 where hash=?";
 
         // 处理对象中的各类地址
         for (EthMev ethMev : ethMevList) {
@@ -188,7 +188,7 @@ public class EthMevController extends Controller {
             // 查询lpHash
             // lpObj容错
             try {
-                EthMev toObj = EthMev.dao.findFirst(findHashSql, 2, dataObj.getString("toAdd"));
+                EthMev toObj = EthMev.dao.findFirst(findHashSql, dataObj.getString("toAdd"));
                 JSONObject toObjDataObj = JSONObject.parseObject(toObj.getStr("data"));
                 ethMev.put("toName", toObjDataObj.getString("name"));
             } catch (Exception ignored) {}
@@ -200,8 +200,9 @@ public class EthMevController extends Controller {
             }
             for (JSONObject tradeInfo : tradeInfoList.toJavaList(JSONObject.class)) {
                 // tokenObj信息处理
+                EthMev tokenObj = null;
                 try {
-                    EthMev tokenObj = EthMev.dao.findFirst(findHashSql, "token", tradeInfo.getString("token"));
+                    tokenObj = EthMev.dao.findFirst(findHashSql, tradeInfo.getString("token"));
 
                     if (tokenObj != null) {
                         JSONObject tokenObjDataObj = JSONObject.parseObject(tokenObj.getStr("data"));
@@ -224,6 +225,7 @@ public class EthMevController extends Controller {
                         tradeInfo.put("amount", realAmount.doubleValue());
                     }
                 } catch (Exception e) {
+                    System.err.println(tokenObj);
                     e.printStackTrace();
                 }