微信小程序WebView跳转wxJS实现签名

2023-04-07

微信小程序的WebView网页，传参或跳转到微信小程序的原生页面，需要后端实现签名。

配置类

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 微信小程序配置信息
 * @date 2023/3/14 2:40 PM
 */
@Configuration
@Data
public class WeJsConfig {

    @Value("${auth.weixin.app-id}")
    private String appId;

    @Value("${auth.weixin.secret}")
    private String secret;

    private String tokenUrl = "https://api.weixin.qq.com/cgi-bin/token";

    private String suffix = "&grant_type=client_credential";

    private String appidPrefix = "?appid=";

    private String secretPrefix = "&secret=";
}

AccessToken类

import com.alibaba.fastjson.JSON;
import com.my.memory.base.http.HttpClientHelper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 获取微信的AccessToken
 * @date 2023/4/4 1:58 PM
 */
@Component
@Slf4j
public class JsAccessToken {

    /** 注入微信小程序配置 */
    private WeJsConfig weJsConfig;

    @Autowired
    public JsAccessToken(WeJsConfig weJsConfig) {
        this.weJsConfig = weJsConfig;
    }

    ///    /** 注入Redis */
    //    private RedisHelper redisHelper;
    //
    //    @Autowired
    //    public void setRedisHelper(RedisHelper redisHelper) {
    //        this.redisHelper = redisHelper;
    //    }

    public String getAccessToken() {

        // 拼接URL
        String url =
                weJsConfig.getTokenUrl()
                        + weJsConfig.getAppidPrefix()
                        + weJsConfig.getAppId()
                        + weJsConfig.getSecretPrefix()
                        + weJsConfig.getSecret()
                        + weJsConfig.getSuffix();
        // 执行请求
        String result = HttpClientHelper.doGet(url);
        // 判断请求是否成功
        if (StringUtils.isBlank(result)) {
            log.error("获取AccessToken失败");

            return null;
        }

        // 解析结果
        // 从结果获取AccessToken
        String accessToken = JSON.parseObject(result).getString("access_token");
        if (StringUtils.isBlank(accessToken)) {
            log.error("获取AccessToken失败");

            return null;
        }

        return accessToken;
    }

    //    // 构造函数之后执行函数
    //    @PostConstruct
    //    public void init() {
    //
    //        // 获取AccessToken
    //        String accessToken = getAccessToken();
    //
    //        // 判断AccessToken是否为空
    //        if (StringUtils.isBlank(accessToken)) {
    //            log.error("获取AccessToken失败");
    //
    //            return;
    //        }
    //
    //        // 将AccessToken存入Redis
    //        redisHelper.set("weXinAccessToken", accessToken, 7000L);
    //    }
    //
    //    // 开启轮询器
    //    // 定时更新AccessToken到Redis
    //    // 保证最新的AccessToken在Redis
    //    // 执行间隔：110分钟
    //    @Scheduled(fixedDelay = 110 * 60 * 1000)
    //    public void start() {
    //
    //        // 获取AccessToken
    //        String accessToken = getAccessToken();
    //
    //        // 判断AccessToken是否为空
    //        if (StringUtils.isBlank(accessToken)) {
    //            log.error("获取AccessToken失败");
    //
    //            return;
    //        }
    //
    //        // 将AccessToken存入Redis
    //        redisHelper.set("weXinAccessToken", accessToken, 7000L);
    //    }
}

Ticket类

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.my.memory.base.http.HttpClientHelper;
import com.my.memory.base.redis.helper.RedisHelper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 获取调用JS的票据
 * @date 2023/4/4 2:27 PM
 */
@Component
@Slf4j
public class JjApiTicket {

    /** 注入获取access_token组件 */
    @Autowired private JsAccessToken jsAccessToken;

    @Autowired
    public JjApiTicket(JsAccessToken jsAccessToken) {
        this.jsAccessToken = jsAccessToken;
    }

    /** 注入Redis */
    private RedisHelper redisHelper;

    @Autowired
    public void setRedisHelper(RedisHelper redisHelper) {
        this.redisHelper = redisHelper;
    }

    @PostConstruct
    public void init() {
        // 获取调用JS的票据
        getTicket();
    }

    // 开启轮询器
    // 执行间隔：100分钟
    @Scheduled(fixedDelay = 100 * 60 * 1000)
    public void start() {
        // 获取调用JS的票据
        getTicket();
    }

    public void getTicket() {

        log.debug("获取调用JS的票据");

        // 1.获取access_token
        String accessTokenString = jsAccessToken.getAccessToken();
        if (StringUtils.isBlank(accessTokenString)) {
            log.error("获取调用JS的accessToken失败");

            return;
        }

        // 2.拼接URL
        String url =
                "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token="
                        + accessTokenString
                        + "&type=jsapi";

        // 3.执行请求
        String result = HttpClientHelper.doGet(url);
        // 4.判断请求是否成功
        if (StringUtils.isBlank(result)) {
            log.error("获取调用JS的票据失败");

            return;
        }

        // 5.解析结果
        JSONObject jsonObject = JSON.parseObject(result);
        // 判断状态码
        if (jsonObject.getInteger("errcode") != 0) {
            log.error("获取调用JS的票据失败");

            return;
        }

        // 6.从结果获取ticket
        String ticket = jsonObject.getString("ticket");
        if (StringUtils.isBlank(ticket)) {
            log.error("获取调用JS的票据失败");

            return;
        }

        // 存储ticket到Redis，有效时间110min
        redisHelper.set("WeXinJsApiTicket", ticket, 110 * 60 * 1000L);
    }
}

Dao类

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 曳戈泰尔
 * @date 2023/4/4 3:07 PM
 */
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class JsApiDto {

    private String appId;

    private String timestamp;

    private String nonceStr;

    private String signature;

    private String url;
}

Signature类

package com.my.memory.base.webView.weixin;

import com.my.memory.base.redis.helper.RedisHelper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.UUID;

/**
 * @author 曳戈泰尔
 * @version 1.0
 * @description 签名类
 * @date 2023/4/4 2:54 PM
 */
@Component
@Slf4j
public class JsSignature {

    /** 注入微信小程序配置 */
    private WeJsConfig weJsConfig;

    @Autowired
    public JsSignature(WeJsConfig weJsConfig) {
        this.weJsConfig = weJsConfig;
    }

    /** 注入Redis */
    private RedisHelper redisHelper;

    @Autowired
    public void setRedisHelper(RedisHelper redisHelper) {
        this.redisHelper = redisHelper;
    }

    /**
     * 获取签名值
     *
     * @param url
     * @return
     */
    public JsApiDto getSignature(String url) {

        String appId = weJsConfig.getAppId();

        // 获取nonceStr
        String nonceStr = UUID.randomUUID().toString();

        // 获取timestamp
        String timestamp = Long.toString(System.currentTimeMillis() / 1000);

        // 获取jspai_ticket
        String jsApiTicket = redisHelper.get("WeXinJsApiTicket");
        if (StringUtils.isBlank(jsApiTicket)) {
            log.error("获取jsapi_ticket失败");

            return null;
        }

        // 4个键值添加到List
        List<String> list =
                Arrays.asList(
                        "jsapi_ticket=" + jsApiTicket,
                        "noncestr=" + nonceStr,
                        "timestamp=" + timestamp,
                        "url=" + url);
        // 数组进行字典排序
        Collections.sort(list);

        // 将四个数据进行组合，传给SHA1进行加密
        StringBuilder waitSignature = new StringBuilder();
        String sep = "";
        for (String s : list) {
            waitSignature.append(sep).append(s);
            sep = "&";
        }

        // sha1加密
        String signature = SHA1(waitSignature.toString());
        if (StringUtils.isBlank(signature)) {
            log.error("签名失败");

            return null;
        }

        return JsApiDto.builder()
                .appId(appId)
                .nonceStr(nonceStr)
                .timestamp(timestamp)
                .signature(signature)
                .url(url)
                .build();
    }

    public String SHA1(String str) {
        try {
            MessageDigest digest = java.security.MessageDigest.getInstance("SHA-1");
            digest.update(str.getBytes());
            byte[] messageDigest = digest.digest();

            // Create Hex String
            StringBuilder hexStr = new StringBuilder();

            // 字节数组转换为 十六进制 数
            for (byte b : messageDigest) {
                String shaHex = Integer.toHexString(b & 0xFF);
                if (shaHex.length() < 2) {
                    hexStr.append(0);
                }
                hexStr.append(shaHex);
            }

            return hexStr.toString();

        } catch (NoSuchAlgorithmException e) {
            log.error("签名失败，原因r：{}", e.getMessage());
        }

        return null;
    }
}