提交微信数据推送问题

pom.xml

@@ -2,7 +2,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.zhiwei</groupId>
   <artifactId>searchhotcrawler</artifactId>
-  <version>0.0.4-SNAPSHOT</version>
+  <version>0.0.6-SNAPSHOT</version>
   <name>各平台热搜榜单采集程序</name>
   <description>各平台热搜榜单采集程序
 目前包含：1.微博时时热搜采集程序、2.知乎热搜采集程序</description>

src/main/java/com/zhiwei/searchhotcrawler/mail/SendMailWeibo.java

@@ -27,7 +27,7 @@ public class SendMailWeibo  {
 		 String subject = "微博实时热搜榜采集程序"; 
 		 String content = mailContent;
 		
-	      MailInfo mailInfo = new MailInfo(mailServerHost, mailServerPort, fromAddress, toAddress, userName, password, validate, subject, content,null);    
+	      MailInfo mailInfo = new MailInfo(mailServerHost, mailServerPort, fromAddress, toAddress, userName, password, validate, subject, content, null, null);    
 	      
 	     boolean f=false;
 		 //这个类主要来发送邮件   

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

@@ -70,6 +70,7 @@ public class SendWeiboHotSearchRun extends Thread{
 		dataMap.put("remark", remark);
 		
 		List<String> userList = getUserList();
+		if(userList!=null && userList.size()>0) {
 			for (String openId : userList) {
 				Template template = new Template();
 				template.setTouser(openId);
@@ -83,6 +84,7 @@ public class SendWeiboHotSearchRun extends Thread{
 				WechatCodeUtil.sendDataJson(templateJson);
 			}
 		}
+	}
 	
 	/**
 	 * @Title: getUserList 

src/main/java/com/zhiwei/searchhotcrawler/util/WechatCodeUtil.java

@@ -33,13 +33,15 @@ public class WechatCodeUtil {
 			String result = HttpClientTemplateOK.get(path, null, headerMap);
 			if (result != null) {
 				JSONObject jsonObject = JSONObject.parseObject(result);
+				if(jsonObject.containsKey("data")) {
 					JSONObject inJson = JSONObject.parseObject(jsonObject.getString("data"));
 					token = inJson.getString("accessToken");
 				}
+			}
 		} catch (IOException e) {
 			logger.error("获取微信公众号推送token失败,问题为:::{}", e.fillInStackTrace());
+			return null;
 		}
-
 		return token;
 	}
 
@@ -62,6 +64,7 @@ public class WechatCodeUtil {
 				if ("ok".equals(jsonObject.getString("errmsg"))) {
 					msgid = jsonObject.getIntValue("msgid");
 				}else {
+					msgid = 0;
 					logger.info("消息推送失败,错误为::{}",jsonObject.toString());
 				}
 			}
@@ -91,8 +94,10 @@ public class WechatCodeUtil {
 		try {
 			JSONObject jsonObject = HttpRequest.httpRequest(url, "GET", postData.toString());
 			if (null != jsonObject) {
+				if(jsonObject.containsKey("data")) {
 					return (List<String>) jsonObject.getJSONObject("data").getObject("openid", List.class);
 				}
+			}
 		} catch (Exception e) {
 			e.printStackTrace();
 			return null;
@@ -118,6 +123,7 @@ public class WechatCodeUtil {
 		try {
 			String htmlBody = HttpClientTemplateOK.get(url, null, headerMap);
 			if (htmlBody != null) {
+				if(htmlBody.contains("tags")) {
 					JSONArray jsonArry = JSONObject.parseObject(htmlBody).getJSONArray("tags");
 					for (int i = 0; i < jsonArry.size(); i++) {
 						JSONObject data = jsonArry.getJSONObject(i);
@@ -129,6 +135,7 @@ public class WechatCodeUtil {
 						}
 					}
 				}
+			}
 		} catch (IOException e) {
 			logger.error("获取分组id时出现错误",e.fillInStackTrace());
 			return null;