玩湃微信商户认证代码

无关风月

2024-07-11 eb6b6dbb35a9f029e0b7d269773685c19fd40976

 cloud-server-account/src/main/java/com/dsh/account/util/weChat/WeChatUtil.java

@@ -32,7 +32,7 @@
    @Value("${wx.appletsAppSecret}")
    private String wxAppletsAppSecret;

//    @Value("${wx.officialAccountAppid}")
    //    @Value("${wx.officialAccountAppid}")
    private String officialAccountAppid;

    @Value("{wx.officialAccountAppSecret}")
@@ -45,43 +45,41 @@
    private String webAppSecret;

    @Autowired
    private HttpClientUtil httpClientUtil;

    @Autowired
    private RestTemplate restTemplate;


    /**
     * 小程序使用jscode获取openid
     *
     * @param jscode
     * @return
     */
    public Map<String, Object> code2Session(String jscode) throws Exception{
    public Map<String, Object> code2Session(String jscode) throws Exception {
        String url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + wxAppletsAppid + "&secret=" + wxAppletsAppSecret
                + "&js_code=" + jscode + "&grant_type=authorization_code";
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if(null == httpResult || httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if (null == httpResult || httpResult.getCode() != 200) {
            return null;
        }
        JSONObject jsonObject = JSON.parseObject(httpResult.getData());
        int errcode = jsonObject.getIntValue("errcode");
        Map<String, Object> map = new HashMap<>();
        map.put("errcode", errcode);
        if(errcode == 0){//成功
        if (errcode == 0) {//成功
            map.put("openid", jsonObject.getString("openid"));
            map.put("sessionKey", jsonObject.getString("session_key"));
            map.put("unionid", jsonObject.getString("unionid"));
            return map;
        }
        if(errcode == -1){//系统繁忙，此时请开发者稍候再试
        if (errcode == -1) {//系统繁忙，此时请开发者稍候再试
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
        if(errcode == 40029){//code 无效
        if (errcode == 40029) {//code 无效
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
        if(errcode == 45011){//频率限制，每个用户每分钟100次
        if (errcode == 45011) {//频率限制，每个用户每分钟100次
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
@@ -91,12 +89,13 @@

    /**
     * 获取微信小程序token
     *
     * @return
     */
    public String getWxAppletsAccessToken() throws Exception{
    public String getWxAppletsAccessToken() throws Exception {
        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + wxAppletsAppid + "&secret=" + wxAppletsAppSecret;
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if(httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if (httpResult.getCode() != 200) {
            return "";
        }
        JSONObject jsonObject = JSON.parseObject(httpResult.getData());
@@ -106,34 +105,35 @@

    /**
     * 网站应用登录
     *
     * @param code
     * @return
     */
    public Map<String, String> webAccessToken(String code) throws Exception{
    public Map<String, String> webAccessToken(String code) throws Exception {
        String url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=" + webAppId + "&secret=" + webAppSecret + "&code=" + code + "&grant_type=authorization_code";
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if(httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if (httpResult.getCode() != 200) {
            return null;
        }
        JSONObject jsonObject = JSON.parseObject(httpResult.getData());
        int errcode = jsonObject.getIntValue("errcode");
        Map<String, String> map = new HashMap<>();
        if(errcode == 0){//成功
        if (errcode == 0) {//成功
            map.put("access_token", jsonObject.getString("access_token"));
            map.put("openid", jsonObject.getString("openid"));
            map.put("refresh_token", jsonObject.getString("refresh_token"));
            map.put("unionid", jsonObject.getString("unionid"));
            return map;
        }
        if(errcode == -1){//系统繁忙，此时请开发者稍候再试
        if (errcode == -1) {//系统繁忙，此时请开发者稍候再试
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
        if(errcode == 40029){//code 无效
        if (errcode == 40029) {//code 无效
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
        if(errcode == 45011){//频率限制，每个用户每分钟100次
        if (errcode == 45011) {//频率限制，每个用户每分钟100次
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
@@ -143,35 +143,36 @@

    /**
     * 获取微信个人信息
     *
     * @param access_token
     * @param openid
     * @return
     */
    public Map<String, Object> getUserInfo(String access_token, String openid) throws Exception{
    public Map<String, Object> getUserInfo(String access_token, String openid) throws Exception {
        String url = "https://api.weixin.qq.com/sns/userinfo?access_token=" + access_token + "&openid=" + openid;
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if(httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if (httpResult.getCode() != 200) {
            return null;
        }
        JSONObject jsonObject = JSON.parseObject(httpResult.getData());
        int errcode = jsonObject.getIntValue("errcode");
        Map<String, Object> map = new HashMap<>();
        if(errcode == 0){//成功
        if (errcode == 0) {//成功
            map.put("nickname", jsonObject.getString("nickname"));
            map.put("openid", jsonObject.getString("openid"));
            map.put("sex", jsonObject.getString("sex"));
            map.put("headimgurl", jsonObject.getString("headimgurl"));
            return map;
        }
        if(errcode == -1){//系统繁忙，此时请开发者稍候再试
        if (errcode == -1) {//系统繁忙，此时请开发者稍候再试
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
        if(errcode == 40029){//code 无效
        if (errcode == 40029) {//code 无效
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
        if(errcode == 45011){//频率限制，每个用户每分钟100次
        if (errcode == 45011) {//频率限制，每个用户每分钟100次
            map.put("msg", jsonObject.getString("errmsg"));
            return map;
        }
@@ -181,18 +182,19 @@

    /**
     * 公众号获取openid
     *
     * @param code
     * @return
     */
    public Map<String,Object> getOpenId(String code) throws Exception{
    public Map<String, Object> getOpenId(String code) throws Exception {
        if (code == null || code.length() == 0) {
            return null;
        }
        String grantType = "authorization_code";
        String params = "appid=" + officialAccountAppid + "&secret=" + officialAccountAppSecret + "&code=" + code + "&grant_type=" + grantType;
        System.out.println("sssss"+params);
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", "https://api.weixin.qq.com/sns/oauth2/access_token?" + params, null, null, "form");
        if(httpResult.getCode() != 200){
        System.out.println("sssss" + params);
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", "https://api.weixin.qq.com/sns/oauth2/access_token?" + params, null, null, "form");
        if (httpResult.getCode() != 200) {
            return null;
        }
        JSONObject json = JSON.parseObject(httpResult.getData());
@@ -202,9 +204,9 @@
        Integer expiresIn = json.getInteger("expires_in");
        String refresh_token = json.getString("refresh_token");
        String unionid = json.getString("unionid");
        Map<String,Object> map=new HashMap<>();
        map.put("openId",openId);
        map.put("accessToken",accessToken);
        Map<String, Object> map = new HashMap<>();
        map.put("openId", openId);
        map.put("accessToken", accessToken);
        map.put("expiresIn", expiresIn);
        map.put("refreshToken", refresh_token);
        map.put("unionid", unionid);
@@ -217,11 +219,11 @@
     * 来源www.vxzsk.com
     * @return
     */
    public String getAccessToken() throws Exception{
    public String getAccessToken() throws Exception {
        String url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + officialAccountAppid
                + "&secret=" + officialAccountAppSecret;
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if(httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if (httpResult.getCode() != 200) {
            return null;
        }
        String accessToken = JSONObject.parseObject(httpResult.getData()).getString("access_token");
@@ -233,25 +235,26 @@
     * 来源 www.vxzsk.com
     * @return
     */
    public String getJSApiTicket() throws Exception{
    public String getJSApiTicket() throws Exception {
        //获取token
        String acess_token= this.getAccessToken();
        String acess_token = this.getAccessToken();
        String urlStr = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=" + acess_token + "&type=jsapi";
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", urlStr, null, null, "form");
        if(httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", urlStr, null, null, "form");
        if (httpResult.getCode() != 200) {
            return null;
        }
        System.out.println(httpResult.getData());
        String ticket = JSONObject.parseObject(httpResult.getData()).getString("ticket");
        return  ticket;
        return ticket;
    }

    /**
     * 通过config接口注入权限验证配置(公众号)
     * 附录1-JS-SDK使用权限签名算法,
     *
     * @return
     */
    public Map<String,Object> getSignatureConfig(String url) throws Exception{
    public Map<String, Object> getSignatureConfig(String url) throws Exception {
        //获取token
        try {
            url = URLDecoder.decode(url, "UTF-8");
@@ -263,25 +266,26 @@
        Long timestamp = System.currentTimeMillis();
        String content = "jsapi_ticket=" + ticket + "&noncestr=" + noncestr + "&timestamp=" + timestamp + "&url=" + url;
        String signature = DigestUtils.sha1Hex(content);
        Map<String,Object> map=new HashMap<>();
        Map<String, Object> map = new HashMap<>();
        map.put("appId", officialAccountAppid);
        map.put("timestamp", timestamp);
        map.put("nonceStr", noncestr);
        map.put("signature", signature);
        return  map;
        return map;
    }


    /**
     * 公众号获取用户个人信息
     *
     * @param access_token
     * @param openid
     * @return
     */
    public Map<String, Object> queryUserInfo(String access_token, String openid) throws Exception{
    public Map<String, Object> queryUserInfo(String access_token, String openid) throws Exception {
        String url = "https://api.weixin.qq.com/sns/userinfo?access_token=" + access_token + "&openid=" + openid + "&lang=zh_CN";
        HttpResult httpResult = httpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if(httpResult.getCode() != 200){
        HttpResult httpResult = HttpClientUtil.pushHttpRequset("GET", url, null, null, "form");
        if (httpResult.getCode() != 200) {
            return null;
        }
        System.err.println(httpResult.getData());
@@ -297,13 +301,14 @@

    /**
     * 获取小程序二维码
     * @param page      跳转页 例如 pages/index/index
     * @param scene     参数 a=1&b=2
     *
     * @param page  跳转页 例如 pages/index/index
     * @param scene 参数 a=1&b=2
     */
    public InputStream getwxacodeunlimit(String page, String scene){
    public InputStream getwxacodeunlimit(String page, String scene) {
        try {
            String token = getWxAppletsAccessToken();
            if(ToolUtil.isEmpty(token)){
            if (ToolUtil.isEmpty(token)) {
                System.err.println("获取接口调用凭证失败");
            }
            String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + token;
@@ -311,17 +316,17 @@
            param.put("scene", scene);
            param.put("page", page);
            HttpHeaders httpHeaders = new HttpHeaders();
            MediaType type= MediaType.parseMediaType("application/json;charset=UTF-8");
            MediaType type = MediaType.parseMediaType("application/json;charset=UTF-8");
            httpHeaders.setContentType(type);
            HttpEntity<Map<String, Object>> requestEntity = new HttpEntity<>(param, httpHeaders);
            ResponseEntity<String> exchange = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class, new Object[0]);
            String body1 = exchange.getBody();
//            System.err.println(body1);
            ResponseEntity<byte[]> entity  = restTemplate.exchange(url, HttpMethod.POST, requestEntity, byte[].class, new Object[0]);
            ResponseEntity<byte[]> entity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, byte[].class, new Object[0]);
            byte[] body = entity.getBody();
//            System.err.println(Base64.encodeBase64String(body));
            return new ByteArrayInputStream(body);
        }catch (Exception e){
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;