1

src/main/java/com/ekexiu/portal/service/SysService.java

@@ -29,6 +29,8 @@ import org.jfw.util.state.StateCode;
import com.ekexiu.portal.dao.OrgDao;
import com.ekexiu.portal.dao.OrgUserDao;
import com.ekexiu.portal.dao.PaperAuthorDao;
import com.ekexiu.portal.dao.PatentAuthorDao;
import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.UserDao;
import com.ekexiu.portal.dao.UserOpenIdDao;
@@ -74,6 +76,11 @@ public class SysService {
	@Autowrie
	private UserOpenIdDao userOpenIdDao;
	@Autowrie
	private PatentAuthorDao patentAuthorDao;
	@Autowrie
	private PaperAuthorDao paperAuthorDao;
	private String bindMailSubject;
	private String bindMailReplaceKey;
@@ -143,6 +150,22 @@ public class SysService {
	private String retrieveOrgFailTempalte;
	private String retrieveOrgFailSubject;
	public PatentAuthorDao getPatentAuthorDao() {
		return patentAuthorDao;
	}
	public void setPatentAuthorDao(PatentAuthorDao patentAuthorDao) {
		this.patentAuthorDao = patentAuthorDao;
	}
	public PaperAuthorDao getPaperAuthorDao() {
		return paperAuthorDao;
	}
	public void setPaperAuthorDao(PaperAuthorDao paperAuthorDao) {
		this.paperAuthorDao = paperAuthorDao;
	}
	public String getRegMailReplaceKey() {
		return regMailReplaceKey;
	}
@@ -753,7 +776,8 @@ public class SysService {
	 */
	@Post
	@Path("/regmobile")
	public String regMobile(@JdbcConn(true) Connection con, String state, String mobilePhone, String validateCode, String password, @Nullable String inviterId) throws SQLException, JfwBaseException {
	public String regMobile(@JdbcConn(true) Connection con, String state, String mobilePhone, String validateCode, String password, @Nullable String inviterId)
			throws SQLException, JfwBaseException {
		@SuppressWarnings("unchecked")
		StateCode<String, String> sc = (StateCode<String, String>) JfwAppContext.getCachedObject(state);
		if (sc == null || sc.getExpiredTime() < System.currentTimeMillis())
@@ -833,7 +857,7 @@ public class SysService {
	@Post
	@Path("/mobileReg")
	public String mobileReg(@JdbcConn(true) Connection con, String state, String mobilePhone, String validateCode, String password, @Nullable String inviterId,
			String name,	@Nullable String oauthType, @Nullable String openid, @Nullable String authCode) throws SQLException, JfwBaseException, IOException {
			String name, @Nullable String oauthType, @Nullable String openid, @Nullable String authCode) throws SQLException, JfwBaseException, IOException {
		@SuppressWarnings("unchecked")
		StateCode<String, String> sc = (StateCode<String, String>) JfwAppContext.getCachedObject(state);
		if (sc == null || sc.getExpiredTime() < System.currentTimeMillis())
@@ -868,6 +892,144 @@ public class SysService {
		}
	}
	@Post
	@Path("/regAndAssPatent")
	public boolean assPatent(@JdbcConn(true) Connection con, String state, String phone, String vc, @Nullable String inviterId, String name, String patent)
			throws SQLException, JfwBaseException, IOException {
		@SuppressWarnings("unchecked")
		 StateCode<String, String> sc = (StateCode<String, String>)
		 JfwAppContext.getCachedObject(state);
		 if (sc == null || sc.getExpiredTime() < System.currentTimeMillis())
		 throw new JfwBaseException(-1, "验证超时");
		 if (!sc.getKey().equals(phone)) {
		 throw new JfwBaseException(-2, "手机号与验证手机不匹配");
		 }
		 if (!sc.getValue().equals(vc)) {
		 throw new JfwBaseException(-3, "验证码错误");
		 }
		User user = null;
		boolean exists = false;
		String uid = StringUtil.buildUUID();
		try {
			try {
				user = new User();
				user.setId(uid);
				String passwd = StringUtil.md5("123456");
				user.setMobilePhone(phone);
				user.setPasswd(passwd);
				user.setUserType("0");
				user.setInviterId(inviterId);
				user.setActiveTime(DATE.format(new Date()));
				this.userDao.insert(con, user);
			} catch (SQLException e) {
				if ("23505".equals(e.getSQLState())) {
					con.rollback();
					user = userDao.queryByEmailOrMobilePhone(con, phone);
					if (user == null)
						throw new RuntimeException("not fonud  with query user by phone");
					exists = true;
					uid = user.getId();
				} else {
					throw e;
				}
			}
			if (exists) {
				Professor professor = this.professorDao.query(con, uid);
				if (professor == null) {
					professor = new Professor();
					professor.setId(uid);
					professor.setName(name);
					professor.setPhone(phone);
					this.professorService.insert(con, professor, null);
				} else {
					name = professor.getName();
				}
			} else {
				Professor professor = new Professor();
				professor.setId(uid);
				professor.setName(name);
				professor.setPhone(phone);
				this.professorService.insert(con, professor, null);
				if (inviterId != null) {
					this.growthLogService.invite(con, inviterId, uid);
				}
			}
			return this.patentAuthorDao.update(con, patent, uid, name) > 0;
		} finally {
			JfwAppContext.removeCachedObject(state);
		}
	}
	@Post
	@Path("/regAndAssPaper")
	public boolean assPaper(@JdbcConn(true) Connection con, String state, String phone, String vc, @Nullable String inviterId, String name, String paper)
			throws SQLException, JfwBaseException, IOException {
		@SuppressWarnings("unchecked")
		 StateCode<String, String> sc = (StateCode<String, String>)
		 JfwAppContext.getCachedObject(state);
		 if (sc == null || sc.getExpiredTime() < System.currentTimeMillis())
		 throw new JfwBaseException(-1, "验证超时");
		 if (!sc.getKey().equals(phone)) {
		 throw new JfwBaseException(-2, "手机号与验证手机不匹配");
		 }
		 if (!sc.getValue().equals(vc)) {
		 throw new JfwBaseException(-3, "验证码错误");
		 }
		User user = null;
		boolean exists = false;
		String uid = StringUtil.buildUUID();
		try {
			try {
				user = new User();
				user.setId(uid);
				String passwd = StringUtil.md5("123456");
				user.setMobilePhone(phone);
				user.setPasswd(passwd);
				user.setUserType("0");
				user.setInviterId(inviterId);
				user.setActiveTime(DATE.format(new Date()));
				this.userDao.insert(con, user);
			} catch (SQLException e) {
				if ("23505".equals(e.getSQLState())) {
					con.rollback();
					user = userDao.queryByEmailOrMobilePhone(con, phone);
					if (user == null)
						throw new RuntimeException("not fonud  with query user by phone");
					exists = true;
					uid = user.getId();
				} else {
					throw e;
				}
			}
			if (exists) {
				Professor professor = this.professorDao.query(con, uid);
				if (professor == null) {
					professor = new Professor();
					professor.setId(uid);
					professor.setName(name);
					professor.setPhone(phone);
					this.professorService.insert(con, professor, null);
				} else {
					name = professor.getName();
				}
			} else {
				Professor professor = new Professor();
				professor.setId(uid);
				professor.setName(name);
				professor.setPhone(phone);
				this.professorService.insert(con, professor, null);
				if (inviterId != null) {
					this.growthLogService.invite(con, inviterId, uid);
				}
			}
			return this.paperAuthorDao.update(con, paper, uid, name) > 0;
		} finally {
			JfwAppContext.removeCachedObject(state);
		}
	}
	/**
	 * 邮箱验证并注册
	 * 
@@ -1288,7 +1450,7 @@ public class SysService {
	}
	@SetCookie(checkResultNull = true, path = "/", value = { "userid=result.getId()", "userMobilePhone=result.getMobilePhone()", "userType=result.getType()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()","authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()", "authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userAuth=String.valueOf(result.isAuth())", "userName=result.getName()==null?\"\":java.net.URLEncoder.encode(result.getName(),\"utf-8\")" })
	@Post
	@Path("/invitelogin")
@@ -1308,14 +1470,14 @@ public class SysService {
		ret.setEmail(user.getEmail());
		if (professor != null) {
			ret.setName(professor.getName());
			ret.setAuthentication(professor.getAuthentication()+"");
			ret.setAuthentication(professor.getAuthentication() + "");
		}
		ret.setAuth(!DEFAULT_PASS_WORD.equals(user.getPasswd()));
		return ret;
	}
	@SetCookie(checkResultNull = true, path = "/", value = { "userid=result.getId()", "userMobilePhone=result.getMobilePhone()", "userType=result.getType()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()","authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()", "authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userAuth=String.valueOf(result.isAuth())", "userName=result.getName()==null?\"\":java.net.URLEncoder.encode(result.getName(),\"utf-8\")" })
	@Post
	@Path("/slogin")
@@ -1331,16 +1493,16 @@ public class SysService {
		ret.setMobilePhone(mobile);
		ret.setType(user.getUserType());
		ret.setEmail(user.getEmail());
		if(professor != null){
		if (professor != null) {
			ret.setName(professor.getName());
			ret.setAuthentication(professor.getAuthentication()+"");
			ret.setAuthentication(professor.getAuthentication() + "");
		}
		ret.setAuth(!DEFAULT_PASS_WORD.equals(user.getPasswd()));
		return ret;
	}
	@SetCookie(checkResultNull = true, path = "/", value = { "userid=result.getId()", "userMobilePhone=result.getMobilePhone()", "userType=result.getType()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()","authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()", "authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userAuth=String.valueOf(result.isAuth())", "userName=result.getName()==null?\"\":java.net.URLEncoder.encode(result.getName(),\"utf-8\")" })
	@Post
	@Path("/login")
@@ -1358,7 +1520,7 @@ public class SysService {
		Professor pf = this.professorDao.query(con, user.getId());
		if (null != pf) {
			ret.setName(pf.getName());
			ret.setAuthentication(pf.getAuthentication()+"");
			ret.setAuthentication(pf.getAuthentication() + "");
		}
		ret.setMobilePhone(user.getMobilePhone());
		ret.setType(user.getUserType());
@@ -1368,7 +1530,7 @@ public class SysService {
	}
	@SetCookie(checkResultNull = true, path = "/", value = { "userid=result.getId()", "userMobilePhone=result.getMobilePhone()", "userType=result.getType()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()","authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userEmail=result.getEmail()==null?\"\":result.getEmail()", "authentication=result.getAuthentication()==null?\"\":result.getAuthentication()",
			"userAuth=String.valueOf(result.isAuth())", "userName=result.getName()==null?\"\":java.net.URLEncoder.encode(result.getName(),\"utf-8\")" })
	@Post
	@Path("/mobileLogin")
@@ -1394,7 +1556,7 @@ public class SysService {
			Professor professor = this.professorDao.query(con, user.getId());
			if (null != professor) {
				ret.setName(professor.getName());
				ret.setAuthentication(professor.getAuthentication()+"");
				ret.setAuthentication(professor.getAuthentication() + "");
			}
			ret.setMobilePhone(user.getMobilePhone());
			ret.setType(user.getUserType());
@@ -1406,8 +1568,8 @@ public class SysService {
		}
	}
	@SetCookie(checkResultNull = true, path = "/", value = { "orgId=result.getId()", "orgType=result.getType()",
			"orgAuth=String.valueOf(result.isAuth())","orgEmail=result.getEmail()==null?\"\":result.getEmail()",
	@SetCookie(checkResultNull = true, path = "/", value = { "orgId=result.getId()", "orgType=result.getType()", "orgAuth=String.valueOf(result.isAuth())",
			"orgEmail=result.getEmail()==null?\"\":result.getEmail()",
			"orgName=result.getName()==null?\"\":java.net.URLEncoder.encode(result.getName(),\"utf-8\")" })
	@Post
	@Path("/orgLogin")