记录一些与小程序相关的内容,例如登录,发送订阅消息等
1. 登录相关
1.1. 获取openid
/**
* code:由小程序生成
* appid:小程序id
* secret:密钥
**/
public String getOpenid(String code) {
String data = "appid=" + appid + "&" +
"secret=" + secret + "&" +
"js_code=" + code + "&" +
"grant_type=" + "authorization_code";
JSONObject jsonObject = JSONObject.parseObject(HttpUtil.get("https://api.weixin.qq.com/sns/jscode2session?" + data));
return jsonObject.getString("openid");
}
1.2. 登录
这块主要是获取openid后,查询是否存在与该openid绑定的账号,有则调用登录,返回登录信息,如果没有,则直接注册新用户
1.3. 获取手机号
手机号登录与openid直接登录相同,我这边写的是,先调用openid登录,如果当前用户未注册,则先不注册,将openid存入redis,返回openidToken,前端调起手机号选择,用户选择手机号后,调用手机号登录,将code与openidToken返回,后端获取手机号就可以获取到用户手机号了,现在可以创建新用户,存入openid与手机号
public String getPhone(String code) {
// 获取token
String appletToken = String.valueOf(getAccessToken());
// 构建参数
Map<String,Object> paramMap = new HashMap<>();
paramMap.put("code",code);
String res = HttpRequest.post("https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=" + appletToken)
.header("Content-Type", "application/json").body(JSONUtils.toJSONString(paramMap)).execute().body();
return JSONObject.parseObject(res).getJSONObject("phone_info").getString("phoneNumber");
}
public String getAccessToken() {
String result;
if (redisUtil.hasKey("AppletToken")) {
return redisUtil.get("AppletToken").toString();
}
try {
String baseUrl = "https://api.weixin.qq.com/cgi-bin/token";
HashMap<String, Object> requestParam = new HashMap<>();
requestParam.put("grant_type", "client_credential");
// 小程序唯一凭证id appid
requestParam.put("appid", appid);
// 小程序 appSecret
requestParam.put("secret", secret);
// 发送GET请求读取调用微信接口获取openid用户唯一标识
result = HttpUtil.get(baseUrl, requestParam);
} catch (Exception e) {
throw new ServiceException(GENERATE_TOKEN_ERROR);
}
String token = JSON.parseObject(result).getString("access_token");
//将token存到redis,有效期100分钟。官方接口返回的token有效期120分钟
redisUtil.set("AppletToken", token, 100 * MyConstants.MINUTER);
return token;
}
2. 发送订阅消息
2.1. 创建参数
public Map<String, Object> createParams(String name,String phone,String time,String reason){
Map<String, Object> objMap = new HashMap<>(5);
Map<String, String> map = new HashMap<>(1);
map.put("value", name);
objMap.put("thing1", map);
map = new HashMap<>(1);
map.put("value", phone);
objMap.put("phone_number7", map);
map = new HashMap<>(1);
map.put("value", time);
objMap.put("time2", map);
map = new HashMap<>(1);
map.put("value", reason);
objMap.put("thing11", map);
return objMap;
}
2.2. 发送订阅消息
public void msgSend(String templateId, String page, Map<String, Object> data,String openId) {
try {
// getAccessToken()在上面有贴过,这里就不贴了,直接调用
String accessToken = getAccessToken();
// region 推送小程序信息
String msgUrl = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + accessToken;
// 请求参数处理
Map<String, Object> params = new HashMap<>(6);
// 目标用户
params.put("touser", openId);
// 这个templateId需要在微信公众号中创建模板,之后使用模板id发送,与短信类似
params.put("template_id", templateId);
// page则为用户收到消息后点击消息跳转的页面,例如/index
params.put("page", page);
params.put("lang", "zh_CN");
params.put("miniprogram_state", "formal");
// 模板参数,2.1调用生成后传入当前方法
params.put("data", data);
String res = HttpRequest.post(msgUrl)
.header("Content-Type", "application/json")
// 这个toJSONString很关键
.body(JSONUtils.toJSONString(params)).execute().body();
JSONObject msgResultObject = JSONObject.parseObject(res);
if (!"0".equals(msgResultObject.get("errcode").toString())) {
throw new RuntimeException("发送订阅消息失败," + msgResultObject.get("errmsg"));
}
} catch (Exception e) {
throw new RuntimeException("发送订阅消息失败," + e);
}
}
标签:map,code,Springboot,程序,token,new,put,相关,String
From: https://www.cnblogs.com/eaglex3/p/18515300