11

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

@@ -1,5 +1,7 @@
package com.ekexiu.portal.oauth;
import java.io.IOException;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.HashMap;
@@ -7,6 +9,7 @@ import java.util.Map;
import java.util.concurrent.TimeUnit;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.method.SetCookie;
import org.jfw.apt.web.annotation.operate.Get;
@@ -14,6 +17,7 @@ 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.reflect.TypeReference;
import org.jfw.util.state.StateCode;
import com.ekexiu.portal.dao.ProfessorDao;
@@ -23,10 +27,14 @@ import com.ekexiu.portal.po.Professor;
import com.ekexiu.portal.po.User;
import com.ekexiu.portal.po.UserOpenId;
import com.ekexiu.portal.pojo.SessionUser;
import com.ekexiu.portal.util.HttpUtil;
@Path("/oauth")
public class OAuthService {
	private static final Type MAP_TYPE = new TypeReference<Map<String, Object>>() {
	}.getType();
	private long expriesWithOpenId = 1000 * 60 * 10;
	@Autowrie
@@ -36,6 +44,9 @@ public class OAuthService {
	@Autowrie
	private ProfessorDao professorDao;
	private String xcxAppid = "";
	private String xcxSecret = "";
	private Map<String, OAuthHandler> handlers;
	public Map<String, OAuthHandler> getHandlers() {
@@ -122,7 +133,7 @@ public class OAuthService {
		User user = this.userDao.query(con, sc.getValue().getUserid());
		if (null == user)
			return null;
		
		JfwAppContext.removeCachedObject(authCode);
		SessionUser ret = new SessionUser();
		ret.setId(user.getId());
@@ -191,16 +202,14 @@ public class OAuthService {
			}
		}
	}
	
	
	
	@Post
	@Path("/checkAssociated")
	public boolean associcated(@JdbcConn(false) Connection con,String userid,String oauthType)throws SQLException,JfwBaseException{
	public boolean associcated(@JdbcConn(false) Connection con, String userid, String oauthType) throws SQLException, JfwBaseException {
		if (null == this.handlers.get(oauthType)) {
			throw new JfwBaseException(-1, "invalid oauthType");
		}
		return userOpenIdDao.queryByUserid(con, oauthType, userid)!=null;
		return userOpenIdDao.queryByUserid(con, oauthType, userid) != null;
	}
	@Post
@@ -238,6 +247,15 @@ public class OAuthService {
		return ret;
	}
	@Get
	@Path("/xcx/openid")
	public String jscode2session(String code,@Nullable String appid,@Nullable String secret) throws IOException {
		if(appid==null) appid = this.xcxAppid;
		if(secret ==null) secret = this.xcxSecret;
		return (String)HttpUtil.<Map<String,Object>>loadJsonObject("https://api.weixin.qq.com/sns/jscode2session?appid=" + appid + "&secret=" + secret + "&js_code=" + code
				+ "&grant_type=authorization_code", MAP_TYPE).get("openid");
	}
	public static class AuthLoginResponse {
		private boolean associated;
		private String authCode;