Commit 7aeea4f7 by zhangxingmin

push

parent 77e7749c
...@@ -76,19 +76,24 @@ public class MiniprogramMessageSender implements MessageSender { ...@@ -76,19 +76,24 @@ public class MiniprogramMessageSender implements MessageSender {
List<WxMaSubscribeMessage.MsgData> dataList = new ArrayList<>(); List<WxMaSubscribeMessage.MsgData> dataList = new ArrayList<>();
for (Map.Entry<String, Object> entry : contentJson.entrySet()) { for (Map.Entry<String, Object> entry : contentJson.entrySet()) {
String key = entry.getKey(); String key = entry.getKey();
String value = entry.getValue() != null ? entry.getValue().toString() : ""; Object obj = entry.getValue();
String value = "";
if (obj instanceof JSONObject) {
value = ((JSONObject) obj).getString("value");
} else {
value = obj != null ? obj.toString() : "";
}
dataList.add(new WxMaSubscribeMessage.MsgData(key, value)); dataList.add(new WxMaSubscribeMessage.MsgData(key, value));
} }
log.info("进入小程序消息发送器=>构建微信订阅消息数据结构List<MsgData>:{}", JSON.toJSONString(dataList)); log.info("进入小程序消息发送器=>构建微信订阅消息数据结构List<MsgData>:{}", JSON.toJSONString(dataList));
// 5. 构建消息体 // 5. 构建消息体
WxMaSubscribeMessage message = new WxMaSubscribeMessage(); WxMaSubscribeMessage message = WxMaSubscribeMessage.builder()
message.setToUser(task.getReceiver()); .toUser(task.getReceiver())
message.setTemplateId(wxTemplateId); .templateId(wxTemplateId)
message.setData(dataList); // 现在参数类型匹配 .data(dataList)
if (StringUtils.hasText(page)) { .page(page) // 如果 page 为空,builder 也会处理
message.setPage(page); .build();
}
// log.info("进入小程序消息发送器=>构建消息体WxMaSubscribeMessage:{}", JSON.toJSONString(message)); // log.info("进入小程序消息发送器=>构建消息体WxMaSubscribeMessage:{}", JSON.toJSONString(message));
// 6. 调用微信 SDK 发送 // 6. 调用微信 SDK 发送
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment