腾讯微博授权Oauth2.0

0 0
腾讯微博授权Oauth2.00

如何改成最新的腾讯微博授权Oauth2.0

回调无法获得oauth_token与oauth_verifier
@RequestMapping(value = "/tencent/login", method = RequestMethod.GET)
	public String tencentLogin(HttpServletRequest request, Model m) throws IOException {
		
		
		com.tencent.weibo.beans.OAuth oauth = new com.tencent.weibo.beans.OAuth();
		OAuthClient auth = new OAuthClient();
		try {
			oauth = auth.requestToken(oauth);
			
			
			if (oauth.getStatus() == 1) {
				return EnumErrorCode.ERROR_404.getValue();
			} else {
				String oauth_token = oauth.getOauth_token();
				if(oauth_token != null && !"".equals(oauth_token)){
					String clientIp = WingsStrUtil.getRemortIP(request);
					
					cacheService.putCache("/OAuth/" + clientIp + oauth_token, oauth, Constants.EXPIRY);
					cacheService.putCache("/OAuthClient/" + clientIp + oauth_token, auth, Constants.EXPIRY);
					
					String url = "http://open.t.qq.com/cgi-bin/authorize?oauth_token=" + oauth_token;
					return "redirect:" + url;
				}
			}
		} catch (Exception e1) {
			e1.printStackTrace();
		}
		return "/accounts/login";

	}


/**
	 * 腾讯微博登录成功后的回调地址
	 * @param oauth_token
	 * @param oauth_verifier
	 * @param openid
	 * @return
	 */
	@RequestMapping(value = "/tencent/login/callback", method = RequestMethod.GET)
	public String tencentLoginCallback(String oauth_token, String oauth_verifier, String openid, String openkey, 
			HttpServletRequest request, HttpServletResponse response, Model model) {
		if(openid == null || "".equals(openid))
			return EnumErrorCode.ERROR_404.getValue();
		
		String clientIp = WingsStrUtil.getRemortIP(request);
		com.tencent.weibo.beans.OAuth oauth = (OAuth)cacheService.getCache("/OAuth/" + clientIp + oauth_token, Constants.EXPIRY);
		OAuthClient auth = (OAuthClient)cacheService.getCache("/OAuthClient/" + clientIp + oauth_token, Constants.EXPIRY);
		try {
			oauth.setOauth_verifier(oauth_verifier);
			oauth = auth.accessToken(oauth);
			//认证状态,0:成功,1:Request失败,2:Access失败
			if(oauth.getStatus() == 0){
				ThirdpartUser thirdpartUser = userService.getThirdpartUser(openid, EnumThirdpartType.TENCENT);
				
				
				//存在中间表
				if(thirdpartUser != null){
					thirdpartService.updateVerifier(openid, EnumThirdpartType.TENCENT, oauth_verifier);
					com.a.b.pojo.accounts.User a= userService.login(thirdpartUser.getUserId(), request, response);
					

						cacheService.putCache(ThirdPartController.class.getName() + "/OAuthClient/" + a.getId(), auth, 24 * 3600);
						CookieUtil.saveUser(request, response, a.getId(), a.getRandom(), false);
					}else{
						return EnumErrorCode.ERROR_404.getValue();
					}
				}else{//不存在中间表
					User_API us = new User_API();
					JSONObject jsonObject = new JSONObject(us.info(oauth, "json"));
					
					//没有获取到用户信息
					if(jsonObject == null)
						return EnumErrorCode.ERROR_404.getValue();
					else{
						jsonObject = jsonObject.getJSONObject("data");
						String name = jsonObject.getString("nick");
						String iconImageLarge = jsonObject.getString("head");
						iconImageLarge = imageService.getHttpImageTempFile(iconImageLarge, 180, 180, false, false);
						if(iconImageLarge != null && !"".equals(iconImageLarge))
							iconImageLarge = imageService.getTempImageUrl(iconImageLarge);
						String location = jsonObject.getString("location");
						String email = jsonObject.getString("email");
						String[] address = location.split(" ");
						String cityName = null;
						int cityId = 0;
						if(address.length > 1)
							cityName = address[1];
						if(cityName != null){
							City city = userService.getLikeCity(cityName);
							if(city == null)
								cityId = 0;
							else 
								cityId = city.getId();
						}
						
						model.addAttribute("email", email);
						model.addAttribute("cityId", cityId);
						model.addAttribute("thirdpartId", openid);
						model.addAttribute("iconImageLarge", iconImageLarge);
						model.addAttribute("name", name);
						model.addAttribute("thirdpartType", EnumThirdpartType.TENCENT.getValue());
						model.addAttribute("verifier", oauth_verifier);
						
						return "/accounts/confim";
					}
				}
			}else//验证失败
				return EnumErrorCode.ERROR_404.getValue();
			
		} catch (Exception e1) {
			e1.printStackTrace();
		}
		
		return "redirect:/";
	}
有没有更好的方式来实现