获取小程序二维码

FullCardClient/src/main/java/com/zhongshu/card/client/model/wechat/UnlimitedQRCodeParam.java

@@ -0,0 +1,13 @@
+package com.zhongshu.card.client.model.wechat;
+
+import lombok.Data;
+
+@Data
+public class UnlimitedQRCodeParam {
+
+    private String scene;
+
+    private String page;
+
+    private String projectId;
+}

FullCardServer/src/main/java/com/zhongshu/card/server/core/controller/WeChatController.java

@@ -0,0 +1,31 @@
+package com.zhongshu.card.server.core.controller;
+
+import com.github.microservice.net.ResultContent;
+import com.zhongshu.card.client.model.operLogs.OperationLogsAddParam;
+import com.zhongshu.card.client.model.org.OrganizationUserModel;
+import com.zhongshu.card.client.model.wechat.UnlimitedQRCodeParam;
+import com.zhongshu.card.server.core.service.wxQRCode.WeChatService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.servlet.http.HttpServletResponse;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("wechat")
+@Tag(name = "微信小程序服务")
+public class WeChatController {
+
+    @Autowired
+    WeChatService weChatService;
+
+
+    @Operation(summary = "获取小程序二维码", description = "获取小程序二维码")
+    @RequestMapping(value = "unlimitedQRCode", method = {RequestMethod.POST})
+    public void unlimitedQRCode(@RequestBody UnlimitedQRCodeParam param, HttpServletResponse response) {
+        weChatService.UnlimitedQRCode(param, response);
+    }
+}

FullCardServer/src/main/java/com/zhongshu/card/server/core/service/wxQRCode/WeChatService.java

@@ -0,0 +1,128 @@
+package com.zhongshu.card.server.core.service.wxQRCode;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.json.JSONUtil;
+import com.github.microservice.core.util.net.HttpClient;
+import com.github.microservice.core.util.net.apache.HttpClientUtil;
+import com.github.microservice.core.util.net.apache.HttpModel;
+import com.github.microservice.core.util.net.apache.MethodType;
+import com.github.microservice.core.util.net.apache.ResponseModel;
+import com.github.microservice.net.ResultContent;
+import com.github.microservice.net.ResultState;
+import com.zhongshu.card.client.model.pay.UnionApplySignParam;
+import com.zhongshu.card.client.model.projectAbout.ProjectWeChatInfoModel;
+import com.zhongshu.card.client.model.wechat.AccessTokenVo;
+import com.zhongshu.card.client.model.wechat.UnlimitedQRCodeParam;
+import com.zhongshu.card.server.core.controller.projectAbout.ProjectWeChatInfoController;
+import com.zhongshu.card.server.core.service.base.RedisService;
+import com.zhongshu.card.server.core.service.projectAbout.ProjectWeChatInfoService;
+import com.zhongshu.card.server.core.util.wx.WechatCUtil;
+import jakarta.servlet.http.HttpServletResponse;
+import lombok.Cleanup;
+import lombok.SneakyThrows;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+@Service
+public class WeChatService {
+
+    @Autowired
+    WechatCUtil wechatCUtil;
+
+    @Autowired
+    RedisService redisService;
+
+    @Autowired
+    ProjectWeChatInfoService projectWeChatInfoService;
+
+    private final static String ACCESS_TOKEN_KEY = "com:zswl:card:wechat:accessToken:";
+
+    private final static String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/stable_token?grant_type=client_credential&appid=%s&secret=%s";
+
+    private final static String UNLIMITED_QRCODE_URL = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=%s";
+
+
+    @SneakyThrows
+    public void UnlimitedQRCode(UnlimitedQRCodeParam param, HttpServletResponse response) {
+
+        ResultContent<ProjectWeChatInfoModel> weChatInfoRet = projectWeChatInfoService.getProjectWeChatInfo(param.getProjectId());
+        if (!weChatInfoRet.getState().equals(ResultState.Success)){
+            throw new RuntimeException("项目未配置微信小程序");
+        }
+
+        ProjectWeChatInfoModel weChatInfoModel = weChatInfoRet.getContent();
+
+        if (StringUtils.isBlank(weChatInfoModel.getAppId()) || StringUtils.isBlank(weChatInfoModel.getAppSecret())){
+            throw new RuntimeException("appId或者secret为空");
+        }
+
+        String accessToken = getAccessToken(weChatInfoModel.getAppId(), weChatInfoModel.getAppSecret());
+
+        byte[] unlimitedQRCodeToByte = getUnlimitedQRCodeToByte(param.getScene(), param.getPage(), accessToken);
+        response.addHeader("Content-Type","image/jpeg");
+        @Cleanup OutputStream outputStream = response.getOutputStream();
+        outputStream.write(unlimitedQRCodeToByte);
+        outputStream.flush();
+    }
+
+    public String getAccessToken(String appId, String secret) throws Exception {
+        String value = redisService.getValue(ACCESS_TOKEN_KEY + appId + ":");
+        if (Objects.isNull(value)) {
+            AccessTokenVo accessTokenVo = getAccess_token(appId, secret);
+
+            value = accessTokenVo.getAccessToken();
+            Integer expiresIn = accessTokenVo.getExpiresIn();
+
+            redisService.setValueSecond(ACCESS_TOKEN_KEY, value, expiresIn);
+        }
+        return value;
+    }
+
+    private synchronized AccessTokenVo getAccess_token(String appId, String secret) throws IOException {
+        String url = String.format(ACCESS_TOKEN_URL, appId, secret);
+        Map<String, Object> map = new HashMap<>();
+        map.put("grant_type", "client_credential");
+        map.put("appid", appId.trim());
+        map.put("secret", secret.trim());
+        String json = JSONUtil.toJsonStr(map);
+        ResponseModel request = HttpClientUtil.request(HttpModel.builder()
+                .url(url).method(MethodType.Post).body(json).build());
+        if (200 == request.getCode()) {
+            return BeanUtil.copyProperties(request.getBody(), AccessTokenVo.class);
+        }
+        return null;
+    }
+
+    /**
+     * 生成微信小程序 页面二维码
+     *
+     * @param scene
+     * @param page
+     * @return
+     * @throws Exception
+     */
+    public byte[] getUnlimitedQRCodeToByte(String scene, String page, String accessToken) throws Exception {
+        String url = String.format(UNLIMITED_QRCODE_URL, accessToken);
+        Map<String, String> header = new HashMap<>();
+        header.put("Content-Type", "image/jpeg");
+        Map<String, Object> map = new HashMap<>();
+        map.put("scene", scene);
+        if (StringUtils.isNotEmpty(page)) {
+            map.put("page", page);
+        }
+        map.put("env_version", "trial");
+        HttpClient.ResultBean resultBean = new HttpClient().ReadDocuments(url, true,
+                JSONUtil.toJsonStr(map).getBytes(), header);
+        if (200 == resultBean.getStat()) {
+            return resultBean.getData();
+        }
+        return null;
+    }
+}