微信公众号模板消息通知:若依框架集成实战

package com.ruoyi.web.controller.wx;import com.alibaba.fastjson2.JSONObject;import com.ruoyi.common.core.redis.RedisCache;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.web.bind.annotation.*;import org.springframework.web.client.RestTemplate;import java.security.MessageDigest;import java.util.*;import java.util.concurrent.TimeUnit;@RestController@RequestMapping("/wx")public class WxController {    @Value("${wx.appId}")    private String appId;    @Value("${wx.appSecret}")    private String appSecret;    @Value("${wx.templateId}")    private String templateId;    // 服务器配置里的 Token，必须和公众号后台填的完全一致    @Value("${wx.token}")    private String token;    @Autowired    private RedisCache redisCache;    private final RestTemplate restTemplate = new RestTemplate();    /**     * 微信服务器配置验证接口     * 微信提交配置时会发 GET 请求过来     * 校验通过必须原样返回 echostr     */    @GetMapping("/check")    public String check(@RequestParam("signature") String signature,                        @RequestParam("timestamp") String timestamp,                        @RequestParam("nonce") String nonce,                        @RequestParam("echostr") String echostr) {        // 1. 将 token、timestamp、nonce 三个参数进行字典序排序        String[] arr = {token, timestamp, nonce};        Arrays.sort(arr);        // 2. 将三个参数字符串拼接成一个字符串进行 sha1 加密        StringBuilder sb = new StringBuilder();        for (String s : arr) {            sb.append(s);        }        String sha1 = sha1(sb.toString());        // 3. 开发者获得加密后的字符串可与 signature 对比，标识该请求来源于微信        if (sha1 != null && sha1.equals(signature)) {            return echostr;        }        return "error";    }    /**     * SHA1 加密工具方法     */    private String sha1(String str) {        try {            MessageDigest md = MessageDigest.getInstance("SHA-1");            byte[] digest = md.digest(str.getBytes("UTF-8"));            StringBuilder hex = new StringBuilder();            for (byte b : digest) {                String s = Integer.toHexString(b & 0xFF);                if (s.length() == 1) {                    hex.append("0");                }                hex.append(s);            }            return hex.toString();        } catch (Exception e) {            e.printStackTrace();            return null;        }    }    /**     * 获取 access_token     * 微信规定这个 token 有效期 7200 秒，且全局唯一     * 每次发消息都重新获取会被限流，必须缓存     */    private String getAccessToken() {        String cacheKey = "wx:access_token";        // 先看 Redis 里有没有        String token = redisCache.getCacheObject(cacheKey);        if (token != null) {            return token;        }        // 没有就请求微信        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential"                + "&appid=" + appId + "&secret=" + appSecret;        JSONObject result = restTemplate.getForObject(url, JSONObject.class);        token = result.getString("access_token");        // 缓存 7000 秒，比微信给的 7200 秒少 200 秒，提前刷新        redisCache.setCacheObject(cacheKey, token, 7000, TimeUnit.SECONDS);        return token;    }    /**     * 发送模板消息     * 访问方式：GET /wx/send?openid=xxx     */    @GetMapping("/send")    public String send(@RequestParamString openid) {        String accessToken = getAccessToken();        String url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken;        // 组装 data        // 微信要求的格式：{"key": {"value": "实际内容"}}        // key 必须和模板里 {{xxx.DATA}} 的 xxx 完全一致        Map<String, Object> data = new HashMap<>();        data.put("orderNo", Collections.singletonMap("value", "20240923001"));        data.put("amount", Collections.singletonMap("value", "99.00"));        data.put("remark", Collections.singletonMap("value", "感谢购买"));        // 组装请求体        Map<String, Object> body = new HashMap<>();        body.put("touser", openid);          // 收件人 OpenID        body.put("template_id", templateId); // 模板 ID        body.put("data", data);              // 填充内容        // 发送请求        JSONObject result = restTemplate.postForObject(url, body, JSONObject.class);        return result.toJSONString();    }}

.antMatchers("/wx/check", "/wx/send").permitAll()

<template>  <view>    <button @tap="handleOrder">下单</button>  </view></template><script>export default {  methods: {    handleOrder() {      // 必须在用户点击时调，自动触发会被微信拦截      uni.requestSubscribeMessage({        tmplIds: ['你的模板ID'],        success: (res) => {          // res 的 key 是模板ID，值是授权状态          // accept = 同意，reject = 拒绝，ban = 已被封禁          if (res['你的模板ID'] === 'accept') {            console.log('用户同意订阅');            // 这里可以调后端接口，把 openid 和订阅状态存起来          }        },        fail: (err) => {          console.error('订阅失败', err);        }      });      this.submitOrder();    },    submitOrder() {      // 你的下单逻辑    }  }}</script>