微信公众号推送小程序模板消息的实现
准备:
微信小程序认证
微信公众号认证
微信开发平台认证(绑定微信小程序和公众号(unionid))
unionid：同一用户，对同一个微信开放平台下的不同应用，unionid是相同的
思路:
1. 获取小程序信息(用户openid小程序用户唯一ID)
将小程序与公众号绑定（绑定后才可获取unionid）
/**
* 小程序用户登录授权
*/
@GetMapping("/getUserOpenId")
public AjaxResult getUserOpenId(String code){
if (StringUtils.isEmpty(code)){
return AjaxResult.error("请输入code");
}
Map<String, Object> result = new LinkedHashMap();
String oAuth = WxAppletUserInfo.getOAuth(code, userAppId, userSecret);
JSONObject jsonObject = JSONObject.fromObject(oAuth);
//获取openId和sessionKey
String openid = jsonObject.get("openid").toString();
String session_key = jsonObject.get("session_key").toString();
String unionid= jsonObject.get("unionid").toString();
......
}
获取小程序信息:WxAppletUserInfo
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.codec.binary.Base64;
import org.slf4j.LoggerFactory;
/**
* @description: 获取小程序信息
**/
public class WxAppletUserInfo {
private static final org.slf4j.Logger log = LoggerFactory.getLogger(WxAppUserInfo.class);
//获取小程序登录信息
private final static String GET_CODE_SESSION_URL="https://api.weixin.qq.com/sns/jscode2session";
// 算法名
public static final String KEY_NAME = "AES";
// 加解密算法/模式/填充方式
// ECB模式只用密钥即可对数据进行加密解密，CBC模式需要添加一个iv
public static final String CIPHER_ALGORITHM = "AES/CBC/PKCS7Padding";
/**
* @Title: getOAuth
* @Description: 获取小程序用户登陆信息
* @param @param code
* @throws
*/
public static String getOAuth(String code,String appId,String secret) {
StringBuffer url = new StringBuffer(GET_CODE_SESSION_URL);
url.append("?appid="+appId).append("&secret="+secret)
.append("&js_code="+code)
.append("&grant_type=authorization_code");
return HttpUtils.get(url.toString());
}
}
2.获取公众号的openid(公众号用户唯一ID)
@GetMapping("/getCode")
public AjaxResult getCode(String code){
if (null == code || code.trim().equals("")){
return AjaxResult.error("code为空");
}
//根据code获取token
String accessTokenCode = WxAppUserInfo.getAccessTokenCode(code, wxAppId, wxAppSecret, wxAuthLoginUrl);
//获取openid
JSONObject jsonObject = JSONObject.fromObject(accessTokenCode);
//获取openid和session_key
String openid = jsonObject.get("openid").toString();
String accessToken = jsonObject.get("access_token").toString();
//获取用户信息
String wxUserInfo = WxAppUserInfo.getWxUserInfo(accessToken, openid);
String userInfo = HttpUtils.get(wxUserInfo);
JSONObject fromObject = JSONObject.fromObject(userInfo);
String openId = fromObject.getString("openid");
String nickName = fromObject.getString("nickname");
String sex = fromObject.getString("sex");
String province = fromObject.getString("province");
String city = fromObject.getString("city");
String country = fromObject.getString("country");
String headImgUrl = fromObject.getString("headimgurl");
String privilege = fromObject.getString("privilege");
String unionId = fromObject.getString("unionid");
.....
}
获取公众号信息
import net.sf.json.JSONObject;
import org.slf4j.LoggerFactory;
/**
* @description: 获取微信公众号信息
**/
public class WxAppUserInfo {
private static final org.slf4j.Logger log = LoggerFactory.getLogger(WxAppUserInfo.class);
/**
* 获取模板消息所需要的access_token(获取微信公众号的access_token(7200秒有效))
* @param urlToken
* @param appId
* @param appSecret
* @return
*/
public static String getAccessToken(String urlToken,String appId,String appSecret) {
StringBuffer url = new StringBuffer(urlToken);
url.append("?appid="+appId)
.append("&secret="+appSecret)
.append("&grant_type=client_credential");
String token = HttpUtils.get(url.toString());
log.info("获取模板消息所的认证参数access_token:{}",token);
JSONObject Json = JSONObject.fromObject(token);
String access_token = String.valueOf(Json.get("access_token").toString());
return access_token;
}
/**
* 根据code获取到网页授权access_token
* @param code
* @return 微信回调后带有的参数code值
*/
public static String getAccessTokenCode(String code,String wxAuthLoginUrl,String appId,String appSecret) {
StringBuffer url = new StringBuffer(wxAuthLoginUrl);
url.append("?appid="+appId)
.append("&secret="+appSecret)
.append("&code="+code)
.append("&grant_type=authorization_code");
log.info("根据code获取到网页授权access_token:{}",url.toString());
return HttpUtils.get(url.toString());
}
/**
* 获取微信用户
* @param accessToken
* @param openId
* @return
*/
public static String getWxUserInfo(String accessToken,String openId) {
StringBuffer url = new StringBuffer();
url.append("?access_token="+accessToken)
.append("&openid="+openId);
log.info("根据access_token和openId获取微信用户信息:{}",url.toString());
return HttpUtils.get(url.toString());
}
}
3.推送消息服务
公众号模板申请:一个月只能有三次,审核7-15个工作日
//1.获取access_token
https请求方式: GET
urlToken = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET'
String TemplateId = "";
//2.模板消息类
//openid 是用户公众号的openid
public static JSONObject packJsonDoctorMsg(String openid,String AppId,String pagePath){
//医生发送公众号模板消息
WechatTemplate wechatTemplate = new WechatTemplate();
wechatTemplate.setTouser(openid);
wechatTemplate.setTemplate_id(TemplateId);
MiniprogramData miniprogramData = new MiniprogramData();
miniprogramData.setAppid(AppId);
miniprogramData.setPagepath(pagePath);//所需跳转到小程序的具体页面路径，支持带参数,（示例index?foo=bar），要求该小程序已发布，暂不支持小游戏
wechatTemplate.setMiniprogram(miniprogramData);
Map<String,TemplateData> dataMap = new HashMap<>();
TemplateData title = new TemplateData();
title.setValue("所发送消息内容");
title.setColor("#000000");
dataMap.put("title",title);
TemplateData first = new TemplateData();
first.setValue("所发送消息内容";
first.setColor("#000000");
dataMap.put("first",first);
TemplateData keyword = new TemplateData();
keyword.setValue("所发送消息内容");
keyword.setColor("#000000");
dataMap.put("keyword",keyword);
TemplateData keyword = new TemplateData();
keyword.setValue("所发送消息内容");
keyword.setColor("#000000");
dataMap.put("keyword", keyword);
TemplateData keyword = new TemplateData();
keyword.setValue("所发送消息内容");
keyword.setColor("#000000");
dataMap.put("keyword", keyword);
TemplateData keyword = new TemplateData();
keyword.setValue("所发送消息内容");
keyword.setColor("#000000");
dataMap.put("keyword", keyword);
TemplateData remark = new TemplateData();
remark.setValue("所发送消息内容");
remark.setColor("#000000");
dataMap.put("remark", remark);
wechatTemplate.setData(dataMap);
JSONObject json = JSONObject.fromObject(wechatTemplate);
return json;
}
//3.用户发送模板消息
JSONObject userMsgDate = MessageModel.packJsonUserMsg(openid, AppId, userPagePath);
JSONObject jsonobjUser = HttpUtils.httpRequest(send+WxAppUserInfo.getAccessToken(urlToken,appId,appSecret),"POST",userMsgDate.toString());
over~