推送时间修改

src/main/java/com/zhiwei/searchhotcrawler/run/HotSearchRun.java

@@ -16,7 +16,7 @@ public class HotSearchRun {
 	private ScheduledExecutorService scheduExec;
 
     public HotSearchRun() {
-        this.scheduExec = Executors.newScheduledThreadPool(1);
+        this.scheduExec = Executors.newScheduledThreadPool(4);
     }     
 
     public void showTimer() {

src/main/java/com/zhiwei/searchhotcrawler/timer/SendWeiboHotSearchRun.java

@@ -20,19 +20,21 @@ public class SendWeiboHotSearchRun extends Thread{
 	
 	@Override
 	public void run() {
-		List<DBObject> list = weiboHotSearchDAO.getWeiboHotOneHour();
 		Calendar calendar = Calendar.getInstance();
-		if(list!=null && list.size()>0){
-			for(DBObject weibo : list){
-				String title = weibo.get("name").toString();
-				String time = TimeParse.dateFormartString((Date)weibo.get("time"), "yyyy-MM-dd HH:mm:ss");
-				String url = weibo.get("url").toString();
-				if(calendar.get(Calendar.HOUR_OF_DAY) > 6 && calendar.get(Calendar.HOUR_OF_DAY) < 23){
+		int hour = calendar.get(Calendar.HOUR_OF_DAY);
+		System.out.println("微博推送,当前系统时间为：" + hour);
+		if(hour > 6 && hour < 23){
+			List<DBObject> list = weiboHotSearchDAO.getWeiboHotOneHour();
+			if(list!=null && list.size()>0){
+				for(DBObject weibo : list){
+					String title = weibo.get("name").toString();
+					String time = TimeParse.dateFormartString((Date)weibo.get("time"), "yyyy-MM-dd HH:mm:ss");
+					String url = weibo.get("url").toString();
 					sendTemplateByUserIds(title, time, url);
 				}
+			}else{
+				sendTemplateByUserIds("最近一小时无数据", TimeParse.dateFormartString(new Date(), "yyyy-MM-dd HH:mm:ss"), null);
 			}
-		}else{
-			sendTemplateByUserIds("最近一小时无数据", TimeParse.dateFormartString(new Date(), "yyyy-MM-dd HH:mm:ss"), null);
 		}
 	}
 	

src/main/java/com/zhiwei/searchhotcrawler/timer/SendZhihuHotSearchRun.java

@@ -19,19 +19,23 @@ public class SendZhihuHotSearchRun extends Thread{
 	private ZhihuHotSearchDAO zhihuHotSearchDAO = new ZhihuHotSearchDAO();
 	@Override
 	public void run() {
-		List<DBObject> list = zhihuHotSearchDAO.getZhiHuHotSearch();
 		Calendar calendar = Calendar.getInstance();
-		if(list!=null && list.size()>0){
-			for(DBObject zhihu : list){
-				String title = zhihu.get("display_query").toString();
-				String time = TimeParse.dateFormartString((Date)zhihu.get("time"), "yyyy-MM-dd HH:mm:ss");
-				String url = zhihu.get("_id").toString();
-				if(calendar.get(Calendar.HOUR_OF_DAY) > 6 && calendar.get(Calendar.HOUR_OF_DAY) < 23){
-					sendTemplateByUserIds(title, time, url);
+		int hour = calendar.get(Calendar.HOUR_OF_DAY);
+		System.out.println("知乎推送,当前系统时间为："+hour);
+		if(hour > 6 && hour <23){
+			List<DBObject> list = zhihuHotSearchDAO.getZhiHuHotSearch();
+			if(list!=null && list.size()>0){
+				for(DBObject zhihu : list){
+					String title = zhihu.get("display_query").toString();
+					String time = TimeParse.dateFormartString((Date)zhihu.get("time"), "yyyy-MM-dd HH:mm:ss");
+					String url = zhihu.get("_id").toString();
+					if(calendar.get(Calendar.HOUR_OF_DAY) > 6 && calendar.get(Calendar.HOUR_OF_DAY) < 23){
+						sendTemplateByUserIds(title, time, url);
+					}
 				}
+			}else{
+				sendTemplateByUserIds("最近一小时无数据", TimeParse.dateFormartString(new Date(), "yyyy-MM-dd HH:mm:ss"), null);
 			}
-		}else{
-			sendTemplateByUserIds("最近一小时无数据", TimeParse.dateFormartString(new Date(), "yyyy-MM-dd HH:mm:ss"), null);
 		}
 	}