package com.xiaopeng.pushMessage.utils;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.http.HttpUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.utils.StringUtils;
|
import com.xiaopeng.common.redis.service.RedisService;
|
import com.xiaopeng.pushMessage.model.Category;
|
import com.xiaopeng.pushMessage.model.MessageTemplate;
|
import com.xiaopeng.pushMessage.model.PubTemplateKeywords;
|
import com.xiaopeng.pushMessage.model.PubTemplatetitles;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* 订阅消息
|
*/
|
@Slf4j
|
@Component
|
public class SubscribeMessageUtil {
|
|
@Value("${wx.appletsAppid}")
|
private String wxAppletsAppid;
|
|
@Value("${wx.appletsAppSecret}")
|
private String wxAppletsAppSecret;
|
|
@Autowired
|
private RedisService redisService;
|
|
|
|
/**
|
* 获取微信小程序token
|
* @return
|
*/
|
public String getWxAppletsAccessToken() {
|
String accessToken = redisService.getCacheObject("wxAppletsAccessToken");
|
if(StringUtils.isNotEmpty(accessToken)){
|
return accessToken;
|
}
|
String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + wxAppletsAppid + "&secret=" + wxAppletsAppSecret;
|
HttpRequest get = HttpUtil.createGet(url);
|
HttpResponse execute = get.execute();
|
if(execute.getStatus() != 200){
|
log.info("获取微信小程序access_token失败:{}", execute.body());
|
throw new RuntimeException("获取微信小程序access_token失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
redisService.setCacheObject("wxAppletsAccessToken", jsonObject.getString("access_token"), 7000L, TimeUnit.SECONDS);
|
return jsonObject.getString("access_token");
|
}
|
|
|
/**
|
* 小程序使用jscode获取openid
|
* @param jscode
|
* @return
|
*/
|
public Map<String, Object> code2Session(String jscode) {
|
String url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + wxAppletsAppid + "&secret=" + wxAppletsAppSecret
|
+ "&js_code=" + jscode + "&grant_type=authorization_code";
|
HttpRequest get = HttpUtil.createGet(url);
|
HttpResponse execute = get.execute();
|
if(execute.getStatus() != 200){
|
log.info("小程序使用jscode获取openid失败:{}", execute.body());
|
throw new RuntimeException("小程序使用jscode获取openid失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
int errcode = jsonObject.getIntValue("errcode");
|
Map<String, Object> map = new HashMap<>();
|
if(errcode == 0){//成功
|
map.put("openid", jsonObject.getString("openid"));
|
map.put("sessionKey", jsonObject.getString("session_key"));
|
map.put("unionid", jsonObject.getString("unionid"));
|
return map;
|
}
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
|
|
|
|
/**
|
* 获取消息类目
|
* @return
|
*/
|
public List<Category> getCategory(){
|
String url = "https://api.weixin.qq.com/wxaapi/newtmpl/getcategory?access_token=" + getWxAppletsAccessToken();
|
HttpRequest get = HttpUtil.createGet(url);
|
HttpResponse execute = get.execute();
|
if(execute.getStatus() != 200){
|
log.info("获取消息类目失败:{}", execute.body());
|
throw new RuntimeException("获取消息类目失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("获取消息类目失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
JSONArray data = jsonObject.getJSONArray("data");
|
List<Category> categories = data.toJavaList(Category.class);
|
return categories;
|
}
|
|
|
/**
|
* 获取所属类目下的公共模板
|
* @param ids
|
* @return
|
*/
|
public List<PubTemplatetitles> getPubTemplateTitles(String ids){
|
List<PubTemplatetitles> pubTemplatetitles = new ArrayList<>();
|
Integer start = 0;
|
while (true){
|
String url = "https://api.weixin.qq.com/wxaapi/newtmpl/getpubtemplatetitles?access_token=" + getWxAppletsAccessToken();
|
Map<String, Object> params = new HashMap<>();
|
params.put("ids", ids);
|
params.put("start", start + "");
|
params.put("limit", 30);
|
HttpRequest get = HttpUtil.createGet(url);
|
get.form(params);
|
HttpResponse execute = get.execute();
|
if(execute.getStatus() != 200){
|
log.info("获取公共模板失败:{}", execute.body());
|
throw new RuntimeException("获取公共模板失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("获取公共模板失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
JSONArray data = jsonObject.getJSONArray("data");
|
List<PubTemplatetitles> pubTemplatetitles1 = data.toJavaList(PubTemplatetitles.class);
|
if(pubTemplatetitles1.size() == 0){
|
break;
|
}
|
pubTemplatetitles.addAll(pubTemplatetitles1);
|
start += 30;
|
}
|
return pubTemplatetitles;
|
}
|
|
|
/**
|
* 获取关键词列表
|
* @param tid
|
* @return
|
*/
|
public List<PubTemplateKeywords> getPubTemplateKeywords(String tid){
|
String url = "https://api.weixin.qq.com/wxaapi/newtmpl/getpubtemplatekeywords?access_token=" + getWxAppletsAccessToken();
|
Map<String, Object> params = new HashMap<>();
|
params.put("tid", tid);
|
HttpRequest get = HttpUtil.createGet(url);
|
get.form(params);
|
HttpResponse execute = get.execute();
|
if(execute.getStatus() != 200){
|
log.info("获取关键词列表失败:{}", execute.body());
|
throw new RuntimeException("获取关键词列表失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("获取关键词列表失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
JSONArray data = jsonObject.getJSONArray("data");
|
List<PubTemplateKeywords> pubTemplateKeywords = data.toJavaList(PubTemplateKeywords.class);
|
return pubTemplateKeywords;
|
}
|
|
|
/**
|
* 获取个人模板列表
|
* @return
|
*/
|
public List<MessageTemplate> getMessageTemplateList(){
|
String url = "https://api.weixin.qq.com/wxaapi/newtmpl/gettemplate?access_token=" + getWxAppletsAccessToken();
|
HttpRequest get = HttpUtil.createGet(url);
|
HttpResponse execute = get.execute();
|
if(execute.getStatus() != 200){
|
log.info("获取个人模板列表失败:{}", execute.body());
|
throw new RuntimeException("获取个人模板列表失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("获取个人模板列表失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
JSONArray data = jsonObject.getJSONArray("data");
|
List<MessageTemplate> messageTemplates = data.toJavaList(MessageTemplate.class);
|
return messageTemplates;
|
}
|
|
|
/**
|
* 添加消息模板
|
* @param tid 模板标题 id
|
* @param kidList 开发者自行组合好的模板关键词列表，关键词顺序可以自由搭配（例如 [3,5,4] 或 [4,5,3]），最多支持5个，最少2个关键词组合
|
* @param sceneDesc 服务场景描述，15个字以内
|
* @return
|
*/
|
public String addTemplate(String tid, String[] kidList, String sceneDesc){
|
String url = "https://api.weixin.qq.com/wxaapi/newtmpl/addtemplate?access_token=" + getWxAppletsAccessToken();
|
Map<String, Object> params = new HashMap<>();
|
params.put("tid", tid);
|
params.put("kidList", kidList);
|
params.put("sceneDesc", sceneDesc);
|
HttpRequest post = HttpUtil.createPost(url);
|
post.body(JSON.toJSONString(params));
|
HttpResponse execute = post.execute();
|
if(execute.getStatus() != 200){
|
log.info("添加消息模板失败:{}", execute.body());
|
throw new RuntimeException("添加消息模板失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("添加消息模板失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
String priTmplId = jsonObject.getString("priTmplId");
|
return priTmplId;
|
}
|
|
|
/**
|
* 删除模板
|
* @param priTmplId 模板id
|
* @return
|
*/
|
public R delTemplate(String priTmplId){
|
String url = "https://api.weixin.qq.com/wxaapi/newtmpl/deltemplate?access_token=" + getWxAppletsAccessToken();
|
Map<String, Object> params = new HashMap<>();
|
params.put("priTmplId", priTmplId);
|
HttpRequest post = HttpUtil.createPost(url);
|
post.body(JSON.toJSONString(params));
|
HttpResponse execute = post.execute();
|
if (execute.getStatus() != 200){
|
log.info("删除模板失败:{}", execute.body());
|
throw new RuntimeException("删除模板失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("删除模板失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
return R.ok();
|
}
|
|
|
/**
|
* 发送消息
|
* @param template_id 所需下发的订阅模板id
|
* @param page 点击模板卡片后的跳转页面，仅限本小程序内的页面。支持带参数,（示例index?foo=bar）。该字段不填则模板无跳转
|
* @param touser 接收者（用户）的 openid
|
* @param data 模板内容，格式形如 { "key1": { "value": any }, "key2": { "value": any } }的object
|
* @param miniprogram_state 跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
|
* @param lang 进入小程序查看”的语言类型，支持zh_CN(简体中文)、en_US(英文)、zh_HK(繁体中文)、zh_TW(繁体中文)，默认为zh_CN
|
* @return
|
*/
|
public R send(String template_id, String page, String touser, String data, String miniprogram_state, String lang){
|
String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + getWxAppletsAccessToken();
|
Map<String, Object> params = new HashMap<>();
|
params.put("template_id", template_id);
|
params.put("page", page);
|
params.put("touser", touser);
|
params.put("data", JSON.parseObject(data));
|
params.put("miniprogram_state", miniprogram_state);
|
params.put("lang", lang);
|
HttpRequest post = HttpUtil.createPost(url);
|
post.body(JSON.toJSONString(params));
|
HttpResponse execute = post.execute();
|
if(execute.getStatus() != 200){
|
log.info("发送消息失败:{}", execute.body());
|
throw new RuntimeException("发送消息失败");
|
}
|
JSONObject jsonObject = JSON.parseObject(execute.body());
|
Integer errcode = jsonObject.getInteger("errcode");
|
if(0 != errcode){
|
log.info("发送消息失败:{}", jsonObject.getString("errmsg"));
|
throw new RuntimeException(jsonObject.getString("errmsg"));
|
}
|
return R.ok();
|
}
|
|
|
}
|
