Commit 477778db by chenweitao

Merge branch 'working' into 'master'

增加TaoBaoUtil判断条件

See merge request !119
parents df3b2479 69c6ace5
...@@ -19,8 +19,8 @@ public class HotSearchRunTest { ...@@ -19,8 +19,8 @@ public class HotSearchRunTest {
//微博热搜开始采集 //微博热搜开始采集
// new WeiboHotSearchRun().start(); // new WeiboHotSearchRun().start();
//快手热榜开始采集 //快手热榜开始采集
// new KuaiShouHotSearchRun().start(); //new KuaiShouHotSearchRun().start();
//百度热搜 //百度热搜
new BaiduHotSearchRun().run(); //new BaiduHotSearchRun().run();
} }
} }
...@@ -7,6 +7,7 @@ import javax.script.Invocable; ...@@ -7,6 +7,7 @@ import javax.script.Invocable;
import javax.script.ScriptEngine; import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager; import javax.script.ScriptEngineManager;
import java.io.*; import java.io.*;
import java.util.Objects;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Log4j2 @Log4j2
...@@ -26,6 +27,12 @@ public class TaoBaoUtils { ...@@ -26,6 +27,12 @@ public class TaoBaoUtils {
//InputStream inputStream = aesJs.getInputStream(); //InputStream inputStream = aesJs.getInputStream();
InputStreamReader inputStreamReader = new InputStreamReader(in); InputStreamReader inputStreamReader = new InputStreamReader(in);
BufferedReader bufferedReader = new BufferedReader(inputStreamReader); BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
if (Objects.isNull(engine)){
log.info("engine为空");
}
if(Objects.isNull(bufferedReader)){
log.info("bufferedReader为空");
}
engine.eval(bufferedReader); engine.eval(bufferedReader);
} finally { } finally {
in.close(); in.close();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment