--第三方登陆相关(未完成)

src/main/java/com/ekexiu/portal/dao/UserOpenIdDao.java

@@ -0,0 +1,34 @@
package com.ekexiu.portal.dao;
import com.ekexiu.portal.po.UserOpenId;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
@DAO
public interface UserOpenIdDao {
    @Insert
    int insert(Connection con, UserOpenId user) throws SQLException;
    @DeleteWith
    @From(UserOpenId.class)
    int delete(Connection con, String userid) throws SQLException;
    @DeleteWith
    @From(UserOpenId.class)
    int delete(Connection con, String oauthType, String openid) throws SQLException;
    @SelectList
    List<UserOpenId> query(Connection con, String userid) throws SQLException;
    @SelectOne
    @Nullable
    UserOpenId query(Connection con, String oauthType, String userid) throws SQLException;
}

src/main/java/com/ekexiu/portal/oauth/OAuthHandler.java

@@ -0,0 +1,9 @@
package com.ekexiu.portal.oauth;
import org.jfw.util.exception.JfwBaseException;
public interface OAuthHandler {
	String getType();
	String getLoginUrl();
	OAuthUser login(String code) throws JfwBaseException;
}

src/main/java/com/ekexiu/portal/oauth/OAuthService.java

@@ -0,0 +1,195 @@
package com.ekexiu.portal.oauth;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.method.SetCookie;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.state.StateCode;
import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.UserDao;
import com.ekexiu.portal.dao.UserOpenIdDao;
import com.ekexiu.portal.po.User;
import com.ekexiu.portal.po.UserOpenId;
import com.ekexiu.portal.pojo.SessionUser;
import com.ekexiu.portal.service.SysService;
@Path("/oauth")
public class OAuthService {
    private long expriesWithOpenId = 1000 * 60 * 10;
    @Autowrie
    private UserOpenIdDao userOpenIdDao;
    @Autowrie
    private UserDao userDao;
    @Autowrie
    private ProfessorDao professorDao;
    private Map<String, OAuthHandler> handlers;
    public Map<String, OAuthHandler> getHandlers() {
        return handlers;
    }
    public void setHandlers(Map<String, OAuthHandler> handlers) {
        this.handlers = handlers;
    }
    public UserOpenIdDao getUserOpenIdDao() {
        return userOpenIdDao;
    }
    public void setUserOpenIdDao(UserOpenIdDao userOpenIdDao) {
        this.userOpenIdDao = userOpenIdDao;
    }
    public UserDao getUserDao() {
        return userDao;
    }
    public void setUserDao(UserDao userDao) {
        this.userDao = userDao;
    }
    public long getExpriesWithOpenId() {
        return expriesWithOpenId;
    }
    public void setExpriesWithOpenId(long expriesWithOpenId) {
        this.expriesWithOpenId = expriesWithOpenId;
    }
    public ProfessorDao getProfessorDao() {
        return professorDao;
    }
    public void setProfessorDao(ProfessorDao professorDao) {
        this.professorDao = professorDao;
    }
    @Get
    @Path("/validCode")
    public AuthLoginResponse validCode(@JdbcConn Connection con, String code, String state) throws SQLException, JfwBaseException {
        OAuthHandler oah = this.handlers.get(state);
        if (oah == null)
            throw new IllegalArgumentException("非法的参数{state=" + state);
        OAuthUser ou = oah.login(code);
        UserOpenId uoi = this.userOpenIdDao.query(con, oah.getType(), ou.getOpenId());
        StateCode<OAuthUser, UserOpenId> sc = new StateCode<OAuthUser, UserOpenId>();
        final String key = JfwAppContext.cacheObjectAndGenKey(sc);
        sc.setKey(ou);
        sc.setValue(uoi);
        sc.setBuildTime(System.currentTimeMillis());
        sc.setExpiredTime(sc.getBuildTime() + this.expriesWithOpenId);
        JfwAppContext.getScheduledExecutorService().schedule(new Runnable() {
            @Override
            public void run() {
                JfwAppContext.removeCachedObject(key);
            }
        }, this.expriesWithOpenId, TimeUnit.MILLISECONDS);
        AuthLoginResponse alr = new AuthLoginResponse();
        alr.setAssociated(null != uoi);
        alr.setAuthCode(key);
        return alr;
    }
    @SetCookie(checkResultNull = true, path = "/", value = { "userid=result.getId()", "userMobilePhone=result.getMobilePhone()", "userType=result.getType()",
            "userAuth=String.valueOf(result.isAuth())", "userEmail=result.getEmail()==null?\"\":result.getEmail()",
            "userName=result.getName()==null?\"\":java.net.URLEncoder.encode(result.getName(),\"utf-8\")" })
    @Post
    @Path("/login")
    public SessionUser login(@JdbcConn Connection con, String authCode) throws SQLException, JfwBaseException {
        @SuppressWarnings("unchecked")
        StateCode<OAuthUser, UserOpenId> sc = (StateCode<OAuthUser, UserOpenId>) JfwAppContext.getCachedObject(authCode);
        JfwAppContext.removeCachedObject(authCode);
        if (sc == null || sc.getExpiredTime() < System.currentTimeMillis())
            throw new JfwBaseException(-1, "authCode is expired");
        if (null == sc.getValue())
            throw new JfwBaseException(-2, "authCode is invalid openid not associate local user");
        User user = this.userDao.query(con, sc.getValue().getUserid());
        if (null == user)
            return null;
        SessionUser ret = new SessionUser();
        ret.setId(user.getId());
        if (null != this.professorDao.query(con, user.getId())) {
            ret.setName(this.professorDao.query(con, user.getId()).getName());
        }
        ret.setMobilePhone(user.getMobilePhone());
        ret.setType(user.getUserType());
        ret.setEmail(user.getEmail());
        ret.setAuth(!SysService.DEFAULT_PASS_WORD.equals(user.getPasswd()));
        return ret;
    }
    @Post
    @Path("/validOpenid")
    public AuthLoginResponse validOpenid(@JdbcConn Connection con, String authType, String openid) throws SQLException, JfwBaseException {
        OAuthUser ou = new OAuthUser();
        ou.setType(authType);
        ou.setOpenId(openid);
        UserOpenId uoi = this.userOpenIdDao.query(con, authType, openid);
        AuthLoginResponse alr = new AuthLoginResponse();
        StateCode<OAuthUser, UserOpenId> sc = new StateCode<OAuthUser, UserOpenId>();
        final String key = JfwAppContext.cacheObjectAndGenKey(sc);
        sc.setKey(ou);
        sc.setValue(uoi);
        sc.setBuildTime(System.currentTimeMillis());
        sc.setExpiredTime(sc.getBuildTime() + this.expriesWithOpenId);
        JfwAppContext.getScheduledExecutorService().schedule(new Runnable() {
            @Override
            public void run() {
                JfwAppContext.removeCachedObject(key);
            }
        }, this.expriesWithOpenId, TimeUnit.MILLISECONDS);
        alr.setAssociated(null != uoi);
        alr.setAuthCode(key);
        return alr;
    }
    
    @Get
    @Path("/redirectUris")
    public Map<String, String> getRedirectUris() {
        Map<String, String> ret = new HashMap<String, String>();
        for (Map.Entry<String, OAuthHandler> h : this.handlers.entrySet()) {
            ret.put(h.getKey(), h.getValue().getLoginUrl());
        }
        return ret;
    }
    public static class AuthLoginResponse {
        private boolean associated;
        private String authCode;
        public boolean isAssociated() {
            return associated;
        }
        public void setAssociated(boolean associated) {
            this.associated = associated;
        }
        public String getAuthCode() {
            return authCode;
        }
        public void setAuthCode(String authCode) {
            this.authCode = authCode;
        }
    }
}

src/main/java/com/ekexiu/portal/oauth/OAuthUser.java

@@ -0,0 +1,58 @@
package com.ekexiu.portal.oauth;
public class OAuthUser {
	private String openId;
    private String type;
    private String accessToken;
    private long expiresIn;
    private String refreshToken;
    private String scope;
	public String getAccessToken() {
		return accessToken;
	}
	public void setAccessToken(String accessToken) {
		this.accessToken = accessToken;
	}
	public long getExpiresIn() {
		return expiresIn;
	}
	public void setExpiresIn(long expiresIn) {
		this.expiresIn = expiresIn;
	}
	public String getRefreshToken() {
		return refreshToken;
	}
	public void setRefreshToken(String refreshToken) {
		this.refreshToken = refreshToken;
	}
	public String getScope() {
		return scope;
	}
	public void setScope(String scope) {
		this.scope = scope;
	}
	public String getType() {
		return type;
	}
	public void setType(String type) {
		this.type = type;
	}
	public String getOpenId() {
		return openId;
	}
	public void setOpenId(String openId) {
		this.openId = openId;
	}
}

src/main/java/com/ekexiu/portal/oauth/weixin/AccessTokenResponse.java

@@ -0,0 +1,77 @@
package com.ekexiu.portal.oauth.weixin;
public class AccessTokenResponse {
	private String access_token ;	
	private long expires_in; 
	private String refresh_token;
	private String openid; 
	private String scope;
	private String unionid;
	private String errcode;
	private String errmsg;
	
	public long getExpires_in() {
		return expires_in;
	}
	public void setExpires_in(long expires_in) {
		this.expires_in = expires_in;
	}
	public String getRefresh_token() {
		return refresh_token;
	}
	public void setRefresh_token(String refresh_token) {
		this.refresh_token = refresh_token;
	}
	public String getOpenid() {
		return openid;
	}
	public void setOpenid(String openid) {
		this.openid = openid;
	}
	public String getScope() {
		return scope;
	}
	public void setScope(String scope) {
		this.scope = scope;
	}
	public String getUnionid() {
		return unionid;
	}
	public void setUnionid(String unionid) {
		this.unionid = unionid;
	}
	public String getErrcode() {
		return errcode;
	}
	public void setErrcode(String errcode) {
		this.errcode = errcode;
	}
	public String getErrmsg() {
		return errmsg;
	}
	public void setErrmsg(String errmsg) {
		this.errmsg = errmsg;
	}
	public String getAccess_token() {
		return access_token;
	}
	public void setAccess_token(String access_token) {
		this.access_token = access_token;
	}
}

src/main/java/com/ekexiu/portal/oauth/weixin/WeiXinHandler.java

@@ -0,0 +1,119 @@
package com.ekexiu.portal.oauth.weixin;
import java.io.IOException;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.json.JsonService;
import com.ekexiu.portal.oauth.OAuthHandler;
import com.ekexiu.portal.oauth.OAuthUser;
import com.ekexiu.portal.util.HttpUtil;
@Bean
public class WeiXinHandler implements OAuthHandler {
	public static final String OAUTH_TYPE = "weixin";
	/**
	 * 在微信上注册的APPID
	 */
	private String appid;
	/**
	 * 在微信上注册的APPID 对应的 APPSECRET
	 */
	private String appsecret;
	/**
	 * 微信请求OAUTH登录的URL
	 */
	private String codeUrl = "https://open.weixin.qq.com/connect/qrconnect";
	/**
	 * 微信登录授权后的跳转面页
	 */
	private String redirectUri;
	/**
	 * 微信请求OAUTH AccessToken的URL
	 */
	private String accessTokenUrl = "https://api.weixin.qq.com/sns/oauth2/access_token";
	public String getAccessTokenUrl() {
		return accessTokenUrl;
	}
	public void setAccessTokenUrl(String accessTokenUrl) {
		this.accessTokenUrl = accessTokenUrl;
	}
	public String getRedirectUri() {
		return redirectUri;
	}
	public void setRedirectUri(String redirectUri) {
		this.redirectUri = redirectUri;
	}
	public String getAppid() {
		return appid;
	}
	public void setAppid(String appid) {
		this.appid = appid;
	}
	public String getAppsecret() {
		return appsecret;
	}
	public void setAppsecret(String appsecret) {
		this.appsecret = appsecret;
	}
	public String getCodeUrl() {
		return codeUrl;
	}
	public void setCodeUrl(String codeUrl) {
		this.codeUrl = codeUrl;
	}
	@Override
	public String getType() {
		return OAUTH_TYPE;
	}
	@Override
	public String getLoginUrl() {
		StringBuilder sb = new StringBuilder();
		sb.append(this.codeUrl).append("?appid=").append(this.appid).append("&redirect_uri=").append(this.redirectUri)
				.append("&response_type=code&scope=snsapi_login&state=weixin#wechat_redirect");
		return sb.toString();
	}
	@Override
	public OAuthUser login(String code) throws JfwBaseException {
        AccessTokenResponse atr;
		try {
			atr = HttpUtil.loadJsonObject(this.buildAccessTokenURL(code),AccessTokenResponse.class);
		} catch (IOException e) {
			throw new JfwBaseException(91,e);
		}
        if(null!= atr.getErrcode()) throw new JfwBaseException(0,"访问微信access_token error:"+JsonService.toJson(atr));
		OAuthUser user = new OAuthUser();
		user.setType(this.getType());
		user.setOpenId(atr.getOpenid());
		user.setAccessToken(atr.getAccess_token());
		user.setExpiresIn(atr.getExpires_in());
		user.setScope(atr.getScope());
		user.setRefreshToken(atr.getRefresh_token());
		return user;
	}
	private String buildAccessTokenURL(String code) {
		StringBuilder sb = new StringBuilder();
		sb.append(this.accessTokenUrl).append("?appid=").append(this.appid)
		.append("&secret=").append(this.appsecret)
		.append("&code=").append(code)
		.append("&grant_type=authorization_code");
		return sb.toString();
	}
}

src/main/java/com/ekexiu/portal/po/UserOpenId.java

@@ -0,0 +1,66 @@
package com.ekexiu.portal.po;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.annotation.entry.Unique;
import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
@Table
@PrimaryKey({ "oauthType", "openid", "userid" })
@Uniques({ @Unique(clolumns = { "userid", "oauthType" }, name = "USER_OPEN_ID_UO"), @Unique(clolumns = { "oauthType", "openid" }, name = "USER_OPEN_ID_OO") })
public class UserOpenId implements CreateTimeSupported, ModifyTimeSupported {
    private String createTime;
    private String modifyTime;
    private String userid;
    private String oauthType;
    private String openid;
    @Column(DE.id_32)
    public String getUserid() {
        return this.userid;
    }
    public void setUserid(String userid) {
        this.userid = userid;
    }
    @Column(dbType = "text", handlerClass = StringHandler.class, insertable = true, nullable = false, queryable = true, renewable = true)
    public String getOauthType() {
        return this.oauthType;
    }
    public void setOauthType(String oauthType) {
        this.oauthType = oauthType;
    }
    @Column(dbType = "text", handlerClass = StringHandler.class, insertable = true, nullable = false, queryable = true, renewable = true)
    public String getOpenid() {
        return this.openid;
    }
    public void setOpenid(String openid) {
        this.openid = openid;
    }
    public String getModifyTime() {
        return this.modifyTime;
    }
    public void setModifyTime(String modifyTime) {
        this.modifyTime = modifyTime;
    }
    public String getCreateTime() {
        return this.createTime;
    }
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
}

src/main/java/com/ekexiu/portal/util/HttpUtil.java

@@ -0,0 +1,95 @@
package com.ekexiu.portal.util;
import java.io.IOException;
import java.lang.reflect.Type;
import java.net.HttpURLConnection;
import java.net.URL;
import org.jfw.util.ConstData;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
public final class HttpUtil {
    public static String loadAsString(String url, String enc) throws IOException {
        URL aurl = new URL(url);
        HttpURLConnection uc = (HttpURLConnection) aurl.openConnection();
        try {
            byte[] bs = IoUtil.readStream(uc.getInputStream(), true);
            return new String(bs, enc);
        } finally {
            try {
                uc.disconnect();
            } catch (Throwable th) {
            }
        }
    }
    public static String loadAsString(String url) throws IOException {
        URL aurl = new URL(url);
        HttpURLConnection uc = (HttpURLConnection) aurl.openConnection();
        try {
            byte[] bs = IoUtil.readStream(uc.getInputStream(), true);
            return new String(bs, ConstData.UTF8);
        } finally {
            try {
                uc.disconnect();
            } catch (Throwable th) {
            }
        }
    }
    public static <T> T loadJsonObject(String url, String enc, Type typeOfT) throws IOException {
        URL aurl = new URL(url);
        HttpURLConnection uc = (HttpURLConnection) aurl.openConnection();
        try {
            byte[] bs = IoUtil.readStream(uc.getInputStream(), true);
            return JsonService.fromJson(new String(bs, enc), typeOfT);
        } finally {
            try {
                uc.disconnect();
            } catch (Throwable th) {
            }
        }
    }
    public static <T> T loadJsonObject(String url, Type typeOfT) throws IOException {
        URL aurl = new URL(url);
        HttpURLConnection uc = (HttpURLConnection) aurl.openConnection();
        try {
            byte[] bs = IoUtil.readStream(uc.getInputStream(), true);
            return JsonService.fromJson(new String(bs, ConstData.UTF8), typeOfT);
        } finally {
            try {
                uc.disconnect();
            } catch (Throwable th) {
            }
        }
    }
    public static <T> T loadJsonObject(String url, String enc, Class<T> clazz) throws IOException {
        URL aurl = new URL(url);
        HttpURLConnection uc = (HttpURLConnection) aurl.openConnection();
        try {
            byte[] bs = IoUtil.readStream(uc.getInputStream(), true);
            return JsonService.fromJson(new String(bs, enc), clazz);
        } finally {
            try {
                uc.disconnect();
            } catch (Throwable th) {
            }
        }
    }
    public static <T> T loadJsonObject(String url, Class<T> clazz) throws IOException {
        URL aurl = new URL(url);
        HttpURLConnection uc = (HttpURLConnection) aurl.openConnection();
        try {
            byte[] bs = IoUtil.readStream(uc.getInputStream(), true);
            return JsonService.fromJson(new String(bs, ConstData.UTF8), clazz);
        } finally {
            try {
                uc.disconnect();
            } catch (Throwable th) {
            }
        }
    }
}