最近公司做小程序需要用到订阅消息推送,笔者在一路采坑做完后几个笔记,希望能帮到大家少走弯路。
如果你连小程序都没有注册也没有做,那就不要继续看了。。。。。。。
微信官方文档?小程序订阅消息 | 微信开放文档?
一、申请模板
在小程序的 公共模板库中如果找不到你需要的模板,可以申请自己的模板,如下图所示
公共模板库 -?一次性订阅 -?翻到最后一页 -?点击忙帮我们完善模板库?
?如图填写好模板的?各个属性即可,属性详细点击问号可以查看。然后提交等待审批即可
?审核通过后?即可在我的模板中查看到信息
?二、小程序获得授权
官方文档:??wx.requestSubscribeMessage(Object object)
wx.requestSubscribeMessage({
tmplIds: ['你的订阅消息模板id'],
success(res) {
console.log(res);
}, fail(res) {
console.log(res);
}
})
这里测试的时候发现,你同意了几次,后面就可以给你发送几次一次性订阅消息
三、后台java代码编写(HTTPS调用)
官方文档:subscribeMessage.send | 微信开放文档
1、获取微信接口调用凭证
因为需要调用微信接口去发送?服务通知,所以这里首先得获取到调用接口里的参数
官方文档:auth.getAccessToken | 微信开放文档
对照上述文档,java?开发获取token,这里的?token?有效期 2小时,为了避免频繁请求微信服务,所以讲该?token?存起来,过期失效后?再重新请求,这里没有用到redis等,就直接用?JWT附上有效时间加密后存到数据库,然后取出来解密查看是否过期,没有过期就继续用,过期了就找微信再要一次?token 。
@GetMapping("/test")
public void test() throws IOException {
// 1、获取 接口调用凭证
String wxApiToken = commonService.getWXApiToken();
// 2、 post
String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + wxApiToken;
HttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost(url);
httpPost.setHeader("Content-Type", "application/json");
httpPost.setHeader("Accept", "application/json");
Map<String, Object> dataMap = new HashMap<>();
dataMap.put("touser", "这里是接收通知用户的小程序下唯一openId");
dataMap.put("template_id", "这里是一次性订阅模板id");
dataMap.put("page", "这里是跳转小程序的页面,可以不填写"); // 小程序跳转界面
dataMap.put("miniprogram_state", "developer"); // 跳转小程序类型
// 按照 模板 拼参数
Map<String, Map<String, String>> ddMap = new HashMap<>();
Map<String, String> ddvMap = new HashMap<>();
ddvMap.put("value", "1");
ddMap.put("thing1", ddvMap);
ddvMap = new HashMap<>();
ddvMap.put("value", "2");
ddMap.put("thing2", ddvMap);
ddvMap = new HashMap<>();
ddvMap.put("value", "2022年5月25日 11:25");
ddMap.put("time3", ddvMap);
ddvMap = new HashMap<>();
ddvMap.put("value", "落3");
ddMap.put("short_thing4", ddvMap);
dataMap.put("data", ddMap);
String content = JSONObject.toJSON(dataMap).toString();
StringEntity stringEntity = new StringEntity(content,"UTF-8");
httpPost.setEntity(stringEntity);
HttpResponse response = httpClient.execute(httpPost);
HttpEntity entity = response.getEntity();
String strEntity = EntityUtils.toString(entity, "UTF-8");
JSONObject jsonObject = JSON.parseObject(strEntity);
}
public String getWXApiToken() throws IOException {
// 1、从数据库取 微信凭证
// TODO 这里换成自己的 DAO
String wxApiToken = baseMapper.getWXData(WX_API_TOKEN);
// 2、如果是 空,获取 微信凭证 并保存到数据库
if (StringUtils.isEmpty(wxApiToken)) {
return createWXApiToken();
}
// 3、检查 token 是否过期
Claims claimByToken = jwtUtils.getClaimByToken(wxApiToken);
Date expiration = claimByToken.getExpiration();
if (jwtUtils.isTokenExpired(expiration)) {
return createWXApiToken();
}
// 4、返回 未过期的 数据库中存储的 微信接口调用凭证
return claimByToken.getSubject();
}
private String createWXApiToken() throws IOException {
// GET https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET
String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + MNWXConfig.appid + "&secret=" + MNWXConfig.secret;
HttpClient httpClient = HttpClients.createDefault();
HttpGet httpGet = new HttpGet(url);
HttpResponse response = httpClient.execute(httpGet);
HttpEntity entity = response.getEntity();
String strEntity = EntityUtils.toString(entity, "UTF-8");
JSONObject jsonObject = JSON.parseObject(strEntity);
if (!"null".equals(String.valueOf(jsonObject.get("errcode"))) &&
!String.valueOf(jsonObject.get("errcode")).equals("0")) {
return null;
} else {
// 凭证有效时间,单位:秒。目前是7200秒之内的值
String expiresIn = String.valueOf(jsonObject.get("expires_in"));
// 接口调用凭证
String accessToken = String.valueOf(jsonObject.get("access_token"));
// 加密后 存入 数据库
Date nowDate = new Date();
Date expireDate = new Date(nowDate.getTime() + Integer.parseInt(expiresIn) * 1000);
String encryptToken = jwtUtils.generateToken(accessToken, expireDate);
// TODO 这里换成自己的 DAO
baseMapper.updateWXData(WX_API_TOKEN, encryptToken);
return accessToken;
}
}
public String generateToken(String target, Date expireDate) {
String secret = "替换成你自己的加密秘钥";
return Jwts.builder().setHeaderParam("type", "JWT").setSubject(target).setIssuedAt(expireDate)
.setExpiration(expireDate).signWith(SignatureAlgorithm.HS512, secret).compact();
}
public boolean isTokenExpired(Date expiration) {
return expiration.before(new Date());
}
public Claims getClaimByToken(String token) {
String secret = "替换成你自己的加密秘钥"
try {
return Jwts.parser().setSigningKey(secret).parseClaimsJws(token).getBody();
} catch (Exception e) {
logger.debug("validate is token error ", e);
return null;
}
}
?对应错误码参考官方文档,如果一切顺利,那么对应?openId?的手机微信就会受到服务消息
|