10 changed files with 443 additions and 241 deletions
@ -1,66 +0,0 @@ |
|||
package com.ccsens.wechatutil.Service; |
|||
|
|||
import com.ccsens.wechatutil.bean.po.MiniProgramUser; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo; |
|||
import com.ccsens.wechatutil.bean.vo.WechatCode; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
public interface IWxService { |
|||
|
|||
/** |
|||
* 小程序登录 |
|||
* -- 从配置文件中获取默认appId |
|||
* 配置文件内的名称 h5.appId: 和 h5.secret: |
|||
* @param code code |
|||
* @return 返回当前用户的openId等 |
|||
*/ |
|||
MiniProgramUser signinByMini(String code); |
|||
|
|||
/** |
|||
* 小程序登录 -- 传入appId |
|||
* @param code code |
|||
* @param appId appId |
|||
* @param secret secret |
|||
* @return 返回当前用户的openId等 |
|||
*/ |
|||
MiniProgramUser signinByMini(String code, String appId, String secret); |
|||
|
|||
/** |
|||
* H5扫码登录，公众号登录 |
|||
* -- 从配置文件中获取默认appId |
|||
* 配置文件内的名称 h5.appId: 和 h5.secret: |
|||
* @param code code |
|||
* @return 返回微信用户信息 |
|||
*/ |
|||
WxOauth2UserInfo signinByH5(String code); |
|||
|
|||
/** |
|||
* H5扫码登录，公众号登录 -- 传入appId |
|||
* @param code code |
|||
* @param appId appId |
|||
* @param secret secret |
|||
* @return 返回微信用户信息 |
|||
*/ |
|||
WxOauth2UserInfo signinByH5(String code, String appId, String secret); |
|||
|
|||
|
|||
/** |
|||
* 生成小程序码，使用方案B |
|||
* @param page |
|||
* @param scene |
|||
* @param color |
|||
* @param path |
|||
* @param code |
|||
*/ |
|||
void getWxCodeB(String page, String scene, WechatCode.LineColor color, String path, String code); |
|||
|
|||
/** |
|||
* 生成小程序码，使用方案B |
|||
* @param page |
|||
* @param path |
|||
* @param code |
|||
*/ |
|||
void getWxCodeC(String page, String path, String code); |
|||
} |
|||
@ -1,145 +0,0 @@ |
|||
package com.ccsens.wechatutil.Service; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import cn.hutool.http.HttpRequest; |
|||
import com.ccsens.util.DateUtil; |
|||
import com.ccsens.util.JacksonUtil; |
|||
import com.ccsens.util.exception.BaseException; |
|||
import com.ccsens.wechatutil.Util.WxCodeError; |
|||
import com.ccsens.wechatutil.Util.WxConstant; |
|||
import com.ccsens.wechatutil.bean.po.MiniProgramUser; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2AccessToken; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo; |
|||
import com.ccsens.wechatutil.bean.vo.WechatCode; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.transaction.annotation.Propagation; |
|||
import org.springframework.transaction.annotation.Transactional; |
|||
|
|||
import java.io.IOException; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
@Service |
|||
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class) |
|||
public class WxService implements IWxService { |
|||
|
|||
@Value("${mini.appId:}") |
|||
private String miniAppId; |
|||
@Value("${mini.secret:}") |
|||
private String miniSecret; |
|||
@Value("${h5.appId:}") |
|||
private String appIdH5; |
|||
@Value("${h5.secret:}") |
|||
private String secretH5; |
|||
|
|||
@Override |
|||
public MiniProgramUser signinByMini(String code) { |
|||
return signinByMini(code,miniAppId,miniSecret); |
|||
} |
|||
|
|||
@Override |
|||
public MiniProgramUser signinByMini(String code, String appId, String secret) { |
|||
MiniProgramUser wxUser; |
|||
//拼接wx的访问的路径
|
|||
String url = String.format(WxConstant.MINI_PROGRAM_LOGIN, appId, secret, code, WxConstant.GRANT_TYPE); |
|||
//调用微信的接口
|
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("url: {}\nresponse: {}",url,response); |
|||
try { |
|||
if(StrUtil.isEmpty(response) || null == (wxUser = JacksonUtil.jsonToBean(response, MiniProgramUser.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(-1,e.getMessage()); |
|||
} |
|||
if(null != wxUser.errcode){ |
|||
throw new BaseException(wxUser.errcode, wxUser.errmsg); |
|||
} |
|||
return wxUser; |
|||
} |
|||
|
|||
@Override |
|||
public WxOauth2UserInfo signinByH5(String code) { |
|||
return signinByH5(code, appIdH5, secretH5); |
|||
} |
|||
|
|||
@Override |
|||
public WxOauth2UserInfo signinByH5(String code, String appId, String secret) { |
|||
//获取accessToken
|
|||
WxOauth2AccessToken wxOauth2AccessToken = getOauth2AccessToken(code, appId, secret); |
|||
//获取用户信息
|
|||
return getOauth2UserInfo(wxOauth2AccessToken.getAccessToken(),wxOauth2AccessToken.getOpenId()); |
|||
} |
|||
|
|||
/** |
|||
* 获取网页授权凭证 |
|||
* @param code OAuth2授权码 |
|||
* @return WxOauth2AccessToken |
|||
*/ |
|||
private static WxOauth2AccessToken getOauth2AccessToken(String code, String appId, String secret) { |
|||
WxOauth2AccessToken wxOauth2AccessToken; |
|||
//拼接访问路径
|
|||
String url = String.format(WxConstant.URL_GET_OAUTH2_ACCESS_TOKEN,appId,secret,code); |
|||
//调用微信接口
|
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("url: {}\nresponse: {}",url,response); |
|||
try { |
|||
if(StrUtil.isEmpty(response) || null == (wxOauth2AccessToken = JacksonUtil.jsonToBean(response,WxOauth2AccessToken.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(-1,e.getMessage()); |
|||
} |
|||
if(null != wxOauth2AccessToken.getErrcode()){ |
|||
throw new BaseException(wxOauth2AccessToken.getErrcode(),wxOauth2AccessToken.getErrmsg()); |
|||
} |
|||
if (StrUtil.isEmpty(wxOauth2AccessToken.getAccessToken())) { |
|||
throw new BaseException(WxCodeError.ACCESS_TOKEN_ERROR); |
|||
} |
|||
wxOauth2AccessToken.setCreatedAt(DateUtil.currentSeconds()); |
|||
return wxOauth2AccessToken; |
|||
} |
|||
|
|||
/** |
|||
* 通过网页授权accessToken获取用户信息 |
|||
* @param accessToken 网页授权接口调用凭证 |
|||
* @param openId 用户标识 |
|||
* @return SNSUserInfo |
|||
*/ |
|||
public static WxOauth2UserInfo getOauth2UserInfo(String accessToken, String openId){ |
|||
WxOauth2UserInfo wxOauth2UserInfo; |
|||
//拼接访问路径
|
|||
String url = String.format(WxConstant.URL_GET_OAUTH2_USER_INFO,accessToken,openId); |
|||
//调用微信接口
|
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("url: {}\nresponse: {}",url,response); |
|||
try { |
|||
if(StrUtil.isEmpty(response) || null == (wxOauth2UserInfo = JacksonUtil.jsonToBean(response, WxOauth2UserInfo.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(-1,e.getMessage()); |
|||
} |
|||
if(null != wxOauth2UserInfo.getErrcode()){ |
|||
throw new BaseException(wxOauth2UserInfo.getErrcode(),wxOauth2UserInfo.getErrmsg()); |
|||
} |
|||
if (StrUtil.isEmpty(wxOauth2UserInfo.getOpenId())) { |
|||
throw new BaseException(WxCodeError.OPENID_ERROR); |
|||
} |
|||
return wxOauth2UserInfo; |
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeB(String page, String scene, WechatCode.LineColor color, String path, String code) { |
|||
|
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeC(String page, String path, String code) { |
|||
|
|||
} |
|||
} |
|||
@ -0,0 +1,105 @@ |
|||
package com.ccsens.wechatutil.service; |
|||
|
|||
import com.ccsens.wechatutil.bean.po.MiniProgramUser; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo; |
|||
import com.ccsens.wechatutil.bean.vo.WechatCode; |
|||
import com.fasterxml.jackson.core.JsonProcessingException; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
public interface IWxService { |
|||
|
|||
/** |
|||
* 小程序登录 |
|||
* -- 从配置文件中获取默认appId |
|||
* 配置文件内的名称 h5.appId: 和 h5.secret: |
|||
* @param code code |
|||
* @return 返回当前用户的openId等 |
|||
*/ |
|||
MiniProgramUser signinByMini(String code); |
|||
|
|||
/** |
|||
* 小程序登录 -- 传入appId |
|||
* @param code code |
|||
* @param appId appId |
|||
* @param secret secret |
|||
* @return 返回当前用户的openId等 |
|||
*/ |
|||
MiniProgramUser signinByMini(String code, String appId, String secret); |
|||
|
|||
/** |
|||
* H5扫码登录，公众号登录 |
|||
* -- 从配置文件中获取默认appId |
|||
* 配置文件内的名称 h5.appId: 和 h5.secret: |
|||
* @param code code |
|||
* @return 返回微信用户信息 |
|||
*/ |
|||
WxOauth2UserInfo signinByH5(String code); |
|||
|
|||
/** |
|||
* H5扫码登录，公众号登录 -- 传入appId |
|||
* @param code code |
|||
* @param appId appId |
|||
* @param secret secret |
|||
* @return 返回微信用户信息 |
|||
*/ |
|||
WxOauth2UserInfo signinByH5(String code, String appId, String secret); |
|||
|
|||
/** |
|||
* 获取小程序码--方案A，可接受 path 参数较长，生成个数受限 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* 使用默认appId |
|||
* @param wechatCodeA 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
*/ |
|||
void getWxCodeA(WechatCode.WechatCodeA wechatCodeA,String path) throws Exception; |
|||
|
|||
/** |
|||
* 获取小程序码--方案A，可接受 path 参数较长，生成个数受限 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* @param wechatCodeA 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
* @param appId appId |
|||
* @param secret secret |
|||
*/ |
|||
void getWxCodeA(WechatCode.WechatCodeA wechatCodeA,String path, String appId, String secret) throws Exception; |
|||
|
|||
/** |
|||
* 获取小程序码--方案B，可接受页面参数较短，生成个数不受限。 |
|||
* 接口 B 调用分钟频率受限(5000次/分钟)，如需大量小程序码，建议预生成 |
|||
* 使用默认appId |
|||
* @param wechatCodeB 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
*/ |
|||
void getWxCodeB(WechatCode.WechatCodeB wechatCodeB,String path) throws Exception; |
|||
|
|||
/** |
|||
* 获取小程序码--方案B，可接受页面参数较短，生成个数不受限。 |
|||
* 接口 B 调用分钟频率受限(5000次/分钟)，如需大量小程序码，建议预生成 |
|||
* @param wechatCodeB 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
* @param appId appId |
|||
* @param secret secret |
|||
*/ |
|||
void getWxCodeB(WechatCode.WechatCodeB wechatCodeB,String path, String appId, String secret) throws Exception; |
|||
|
|||
/** |
|||
* 方案C-生成小程序码(二维码)，可接受 path 参数较长，生成个数受限，数量限制见 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* 使用默认appId |
|||
* @param wechatCodeC 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
*/ |
|||
void getWxCodeC(WechatCode.WechatCodeC wechatCodeC,String path) throws Exception; |
|||
|
|||
/** |
|||
* 方案C-生成小程序码(二维码)，可接受 path 参数较长，生成个数受限，数量限制见 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* @param wechatCodeC 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
* @param appId appId |
|||
* @param secret secret |
|||
*/ |
|||
void getWxCodeC(WechatCode.WechatCodeC wechatCodeC,String path, String appId, String secret) throws Exception; |
|||
} |
|||
@ -0,0 +1,274 @@ |
|||
package com.ccsens.wechatutil.service; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import cn.hutool.http.HttpRequest; |
|||
import com.ccsens.util.*; |
|||
import com.ccsens.util.bean.wx.po.WxAccessToken; |
|||
import com.ccsens.util.exception.BaseException; |
|||
import com.ccsens.util.exception.BusinessException; |
|||
import com.ccsens.util.exception.WxException; |
|||
import com.ccsens.util.wx.WxGzhUtil; |
|||
import com.ccsens.util.wx.WxXcxUtil; |
|||
import com.ccsens.wechatutil.bean.po.WxBaseEntity; |
|||
import com.ccsens.wechatutil.util.WxCodeError; |
|||
import com.ccsens.wechatutil.util.WxConstant; |
|||
import com.ccsens.wechatutil.bean.po.MiniProgramUser; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2AccessToken; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo; |
|||
import com.ccsens.wechatutil.bean.vo.WechatCode; |
|||
import com.fasterxml.jackson.core.JsonProcessingException; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.transaction.annotation.Propagation; |
|||
import org.springframework.transaction.annotation.Transactional; |
|||
|
|||
import javax.annotation.Resource; |
|||
import javax.net.ssl.HttpsURLConnection; |
|||
import javax.net.ssl.SSLContext; |
|||
import javax.net.ssl.SSLSocketFactory; |
|||
import javax.net.ssl.TrustManager; |
|||
import java.io.*; |
|||
import java.net.URL; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
@Service |
|||
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class) |
|||
public class WxService implements IWxService { |
|||
|
|||
@Resource |
|||
private RedisUtil redisUtil; |
|||
|
|||
@Value("${mini.appId:}") |
|||
private String miniAppId; |
|||
@Value("${mini.secret:}") |
|||
private String miniSecret; |
|||
@Value("${h5.appId:}") |
|||
private String appIdH5; |
|||
@Value("${h5.secret:}") |
|||
private String secretH5; |
|||
|
|||
@Override |
|||
public MiniProgramUser signinByMini(String code) { |
|||
return signinByMini(code, miniAppId, miniSecret); |
|||
} |
|||
|
|||
@Override |
|||
public MiniProgramUser signinByMini(String code, String appId, String secret) { |
|||
MiniProgramUser wxUser; |
|||
//拼接wx的访问的路径
|
|||
String url = String.format(WxConstant.MINI_PROGRAM_LOGIN, appId, secret, code, WxConstant.GRANT_TYPE); |
|||
//调用微信的接口
|
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("url: {}\nresponse: {}", url, response); |
|||
try { |
|||
if (StrUtil.isEmpty(response) || null == (wxUser = JacksonUtil.jsonToBean(response, MiniProgramUser.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(e.getMessage()); |
|||
} |
|||
if (null != wxUser.errcode) { |
|||
throw new BaseException(wxUser.errcode, wxUser.errmsg); |
|||
} |
|||
return wxUser; |
|||
} |
|||
|
|||
@Override |
|||
public WxOauth2UserInfo signinByH5(String code) { |
|||
return signinByH5(code, appIdH5, secretH5); |
|||
} |
|||
|
|||
@Override |
|||
public WxOauth2UserInfo signinByH5(String code, String appId, String secret) { |
|||
//获取accessToken
|
|||
WxOauth2AccessToken wxOauth2AccessToken = getOauth2AccessToken(code, appId, secret); |
|||
//获取用户信息
|
|||
return getOauth2UserInfo(wxOauth2AccessToken.getAccessToken(), wxOauth2AccessToken.getOpenId()); |
|||
} |
|||
|
|||
|
|||
|
|||
@Override |
|||
public void getWxCodeA(WechatCode.WechatCodeA wechatCodeA, String path)throws Exception { |
|||
getWxCodeA(wechatCodeA,path,miniAppId,miniSecret); |
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeA(WechatCode.WechatCodeA wechatCodeA, String path, String appId, String secret) throws Exception { |
|||
String url = String.format(WxConstant.URL_GET_WX_CODE_A, getAccessToken(appId, secret)); |
|||
log.info("调用生成二维码路径和accessToken：{}", url); |
|||
String postStr = JacksonUtil.beanToJson(wechatCodeA); |
|||
log.info("二维码的参数：{}", postStr); |
|||
//调用微信接口在指定位置生成图片
|
|||
httpWxCode(path, url, postStr); |
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeB(WechatCode.WechatCodeB wechatCodeB, String path)throws Exception { |
|||
getWxCodeB(wechatCodeB,path,miniAppId, miniSecret); |
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeB(WechatCode.WechatCodeB wechatCodeB, String path, String appId, String secret) throws Exception { |
|||
String url = String.format(WxConstant.URL_GET_WX_CODE_B, getAccessToken(appId, secret)); |
|||
log.info("调用生成二维码路径和accessToken：{}", url); |
|||
String postStr = JacksonUtil.beanToJson(wechatCodeB); |
|||
log.info("二维码的参数：{}", postStr); |
|||
//调用微信接口在指定位置生成图片
|
|||
httpWxCode(path, url, postStr); |
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeC(WechatCode.WechatCodeC wechatCodeC, String path) throws Exception { |
|||
getWxCodeC(wechatCodeC,path,miniAppId, miniSecret); |
|||
} |
|||
|
|||
@Override |
|||
public void getWxCodeC(WechatCode.WechatCodeC wechatCodeC, String path, String appId, String secret) throws Exception { |
|||
String url = String.format(WxConstant.URL_GET_WX_CODE_C, getAccessToken(appId, secret)); |
|||
log.info("调用生成二维码路径和accessToken：{}", url); |
|||
String postStr = JacksonUtil.beanToJson(wechatCodeC); |
|||
log.info("二维码的参数：{}", postStr); |
|||
//调用微信接口在指定位置生成图片
|
|||
httpWxCode(path, url, postStr); |
|||
} |
|||
|
|||
/** |
|||
* 获取网页授权凭证 |
|||
* |
|||
* @param code OAuth2授权码 |
|||
* @return WxOauth2AccessToken |
|||
*/ |
|||
private WxOauth2AccessToken getOauth2AccessToken(String code, String appId, String secret) { |
|||
WxOauth2AccessToken wxOauth2AccessToken; |
|||
//拼接访问路径
|
|||
String url = String.format(WxConstant.URL_GET_OAUTH2_ACCESS_TOKEN, appId, secret, code); |
|||
//调用微信接口
|
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("url: {}\nresponse: {}", url, response); |
|||
try { |
|||
if (StrUtil.isEmpty(response) || null == (wxOauth2AccessToken = JacksonUtil.jsonToBean(response, WxOauth2AccessToken.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(e.getMessage()); |
|||
} |
|||
if (null != wxOauth2AccessToken.getErrcode()) { |
|||
throw new BaseException(wxOauth2AccessToken.getErrcode(), wxOauth2AccessToken.getErrmsg()); |
|||
} |
|||
if (StrUtil.isEmpty(wxOauth2AccessToken.getAccessToken())) { |
|||
throw new BaseException(WxCodeError.ACCESS_TOKEN_ERROR); |
|||
} |
|||
wxOauth2AccessToken.setCreatedAt(DateUtil.currentSeconds()); |
|||
return wxOauth2AccessToken; |
|||
} |
|||
|
|||
/** |
|||
* 通过网页授权accessToken获取用户信息 |
|||
* |
|||
* @param accessToken 网页授权接口调用凭证 |
|||
* @param openId 用户标识 |
|||
* @return SNSUserInfo |
|||
*/ |
|||
private WxOauth2UserInfo getOauth2UserInfo(String accessToken, String openId) { |
|||
WxOauth2UserInfo wxOauth2UserInfo; |
|||
//拼接访问路径
|
|||
String url = String.format(WxConstant.URL_GET_OAUTH2_USER_INFO, accessToken, openId); |
|||
//调用微信接口
|
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("url: {}\nresponse: {}", url, response); |
|||
try { |
|||
if (StrUtil.isEmpty(response) || null == (wxOauth2UserInfo = JacksonUtil.jsonToBean(response, WxOauth2UserInfo.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(e.getMessage()); |
|||
} |
|||
if (null != wxOauth2UserInfo.getErrcode()) { |
|||
throw new BaseException(wxOauth2UserInfo.getErrcode(), wxOauth2UserInfo.getErrmsg()); |
|||
} |
|||
if (StrUtil.isEmpty(wxOauth2UserInfo.getOpenId())) { |
|||
throw new BaseException(WxCodeError.OPENID_ERROR); |
|||
} |
|||
return wxOauth2UserInfo; |
|||
} |
|||
|
|||
/** |
|||
* 调用微信的接口在指定位置生成二维码 |
|||
* @param path 图片储存位置 |
|||
* @param url 微信接口路径 |
|||
* @param postStr 传入参数 |
|||
* @throws Exception 异常 |
|||
*/ |
|||
public void httpWxCode(String path, String url, String postStr) throws Exception { |
|||
WxBaseEntity wxBaseEntity; |
|||
String response = HttpsUtil.httpsRequest(url, "POST", postStr); |
|||
if(StrUtil.isEmpty(response)){ |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
try { |
|||
if (null == (wxBaseEntity = JacksonUtil.jsonToBean(response, WxBaseEntity.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
if (null != wxBaseEntity.getErrcode()) { |
|||
throw new BaseException(wxBaseEntity.getErrcode(), wxBaseEntity.getErrmsg()); |
|||
} |
|||
} catch (IOException e) { |
|||
// 从输入流读取返回内容
|
|||
File file = new File(path); |
|||
if (!file.getParentFile().exists()) { |
|||
file.getParentFile().mkdirs(); |
|||
} |
|||
InputStream inputStream = new ByteArrayInputStream(response.getBytes()); |
|||
BufferedInputStream bis = new BufferedInputStream(inputStream); |
|||
OutputStream os = new FileOutputStream(file); |
|||
int len; |
|||
byte[] arr = new byte[1024]; |
|||
while ((len = bis.read(arr)) != -1) |
|||
{ |
|||
os.write(arr, 0, len); |
|||
os.flush(); |
|||
} |
|||
os.close(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 小程序获取Access_token |
|||
*/ |
|||
private String getAccessToken(String appId, String secret) throws BaseException { |
|||
log.info("获取accessToken，appid：{}", appId.substring(appId.length() - 4)); |
|||
Object obj = redisUtil.get(WxConstant.ACCESS_TOKEN + appId); |
|||
if (obj == null || StrUtil.isBlank((String) obj)) { |
|||
WxAccessToken wxAccessToken; |
|||
String url = String.format(WxConstant.URL_GET_ACCESS_TOKEN, "client_credential", appId, secret); |
|||
String response = HttpRequest.get(url).execute().body(); |
|||
log.info("getAccessToken: {}", response); |
|||
try { |
|||
if (StrUtil.isEmpty(response) || null == (wxAccessToken = JacksonUtil.jsonToBean(response, WxAccessToken.class))) { |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
} catch (IOException e) { |
|||
throw new BaseException(e.getMessage()); |
|||
} |
|||
|
|||
if (null != wxAccessToken.getErrcode()) { |
|||
throw new BaseException(wxAccessToken.getErrcode(), wxAccessToken.getErrmsg()); |
|||
} |
|||
if (StrUtil.isEmpty(wxAccessToken.getAccessToken())) { |
|||
throw new BaseException(WxCodeError.ACCESS_TOKEN_ERROR); |
|||
} |
|||
redisUtil.set(WebConstant.Wx.ACCESS_TOKEN + appId, wxAccessToken.getAccessToken(), WebConstant.Wx.EXPIRE_TIME); |
|||
log.info("存储access_token:{}", wxAccessToken.getAccessToken()); |
|||
return wxAccessToken.getAccessToken(); |
|||
} |
|||
log.info("读取reids的token:{}", obj); |
|||
return (String) obj; |
|||
} |
|||
|
|||
|
|||
} |
|||
@ -1,4 +1,4 @@ |
|||
package com.ccsens.wechatutil.Util; |
|||
package com.ccsens.wechatutil.util; |
|||
|
|||
import com.ccsens.util.CodeError; |
|||
|
|||
Loading…
Reference in new issue