|
@ -83,7 +83,7 @@ public class NoticeJobPushMsgTask {
|
|
while (true) {
|
|
while (true) {
|
|
// 如果queue为空,则当前线程会堵塞,直到有新数据加入
|
|
// 如果queue为空,则当前线程会堵塞,直到有新数据加入
|
|
JSONObject json = queue.take();
|
|
JSONObject json = queue.take();
|
|
logger.info("发送前:"+json);
|
|
|
|
|
|
//logger.info("发送前:"+json);
|
|
// 推送平台消息
|
|
// 推送平台消息
|
|
String receiver = json.containsKey("receiver") ? json.getString("receiver") : "";
|
|
String receiver = json.containsKey("receiver") ? json.getString("receiver") : "";
|
|
String type = json.containsKey("type") ? json.getString("type") : "";
|
|
String type = json.containsKey("type") ? json.getString("type") : "";
|
|
@ -91,11 +91,11 @@ public class NoticeJobPushMsgTask {
|
|
String msg = json.containsKey("msg") ? json.getString("msg") : "";
|
|
String msg = json.containsKey("msg") ? json.getString("msg") : "";
|
|
String data = json.containsKey("data") ? json.getString("data") : "";
|
|
String data = json.containsKey("data") ? json.getString("data") : "";
|
|
boolean res = pushMessage(receiver, type, title, msg, data);
|
|
boolean res = pushMessage(receiver, type, title, msg, data);
|
|
if (res) {
|
|
|
|
logger.info("消息推送成功!");
|
|
|
|
} else {
|
|
|
|
logger.error("消息推送失败!");
|
|
|
|
}
|
|
|
|
|
|
// if (res) {
|
|
|
|
// logger.info("消息推送成功!");
|
|
|
|
// } else {
|
|
|
|
// logger.error("消息推送失败!");
|
|
|
|
// }
|
|
}
|
|
}
|
|
} catch (Exception ex) {
|
|
} catch (Exception ex) {
|
|
ex.printStackTrace();
|
|
ex.printStackTrace();
|