11

pom.xml

@@ -10,6 +10,7 @@
		<maven.compiler.source>1.7</maven.compiler.source>
		<maven.compiler.target>1.7</maven.compiler.target>
		<maven.war.filteringDeploymentDescriptors>true</maven.war.filteringDeploymentDescriptors>
		<maven.tomcat.path>/</maven.tomcat.path>
	</properties>
	<profiles>
@@ -87,12 +88,8 @@
			<artifactId>jfwWebUtil</artifactId>
			<version>0.0.2-SNAPSHOT</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>servlet-api</artifactId>
			<scope>provided</scope>
			<version>2.5</version>
		</dependency>
		<!-- <dependency> <groupId>javax.servlet</groupId> <artifactId>servlet-api</artifactId> 
			<scope>provided</scope> <version>2.5</version> </dependency> -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>druid</artifactId>
@@ -179,6 +176,19 @@
			<version>7.0.0</version>
			<!-- sign depends on kernel, layout and forms -->
		</dependency>
		<!-- https://mvnrepository.com/artifact/org.apache.tomcat/tomcat-websocket-api -->
		<dependency>
			<groupId>org.apache.tomcat</groupId>
			<artifactId>tomcat-catalina</artifactId>
			<version>7.0.69</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>javax.websocket</groupId>
			<artifactId>javax.websocket-api</artifactId>
			<version>1.1</version>
			<scope>provided</scope>
		</dependency>
	</dependencies>
	<build>
		<resources>
@@ -205,6 +215,12 @@
					<stopKey>foo</stopKey>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.apache.tomcat.maven</groupId>
				<artifactId>tomcat7-maven-plugin</artifactId>
				<version>2.1</version>
				<!-- <configuration> <path>/portal</path> </configuration> -->
			</plugin>
		</plugins>
		<finalName>portal</finalName>
	</build>

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

@@ -2046,8 +2046,8 @@ public abstract class ProfessorDao {
					userInfo.setAuthStatus(rs.getInt(10));
					userInfo.setId(rs.getString(11));
					userInfo.setName(rs.getString(12));
					userInfo.setEmail(rs.getString(13));
					userInfo.setPhone(rs.getString(14));
//					userInfo.setEmail(rs.getString(13));
//					userInfo.setPhone(rs.getString(14));
					userInfo.setActiveTime(rs.getString(15));
					userInfo.setActiveState(!(rs.getString(15) == null));
					userInfo.setOrgAuth(rs.getString(16));

src/main/java/com/ekexiu/portal/msg/ActorItem.java

@@ -0,0 +1,42 @@
package com.ekexiu.portal.msg;
public class ActorItem {
	private String id;
	private long time;
	private String timeStr;
	private String cnt;
	private int num;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public long getTime() {
		return time;
	}
	public void setTime(long time) {
		this.time = time;
	}
	public String getTimeStr() {
		return timeStr;
	}
	public void setTimeStr(String timeStr) {
		this.timeStr = timeStr;
	}
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	public int getNum() {
		return num;
	}
	public void setNum(int num) {
		this.num = num;
	}
	
	
	
}

src/main/java/com/ekexiu/portal/msg/Service.java

@@ -0,0 +1,176 @@
package com.ekexiu.portal.msg;
import java.sql.Connection;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.ListIterator;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.Path;
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.DateUtil;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
@Path("/webMsg")
public class Service {
	public static final List<ActorItem> EMPTY_ACTORS = Collections.<ActorItem> emptyList();
	@Autowrie
	private WebMsgDao webMsgDao;
	public WebMsgDao getWebMsgDao() {
		return webMsgDao;
	}
	public void setWebMsgDao(WebMsgDao webMsgDao) {
		this.webMsgDao = webMsgDao;
	}
	public static ActorItem build(WebMsgIdx wmi, String owner, SimpleDateFormat sf) {
		ActorItem item = new ActorItem();
		item.setCnt(wmi.getLastCnt());
		String actor = wmi.getActor();
		if (owner.equals(actor)) {
			item.setId(wmi.getOwner());
			item.setNum(wmi.getNumOfOwner());
		} else {
			item.setId(actor);
			item.setNum(wmi.getNumOfActor());
		}
		item.setTime(wmi.getLastTime());
		item.setTimeStr(sf.format(new Date(wmi.getLastTime())));
		return item;
	}
	public static List<ActorItem> build(List<WebMsgIdx> list, String owner) {
		if (list == null || list.isEmpty())
			return EMPTY_ACTORS;
		SimpleDateFormat sf = new SimpleDateFormat(DateUtil.DATETIME_FORMAT);
		List<ActorItem> ret = new ArrayList<ActorItem>(list.size());
		for (ListIterator<WebMsgIdx> it = list.listIterator(); it.hasNext();) {
			ret.add(build(it.next(), owner, sf));
		}
		return ret;
	}
	@Get
	@Path("/idx")
	public List<ActorItem> query(@JdbcConn Connection con, String id) throws SQLException {
		List<WebMsgIdx> list = webMsgDao.query(con, id);
		return build(list, id);
	}
	@Get
	@Path("/idx/pq")
	public PageQueryResult<ActorItem> query(@JdbcConn Connection con, String id, @DefaultValue("1") int pageNo, @DefaultValue("10") int pageSize)
			throws SQLException {
		PageQueryResult<WebMsgIdx> wmis = this.webMsgDao.query(con, id, pageSize, pageNo);
		PageQueryResult<ActorItem> ret = new PageQueryResult<ActorItem>();
		ret.setPageNo(ret.getPageNo());
		ret.setPageSize(wmis.getPageSize());
		ret.setTotal(wmis.getTotal());
		ret.setData(build(wmis.getData(), id));
		return ret;
	}
	@Post
	@Path
	public void send(@JdbcConn Connection con, String sender, String reciver, String cnt) throws SQLException {
		boolean ownerSend = true;
		String owner = sender;
		String actor = reciver;
		boolean next = true;
		if (sender.compareTo(reciver) < 0) {
			ownerSend = false;
			owner = reciver;
			actor = sender;
		}
		String id = StringUtil.buildUUID();
		WebMsgCnt wmc = new WebMsgCnt();
		wmc.setId(id);
		wmc.setCnt(cnt);
		wmc.setReaded(false);
		wmc.setReciver(reciver);
		wmc.setSender(sender);
		WebMsgIdx wmi = null;
		while (next) {
			try {
				long time = System.currentTimeMillis();
				wmc.setSendTime(DateUtil.formatDateTime(time));
				webMsgDao.insert(con, wmc);
				int numOfUpdate = 0;
				if (ownerSend) {
					numOfUpdate = webMsgDao.incActorNum(con, owner, actor, cnt, time);
				} else {
					numOfUpdate = webMsgDao.incOwnerNum(con, owner, actor, cnt, time);
				}
				if (numOfUpdate == 0) {
					if (wmi == null) {
						wmi = new WebMsgIdx();
						wmi.setActor(actor);
						wmi.setLastCnt(cnt);
					
						wmi.setNumOfActor(ownerSend ? 1 : 0);
						wmi.setNumOfOwner(ownerSend ? 0 : 1);
						wmi.setOwner(owner);
						wmi.setShowOfActor(true);
						wmi.setShowOfOwner(true);
					}
					wmi.setLastTime(time);
					webMsgDao.insert(con,wmi);
				}
				con.commit();
				next=false;
			} catch (SQLException e) {
				if ("23505".equals(e.getSQLState())) {
					con.rollback();
				}
				throw e;
			}
		}
	}
	@Get
	@Path("/cnt/load")
	public List<WebMsgCnt> load(@JdbcConn Connection con,String sender,String reciver,@Nullable String bt,@DefaultValue("true") boolean all)throws SQLException{
		if(all){
			return webMsgDao.queryAll(con,sender, reciver, bt);
		}else{
			return webMsgDao.query(con, sender, reciver, bt);
		}
	}
	
	@Post
	@Path("/readed")
	public void readed(@JdbcConn(true) Connection con,String sender,String reciver,String time)throws SQLException{
		int num = webMsgDao.readed(con, sender, reciver, time);
		if(num>0){
			String owner = sender;
			String actor = reciver;
			boolean 	ownerSend = true;
			if(sender.compareTo(reciver)>0){
				owner = reciver;
				actor = sender;
				ownerSend = false;
			}
			if(ownerSend){
				webMsgDao.decActorNum(con, owner, actor,num);
			}else{
				webMsgDao.decOwnerNum(con, owner, actor, num);
			}
		}
	}
}

src/main/java/com/ekexiu/portal/msg/WebMsgCnt.java

@@ -0,0 +1,73 @@
package com.ekexiu.portal.msg;
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.enums.DE;
@Uniques(@Unique(clolumns = { "sender","reciver","sendTime" }, name = "WEB_MSG_CNT_S_R_TIME"))
@PrimaryKey("id")
@Table
public class WebMsgCnt {
	private String id;
	private String cnt;
	private String sendTime;
	private String sender;
	private String reciver;
	private boolean readed;
	
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	/**
	 * 消息内容
	 * @return
	 */
	@Column(DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	
	@Column(DE.dateTime_de)
	public String getSendTime() {
		return sendTime;
	}
	public void setSendTime(String sendTime) {
		this.sendTime = sendTime;
	}
	@Column(DE.id_32)
	public String getSender() {
		return sender;
	}
	public void setSender(String sender) {
		this.sender = sender;
	}
	@Column(DE.id_32)
	public String getReciver() {
		return reciver;
	}
	public void setReciver(String reciver) {
		this.reciver = reciver;
	}
	/**
	 * 是否已读
	 * @return
	 */
	@Column(DE.boolean_de)
	public boolean isReaded() {
		return readed;
	}
	public void setReaded(boolean readed) {
		this.readed = readed;
	}
}

src/main/java/com/ekexiu/portal/msg/WebMsgDao.java

@@ -0,0 +1,90 @@
package com.ekexiu.portal.msg;
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.Exclude;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.GroupSqlColumn;
import org.jfw.apt.orm.annotation.dao.param.GtEq;
import org.jfw.apt.orm.annotation.dao.param.LtEq;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
@DAO
public interface WebMsgDao {
	@Exclude({"showOfOwner","showOfActor"})
	@SelectList
	@OrderBy("ORDER BY LAST_TIME DESC")
	List<WebMsgIdx> query(Connection con, @GroupSqlColumn(handlerClass = StringHandler.class, isAnd = false, value = { "OWNER=? AND SHOW_OF_OWNER='1'",
			"ACTOR=? AND SHOW_OF_ACTOR='1'" },force=false) String id) throws SQLException;
	
	
	@Exclude({"showOfOwner","showOfActor"})
	@PageSelect
	@OrderBy("ORDER BY LAST_TIME DESC,OWNER ASC")
	PageQueryResult<WebMsgIdx>  query(Connection con, @GroupSqlColumn(handlerClass = StringHandler.class, isAnd = false, value = { "OWNER=? AND SHOW_OF_OWNER='1'",
	"ACTOR=? AND SHOW_OF_ACTOR='1'" },force=false) String id,int pageSize,int pageNo) throws SQLException;
	
	
	
	
	@Insert 
	int insert(Connection con,WebMsgCnt cnt)throws SQLException;
	@Insert
	int insert(Connection con,WebMsgIdx idx)throws SQLException;
	
	@UpdateWith
	@From(WebMsgIdx.class)
	@SetSentence("NUM_OF_ACTOR = NUM_OF_ACTOR + 1,SHOW_OF_ACTOR='1'")
	int incActorNum(Connection con,String owner,String actor,@Set String lastCnt,@Set long lastTime) throws SQLException;
	
	
	
	@UpdateWith
	@From(WebMsgIdx.class)
	@SetSentence("NUM_OF_OWNER = NUM_OF_OWNER + 1,SHOW_OF_OWNER='1'")
	int incOwnerNum(Connection con,String owner,String actor,@Set String lastCnt,@Set long lastTime) throws SQLException;
	
	
	
	
	@UpdateWith
	@From(WebMsgIdx.class)
	int decActorNum(Connection con,String owner,String actor,@Set("= NUM_OF_ACTOR - ?") int numOfActor) throws SQLException;
	
	
	
	@UpdateWith
	@From(WebMsgIdx.class)
	int decOwnerNum(Connection con,String owner,String actor,@Set("= NUM_OF_OWNER - ?") int numOfOwner) throws SQLException;
	
	
	@SelectList
	@OrderBy("ORDER BY SEND_TIME SEND_TIME ASC")
	List<WebMsgCnt> query(Connection con,String sender,String reciver,@Nullable @GtEq String sendTime)throws SQLException;
	
	@SelectList
	@OrderBy("ORDER BY SEND_TIME SEND_TIME ASC")
	List<WebMsgCnt> queryAll(Connection con, @GroupSqlColumn(handlerClass = StringHandler.class, value = { "SENDER=?","RECIVER=?" },isAnd=false) String actor1,@GroupSqlColumn(handlerClass = StringHandler.class, value = { "SENDER=?","RECIVER=?" },isAnd=false) String actor2,@Nullable @GtEq String sendTime)throws SQLException;
	
	@UpdateWith
	@From(WebMsgCnt.class)
	@SetSentence("READED='1'")
	int readed(Connection con,String sender,String reciver,@LtEq String sendTime)throws SQLException;
	
	
}

src/main/java/com/ekexiu/portal/msg/WebMsgIdx.java

@@ -0,0 +1,114 @@
package com.ekexiu.portal.msg;
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.core.enums.DE;
@PrimaryKey({"owner","actor"})
@Table
public class WebMsgIdx {
	
	private String owner;
	private String  actor;
	private long lastTime;
	private int numOfOwner;
	private int numOfActor;
	private String lastCnt;
	private boolean showOfOwner;
	private boolean showOfActor;
	
	
	/**
	 * 所有者(两个ID相比小的是Owner)
	 * @return
	 */
	@Column(DE.id_32)
	public String getOwner() {
		return owner;
	}
	public void setOwner(String owner) {
		this.owner = owner;
	}
	/**
	 *参与者
	 * @return
	 */
	@Column(DE.id_32)
	public String getActor() {
		return actor;
	}
	public void setActor(String actor) {
		this.actor = actor;
	}
	/**
	 * 最后发送时间
	 * @return
	 */
	@Column(DE.long_de)
	public long getLastTime() {
		return lastTime;
	}
	public void setLastTime(long lastTime) {
		this.lastTime = lastTime;
	}
	/**
	 * 未读信息数(所有者)
	 * @return
	 */
	@Column(DE.int_de)
	public int getNumOfOwner() {
		return numOfOwner;
	}
	public void setNumOfOwner(int num) {
		this.numOfOwner = num;
	}
	
	
	/**
	 * 未读信息数(参有者)
	 * @return
	 */
	@Column(DE.int_de)
	public int getNumOfActor() {
		return numOfActor;
	}
	public void setNumOfActor(int numOfActor) {
		this.numOfActor = numOfActor;
	}
	/**
	 * 最后信息内容
	 * @return
	 */
	@Column(DE.text_de)
	public String getLastCnt() {
		return lastCnt;
	}
	public void setLastCnt(String lastCnt) {
		this.lastCnt = lastCnt;
	}
	
	/**
	 * 所有者是否显示（会话在所有者的列表中未被删除）
	 * @return
	 */
	@Column(DE.boolean_de)
	public boolean isShowOfOwner() {
		return showOfOwner;
	}
	public void setShowOfOwner(boolean showOfOwner) {
		this.showOfOwner = showOfOwner;
	}
	/**
	 * 参与者是否显示（会话在参与者的列表中未被删除）
	 * @return
	 */
	@Column(DE.boolean_de)
	public boolean isShowOfActor() {
		return showOfActor;
	}
	public void setShowOfActor(boolean showOfActor) {
		this.showOfActor = showOfActor;
	}
}

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

@@ -362,7 +362,7 @@ public class ProfessorService {
				this.professorDao.updateOrg(con, oid, id);
				if (old != null) {
					this.professorDao.updateOrgAuth(con, id, "0");
					this.demandDao.closeByCreator(con,id, id);
					this.demandDao.closeByCreator(con, id, id);
					this.orgResStaffDao.deletePro(con, id);
				}
				return true;
@@ -450,6 +450,7 @@ public class ProfessorService {
		EditProfessor professor = this.professorDao.queryBaseInfo(con, id);
		if (null != professor) {
			professor.setHasHeadImage(this.imageService.hasProfessorImage(id));
			hiddenPrivacyInfo(professor);
		}
		return professor;
	}
@@ -463,6 +464,7 @@ public class ProfessorService {
		List<EditProfessor> professors = this.professorDao.queryByName(con, name, total);
		for (EditProfessor professor : professors) {
			professor.setHasHeadImage(this.imageService.hasProfessorImage(professor.getId()));
			hiddenPrivacyInfo(professor);
		}
		return professors;
	}
@@ -480,13 +482,18 @@ public class ProfessorService {
	@Get
	@Path("/{id}")
	public Professor query(@JdbcConn Connection con, @PathVar String id) throws SQLException {
		return this.professorDao.query(con, id);
		Professor ret = this.professorDao.query(con, id);
		if (null != ret) {
			hiddenPrivacyInfo(ret);
		}
		return ret;
	}
	@Get
	@Path("/qa")
	public List<Professor> queryAll(@JdbcConn Connection con) throws SQLException {
		return this.professorDao.query(con);
		return hiddenPrivacyInfo(this.professorDao.query(con));
	}
	@Get
@@ -500,6 +507,7 @@ public class ProfessorService {
				professor.setHasHeadImage(this.imageService.hasProfessorImage(professor.getId()));
				professor.setResearchAreas(this.researchAreaDao.query(con, professor.getId()));
			}
			hiddenPrivacyInfo(professors);
			queryResult.setData(professors);
		}
		return queryResult;
@@ -513,7 +521,7 @@ public class ProfessorService {
			professor.setHasHeadImage(this.imageService.hasProfessorImage(professor.getId()));
			professor.setResearchAreas(this.researchAreaDao.query(con, professor.getId()));
		}
		return professors;
		return hiddenPrivacyInfo(professors);
	}
	public void updateStarAvg(Connection con) throws SQLException {
@@ -565,6 +573,8 @@ public class ProfessorService {
				editProfessor.setHasHeadImage(this.imageService.hasProfessorImage(editProfessor.getId()));
				editProfessor.setResearchAreas(this.researchAreaDao.query(con, editProfessor.getId()));
				editProfessor.setResources(this.resourceDao.queryList(con, editProfessor.getId()));
				editProfessor.setPhone(null);
				editProfessor.setEmail(null);
			}
		}
		return queryResult;
@@ -599,6 +609,7 @@ public class ProfessorService {
				editProfessor.setResources(this.resourceDao.queryList(con, editProfessor.getId()));
			}
			queryResult.setData(editProfessors);
			hiddenPrivacyInfo(editProfessors);
		}
		return queryResult;
	}
@@ -737,6 +748,7 @@ public class ProfessorService {
				editProfessor.setHasHeadImage(this.imageService.hasProfessorImage(editProfessor.getId()));
				editProfessor.setResearchAreas(this.researchAreaDao.query(con, editProfessor.getId()));
			}
			hiddenPrivacyInfo(editProfessors);
			queryResult.setData(editProfessors);
		}
		return queryResult;
@@ -777,8 +789,8 @@ public class ProfessorService {
	}
	@Get
	@Path("/info/{id}")
	public ProfessorInfo qinfo(@JdbcConn(false) Connection con, @PathVar String id) throws SQLException {
	@Path("/editInfo/{id}")
	public ProfessorInfo editInfo(@JdbcConn(false) Connection con, @PathVar String id) throws SQLException {
		ProfessorInfo info = this.professorDao.queryInfo(con, id);
		if (info != null) {
			if (info.getOrgId() != null) {
@@ -811,10 +823,21 @@ public class ProfessorService {
	}
	@Get
	@Path("/info/{id}")
	public ProfessorInfo qinfo(@JdbcConn(false) Connection con, @PathVar String id) throws SQLException {
		ProfessorInfo qi = this.editInfo(con, id);
		if (qi != null) {
			qi.setPhone(null);
			qi.setEmail(null);
		}
		return qi;
	}
	@Get
	@Path("/byShareId")
	public Professor query(@JdbcConn Connection con, long id) throws SQLException {
		return this.professorDao.query(con, id);
		return hiddenPrivacyInfo(this.professorDao.query(con, id));
	}
	/**
@@ -836,7 +859,8 @@ public class ProfessorService {
		String[] ids = this.professorDao.queryProfessorIdWithSameKeyWord(con, professorId, rows);
		if (ids != null) {
			List<Professor> ret = this.professorDao.query(con, ids);
			return ret;
			return hiddenPrivacyInfo(ret);
		}
		return Collections.<Professor> emptyList();
	}
@@ -875,6 +899,22 @@ public class ProfessorService {
		}
	}
	public static <T extends Professor> T hiddenPrivacyInfo(T p) {
		if (null != p) {
			p.setPhone(null);
			p.setEmail(null);
		}
		return p;
	}
	public static <T extends Professor> List<T> hiddenPrivacyInfo(List<T> ps) {
		if (ps != null && ps.size() > 0)
			for (Professor p : ps) {
				hiddenPrivacyInfo(p);
			}
		return ps;
	}
	//
	//
	// @Get

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

@@ -789,6 +789,41 @@ public class SysService {
		user2.setEmail(user.getEmail());
		return user2;
	}
	
	@Get
	@Path("/baseUserInfo")
	public User queryBaseUser(@JdbcConn Connection con,String id) throws SQLException{
		User user = this.userDao.query(con, id);
		if(user!=null){
			user.setInviteCode(null);
			user.setInviterId(null);
			String mp = user.getMobilePhone();
			if(mp!=null && mp.length()>4){
				user.setMobilePhone(mp.substring(mp.length()-4));
			}
			String em = user.getEmail();
			if(em!=null){
				int idx = em.indexOf('@');
				if(idx>0){
					StringBuilder sb = new StringBuilder();
					sb.append(em);
					if(idx==1){
						sb.setCharAt(0, '*');
					}else{
						int b =Math.max(1, idx-4);
						for(;b<idx;++b){
							sb.setCharAt(b, '*');
						}
					}
					user.setEmail(sb.toString());
				}
			}
			user.setPasswd(null);
			user.setSendMailStatus(null);
			user.setUserType(null);
		}
		return user;
	}
	/**
	 * 手机验证注册

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

@@ -0,0 +1,15 @@
package com.ekexiu.portal.util;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
@Path("/debug")
public class DebugService {
	@Get
	@Post
	@Path("/msg/send")
	public void sendMsg(String to,String cnt){
		WebMsgSocketServlet.sendMessage(to, cnt);
	}
}

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

@@ -0,0 +1,140 @@
package com.ekexiu.portal.util;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.PongMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
@ServerEndpoint("/websocket/msg")
public class WebMsgSocketServlet {
	private static final Object lock = new Object();
	private static final Map<String, Session> sessions = new ConcurrentHashMap<String, Session>();
	private static final String[] TYPE_LIST = new String[]{"www","app"};
	
	
	public static void sendMessage(String id ,String cnt){
		
		for(String type:TYPE_LIST){
			String key = id+"~"+type;
			Session session = sessions.get(key);
			if(session!=null && session.isOpen()){
				try {
					System.out.println("SEND:"+key+"           "+cnt);
					session.getBasicRemote().sendText(cnt);
				} catch (IOException e) {
				}
			}
			
		}
	}
	@OnMessage
	public void echoTextMessage(Session session, String msg, boolean last) {
		// try {
		// if (session.isOpen()) {
		// session.getBasicRemote().sendText(msg, last);
		// }
		// } catch (IOException e) {
		// try {
		// session.close();
		// } catch (IOException e1) {
		// // Ignore
		// }
		// }
	}
	@OnMessage
	public void echoBinaryMessage(Session session, ByteBuffer bb, boolean last) {
		// try {
		// if (session.isOpen()) {
		// session.getBasicRemote().sendBinary(bb, last);
		// }
		// } catch (IOException e) {
		// try {
		// session.close();
		// } catch (IOException e1) {
		// // Ignore
		// }
		// }
	}
	@OnMessage
	public void echoPongMessage(PongMessage pm) {
		// NO-OP
	}
	@OnOpen
	public void open(Session session) {
		String qs = session.getQueryString();
		System.out.println("onOpen:"+qs);
		String[] ps = qs.split("&");
		String id = null;
		String type = null;
		for (String p : ps) {
			if (p != null && p.length() > 3) {
				if (p.startsWith("id=")) {
					id = p.substring(3);
				} else if (p.startsWith("pm=")) {
					type = p.substring(3);
				}
			}
		}
		if (id == null || type == null) {
			try {
				session.close();
			} catch (IOException e) {
			}
			return;
		}
		String sessionFlag = id + "~" + type;
		Session old = null;
		synchronized (lock) {
			old = sessions.get(sessionFlag);
			sessions.put(sessionFlag, session);
		}
		if (old != null && old.isOpen()) {
			try {
				old.close();
			} catch (IOException e) {
			}
		}
	}
	@OnClose
	public void close(Session session) {
		String qs = session.getQueryString();
		System.out.println("OnClose:"+qs);
		String[] ps = qs.split("&");
		String id = null;
		String type = null;
		for (String p : ps) {
			if (p != null && p.length() > 3) {
				if (p.startsWith("id=")) {
					id = p.substring(3);
				} else if (p.startsWith("pm=")) {
					type = p.substring(3);
				}
			}
		}
		if (id == null || type == null) {
			return;
		}
		String sessionFlag = id + "~" + type;
		synchronized (lock) {
			if (session.equals(sessions.get(sessionFlag)))
				sessions.remove(sessionFlag);
		}
	}
}

src/main/webapp/WEB-INF/web.xml

@@ -1,97 +1,100 @@
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlnshttp://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5">
  <servlet>
    <servlet-name>ajax</servlet-name>
    <servlet-class>org.jfw.web.servlet.core.FilenameConfigServlet</servlet-class>
    <init-param>
      <param-name>prefixLen</param-name>
      <param-value>${ajax.prefixLen}</param-value>
    </init-param>
    <init-param>
      <param-name>viewType</param-name>
      <param-value>1</param-value>
    </init-param>
    <init-param>
      <param-name>configFileName</param-name>
      <param-value>beanConfig.properties,${main.config}</param-value>
    </init-param>
    <init-param>
      <param-name>afterBeanFactory</param-name>
      <param-value>com.ekexiu.portal.job.SchJob,com.ekexiu.portal.job.TaskJob</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet>
    <servlet-name>cachedFileUploadServlet</servlet-name>
    <servlet-class>org.jfw.web.servlet.fileupload.cached.CachedUploadServlet</servlet-class>
    <load-on-startup>2</load-on-startup>
  </servlet>
  <servlet>
    <servlet-name>resFileUploadServlet</servlet-name>
    <servlet-class>org.jfw.web.servlet.fileupload.cached.CachedUploadServlet</servlet-class>
    <load-on-startup>3</load-on-startup>
  </servlet>
  <servlet>
    <servlet-name>serviceFileUploadServlet</servlet-name>
    <servlet-class>org.jfw.web.servlet.fileupload.cached.CachedUploadServlet</servlet-class>
    <load-on-startup>3</load-on-startup>
  </servlet>
  <servlet>
    <servlet-name>FileDownload</servlet-name>
    <servlet-class>com.ekexiu.portal.util.FileDownload</servlet-class>
    <init-param>
      <param-name>accessoryFolder</param-name>
      <param-value>${accessoryFolder}</param-value>
    </init-param>
    <load-on-startup>4</load-on-startup>
  </servlet>
  <servlet>
    <servlet-name>PictureVC</servlet-name>
    <servlet-class>com.ekexiu.portal.util.PictureVC</servlet-class>
    <load-on-startup>5</load-on-startup>
  </servlet>
  <servlet>
    <servlet-name>CheckPictureVC</servlet-name>
    <servlet-class>com.ekexiu.portal.util.CheckPictureVC</servlet-class>
    <load-on-startup>6</load-on-startup>
  </servlet>
    <servlet>
    <description></description>
    <display-name>ProfessorPdfServlet</display-name>
    <servlet-name>ProfessorPdfServlet</servlet-name>
    <servlet-class>com.ekexiu.portal.util.ProfessorPdfServlet</servlet-class>
    <load-on-startup>7</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>ajax</servlet-name>
    <url-pattern>/ajax/*</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>cachedFileUploadServlet</servlet-name>
    <url-pattern>/ajax/cachedFileUpload</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>resFileUploadServlet</servlet-name>
    <url-pattern>/ajax/resFileUpload</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>serviceFileUploadServlet</servlet-name>
    <url-pattern>/ajax/serviceFileUpload</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>FileDownload</servlet-name>
    <url-pattern>/ajax/FileDownload</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>PictureVC</servlet-name>
    <url-pattern>/ajax/PictureVC</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>CheckPictureVC</servlet-name>
    <url-pattern>/ajax/CheckPictureVC</url-pattern>
  </servlet-mapping>
  <servlet-mapping>
    <servlet-name>ProfessorPdfServlet</servlet-name>
    <url-pattern>/pdf/professor</url-pattern>
  </servlet-mapping>
<web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlnshttp://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
                      http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
	version="3.0" metadata-complete="true">
	<servlet>
		<servlet-name>ajax</servlet-name>
		<servlet-class>org.jfw.web.servlet.core.FilenameConfigServlet</servlet-class>
		<init-param>
			<param-name>prefixLen</param-name>
			<param-value>${ajax.prefixLen}</param-value>
		</init-param>
		<init-param>
			<param-name>viewType</param-name>
			<param-value>1</param-value>
		</init-param>
		<init-param>
			<param-name>configFileName</param-name>
			<param-value>beanConfig.properties,${main.config}</param-value>
		</init-param>
		<init-param>
			<param-name>afterBeanFactory</param-name>
			<param-value>com.ekexiu.portal.job.SchJob,com.ekexiu.portal.job.TaskJob</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>cachedFileUploadServlet</servlet-name>
		<servlet-class>org.jfw.web.servlet.fileupload.cached.CachedUploadServlet</servlet-class>
		<load-on-startup>2</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>resFileUploadServlet</servlet-name>
		<servlet-class>org.jfw.web.servlet.fileupload.cached.CachedUploadServlet</servlet-class>
		<load-on-startup>3</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>serviceFileUploadServlet</servlet-name>
		<servlet-class>org.jfw.web.servlet.fileupload.cached.CachedUploadServlet</servlet-class>
		<load-on-startup>3</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>FileDownload</servlet-name>
		<servlet-class>com.ekexiu.portal.util.FileDownload</servlet-class>
		<init-param>
			<param-name>accessoryFolder</param-name>
			<param-value>${accessoryFolder}</param-value>
		</init-param>
		<load-on-startup>4</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>PictureVC</servlet-name>
		<servlet-class>com.ekexiu.portal.util.PictureVC</servlet-class>
		<load-on-startup>5</load-on-startup>
	</servlet>
	<servlet>
		<servlet-name>CheckPictureVC</servlet-name>
		<servlet-class>com.ekexiu.portal.util.CheckPictureVC</servlet-class>
		<load-on-startup>6</load-on-startup>
	</servlet>
	<servlet>
		<description></description>
		<display-name>ProfessorPdfServlet</display-name>
		<servlet-name>ProfessorPdfServlet</servlet-name>
		<servlet-class>com.ekexiu.portal.util.ProfessorPdfServlet</servlet-class>
		<load-on-startup>7</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>ajax</servlet-name>
		<url-pattern>/ajax/*</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>cachedFileUploadServlet</servlet-name>
		<url-pattern>/ajax/cachedFileUpload</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>resFileUploadServlet</servlet-name>
		<url-pattern>/ajax/resFileUpload</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>serviceFileUploadServlet</servlet-name>
		<url-pattern>/ajax/serviceFileUpload</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>FileDownload</servlet-name>
		<url-pattern>/ajax/FileDownload</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>PictureVC</servlet-name>
		<url-pattern>/ajax/PictureVC</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>CheckPictureVC</servlet-name>
		<url-pattern>/ajax/CheckPictureVC</url-pattern>
	</servlet-mapping>
	<servlet-mapping>
		<servlet-name>ProfessorPdfServlet</servlet-name>
		<url-pattern>/pdf/professor</url-pattern>
	</servlet-mapping>
</web-app>