对接微信小步调授权登录

一. 微信小步调授权登录

---

引入依靠

1. <!--微信小程序-->
2. <dependency>
3.     <groupId>com.github.binarywang</groupId>
4.     <artifactId>weixin-java-miniapp</artifactId>
5.     <version>4.3.0</version>
6. </dependency>

复制代码

修改设置文件

1. wx:
2.   # 微信小程序appid
3.   app-id: wxcbxxxxxxxxxxxxxxx
4.   # 小程序密钥
5.   app-secret: 8ccxxxxxxxxxxxxxxxx
6.   msgDataFormat: JSON

复制代码

设置类Properties

1. import lombok.Data;
2. import lombok.ToString;
3. import org.springframework.boot.context.properties.ConfigurationProperties;
4. import org.springframework.stereotype.Component;
6. /**
7. * @Author：Ccoo
8. * @Date：2024/3/21 20:40
9. */
10. @Data
11. @ToString
12. @Component
13. @ConfigurationProperties(prefix = "wx")
14. public class WxProperties {
15.     /**
16.      * 设置微信小程序的appid
17.      */
18.     private String appId;
20.     /**
21.      * 设置微信小程序的Secret
22.      */
23.     private String appSecret;
25.     /**
26.      * 消息格式，XML或者JSON
27.      */
28.     private String msgDataFormat;
30. }

复制代码

设置类Config

1. import cn.binarywang.wx.miniapp.api.WxMaService;
2. import cn.binarywang.wx.miniapp.api.WxMaUserService;
3. import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
4. import cn.binarywang.wx.miniapp.api.impl.WxMaUserServiceImpl;
5. import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
6. import lombok.extern.slf4j.Slf4j;
7. import me.chanjar.weixin.common.error.WxRuntimeException;
8. import org.springframework.context.annotation.Bean;
9. import org.springframework.context.annotation.Configuration;
11. import javax.annotation.Resource;
12. import java.util.HashMap;
13. import java.util.Objects;
15. @Slf4j
16. @Configuration
17. public class WxMaConfiguration {
19.     @Resource
20.     private WxProperties wxProperties;
22.     @Bean
23.     public WxMaService wxMaService() {
24.         if (Objects.isNull(wxProperties)) {
25.             throw new WxRuntimeException("请添加下相关配置, 注意别配错了!");
26.         }
28.         WxMaService maService = new WxMaServiceImpl();
29.         try {
30.             WxMaDefaultConfigImpl config = new WxMaDefaultConfigImpl();
31.             config.setAppid(wxProperties.getAppId());
32.             config.setSecret(wxProperties.getAppSecret());
33.             config.setMsgDataFormat(wxProperties.getMsgDataFormat());
34.             HashMap configMap = new HashMap<>();
35.             configMap.put(config.getAppid(), config);
36.             maService.setMultiConfigs(configMap);
37.         } catch (Exception e) {
38.             throw new WxRuntimeException("微信小程序相关配置配置失败！");
39.         }
40.         return maService;
41.     }
43. }

复制代码

Controller控制器代码

1. import com.itheima.mp.domain.R;
2. import com.itheima.mp.service.WeChatService;
3. import io.swagger.annotations.ApiOperation;
4. import io.swagger.annotations.ApiParam;
5. import org.springframework.beans.factory.annotation.Autowired;
6. import org.springframework.web.bind.annotation.PostMapping;
7. import org.springframework.web.bind.annotation.RequestMapping;
8. import org.springframework.web.bind.annotation.RequestParam;
9. import org.springframework.web.bind.annotation.RestController;
11. /**
12. * <p>
13. *  前端控制器
14. * </p>
15. *
16. * @author Ccoo
17. * @since 2023-10-01
18. */
19. @RestController
20. @RequestMapping("/wechat")
21. public class WeChatController {
23.         @Autowired
24.         private WeChatService wechatService;
26.         @ApiOperation(value = "微信小程序授权登录", notes = "微信小程序授权登录")
27.         @PostMapping("/wxLogin")
28.         public R<?> wxLogin(@ApiParam("loginCode") @RequestParam String code) {
29.                 return wechatService.wxLogin(code);
30.         }
33. }

复制代码

Service接口层代码

1. import com.itheima.mp.domain.R;
3. /**
4. * @author Ccoo
5. * 2024/8/23
6. */
7. public interface WeChatService {
9.         /**
10.          * 微信授权登录
11.          * @param code  授权码
12.          * @return 结果
13.          */
14.         R<?> wxLogin(String code);
17. }

复制代码

ServiceImpl实现层代码

1. import cn.binarywang.wx.miniapp.api.WxMaService;
2. import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
3. import cn.hutool.json.JSONUtil;
4. import lombok.RequiredArgsConstructor;
5. import lombok.extern.slf4j.Slf4j;
6. import me.chanjar.weixin.common.error.WxErrorException;
7. import org.springframework.stereotype.Service;
9. /**
10. * @author Ccoo
11. * 2024/8/23
12. */
13. @Slf4j
14. @Service
15. @RequiredArgsConstructor
16. public class WeChatServiceImpl implements WeChatService {
18.         private final WxMaService wxMaService;
20.         /**
21.          * 微信授权登录
22.          *
23.          * @param code 授权码
24.          * @return 结果
25.          */
26.         @Override
27.         public R<?> wxLogin(String code) {
28.                
29.                 try {
30.                         WxMaJscode2SessionResult sessionInfo = wxMaService.getUserService().getSessionInfo(code);
31.                         String info = JSONUtil.toJsonStr(sessionInfo);
33.                         log.info("微信授权登录成功：{}", info);
34.                         return R.ok(info);
35.                 } catch (WxErrorException e) {
37.                         log.error("微信授权登录失败：{}", e.getError().getErrorMsg());
38.                         return R.fail(e.getError().getErrorCode(), e.getError().getErrorMsg());
39.                 }
41.         }
42. }

复制代码

同一相应类 R

1. import java.io.Serializable;
3. /**
4. * 响应信息主体
5. *
6. * @author Ccoo
7. */
8. public class R<T> implements Serializable
9. {
10.     private static final long serialVersionUID = 1L;
12.     /** 成功 */
13.     public static final int SUCCESS = 200;
15.     /** 失败 */
16.     public static final int FAIL = 500;
18.     private int code;
20.     private String msg;
22.     private T data;
24.     public static <T> R<T> ok()
25.     {
26.         return restResult(null, SUCCESS, "操作成功");
27.     }
28.     public static <T> R<T> ok(String msg)
29.     {
30.         return restResult(null, SUCCESS, msg);
31.     }
33.     public static <T> R<T> ok(T data)
34.     {
35.         return restResult(data, SUCCESS, "操作成功");
36.     }
38.     public static <T> R<T> ok(T data, String msg)
39.     {
40.         return restResult(data, SUCCESS, msg);
41.     }
43.     public static <T> R<T> fail()
44.     {
45.         return restResult(null, FAIL, "操作失败");
46.     }
48.     public static <T> R<T> fail(String msg)
49.     {
50.         return restResult(null, FAIL, msg);
51.     }
53.     public static <T> R<T> fail(T data)
54.     {
55.         return restResult(data, FAIL, "操作失败");
56.     }
58.     public static <T> R<T> fail(T data, String msg)
59.     {
60.         return restResult(data, FAIL, msg);
61.     }
63.     public static <T> R<T> fail(int code, String msg)
64.     {
65.         return restResult(null, code, msg);
66.     }
68.     private static <T> R<T> restResult(T data, int code, String msg)
69.     {
70.         R<T> apiResult = new R<>();
71.         apiResult.setCode(code);
72.         apiResult.setData(data);
73.         apiResult.setMsg(msg);
74.         return apiResult;
75.     }
77.     public int getCode()
78.     {
79.         return code;
80.     }
82.     public void setCode(int code)
83.     {
84.         this.code = code;
85.     }
87.     public String getMsg()
88.     {
89.         return msg;
90.     }
92.     public void setMsg(String msg)
93.     {
94.         this.msg = msg;
95.     }
97.     public T getData()
98.     {
99.         return data;
100.     }
102.     public void setData(T data)
103.     {
104.         this.data = data;
105.     }
106. }

复制代码

具体授权登录代码

   微信小步调授权登录思路 :
  

• 先判断Redis中缓存是否命中, 如果命中则直接返回缓存信息
  
• 如果未命中缓存, 则使用暂时校验码code去微信调换openid
  
• 查询数据库该openid对应用户信息是否存在, 存在则直接返回, 不存在则注册用户信息
  
• 最后将用户信息存入redis, 并返回相应的token供下次授权登录前判断是否缓存信息
  

   具体实当代码如下

1. @ApiOperation("微信授权登录")
2. @PostMapping("/customer_login")
3. public R<SysWxUser> customerLogin(@RequestBody WXAuth wxAuth) {
4.     return weixinService.customerLogin(wxAuth);
5. }

复制代码

1. R<SysWxUser> customerLogin(WXAuth wxAuth);

复制代码

1. /**
2. * 授权登录
3. *
4. * @param wxAuth 授权信息
5. * @return 结果
6. */
7. @Override
8. public R<SysWxUser> customerLogin(WXAuth wxAuth) {
9.     String code = wxAuth.getCode();
10.     String iv = wxAuth.getIv();
11.     String token = wxAuth.getToken();
12.     String encryptedData = wxAuth.getEncryptedData();
14.     if(StrUtil.isBlank(code) && StrUtil.isBlank(token)){
15.         return R.fail(MessageConstants.PARAMS_ERROR);
16.     }
18.     // 判断登录态是否在有效期
19.     if(StrUtil.isNotBlank(token)){
20.         // token不为空  判断token是否过期
21.         String content = redisTemplate.opsForValue().get(RedisKey.WX_SESSION_KEY + token);
22.         if(content == null){
23.             return R.fail(MessageConstants.TOKEN_NOT_EXIST);
24.         }
25.         // 查询token对应用户信息
26.         SysWxUser info = JSONUtil.toBean(content, SysWxUser.class);
27.         // 刷新token有效时间
28.         redisTemplate.opsForValue().set(RedisKey.WX_SESSION_KEY + token, content, 3600, TimeUnit.SECONDS);
29.         return R.ok(info);
30.     }
32.     SysWxUser wxUser = null;
33.     WxMaJscode2SessionResult sessionInfo = null;
34.     try {
35.         sessionInfo = wxMaService.getUserService().getSessionInfo(code);
36.         WxMaUserInfo userInfo = wxMaService.getUserService().getUserInfo(sessionInfo.getSessionKey(), encryptedData, iv);
37.         
38.         String openid = sessionInfo.getOpenid();
39.         
40.         // 使用微信openId查询是否有此用户(WxUser)
41.         wxUser = lambdaQuery().eq(SysWxUser::getOpenid, openid).one();
42.         
43.         // 不存在 构建用户信息进行注册
44.         if(wxUser == null) {
45.             wxUser = new SysWxUser();
46.             wxUser.setOpenid(openid);
47.             wxUser.setWxName(Constants.WX_PREFIX + RandomUtil.randomString(6));
48.             wxUser.setAvatarUrl(userInfo.getAvatarUrl());
49.             int insert = wxUserMapper.insert(wxUser);
50.             if (insert == 0) {
51.                 return R.fail(MessageConstants.USER_BIND_ERROR);
52.             }
53.         }
54.         
55.     } catch (Exception e) {
56.         e.printStackTrace();
57.         log.error(MessageConstants.SYSTEM_ERROR);
58.     }
60.     String sessionKey = sessionInfo.getSessionKey();
61.     String cacheKey = RedisKey.WX_SESSION_KEY + sessionKey;
63.     // 将 openid / sessionKey 存入redis
64.     redisTemplate.opsForValue().set(cacheKey, JSONUtil.toJsonStr(wxUser), 3600, TimeUnit.SECONDS);
65.     return R.ok(wxUser,Constants.TOKEN_PRE + sessionKey);
66. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。