diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/SuperviseWxMessSender.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/SuperviseWxMessSender.java index 3a5c140f..59a4e118 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/SuperviseWxMessSender.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/SuperviseWxMessSender.java @@ -109,7 +109,7 @@ public class SuperviseWxMessSender { data.put("thing2", "设备名"); data.put("time5", reportTime); for(String touser:tousers){ - respMessReturn = WxMessage.sendMessage("A1u0HdEegfdJl3_MndronKahtvwkAa5IFDSy2NRHu8U", touser, pagepath, data); + respMessReturn = WxMessage.sendMessages("A1u0HdEegfdJl3_MndronKahtvwkAa5IFDSy2NRHu8U", touser, pagepath, data); } return respMessReturn; } diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/WxMessage.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/WxMessage.java index 115d2b00..c6a3d22d 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/WxMessage.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/wx/WxMessage.java @@ -27,6 +27,33 @@ public class WxMessage { mp_template_msg.put("template_id", template_id);// 模板Id mp_template_msg.put("url", ""); // 点击模板信息跳转地址 + Map miniprogram = new HashMap<>(); + miniprogram.put("appid", WxConfig.MP_APPID); + miniprogram.put("pagepath", pagepath); + mp_template_msg.put("miniprogram", miniprogram); + + Map sendData = new HashMap<>(); + data.forEach((key, val) -> { + sendData.put(key, new TemplateDataValue(val)); + }); + mp_template_msg.put("data", sendData); + + sendBody.put("mp_template_msg", mp_template_msg); + ResponseEntity forEntity = new RestTemplate().postForEntity(wxUrl, sendBody, RespMessReturn.class); + return forEntity.getBody(); + } + public static RespMessReturn sendMessages(String template_id, String touser, String pagepath, Map data) { + String wxUrl = MP_URL_MESSAGE_SEND.replace("ACCESS_TOKEN", WxConfig.mpAccessToken()); + + Map sendBody = new HashMap<>(); + sendBody.put("touser", touser); + + //拼接base参数 + Map mp_template_msg = new HashMap<>(); + mp_template_msg.put("appid", WxConfig.WX_APPID); + mp_template_msg.put("template_id", template_id);// 模板Id + mp_template_msg.put("url", ""); // 点击模板信息跳转地址 + // Map miniprogram = new HashMap<>(); // miniprogram.put("appid", WxConfig.MP_APPID); // miniprogram.put("pagepath", pagepath); @@ -42,7 +69,6 @@ public class WxMessage { ResponseEntity forEntity = new RestTemplate().postForEntity(wxUrl, sendBody, RespMessReturn.class); return forEntity.getBody(); } - /** * 向多个用户推送同一模板消息 *