package com.ruoyi.common.utils;
|
|
import lombok.extern.slf4j.Slf4j;
|
import me.chanjar.weixin.common.exception.WxErrorException;
|
import me.chanjar.weixin.mp.api.WxMpInMemoryConfigStorage;
|
import me.chanjar.weixin.mp.api.WxMpService;
|
import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
|
import me.chanjar.weixin.mp.bean.kefu.WxMpKefuMessage;
|
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
|
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;
|
|
import java.util.Map;
|
|
/**
|
* 微信公众号消息发送工具类
|
* 支持：文本客服消息、模板消息
|
*/
|
@Slf4j
|
public class WxMpUtils {
|
|
private final WxMpService wxMpService;
|
|
/**
|
* 构造方法，通过 appId 和 appSecret 初始化微信公众号服务
|
*
|
* @param appId 微信公众号 AppID
|
* @param appSecret 微信公众号 AppSecret
|
*/
|
public WxMpUtils(String appId, String appSecret) {
|
WxMpInMemoryConfigStorage configStorage = new WxMpInMemoryConfigStorage();
|
configStorage.setAppId(appId);
|
configStorage.setSecret(appSecret);
|
wxMpService = new WxMpServiceImpl();
|
wxMpService.setWxMpConfigStorage(configStorage);
|
}
|
|
// -------------------------------------------------------------------------
|
// 文本客服消息
|
// -------------------------------------------------------------------------
|
|
/**
|
* 向指定 openid 的用户发送文本客服消息
|
* 注意：用户需在48小时内与公众号有过交互才可发送
|
*
|
* @param openid 用户的微信 openid
|
* @param content 消息内容
|
* @return 发送成功返回 true，失败返回 false
|
*/
|
public boolean sendTextMessage(String openid, String content) {
|
if (StringUtils.isEmpty(openid)) {
|
log.warn("【WxMpUtils】sendTextMessage 失败：openid 为空");
|
return false;
|
}
|
if (StringUtils.isEmpty(content)) {
|
log.warn("【WxMpUtils】sendTextMessage 失败：content 为空");
|
return false;
|
}
|
try {
|
WxMpKefuMessage message = WxMpKefuMessage.TEXT()
|
.toUser(openid)
|
.content(content)
|
.build();
|
boolean result = wxMpService.getKefuService().sendKefuMessage(message);
|
log.info("【WxMpUtils】文本客服消息发送{}，openid：{}", result ? "成功" : "失败", openid);
|
return result;
|
} catch (WxErrorException e) {
|
log.error("【WxMpUtils】文本客服消息发送异常，openid：{}，错误：{}", openid, e.getError(), e);
|
return false;
|
}
|
}
|
|
// -------------------------------------------------------------------------
|
// 模板消息
|
// -------------------------------------------------------------------------
|
|
/**
|
* 向指定 openid 的用户发送模板消息（含跳转URL）
|
*
|
* @param openid 用户的微信 openid
|
* @param templateId 模板消息 ID（在微信公众平台配置）
|
* @param url 点击消息后的跳转 URL，不需要跳转可传 null
|
* @param dataMap 模板数据，key 为模板字段名，value 为 WxMpTemplateData（含值和颜色）
|
* 示例：{"first": new WxMpTemplateData("first", "你好", "#173177"), ...}
|
* @return 发送成功返回微信返回的 msgid，失败返回 null
|
*/
|
public String sendTemplateMessage(String openid, String templateId, String url,
|
Map<String, WxMpTemplateData> dataMap) {
|
if (StringUtils.isEmpty(openid)) {
|
log.warn("【WxMpUtils】sendTemplateMessage 失败：openid 为空");
|
return null;
|
}
|
if (StringUtils.isEmpty(templateId)) {
|
log.warn("【WxMpUtils】sendTemplateMessage 失败：templateId 为空");
|
return null;
|
}
|
try {
|
WxMpTemplateMessage templateMessage = new WxMpTemplateMessage();
|
templateMessage.setToUser(openid);
|
templateMessage.setTemplateId(templateId);
|
if (StringUtils.isNotEmpty(url)) {
|
templateMessage.setUrl(url);
|
}
|
if (dataMap != null) {
|
for (WxMpTemplateData data : dataMap.values()) {
|
templateMessage.addData(data);
|
}
|
}
|
String msgId = wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
|
log.info("【WxMpUtils】模板消息发送成功，openid：{}，msgId：{}", openid, msgId);
|
return msgId;
|
} catch (WxErrorException e) {
|
log.error("【WxMpUtils】模板消息发送异常，openid：{}，templateId：{}，错误：{}",
|
openid, templateId, e.getError(), e);
|
return null;
|
}
|
}
|
|
/**
|
* 向指定 openid 的用户发送模板消息（简化版，value 不设置颜色）
|
*
|
* @param openid 用户的微信 openid
|
* @param templateId 模板消息 ID
|
* @param url 点击消息后的跳转 URL，不需要跳转可传 null
|
* @param dataMap 模板数据，key 为模板字段名，value 为字段显示的文本内容
|
* 示例：{"first": "你好", "keyword1": "2024-01-01", "remark": "感谢使用"}
|
* @return 发送成功返回微信返回的 msgid，失败返回 null
|
*/
|
public String sendTemplateMessage(String openid, String templateId, String url,
|
Map<String, String> dataMap, String defaultColor) {
|
if (StringUtils.isEmpty(openid)) {
|
log.warn("【WxMpUtils】sendTemplateMessage 失败：openid 为空");
|
return null;
|
}
|
if (StringUtils.isEmpty(templateId)) {
|
log.warn("【WxMpUtils】sendTemplateMessage 失败：templateId 为空");
|
return null;
|
}
|
try {
|
WxMpTemplateMessage templateMessage = new WxMpTemplateMessage();
|
templateMessage.setToUser(openid);
|
templateMessage.setTemplateId(templateId);
|
if (StringUtils.isNotEmpty(url)) {
|
templateMessage.setUrl(url);
|
}
|
if (dataMap != null) {
|
String color = StringUtils.isEmpty(defaultColor) ? "#173177" : defaultColor;
|
for (Map.Entry<String, String> entry : dataMap.entrySet()) {
|
templateMessage.addData(new WxMpTemplateData(entry.getKey(), entry.getValue(), color));
|
}
|
}
|
String msgId = wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
|
log.info("【WxMpUtils】模板消息发送成功，openid：{}，msgId：{}", openid, msgId);
|
return msgId;
|
} catch (WxErrorException e) {
|
log.error("【WxMpUtils】模板消息发送异常，openid：{}，templateId：{}，错误：{}",
|
openid, templateId, e.getError(), e);
|
return null;
|
}
|
}
|
|
// -------------------------------------------------------------------------
|
// 静态工厂方法（快速构造）
|
// -------------------------------------------------------------------------
|
|
/**
|
* 快速创建 WxMpUtils 实例
|
*
|
* @param appId 微信公众号 AppID
|
* @param appSecret 微信公众号 AppSecret
|
* @return WxMpUtils 实例
|
*/
|
public static WxMpUtils of(String appId, String appSecret) {
|
return new WxMpUtils(appId, appSecret);
|
}
|
}
|
