import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
@Override
protected void doView(RenderRequest request, RenderResponse response) throws PortletException, IOException {
    AccessToken accessToken = getAccessToken();
    final Oauth2 service = getOAuthProvider().getAuthorizedSocialApiObject(accessToken, Oauth2.class);

    Userinfo userInfo = new GooglePortletRequest<Userinfo>(request, response, getPortletContext(), getOAuthProvider(),
            REQUIRED_SCOPE) {

        @Override
        protected Userinfo invokeRequest() throws IOException {
            return service.userinfo().v2().me().get().execute();
        }

    }.executeRequest();

    if (userInfo != null) {
        request.setAttribute(GOOGLE_USER_INFO, userInfo);
    }

    PortletRequestDispatcher prd = getPortletContext().getRequestDispatcher("/jsp/google/userinfo.jsp");
    prd.include(request, response);
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
/**
 * Send a request to the UserInfo API to retrieve the user's
 * information.
 * 
 * @param credentials OAuth 2.0 credentials to authorize the request.
 * @return User's information.
 * @throws NoUserIdException An error occurred.
 */
static Userinfo getUserInfo(Credential credentials)
        throws NoUserIdException {
    Oauth2 userInfoService = new Oauth2.Builder(new NetHttpTransport(),
            new JacksonFactory(), credentials).build();
    Userinfo userInfo = null;
    try {
        userInfo = userInfoService.userinfo().get().execute();
    } catch (IOException e) {
        System.err.println("An error occurred: " + e);
    }
    if (userInfo != null && userInfo.getId() != null) {
        return userInfo;
    } else {
        throw new NoUserIdException();
    }
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
protected Userinfo getUserInfo(Credential credentials)
	throws NoSuchUserIdException {

	Oauth2.Builder builder = new Oauth2.Builder(
		new NetHttpTransport(), new JacksonFactory(), credentials);

	Oauth2 oauth2 = builder.build();

	Userinfo userInfo = null;

	try {
		userInfo = oauth2.userinfo().get().execute();
	}
	catch (IOException e) {
		System.err.println("An error occurred: " + e);
	}

	if ((userInfo != null) && (userInfo.getId() != null)) {
		return userInfo;
	}
	else {
		throw new NoSuchUserIdException();
	}
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
/**
 * If OAuth2 redirect callback is invoked and there is a code query param,
 * retrieve user credentials and profile. Then, redirect to the home page.
 * @param req   Request object.
 * @param resp  Response object.
 * @throws IOException
 */
protected boolean handleCallbackIfRequired(HttpServletRequest req,
    HttpServletResponse resp) throws IOException {
  String code = req.getParameter("code");
  if (code != null) {
    // retrieve new credentials with code
    Credential credential = credentialManager.retrieve(code);
    // request userinfo
    Oauth2 service = getOauth2Service(credential);
    Userinfo about = service.userinfo().get().execute();
    String id = about.getId();
    credentialManager.save(id, credential);
    req.getSession().setAttribute(KEY_SESSION_USERID, id);

    String redirect = (String) req.getSession().getAttribute(KEY_SESSION_REDIRECT);
    req.getSession().setAttribute(KEY_SESSION_REDIRECT, null);
    if (redirect != null) {
      resp.sendRedirect(redirect);
    } else {
      resp.sendRedirect("?");
    }
    return true;
  }
  return false;
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
private static UserProfile createUserProfile(User user) throws IOException {
    UserProfile userProfile = UserProfile.create(user);

    try {
        Userinfo userInfo = GoogleApiUtils.getOauth2(userProfile.getEmail())
                .userinfo()
                .get()
                .execute();
        userProfile.setFullName(userInfo.getName());
    } catch (GoogleJsonResponseException e) {
        int statusCode = e.getDetails().getCode();
        if (statusCode == 401 || statusCode == 403) {
            // TODO: Log a warning and continue
        } else {
            throw e;
        }
    }

    return userProfile;
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
protected User addUser(
		HttpSession session, long companyId, Userinfo userinfo)
	throws Exception {

	long creatorUserId = 0;
	boolean autoPassword = true;
	String password1 = StringPool.BLANK;
	String password2 = StringPool.BLANK;
	boolean autoScreenName = true;
	String screenName = StringPool.BLANK;
	String emailAddress = userinfo.getEmail();
	String openId = StringPool.BLANK;
	Locale locale = LocaleUtil.getDefault();
	String firstName = userinfo.getGivenName();
	String middleName = StringPool.BLANK;
	String lastName = userinfo.getFamilyName();
	int prefixId = 0;
	int suffixId = 0;
	boolean male = Validator.equals(userinfo.getGender(), "male");
	int birthdayMonth = Calendar.JANUARY;
	int birthdayDay = 1;
	int birthdayYear = 1970;
	String jobTitle = StringPool.BLANK;
	long[] groupIds = null;
	long[] organizationIds = null;
	long[] roleIds = null;
	long[] userGroupIds = null;
	boolean sendEmail = true;

	ServiceContext serviceContext = new ServiceContext();

	User user = UserLocalServiceUtil.addUser(
		creatorUserId, companyId, autoPassword, password1, password2,
		autoScreenName, screenName, emailAddress, 0, openId,
		locale, firstName, middleName, lastName, prefixId, suffixId, male,
		birthdayMonth, birthdayDay, birthdayYear, jobTitle, groupIds,
		organizationIds, roleIds, userGroupIds, sendEmail, serviceContext);

	user = UserLocalServiceUtil.updateLastLogin(
		user.getUserId(), user.getLoginIP());

	user = UserLocalServiceUtil.updatePasswordReset(
		user.getUserId(), false);

	user = UserLocalServiceUtil.updateEmailAddressVerified(
		user.getUserId(), true);

	session.setAttribute("GOOGLE_USER_EMAIL_ADDRESS", emailAddress);

	return user;
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
protected User setGoogleCredentials(
		HttpSession session, long companyId, Userinfo userinfo)
	throws Exception {

	if (userinfo == null) {
		return null;
	}

	User user = null;

	String emailAddress = userinfo.getEmail();

	if ((user == null) && Validator.isNotNull(emailAddress)) {
		user = UserLocalServiceUtil.fetchUserByEmailAddress(
			companyId, emailAddress);

		if ((user != null) &&
			(user.getStatus() != WorkflowConstants.STATUS_INCOMPLETE)) {

			session.setAttribute(
				"GOOGLE_USER_EMAIL_ADDRESS", emailAddress);
		}
	}

	if (user != null) {
		if (user.getStatus() == WorkflowConstants.STATUS_INCOMPLETE) {
			session.setAttribute(
				"GOOGLE_INCOMPLETE_USER_ID", userinfo.getId());

			user.setEmailAddress(userinfo.getEmail());
			user.setFirstName(userinfo.getGivenName());
			user.setLastName(userinfo.getFamilyName());

			return user;
		}

		user = updateUser(user, userinfo);
	}
	else {
		user = addUser(session, companyId, userinfo);
	}

	return user;
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
protected User updateUser(User user, Userinfo userinfo)
	throws Exception {

	String emailAddress = userinfo.getEmail();
	String firstName = userinfo.getGivenName();
	String lastName = userinfo.getFamilyName();
	boolean male = Validator.equals(userinfo.getGender(), "male");

	if (emailAddress.equals(user.getEmailAddress()) &&
		firstName.equals(user.getFirstName()) &&
		lastName.equals(user.getLastName()) && (male == user.isMale())) {

		return user;
	}

	Contact contact = user.getContact();

	Calendar birthdayCal = CalendarFactoryUtil.getCalendar();

	birthdayCal.setTime(contact.getBirthday());

	int birthdayMonth = birthdayCal.get(Calendar.MONTH);
	int birthdayDay = birthdayCal.get(Calendar.DAY_OF_MONTH);
	int birthdayYear = birthdayCal.get(Calendar.YEAR);

	long[] groupIds = null;
	long[] organizationIds = null;
	long[] roleIds = null;
	List<UserGroupRole> userGroupRoles = null;
	long[] userGroupIds = null;

	ServiceContext serviceContext = new ServiceContext();

	if (!StringUtil.equalsIgnoreCase(
			emailAddress, user.getEmailAddress())) {

		UserLocalServiceUtil.updateEmailAddress(
			user.getUserId(), StringPool.BLANK, emailAddress, emailAddress);
	}

	UserLocalServiceUtil.updateEmailAddressVerified(user.getUserId(), true);

	return UserLocalServiceUtil.updateUser(
		user.getUserId(), StringPool.BLANK, StringPool.BLANK,
		StringPool.BLANK, false, user.getReminderQueryQuestion(),
		user.getReminderQueryAnswer(), user.getScreenName(), emailAddress,
		0, user.getOpenId(), user.getLanguageId(),
		user.getTimeZoneId(), user.getGreeting(), user.getComments(),
		firstName, user.getMiddleName(), lastName, contact.getPrefixId(),
		contact.getSuffixId(), male, birthdayMonth, birthdayDay,
		birthdayYear, contact.getSmsSn(), contact.getAimSn(),
		contact.getFacebookSn(), contact.getIcqSn(), contact.getJabberSn(),
		contact.getMsnSn(), contact.getMySpaceSn(), contact.getSkypeSn(),
		contact.getTwitterSn(), contact.getYmSn(), contact.getJobTitle(),
		groupIds, organizationIds, roleIds, userGroupRoles, userGroupIds,
		serviceContext);
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
public User getUserInfo(String userId, Credential credential) throws IOException {
	Oauth2 service = getOauth2Service(credential);
	Userinfo userInfo = service.userinfo().get().execute();
	return new User(userInfo.getEmail(), userInfo.getLink(), userInfo.getPicture());
}
 

import com.google.api.services.oauth2.model.Userinfo; //导入依赖的package包/类
public String execute(
		HttpServletRequest request, HttpServletResponse response)
	throws Exception {

	ThemeDisplay themeDisplay = (ThemeDisplay)request.getAttribute(
		WebKeys.THEME_DISPLAY);

	String cmd = ParamUtil.getString(request, Constants.CMD);

	String redirectUri = PortalUtil.getPortalURL(request) + _REDIRECT_URI;

	if (cmd.equals("login")) {
		GoogleAuthorizationCodeFlow flow = getFlow();

		GoogleAuthorizationCodeRequestUrl
			googleAuthorizationCodeRequestUrl = flow.newAuthorizationUrl();

		googleAuthorizationCodeRequestUrl.setRedirectUri(redirectUri);

		String url = googleAuthorizationCodeRequestUrl.build();

		response.sendRedirect(url);
	}
	else if (cmd.equals("token")) {
		HttpSession session = request.getSession();

		String code = ParamUtil.getString(request, "code");

		if (Validator.isNotNull(code)) {
			Credential credential = exchangeCode(code, redirectUri);

			Userinfo userinfo = getUserInfo(credential);

			User user = setGoogleCredentials(
				session, themeDisplay.getCompanyId(), userinfo);

			if ((user != null) &&
				(user.getStatus() == WorkflowConstants.STATUS_INCOMPLETE)) {

				redirectUpdateAccount(request, response, user);

				return null;
			}

			PortletURL portletURL = PortletURLFactoryUtil.create(
				request, PortletKeys.FAST_LOGIN, themeDisplay.getPlid(),
				PortletRequest.RENDER_PHASE);

			portletURL.setWindowState(LiferayWindowState.POP_UP);

			portletURL.setParameter(
				"struts_action", "/login/login_redirect");

			response.sendRedirect(portletURL.toString());
		}
	}

	return null;
}