JiahengHe 1 rok pred
rodič
commit
78d6f13560

+ 8 - 0
price_collection/src/main/java/com/liangjiang/price_collection/service/impl/TableServiceImpl.java

@@ -33,6 +33,10 @@ public class TableServiceImpl implements ITableService {
 
         for (String tableName : tableNames){
             String[] infos = tableName.split("_");
+            if(infos.length != 3){
+//                System.out.println("exchange = " + tableName);
+                continue;
+            }
             // 交易所和类型
             exchanges.add(String.format("%s_%s", infos[1], infos[2]));
         }
@@ -54,6 +58,10 @@ public class TableServiceImpl implements ITableService {
         }
         for (String tableName : tableNames){
             String[] infos = tableName.split("_");
+            if(infos.length != 3){
+//                System.out.println("exchange = " + tableName);
+                continue;
+            }
             // 交易所和类型
             String key = String.format("%s_%s", infos[1], infos[2]);
             if (exchange_coin.containsKey(key)){