https://api.weibo.com/oauth2/authorize?client_id=YOUR_CLIENT_ID&response_type=code&redirect_uri=YOUR_REGISTERED_REDIRECT_URI
YOUR_CLIENT_ID、
YOUR_REGISTERED_REDIRECT_URI分別表明下圖中APP KEY和受權回調頁:
https://api.weibo.com/oauth2/access_token?client_id=YOUR_CLIENT_ID&client_secret=YOUR_CLIENT_SECRET&grant_type=authorization_code&redirect_uri=YOUR_REGISTERED_REDIRECT_URI&code=CODEhtml
其中YOUR_CLIENT_ID、
YOUR_CLIENT_SECRET分別表明APP KEY和APP Secret,
YOUR_REGISTERED_REDIRECT_URI表明
前端受權回調頁,code則爲CODE受權令牌
:
@Controller public class OAuth2Controller { @Autowired MemberFeignSerivce memberFeignSerivce; @GetMapping( "/oauth2.0/weibo/success") public String weibo(@RequestParam("code") String code) throws Exception { //一、根據code換取accessToken Map<String,String> map = new HashMap<>(); map.put("client_id","21*********6"); map.put("client_secret","65ae****************e30a"); map.put("grant_type","authorization_code"); map.put("redirect_uri","http://auth.gulimall.com/oauth2.0/weibo/success"); map.put("code",code); HttpResponse response = HttpUtils.doPost("https://api.weibo.com", "/oauth2/access_token", "post", new HashMap<String, String>(), new HashMap<String, String>(), map); //二、處理微博登錄成功的回調 System.out.println(response.getStatusLine().getStatusCode()); if (response.getStatusLine().getStatusCode()==200){ //將返回的json數據變成對象 String json = EntityUtils.toString(response.getEntity()); System.out.println("返回json數據:"+json); SocialUser socialUser = JSON.parseObject(json, SocialUser.class); //若是當前用戶是第一次登陸則自動註冊爲本網站用戶(爲當前社交用戶生成一個信息帳號,之後社交帳號對應指定會員) //登陸或註冊這個帳戶 R oauthlogin = memberFeignSerivce.oauthlogin(socialUser); if (oauthlogin.getCode()==0){ MemberResVo data = oauthlogin.getData("data", new TypeReference<MemberResVo>() { }); System.out.println("登錄成功:"+ data.toString()); return "redirect:http://gulimall.com"; }else { return "redirect:http://auth.gulimall.com/login.html"; } }else { return "redirect:http://auth.gulimall.com/login.html"; } } }
@FeignClient("gulimall-member") public interface MemberFeignSerivce { @PostMapping("/member/member/oauth2/login") public R oauthlogin(@RequestBody SocialUser socialUser); }
@RestController @RequestMapping("member/member") public class MemberController { @Autowired private MemberService memberService; @PostMapping("/oauth2/login") public R oauthlogin(@RequestBody SocialUser socialUser) throws Exception { MemberEntity memberEntity = memberService.login(socialUser); if (memberEntity != null) { return R.ok().setData(memberEntity); } else { return R.error(BizCodeEnume.LOGIN_PASSWORD_INVAILD_EXCEPTION.getCode(),BizCodeEnume.LOGIN_PASSWORD_INVAILD_EXCEPTION.getMsg()); } } }
public interface MemberService extends IService<MemberEntity> { MemberEntity login(SocialUser socialUser) throws Exception; }
@Service("memberService") public class MemberServiceImpl extends ServiceImpl<MemberDao, MemberEntity> implements MemberService { @Resource MemberLevelDao memberLevelDao; @Override public MemberEntity login(SocialUser socialUser) throws Exception{ //登陸和合並邏輯 String uid = socialUser.getUid(); //一、判斷當前社交用戶是否已經登錄過 MemberDao baseMapper = this.baseMapper; //查找當前社區用戶的帳號uid MemberEntity memberEntity = baseMapper.selectOne(new QueryWrapper<MemberEntity>().eq("social_uid", uid)); //則代表已註冊過 if (memberEntity != null) { MemberEntity update = new MemberEntity(); update.setId(memberEntity.getId()); update.setAccessToken(socialUser.getAccess_token()); update.setExpiresIn(socialUser.getExpires_in()); //僅僅是更新本次的令牌號碼和過時時間 baseMapper.updateById(update); //返回最新的本次的令牌號碼和過時時間 memberEntity.setAccessToken(socialUser.getAccess_token()); memberEntity.setExpiresIn(socialUser.getExpires_in()); return memberEntity; } else { //二、沒查到當前用戶,則須要註冊 MemberEntity regist = new MemberEntity(); try { //查詢當前社交用戶的社交信息資料 HashMap<String, String> query = new HashMap<>(); query.put("access_token", socialUser.getAccess_token()); query.put("uid", socialUser.getUid()); HttpResponse response = HttpUtils.doGet("https://api.weibo.com", "/2/users/show.json", "get", new HashMap<String, String>(), query); //查詢成功 if (response.getStatusLine().getStatusCode() == 200) { String json = EntityUtils.toString(response.getEntity()); JSONObject jsonObject = JSON.parseObject(json); //獲取用戶名稱等資料 String name = jsonObject.getString("name"); String gender = jsonObject.getString("gender"); //...... regist.setNickname(name); regist.setGender("m".equals(gender) ? 1 : 0); //....... } } catch (Exception e) { e.printStackTrace(); } regist.setSocialUid(socialUser.getUid()); regist.setAccessToken(socialUser.getAccess_token()); regist.setExpiresIn(socialUser.getExpires_in()); //插入數據庫 baseMapper.insert(regist); return regist; } } }
@ToString @Data public class MemberResVo { private Long id; /** * 會員等級id */ private Long levelId; /** * 用戶名 */ private String username; /** * 密碼 */ private String password; /** * 暱稱 */ private String nickname; /** * 手機號碼 */ private String mobile; /** * 郵箱 */ private String email; /** * 頭像 */ private String header; /** * 性別 */ private Integer gender; /** * 生日 */ private Date birth; /** * 所在城市 */ private String city; /** * 職業 */ private String job; /** * 個性簽名 */ private String sign; /** * 用戶來源 */ private Integer sourceType; /** * 積分 */ private Integer integration; /** * 成長值 */ private Integer growth; /** * 啓用狀態 */ private Integer status; /** * 註冊時間 */ private Date createTime; /** * accesstoken碼 */ private String accessToken; /** * 過時時間 */ private long expiresIn; /** * 社區帳戶的id */ private String socialUid; }
@Data @TableName("ums_member") public class MemberEntity implements Serializable { private static final long serialVersionUID = 1L; /** * id */ @TableId private Long id; /** * 會員等級id */ private Long levelId; /** * 用戶名 */ private String username; /** * 密碼 */ private String password; /** * 暱稱 */ private String nickname; /** * 手機號碼 */ private String mobile; /** * 郵箱 */ private String email; /** * 頭像 */ private String header; /** * 性別 */ private Integer gender; /** * 生日 */ private Date birth; /** * 所在城市 */ private String city; /** * 職業 */ private String job; /** * 個性簽名 */ private String sign; /** * 用戶來源 */ private Integer sourceType; /** * 積分 */ private Integer integration; /** * 成長值 */ private Integer growth; /** * 啓用狀態 */ private Integer status; /** * 註冊時間 */ private Date createTime; /** * accesstoken碼 */ private String accessToken; /** * 過時時間 */ private long expiresIn; /** * 社區帳戶的id */ private String socialUid; }