package com.moral.monitor.listener.message;
|
|
import org.json.JSONException;
|
import org.json.JSONObject;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import javax.net.ssl.HttpsURLConnection;
|
import java.io.BufferedReader;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.net.ConnectException;
|
import java.net.URL;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
|
import static com.moral.monitor.listener.quartz.GetAccessToken.access_token;
|
|
/**
|
* Created by a on 2017/3/13.
|
*/
|
public class WeChat implements Runnable {
|
private Logger logger = LoggerFactory.getLogger(WeChat.class);
|
private int level;
|
private String zu;
|
private String wx;
|
private Long time;
|
private String mac;
|
public void run() {
|
long ssatime = new Date().getTime();
|
String result = sendWechatmsgToUser(level, zu, wx, mac, time);
|
long esatime = new Date().getTime();
|
logger.warn(" 微信报警耗时 " + (esatime - ssatime) + "==========" + Thread.currentThread().getName() + "=========");
|
if (!"success".equals(result)) {
|
logger.warn("微信发送失败" + result);
|
}
|
}
|
|
public static JSONObject packJsonmsg(Integer level, String zu, String time) {
|
String lev = null;
|
String col = null;
|
if (level == 3) {
|
lev = "三级";
|
col = "#fd416e";
|
} else if (level == 2) {
|
lev = "二级";
|
col = "#fe926f";
|
} else if (level == 1) {
|
lev = "一级";
|
col = "#fdf24a";
|
}
|
JSONObject json = new JSONObject();
|
// 标题
|
JSONObject first = new JSONObject();
|
first.put("value", "七星瓢虫坏境监控智能报警");
|
first.put("color", "#000000");
|
json.put("first", first);
|
// 报警来源
|
JSONObject keyword1 = new JSONObject();
|
keyword1.put("value", "江苏省昆山市摩瑞尔电器有限公司");
|
keyword1.put("color", "#000000");
|
json.put("keyword1", keyword1);
|
// 报警内容
|
JSONObject keyword2 = new JSONObject();
|
keyword2.put("value", "环境数（工业级）监测到异常数据");
|
keyword2.put("color", "#000000");
|
json.put("keyword2", keyword2);
|
// 报警组别
|
JSONObject keyword3 = new JSONObject();
|
keyword3.put("value", zu + "指数超标");
|
keyword3.put("color", "#000000");
|
json.put("keyword3", keyword3);
|
// 报警等级
|
JSONObject keyword4 = new JSONObject();
|
keyword4.put("value", lev);
|
keyword4.put("color", col);
|
json.put("keyword4", keyword4);
|
// 报警时间
|
JSONObject keyword5 = new JSONObject();
|
keyword5.put("value", time);
|
keyword5.put("color", "#000000");
|
json.put("keyword5", keyword5);
|
// 提示语
|
JSONObject remark = new JSONObject();
|
remark.put("value", "情况紧急，请马上处理（点击查看详情）");
|
remark.put("color", "#000000");
|
json.put("remark", remark);
|
return json;
|
}
|
|
//微信： 等级，传感中文名，联系人，报警信息
|
public static String sendWechatmsgToUser(int level, String zu, String wx, String mac, Long time) {
|
String url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + access_token;
|
//处理时间,准备mac 地址，做为微信公从号推送内容的参数
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
String times = sdf.format(new Date());
|
//获取 要发送的 json 对象 .报警组，报警数据，日期
|
JSONObject data = packJsonmsg(level, zu, times);
|
// 微信详情页 时间，mac, 等级
|
String clickurl = "http://101.37.22.173:8080/task/detail.do?time=" + time + "&mac=" + mac + "&level=" + level;
|
String topcolor = "#FF0000";
|
String templat_id = "j8E0d-GgKljSCpuTlCoYdWS6kquaSE1AnvmklE5MoO0";
|
JSONObject json = new JSONObject();
|
try {
|
json.put("touser", wx);
|
json.put("template_id", templat_id);
|
json.put("url", clickurl);
|
json.put("topcolor", topcolor);
|
json.put("data", data);
|
} catch (JSONException e) {
|
e.printStackTrace();
|
}
|
String result = httpsRequest(url, "POST", json.toString());
|
try {
|
JSONObject resultJson = new JSONObject(result);
|
String errmsg = (String) resultJson.get("errmsg");
|
if (!"ok".equals(errmsg)) { //如果为errmsg为ok，则代表发送成功，公众号推送信息给用户了。
|
return errmsg;
|
}
|
} catch (JSONException e) {
|
e.printStackTrace();
|
}
|
return "success";
|
}
|
|
|
public static String httpsRequest(String requestUrl, String requestMethod, String outputStr) {
|
try {
|
URL url = new URL(requestUrl);
|
HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
|
conn.setDoOutput(true);
|
conn.setDoInput(true);
|
conn.setUseCaches(false);
|
// 设置请求方式（GET/POST）
|
conn.setRequestMethod(requestMethod);
|
conn.setRequestProperty("content-type", "application/x-www-form-urlencoded");
|
// 当outputStr不为null时向输出流写数据
|
if (null != outputStr) {
|
OutputStream outputStream = conn.getOutputStream();
|
// 注意编码格式
|
outputStream.write(outputStr.getBytes("UTF-8"));
|
outputStream.close();
|
}
|
// 从输入流读取返回内容
|
InputStream inputStream = conn.getInputStream();
|
InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "utf-8");
|
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
|
String str = null;
|
StringBuffer buffer = new StringBuffer();
|
while ((str = bufferedReader.readLine()) != null) {
|
buffer.append(str);
|
}
|
// 释放资源
|
bufferedReader.close();
|
inputStreamReader.close();
|
inputStream.close();
|
inputStream = null;
|
conn.disconnect();
|
return buffer.toString();
|
} catch (ConnectException ce) {
|
System.out.println("连接超时：{}");
|
} catch (Exception e) {
|
System.out.println("https请求异常：{}");
|
}
|
return null;
|
}
|
|
public WeChat(int level, String zu, String wx, String mac, long time) {
|
this.level = level;
|
this.zu = zu;
|
this.wx = wx;
|
this.mac = mac;
|
this.time = time;
|
}
|
}
|
