Commit c545511e by 马黎滨

话题采集预警恢复

parent 31c6cb65
...@@ -49,7 +49,7 @@ public class SougoHotSearchRun extends Thread { ...@@ -49,7 +49,7 @@ public class SougoHotSearchRun extends Thread {
}else { }else {
List<Document> data = hotSearchCacheDAO.addData(list); List<Document> data = hotSearchCacheDAO.addData(list);
hotSearchDAO.addHotSearchList(data); hotSearchDAO.addHotSearchList(data);
TipsUtils.sendTips("搜狗微信热搜",new Date()); TipsUtils.recoveryTips("搜狗微信热搜",new Date());
} }
log.info("搜狗微信采集结束........"); log.info("搜狗微信采集结束........");
} }
......
...@@ -45,7 +45,7 @@ public class ToutiaoHotSearchRun extends Thread{ ...@@ -45,7 +45,7 @@ public class ToutiaoHotSearchRun extends Thread{
}else { }else {
List<Document> data = hotSearchCacheDAO.addData(list); List<Document> data = hotSearchCacheDAO.addData(list);
hotSearchDAO.addHotSearchList(data); hotSearchDAO.addHotSearchList(data);
TipsUtils.sendTips("今日头条热搜",new Date()); TipsUtils.recoveryTips("今日头条热搜",new Date());
} }
log.info("今日头条热搜采集结束........"); log.info("今日头条热搜采集结束........");
} }
......
...@@ -43,7 +43,7 @@ public class WeiboHotSearchRun extends Thread{ ...@@ -43,7 +43,7 @@ public class WeiboHotSearchRun extends Thread{
}else { }else {
List<Document> data = hotSearchCacheDAO.addData(list); List<Document> data = hotSearchCacheDAO.addData(list);
hotSearchDAO.addHotSearchList(data); hotSearchDAO.addHotSearchList(data);
TipsUtils.sendTips("微博热搜",new Date()); TipsUtils.recoveryTips("微博热搜",new Date());
} }
} }
......
...@@ -41,7 +41,7 @@ public class WeiboTopicRun extends Thread{ ...@@ -41,7 +41,7 @@ public class WeiboTopicRun extends Thread{
if(list == null || list.size() == 0){ if(list == null || list.size() == 0){
TipsUtils.sendTips("微博话题",new Date()); TipsUtils.sendTips("微博话题",new Date());
}else{ }else{
TipsUtils.sendTips("微博话题",new Date()); TipsUtils.recoveryTips("微博话题",new Date());
} }
List<Document> data = new ArrayList<>(); List<Document> data = new ArrayList<>();
for(HotSearchList topic : list){ for(HotSearchList topic : list){
......
...@@ -47,7 +47,7 @@ public class ZhihuChildHotSearchRun extends Thread { ...@@ -47,7 +47,7 @@ public class ZhihuChildHotSearchRun extends Thread {
}else { }else {
List<Document> data = hotSearchCacheDAO.addData(list); List<Document> data = hotSearchCacheDAO.addData(list);
hotSearchDAO.addHotSearchList(data); hotSearchDAO.addHotSearchList(data);
TipsUtils.sendTips("知乎热搜"+name+"分类",new Date()); TipsUtils.recoveryTips("知乎热搜"+name+"分类",new Date());
} }
log.info("知乎{}话题热榜采集结束...", name); log.info("知乎{}话题热榜采集结束...", name);
ZhiWeiTools.sleep(3000); ZhiWeiTools.sleep(3000);
......
...@@ -50,7 +50,7 @@ public class ZhihuHotSearchRun extends Thread{ ...@@ -50,7 +50,7 @@ public class ZhihuHotSearchRun extends Thread{
}else { }else {
List<Document> data = hotSearchCacheDAO.addData(list); List<Document> data = hotSearchCacheDAO.addData(list);
hotSearchDAO.addHotSearchList(data); hotSearchDAO.addHotSearchList(data);
TipsUtils.sendTips("知乎热搜",new Date()); TipsUtils.recoveryTips("知乎热搜",new Date());
} }
log.info("知乎话题采集结束........"); log.info("知乎话题采集结束........");
} }
......
...@@ -42,7 +42,7 @@ public class ZhihuTopSearchRun extends Thread { ...@@ -42,7 +42,7 @@ public class ZhihuTopSearchRun extends Thread {
}else { }else {
List<Document> data = hotSearchCacheDAO.addData(list); List<Document> data = hotSearchCacheDAO.addData(list);
hotSearchDAO.addHotSearchList(data); hotSearchDAO.addHotSearchList(data);
TipsUtils.sendTips("知乎热搜榜单",new Date()); TipsUtils.recoveryTips("知乎热搜榜单",new Date());
} }
log.info("知乎热搜话题采集结束........"); log.info("知乎热搜话题采集结束........");
} }
......
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