从零玩转系列之腾讯云微信扫码授权系统

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-configuration-processor</artifactId>
  <optional>true</optional>
</dependency>
<dependency>
  <groupId>org.projectlombok</groupId>
  <artifactId>lombok</artifactId>
  <optional>true</optional>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
</dependency>


<dependency>
  <groupId>org.apache.commons</groupId>
  <artifactId>commons-lang3</artifactId>
  <version>3.12.0</version>
</dependency>


<dependency>
  <groupId>cn.hutool</groupId>
  <artifactId>hutool-all</artifactId>
  <version>5.8.21</version>
</dependency>

/**
     * 获取访问令牌
     */
@Test
public void getAccessTokenTest() {
    getAccessToken();
}

public String getAccessToken() {
    String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={}&secret={}";
    String body = HttpUtil.get(StrUtil.format(url, appId, secret));
    JSONObject object = JSONUtil.parseObj(body);
    return object.getStr("access_token");
}

    /**
     * 创建二维码
     */
    @Test
    public void createQrCode() {
        // 组装请求参数
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + getAccessToken();
        JSONObject jsonParam = new JSONObject();
        // 封装请求对象
        // scene值 - 最大32字符 雪花算法够了
        jsonParam.set("scene", IdUtil.getSnowflakeNextIdStr());
        // 跳往的小程序页面，一般为认证界面
        jsonParam.set("page", "/page/auth/index");
        // 图片宽度，默认为 430
        jsonParam.set("width", "430");
        // 检测页面是否存在，默认为 true
        jsonParam.set("check_path", false);
    }

public String remoteQRCode(String url, JSONObject jsonParam)

byte[] responseBytes;
try (cn.hutool.http.HttpResponse response = HttpUtil.createPost(url)
        .body(jsonParam.toString())
        .header("Content-Type", "application/json")
        .execute()) {

if (!response.isOk()) {
    log.error("[remoteQRCode] 请求失败，状态码: {}", response.getStatus());
    throw new RuntimeException("暂未支持小程序扫码登录！");
}

responseBytes = response.bodyBytes();

String responseStr = new String(responseBytes, StandardCharsets.UTF_8);
if (JSONUtil.isTypeJSON(responseStr)) {
    log.error("[remoteQRCode] 微信接口返回错误: {}", responseStr);
    throw new RuntimeException("暂未支持小程序扫码登录！");
}

Files.write(Paths.get("output.png"), responseBytes);

return Base64.encode(responseBytes);

} catch (Exception e) {
    log.error("获取小程序二维码异常", e);
    throw new RuntimeException("暂未支持小程序扫码登录！");
}

    /**
     * 创建二维码
     */
    @Test
    public void createQrCode() {
        // 组装请求参数
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + getAccessToken();
        JSONObject jsonParam = new JSONObject();
        // 封装请求对象
        // scene值 - 最大32字符 雪花算法够了
        jsonParam.set("scene", IdUtil.getSnowflakeNextIdStr());
        // 跳往的小程序页面，一般为认证界面
        jsonParam.set("page", "page/auth/index");
        // 图片宽度，默认为 430
        jsonParam.set("width", "430");
        // 检测页面是否存在，默认为 true
        jsonParam.set("check_path", false);
        // 构建发起请求
        String remotedQRCode = remoteQRCode(url, jsonParam);
        System.out.println(remotedQRCode);
    }
    
    
    /**
     * 发送post请求
     *
     * @param url       请求地址
     * @param jsonParam 请求参数
     * @return 响应流
     */
    public String remoteQRCode(String url, JSONObject jsonParam) {
        try {
            // 发送POST请求
            byte[] responseBytes;
            try (cn.hutool.http.HttpResponse response = HttpUtil.createPost(url)
                    .body(jsonParam.toString())
                    .header("Content-Type", "application/json")
                    .execute()) {
                
                // 检查响应状态
                if (!response.isOk()) {
                    log.error("[remoteQRCode] 请求失败，状态码: {}", response.getStatus());
                    throw new RuntimeException("暂未支持小程序扫码登录！");
                }
                
                responseBytes = response.bodyBytes();
            }
            
            // 尝试解析为JSON，判断是否为错误响应
            String responseStr = new String(responseBytes, StandardCharsets.UTF_8);
            if (JSONUtil.isTypeJSON(responseStr)) {
                log.error("[remoteQRCode] 微信接口返回错误: {}", responseStr);
                throw new RuntimeException("暂未支持小程序扫码登录！");
            }
            
            // 保存图片到文件中以确认图片是否损坏
            Files.write(Paths.get("output.png"), responseBytes);
            return Base64.encode(responseBytes);
        } catch (Exception e) {
            log.error("获取小程序二维码异常", e);
            throw new RuntimeException("暂未支持小程序扫码登录！");
        }
    }

/*
* 提示：该行代码过长，系统自动注释不进行高亮。一键复制会移除系统注释 
* data:image/png;base64,/9j/4AAQSkZJRgABAQAAAQABAAD/2wBDAAEBAQEBAQEBA6ahYzrbzjCzxBZVADYr+7v/g0h8O6tQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQH/2wBDAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQEBAQH/wAARCAGuAa4DASIAAhEBAxEB/8QAHwAAAQUBAQEBAQEAAAAAAAAAAAECAwQFBgcICQoL/8QAtRAAAgEDAwIEAwUFBAQAAAF9AQIDAAQRBRIhMUEGE1FhByJxFDKBkaEII0KxwRVS0fAkM2JyggkKFhcYGRolJicoKSo0NTY3ODk6Q0RFRkdISUpTVFVWV1hZWmNkZWZnaGlqc3R1dnd4eXqDhIWGh4iJipKTlJWWl5iZmqKjpKWmp6ipqrKztLW2t7i5usLDxMXGx8jJytLT1NXW19jZ2uHi4+Tl5ufo6erx8vP09fb3+Pn6/8QAHwEAAwEBAQEBAQEBAQAAAAAAAAECAwQFBgcICQoL/8QAtREAAgECBAQDBAcFBAQAAQJ3AAECAxEEBSExBhJBUQdhcRMiMoEIFEKRobHBCSMzUvAVYnLRChYkNOEl8RcYGRomJygpKjU2Nzg5OkNERUZHSElKU1RVVldYWVpjZGVmZ2hpanN0dXZ3eHl6goOEhYaHiImKkpOUlZaXmJmaoqOkpaanqKmqsrO0tba3uLm6wsPExcbHyMnK0tPU1dbX2Nna4uPk5ebn6Onq8vP09fb3+Pn6/9oADAMBAAIRAxEAPwD+/iiiigAooooAKKKKACiiigAooooAKKKKACiiigAooooAKKKKACiiigAooooAKKKKACiiigBrukas8jKiKCWd2CqoHUsxIAA7kkCnV/ni/wDB5T+3F+0L4L/aP/Z4/ZL+G/xK8dfDf4ZWvwVb4ueLLHwT4u1nw1H458SeLPGPiDw7py+Ik0SewmvrTw1p/g1/7Ntby5urVZ9YvJ1gilyz/rb/AMGhX7ZPxu/ai/YR+MPgb44eNfFHxI1P9nn40WvhTwh4z8Z+IL/xJ4jl8GeLfCdjr1h4bu9T1V7jUbi18N39rqSaZJdX1y0djqENjEsEFjErgH9ZtFFFABRRRQAUUV5vbfGP4R3nj26+Fdp8Ufh3dfE2ytlvLz4d2/jTw5N44tbVw7LcXHhWPUm1yGIojPvksVAjHmHCEMQD0iiiigAooooAKKKKACiiigAooooAKKKKACiiigAooooAKKKKACiiigAooooAKKKKACiiigAooooAKKKKACiiigAooooAKKK/ND/grX/wUa8O/wDBLT9i3xz+1ZrPgqT4j6xpeueGfBfgbwIuqnQ7fxJ4y8XXzWumwalq6Wl/Lp+k6faW+oatqM0NnPPJb2BtYBHNcpNGAfpfXy5+2j+138Jv2Ef2Zfit+1V8bp9Vj+Hfwm0OHVtVs9AtoL3xBrd9qGo2ei6H4fb1nUbHTrJLm8tbZJJ/NuJ4oY5HH83v/BE//g6B0z/gpJ+0PH+yf+0V81UNV8F+M7jRrefVbvwVqNn4iVNT0rxQujQXF3pNzb3l/Z679hurf7Lpt0IEuv2M/4Lcfslav8Atsf8EwP2svgX4Xhv7vxvc/D2Xx74B0/TnUXGr+NPhle23jrQtCEbqy3A16fQ20ZYCYzJLfRbZYmVXUA+E/8AglX/AMHL/wCyT/wU9+PF3+zXZfDXx/8As/8AxZ1Sz1nVfhrpnjzVvD+vaR8SLLRUlvr3S9K1TQ2iksPFdrokNxrU2jXVi9pJY2GoyWuqzPbLFN/SLX+E3+yJ+0R4u/Y8/ao+BX7SXhON08T/AAN+KnhbxwlhK81t9vg0HVoW1zQbsxgTxQaxpP8AaOjXgUeYsN5KApYYr/cm+FXxH8M/GL4Y/Dz4s+C76HU/CPxM8E+F/Hnhm/t5Y54bvQ/Fmi2WuaZMksTNG+6zvotxRiA24Z4oA76ivkD9q79vz9jX9hyw8Nah+1j+0R8N/ggvjK4e38K2PjDWGj1rXxDNFBd3el6Dp8F9rV1punyTRjUdUjsDp1hvUXV1EzIre/8Aws+K3w1+N/gDwz8VPg/468L/ABK+HHjPT11Xwt418G6xZ694c12wMkkDT6fqdhLNbzeTcQzW1zFuE1rdQzWtzHFcQyRqAegUUUUAFFFFAH+YJ/wejf8AKTX4Lf8AZoHgn/1Z/wAWK/X/AP4Mhv8Ak1j9uD/s4D4ef+q6mr4A/wCD039mj4sD9q39m79p7TfCuua38KfEXwJHwqu/EOkaNf32neG/GHgzxt4l159O17ULaOa30+XW9M8aWlxo63X2dbz7BqCW7zyW8yRfr1/wZr/s3fFP4NfsF/HP4n/EfwzrHhPS/j78c7LW/h9puv6Te6Pqep+F/BfhCy0KXxPFb3yQzS6NrGq3t5baTdCFI7pdKuLmB5raaCVgD+wGiiigAooooA+Jv+CkH7TDfsdfsIftWftK215DY6z8J/gr411/wpNOI3Q+N59Ll0nwREIpQyzNL4r1HR0ERjm3AnMEwBib/G1/ZE+IPx68Z/t//s7/ABB8HeL/ABLqf7QXjX9p74aatp3iw6hdSa/rHjjxN8R9Ilmur26jlSa4XUr68lF/bhhFPazTWwj8phHX+ht/weQ/tQp8Jv8AgnL4D/Z30y88rxB+1D8ZNHs7+3iu4I5j4E+FMcXjTXHltDMLme1m8Sv4Nti6W8lvHI482eCb7Ok/8jn/AAa1/sxS/tG/8Fe/gfrd5ZQ3fhf9nTRPFvx/8R/aGj8tLjwvp66D4PCxyE+dKPG3ibw/crGIpcR2krnygnnxAH+uZF5iwx/aGjMyxJ57R5WIyBB5jJu5Ee7cV3chcZ5r+Tn9o7/g7z/YN+AX7WGt/s7af8LPi18VPAvgnxXceC/Hvx28HXnhiLw5Ya3Y3kdjq83hbw3qV5DqnijSNCuhd22o3st3ok81zZzpp9ndRok037Lf8Fif2yof2DP+CcX7T/7RdtcW0Pi3RfAV34Q+GsNzcG3N38SviDInhDwgICjLNLJp2oar/bskUGZTa6TcuTHFHJLH/jYfs6/BTx1+1V+0V8JPgR4Ktb3W/Hfxv+JvhrwTpqwp591Jf+Ktbgtr7VJ8kDydPt57vVr+Z2WOK1tbieVlRGYAH+7L4W8TaH418MeHfGPhnUIdV8N+LNC0nxL4f1S3JMGo6Lrthb6npd9CSAfKu7G6gnjyAdsgyAcit6vO/hH8OtJ+D3wp+Gvwo0Ka4n0T4ZeAvCXgLSrm9lE13Pp3hHQbDQbS4upgkSyTzW9gksziONWkZiI0GFH8W/8AwUD/AODwuL9mz9snxn8CP2bv2c/BHxw+D3wg8YXHgzx18R9f8ca5ouqeOda0SQ2Pi6DwDHpulzabpOn6NrCXul6drOpR69b6zLpzX0MEen3UJIB/cZRXiv7OHxy8K/tM/AH4NftC+CIrq38JfGn4z1mLT7AhvNPN01ldFQFM8EhUAEAe1UAFFFFABRRRQAUUUUAFFFFABRRRQAUUUUAFFFFABRRRQAUUUUAFFFFABRRRQAUUUUAFFFcb8RPiB4R+FHgHxr8T/H+tWvhzwP8ADzwrr3jXxfr96xW00bw34Z0u61jWtSnIBYx2en2dxOVQF32bEVnZQQDsqK/mz/ZM/wCDp3/gmP8AtaftH6Z+zdod58WfhfrPjHxNb+E/hh45+KnhTStD8DePdavp0tNLsl1DTvEGrXnhS41i6YQ6UPFVlpkE7SW0Nxc2l7cLZr/SZQAV+Xv/AAWS/YSX/gox/wAE8fj9+zTp8r2/jnUNDg8d/Cm4E7wQj4o/D+R/EPhCyvdrBJLDXLqCbw9eCYOkMGrvdqomtomX9QqKAP8ABp+G3j74pfsufHfwh8RfCc+qeCPi/wDAr4k6br+lmVJrPU/D/jTwLrySvY31udkqPBqNhLp+pWUgAliNzazKUd1P+6F8EPHN38Vvgn8JPiTq+mjTb/4jfC/wJ411TSJba4t1sbzxb4V0vW77TzaXyJcxRW89/LbrDdRrKI0CyruyK/Ob4x/8ELf+CV3x7/aKH7UvxQ/ZJ8Ea/wDF241ZPEGvX0GoeJNG8MeMPEMU0NxHr3jHwTo2s2PhXxFqxlhD3V1qGlSHU3Zn1Zb+TYyfrRb28FrBBa20MVvbW0Mdvb28KLFDBBCixxQxRoAkcUUaqkaKAqKoVQAAKAP8Y3/gu9+xY/7Cf/BT/wDaX+Eem2TWvgPxV4qk+MvwuZYDDa/8IJ8VZJ/FFlp1mDLPuh8Natc6x4Wyzhy2iF2RFdM/6AX/AAaYftUeJv2iv+CU/hzwL4vfUL3WP2X/AIkeJvgnYa1f3KXJ1Pwelvp/jLwfbRs13Pdovh/SvEv/AAjkSTw20KWWl2UVqsixyMPu/wD4Kl/8ERP2M/8AgrND4L1f49WvjDwX8Tvh9Z3Wk+GPiz8L77SNI8X/APCP3c/2t/DHiD+19H1iw8ReH7e9ae902yv7cS6Td3uozaZc2jaje+f9T/8ABPr/AIJ9fs8f8E0v2eNJ/Zs/Zs0nXLTwZaa5qnivW9b8V6pHrXi7xh4u1qOzh1TxH4j1SGz0+3nvJ7fT7Gzt7ezsbOwsLCztrOztYoYgCAf5+v8AwejeFPH2l/8ABRf4G+LNevprvwF4q/Zi0Sz8AW52rbaXd+HPG/iyHxhZJGLydmuJr7UtM1Ke6a0svOivrW2X7SLEyj9Xf+DKP9qfU/F3wG/ar/ZG8Ra/eag3wi8aeFviz8PtKvr2W4XSvCnxEtb3RvFNlpMEryG00238UeHrTUp7eAQWq6h4hnuY4nuLy7lP6a/8HLP/AASB+Kn/AAVJ/Zu+Fuu/s42+k6n+0T+zt4m1/VfC3hPWtWtNAtPHngzxnaabbeLfDdtrep3dtpGna1bXOh6Nq+jNqRitruW2ubCS/sRc+Y3wz/wa0/8ABFn9r/8A4J7/ABB/aA/aP/bB8I2fws1r4hfD/RPhj8PvhynifRPEWvSWA8Qp4j8ReIvEi+G7/U9L0yNZNL0ey0eykvpr+Xz9Qmnhs1iRbgA/s9ooooA/jY/4PAP2vf22f2Y/gp+y7oX7NHjv4g/CH4W/E7xP8QbL4u/Ef4a6rqfh/XbvWNG0/wAPyeEfBGoeJdJEF/oek6laXuv6qYrW/tX1ufTzbTMbeykhufdP+DSv9q39sr9qb9iX4x6h+1Z4v8b/ABQ0DwD8YrTwx8G/ij8Rb6+1bxRruizeFrG/8S+HW17Uka98RaZ4Y1J7KSz1O7vLy6im1m70+S4eO1hSH+onxn4F8FfEfw9feEviF4Q8MeOfCuqII9S8N+L9B0vxJoV8gOVF3pOsWt5Y3GxvmQywMUYBkKsARc8M+FvDHgrQ9P8ADPg7w7oXhPw3pUIt9L8P+GtJsNC0XToASRDY6Xplva2NpFkk+XBBGuSTjJJoAuavpmj6xYT2Gu6dpuqaXMv+lWWr2lrfWEqD/nvbXkctu6jJ/wBYhAq9FDFbxRwQRRwwwoscUMSLHFFGgCpHHGgVERVAVVUBVAAAAFf55P8AweU/txftC+C/2j/2eP2S/hv8SvHXw3+GVr8FW+Lniyx8E+LtZ8NR+OfEnizxj4g8O6cviJNEnsJr608Naf4Nf+zbW8ubq1WfWLydYIpcs/62/wDBoV+2T8bv2ov2EfjD4G+OHjXxR8SNT/Z5+NFr4U8IeM/GfiC/8SeI5fBni3wnY69YeG7vU9Ve41G4tfDd/a6kmmSXV9ctHY6hDYxLBBYxK4B+MP8Awdg/8FV/2wfht+3boX7InwA+O/xA+CXw0+FPwv8AAvi/xDF8JfHGp+FNW8YePfGhuvEC3ninU/D1xY6rGvh7TI9JttK0OW9NrGzy6rNA8t3bmD+kf/g2K/bm+Nn7df8AwTR07xb+0J4m1rx78UPhH8W/Gnwe1P4ieIZI59a8baRpO6ahY+7v/g0/g0h8O6t6a/g0h8/g0h8O6t6ah/g0h8O6t6ah/g0h8O6t6ah/g0h8O6t6ah/g0h8O6t6ah/g0h8O6t6ah/g0h8O6t6ahO6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjC+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjC/g0h8O6t6ahYzrbzjC+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjC+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6tn+HvFHh7UtWu0Ctf6np2leKoNBu9QnVbm9OlRz3LTXL6ahYzrbzjCzxBZVADYr+7v/g0h8O6tTXE386ahY6ahYzrbzjCzxBZVADYr+7v/g0h8O6tzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6tAP/AAcreL9G8Z/8Fqv22L3RHuHg0XxR6ahYzrbzjCzxBZVADYr+7v/g0h8O6t6ahYzrbzjCzxBZVADYr+7v/g0h8O6t4B8IXxuYGt2XWfCXwp8D6BrCRqxPmW6ahYzrbzjCzxBZVADYr+7v/g0h8O6toP8AwRo+GV1qmmT
*/

# 小程序登录配置
login:
  enable: true
  appId: xxxxxxxxxx
  secret: xxxxxxxxxxxx
  # 小程序认证界面,扫码后将跳转到这个界面
  authPage: pages/oauth/index
  # 图片宽度，默认为 430
  width: 430
  # 是否页面是否存在 默认是true
  checkPath: false

/*
 * 您可以更改此项目但请不要删除作者署名谢谢，否则根据中华人民共和国版权法进行处理.
 * You may change this item but please do not remove the author's signature,
 * otherwise it will be dealt with according to the Copyright Law of the People's Republic of China.
 * yangbuyi Copyright (c) https://yby6.com 2024.
 */

package com.yby6.tencentwechatappletloginproject.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;


/**
 * 小程序配置
 *
 * @author Yang Shuai
 * Create By 2024/11/26
 */
@Configuration
@ConfigurationProperties(prefix = "login")
public class WechatLoginConfig {
    /**
     * 是否开启
     */
    public static boolean enable;
    /**
     * 小程序appId
     */
    public static String appId;

    /**
     * 小程序密钥
     */
    public static String secret;

    /**
     * 小程序授权登录页面
     */
    public static String authPage;
    /**
     * 二维码大小 默认430
     */
    public static String width = "430";

    /**
     * 是否检查路径
     */
    public static boolean checkPath;


    public void setEnable(boolean enable) {
        WechatLoginConfig.enable = enable;
    }
    public void setAppId(String appId) {
        WechatLoginConfig.appId = appId;
    }

    public void setSecret(String secret) {
        WechatLoginConfig.secret = secret;
    }

    public void setAuthpage(String authPage) {
        WechatLoginConfig.authPage = authPage;
    }

}

package com.yby6.tencentwechatappletloginproject.controller;

import com.yby6.tencentwechatappletloginproject.domain.R;
import com.yby6.tencentwechatappletloginproject.service.AppletAuthService;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 小程序身份验证控制器
 *
 * @author Yang Shuai
 * Create By 2024/11/26
 */
@RestController
@RequestMapping("applet")
@RequiredArgsConstructor
public class AppletAuthController {

    private final AppletAuthService appletAuthService;

    /**
     * 小程序二维码认证
     *
     * @return {@code R<Object> }
     */
    @PostMapping("createAppletQrCode")
    public R<Object> createAppletQrCode() {
        return appletAuthService.createAppletQrCode();
    }


}

/*
 * 您可以更改此项目但请不要删除作者署名谢谢，否则根据中华人民共和国版权法进行处理.
 * You may change this item but please do not remove the author's signature,
 * otherwise it will be dealt with according to the Copyright Law of the People's Republic of China.
 * yangbuyi Copyright (c) https://yby6.com 2024.
 */

package com.yby6.tencentwechatappletloginproject.domain;

import java.io.Serial;
import java.io.Serializable;

/**
 * 响应信息主体
 *
 * @author 杨不易呀
 * Create By 2024/11/26
 */
public class R<T> implements Serializable {
    /**
     * 成功
     */
    public static final int SUCCESS = 200;
    /**
     * 失败
     */
    public static final int FAIL = 500;
    /**
     * 失败忽略
     */
    public static final int FAILIGNORE = 201;
    @Serial
    private static final long serialVersionUID = 1L;
    /**
     * 消息状态码
     */
    private int code;

    /**
     * 消息内容
     */
    private String msg;

    /**
     * 数据对象
     */
    private T data;

    public static <T> R<T> ok() {
        return restResult(null, SUCCESS, "操作成功");
    }

    public static <T> R<T> ok(T data) {
        return restResult(data, SUCCESS, "操作成功");
    }

    public static <T> R<T> ok(String msg) {
        return restResult(null, SUCCESS, msg);
    }

    public static <T> R<T> ok(String msg, T data) {
        return restResult(data, SUCCESS, msg);
    }

    public static <T> R<T> fail() {
        return restResult(null, FAIL, "操作失败");
    }

    public static <T> R<T> failIgnore() {
        return restResult(null, FAILIGNORE, "操作失败");
    }

    public static <T> R<T> failIgnore(T data) {
        return restResult(data, FAILIGNORE, "操作失败");
    }

    public static <T> R<T> fail(String msg) {
        return restResult(null, FAIL, msg);
    }

    public static <T> R<T> fail(T data) {
        return restResult(data, FAIL, "操作失败");
    }

    public static <T> R<T> fail(String msg, T data) {
        return restResult(data, FAIL, msg);
    }

    public static <T> R<T> fail(int code, String msg) {
        return restResult(null, code, msg);
    }

    public static <T> R<T> check(int row) {
        return row > 0 ? ok() : fail();
    }

    public static <T> R<T> check(boolean isTure) {
        return isTure ? ok() : fail();
    }


    /**
     * 返回警告消息
     *
     * @param msg 返回内容
     * @return 警告消息
     */
    public static <T> R<T> warn(String msg) {
        return restResult(null, 601, msg);
    }

    /**
     * 返回警告消息
     *
     * @param msg  返回内容
     * @param data 数据对象
     * @return 警告消息
     */
    public static <T> R<T> warn(String msg, T data) {
        return restResult(data, 601, msg);
    }

    private static <T> R<T> restResult(T data, int code, String msg) {
        R<T> r = new R<>();
        r.setCode(code);
        r.setData(data);
        r.setMsg(msg);
        return r;
    }

    public static <T> Boolean isError(R<T> ret) {
        return !isSuccess(ret);
    }

    public static <T> Boolean isSuccess(R<T> ret) {
        return R.SUCCESS == ret.getCode();
    }

    public int getCode() {
        return code;
    }

    public void setCode(int code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }
}

package com.yby6.tencentwechatappletloginproject.service;

import com.yby6.tencentwechatappletloginproject.domain.R;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

/**
 * 小程序身份验证服务
 *
 * @author Yang Shuai
 * Create By 2024/11/26
 */
@Slf4j
@Service
public class AppletAuthService {

    /**
     * 小程序二维码认证
     *
     * @return {@code R<Object> }
     */
    public R<Object> createAppletQrCode() {

        // .... TODO 创建二维码

        return null;
    }
}

    /**
     * 带参数无限个数小程序码接口
     * <a href="https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/qrcode-link/qr-code/getUnlimitedQRCode.html">...</a>
     *
     * @param accessToken 访问令牌
     * @param scene       场景
     * @return {@code InputStream }
     */
    private String getWechatQrCode(String accessToken, String scene) {
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + accessToken;
        JSONObject jsonParam = new JSONObject();
        // 封装请求对象
        // scene值
        jsonParam.set("scene", scene);
        // 跳往的小程序页面，一般为认证界面
        jsonParam.set("page", WechatLoginConfig.authPage);
        // 图片宽度，默认为 430
        jsonParam.set("width", WechatLoginConfig.width);
        // 检测页面是否存在，默认为 true
        jsonParam.set("check_path", WechatLoginConfig.checkPath);
        // 返回请求结果
        return remoteQRCode(url, jsonParam);
    }

    /**
     * 获取微信唯一凭证
     *
     * @param code 代码
     * @return {@link String}
     */
    private String getOpenId(String code) {
        String url = "https://api.weixin.qq.com/sns/jscode2session";
        Map<String, Object> map = new HashMap<>();
        map.put("appId", WechatLoginConfig.appId);
        map.put("secret", WechatLoginConfig.secret);
        map.put("js_code", code);
        map.put("grant_type", "authorization_code");
        String post = HttpUtil.post(url, map);
        log.info("微信返回： {}", post);
        JSONObject obj = JSONUtil.parseObj(post);
        String openid = obj.getStr("openid");
        if (StringUtils.isNoneBlank(openid)) {
            return openid;
        }
        throw new RuntimeException("临时登录凭证错误");
    }


    /**
     * 发送post请求
     *
     * @param url       请求地址
     * @param jsonParam 请求参数
     * @return 响应流
     */
    private String remoteQRCode(String url, JSONObject jsonParam) {
        try {
            // 发送POST请求
            byte[] responseBytes;
            try (cn.hutool.http.HttpResponse response = HttpUtil.createPost(url)
                    .body(jsonParam.toString())
                    .header("Content-Type", "application/json")
                    .execute()) {

                // 检查响应状态
                if (!response.isOk()) {
                    log.error("[remoteQRCode] 请求失败，状态码: {}", response.getStatus());
                    throw new RuntimeException("暂未支持小程序扫码登录！");
                }

                responseBytes = response.bodyBytes();
            }

            // 尝试解析为JSON，判断是否为错误响应
            String responseStr = new String(responseBytes, StandardCharsets.UTF_8);
            if (JSONUtil.isTypeJSON(responseStr)) {
                log.error("[remoteQRCode] 微信接口返回错误: {}", responseStr);
                throw new RuntimeException("暂未支持小程序扫码登录！");
            }

            // 保存图片到文件中以确认图片是否损坏
            // Files.write(Paths.get("output.png"), imageBytes);
            String base64 = Base64.encodeBase64String(responseBytes);
            // 返回带有 MIME 类型的 Base64 字符串
            return "data:image/png;base64," + base64;
        } catch (Exception e) {
            log.error("获取小程序二维码异常", e);
            throw new RuntimeException("暂未支持小程序扫码登录！");
        }
    }


    /**
     * 获取access_token 2小时
     * <a href="https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Get_access_token.html">...</a>
     *
     * @return access_token
     */
    private String getAccessToken() {
        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={}&secret={}";
        String body = HttpUtil.get(StrUtil.format(url, WechatLoginConfig.appId, WechatLoginConfig.secret));
        JSONObject object = JSONUtil.parseObj(body);
        return object.getStr("access_token");
    }

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.37.0</version>
</dependency>

--- # redis 配置
spring:
  data:
    redis:
      # 地址
      host: 127.0.0.1
      # 端口，默认为6379
      port: 6379
      # 数据库索引
      database: 0
      # 密码
      password: '123123123123..'
      # 连接超时时间
      timeout: 10s
      ssl:
        enabled: false

# 分布式redis配置
redisson:
  # redis key前缀
  keyPrefix: xcx_qrcode
  # 线程池数量
  threads: 4
  # Netty线程池数量
  nettyThreads: 8
  # 单节点配置
  singleServerConfig:
    # 客户端名称
    clientName: yangbuyiya
    # 最小空闲连接数
    connectionMinimumIdleSize: 8
    # 连接池大小
    connectionPoolSize: 32
    # 连接空闲超时，单位：毫秒
    idleConnectionTimeout: 10000
    # 命令等待超时，单位：毫秒
    timeout: 3000
    # 发布和订阅连接池大小
    subscriptionConnectionPoolSize: 50

/*
 * 您可以更改此项目但请不要删除作者署名谢谢，否则根据中华人民共和国版权法进行处理.
 * You may change this item but please do not remove the author's signature,
 * otherwise it will be dealt with according to the Copyright Law of the People's Republic of China.
 * yangbuyi Copyright (c) https://yby6.com 2024.
 */

package com.yby6.tencentwechatappletloginproject.config.redis;

import org.apache.commons.lang3.StringUtils;
import org.redisson.api.NameMapper;

/**
 * redis缓存key前缀处理
 *
 * @author 杨不易呀
 * Create By 2024/11/27
 */
public class KeyPrefixHandler implements NameMapper {

    private final String keyPrefix;

    public KeyPrefixHandler(String keyPrefix) {
        //前缀为空 则返回空前缀
        this.keyPrefix = StringUtils.isBlank(keyPrefix) ? "" : keyPrefix + ":";
    }

    /**
     * 增加前缀
     */
    @Override
    public String map(String name) {
        if (StringUtils.isBlank(name)) {
            return null;
        }
        if (StringUtils.isNotBlank(keyPrefix) && !name.startsWith(keyPrefix)) {
            return keyPrefix + name;
        }
        return name;
    }

    /**
     * 去除前缀
     */
    @Override
    public String unmap(String name) {
        if (StringUtils.isBlank(name)) {
            return null;
        }
        if (StringUtils.isNotBlank(keyPrefix) && name.startsWith(keyPrefix)) {
            return name.substring(keyPrefix.length());
        }
        return name;
    }

}

/*
 * 您可以更改此项目但请不要删除作者署名谢谢，否则根据中华人民共和国版权法进行处理.
 * You may change this item but please do not remove the author's signature,
 * otherwise it will be dealt with according to the Copyright Law of the People's Republic of China.
 * yangbuyi Copyright (c) https://yby6.com 2024.
 */

package com.yby6.tencentwechatappletloginproject.config.redis;

import lombok.Data;
import lombok.NoArgsConstructor;
import org.redisson.config.ReadMode;
import org.redisson.config.SubscriptionMode;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/**
 * Redisson 配置属性
 *
 * @author 杨不易呀
 */
@Data
@Component
@ConfigurationProperties(prefix = "redisson")
public class RedissonProperties {

    /**
     * redis缓存key前缀
     */
    private String keyPrefix;

    /**
     * 线程池数量,默认值 = 当前处理核数量 * 2
     */
    private int threads;

    /**
     * Netty线程池数量,默认值 = 当前处理核数量 * 2
     */
    private int nettyThreads;

    /**
     * 单机服务配置
     */
    private SingleServerConfig singleServerConfig;

    /**
     * 集群服务配置
     */
    private ClusterServersConfig clusterServersConfig;

    @Data
    @NoArgsConstructor
    public static class SingleServerConfig {

        /**
         * 客户端名称
         */
        private String clientName;

        /**
         * 最小空闲连接数
         */
        private int connectionMinimumIdleSize;

        /**
         * 连接池大小
         */
        private int connectionPoolSize;

        /**
         * 连接空闲超时，单位：毫秒
         */
        private int idleConnectionTimeout;

        /**
         * 命令等待超时，单位：毫秒
         */
        private int timeout;

        /**
         * 发布和订阅连接池大小
         */
        private int subscriptionConnectionPoolSize;

    }

    @Data
    @NoArgsConstructor
    public static class ClusterServersConfig {

        /**
         * 客户端名称
         */
        private String clientName;

        /**
         * master最小空闲连接数
         */
        private int masterConnectionMinimumIdleSize;

        /**
         * master连接池大小
         */
        private int masterConnectionPoolSize;

        /**
         * slave最小空闲连接数
         */
        private int slaveConnectionMinimumIdleSize;

        /**
         * slave连接池大小
         */
        private int slaveConnectionPoolSize;

        /**
         * 连接空闲超时，单位：毫秒
         */
        private int idleConnectionTimeout;

        /**
         * 命令等待超时，单位：毫秒
         */
        private int timeout;

        /**
         * 发布和订阅连接池大小
         */
        private int subscriptionConnectionPoolSize;

        /**
         * 读取模式
         */
        private ReadMode readMode;

        /**
         * 订阅模式
         */
        private SubscriptionMode subscriptionMode;

    }

}

/*
 * 您可以更改此项目但请不要删除作者署名谢谢，否则根据中华人民共和国版权法进行处理.
 * You may change this item but please do not remove the author's signature,
 * otherwise it will be dealt with according to the Copyright Law of the People's Republic of China.
 * yangbuyi Copyright (c) https://yby6.com 2024.
 */

package com.yby6.tencentwechatappletloginproject.config.redis;

import cn.hutool.core.util.ObjectUtil;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.redisson.codec.JsonJacksonCodec;
import org.redisson.spring.starter.RedissonAutoConfigurationCustomizer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * redis配置
 *
 * @author 杨不易呀
 */
@Slf4j
@Configuration
@EnableCaching
@EnableConfigurationProperties(RedissonProperties.class)
public class RedisConfig {

    @Autowired
    private RedissonProperties redissonProperties;

    @Autowired
    private ObjectMapper objectMapper;

    @Bean
    public RedissonAutoConfigurationCustomizer redissonCustomizer() {
        return config -> {
            config.setThreads(redissonProperties.getThreads())
                .setNettyThreads(redissonProperties.getNettyThreads())
                .setCodec(new JsonJacksonCodec(objectMapper));
            RedissonProperties.SingleServerConfig singleServerConfig = redissonProperties.getSingleServerConfig();
            if (ObjectUtil.isNotNull(singleServerConfig)) {
                // 使用单机模式
                config.useSingleServer()
                    //设置redis key前缀
                    .setNameMapper(new KeyPrefixHandler(redissonProperties.getKeyPrefix()))
                    .setTimeout(singleServerConfig.getTimeout())
                    .setClientName(singleServerConfig.getClientName())
                    .setIdleConnectionTimeout(singleServerConfig.getIdleConnectionTimeout())
                    .setSubscriptionConnectionPoolSize(singleServerConfig.getSubscriptionConnectionPoolSize())
                    .setConnectionMinimumIdleSize(singleServerConfig.getConnectionMinimumIdleSize())
                    .setConnectionPoolSize(singleServerConfig.getConnectionPoolSize());
            }
            // 集群配置方式 参考下方注释
            RedissonProperties.ClusterServersConfig clusterServersConfig = redissonProperties.getClusterServersConfig();
            if (ObjectUtil.isNotNull(clusterServersConfig)) {
                config.useClusterServers()
                    //设置redis key前缀
                    .setNameMapper(new KeyPrefixHandler(redissonProperties.getKeyPrefix()))
                    .setTimeout(clusterServersConfig.getTimeout())
                    .setClientName(clusterServersConfig.getClientName())
                    .setIdleConnectionTimeout(clusterServersConfig.getIdleConnectionTimeout())
                    .setSubscriptionConnectionPoolSize(clusterServersConfig.getSubscriptionConnectionPoolSize())
                    .setMasterConnectionMinimumIdleSize(clusterServersConfig.getMasterConnectionMinimumIdleSize())
                    .setMasterConnectionPoolSize(clusterServersConfig.getMasterConnectionPoolSize())
                    .setSlaveConnectionMinimumIdleSize(clusterServersConfig.getSlaveConnectionMinimumIdleSize())
                    .setSlaveConnectionPoolSize(clusterServersConfig.getSlaveConnectionPoolSize())
                    .setReadMode(clusterServersConfig.getReadMode())
                    .setSubscriptionMode(clusterServersConfig.getSubscriptionMode());
            }
            log.info("初始化 redis 配置");
        };
    }

    /**
     * redis集群配置 yml
     *
     * --- # redis 集群配置(单机与集群只能开启一个另一个需要注释掉)
     * spring:
     *   redis:
     *     cluster:
     *       nodes:
     *         - 192.168.0.100:6379
     *         - 192.168.0.101:6379
     *         - 192.168.0.102:6379
     *     # 密码
     *     password:
     *     # 连接超时时间
     *     timeout: 10s
     *     # 是否开启ssl
     *     ssl: false
     *
     * redisson:
     *   # 线程池数量
     *   threads: 16
     *   # Netty线程池数量
     *   nettyThreads: 32
     *   # 集群配置
     *   clusterServersConfig:
     *     # 客户端名称
     *     clientName: ${ruoyi.name}
     *     # master最小空闲连接数
     *     masterConnectionMinimumIdleSize: 32
     *     # master连接池大小
     *     masterConnectionPoolSize: 64
     *     # slave最小空闲连接数
     *     slaveConnectionMinimumIdleSize: 32
     *     # slave连接池大小
     *     slaveConnectionPoolSize: 64
     *     # 连接空闲超时，单位：毫秒
     *     idleConnectionTimeout: 10000
     *     # 命令等待超时，单位：毫秒
     *     timeout: 3000
     *     # 发布和订阅连接池大小
     *     subscriptionConnectionPoolSize: 50
     *     # 读取模式
     *     readMode: "SLAVE"
     *     # 订阅模式
     *     subscriptionMode: "MASTER"
     */

}

/**
 * 获取access_token 2小时
 * <a href="https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Get_access_token.html">...</a>
 *
 * @return access_token
 */
public String getAccessToken() {
    // 存在缓存TOKEN继续使用
    String accessToken = RedisUtils.getCacheObject(GlobalConstants.WECHAT_AUTH_TOKEN + WechatLoginConfig.appId);
    if (StrUtil.isNotBlank(accessToken)) {
        return accessToken;
    }
    String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={}&secret={}";
    String body = HttpUtil.get(StrUtil.format(url, WechatLoginConfig.appId, WechatLoginConfig.secret));
    JSONObject object = JSONUtil.parseObj(body);
    accessToken = object.getStr("access_token");
    long expiresIn = Long.parseLong(object.getStr("expires_in"));
    // 设置过期时间 expiresIn 秒
    RedisUtils.setCacheObject(GlobalConstants.WECHAT_AUTH_TOKEN + WechatLoginConfig.appId,
            accessToken, Duration.ofSeconds(expiresIn));
    return accessToken;
}

package com.yby6.tencentwechatappletloginproject.constant;

/**
 * 全局常量
 *
 * @author Yang Shuai
 * Create By 2024/11/28
 */
public interface GlobalConstants {
    
    /**
     * 微信登录状态
     */
    String WECHAT_LOGIN_STATE = "wechat_login_state:";
    /**
     * 微信授权TOKEN
     */
    String WECHAT_AUTH_TOKEN = "wechat_auth_token:";
    
}

/**
 * 修改扫码状态为 已扫码
 *
 * @param scene 场景
 * @return {@code R<Void> }
 */
public R<Void> userScanQrcode(String scene) {
// 1.先判断本次请求是否合法 || 判断状态是否为 wait
String state = RedisUtils.getCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene);
if (null == scene || !ScanStatus.WAIT.getStatus().equals(state)) {
    return R.fail("非法操作,请勿重复扫码!");
}
// 2.修改状态为 已扫码
RedisUtils.setCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene,
                          ScanStatus.SCANNED.getStatus(),
                          true);
return R.ok();
}

/**
 * 用户取消认证
 *
 * @param scene 场景值
 * @return {@code R<Void> }
 */
public R<Void> userCancelAuth(String scene) {
// 1.判断是否存在 避免走后面的逻辑了
String state = RedisUtils.getCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene);
if (null == scene) {
    return R.ok();
}
// 2.存在就更新缓存为关闭扫码
RedisUtils.setCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene,
                          ScanStatus.CANCEL.getStatus(),
                          true);
return R.ok();
}

@Test
public void getOpenId () {
    String url = "https://api.weixin.qq.com/sns/jscode2session";
    Map<String, Object> map = new HashMap<>();
    map.put("appId", appId);
    map.put("secret", secret);
    map.put("js_code", "这里就是小程序登录的code");
    map.put("grant_type", "authorization_code");
    String post = HttpUtil.post(url, map);
    log.info("微信返回： {}", post);
    JSONObject obj = JSONUtil.parseObj(post);
    String openid = obj.getStr("openid");
}

/**
 * 获取微信唯一凭证
 *
 * @param code 代码
 * @return {@link String}
 */
private String getOpenId(String code) {
String url = "https://api.weixin.qq.com/sns/jscode2session";
    Map<String, Object> map = new HashMap<>();
    map.put("appId", WechatLoginConfig.appId);
    map.put("secret", WechatLoginConfig.secret);
    map.put("js_code", code);
    map.put("grant_type", "authorization_code");
    String post = HttpUtil.post(url, map);
    log.info("微信返回： {}", post);
    JSONObject obj = JSONUtil.parseObj(post);
    String openid = obj.getStr("openid");
    if (StringUtils.isNoneBlank(openid)) {
        return openid;
    }
    throw new RuntimeException("临时登录凭证错误");
}

/**
 * 用户点击确认授权
 *
 * @param scene 场景
 * @param code  代码
 * @return {@code R<Void> }
 */
@PostMapping("userAuthWebPro/{scene}/{code}/applet")
public R<Void> userAuthWebPro(@PathVariable String scene, @PathVariable String code) {
    return appletAuthService.userAuthWebPro(scene,code);
}

/**
 * 用户点击确认授权
 *
 * @param scene 场景
 * @param code  代码
 * @return {@code R<Void> }
 */
public R<Void> userAuthWebPro(String scene, String code) {
    // 1.判断是否存在 避免走后面的逻辑了
    String status = RedisUtils.getCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene);
    // 只能是扫码状态进来授权否则都认定为异常操作
    if (null == status || !status.equals(ScanStatus.SCANNED.getStatus())) {
        return R.fail("扫码超时,请重新扫码授权!");
    }

    // 2.获取OpenId 这里就是做一些和你的系统绑定业务....我这里就简单记录一下当前登录人
    String openId = getOpenId(code);
    RedisUtils.setCacheObject(GlobalConstants.WECHAT_AUTH_INFO, openId);

    // 3.修改扫码状态为 已授权 提供前端校验
    RedisUtils.setCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene,
                              ScanStatus.SUCCESS.getStatus(), true);
    return R.ok();
}

/**
 * 微信授权信息
 */
String WECHAT_AUTH_INFO = "wechat_auth_INFO:";

 /**
     * 浏览器查询 当前二维码状态
     *
     * @param scene 场景值
     * @return {@code R<String> }
     */
    @GetMapping("userAuthStatus/{scene}/applet")
    public R<Object> userAuthStatus(@PathVariable String scene) {
        String result = RedisUtils.getCacheObject(GlobalConstants.WECHAT_LOGIN_STATE + scene);
        // 检测到success直接删除并且传递给调用方
        if (null != result && result.equals(ScanStatus.SUCCESS.getStatus())) {
            RedisUtils.deleteObject(scene);
            // 获取到登录信息
            Object cacheObject = RedisUtils.getCacheObject(GlobalConstants.WECHAT_AUTH_INFO);
            return R.ok(result, cacheObject);
        }
        return R.ok(result);
    }

/*
 * 您可以更改此项目但请不要删除作者署名谢谢，否则根据中华人民共和国版权法进行处理.
 * You may change this item but please do not remove the author's signature,
 * otherwise it will be dealt with according to the Copyright Law of the People's Republic of China.
 * yangbuyi Copyright (c) https://yby6.com 2024.
 */

package com.yby6.tencentwechatappletloginproject.service.base;

import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.yby6.tencentwechatappletloginproject.constant.GlobalConstants;
import com.yby6.tencentwechatappletloginproject.config.WechatLoginConfig;
import com.yby6.tencentwechatappletloginproject.utils.RedisUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.tomcat.util.codec.binary.Base64;
import org.springframework.stereotype.Service;

import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.util.HashMap;
import java.util.Map;

/**
 * 抽象小程序服务
 *
 * @author 杨不易呀
 * Create By 2024/11/26
 */
@Slf4j
public abstract class AbstractAppletService {

    /**
     * 带参数无限个数小程序码接口
     * <a href="https://developers.weixin.qq.com/miniprogram/dev/OpenApiDoc/qrcode-link/qr-code/getUnlimitedQRCode.html">...</a>
     *
     * @param accessToken 访问令牌
     * @param scene       场景
     * @return {@code InputStream }
     */
    public String getWechatQrCode(String accessToken, String scene) {
        String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + accessToken;
        JSONObject jsonParam = new JSONObject();
        // 封装请求对象
        // scene值
        jsonParam.set("scene", scene);
        // 跳往的小程序页面，一般为认证界面
        jsonParam.set("page", WechatLoginConfig.authPage);
        // 图片宽度，默认为 430
        jsonParam.set("width", WechatLoginConfig.width);
        // 检测页面是否存在，默认为 true
        jsonParam.set("check_path", WechatLoginConfig.checkPath);
        // 返回请求结果
        return remoteQRCode(url, jsonParam);
    }

    /**
     * 获取微信唯一凭证
     *
     * @param code 代码
     * @return {@link String}
     */
    public String getOpenId(String code) {
        String url = "https://api.weixin.qq.com/sns/jscode2session";
        Map<String, Object> map = new HashMap<>();
        map.put("appId", WechatLoginConfig.appId);
        map.put("secret", WechatLoginConfig.secret);
        map.put("js_code", code);
        map.put("grant_type", "authorization_code");
        String post = HttpUtil.post(url, map);
        log.info("微信返回： {}", post);
        JSONObject obj = JSONUtil.parseObj(post);
        String openid = obj.getStr("openid");
        if (StringUtils.isNoneBlank(openid)) {
            return openid;
        }
        throw new RuntimeException("临时登录凭证错误");
    }


    /**
     * 发送post请求
     *
     * @param url       请求地址
     * @param jsonParam 请求参数
     * @return 响应流
     */
    public String remoteQRCode(String url, JSONObject jsonParam) {
        try {
            // 发送POST请求
            byte[] responseBytes;
            try (cn.hutool.http.HttpResponse response = HttpUtil.createPost(url)
                    .body(jsonParam.toString())
                    .header("Content-Type", "application/json")
                    .execute()) {
                
                // 检查响应状态
                if (!response.isOk()) {
                    log.error("[remoteQRCode] 请求失败，状态码: {}", response.getStatus());
                    throw new RuntimeException("暂未支持小程序扫码登录！");
                }
                
                responseBytes = response.bodyBytes();
            }
            
            // 尝试解析为JSON，判断是否为错误响应
            String responseStr = new String(responseBytes, StandardCharsets.UTF_8);
            if (JSONUtil.isTypeJSON(responseStr)) {
                log.error("[remoteQRCode] 微信接口返回错误: {}", responseStr);
                throw new RuntimeException("暂未支持小程序扫码登录！");
            }
            
            // 保存图片到文件中以确认图片是否损坏
            // Files.write(Paths.get("output.png"), imageBytes);
            String base64 = Base64.encodeBase64String(responseBytes);
            // 返回带有 MIME 类型的 Base64 字符串
            return "data:image/png;base64," + base64;
        } catch (Exception e) {
            log.error("获取小程序二维码异常", e);
            throw new RuntimeException("暂未支持小程序扫码登录！");
        }
    }
    
    
    /**
     * 获取access_token 2小时
     * <a href="https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Get_access_token.html">...</a>
     *
     * @return access_token
     */
    public String getAccessToken() {
        // 存在缓存TOKEN继续使用
        String accessToken = RedisUtils.getCacheObject(GlobalConstants.WECHAT_AUTH_TOKEN + WechatLoginConfig.appId);
        if (StrUtil.isNotBlank(accessToken)) {
            return accessToken;
        }
        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={}&secret={}";
        String body = HttpUtil.get(StrUtil.format(url, WechatLoginConfig.appId, WechatLoginConfig.secret));
        JSONObject object = JSONUtil.parseObj(body);
        accessToken = object.getStr("access_token");
        long expiresIn = Long.parseLong(object.getStr("expires_in"));
        // 设置过期时间29分钟
        RedisUtils.setCacheObject(GlobalConstants.WECHAT_AUTH_TOKEN + WechatLoginConfig.appId, accessToken, Duration.ofSeconds(expiresIn));
        return accessToken;
    }
    
}