掃二維碼與項(xiàng)目經(jīng)理溝通
我們?cè)谖⑿派?4小時(shí)期待你的聲音
解答本文疑問(wèn)/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流
在前面的設(shè)計(jì)和實(shí)現(xiàn)中,我們的微服務(wù)開(kāi)發(fā)平臺(tái)通過(guò)JustAuth來(lái)實(shí)現(xiàn)第三方授權(quán)登錄,通過(guò)集成公共組件,著實(shí)減少了很多工作量,大多數(shù)的第三方登錄直接通過(guò)配置就可以實(shí)現(xiàn)。而在第三方授權(quán)登錄中,微信小程序授權(quán)登錄和APP微信授權(quán)登錄是兩種特殊的第三方授權(quán)登錄。
??JustAuth之所以能夠?qū)⒍喾N第三方授權(quán)登錄服務(wù)整合在一起,抽象公共組件的原因是大多數(shù)的授權(quán)登錄服務(wù)器都是遵循OAuth2.0協(xié)議開(kāi)發(fā),雖然略有不同但可通過(guò)適配器進(jìn)行轉(zhuǎn)換為統(tǒng)一接口。微信小程序授權(quán)登錄和APP的微信授權(quán)登錄也是OAutn2.0協(xié)議的授權(quán)登錄,但在對(duì)接的流程中不是完整的OAuth2.0對(duì)接流程。
??通常的第三方授權(quán)登錄過(guò)程中,獲取token的state和code是在回調(diào)客戶端url中獲取的,而微信小程序授權(quán)登錄和APP的微信授權(quán)登錄獲取token的state和code是使用微信提供的特定方法獲取到的,然后通過(guò)微信傳給客戶端,客戶端拿到code之后到后臺(tái)取獲取openid等微信用戶信息。然后,再進(jìn)行系統(tǒng)登錄相關(guān)操作。

創(chuàng)新互聯(lián)建站服務(wù)項(xiàng)目包括峽江網(wǎng)站建設(shè)、峽江網(wǎng)站制作、峽江網(wǎng)頁(yè)制作以及峽江網(wǎng)絡(luò)營(yíng)銷策劃等。多年來(lái),我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等,向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案,峽江網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前,我們服務(wù)的客戶以成都為中心已經(jīng)輻射到峽江省份的部分城市,未來(lái)相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任!
??微信通過(guò)其開(kāi)放平臺(tái)提供小程序登錄功能接口,我們的業(yè)務(wù)服務(wù)可以通過(guò)小程序的登錄接口方便地獲取微信提供的用戶身份標(biāo)識(shí),進(jìn)而將業(yè)務(wù)自身用戶體系和微信用戶相結(jié)合,從而更完美地在微信小程序中實(shí)現(xiàn)業(yè)務(wù)功能。
??微信小程序提供了對(duì)接登錄的SDK,我們只需要按照其官方文檔對(duì)接開(kāi)發(fā)即可。同時(shí)也有很多開(kāi)源組件將SDK再次進(jìn)行封裝,在業(yè)務(wù)開(kāi)發(fā)中可以更快速的集成小程序各個(gè)接口的調(diào)用。
??出于快速開(kāi)發(fā)的原則,同時(shí)也少走彎路、少踩坑,我們可以選擇一款實(shí)現(xiàn)比較完善的組件進(jìn)行微信小程序的對(duì)接。weixin-java-miniapp是集成微信小程序相關(guān)SDK操作的工具包,我們?cè)陧?xiàng)目中集成此工具包來(lái)實(shí)現(xiàn)微信小程序授權(quán)登錄。
??一般在選擇開(kāi)源工具包時(shí),我們不會(huì)選擇最新版,而是選擇穩(wěn)定版本,但是微信的開(kāi)放接口經(jīng)常變動(dòng),這里為了能夠兼容最新的微信小程序接口,我們?cè)谝冒臅r(shí)候一定要選擇更新版本,否則會(huì)影響部分接口的調(diào)用。
......
......
4.4.0
......
com.github.binarywang
weixin-java-miniapp
${weixin-java-miniapp.version}
......
??關(guān)于小程序如何注冊(cè),appid和appsecret如何獲取,這里不展開(kāi)講,微信開(kāi)放平臺(tái)有詳細(xì)的說(shuō)明文檔。
wx:
miniapp:
configs:
- appid: #微信小程序appid
secret: #微信小程序secret
token: #微信小程序消息服務(wù)器配置的token
aesKey: #微信小程序消息服務(wù)器配置的EncodingAESKey
msgDataFormat: JSON
......
@Data
@ConfigurationProperties(prefix = "wx.miniapp")
public class WxMaProperties {
private Listconfigs;
@Data
public static class Config {
/**
* 設(shè)置微信小程序的appid
*/
private String appid;
/**
* 設(shè)置微信小程序的Secret
*/
private String secret;
/**
* 設(shè)置微信小程序消息服務(wù)器配置的token
*/
private String token;
/**
* 設(shè)置微信小程序消息服務(wù)器配置的EncodingAESKey
*/
private String aesKey;
/**
* 消息格式,XML或者JSON
*/
private String msgDataFormat;
}
}
......
......
private final WxMaProperties properties;
@Autowired
public WxMaConfiguration(WxMaProperties properties) {
this.properties = properties;
}
@Bean
public WxMaService wxMaService() {
Listconfigs = this.properties.getConfigs();
if (configs == null) {
throw new WxRuntimeException("配置錯(cuò)誤!");
}
WxMaService maService = new WxMaServiceImpl();
maService.setMultiConfigs(
configs.stream()
.map(a -> {
WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
config.setAppid(a.getAppid());
config.setSecret(a.getSecret());
config.setToken(a.getToken());
config.setAesKey(a.getAesKey());
config.setMsgDataFormat(a.getMsgDataFormat());
return config;
}).collect(Collectors.toMap(WxMaDefaultConfigImpl::getAppid, a -> a, (o, n) -> o)));
return maService;
}
......
/**
* 登陸接口
*/
@ApiOperation(value = "小程序登錄接口")
@ApiImplicitParams({
@ApiImplicitParam(name = "code", value = "小程序code", dataType="String", paramType = "query"),
})
@GetMapping("/login")
public Result> login(@PathVariable String appid, String code) {
if (StringUtils.isBlank(code)) {
return Result.error("code 不能為空");
}
if (!wxMaService.switchover(appid)) {
throw new IllegalArgumentException(String.format("未找到對(duì)應(yīng)appid=[%s]的配置,請(qǐng)核實(shí)!", appid));
}
WeChatMiniAppLoginDTO weChatMiniAppLoginDTO = new WeChatMiniAppLoginDTO();
try {
WxMaJscode2SessionResult session = wxMaService.getUserService().getSessionInfo(code);
weChatMiniAppLoginDTO.setOpenid(session.getOpenid());
weChatMiniAppLoginDTO.setUnionid(session.getUnionid());
// 通過(guò)openId獲取在系統(tǒng)中是否是已經(jīng)綁定過(guò)的用戶,如果沒(méi)有綁定,那么返回到前臺(tái),提示需要綁定或者注冊(cè)用戶
LambdaQueryWrappersocialLambdaQueryWrapper = new LambdaQueryWrapper<>();
// 如果微信開(kāi)通了開(kāi)放平臺(tái),那么各個(gè)渠道(小程序、公眾號(hào)等)都會(huì)有統(tǒng)一的unionid,如果沒(méi)開(kāi)通,就僅僅使用openId
if (StringUtils.isBlank(session.getUnionid()))
{
socialLambdaQueryWrapper.eq(JustAuthSocial::getOpenId, session.getOpenid())
.eq(JustAuthSocial::getSource, "WECHAT_MINI_APP");
}
else
{
socialLambdaQueryWrapper.eq(JustAuthSocial::getUnionId, session.getUnionid())
.and(e -> e.eq(JustAuthSocial::getSource, "WECHAT_MINI_APP")
.or().eq(JustAuthSocial::getSource, "WECHAT_OPEN")
.or().eq(JustAuthSocial::getSource, "WECHAT_MP")
.or().eq(JustAuthSocial::getSource, "WECHAT_ENTERPRISE")
.or().eq(JustAuthSocial::getSource, "WECHAT_APP"));
}
JustAuthSocial justAuthSocial = justAuthSocialService.getOne(socialLambdaQueryWrapper, false);
if (null == justAuthSocial)
{
weChatMiniAppLoginDTO.setUserInfoAlready(false);
weChatMiniAppLoginDTO.setUserBindAlready(false);
justAuthSocial = new JustAuthSocial();
justAuthSocial.setAccessCode(session.getSessionKey());
justAuthSocial.setOpenId(session.getOpenid());
justAuthSocial.setUnionId(session.getUnionid());
justAuthSocial.setSource("WECHAT_MINI_APP");
justAuthSocialService.save(justAuthSocial);
} else {
justAuthSocial.setAccessCode(session.getSessionKey());
justAuthSocialService.updateById(justAuthSocial);
}
// 將socialId進(jìn)行加密返回,用于前端進(jìn)行第三方登錄,獲取token
DES des = new DES(Mode.CTS, Padding.PKCS5Padding, secretKey.getBytes(), secretKeySalt.getBytes());
// 這里將source+uuid通過(guò)des加密作為key返回到前臺(tái)
String socialKey = "WECHAT_MINI_APP" + StrPool.UNDERLINE + (StringUtils.isBlank(session.getUnionid()) ? session.getOpenid() : session.getUnionid());
// 將socialKey放入緩存,默認(rèn)有效期2個(gè)小時(shí),如果2個(gè)小時(shí)未完成驗(yàn)證,那么操作失效,重新獲取,在system:socialLoginExpiration配置
redisTemplate.opsForValue().set(AuthConstant.SOCIAL_VALIDATION_PREFIX + socialKey, String.valueOf(justAuthSocial.getId()), socialLoginExpiration,
TimeUnit.SECONDS);
String desSocialKey = des.encryptHex(socialKey);
weChatMiniAppLoginDTO.setBindKey(desSocialKey);
// 查詢是否綁定用戶
// 判斷此第三方用戶是否被綁定到系統(tǒng)用戶
Result
/**
* 獲取用戶信息接口
*/
@ApiOperation(value = "小程序獲取用戶信息接口")
@ApiImplicitParams({
@ApiImplicitParam(name = "socialKey", value = "加密的登錄key,用于綁定用戶", required = true, dataType="String", paramType = "query"),
@ApiImplicitParam(name = "signature", value = "使用 sha1( rawData + sessionkey ) 得到字符串,用于校驗(yàn)用戶信息", required = true, dataType="String", paramType = "query"),
@ApiImplicitParam(name = "rawData", value = "不包括敏感信息的原始數(shù)據(jù)字符串,用于計(jì)算簽名", required = true, dataType="String", paramType = "query"),
@ApiImplicitParam(name = "encryptedData", value = "包括敏感數(shù)據(jù)在內(nèi)的完整用戶信息的加密數(shù)據(jù)", required = true, dataType="String", paramType = "query"),
@ApiImplicitParam(name = "iv", value = "加密算法的初始向量", required = true, dataType="String", paramType = "query")
})
@GetMapping("/info")
public Result> info(@PathVariable String appid, String socialKey,
String signature, String rawData, String encryptedData, String iv) {
if (!wxMaService.switchover(appid)) {
throw new IllegalArgumentException(String.format("未找到對(duì)應(yīng)appid=[%s]的配置,請(qǐng)核實(shí)!", appid));
}
// 查詢第三方用戶信息
JustAuthSocial justAuthSocial = this.getJustAuthSocial(socialKey);
if (StringUtils.isBlank(justAuthSocial.getAccessCode()))
{
throw new BusinessException("登錄狀態(tài)失效,請(qǐng)嘗試重新進(jìn)入小程序");
}
// 用戶信息校驗(yàn)
if (!wxMaService.getUserService().checkUserInfo(justAuthSocial.getAccessCode(), rawData, signature)) {
WxMaConfigHolder.remove();//清理ThreadLocal
return Result.error("user check failed");
}
// 解密用戶信息
WxMaUserInfo userInfo = wxMaService.getUserService().getUserInfo(justAuthSocial.getAccessCode(), encryptedData, iv);
WxMaConfigHolder.remove();//清理ThreadLocal
justAuthSocial.setAvatar(userInfo.getAvatarUrl());
justAuthSocial.setUnionId(userInfo.getUnionId());
justAuthSocial.setNickname(userInfo.getNickName());
justAuthSocialService.updateById(justAuthSocial);
return Result.data(userInfo);
}
/**
* 獲取用戶綁定手機(jī)號(hào)信息
*/
@ApiOperation(value = "小程序獲取用戶綁定手機(jī)號(hào)信息")
@ApiImplicitParams({
@ApiImplicitParam(name = "socialKey", value = "加密的登錄key,用于綁定用戶", required = true, dataType="String", paramType = "query"),
@ApiImplicitParam(name = "encryptedData", value = "包括敏感數(shù)據(jù)在內(nèi)的完整用戶信息的加密數(shù)據(jù)", required = true, dataType="String", paramType = "query"),
@ApiImplicitParam(name = "iv", value = "加密算法的初始向量", required = true, dataType="String", paramType = "query")
})
@GetMapping("/phone")
public Result> phone(@PathVariable String appid, String socialKey, String encryptedData, String iv) {
if (!wxMaService.switchover(appid)) {
throw new IllegalArgumentException(String.format("未找到對(duì)應(yīng)appid=[%s]的配置,請(qǐng)核實(shí)!", appid));
}
// 查詢第三方用戶信息
JustAuthSocial justAuthSocial = this.getJustAuthSocial(socialKey);
if (StringUtils.isBlank(justAuthSocial.getAccessCode()))
{
throw new BusinessException("登錄狀態(tài)失效,請(qǐng)嘗試重新進(jìn)入小程序");
}
// 解密
WxMaPhoneNumberInfo phoneNoInfo = wxMaService.getUserService().getPhoneNoInfo(justAuthSocial.getAccessCode(), encryptedData, iv);
WxMaConfigHolder.remove();//清理ThreadLocal
// 不帶區(qū)號(hào)的手機(jī),國(guó)外的手機(jī)會(huì)帶區(qū)號(hào)
String phoneNumber = phoneNoInfo.getPurePhoneNumber();
// 查詢用戶是否存在,如果存在,那么直接調(diào)用綁定接口
LambdaQueryWrapperlambdaQueryWrapper = new LambdaQueryWrapper<>();
lambdaQueryWrapper.eq(User::getMobile, phoneNumber);
User userInfo = userService.getOne(lambdaQueryWrapper);
Long userId;
// 判斷返回信息
if (null != userInfo && null != userInfo.getId()) {
userId = userInfo.getId();
}
else {
// 如果用戶不存在,那么調(diào)用新建用戶接口,并綁定
CreateUserDTO createUserDTO = new CreateUserDTO();
createUserDTO.setAccount(phoneNumber);
createUserDTO.setMobile(phoneNumber);
createUserDTO.setNickname(StringUtils.isBlank(justAuthSocial.getNickname()) ? phoneNumber : justAuthSocial.getNickname());
createUserDTO.setPassword(StringUtils.isBlank(justAuthSocial.getUnionId()) ? justAuthSocial.getOpenId() : justAuthSocial.getUnionId());
createUserDTO.setStatus(GitEggConstant.UserStatus.ENABLE);
createUserDTO.setAvatar(justAuthSocial.getAvatar());
createUserDTO.setEmail(justAuthSocial.getEmail());
createUserDTO.setStreet(justAuthSocial.getLocation());
createUserDTO.setComments(justAuthSocial.getRemark());
CreateUserDTO resultUserAdd = userService.createUser(createUserDTO);
if (null != resultUserAdd && null != resultUserAdd.getId()) {
userId = resultUserAdd.getId();
} else {
// 如果添加失敗,則返回失敗信息
return Result.data(resultUserAdd);
}
}
// 執(zhí)行綁定操作
justAuthService.userBind(justAuthSocial.getId(), userId);
return Result.success("賬號(hào)綁定成功");
}
/**
* 綁定當(dāng)前登錄賬號(hào)
*/
@ApiOperation(value = "綁定當(dāng)前登錄賬號(hào)")
@ApiImplicitParams({
@ApiImplicitParam(name = "socialKey", value = "加密的登錄key,用于綁定用戶", required = true, dataType="String", paramType = "query")
})
@GetMapping("/bind")
public Result> bind(@PathVariable String appid, @NotBlank String socialKey, @CurrentUser GitEggUser user) {
if (!wxMaService.switchover(appid)) {
throw new IllegalArgumentException(String.format("未找到對(duì)應(yīng)appid=[%s]的配置,請(qǐng)核實(shí)!", appid));
}
if (null == user || (null != user && null == user.getId())) {
throw new BusinessException("用戶未登錄");
}
// 查詢第三方用戶信息
JustAuthSocial justAuthSocial = this.getJustAuthSocial(socialKey);
if (StringUtils.isBlank(justAuthSocial.getAccessCode()))
{
throw new BusinessException("賬號(hào)綁定失敗,請(qǐng)嘗試重新進(jìn)入小程序");
}
// 執(zhí)行綁定操作
justAuthService.userBind(justAuthSocial.getId(), user.getId());
return Result.success("賬號(hào)綁定成功");
}
/**
* 解綁當(dāng)前登錄賬號(hào)
*/
@ApiOperation(value = "解綁當(dāng)前登錄賬號(hào)")
@GetMapping("/unbind")
public Result> unbind(@PathVariable String appid, @CurrentUser GitEggUser user) {
if (!wxMaService.switchover(appid)) {
throw new IllegalArgumentException(String.format("未找到對(duì)應(yīng)appid=[%s]的配置,請(qǐng)核實(shí)!", appid));
}
if (null == user || (null != user && null == user.getId())) {
throw new BusinessException("用戶未登錄");
}
LambdaQueryWrapperqueryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(JustAuthSocialUser::getUserId, user.getId());
justAuthSocialUserService.remove(queryWrapper);
return Result.success("賬號(hào)解綁成功");
}
??通過(guò)以上接口的功能,基本實(shí)現(xiàn)了微信小程序前端進(jìn)行綁定、注冊(cè)以及獲取用戶信息、用戶手機(jī)號(hào)所需要的接口,下面來(lái)實(shí)現(xiàn)小程序前端具體的業(yè)務(wù)實(shí)現(xiàn)。
??微信小程序前端開(kāi)發(fā)有多種方式,可以使用微信小程序官方開(kāi)發(fā)方式,也可以使用第三方的開(kāi)發(fā)方式。因?yàn)榇蠖鄶?shù)前端都會(huì)使用Vue.js開(kāi)發(fā),而mpvue可以使用開(kāi)發(fā)Vue.js的方式來(lái)開(kāi)發(fā)微信小程序,所以這里我們選擇使用mpvue來(lái)開(kāi)發(fā)微信小程序。這里不詳細(xì)講解mpvue框架的搭建過(guò)程,只詳細(xì)說(shuō)明微信小程序授權(quán)登錄相關(guān)功能,有需要的可以參考mpvue官方文檔。
??因?yàn)槲覀兊拈_(kāi)發(fā)框架是支持多租戶的,同時(shí)也是支持多個(gè)小程序的,為了同一套后臺(tái)可以支持多個(gè)微信小程序,這里選擇在發(fā)布的微信小程序中配置appId,由微信小程序前端參數(shù)來(lái)確定具體的微信小程序。
import fly from '@/utils/requestWx'
// 獲取用戶信息
export function getOpenId (params) {
return fly.get(`/wx/user/${params.appId}/login`, params)
}
// 獲取用戶信息
export function getUserInfo (params) {
return fly.get(`/wx/user/${params.appId}/info`, params)
}
// 獲取用戶手機(jī)號(hào)
export function getUserPhone (params) {
return fly.get(`/wx/user/${params.appId}/phone`, params)
}
// 綁定微信賬號(hào)
export function bindWeChatUser (params) {
return fly.get(`/wx/user/${params.appId}/bind`, params)
}
// 解綁微信賬號(hào)
export function unbindWeChatUser (params) {
return fly.get(`/wx/ 分享標(biāo)題:「SpringCloud」微信小程序授權(quán)登錄流程設(shè)計(jì)和實(shí)現(xiàn)
文章來(lái)源:http://uogjgqi.cn/article/dpddshe.html

我們?cè)谖⑿派?4小時(shí)期待你的聲音
解答本文疑問(wèn)/技術(shù)咨詢/運(yùn)營(yíng)咨詢/技術(shù)建議/互聯(lián)網(wǎng)交流