package com.ruoyi.system.utils.util;
|
|
|
import com.ruoyi.common.constant.Constants;
|
import com.ruoyi.common.core.redis.RedisCache;
|
import com.ruoyi.common.core.utils.HttpUtils;
|
import com.ruoyi.common.redis.service.RedisService;
|
import com.ruoyi.system.utils.wx.model.WeixinProperties;
|
import com.ruoyi.system.utils.wx.template.Template;
|
import com.ruoyi.system.utils.wx.template.wxTemplateAppLiveResult.WxOfficeTemplateAppLiveResultRequest;
|
import com.ruoyi.system.utils.wx.template.wxTemplateAppLiveResult.WxOfficeTemplateAppLiveResultRequestData;
|
import com.ruoyi.system.utils.wx.template.wxTemplateAppLiveResult.WxTemplateAppLiveResultRequest;
|
import com.ruoyi.system.utils.wx.template.wxTemplateAppLiveResult.WxTemplateAppLiveResultRequestData;
|
import com.ruoyi.system.utils.wx.tools.WxAppletTools;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.client.RestTemplate;
|
|
import javax.annotation.Resource;
|
import java.io.Serializable;
|
|
/**
|
* 消息模板发送
|
*/
|
@Slf4j
|
@Component
|
public class TemplateMessageSendUtil implements Serializable {
|
private final static String ACCESS_TOKEN_CACHE_KEY = "accessToken:";
|
@Autowired
|
private RedisCache redisCache;
|
@Autowired
|
private RestTemplate wxRestTemplate;
|
@Autowired
|
private WeixinProperties weixinProperties;
|
@Resource
|
private RedisService redisService;
|
|
/**
|
* 直播开始小程序订阅通知
|
* @param openId 用户openId
|
* @param liveTitle 标题
|
* @param startTime 开始时间
|
*/
|
public String wxTemplateAppLiveResultRequest(String openId,String liveTitle,String startTime) {
|
WxAppletTools appletTools = new WxAppletTools(wxRestTemplate, weixinProperties, redisService);
|
// 1,获取access_token
|
String accessToken = redisCache.getCacheObject(ACCESS_TOKEN_CACHE_KEY);
|
if (!StringUtils.hasLength(accessToken)) {
|
accessToken = appletTools.getAccessToken();
|
}
|
try {
|
log.info("直播开始提醒通知：------------------------");
|
// 创建请求实体
|
WxTemplateAppLiveResultRequest wxTemplateAppLiveResultRequest = new WxTemplateAppLiveResultRequest();
|
wxTemplateAppLiveResultRequest.setTouser(openId);
|
wxTemplateAppLiveResultRequest.setTemplate_id(weixinProperties.getAppLiveResultTemplateId());
|
// 标题
|
Template thing1 = new Template();
|
thing1.setValue(liveTitle);
|
// 开始时间
|
Template time2 = new Template();
|
time2.setValue(startTime);
|
// 发送模板消息参数实体封装
|
WxTemplateAppLiveResultRequestData wxTemplateAppLiveResultRequestData = new WxTemplateAppLiveResultRequestData();
|
wxTemplateAppLiveResultRequestData.setThing1(thing1);
|
wxTemplateAppLiveResultRequestData.setTime2(time2);
|
wxTemplateAppLiveResultRequest.setData(wxTemplateAppLiveResultRequestData);
|
// 4,发送消息给用户
|
String url = Constants.TEMPLATE_URL.replace("ACCESS_TOKEN", accessToken);
|
String result = HttpUtils.sendPost(url, JsonUtils.toJsonString(wxTemplateAppLiveResultRequest));
|
log.info("直播开始通知模板消息返回数据:{}", result);
|
return result;
|
} catch (Exception e) {
|
log.error("直播开始通知失败;");
|
}
|
return null;
|
}
|
|
|
/**
|
* 微信公众号模板消息发送
|
* @param openId 用户openId
|
* @param liveTitle 标题
|
* @param startTime 开始时间
|
*/
|
public String wxOfficeTemplateAppLiveRequest(String openId,String liveTitle,String startTime) {
|
WxAppletTools appletTools = new WxAppletTools(wxRestTemplate, weixinProperties, redisService);
|
// 1,获取access_token
|
String accessToken = redisCache.getCacheObject(ACCESS_TOKEN_CACHE_KEY);
|
if (!StringUtils.hasLength(accessToken)) {
|
accessToken = appletTools.getAccessToken();
|
}
|
try {
|
log.info("模板消息发送提醒通知：------------------------");
|
// 创建请求实体
|
WxOfficeTemplateAppLiveResultRequest wxOfficeTemplateAppLiveResultRequest = new WxOfficeTemplateAppLiveResultRequest();
|
wxOfficeTemplateAppLiveResultRequest.setTouser(openId);
|
wxOfficeTemplateAppLiveResultRequest.setTemplate_id(weixinProperties.getOfficeAppLiveResultTemplateId());
|
// 标题
|
Template thing1 = new Template();
|
thing1.setValue(liveTitle);
|
// 开始时间
|
Template time18 = new Template();
|
time18.setValue(startTime);
|
// 发送模板消息参数实体封装
|
WxOfficeTemplateAppLiveResultRequestData wxOfficeTemplateAppLiveResultRequestData = new WxOfficeTemplateAppLiveResultRequestData();
|
wxOfficeTemplateAppLiveResultRequestData.setThing1(thing1);
|
wxOfficeTemplateAppLiveResultRequestData.setTime18(time18);
|
wxOfficeTemplateAppLiveResultRequest.setData(wxOfficeTemplateAppLiveResultRequestData);
|
// 4,发送消息给用户
|
String url = Constants.OFFICIAL_ACCOUNT_TEMPLATE_URL.replace("ACCESS_TOKEN", accessToken);
|
String result = HttpUtils.sendPost(url, JsonUtils.toJsonString(wxOfficeTemplateAppLiveResultRequest));
|
log.info("模板消息发送通知模板消息返回数据:{}", result);
|
return result;
|
} catch (Exception e) {
|
log.error("模板消息发送通知失败;");
|
}
|
return null;
|
}
|
|
|
}
|
