学校功能

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

@@ -0,0 +1,19 @@
+package com.zhongshu.card.client.model.wechat;
+
+import lombok.Data;
+
+/**
+ */
+@Data
+public class AccessTokenVo {
+
+    /**
+     * token
+     */
+    private String accessToken;
+
+    /**
+     * 有效时间，默认2小时
+     */
+    private Integer expiresIn;
+}

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

@@ -0,0 +1,25 @@
+package com.zhongshu.card.client.model.wechat;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author: wy
+ * @Date: 2023/7/14 10:00
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class GenerateSchemeVo {
+
+    @Schema(description = "错误码")
+    private Integer errCode;
+
+    @Schema(description = "错误信息")
+    private String errMsg;
+
+    @Schema(description = "生成的小程序 scheme 码")
+    private String openLink;
+}

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

@@ -0,0 +1,25 @@
+package com.zhongshu.card.client.model.wechat;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author: wy
+ * @Date: 2023/6/25 17:02
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class MiniAppUserInfoVo {
+
+    private String openid;
+
+    @JsonProperty("session_key")
+    private String sessionKey;
+
+    private String unionid;
+
+    private String msg;
+}

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

@@ -0,0 +1,19 @@
+package com.zhongshu.card.client.model.wechat;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author TRX
+ * @date 2024/4/17
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class PhoneLoginParam {
+    private String phoneNumber;
+    private String deviceType;
+    private String loginType;
+    String iv;
+}

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

@@ -0,0 +1,18 @@
+package com.zhongshu.card.client.model.wechat;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author TRX
+ * @date 2024/4/17
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+public class PhoneModel {
+    private String phone;
+}

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

@@ -0,0 +1,43 @@
+package com.zhongshu.card.client.model.wechat;
+
+import lombok.Data;
+
+/**
+ *
+ */
+@Data
+public class WechatPhoneNumber {
+
+    /**
+     * 用户绑定的手机号（国外手机号会有区号）
+     */
+    private String phoneNumber;
+
+    /**
+     * 没有区号的手机号
+     */
+    private String purePhoneNumber;
+
+    /**
+     * 区号
+     */
+    private String countryCode;
+
+    /**
+     * 数据水印
+     */
+    private Watermark watermark;
+
+    @Data
+    static class Watermark {
+        /**
+         * 用户获取手机号操作的时间戳
+         */
+        private Integer timestamp;
+
+        /**
+         * 小程序appid
+         */
+        private String appid;
+    }
+}

FullCardServer/src/main/java/com/zhongshu/card/server/core/init/WxInit.java

@@ -0,0 +1,36 @@
+package com.zhongshu.card.server.core.init;
+
+import com.zhongshu.card.server.core.util.wx.WechatCUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author TRX
+ * @date 2024/6/11
+ */
+@Component
+@Slf4j
+public class WxInit implements CommandLineRunner {
+
+    @Autowired
+    WechatCUtil wechatCUtil;
+
+    @Override
+    public void run(String... args) throws Exception {
+        log.info("SuperCountInit");
+        CompletableFuture.runAsync(() -> {
+            try {
+                TimeUnit.SECONDS.sleep(12);
+                log.info("---------初始微信token信息-----------");
+                wechatCUtil.init();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        });
+    }
+}

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

@@ -3,6 +3,7 @@ package com.zhongshu.card.server.core.service;
 import com.zhongshu.card.client.ret.ResultContent;
 import com.zhongshu.card.client.service.org.OrganizationService;
 import com.zhongshu.card.server.core.service.base.RedisService;
+import com.zhongshu.card.server.core.util.wx.WechatCUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -20,9 +21,13 @@ public class TestService {
     @Autowired
     RedisService redisService;
 
+    @Autowired
+    WechatCUtil wechatCUtil;
+
     public ResultContent text() {
         try {
-            redisService.setValueSecond("a", "123", 3);
+            wechatCUtil.init();
+            redisService.setValueSecond("a", "123", 1);
             log.info("a: {}", redisService.getValue("a"));
         } catch (Exception e) {
             e.printStackTrace();

FullCardServer/src/main/java/com/zhongshu/card/server/core/test/Test.java

@@ -1,9 +1,13 @@
 package com.zhongshu.card.server.core.test;
 
 import cn.hutool.core.lang.Snowflake;
+import cn.hutool.json.JSONUtil;
 import com.zhongshu.card.server.core.util.ValidateResult;
 import com.zhongshu.card.server.core.util.ValidateUtils;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * @author TRX
  * @date 2024/5/31
@@ -18,5 +22,11 @@ public class Test {
         ValidateResult result = ValidateUtils.validatePassWord(str);
         System .out.println("结果：" + result.isSuccess() + " = " + result.getMsg()
          + " == " + ValidateUtils.isPhoneNumber("18723497166"));
+
+        Map<String, Object> map = new HashMap<>();
+        map.put("orderNo", orderNo);
+        map.put("age", 24);
+        System.out.println("map = " + JSONUtil.toJsonStr(map));
+
     }
 }

FullCardServer/src/main/java/com/zhongshu/card/server/core/util/wx/WechatCAuthConfig.java

@@ -0,0 +1,18 @@
+package com.zhongshu.card.server.core.util.wx;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * c端小程序的配置
+ */
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "cwechat")
+public class WechatCAuthConfig {
+
+    private String appid;
+
+    private String secret;
+}

FullCardServer/src/main/java/com/zhongshu/card/server/core/util/wx/WechatCUtil.java

@@ -0,0 +1,201 @@
+package com.zhongshu.card.server.core.util.wx;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.json.JSON;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.github.microservice.core.util.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.zhongshu.card.client.model.wechat.AccessTokenVo;
+import com.zhongshu.card.client.model.wechat.GenerateSchemeVo;
+import com.zhongshu.card.client.model.wechat.MiniAppUserInfoVo;
+import com.zhongshu.card.client.model.wechat.WechatPhoneNumber;
+import com.zhongshu.card.client.ret.ResultContent;
+import com.zhongshu.card.client.ret.ResultState;
+import com.zhongshu.card.server.core.service.base.RedisService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStreamWriter;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ *
+ */
+@Component
+@Slf4j
+public class WechatCUtil {
+
+    private final static String ACCESS_TOKEN_KEY = "com:zswl:cloud:bdb: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 WECHAT_MINI_APP_AUTH_URL = "https://api.weixin.qq.com/sns/jscode2session?appid=%s&secret=%s&js_code=%s&grant_type=%s";
+
+    private final static String PHONE_NUMBER_URL = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=%s";
+
+    private final static String GENERATE_SCHEME = "https://api.weixin.qq.com/wxa/generatescheme?access_token=%s";
+
+    private final static String UNLIMITED_QRCODE_URL = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=%s";
+
+    @Resource
+    private WechatCAuthConfig wechatAuthConfig;
+
+    @Autowired
+    private RedisService redisService;
+
+    //    @PostConstruct
+    public void init() throws Exception {
+        log.info("init微信Token... ");
+        AccessTokenVo accessTokenVo = getAccess_token();
+        if (Objects.nonNull(accessTokenVo) && StringUtils.isNotEmpty(accessTokenVo.getAccessToken())) {
+            log.info("accessTokenVo: {}", accessTokenVo);
+            redisService.setValueSecond(ACCESS_TOKEN_KEY, accessTokenVo.getAccessToken(), 300);
+            log.info("微信登录初始化成功");
+        } else {
+            log.error("*******fail *********");
+            log.error("WechatUtil init fail");
+            log.error("*******fail *********");
+        }
+    }
+
+    public AccessTokenVo genAccessToken() throws Exception {
+        String url = String.format(ACCESS_TOKEN_URL, wechatAuthConfig.getAppid().trim(), wechatAuthConfig.getSecret().trim());
+        ResponseModel request = HttpClientUtil.request(HttpModel.builder().method(MethodType.Get).url(url).build());
+        if (200 == request.getCode()) {
+            return BeanUtil.copyProperties(request.getBody(), AccessTokenVo.class);
+        }
+        return null;
+    }
+
+    public synchronized AccessTokenVo getAccess_token() throws IOException {
+        String url = String.format(ACCESS_TOKEN_URL, wechatAuthConfig.getAppid(), wechatAuthConfig.getSecret());
+        Map<String, Object> map = new HashMap<>();
+        map.put("grant_type", "client_credential");
+        map.put("appid", wechatAuthConfig.getAppid().trim());
+        map.put("secret", wechatAuthConfig.getSecret().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;
+    }
+
+    public String getAccessToken() throws Exception {
+        String value = redisService.getValue(ACCESS_TOKEN_KEY);
+        if (Objects.isNull(value)) {
+            init();
+            value = redisService.getValue(ACCESS_TOKEN_KEY);
+        }
+        return value;
+    }
+
+    public WechatPhoneNumber getPhoneNumber(String code) throws Exception {
+        String url = String.format(PHONE_NUMBER_URL, getAccessToken());
+        Map<String, Object> map = new HashMap<>();
+        map.put("code", code);
+        String json = JSONUtil.toJsonStr(map);
+        ResponseModel request = HttpClientUtil.request(HttpModel.builder().method(MethodType.Post)
+                .url(url).body(json).build());
+        if (200 == request.getCode()) {
+            try {
+                LinkedHashMap map1 = (LinkedHashMap) request.getBody();
+                if (map1.containsKey("errcode")) {
+                    log.error("getPhoneNumber error: {} {} {}", map1.get("errcode"), map1.get("errmsg"), code);
+                    String errcode = map1.get("errcode").toString();
+                    if (errcode.equals("40001")) {
+                        clear();
+                    }
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            WechatPhoneNumber wechatPhoneNumber = BeanUtil.copyProperties(((LinkedHashMap) request.getBody()).get("phone_info"), WechatPhoneNumber.class);
+            log.info("wechatPhoneNumber: {}", wechatPhoneNumber);
+            return wechatPhoneNumber;
+        }
+        return null;
+    }
+
+    public MiniAppUserInfoVo getMiniAppUserInfo(String jsCode) throws Exception {
+        String url = String.format(WECHAT_MINI_APP_AUTH_URL, wechatAuthConfig.getAppid(), wechatAuthConfig.getSecret(), jsCode, "authorization_code");
+        ResponseModel request = HttpClientUtil.request(HttpModel.builder().url(url).build());
+        if (200 == request.getCode()) {
+            MiniAppUserInfoVo miniAppUserInfoVo = BeanUtil.copyProperties(
+                    JSONUtil.parseObj(request.getBody().toString()),
+                    MiniAppUserInfoVo.class);
+            if (Objects.nonNull(miniAppUserInfoVo.getOpenid())) {
+                return miniAppUserInfoVo;
+            }
+        } else {
+            MiniAppUserInfoVo vo = new MiniAppUserInfoVo();
+            vo.setMsg(request.toString());
+            return vo;
+        }
+        return null;
+    }
+
+    public ResultContent generateScheme() throws Exception {
+        String accessToken = getAccessToken();
+        String url = String.format(GENERATE_SCHEME, accessToken);
+        ResponseModel request = HttpClientUtil.request(HttpModel.builder().method(MethodType.Post).url(url).build());
+        String msg = "";
+        if (200 == request.getCode()) {
+            LinkedHashMap body = (LinkedHashMap) request.getBody();
+            Integer errcode = (Integer) body.get("errcode");
+            msg = body.get("errmsg").toString();
+            String openlink = (String) body.get("openlink");
+            GenerateSchemeVo vo = new GenerateSchemeVo(errcode, msg, openlink);
+            if (Objects.nonNull(vo.getOpenLink()))
+                return ResultContent.buildContent(vo.getOpenLink());
+            msg = vo.getErrMsg();
+        }
+        return ResultContent.build(ResultState.Exception, msg);
+    }
+
+    /**
+     * 生成微信小程序 页面二维码
+     *
+     * @param scene
+     * @param page
+     * @return
+     * @throws Exception
+     */
+    public byte[] getUnlimitedQRCodeToByte(String scene, String page) throws Exception {
+        String url = String.format(UNLIMITED_QRCODE_URL, getAccessToken());
+        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;
+    }
+
+    public void clear() {
+        redisService.removeValue(ACCESS_TOKEN_KEY);
+    }
+}

FullCardServer/src/main/java/com/zhongshu/card/server/core/util/wx/WechatSAuthConfig.java

@@ -0,0 +1,18 @@
+package com.zhongshu.card.server.core.util.wx;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * 商户端小程序的配置
+ */
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "swechat")
+public class WechatSAuthConfig {
+
+    private String appid;
+
+    private String secret;
+}