14 changed files with 686 additions and 513 deletions
@ -1,80 +1,80 @@ |
|||
package com.ccsens.wechatutil.api; |
|||
|
|||
import com.ccsens.util.JsonResponse; |
|||
import com.ccsens.wechatutil.bean.dto.WxMessageDto; |
|||
import com.ccsens.wechatutil.service.IWxMessageService; |
|||
import com.ccsens.wechatutil.service.IWxService; |
|||
import com.ccsens.wechatutil.bean.po.MiniProgramUser; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo; |
|||
import com.ccsens.wechatutil.bean.dto.WechatCode; |
|||
import io.swagger.annotations.Api; |
|||
import io.swagger.annotations.ApiOperation; |
|||
import io.swagger.annotations.ApiParam; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.validation.annotation.Validated; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RequestMethod; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
import javax.annotation.Resource; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Api(tags = "DEBUG" , description = "DebugController | ") |
|||
@RestController |
|||
@RequestMapping("/wx") |
|||
@Slf4j |
|||
public class WxController { |
|||
|
|||
@Resource |
|||
private IWxService miniProgramService; |
|||
@Resource |
|||
private IWxMessageService wxMessageService; |
|||
|
|||
@ApiOperation(value = "小程序根据code获取appId", notes = "小程序") |
|||
@RequestMapping(value = "/signinByMini", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse signinByMini(@ApiParam @Validated String code) throws Exception{ |
|||
MiniProgramUser wxUser = miniProgramService.signinByMini(code); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
@ApiOperation(value = "公众号/网页二维码登录", notes = "公众号/网页二维码") |
|||
@RequestMapping(value = "/signinByH5", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse signinByH5(@ApiParam @Validated String code) throws Exception{ |
|||
WxOauth2UserInfo wxUser = miniProgramService.signinByH5(code); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
@ApiOperation(value = "生成小程序码-方案A", notes = "") |
|||
@RequestMapping(value = "/getWxCodeA", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse getWxCodeA(@ApiParam @Validated WechatCode.WechatCodeA wechatCodeA, String path) throws Exception{ |
|||
miniProgramService.getWxCodeA(wechatCodeA, path); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
|
|||
@ApiOperation(value = "生成小程序码-方案B", notes = "") |
|||
@RequestMapping(value = "/getWxCodeB", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse getWxCodeB(@ApiParam @Validated WechatCode.WechatCodeB wechatCodeB,String path) throws Exception{ |
|||
wechatCodeB = new WechatCode.WechatCodeB(); |
|||
wechatCodeB.setScene("id=1&type=SQ"); |
|||
wechatCodeB.setPage("pages/index/index"); |
|||
miniProgramService.getWxCodeB(wechatCodeB,path); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
@ApiOperation(value = "生成小程序码-方案B", notes = "") |
|||
@RequestMapping(value = "/getWxCodeC", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse getWxCodeC(@ApiParam @Validated WechatCode.WechatCodeC wechatCodeC,String path) throws Exception{ |
|||
miniProgramService.getWxCodeC(wechatCodeC,path); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
|
|||
@ApiOperation(value = "群机器人发送消息", notes = "") |
|||
@RequestMapping(value = "/robotMessage", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) |
|||
public JsonResponse robotMessage(@ApiParam @Validated WxMessageDto.RobotMessage robotMessage) throws Exception{ |
|||
wxMessageService.sendRobotInfo(robotMessage); |
|||
return JsonResponse.newInstance().ok(); |
|||
} |
|||
} |
|||
//package com.ccsens.wechatutil.api;
|
|||
//
|
|||
//import com.ccsens.util.JsonResponse;
|
|||
//import com.ccsens.wechatutil.bean.dto.WxMessageDto;
|
|||
//import com.ccsens.wechatutil.service.IWxMessageService;
|
|||
//import com.ccsens.wechatutil.service.IWxService;
|
|||
//import com.ccsens.wechatutil.bean.po.MiniProgramUser;
|
|||
//import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo;
|
|||
//import com.ccsens.wechatutil.bean.dto.WechatCode;
|
|||
//import io.swagger.annotations.Api;
|
|||
//import io.swagger.annotations.ApiOperation;
|
|||
//import io.swagger.annotations.ApiParam;
|
|||
//import lombok.extern.slf4j.Slf4j;
|
|||
//import org.springframework.validation.annotation.Validated;
|
|||
//import org.springframework.web.bind.annotation.RequestMapping;
|
|||
//import org.springframework.web.bind.annotation.RequestMethod;
|
|||
//import org.springframework.web.bind.annotation.RestController;
|
|||
//
|
|||
//import javax.annotation.Resource;
|
|||
//
|
|||
///**
|
|||
// * @author 逗
|
|||
// */
|
|||
//@Api(tags = "DEBUG" , description = "DebugController | ")
|
|||
//@RestController
|
|||
//@RequestMapping("/wx")
|
|||
//@Slf4j
|
|||
//public class WxController {
|
|||
//
|
|||
// @Resource
|
|||
// private IWxService miniProgramService;
|
|||
// @Resource
|
|||
// private IWxMessageService wxMessageService;
|
|||
//
|
|||
// @ApiOperation(value = "小程序根据code获取appId", notes = "小程序")
|
|||
// @RequestMapping(value = "/signinByMini", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
|
|||
// public JsonResponse signinByMini(@ApiParam @Validated String code) throws Exception{
|
|||
// MiniProgramUser wxUser = miniProgramService.signinByMini(code);
|
|||
// return JsonResponse.newInstance().ok();
|
|||
// }
|
|||
//
|
|||
// @ApiOperation(value = "公众号/网页二维码登录", notes = "公众号/网页二维码")
|
|||
// @RequestMapping(value = "/signinByH5", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
|
|||
// public JsonResponse signinByH5(@ApiParam @Validated String code) throws Exception{
|
|||
// WxOauth2UserInfo wxUser = miniProgramService.signinByH5(code);
|
|||
// return JsonResponse.newInstance().ok();
|
|||
// }
|
|||
//
|
|||
// @ApiOperation(value = "生成小程序码-方案A", notes = "")
|
|||
// @RequestMapping(value = "/getWxCodeA", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
|
|||
// public JsonResponse getWxCodeA(@ApiParam @Validated WechatCode.WechatCodeA wechatCodeA, String path) throws Exception{
|
|||
// miniProgramService.getWxCodeA(wechatCodeA, path);
|
|||
// return JsonResponse.newInstance().ok();
|
|||
// }
|
|||
//
|
|||
//
|
|||
// @ApiOperation(value = "生成小程序码-方案B", notes = "")
|
|||
// @RequestMapping(value = "/getWxCodeB", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
|
|||
// public JsonResponse getWxCodeB(@ApiParam @Validated WechatCode.WechatCodeB wechatCodeB,String path) throws Exception{
|
|||
// wechatCodeB = new WechatCode.WechatCodeB();
|
|||
// wechatCodeB.setScene("id=1&type=SQ");
|
|||
// wechatCodeB.setPage("pages/index/index");
|
|||
// miniProgramService.getWxCodeB(wechatCodeB,path);
|
|||
// return JsonResponse.newInstance().ok();
|
|||
// }
|
|||
//
|
|||
// @ApiOperation(value = "生成小程序码-方案B", notes = "")
|
|||
// @RequestMapping(value = "/getWxCodeC", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
|
|||
// public JsonResponse getWxCodeC(@ApiParam @Validated WechatCode.WechatCodeC wechatCodeC,String path) throws Exception{
|
|||
// miniProgramService.getWxCodeC(wechatCodeC,path);
|
|||
// return JsonResponse.newInstance().ok();
|
|||
// }
|
|||
//
|
|||
// @ApiOperation(value = "群机器人发送消息", notes = "")
|
|||
// @RequestMapping(value = "/robotMessage", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
|
|||
// public JsonResponse robotMessage(@ApiParam @Validated WxMessageDto.RobotMessage robotMessage) throws Exception{
|
|||
// wxMessageService.sendRobotInfo(robotMessage);
|
|||
// return JsonResponse.newInstance().ok();
|
|||
// }
|
|||
//}
|
|||
|
|||
@ -1,12 +0,0 @@ |
|||
package com.ccsens.wechatutil.service; |
|||
|
|||
import com.ccsens.wechatutil.bean.dto.WxMessageDto; |
|||
|
|||
public interface IWxMessageService { |
|||
/** |
|||
* 群机器人发送消息 |
|||
* @param robotMessage |
|||
* @throws Exception |
|||
*/ |
|||
void sendRobotInfo(WxMessageDto.RobotMessage robotMessage)throws Exception; |
|||
} |
|||
@ -1,104 +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.dto.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); |
|||
|
|||
/** |
|||
* 获取小程序码--方案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; |
|||
} |
|||
@ -1,266 +0,0 @@ |
|||
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.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.dto.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 javax.annotation.Resource; |
|||
import java.io.*; |
|||
|
|||
/** |
|||
* @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.getErrcode()) { |
|||
throw new BaseException(wxUser.getErrcode(), wxUser.getErrmsg()); |
|||
} |
|||
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 { |
|||
// HttpsUtil.httpsRequest(url, "POST", postStr,path);
|
|||
WxBaseEntity wxBaseEntity; |
|||
byte[] response = HttpsUtil.httpsRequestByte(url, "POST", postStr); |
|||
|
|||
if(response.length == 0){ |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
try { |
|||
if (null == (wxBaseEntity = JacksonUtil.jsonToBean(new String(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); |
|||
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; |
|||
} |
|||
|
|||
|
|||
} |
|||
@ -0,0 +1,67 @@ |
|||
package com.ccsens.wechatutil.wxcommon; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import cn.hutool.http.HttpRequest; |
|||
import com.ccsens.util.JacksonUtil; |
|||
import com.ccsens.util.RedisUtil; |
|||
import com.ccsens.util.WebConstant; |
|||
import com.ccsens.util.bean.wx.po.WxAccessToken; |
|||
import com.ccsens.util.exception.BaseException; |
|||
import com.ccsens.wechatutil.util.WxCodeError; |
|||
import com.ccsens.wechatutil.util.WxConstant; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
|
|||
import javax.annotation.PostConstruct; |
|||
import javax.annotation.Resource; |
|||
import java.io.IOException; |
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
public class WxCommonUtil { |
|||
|
|||
|
|||
@Resource |
|||
private RedisUtil redisUtil; |
|||
|
|||
private static WxCommonUtil util; |
|||
|
|||
@PostConstruct |
|||
public void init(){ |
|||
util = this; |
|||
} |
|||
|
|||
|
|||
/** |
|||
* 小程序获取Access_token |
|||
*/ |
|||
public static String getAccessToken(String appId, String secret) throws BaseException { |
|||
log.info("获取accessToken，appid：{}", appId.substring(appId.length() - 4)); |
|||
Object obj = util.redisUtil.get(WxConstant.ACCESS_TOKEN + appId); |
|||
if (obj == null || StrUtil.isBlank((String) obj)) { |
|||
WxAccessToken wxAccessToken; |
|||
String url = String.format(WxConstant.URL_GET_ACCESS_TOKEN, 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); |
|||
} |
|||
util.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; |
|||
} |
|||
} |
|||
@ -0,0 +1,151 @@ |
|||
package com.ccsens.wechatutil.wxmini; |
|||
|
|||
import com.ccsens.util.HttpsUtil; |
|||
import com.ccsens.util.JacksonUtil; |
|||
import com.ccsens.util.exception.BaseException; |
|||
import com.ccsens.wechatutil.bean.dto.WechatCode; |
|||
import com.ccsens.wechatutil.bean.po.WxBaseEntity; |
|||
import com.ccsens.wechatutil.util.WxCodeError; |
|||
import com.ccsens.wechatutil.util.WxConstant; |
|||
import com.ccsens.wechatutil.wxcommon.WxCommonUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
|
|||
import java.io.*; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
public class MiniCode { |
|||
|
|||
@Value("${mini.appId:}") |
|||
private static String miniAppId; |
|||
@Value("${mini.secret:}") |
|||
private static String miniSecret; |
|||
|
|||
/** |
|||
* 获取小程序码--方案A，可接受 path 参数较长，生成个数受限 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* 使用默认appId |
|||
* @param wechatCodeA 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
*/ |
|||
public static void getWxCodeA(WechatCode.WechatCodeA wechatCodeA, String path)throws Exception { |
|||
getWxCodeA(wechatCodeA,path,miniAppId,miniSecret); |
|||
} |
|||
|
|||
/** |
|||
* 获取小程序码--方案A，可接受 path 参数较长，生成个数受限 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* @param wechatCodeA 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
* @param appId appId |
|||
* @param secret secret |
|||
*/ |
|||
public static void getWxCodeA(WechatCode.WechatCodeA wechatCodeA, String path, String appId, String secret) throws Exception { |
|||
String url = String.format(WxConstant.URL_GET_WX_CODE_A, WxCommonUtil.getAccessToken(appId, secret)); |
|||
log.info("调用生成二维码路径和accessToken：{}", url); |
|||
String postStr = JacksonUtil.beanToJson(wechatCodeA); |
|||
log.info("二维码的参数：{}", postStr); |
|||
//调用微信接口在指定位置生成图片
|
|||
httpWxCode(path, url, postStr); |
|||
} |
|||
|
|||
/** |
|||
* 获取小程序码--方案B，可接受页面参数较短，生成个数不受限。 |
|||
* 接口 B 调用分钟频率受限(5000次/分钟)，如需大量小程序码，建议预生成 |
|||
* 使用默认appId |
|||
* @param wechatCodeB 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
*/ |
|||
public static void getWxCodeB(WechatCode.WechatCodeB wechatCodeB, String path)throws Exception { |
|||
getWxCodeB(wechatCodeB,path,miniAppId, miniSecret); |
|||
} |
|||
|
|||
/** |
|||
* 获取小程序码--方案B，可接受页面参数较短，生成个数不受限。 |
|||
* 接口 B 调用分钟频率受限(5000次/分钟)，如需大量小程序码，建议预生成 |
|||
* @param wechatCodeB 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
* @param appId appId |
|||
* @param secret secret |
|||
*/ |
|||
public static void getWxCodeB(WechatCode.WechatCodeB wechatCodeB, String path, String appId, String secret) throws Exception { |
|||
String url = String.format(WxConstant.URL_GET_WX_CODE_B, WxCommonUtil.getAccessToken(appId, secret)); |
|||
log.info("调用生成二维码路径和accessToken：{}", url); |
|||
String postStr = JacksonUtil.beanToJson(wechatCodeB); |
|||
log.info("二维码的参数：{}", postStr); |
|||
//调用微信接口在指定位置生成图片
|
|||
httpWxCode(path, url, postStr); |
|||
} |
|||
|
|||
/** |
|||
* 方案C-生成小程序码(二维码)，可接受 path 参数较长，生成个数受限，数量限制见 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* 使用默认appId |
|||
* @param wechatCodeC 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
*/ |
|||
public static void getWxCodeC(WechatCode.WechatCodeC wechatCodeC, String path) throws Exception { |
|||
getWxCodeC(wechatCodeC,path,miniAppId, miniSecret); |
|||
} |
|||
|
|||
/** |
|||
* 方案C-生成小程序码(二维码)，可接受 path 参数较长，生成个数受限，数量限制见 |
|||
* 接口 A 加上接口 C，总共生成的码数量限制为 100,000，请谨慎调用。 |
|||
* @param wechatCodeC 传入参数 |
|||
* @param path 小程序码存储位置 |
|||
* @param appId appId |
|||
* @param secret secret |
|||
*/ |
|||
public static void getWxCodeC(WechatCode.WechatCodeC wechatCodeC, String path, String appId, String secret) throws Exception { |
|||
String url = String.format(WxConstant.URL_GET_WX_CODE_C, WxCommonUtil.getAccessToken(appId, secret)); |
|||
log.info("调用生成二维码路径和accessToken：{}", url); |
|||
String postStr = JacksonUtil.beanToJson(wechatCodeC); |
|||
log.info("二维码的参数：{}", postStr); |
|||
//调用微信接口在指定位置生成图片
|
|||
httpWxCode(path, url, postStr); |
|||
} |
|||
|
|||
/** |
|||
* 调用微信的接口在指定位置生成二维码 |
|||
* @param path 图片储存位置 |
|||
* @param url 微信接口路径 |
|||
* @param postStr 传入参数 |
|||
* @throws Exception 异常 |
|||
*/ |
|||
public static void httpWxCode(String path, String url, String postStr) throws Exception { |
|||
WxBaseEntity wxBaseEntity; |
|||
byte[] response = HttpsUtil.httpsRequestByte(url, "POST", postStr); |
|||
|
|||
if(response.length == 0){ |
|||
throw new BaseException(WxCodeError.WX_HTTP_ERROR); |
|||
} |
|||
try { |
|||
if (null == (wxBaseEntity = JacksonUtil.jsonToBean(new String(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); |
|||
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(); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,82 @@ |
|||
package com.ccsens.wechatutil.wxmini; |
|||
|
|||
import com.ccsens.util.HttpsUtil; |
|||
import com.ccsens.wechatutil.bean.dto.WxMessageDto; |
|||
import com.ccsens.wechatutil.util.WxConstant; |
|||
import com.ccsens.wechatutil.wxcommon.WxCommonUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
|
|||
import java.util.List; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
public class MiniMessage { |
|||
|
|||
@Value("${mini.appId:}") |
|||
private static String miniAppId; |
|||
@Value("${mini.secret:}") |
|||
private static String miniSecret; |
|||
|
|||
/** |
|||
* 发送微信订阅消息 (使用默认appId) |
|||
* |
|||
* @param notifyType 通知类型 |
|||
* @param toUser 用户openid |
|||
* @param page 小程序页面路径 |
|||
* @param params 小程序模板数据 |
|||
*/ |
|||
public static boolean sendSubcribeMsg(WxConstant.Packet_Notify_Type notifyType, String toUser, String page, List<String> params) throws Exception { |
|||
return sendSubcribeMsg(notifyType,toUser,page,params,miniAppId,miniSecret); |
|||
} |
|||
|
|||
/** |
|||
* 发送微信订阅消息 |
|||
* |
|||
* @param notifyType 通知类型 |
|||
* @param toUser 用户openid |
|||
* @param page 小程序页面路径 |
|||
* @param params 小程序模板数据 |
|||
*/ |
|||
public static boolean sendSubcribeMsg(WxConstant.Packet_Notify_Type notifyType, String toUser, String page, List<String> params,String appId, String secret) throws Exception { |
|||
String ret = null; |
|||
String url = String.format(WxConstant.URL_SEND_SUBSCRIBE_MESSAGE, WxCommonUtil.getAccessToken(appId, secret)); |
|||
switch (notifyType) { |
|||
//订单支付成功通知
|
|||
case Buy: { |
|||
WxMessageDto.SubscribeEntity<WxMessageDto.ReceiveSubscriBuyData> t = new WxMessageDto.SubscribeEntity<>(); |
|||
t.setTouser(toUser); |
|||
t.setTemplate_id(WxConstant.SUBSCRIBE_MSG_ID_BUY); |
|||
t.setPage(page); |
|||
t.setData(new WxMessageDto.ReceiveSubscriBuyData(params)); |
|||
System.out.println(com.ccsens.wechatutil.payutil.JacksonUtil.beanToJson(t)); |
|||
ret = HttpsUtil.httpsRequest(url, "POST", com.ccsens.wechatutil.payutil.JacksonUtil.beanToJson(t)); |
|||
break; |
|||
} |
|||
//订单发货
|
|||
case ReceiveSubscriBuyData: { |
|||
WxMessageDto.SubscribeEntity<WxMessageDto.ReceiveSubscriOrderSendData> t = new WxMessageDto.SubscribeEntity<>(); |
|||
t.setTouser(toUser); |
|||
t.setTemplate_id(WxConstant.SUBSCRIBE_MSG_ID_ORDERSEND); |
|||
t.setData(new WxMessageDto.ReceiveSubscriOrderSendData(params)); |
|||
System.out.println(com.ccsens.wechatutil.payutil.JacksonUtil.beanToJson(t)); |
|||
ret = HttpsUtil.httpsRequest(url, "POST", com.ccsens.wechatutil.payutil.JacksonUtil.beanToJson(t)); |
|||
break; |
|||
} |
|||
default: { |
|||
break; |
|||
} |
|||
} |
|||
//ok: {"errcode":0,"errmsg":"ok"}
|
|||
//err: {"errcode":43101,"errmsg":"user refuse to accept the msg hint: [V_GEdA02503942]"}
|
|||
System.out.println("Send Subscribe Message：" + ret); |
|||
String errCode = com.ccsens.wechatutil.payutil.JacksonUtil.getJsonValue(ret, "errcode"); |
|||
System.out.println(errCode); |
|||
return "0".equals(errCode); |
|||
} |
|||
|
|||
|
|||
|
|||
} |
|||
@ -0,0 +1,70 @@ |
|||
package com.ccsens.wechatutil.wxmini; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import cn.hutool.http.HttpRequest; |
|||
import com.ccsens.util.HttpsUtil; |
|||
import com.ccsens.util.JacksonUtil; |
|||
import com.ccsens.util.exception.BaseException; |
|||
import com.ccsens.wechatutil.bean.dto.WechatCode; |
|||
import com.ccsens.wechatutil.bean.dto.WxMessageDto; |
|||
import com.ccsens.wechatutil.bean.po.MiniProgramUser; |
|||
import com.ccsens.wechatutil.bean.po.WxBaseEntity; |
|||
import com.ccsens.wechatutil.util.WxCodeError; |
|||
import com.ccsens.wechatutil.util.WxConstant; |
|||
import com.ccsens.wechatutil.wxcommon.WxCommonUtil; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
|
|||
import java.io.*; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
public class MiniSigninUtil { |
|||
|
|||
@Value("${mini.appId:}") |
|||
private static String miniAppId; |
|||
@Value("${mini.secret:}") |
|||
private static String miniSecret; |
|||
|
|||
/** |
|||
* 小程序登录 |
|||
* -- 从配置文件中获取默认appId |
|||
* 配置文件内的名称 h5.appId: 和 h5.secret: |
|||
* @param code code |
|||
* @return 返回当前用户的openId等 |
|||
*/ |
|||
public static MiniProgramUser signinByMini(String code) { |
|||
return signinByMini(code, miniAppId, miniSecret); |
|||
} |
|||
/** |
|||
* 小程序登录 -- 传入appId |
|||
* @param code code |
|||
* @param appId appId |
|||
* @param secret secret |
|||
* @return 返回当前用户的openId等 |
|||
*/ |
|||
public static 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.getErrcode()) { |
|||
throw new BaseException(wxUser.getErrcode(), wxUser.getErrmsg()); |
|||
} |
|||
return wxUser; |
|||
} |
|||
|
|||
|
|||
} |
|||
@ -0,0 +1,96 @@ |
|||
package com.ccsens.wechatutil.wxofficial; |
|||
|
|||
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.bean.po.WxOauth2AccessToken; |
|||
import com.ccsens.wechatutil.bean.po.WxOauth2UserInfo; |
|||
import com.ccsens.wechatutil.util.WxCodeError; |
|||
import com.ccsens.wechatutil.util.WxConstant; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Value; |
|||
|
|||
import java.io.IOException; |
|||
|
|||
/** |
|||
* @author 逗 |
|||
*/ |
|||
@Slf4j |
|||
public class OfficialAccountSigninUtil { |
|||
|
|||
@Value("${h5.appId:}") |
|||
private static String appIdH5; |
|||
@Value("${h5.secret:}") |
|||
private static String secretH5; |
|||
|
|||
public static WxOauth2UserInfo signinByH5(String code) { |
|||
return signinByH5(code, appIdH5, secretH5); |
|||
} |
|||
|
|||
public static 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(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 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(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; |
|||
} |
|||
} |
|||
Loading…
Reference in new issue