Merge remote-tracking branch 'origin/test'

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

@@ -0,0 +1,54 @@
package com.ekexiu.portal.found;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
@Path("/found")
public class Service {
/**
 * 查询新发现（含提问）
 * @param con
 * @param time 下拉加载上一次返回的最后一条数据的tm,首次不传
 * @param id 下拉加载上一次返回的最后一条数据的id,首次不传
 * @param rows 下拉加载返回的数据条数，默认20
 * @param ex 排除的文章ID
 * @return [{ctype:"1:专家文章，2：企业文章  3， 提问"
 *                 id:"文章id 或  提问ID ",
 *                 uid:"专家ID 或 企业id 或 提问人ID ",
 *                 tm:"文章发布时间 或 提问时间，
 *                 num:0 ,//提问回答数
 *                 img:"图片",
 *                 col:0,//文章栏目
 *                  }....]
 * @throws SQLException
 */
	@Get
	@Path("/index")
	public List<Map<String,Object>> query(@JdbcConn Connection con,@DefaultValue("\"9\"") final String time,@DefaultValue("\"0\"") final String id,@DefaultValue("20") final int rows,final String ex)throws SQLException{
		return JdbcUtil.queryMaps(con, "SELECT * FROM 	( "+
		"SELECT ID id,'3' ctype,uid uid,title title,	last_reply_time tm,reply_count num,img img,null col	FROM question where state='1' UNION ALL "+
		"SELECT ARTICLE_ID id,	'1' ctype,professor_id uid,article_title title,publish_time tm,	0 num,article_img img,col_num col FROM article WHERE status = '1' AND article_type = '1' AND article_id <>? UNION ALL "+
		"SELECT ARTICLE_ID id,	'2' ctype,org_id uid,article_title title,publish_time tm,0 num,article_img img,col_num col FROM article WHERE status = '1' AND article_type = '2' AND article_id <>? 	) T "+
        "WHERE T.tm<? OR (T.tm = ? AND T.id > ?) ORDER BY tm DESC LIMIT ?", new PreparedStatementConfig() {
			@Override
			public void config(PreparedStatement ps) throws SQLException {
				ps.setString(1,ex);
				ps.setString(2, ex);
				ps.setString(3, time);
				ps.setString(4, time);
				ps.setString(5, id);
				ps.setInt(6,rows);
			}
		});
	}
}

src/main/java/com/ekexiu/portal/leavemsg/LeaveMsg.java

@@ -0,0 +1,159 @@
package com.ekexiu.portal.leavemsg;
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;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Table
public class LeaveMsg implements ModifyTimeSupported {
	private String id;
	private String cnt;
	private String refId;
	private String refType;
	private String top;
	private String parent;
	private String sender;
	private String reciver;
	private String createTime;
	private String modifyTime;
	private String state;
	private long  agreeCount;
	
	private transient String timeDesc;
	
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	/**
	 * id
	 * @return
	 */
	@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;
	}
	/**
	 * 留言主体ID ,  文章ID,论文ID,专利ID,提问ID
	 * @return
	 */
	@Column(DE.text_de)
	public String getRefId() {
		return refId;
	}
	public void setRefId(String refId) {
		this.refId = refId;
	}
	/**
	 * 留言主体类型,1:文章   2:论文   3:专利      4:回答
	 * @return
	 */
	@Column(DE.singleChar)
	public String getRefType() {
		return refType;
	}
	public void setRefType(String refType) {
		this.refType = refType;
	}
	/**
	 * 顶级留言ID
	 * @return
	 */
	@Column(DE.text_de)
	public String getTop() {
		return top;
	}
	public void setTop(String top) {
		this.top = top;
	}
	/**
	 * 上级留言ID
	 * @return
	 */
	@Column(DE.Text_de)
	public String getParent() {
		return parent;
	}
	public void setParent(String parent) {
		this.parent = parent;
	}
	/**
	 * 留言人ID
	 * @return
	 */
	@Column(DE.text_de)
	public String getSender() {
		return sender;
	}
	public void setSender(String sender) {
		this.sender = sender;
	}
	/**
	 * 上级留言的留言人ID
	 * @return
	 */
	@Column(DE.Text_de)
	public String getReciver() {
		return reciver;
	}
	public void setReciver(String reciver) {
		this.reciver = reciver;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	/**
	 * 状态  1： 发布中   0 ：删除的
	 * @return
	 */
	@Column(DE.singleChar)
	public String getState() {
		return state;
	}
	public void setState(String state) {
		this.state = state;
	}
	/**
	 * 留言语的点赞数
	 * @return
	 */
	@Column(DE.long_de)
	public long getAgreeCount() {
		return agreeCount;
	}
	public void setAgreeCount(long agreeCount) {
		this.agreeCount = agreeCount;
	}
}

src/main/java/com/ekexiu/portal/leavemsg/LeaveMsgAgreeRec.java

@@ -0,0 +1,40 @@
package com.ekexiu.portal.leavemsg;
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;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@Table
@PrimaryKey({"id","uid"})
public class LeaveMsgAgreeRec  implements CreateTimeSupported{
	private String id;
	private String uid;
	private String createTime;
	@Column(DE.text_de)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Override
	public String getCreateTime() {
		return this.createTime;
	}
	@Override
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
}

src/main/java/com/ekexiu/portal/leavemsg/LeaveMsgDao.java

@@ -0,0 +1,80 @@
package com.ekexiu.portal.leavemsg;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Column;
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.IncludeFixSet;
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.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.LimitSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryVal;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.GreaterThan;
import org.jfw.apt.orm.annotation.dao.param.GroupSqlColumn;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
@DAO
public interface LeaveMsgDao {
	@Insert
	int insert(Connection con, LeaveMsg msg) throws SQLException;
	@UpdateWith
	@From(LeaveMsg.class)
	@SetSentence("STATE = '0'")
	@Where("STATE = '1' ")
	@IncludeFixSet
	int logicDelete(Connection con, String id) throws SQLException;
	@UpdateWith
	@From(LeaveMsg.class)
	@SetSentence("AGREE_COUNT = AGREE_COUNT + 1")
	@IncludeFixSet
	int incAgree(Connection con, String id) throws SQLException;
	@LimitSelect
	@Where("STATE='1'")
	@OrderBy("ORDER BY TIME_DESC ASC")
	List<LeaveMsg> query(Connection con, String refId, String refType, @GreaterThan String timeDesc, int rows) throws SQLException;
	@Nullable
	@SelectOne
	LeaveMsg query(Connection con, String id) throws SQLException;
	@Insert
	int insert(Connection con, LeaveMsgAgreeRec rec) throws SQLException;
	@Nullable
	@SelectOne
	LeaveMsgAgreeRec queryAgreeRec(Connection con, String id, String uid) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC ASC")
	List<LeaveMsg> queryWithParent(Connection con, String parent, @GreaterThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC ASC")
	List<LeaveMsg> queryWithTop(Connection con, String top,
			@GroupSqlColumn(handlerClass = StringHandler.class, isAnd = false, value = { "SENDER=?", "RECIVER=?" }, force = true) String sid,
			@GroupSqlColumn(handlerClass = StringHandler.class, isAnd = false, value = { "SENDER=?", "RECIVER=?" }, force = true) String rid,
			 @GreaterThan String timeDesc,int rows) throws SQLException;
	@QueryVal
	@From(LeaveMsg.class)
	@DefaultValue("0")
	@Column(value="COUNT(ID)",handlerClass=IntHandler.class)
	@Where("STATE='1'")
	int queryCount(Connection con,String refType,String refId) throws SQLException;
	
	
}

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

@@ -0,0 +1,464 @@
package com.ekexiu.portal.leavemsg;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.FieldParam;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.RequestParam;
import org.jfw.util.DateUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import com.ekexiu.portal.dao.ArticleDao;
import com.ekexiu.portal.dao.PaperAuthorDao;
import com.ekexiu.portal.dao.PatentAuthorDao;
import com.ekexiu.portal.dao.PpaperDao;
import com.ekexiu.portal.dao.PpatentDao;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.po.Article;
import com.ekexiu.portal.po.PaperAuthor;
import com.ekexiu.portal.po.PatentAuthor;
import com.ekexiu.portal.po.Ppaper;
import com.ekexiu.portal.po.Ppatent;
import com.ekexiu.portal.question.Answer;
import com.ekexiu.portal.question.Question;
import com.ekexiu.portal.question.QuestionDao;
@Path("/leavemsg")
public class Service {
	@Autowrie
	private LeaveMsgDao leaveMsgDao;
	@Autowrie
	private ArticleDao articleDao;
	@Autowrie
	private PpatentDao ppatentDao;
	@Autowrie
	private PpaperDao ppaperDao;
	@Autowrie
	private QuestionDao questionDao;
	@Autowrie
	private NotifyService notifyService;
	@Autowrie
	private PaperAuthorDao paperAuthorDao;
	@Autowrie
	private PatentAuthorDao patentAuthorDao;
	public PaperAuthorDao getPaperAuthorDao() {
		return paperAuthorDao;
	}
	public void setPaperAuthorDao(PaperAuthorDao paperAuthorDao) {
		this.paperAuthorDao = paperAuthorDao;
	}
	public PatentAuthorDao getPatentAuthorDao() {
		return patentAuthorDao;
	}
	public void setPatentAuthorDao(PatentAuthorDao patentAuthorDao) {
		this.patentAuthorDao = patentAuthorDao;
	}
	public ArticleDao getArticleDao() {
		return articleDao;
	}
	public void setArticleDao(ArticleDao articleDao) {
		this.articleDao = articleDao;
	}
	public PpatentDao getPpatentDao() {
		return ppatentDao;
	}
	public void setPpatentDao(PpatentDao ppatentDao) {
		this.ppatentDao = ppatentDao;
	}
	public PpaperDao getPpaperDao() {
		return ppaperDao;
	}
	public void setPpaperDao(PpaperDao ppaperDao) {
		this.ppaperDao = ppaperDao;
	}
	public QuestionDao getQuestionDao() {
		return questionDao;
	}
	public void setQuestionDao(QuestionDao questionDao) {
		this.questionDao = questionDao;
	}
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public LeaveMsgDao getLeaveMsgDao() {
		return leaveMsgDao;
	}
	public void setLeaveMsgDao(LeaveMsgDao leaveMsgDao) {
		this.leaveMsgDao = leaveMsgDao;
	}
	// 1:文章 2:论文 3:专利 4:回答
	public void notify(Connection con, String type, String id, String reciver, String uid, String uname, String lid, boolean agree, List<Runnable> runs)
			throws SQLException, JfwBaseException {
		if (type.equals("1")) {
			Article article = this.articleDao.queryOne(con, id);
			if (article == null) {
				throw new JfwBaseException(50000, "article[" + id + "] not found");
			}
			if (reciver == null) {
				if (article.getArticleType().equals("1") && (!uid.equals(article.getProfessorId()))) {
					this.notifyService.notify(con, article.getProfessorId(), uid, uname, lid, article.getArticleTitle(), NotifyType.LEAVE_MSG_AT_ARTICLE, runs);
				}
			} else {
				if (!uid.equals(reciver)) {
					this.notifyService.notify(con, reciver, uid, uname, lid, article.getArticleTitle(),
							agree ? NotifyType.AGREE_LEAVE_MSG_AT_ARTICLE : NotifyType.REPLY_LEAVE_MSG_AT_ARTICLE, runs);
				}
			}
		} else if (type.equals("2")) {
			Ppaper paper = this.ppaperDao.query(con, id);
			if (paper == null) {
				throw new JfwBaseException(50000, "paper[" + id + "] not found");
			}
			if (reciver == null) {
				for (PaperAuthor pa : this.paperAuthorDao.query(con, id)) {
					if (!pa.getProfessorId().startsWith("#") && (!uid.equals(pa.getProfessorId()))) {
						this.notifyService.notify(con, pa.getProfessorId(), uid, uname, lid, paper.getName(), NotifyType.LEAVE_MSG_AT_PAPER, runs);
					}
				}
			} else {
				if (!uid.equals(reciver)) {
					this.notifyService.notify(con, reciver, uid, uname, lid, paper.getName(),
							agree ? NotifyType.AGREE_LEAVE_MSG_AT_PAPER : NotifyType.REPLY_LEAVE_MSG_AT_PAPER, runs);
				}
			}
		} else if (type.equals("3")) {
			Ppatent patent = this.ppatentDao.query(con, id);
			if (patent == null) {
				throw new JfwBaseException(50000, "patent[" + id + "] not found");
			}
			if (reciver == null) {
				for (PatentAuthor pa : this.patentAuthorDao.query(con, id)) {
					if (!pa.getProfessorId().startsWith("#") && (!uid.equals(pa.getProfessorId()))) {
						this.notifyService.notify(con, pa.getProfessorId(), uid, uname, lid, patent.getName(), NotifyType.LEAVE_MSG_AT_PARENT, runs);
					}
				}
			} else {
				if (!uid.equals(reciver)) {
					this.notifyService.notify(con, reciver, uid, uname, lid, patent.getName(),
							agree ? NotifyType.AGREE_LEAVE_MSG_AT_PARENT : NotifyType.REPLY_LEAVE_MSG_AT_PARENT, runs);
				}
			}
		} else if (type.equals("4")) {
			Answer a = this.questionDao.queryAnswer(con, id);
			if (a == null) {
				throw new JfwBaseException(50000, "answer[" + id + "] not found");
			}
			Question q = this.questionDao.query(con, a.getQid());
			if (q == null) {
				throw new JfwBaseException(50000, "answer[" + id + "]'question not found");
			}
			if (reciver == null) {
				if (!uid.equals(a.getUid())) {
					this.notifyService.notify(con, a.getUid(), uid, uname, lid, q.getTitle(), NotifyType.LEAVE_MSG_AT_ANSWER, runs);
				}
			} else {
				if (!uid.equals(reciver)) {
					this.notifyService.notify(con, reciver, uid, uname, lid, q.getTitle(),
							agree ? NotifyType.AGREE_LEAVE_MSG_AT_ANSWER : NotifyType.REPLY_LEAVE_MSG_AT_ANSWER, runs);
				}
			}
		} else {
			throw new IllegalArgumentException();
		}
	}
	/**
	 * 新增一顶级留言
	 * 
	 * @param con
	 * @param msg
	 *            cnt
	 * @param title
	 *            文章标题 论文标题 专利标题 提问
	 * @param uname
	 *            发送人名称
	 * @param runs
	 * @return
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Path()
	@Post
	public String save(@JdbcConn(true) Connection con,
			@RequestParam(fields = { @FieldParam(value = "cnt", valueClass = String.class), @FieldParam(value = "refId", valueClass = String.class),
					@FieldParam(value = "refType", valueClass = String.class), @FieldParam(value = "sender", valueClass = String.class) }) LeaveMsg msg,
			String uname, @AfterCommit List<Runnable> runs) throws SQLException, JfwBaseException {
		String id = StringUtil.buildUUID();
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		msg.setId(id);
		msg.setTop(id);
		msg.setState("1");
		msg.setParent(null);
		msg.setAgreeCount(0);
		msg.setCreateTime(time);
		msg.setTimeDesc(time + id);
		leaveMsgDao.insert(con, msg);
		this.notify(con, msg.getRefType(), msg.getRefId(), null, msg.getSender(), uname, id, false, runs);
		return id;
	}
	/**
	 * 回复留言
	 * 
	 * @param con
	 * @param cnt
	 *            留言内容
	 * @param id
	 *            被回复留言ID
	 * @param uid
	 *            用户ID
	 * @param title
	 *            留言主体 文章标题 论文标题 专利标题 提问
	 * @param uname
	 *            用户姓名
	 * @param runs
	 * @return
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Path("/reply")
	@Post
	public String reply(@JdbcConn(true) Connection con, String cnt, String id, String uid, String uname, @AfterCommit List<Runnable> runs)
			throws SQLException, JfwBaseException {
		final LeaveMsg msg = leaveMsgDao.query(con, id);
		if (msg == null)
			throw new JfwBaseException(50000, "leave message[id:" + id + "] not found");
		if (msg.getSender().equals(uid)) {
			throw new JfwBaseException(50001, "can't reply self");
		}
		String nid = StringUtil.buildUUID();
		msg.setParent(id);
		msg.setReciver(msg.getSender());
		msg.setSender(uid);
		msg.setState("1");
		msg.setCnt(cnt);
		msg.setId(nid);
		msg.setAgreeCount(0);
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		msg.setCreateTime(time);
		msg.setTimeDesc(time + nid);
		leaveMsgDao.insert(con, msg);
		this.notify(con, msg.getRefType(), msg.getRefId(), msg.getReciver(), uid, uname, id, false, runs);
		return nid;
	}
	/**
	 * 查询某主体下的留言
	 * 
	 * @param con
	 * @param stype
	 *            主体类型 1:文章 2:论文 3:专利 4:提问
	 * @param sid
	 *            留言主体ID , 文章ID,论文ID,专利ID,提问ID
	 * @param time
	 *            留言时间 time > createTime
	 * @param id
	 *            留言ID time > createTime && id >leaveMsg.id
	 * @param rows
	 *            返回的最大条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/subject")
	public List<LeaveMsg> query(@JdbcConn Connection con, String stype, String sid, @DefaultValue("\"0\"") String time, @DefaultValue("\"0\"") String id,
			int rows) throws SQLException {
		return leaveMsgDao.query(con, sid, stype, time + id, rows);
	}
	@Get
	@Path("/count")
	public int query(@JdbcConn Connection con, String stype, String sid) throws SQLException {
		return leaveMsgDao.queryCount(con, stype, sid);
	}
	@Get
	@Path("/counts")
	public List<Map<String, Object>> query(@JdbcConn Connection con, final String stype, final String[] ids) throws SQLException {
		StringBuilder sb = new StringBuilder();
		sb.append("SELECT REF_ID rid,COUNT(1) num FROM LEAVE_MSG WHERE STATE='1' AND REF_TYPE =? AND REF_ID IN (?");
		for (int i = 1; i < ids.length; ++i) {
			sb.append(",?");
		}
		sb.append(") GROUP BY rid");
		return JdbcUtil.queryMaps(con, sb.toString(), new PreparedStatementConfig() {
			@Override
			public void config(PreparedStatement ps) throws SQLException {
				int idx = 1;
				ps.setString(idx++, stype);
				for (int i = 0; i < ids.length; ++i) {
					ps.setString(idx++, ids[i]);
				}
			}
		});
	}
	/**
	 * 删除留言
	 * 
	 * @param con
	 * @param id
	 *            留言ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/del")
	public int delete(@JdbcConn(true) Connection con, String id) throws SQLException {
		return leaveMsgDao.logicDelete(con, id);
	}
	/**
	 * 点赞留言
	 * 
	 * @param con
	 * @param id
	 *            留言ID
	 * @param uid
	 *            点赞用户ID * @param uname 点赞用户姓名
	 * @param runs
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Post
	@Path("/agree")
	public void agree(@JdbcConn(true) Connection con, String id, String uid, String uname, @AfterCommit List<Runnable> runs)
			throws SQLException, JfwBaseException {
		LeaveMsg msg = leaveMsgDao.query(con, id);
		if (msg == null) {
			throw new JfwBaseException(50000, "leave message[id:" + id + "] not found");
		}
		LeaveMsgAgreeRec lmar = new LeaveMsgAgreeRec();
		lmar.setId(id);
		lmar.setUid(uid);
		try {
			leaveMsgDao.insert(con, lmar);
		} catch (SQLException e) {
			if ("23505".equals(e.getSQLState())) {
				con.rollback();
				throw new JfwBaseException(50001, "leave message  duplicate agree");
			}
			throw e;
		}
		if (leaveMsgDao.incAgree(con, id) > 0) {
			this.notify(con, msg.getRefType(), msg.getRefId(), msg.getSender(), uid, uname, msg.getId(), true, runs);
		}
	}
	/**
	 * 是否对指定留言点过赞
	 * 
	 * @param con
	 * @param id
	 *            留言 ID
	 * @param uid
	 *            用户ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/agree")
	public boolean agree(@JdbcConn Connection con, String id, String uid) throws SQLException {
		return null != leaveMsgDao.queryAgreeRec(con, id, uid);
	}
	/**
	 * 查贸询一个指定的留言
	 * 
	 * @param con
	 * @param id
	 *            留言ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/qo")
	public LeaveMsg query(@JdbcConn Connection con, String id) throws SQLException {
		return leaveMsgDao.query(con, id);
	}
	// @Get
	// @Path("/parent")
	// public List<LeaveMsg> parent(@JdbcConn Connection con, String parent,
	// @DefaultValue("\"0\"") String time, @DefaultValue("\"0\"") String id,
	// @DefaultValue("10") int rows) throws SQLException {
	// return leaveMsgDao.queryWithParent(con, parent, time, id, rows);
	// }
	//
	// @Get
	// @Path("/top")
	// public List<LeaveMsg> top(@JdbcConn Connection con, String top, String
	// sid, String rid, @DefaultValue("\"0\"") String time,
	// @DefaultValue("\"0\"") String id,
	// @DefaultValue("10") int rows) throws SQLException {
	// return leaveMsgDao.queryWithTop(con, top, sid, rid, time, id, rows);
	// }
	/**
	 * 留言对话框
	 * 
	 * @param con
	 * @param id
	 *            留言ID
	 * @return
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Get
	@Path("/dialog")
	public List<LeaveMsg> dialog(@JdbcConn Connection con, String id) throws SQLException, JfwBaseException {
		List<LeaveMsg> ret = null;
		LeaveMsg msg = leaveMsgDao.query(con, id);
		if (msg == null)
			throw new JfwBaseException(50000, "leave message[id:" + id + "] not found");
		if (msg.getId().equals(msg.getTop())) {
			ret = leaveMsgDao.queryWithParent(con, msg.getId(), "0", Integer.MAX_VALUE);
			ret.add(0, msg);
		} else {
			ret = leaveMsgDao.queryWithTop(con, msg.getTop(), msg.getSender(), msg.getReciver(), "0", Integer.MAX_VALUE);
		}
		return ret;
	}
}

src/main/java/com/ekexiu/portal/notify/NotifyMsgCnt.java

@@ -0,0 +1,87 @@
package com.ekexiu.portal.notify;
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;
@Table
@PrimaryKey("id")
public class NotifyMsgCnt{
	private String id;
	private String cnt;
	private String reciver;
	private boolean readed;
	private String pid;
	private String uid;
	private String createTime;
	private int opType;
	
	private transient String timeDesc;
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	@Column(DE.text_de)
	public String getReciver() {
		return reciver;
	}
	public void setReciver(String reciver) {
		this.reciver = reciver;
	}
	@Column(DE.boolean_de)
	public boolean isReaded() {
		return readed;
	}
	public void setReaded(boolean readed) {
		this.readed = readed;
	}
	@Column(DE.text_de)
	public String getPid() {
		return pid;
	}
	public void setPid(String pid) {
		this.pid = pid;
	}
	@Column(DE.text_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(DE.int_de)
	public int getOpType() {
		return opType;
	}
	public void setOpType(int opType) {
		this.opType = opType;
	}
	
}

src/main/java/com/ekexiu/portal/notify/NotifyMsgDao.java

@@ -0,0 +1,51 @@
package com.ekexiu.portal.notify;
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.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.LimitSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.LessThan;
import org.jfw.apt.orm.annotation.dao.param.LtEq;
import org.jfw.apt.orm.annotation.dao.param.Set;
@DAO
public interface NotifyMsgDao {
	@Insert
	int insert(Connection con,NotifyMsgIdx msg)throws SQLException;
	@Insert
	int insert(Connection con,NotifyMsgCnt msg)throws SQLException;
	@UpdateWith
	@From(NotifyMsgIdx.class)
	@SetSentence("UN_READ = UN_READ +1")
	int updateIdx(Connection con,@Set String lastCnt,@Set String lastTime,String reciver ) throws SQLException;
	
	@UpdateWith
	@From(NotifyMsgIdx.class)
	int decUnRead(Connection con,String reciver, @Set(" = UN_READ - ?") int unRead ) throws SQLException;
	
	@SelectOne
	@Nullable
	NotifyMsgIdx queryIdx(Connection con,String reciver)throws SQLException;
	
	
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC DESC")
	List<NotifyMsgCnt> queryCnt(Connection con,String reciver,@LessThan String timeDesc,int rows)throws SQLException;
	
	@UpdateWith
	@From(NotifyMsgCnt.class)
	@SetSentence("READED='1'")
	@Where("READED<>'1'")
	int readed(Connection con,String reciver ,@LtEq String timeDesc)throws SQLException; 
}

src/main/java/com/ekexiu/portal/notify/NotifyMsgIdx.java

@@ -0,0 +1,44 @@
package com.ekexiu.portal.notify;
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;
@Table
@PrimaryKey("reciver")
public class NotifyMsgIdx {
	private String reciver;
	private String lastCnt;
	private String lastTime;
	private int unRead;
	@Column(DE.text_de)
	public String getReciver() {
		return reciver;
	}
	public void setReciver(String reciver) {
		this.reciver = reciver;
	}
	@Column(DE.text_de)
	public String getLastCnt() {
		return lastCnt;
	}
	public void setLastCnt(String lastCnt) {
		this.lastCnt = lastCnt;
	}
	@Column(DE.text_de)
	public String getLastTime() {
		return lastTime;
	}
	public void setLastTime(String lastTime) {
		this.lastTime = lastTime;
	}
	@Column(DE.int_de)
	public int getUnRead() {
		return unRead;
	}
	public void setUnRead(int unRead) {
		this.unRead = unRead;
	}
	
}

src/main/java/com/ekexiu/portal/notify/NotifyService.java

@@ -0,0 +1,101 @@
package com.ekexiu.portal.notify;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
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.StringUtil;
import org.jfw.util.json.JsonService;
import com.ekexiu.portal.util.WebMsgSocketServlet;
import com.ekexiu.push.service.PushService;
@Path("/notify")
public class NotifyService {
	@Autowrie
	private NotifyMsgDao notifyMsgDao;
	@Autowrie
	private PushService pushService;
	public NotifyMsgDao getNotifyMsgDao() {
		return notifyMsgDao;
	}
	public void setNotifyMsgDao(NotifyMsgDao notifyMsgDao) {
		this.notifyMsgDao = notifyMsgDao;
	}
	public PushService getPushService() {
		return pushService;
	}
	public void setPushService(PushService pushService) {
		this.pushService = pushService;
	}
	public void notify(Connection con, final String rid, String uid, String uname, String pid, String pname, NotifyType type,List<Runnable> runs) throws SQLException {
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		String id = StringUtil.buildUUID();
		String tCnt = type.format(uname, pname);
		final NotifyMsgCnt cnt = new NotifyMsgCnt();
		cnt.setId(id);
		cnt.setCnt(tCnt);
		cnt.setCreateTime(time);
		cnt.setOpType(type.getType());
		cnt.setPid(pid);
		cnt.setReaded(false);
		cnt.setReciver(rid);
		cnt.setUid(uid);
		cnt.setTimeDesc(time+id);
		notifyMsgDao.insert(con, cnt);
		final NotifyMsgIdx idx = new NotifyMsgIdx();
		idx.setLastCnt(tCnt);
		idx.setLastTime(time);
		idx.setReciver(rid);
		idx.setUnRead(1);
		if (notifyMsgDao.updateIdx(con, tCnt, time, rid) < 1) {
			notifyMsgDao.insert(con, idx);
		}
		final Runnable ret = new Runnable() {
			public void run() {
				WebMsgSocketServlet.sendMessage(rid, JsonService.toJson(cnt));
				try {
					pushService.pushWithAlias("通知", "您收到了一条通知", "msgsend", rid);
				} catch (Throwable thr) {
				}
			}
		};
		runs.add(ret);
	}
	@Path("/idx")
	@Get
	public NotifyMsgIdx query(@JdbcConn Connection con, String id) throws SQLException {
		return notifyMsgDao.queryIdx(con, id);
	}
	@Path()
	@Get
	public List<NotifyMsgCnt> query(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String mid,
			@DefaultValue("20") int rows) throws SQLException {
		return notifyMsgDao.queryCnt(con, uid, time+mid, rows);
	}
	@Post
	@Path("/readed")
	public int read(@JdbcConn(true) Connection con,String uid,String time,String mid)throws SQLException{
		int num = this.notifyMsgDao.readed(con, uid,time+mid);
		if(num>0){
			this.notifyMsgDao.decUnRead(con, uid,num);
		}
		return num;
	}
}

src/main/java/com/ekexiu/portal/notify/NotifyType.java

@@ -0,0 +1,57 @@
package com.ekexiu.portal.notify;
public enum NotifyType {
	AGREE_LEAVE_MSG_AT_ANSWER("%s  点赞了您在回答 <span>%s</span> 下的留言",19, 2) ,
	AGREE_LEAVE_MSG_AT_PAPER("%s  点赞了您在论文 <span>%s</span> 下的留言",18, 2) ,
	AGREE_LEAVE_MSG_AT_PARENT("%s  点赞了您在专利 <span>%s</span> 下的留言",17, 2) ,
	AGREE_LEAVE_MSG_AT_ARTICLE("%s  点赞了您在文章 <span>%s</span> 下的留言",16, 2) ,
	REPLY_LEAVE_MSG_AT_ANSWER("%s  回复了您在回答 <span>%s</span> 下的留言",15, 2) ,
	REPLY_LEAVE_MSG_AT_PAPER("%s  回复了您在论文 <span>%s</span> 下的留言",14, 2) ,
	REPLY_LEAVE_MSG_AT_PARENT("%s  回复了您在专利 <span>%s</span> 下的留言",13, 2) ,
	REPLY_LEAVE_MSG_AT_ARTICLE("%s  回复了您在文章 <span>%s</span> 下的留言",12, 2) ,
	LEAVE_MSG_AT_ANSWER("%s  给您的回答 <span>%s</span> 留言了",11, 2) ,
	LEAVE_MSG_AT_PAPER("%s  给您的论文 <span>%s</span> 留言了",10, 2) ,
	LEAVE_MSG_AT_PARENT("%s  给您的专利 <span>%s</span> 留言了", 9, 2) ,
	LEAVE_MSG_AT_ARTICLE("%s  给您的文章 <span>%s</span> 留言了", 8, 2) ,
	AGREE_PAPER("%s 点赞了您的论文 <span>%s</span>", 7, 2) ,
	AGREE_PATENT("%s 点赞了您的专利 <span>%s</span>", 6, 2) ,
	INVITE_ANSWER("%s 邀请您回答问题 <span>%s</span>", 5, 2) ,
	ACCEPT_ANSWER("%s 点赞了您在问题 <span>%s</span> 下的回答", 4, 2) ,
	ANSWER_QUESTION("%s 回答了您的提问 <span>%s</span>", 3, 2) ,
	AGREE_ARTICLE("%s 点赞了您的文章 <span>%s</span>", 2, 2) ,
	AGREE_RESEARCH_AREA("%s 点赞了您的研究方向 <span>%s</span>", 1, 2) ,
	WATCH_USER("<span>%s</span> 关注了您", 0, 1);
	private String template;
	private int type;
	private int paramSize;
	NotifyType(String template, int type, int paramSize) {
		this.template = template;
		this.type = type;
		this.paramSize = paramSize;
	}
	public String getTemplate() {
		return template;
	}
	public int getType() {
		return type;
	}
	public String format(String user, String title) {
		return paramSize == 1 ? String.format(this.template, html(user)) : String.format(this.template, html(user), html(title));
	}
	private static String html(String html) {
		html = html.replaceAll("&", "&amp;");
		html = html.replace("\"", "&quot;"); // "
		html = html.replace("\t", "&nbsp;&nbsp;");// 替换跳格
		html = html.replace(" ", "&nbsp;");// 替换空格
		html = html.replace("<", "&lt;");
		html = html.replaceAll(">", "&gt;");
		return html;
	}
}

src/main/java/com/ekexiu/portal/question/Answer.java

@@ -0,0 +1,127 @@
package com.ekexiu.portal.question;
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;
@PrimaryKey("id")
@Uniques({@Unique(clolumns={"qid","uid"},name="UNI_ANSWER_QID_UID")})
@Table
public class Answer {
	private String id;
	private String qid;
	private String uid;
	private String state;
	private String cnt;
	private long agree;
	private long  ballot;
	private String createTime;
	private String modifyTime;
	private transient String timeDesc;
	
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	/**
	 * ID
	 * @return
	 */
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	/**
	 * 问题ID
	 * @return
	 */
	@Column(DE.text_de)
	public String getQid() {
		return qid;
	}
	public void setQid(String qid) {
		this.qid = qid;
	}
	/**
	 * 回答人ID
	 * @return
	 */
	@Column(DE.text_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	/**
	 * 状态 1：发布中   
	 * @return
	 */
	@Column(DE.singleChar)
	public String getState() {
		return state;
	}
	public void setState(String state) {
		this.state = state;
	}
	/**
	 * 回答内容
	 * @return
	 */
	@Column(DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	/**
	 * 点赞数量
	 */
	@Column(DE.long_de)
	public long getAgree() {
		return agree;
	}
	public void setAgree(long agree) {
		this.agree = agree;
	}
	/**
	 * 总数投票数
	 * @return
	 */
	@Column(DE.long_de)
	public long getBallot() {
		return ballot;
	}
	public void setBallot(long ballot) {
		this.ballot = ballot;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(DE.text_de)
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	
	
	
	
	
}

src/main/java/com/ekexiu/portal/question/AnswerAgreeRec.java

@@ -0,0 +1,37 @@
package com.ekexiu.portal.question;
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({"uid","aid"})
@Table
public class AnswerAgreeRec{
	private String uid;
	private String aid;
	private boolean flag;
	@Column(DE.text_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Column(DE.text_de)
	public String getAid() {
		return aid;
	}
	public void setAid(String aid) {
		this.aid = aid;
	}
	@Column(DE.boolean_de)
	public boolean isFlag() {
		return flag;
	}
	public void setFlag(boolean flag) {
		this.flag = flag;
	}
	
}

src/main/java/com/ekexiu/portal/question/QetKeyWord.java

@@ -0,0 +1,29 @@
package com.ekexiu.portal.question;
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({"id","kw"})
@Table
public class QetKeyWord {
	private String id;
	private String kw;
	@Column(DE.text_de)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getKw() {
		return kw;
	}
	public void setKw(String kw) {
		this.kw = kw;
	}
	
	
}

src/main/java/com/ekexiu/portal/question/Question.java

@@ -0,0 +1,153 @@
package com.ekexiu.portal.question;
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.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Table
public class Question implements ModifyTimeSupported{
	
	private String id;
	private String title;
	private String cnt;
	private String img;
	private String createTime;
	private String modifyTime;
	private String keys;
	private String uid;	
	private String lastReplyTime;
	private long replyCount;
	private String state;
	private long pageViews;
	private transient String timeDesc;
	
	
	@Column(DE.long_de)
	public long getPageViews() {
		return pageViews;
	}
	public void setPageViews(long pageViews) {
		this.pageViews = pageViews;
	}
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	/**
	 * ID
	 * @return
	 */
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.text_de)
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	/**
	 * 提问内容
	 * @return
	 */
	@Column(DE.Text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	/**
	 * 图片 用英文豆号分隔
	 * @return
	 */
	@Column(DE.Text_de)
	public String getImg() {
		return img;
	}
	public void setImg(String img) {
		this.img = img;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	/**
	 * 关键词，以英文逗号分隔
	 * @return
	 */
	@Column(DE.text_de)
	public String getKeys() {
		return keys;
	}
	public void setKeys(String keys) {
		this.keys = keys;
	}
	/**
	 * 发布人ID
	 * @return
	 */
	@Column(DE.text_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	/**
	 * 最后回答时间
	 * @return
	 */
	@Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = false, nullable = true, queryable = true, renewable = true)
	public String getLastReplyTime() {
		return lastReplyTime;
	}
	public void setLastReplyTime(String lastReplyTime) {
		this.lastReplyTime = lastReplyTime;
	}
	/**
	 * 回答次数
	 * @return
	 */
	@Column(DE.long_de)
	public long getReplyCount() {
		return replyCount;
	}
	public void setReplyCount(long replyCount) {
		this.replyCount = replyCount;
	}
	/**
	 * 提问状态  1：发布中
	 * @return
	 */
	@Column(DE.singleChar)
	public String getState() {
		return state;
	}
	public void setState(String state) {
		this.state = state;
	}
	
}

src/main/java/com/ekexiu/portal/question/QuestionDao.java

@@ -0,0 +1,185 @@
package com.ekexiu.portal.question;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.Column;
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.IncludeFixSet;
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.Where;
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.LimitQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.LimitSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryVal;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.In;
import org.jfw.apt.orm.annotation.dao.param.LessThan;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.annotation.dao.param.SqlColumn;
import org.jfw.apt.orm.core.defaultImpl.LongHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
@DAO
public interface QuestionDao {
	@Insert
	int insert(Connection con, Question qen) throws SQLException;
	@DeleteWith
	@From(QetKeyWord.class)
	int deleteKeys(Connection con, String id) throws SQLException;
	
	
	@UpdateWith
	@From(Question.class)
	@IncludeFixSet
	@SetSentence("REPLY_COUNT=REPLY_COUNT+1")
	int incQuestionReply(Connection con,String id)throws SQLException;
	
	@UpdateWith
	@From(Question.class)
	@SetSentence("REPLY_COUNT=REPLY_COUNT+1")
	int onlyIncQuestionReply(Connection con,String id)throws SQLException;
	
	
	
	@UpdateWith
	@From(Question.class)
	@SetSentence("REPLY_COUNT=REPLY_COUNT-1")
	@Where("REPLY_COUNT >0")
	int decQuestionReply(Connection con,String id)throws SQLException;
	
	@UpdateWith
	@From(Question.class)
	@SetSentence("PAGE_VIEWS=PAGE_VIEWS+1")
	int incQuestionPageViews(Connection con,String id)throws SQLException;
	@Insert
	@Batch
	int[] insert(Connection con, QetKeyWord[] kws) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC DESC")
	List<Question> query(Connection con, @Nullable String state, @Nullable String uid, @LessThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where(" STATE='1'")
	List<Question> watch(Connection con,
			@SqlColumn(handlerClass = StringHandler.class, value = {
					" ID IN (SELECT WATCH_OBJECT FROM WATCH WHERE WATCH_TYPE='8' AND PROFESSOR_ID=?)" }) String uid,
			@LessThan String timeDesc, int rows) throws SQLException;
	@SelectOne
	@Nullable
	Question query(Connection con, String id) throws SQLException;
	
	@UpdateWith
	@From(Answer.class)
	@SetSentence("STATE='0'")
	@Where("STATE ='1'")
	int logicDeleteAnswer(Connection con,String id,String qid)throws SQLException;
	
	@UpdateWith
	@From(Answer.class)
	@SetSentence("STATE='1'")
	@Where("STATE <>'1'")
	int unDeleteAnswer(Connection con,String id,String qid)throws SQLException;
	
	@SelectOne
	@Nullable
	Answer queryAnswer(Connection con,String id)throws SQLException;
	@SelectList
	List<Question> query(Connection con, @In String[] id) throws SQLException;
	
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> answer(Connection con,@LessThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> answerSelf(Connection con, String uid, @LessThan String timeDesc, int rows) throws SQLException;
	
	@SelectOne
	@Nullable
	Answer answer(Connection con,String uid,String qid)throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> watchAnswer(Connection con,
			@SqlColumn(handlerClass = StringHandler.class, value = {
					" ID IN (SELECT WATCH_OBJECT FROM WATCH WHERE WATCH_TYPE='9' AND PROFESSOR_ID=?)" }) String uid,
			@LessThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@Where("STATE='1'")
	@OrderBy("ORDER BY TIME_DESC DESC")
	List<Answer> byQes(Connection con, String qid, @LessThan String timeDesc, int rows) throws SQLException;
	@LimitQuery
	@OrderBy("ORDER BY SCORE_DESC DESC")
	@Where("STATE='1'")
	List<SortedAnswwer> byQesScore(Connection con, String qid, @SqlColumn(handlerClass = StringHandler.class, value = { "(case when ballot=0 then '00000'  else  TO_CHAR(10000 *AGREE / BALLOT,'00009') end  || ID) < ?  " })  String score, int rows) throws SQLException;
	@Insert
	int insert(Connection con,AnswerAgreeRec aar)throws SQLException;
	@UpdateWith
	@From(AnswerAgreeRec.class)
	@Where("FLAG<>'1'")
	@SetSentence("FLAG='1'")
	int agree(Connection con,String uid,String aid)throws SQLException;
	@UpdateWith
	@From(AnswerAgreeRec.class)
	@Where("FLAG='1'")
	@SetSentence("FLAG='0'")
	int unAgree(Connection con,String uid,String aid)throws SQLException;
	
	@UpdateWith
	@From(Answer.class)
	int update(Connection con,String id, @Set( " = AGREE +?" ) long agree,@Set("=BALLOT+?") long ballot)throws SQLException;
	
	
	@Insert
	int insert(Connection con, Answer answer) throws SQLException;
	@UpdateWith
	@From(Answer.class)
	@Where("STATE='1'")
	@SetSentence("MODIFY_TIME=TO_CHAR(NOW(),'YYYYMMDDHH24MISS')")
	int updateAnswer(Connection con, String id, @Set String cnt) throws SQLException;
	
	@Insert
	int insert(Connection con,QuestionInviteRec rec)throws SQLException;
	
	@SelectList
	List<QuestionInviteRec> queryInviteRec(Connection con,String qid,String uid,@In String[] pid)throws SQLException;
	
	@SelectOne
	@Nullable
	AnswerAgreeRec queryAswerAgreRec(Connection con,String uid,String aid)throws SQLException;
	
	@DeleteWith
	@From(AnswerAgreeRec.class)
	int deleteAnswerAgreeRec(Connection con,String uid,String aid,boolean flag)throws SQLException;
	
	@DefaultValue("0")
	@QueryVal
	@Column(value="COUNT(1)",handlerClass=LongHandler.class)
	@From(Answer.class)
	long answerCount(Connection con,@Nullable String uid,@Nullable String qid, @Nullable String state)throws SQLException;
}

src/main/java/com/ekexiu/portal/question/QuestionInviteRec.java

@@ -0,0 +1,46 @@
package com.ekexiu.portal.question;
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;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@PrimaryKey({"uid","qid","pid"})
@Table
public class QuestionInviteRec implements CreateTimeSupported {
	private String uid;
	private String qid;
	private String pid;
	private String createTime;
	@Column(DE.text_de)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Column(DE.text_de)
	public String getQid() {
		return qid;
	}
	public void setQid(String qid) {
		this.qid = qid;
	}
	@Column(DE.text_de)
	public String getPid() {
		return pid;
	}
	public void setPid(String pid) {
		this.pid = pid;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	
}

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

@@ -0,0 +1,825 @@
package com.ekexiu.portal.question;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.FieldParam;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.RequestParam;
import org.jfw.apt.web.annotation.param.Upload;
import org.jfw.util.DateUtil;
import org.jfw.util.JpgUtil;
import org.jfw.util.ListUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import org.jfw.util.web.fileupload.Item;
import org.jfw.util.web.fileupload.UploadItemIterator;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.util.SqlUtil;
@Path("/question")
public class Service {
	private static final AtomicInteger FN_IDX = new AtomicInteger(1);
	@Autowrie
	private QuestionDao questionDao;
	@Autowrie
	private NotifyService notifyService;
	private File imgPath;
	private int imgMaxWidth = 70;
	public int getImgMaxWidth() {
		return imgMaxWidth;
	}
	public void setImgMaxWidth(int imgMaxWidth) {
		this.imgMaxWidth = imgMaxWidth;
	}
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public File getImgPath() {
		return imgPath;
	}
	public void setImgPath(File imgPath) {
		this.imgPath = imgPath;
	}
	public QuestionDao getQuestionDao() {
		return questionDao;
	}
	public void setQuestionDao(QuestionDao questionDao) {
		this.questionDao = questionDao;
	}
	/**
	 * 上传文件
	 * 
	 * @param it
	 * @return
	 * @throws Exception
	 */
	@Path("/upload")
	@Post
	public List<UploadFile> upload(@Upload UploadItemIterator it) throws Exception {
		List<UploadFile> ret = new LinkedList<UploadFile>();
		try {
			while (it.hasNext()) {
				Item item = it.next();
				if (!item.isFormField()) {
					String name = normalizeFileName(item.getName());
					int index = name.lastIndexOf('.');
					String ext = index >= 0 ? name.substring(index + 1) : "";
					ext = ext.trim();
					long fileLen = 0;
					int len = 0;
					UploadFile uf = this.buildTargetFile(ext);
					uf.setName(name);
					File file = uf.getFn();
					ret.add(uf);
					byte[] buf = new byte[8092];
					OutputStream of = new FileOutputStream(file);
					try {
						InputStream in = item.getInputStream();
						try {
							while ((len = in.read(buf)) >= 0) {
								if (len > 0) {
									of.write(buf, 0, len);
									fileLen += len;
								}
							}
							uf.setSize(fileLen);
						} finally {
							in.close();
						}
					} finally {
						of.close();
					}
				}
			}
			return ret;
		} catch (Exception e) {
			this.remove(ret);
			throw e;
		} finally {
			if (it != null)
				it.clean();
		}
	}
	private void saveSmallImg(String imgs) throws IOException {
		if (imgs != null) {
			List<String> list = ListUtil.splitTrimExcludeEmpty(imgs, ',');
			if (list.size() > 0) {
				String oname = list.get(0);
				if (oname != null) {
					if (oname.startsWith("/")) {
						oname = oname.substring(1);
						int idx = oname.indexOf('.');
						if (idx > 0) {
							String dname = oname.substring(0, idx) + "_s.jpg";
							File dest = new File(this.imgPath, dname);
							if (dest.exists())
								return;
							File src = new File(this.imgPath, oname);
							if (src.exists()) {
								byte[] obs = IoUtil.readStream(new FileInputStream(src), true);
								obs = JpgUtil.read(obs);
								FileOutputStream out = new FileOutputStream(dest);
								try {
									JpgUtil.scalingZoom(new ByteArrayInputStream(obs), out, this.imgMaxWidth);
									out.flush();
								} finally {
									IoUtil.close(out);
								}
							}
						}
					}
				}
			}
		}
	}
	/**
	 * 新增一提问
	 * 
	 * @param con
	 * @param q
	 *            title 标题 ，cnt 描述 img 图片 以英文逗号分隔， keys 关键字 以英文逗号分隔 ，uid 用户ID
	 * @return
	 * @throws SQLException
	 * @throws IOException
	 */
	@Path()
	@Post
	public String save(@JdbcConn(true) Connection con,
			@RequestParam(fields = { @FieldParam(value = "title", valueClass = String.class),
					@FieldParam(value = "cnt", valueClass = String.class, required = false),
					@FieldParam(value = "img", valueClass = String.class, required = false), @FieldParam(value = "keys", valueClass = String.class),
					@FieldParam(value = "uid", valueClass = String.class) }) Question q)
			throws SQLException, IOException {
		String id = StringUtil.buildUUID();
		q.setId(id);
		q.setReplyCount(0);
		q.setState("1");
		q.setPageViews(0);
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		q.setCreateTime(time);
		q.setTimeDesc(time + id);
		List<String> kws = ListUtil.splitTrimExcludeEmpty(q.getKeys(), ',');
		if (kws.isEmpty())
			throw new IllegalArgumentException("param keys invalid");
		this.saveSmallImg(q.getImg());
		questionDao.insert(con, q);
		questionDao.insert(con, build(id, kws));
		return id;
	}
	@Path("/pageViews")
	@Post
	public void incQuestionPageView(@JdbcConn(true) Connection con, String qid) throws SQLException {
		questionDao.incQuestionPageViews(con, qid);
	}
	/**
	 * 默认的邀请专家
	 * 
	 * @param con
	 * @param id
	 *            提问ID
	 * @param uid
	 *            本人ID
	 * @param count
	 *            limit 查询 返回最后一条的 kws ,首次不传
	 * @param pid
	 *            limit 查询 返回最后一条的 id 首次可不传
	 * @param rows
	 *            limit查询返回的最大数据条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/commendatoryPro")
	public List<Map<String, Object>> professor(@JdbcConn Connection con, final String id, final String uid, final @DefaultValue("Integer.MAX_VALUE") int count,
			final @DefaultValue("\"0\"") String pid, final @DefaultValue("Integer.MAX_VALUE") int rows) throws SQLException {
		return JdbcUtil.queryMaps(con,
				"select id, kws from(select id,count(1) kws from pro_key_word where id <> ? and kw in (select kw from qet_key_word where id =?) group by id ) t where kws<= ? and id >? order by kws desc,id asc limit ?",
				new PreparedStatementConfig() {
					@Override
					public void config(PreparedStatement ps) throws SQLException {
						ps.setString(1, uid);
						ps.setString(2, id);
						ps.setInt(3, count);
						ps.setString(4, pid);
						ps.setInt(5, rows);
					}
				});
	}
	/**
	 * 邀请专家回答提问
	 * 
	 * @param con
	 * @param qid
	 *            提问id
	 * @param pid
	 *            专家id(被邀请人)
	 * @param uid
	 *            操作人（邀请人
	 * @param uname
	 *            操作人（邀请人）姓名
	 * @return
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Post
	@Path("/invite")
	public boolean invite(@JdbcConn(true) Connection con, String qid, String pid, String uid, String uname, @AfterCommit List<Runnable> runs)
			throws SQLException, JfwBaseException {
		Question q = questionDao.query(con, qid);
		if (q == null) {
			throw new JfwBaseException(50000, "question[" + qid + "] not found");
		}
		QuestionInviteRec rec = new QuestionInviteRec();
		rec.setUid(uid);
		rec.setPid(pid);
		rec.setQid(qid);
		try {
			questionDao.insert(con, rec);
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				throw new JfwBaseException(50001, "duplicate invite");
			}
			throw e;
		}
		if (!pid.equals(uid)) {
			this.notifyService.notify(con, pid, uid, uname, qid, q.getTitle(), NotifyType.INVITE_ANSWER, runs);
		}
		return true;
	}
	@Get
	@Path("/invite")
	public List<QuestionInviteRec> queryInviteRec(@JdbcConn Connection con, String uid, String qid, String[] pid) throws SQLException {
		return questionDao.queryInviteRec(con, qid, uid, pid);
	}
	/**
	 * 回答一个提问
	 * 
	 * @param con
	 * @param qid
	 *            提问ID
	 * @param cnt
	 *            回答内容
	 * @param uid
	 *            回答 人ID
	 * @param uname
	 *            回答人姓名
	 * @return
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Post
	@Path("/answer")
	public String answer(@JdbcConn(true) Connection con, String qid, String cnt, String uid, String uname, @AfterCommit List<Runnable> runs)
			throws SQLException, JfwBaseException {
		Question q = questionDao.query(con, qid);
		if (q == null) {
			throw new JfwBaseException(50000, "question[" + qid + "] not found");
		}
		String id = StringUtil.buildUUID();
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		Answer a = new Answer();
		a.setId(id);
		a.setAgree(0);
		a.setBallot(0);
		a.setCnt(cnt);
		a.setQid(qid);
		a.setState("1");
		a.setUid(uid);
		a.setCreateTime(time);
		a.setTimeDesc(time + id);
		a.setModifyTime(time);
		try {
			questionDao.insert(con, a);
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				throw new JfwBaseException(50001, "duplicate answer");
			}
			throw e;
		}
		questionDao.incQuestionReply(con, qid);
		if (!uid.equals(q.getUid())) {
			notifyService.notify(con, q.getUid(), uid, uname, id + ":" + qid, q.getTitle(), NotifyType.ANSWER_QUESTION, runs);
		}
		return id;
	}
	@Get
	@Path("/answer")
	public Answer answer(@JdbcConn Connection con, @Nullable String id, @Nullable String uid, @Nullable String qid) throws SQLException {
		if (id != null) {
			return questionDao.queryAnswer(con, id);
		} else if (qid != null && uid != null) {
			return questionDao.answer(con, uid, qid);
		}
		return null;
	}
	@Get
	@Path("/answer/exists")
	public boolean existsAnswer(@JdbcConn Connection con, String uid, String qid) throws SQLException {
		return null != questionDao.answer(con, uid, qid);
	}
	/**
	 * 修改一个回答
	 * 
	 * @param con
	 * @param id
	 *            回答ID
	 * @param cnt
	 *            回答内容
	 * @param uid
	 *            用户ID
	 * @param uname
	 *            用户姓名
	 * @return
	 * @throws SQLException
	 */
	@Post
	@Path("/answer/modify")
	public int answerUpdate(@JdbcConn(true) Connection con, String id, String cnt, String uid, String uname) throws SQLException {
		return questionDao.updateAnswer(con, id, cnt);
	}
	@Get
	@Path("/qo")
	public Question queryOne(@JdbcConn Connection con, String id) throws SQLException {
		return questionDao.query(con, id);
	}
	@Get
	@Path("/qm")
	public List<Question> query(@JdbcConn Connection con, String[] ids) throws SQLException {
		return questionDao.query(con, ids);
	}
	/**
	 * 等您回答 1、只显示“发布中”的问题 按问题发布时间，由新到旧排序。
	 * 
	 * @param con
	 * @param time
	 *            limit查询最后一条的createTime 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path()
	public List<Question> query(@JdbcConn Connection con, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.query(con, "1", null, time + id, rows);
	}
	/**
	 * 我提出的 1、只显示“发布中”的问题 按问题发布时间，由新到旧排序。
	 * 
	 * @param con
	 * @param uid
	 *            用户ID
	 * @param time
	 *            limit查询最后一条的createTime 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/my")
	public List<Question> querySelf(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.query(con, "1", uid, time + id, rows);
	}
	@Get
	@Path("/answer/count")
	public long answerCount(@JdbcConn Connection con, @Nullable String qid, @Nullable String uid, @Nullable String state) throws SQLException {
		return questionDao.answerCount(con, uid, qid, state);
	}
	/**
	 * 我关注的 1、只显示“发布中”的问题 按问题发布时间，由新到旧排序。
	 * 
	 * @param con
	 * @param uid
	 *            用户ID
	 * @param time
	 *            limit查询最后一条的createTime 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/watch")
	public List<Question> watch(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.watch(con, uid, time + id, rows);
	}
	/**
	 * 我回答的
	 * 
	 * @param con
	 * @param uid
	 *            用户ID
	 * @param time
	 *            limit查询最后一条的createTime 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/bySelf")
	public List<Answer> answerSelf(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.answerSelf(con, uid, time + id, rows);
	}
	/**
	 * 我关注的回答
	 * 
	 * @param con
	 * @param uid
	 *            用户ID
	 * @param time
	 *            limit查询最后一条的createTime 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/byWatch")
	public List<Answer> answerWatch(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.watchAnswer(con, uid, time + id, rows);
	}
	/**
	 * 查询所有合法的回答（“发布中”的问题下的“发布中”的回答。); 按最新回答时间，由新到旧排序 }）
	 * 
	 * @param con
	 * @param time
	 * @param id
	 * @param rows
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/byTime")
	public List<Answer> answerByTime(@JdbcConn Connection con, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.answer(con, time + id, rows);
	}
	/**
	 * 指定提问的回答(按最新回答时间，由新到旧排序）
	 * 
	 * @param con
	 * @param qid
	 *            提问ID
	 * @param time
	 *            limit查询最后一条的createTime 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/qes/byTime")
	public List<Answer> byQes(@JdbcConn Connection con, String qid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.byQes(con, qid, time + id, rows);
	}
	/**
	 * 指定提问的回答(按最新回答时间，由新到旧排序）
	 * 
	 * @param con
	 * @param qid
	 *            提问ID
	 * @param score
	 *            limit查询最后一条的score 首次不传
	 * @param id
	 *            limit查询最后一条的id 首次不传
	 * @param rows
	 *            limit查询最后一条的最大返回条数
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/qes/byScore")
	public List<SortedAnswwer> byQes(@JdbcConn Connection con, String qid, @DefaultValue("99999") int score, @DefaultValue("\"Z\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		String p = "000000" + score;
		p = p.substring(p.length() - 5) + id;
		return questionDao.byQesScore(con, qid, p, rows);
	}
	/**
	 * 我的回答总点赞数
	 * 
	 * @param con
	 * @param id
	 *            用户ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/my/agree/count")
	public int queryCountWithMyAnswer(@JdbcConn Connection con, final String id) throws SQLException {
		return JdbcUtil.queryInt(con, "SELECT SUM(AGREE) FROM ANSWER WHERE UID=?", new PreparedStatementConfig() {
			@Override
			public void config(PreparedStatement ps) throws SQLException {
				ps.setString(1, id);
			}
		}, 0);
	}
	@Post
	@Path("/answer/agree")
	public void agree(@JdbcConn(true) Connection con, String id, String uid, String uname, @AfterCommit List<Runnable> runs)
			throws SQLException, JfwBaseException {
		Answer a = questionDao.queryAnswer(con, id);
		if (a == null)
			throw new JfwBaseException(50000, "answer[" + id + "] not found");
		String qid = a.getQid();
		Question q = questionDao.query(con, qid);
		if (q == null)
			throw new JfwBaseException(50000, "answer[" + id + "] ' question  not found");
		AnswerAgreeRec aar = new AnswerAgreeRec();
		aar.setAid(id);
		aar.setUid(uid);
		aar.setFlag(true);
		boolean inserted = false;
		try {
			questionDao.insert(con, aar);
			inserted = true;
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				con.rollback();
			} else {
				throw e;
			}
		}
		if (inserted) {
			questionDao.update(con, id, 1, 1);
		} else {
			if (questionDao.agree(con, uid, id) > 0) {
				questionDao.update(con, id, 1, 0);
			} else {
				throw new JfwBaseException(50001, "duplicate answer agree");
			}
		}
		if (!uid.equals(a.getUid())) {
			notifyService.notify(con, a.getUid(), uid, uname, a.getId() + ":" + qid, q.getTitle(), NotifyType.ACCEPT_ANSWER, runs);
		}
	}
	@Post
	@Path("/answer/agree/cancle")
	public int unAgree(@JdbcConn(true) Connection con, String id, String uid, String uname) throws SQLException, JfwBaseException {
		Answer a = questionDao.queryAnswer(con, id);
		if (a == null)
			throw new JfwBaseException(50000, "answer[" + id + "] not found");
		if (questionDao.deleteAnswerAgreeRec(con, uid, id, true) > 0) {
			questionDao.update(con, id, -1, -1);
			return 1;
		}
		return 0;
	}
	@Post
	@Path("/answer/oppose/cancle")
	public int unOpp(@JdbcConn(true) Connection con, String id, String uid, String uname) throws SQLException, JfwBaseException {
		Answer a = questionDao.queryAnswer(con, id);
		if (a == null)
			throw new JfwBaseException(50000, "answer[" + id + "] not found");
		if (questionDao.deleteAnswerAgreeRec(con, uid, id, false) > 0) {
			questionDao.update(con, id, 0, -1);
			return 1;
		}
		return 0;
	}
	@Get
	@Path("/answer/agree")
	public AnswerAgreeRec isAgree(@JdbcConn Connection con, String aid, String uid) throws SQLException {
		return questionDao.queryAswerAgreRec(con, uid, aid);
	}
	@Get
	@Path("/answer/delete")
	public int logicDelete(@JdbcConn(true) Connection con, String id, String qid) throws SQLException {
		if (questionDao.logicDeleteAnswer(con, id, qid) > 0) {
			questionDao.decQuestionReply(con, qid);
			return 1;
		}
		return 0;
	}
	@Get
	@Path("/answer/unDel")
	public int unDelete(@JdbcConn(true) Connection con, String id, String qid) throws SQLException {
		if (questionDao.unDeleteAnswer(con, id, qid) > 0) {
			questionDao.onlyIncQuestionReply(con, qid);
			return 1;
		}
		return 0;
	}
	@Post
	@Path("/answer/oppose")
	public void oppose(@JdbcConn(true) Connection con, String id, String uid, String uname) throws SQLException, JfwBaseException {
		AnswerAgreeRec aar = new AnswerAgreeRec();
		aar.setAid(id);
		aar.setUid(uid);
		aar.setFlag(false);
		boolean inserted = false;
		try {
			questionDao.insert(con, aar);
			inserted = true;
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				con.rollback();
			} else {
				throw e;
			}
		}
		if (inserted) {
			questionDao.update(con, id, 0, 1);
		} else {
			if (questionDao.unAgree(con, uid, id) > 0) {
				questionDao.update(con, id, -1, 0);
			} else {
				throw new JfwBaseException(50001, "duplicate answer oppose");
			}
		}
	}
	public QetKeyWord[] build(String id, List<String> ss) {
		List<QetKeyWord> qKws = new ArrayList<>(ss.size());
		for (String s : ss) {
			QetKeyWord kw = new QetKeyWord();
			kw.setId(id);
			kw.setKw(s);
			qKws.add(kw);
		}
		return qKws.toArray(new QetKeyWord[qKws.size()]);
	}
	private void remove(List<UploadFile> list) {
		for (UploadFile file : list) {
			if (file.fn != null)
				file.fn.delete();
		}
	}
	private UploadFile buildTargetFile(String ext) {
		StringBuilder sb = new StringBuilder();
		sb.append(System.currentTimeMillis() / (1000 * 60 * 60 * 24));
		File path = new File(this.imgPath, sb.toString());
		if (!path.exists()) {
			synchronized (this) {
				if (!path.mkdirs())
					throw new RuntimeException("mkdir error[" + path + "]");
				FN_IDX.set(1);
			}
		}
		File file;
		do {
			String fn = FN_IDX.toString();
			if (ext.isEmpty()) {
				file = new File(path, fn);
			} else {
				file = new File(path, fn + "." + ext);
			}
			FN_IDX.incrementAndGet();
		} while (file.exists());
		sb.append("/").append(file.getName());
		UploadFile uf = new UploadFile();
		uf.setFn(file);
		uf.setUri("/" + sb.toString());
		return uf;
	}
	private String normalizeFileName(String fn) {
		int index = fn.indexOf('\\');
		if (index >= 0) {
			fn = fn.substring(fn.lastIndexOf('\\') + 1);
		}
		index = fn.indexOf('/');
		if (index >= 0) {
			fn = fn.substring(fn.lastIndexOf('/') + 1);
		}
		if (fn.length() == 0)
			throw new RuntimeException("invalid filename in Multipart/data request");
		return fn;
	}
	public static class UploadFile {
		private String name;
		private String uri;
		private long size;
		private transient File fn;
		public File getFn() {
			return fn;
		}
		public void setFn(File fn) {
			this.fn = fn;
		}
		public String getName() {
			return name;
		}
		public void setName(String name) {
			this.name = name;
		}
		public String getUri() {
			return uri;
		}
		public void setUri(String uri) {
			this.uri = uri;
		}
		public long getSize() {
			return size;
		}
		public void setSize(long size) {
			this.size = size;
		}
	}
}

src/main/java/com/ekexiu/portal/question/SortedAnswwer.java

@@ -0,0 +1,32 @@
package com.ekexiu.portal.question;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendTable;
import org.jfw.apt.orm.core.defaultImpl.LongHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
@ExtendTable
public class SortedAnswwer extends Answer {
	private long score ;
	private transient String scoreDesc;
	
	
	@CalcColumn(nullable=false,handlerClass=StringHandler.class,column=" case when ballot=0 then '00000' else  TO_CHAR(10000 *AGREE / BALLOT,'00009') end  || ID SCORE_DESC")
	public String getScoreDesc() {
		return scoreDesc;
	}
	public void setScoreDesc(String scoreDesc) {
		this.scoreDesc = scoreDesc;
	}
	@CalcColumn(nullable=false,handlerClass=LongHandler.class,column="case when ballot=0 then 0 else  10000 *AGREE / BALLOT end SCORE")
	public long getScore() {
		return score;
	}
	public void setScore(long score) {
		this.score = score;
	}
   
}

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

@@ -1,33 +1,5 @@
package com.ekexiu.portal.service;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Collections;
import java.util.Date;
import java.util.List;
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.JpgUtil;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import com.ekexiu.portal.cms.ContentType;
import com.ekexiu.portal.cms.TemplateService;
import com.ekexiu.portal.dao.ArticleAgreeDao;
@@ -41,6 +13,8 @@ import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.ResearchAreaDao;
import com.ekexiu.portal.dao.ResourceDao;
import com.ekexiu.portal.dao.WatchDao;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.po.Article;
import com.ekexiu.portal.po.ArticleAgree;
import com.ekexiu.portal.po.ArticleOrg;
@@ -51,6 +25,34 @@ import com.ekexiu.portal.pojo.EditOrganization;
import com.ekexiu.portal.pojo.EditProfessor;
import com.ekexiu.portal.pojo.FindInfo;
import com.ekexiu.portal.pojo.SelfArticle;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.DateUtil;
import org.jfw.util.JpgUtil;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Collections;
import java.util.Date;
import java.util.List;
@Path("/article")
public class ArticleService {
@@ -95,6 +97,18 @@ public class ArticleService {
	@Autowrie
	private TemplateService templateService;
	
	@Autowrie
	private NotifyService notifyService;
	
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public TemplateService getTemplateService() {
		return templateService;
@@ -747,12 +761,21 @@ public class ArticleService {
	@Post
	@Path("/agree")
	public void agree(@JdbcConn(true) Connection con, String operateId, String articleId) throws SQLException {
	public void agree(@JdbcConn(true) Connection con, String operateId, String articleId,@Nullable String uname,@AfterCommit List<Runnable> runs) throws SQLException {
		final Article article = this.articleDao.queryOne(con, articleId);
		if(article==null){
			throw new IllegalArgumentException("not found article["+articleId+ "]");
		}
		if (this.articleDao.incAgree(con, articleId) > 0) {
			ArticleAgree articleAgree = new ArticleAgree();
			articleAgree.setOperateId(operateId);
			articleAgree.setArticleId(articleId);
			this.articleAgreeDao.insert(con, articleAgree);
			if (uname != null) {
				if (article.getArticleType().equals("1") && (!operateId.equals(article.getProfessorId()))) {
					this.notifyService.notify(con, article.getProfessorId(), operateId, uname, articleId, article.getArticleTitle(), NotifyType.AGREE_ARTICLE, runs);
				}
			}
		}
	}

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

@@ -125,8 +125,31 @@ public class FeedbackService {
		fb.setState("0");
		fb.setContent(cnt);
		fb.setUserId(user);
		fb.setSchema(7);
		return this.feedbackDao.insert(con, fb);
	}
	@Post
	@Path("/error/question")
	public long errorQuestion(@JdbcConn(true) Connection con,String cnt,String id,@Nullable String user)throws SQLException{
		Feedback fb = new Feedback();
		fb.setCategory(1);
		fb.setParam(id);
		fb.setState("0");
		fb.setContent(cnt);
		fb.setUserId(user);
		fb.setSchema(8);
		return this.feedbackDao.insert(con, fb);
	}
	@Post
	@Path("/error/answer")
	public long errorAnswer(@JdbcConn(true) Connection con,String cnt,String id,@Nullable String user)throws SQLException{
		Feedback fb = new Feedback();
		fb.setCategory(1);
		fb.setParam(id);
		fb.setState("0");
		fb.setContent(cnt);
		fb.setUserId(user);
		fb.setSchema(9);
		return this.feedbackDao.insert(con, fb);
	}
	
	
}

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

@@ -1,26 +1,29 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.List;
import com.ekexiu.portal.dao.PaperAgreeDao;
import com.ekexiu.portal.dao.PaperAuthorDao;
import com.ekexiu.portal.dao.PpaperDao;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.po.PaperAgree;
import com.ekexiu.portal.po.PaperAuthor;
import com.ekexiu.portal.po.Ppaper;
import com.ekexiu.portal.pojo.AssedPaper;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.PageQueryResult;
import org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.dao.PaperAgreeDao;
import com.ekexiu.portal.dao.PaperAuthorDao;
import com.ekexiu.portal.dao.PpaperDao;
import com.ekexiu.portal.po.PaperAgree;
import com.ekexiu.portal.po.PaperAuthor;
import com.ekexiu.portal.po.Ppaper;
import com.ekexiu.portal.pojo.AssedPaper;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.List;
@Path("/ppaper")
public class PpaperService {
@@ -29,15 +32,23 @@ public class PpaperService {
	private PpaperDao ppaperDao;
	@Autowrie
	private PaperAuthorDao paperAuthorDao;
	
	@Autowrie
	private KeyWordService keyWordService;
	
	@Autowrie
	private PaperAgreeDao paperAgreeDao;
	
	
	
	@Autowrie
	private NotifyService notifyService;
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public PaperAgreeDao getPaperAgreeDao() {
		return paperAgreeDao;
@@ -164,57 +175,74 @@ public class PpaperService {
	@Path("/kw")
	public void update(@JdbcConn(true) Connection con, String id, @Nullable String keywords) throws SQLException {
		this.ppaperDao.update(con, id, keywords);
		this.keyWordService.refreshPaper(con, id, KeyWordService.splitKeyWord(keywords));		
		this.keyWordService.refreshPaper(con, id, KeyWordService.splitKeyWord(keywords));
	}
	@Get
	@Path("/byShareId")
	public Ppaper query(@JdbcConn Connection con,long id) throws SQLException{
		return this.ppaperDao.query(con,id);
	public Ppaper query(@JdbcConn Connection con, long id) throws SQLException {
		return this.ppaperDao.query(con, id);
	}
	@Get
	@Path("/ralatePapers")
	public List<Ppaper> ralatePapers(@JdbcConn Connection con,String paperId,@DefaultValue("5") int rows)throws SQLException{
	public List<Ppaper> ralatePapers(@JdbcConn Connection con, String paperId, @DefaultValue("5") int rows) throws SQLException {
		String[] ids = this.ppaperDao.queryPaperIdWithSameKeyWord(con, paperId, rows);
		if(ids!=null){
			return this.ppaperDao.query(con,ids);
		if (ids != null) {
			return this.ppaperDao.query(con, ids);
		}
		return Collections.<Ppaper>emptyList();
		return Collections.<Ppaper> emptyList();
	}
	
	
	@Post
	@Path("/agree")
	public void agree(@JdbcConn(true) Connection con,String id,String uid)throws SQLException{
	public void agree(@JdbcConn(true) Connection con, String id, String uid,@Nullable String uname, @AfterCommit List<Runnable> runs) throws SQLException, JfwBaseException {
		Ppaper p = this.ppaperDao.query(con, id);
		if (p == null) {
			throw new JfwBaseException(50000, "paper[" + id + "] not found");
		}
		PaperAgree pa = new PaperAgree();
		pa.setOpId(uid);
		pa.setPaperId(id);
		this.paperAgreeDao.insert(con, pa);		
	}
	
//	@Post
//	@Path("/unAgree")
//	public void unAgree(@JdbcConn(true) Connection con,String id,String uid)throws SQLException{
//		this.paperAgreeDao.delete(con,uid, id);
//	}
	
		this.paperAgreeDao.insert(con, pa);
		if (uname != null) {
			List<PaperAuthor> pas = this.paperAuthorDao.query(con, id);
			for (PaperAuthor au : pas) {
				if (!au.getProfessorId().startsWith("#") && (!uid.equals(au.getProfessorId()))) {
					this.notifyService.notify(con, au.getProfessorId(), uid, uname, id, p.getName(), NotifyType.AGREE_PAPER, runs);
				}
			}
		}
	}
	// @Post
	// @Path("/unAgree")
	// public void unAgree(@JdbcConn(true) Connection con,String id,String
	// uid)throws SQLException{
	// this.paperAgreeDao.delete(con,uid, id);
	// }
	@Get
	@Path("/agree")
	public boolean hasAgree(@JdbcConn(false) Connection con,String id,String uid)throws SQLException{
		return null!= this.paperAgreeDao.query(con,uid, id);
	public boolean hasAgree(@JdbcConn(false) Connection con, String id, String uid) throws SQLException {
		return null != this.paperAgreeDao.query(con, uid, id);
	}
	@Get
	@Path("/agreeCount")
	public int agreeCount(@JdbcConn(false) Connection con,String id)throws SQLException{
		return this.paperAgreeDao.query(con,id);
	public int agreeCount(@JdbcConn(false) Connection con, String id) throws SQLException {
		return this.paperAgreeDao.query(con, id);
	}
	
	@Get
	@Path("/assPapers")
	public List<Ppaper> assPapers(@JdbcConn Connection con,String[] kws,@DefaultValue("5") int rows) throws SQLException{
		if(kws==null || kws.length==0) return Collections.<Ppaper>emptyList();		
	public List<Ppaper> assPapers(@JdbcConn Connection con, String[] kws, @DefaultValue("5") int rows) throws SQLException {
		if (kws == null || kws.length == 0)
			return Collections.<Ppaper> emptyList();
		String[] ids = this.ppaperDao.queryPatentIdWithKeyWord(con, kws, rows);
		if(ids==null || ids.length==0) return Collections.<Ppaper>emptyList();
		return this.ppaperDao.query(con, ids);		
		if (ids == null || ids.length == 0)
			return Collections.<Ppaper> emptyList();
		return this.ppaperDao.query(con, ids);
	}
}

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

@@ -1,26 +1,29 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.List;
import com.ekexiu.portal.dao.PatentAgreeDao;
import com.ekexiu.portal.dao.PatentAuthorDao;
import com.ekexiu.portal.dao.PpatentDao;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.po.PatentAgree;
import com.ekexiu.portal.po.PatentAuthor;
import com.ekexiu.portal.po.Ppatent;
import com.ekexiu.portal.pojo.AssedPatent;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.PageQueryResult;
import org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.dao.PatentAgreeDao;
import com.ekexiu.portal.dao.PatentAuthorDao;
import com.ekexiu.portal.dao.PpatentDao;
import com.ekexiu.portal.po.PatentAgree;
import com.ekexiu.portal.po.PatentAuthor;
import com.ekexiu.portal.po.Ppatent;
import com.ekexiu.portal.pojo.AssedPatent;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.List;
@Path("/ppatent")
public class PpatentServcie {
@@ -36,7 +39,18 @@ public class PpatentServcie {
	@Autowrie
	private PatentAgreeDao patentAgreeDao;
	
	@Autowrie
	private NotifyService notifyService;
	
	
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public PatentAgreeDao getPatentAgreeDao() {
		return patentAgreeDao;
@@ -178,11 +192,23 @@ public class PpatentServcie {
	
	@Post
	@Path("/agree")
	public void agree(@JdbcConn(true) Connection con,String id,String uid)throws SQLException{
	public void agree(@JdbcConn(true) Connection con,String id,String uid,@Nullable String uname,@AfterCommit List<Runnable> runs)throws SQLException, JfwBaseException{
		Ppatent p = ppatentDao.query(con, id);
		if(p==null){
			throw new JfwBaseException(50000, "patent["+id+"] not found");
		}
		PatentAgree pa = new PatentAgree();
		pa.setOpId(uid);
		pa.setPatentId(id);
		this.patentAgreeDao.insert(con, pa);		
		this.patentAgreeDao.insert(con, pa);
		if (uname != null) {
			List<PatentAuthor> authors = this.patentAuthorDao.query(con, id);
			for (PatentAuthor pau : authors) {
				if (!pau.getProfessorId().startsWith("#") && (!uid.equals(pau.getProfessorId()))) {
					this.notifyService.notify(con, pau.getProfessorId(), uid, uname, id, p.getName(), NotifyType.AGREE_PATENT, runs);
				}
			}
		}
	}
	
//	@Post

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

@@ -28,6 +28,7 @@ import org.jfw.apt.web.annotation.param.RequestBody;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import com.ekexiu.portal.dao.ArticleDao;
import com.ekexiu.portal.dao.DemandDao;
@@ -726,8 +727,8 @@ public class ProfessorService {
	@Get
	@Path("/pqBaseInfo")
	PageQueryResult<EditProfessor> queryEditBaseInfo(@JdbcConn(false) Connection con, @Nullable String key, @Nullable String subject, @Nullable String industry,
			@Nullable String address, @DefaultValue("1") Integer authType, @DefaultValue("10") int pageSize, @DefaultValue("1") int pageNo)
	public PageQueryResult<EditProfessor> queryEditBaseInfo(@JdbcConn(false) Connection con, @Nullable String key, @Nullable String subject,
			@Nullable String industry, @Nullable String address, @Nullable Integer authType, @DefaultValue("10") int pageSize, @DefaultValue("1") int pageNo)
			throws SQLException {
		if (key != null) {
			key = "%" + key + "%";
@@ -756,7 +757,7 @@ public class ProfessorService {
	@Get
	@Path("/pqUserInfo")
	PageQueryResult<UserInfo> queryUserInfo(@JdbcConn(false) Connection con, @Nullable String key, @Nullable String address, @Nullable String orgName,
	public PageQueryResult<UserInfo> queryUserInfo(@JdbcConn(false) Connection con, @Nullable String key, @Nullable String address, @Nullable String orgName,
			@Nullable Integer activeState, @Nullable Integer authType, @DefaultValue("20") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
		if (key != null) {
			key = "%" + key + "%";
@@ -772,7 +773,7 @@ public class ProfessorService {
	@Get
	@Path("/pq")
	PageQueryResult<Professor> query(@JdbcConn(false) Connection con, @Nullable String key, @Nullable String subject, @Nullable String industry,
	public PageQueryResult<Professor> query(@JdbcConn(false) Connection con, @Nullable String key, @Nullable String subject, @Nullable String industry,
			@Nullable String address, @DefaultValue("10") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
		// System.out.println("key==["+(key==null?"":key)+"]");
		// System.out.println("subject==["+(subject==null?"":subject)+"]");
@@ -788,6 +789,22 @@ public class ProfessorService {
		return this.professorDao.query(con, key, subject, industry, address, pageSize, pageNo);
	}
	@Get
	@Path("/agree/sum")
	public long agreeSum(@JdbcConn Connection con, final String id) throws SQLException {
		return JdbcUtil.queryLong(con,
				" select SUM(agree) from (SELECT article_agree agree FROM ARTICLE WHERE STATUS ='1' AND professor_id =? UNION ALL SELECT AGREE FROM ANSWER WHERE STATE='1' AND UID =? ) t",
				new PreparedStatementConfig() {
					@Override
					public void config(PreparedStatement ps) throws SQLException {
						ps.setString(1, id);
						ps.setString(2, id);
					}
				}, 0);
	}
	@Get
	@Path("/editInfo/{id}")
	public ProfessorInfo editInfo(@JdbcConn(false) Connection con, @PathVar String id) throws SQLException {

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

@@ -1,23 +1,26 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import com.ekexiu.portal.dao.ResearchAreaDao;
import com.ekexiu.portal.dao.ResearchAreaLogDao;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.po.ResearchArea;
import com.ekexiu.portal.po.ResearchAreaLog;
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.operate.Delete;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.operate.Put;
import org.jfw.apt.web.annotation.param.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.apt.web.annotation.param.RequestBody;
import com.ekexiu.portal.dao.ResearchAreaDao;
import com.ekexiu.portal.dao.ResearchAreaLogDao;
import com.ekexiu.portal.po.ResearchArea;
import com.ekexiu.portal.po.ResearchAreaLog;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@Path("/researchArea")
public class ResearchAreaService {
@@ -27,6 +30,17 @@ public class ResearchAreaService {
	@Autowrie
	private ResearchAreaLogDao researchAreaLogDao;
	@Autowrie
	private NotifyService notifyService;
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public ResearchAreaDao getResearchAreaDao() {
		return researchAreaDao;
	}
@@ -45,13 +59,14 @@ public class ResearchAreaService {
	@Get
	@Path("/{professorId}")
	public List<ResearchArea> query(@JdbcConn Connection con,@PathVar String professorId) throws SQLException {
	public List<ResearchArea> query(@JdbcConn Connection con, @PathVar String professorId) throws SQLException {
		return this.researchAreaDao.query(con, professorId);
	}
	@Post
	@Path("/agree")
	public void agree(@JdbcConn(true) Connection con, String targetId, String targetCaption, String opId) throws SQLException {
	public void agree(@JdbcConn(true) Connection con, String targetId, String targetCaption, String opId, @Nullable String uname, @AfterCommit List<Runnable> runs)
			throws SQLException {
		if (this.researchAreaDao.inc(con, targetId, targetCaption) > 0) {
			ResearchAreaLog log = new ResearchAreaLog();
@@ -59,6 +74,11 @@ public class ResearchAreaService {
			log.setOpreteProfessorId(opId);
			log.setProfessorId(targetId);
			this.researchAreaLogDao.insert(con, log);
			if (uname != null) {
				if (!targetId.equals(opId)) {
					this.notifyService.notify(con, targetId, opId, uname, targetId, targetCaption, NotifyType.AGREE_RESEARCH_AREA, runs);
				}
			}
		}
	}
@@ -71,13 +91,13 @@ public class ResearchAreaService {
		}
	}
	
	@Delete
	@Path("/{professorId}")
	public void delete(@JdbcConn(true) Connection con,@PathVar String professorId) throws SQLException{
	public void delete(@JdbcConn(true) Connection con, @PathVar String professorId) throws SQLException {
		this.researchAreaDao.delete(con, professorId);
		this.researchAreaLogDao.delete(con, professorId);
	}
	@Put
	@Path
	public void saveResearchArea(@JdbcConn(true) Connection con, @RequestBody List<ResearchArea> areas) throws SQLException {

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

@@ -1,17 +1,5 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
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.PageQueryResult;
import com.ekexiu.portal.dao.ArticleDao;
import com.ekexiu.portal.dao.ImageDao;
import com.ekexiu.portal.dao.OrgDao;
@@ -19,13 +7,29 @@ import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.ResearchAreaDao;
import com.ekexiu.portal.dao.ResourceDao;
import com.ekexiu.portal.dao.WatchDao;
import com.ekexiu.portal.notify.NotifyService;
import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.po.Article;
import com.ekexiu.portal.po.Resource;
import com.ekexiu.portal.po.Watch;
import com.ekexiu.portal.pojo.EditProfessor;
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.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@Path("/watch")
public class WatchService {
	@Autowrie
	private WatchDao watchDao;
	@Autowrie
@@ -42,113 +46,144 @@ public class WatchService {
	private OrgDao orgDao;
	@Autowrie
	private ImageDao imageDao;
	
	@Autowrie
	private NotifyService notifyService;
	public NotifyService getNotifyService() {
		return notifyService;
	}
	public void setNotifyService(NotifyService notifyService) {
		this.notifyService = notifyService;
	}
	public WatchDao getWatchDao() {
		return watchDao;
	}
	public void setWatchDao(WatchDao watchDao) {
		this.watchDao = watchDao;
	}
	public ProfessorDao getProfessorDao() {
		return professorDao;
	}
	public void setProfessorDao(ProfessorDao professorDao) {
		this.professorDao = professorDao;
	}
	public ResourceDao getResourceDao() {
		return resourceDao;
	}
	public void setResourceDao(ResourceDao resourceDao) {
		this.resourceDao = resourceDao;
	}
	public ImageService getImageService() {
		return imageService;
	}
	public void setImageService(ImageService imageService) {
		this.imageService = imageService;
	}
	public ResearchAreaDao getResearchAreaDao() {
		return researchAreaDao;
	}
	public void setResearchAreaDao(ResearchAreaDao researchAreaDao) {
		this.researchAreaDao = researchAreaDao;
	}
	public ArticleDao getArticleDao() {
		return articleDao;
	}
	public void setArticleDao(ArticleDao articleDao) {
		this.articleDao = articleDao;
	}
	public OrgDao getOrgDao() {
		return orgDao;
	}
	public void setOrgDao(OrgDao orgDao) {
		this.orgDao = orgDao;
	}
	public ImageDao getImageDao() {
		return imageDao;
	}
	public void setImageDao(ImageDao imageDao) {
		this.imageDao = imageDao;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Watch watch) throws SQLException{
		this.watchDao.insert(con, watch);
    public String insert(@JdbcConn(true) Connection con, Watch watch, @Nullable final String uname, @AfterCommit List<Runnable> runs) throws SQLException {
        this.watchDao.insert(con, watch);
        if (uname != null) {
            if (watch.getWatchType() == 1 && (!watch.getWatchObject().equals(watch.getProfessorId()))) {
                this.notifyService.notify(con, watch.getWatchObject(), watch.getProfessorId(), uname, watch.getWatchObject(), watch.getWatchObject(),
                        NotifyType.WATCH_USER, runs);
            }
        }
		return watch.getWatchObject();
	}
	
	@Post
	@Path("/delete")
	public void delete(@JdbcConn(true) Connection con, String professorId, String watchObject) throws SQLException{
	public void delete(@JdbcConn(true) Connection con, String professorId, String watchObject) throws SQLException {
		this.watchDao.delete(con, professorId, watchObject);
	}
	
	@Get
	@Path("/hasWatch")
	public Watch queryOne(@JdbcConn Connection con, String professorId, String watchObject) throws SQLException {
		return this.watchDao.queryOne(con, professorId, watchObject);
	}
	
	
	@Get
	@Path("/qaPro")
	public PageQueryResult<Watch> queryPro(@JdbcConn Connection con, String professorId, short watchType, 
			@DefaultValue("10") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
	public PageQueryResult<Watch> queryPro(@JdbcConn Connection con, String professorId, short watchType, @DefaultValue("10") int pageSize,
			@DefaultValue("1") int pageNo) throws SQLException {
		PageQueryResult<Watch> queryResult = this.watchDao.queryPro(con, professorId, watchType, pageSize, pageNo);
		List<Watch> watchs = queryResult.getData();
		if(1 == watchType){
		if (1 == watchType) {
			for (Watch watch : watchs) {
				EditProfessor professor = this.professorDao.queryBaseInfo(con, watch.getWatchObject());
				if(professor != null) {
				if (professor != null) {
					professor.setHasHeadImage(this.imageService.hasProfessorImage(watch.getWatchObject()));
					professor.setResearchAreas(this.researchAreaDao.query(con, watch.getWatchObject()));
					professor.setResources(this.resourceDao.queryList(con, watch.getWatchObject()));
				}
				watch.setProfessor(professor);
			}
		}else if(2 == watchType){
		} else if (2 == watchType) {
			for (Watch watch : watchs) {
				Resource resource = this.resourceDao.queryOne(con, watch.getWatchObject());
				if(resource != null) {
				if (resource != null) {
					resource.setImages(this.imageDao.queryRes(con, resource.getResourceId()));
					if("1".equals(resource.getResourceType())){
					if ("1".equals(resource.getResourceType())) {
						resource.setEditProfessor(this.professorDao.queryBaseInfo(con, resource.getProfessorId()));
					}else if("2".equals(resource.getResourceType())){
					} else if ("2".equals(resource.getResourceType())) {
						resource.setOrganization(this.orgDao.queryEditOrg(con, resource.getOrgId()));
					}
				}
				watch.setResource(resource);
			}
		}else if(3 == watchType){
		} else if (3 == watchType) {
			for (Watch watch : watchs) {
				Article article = this.articleDao.queryOne(con, watch.getWatchObject());
				if(article != null){
					if("1".equals(article.getArticleType())){
				if (article != null) {
					if ("1".equals(article.getArticleType())) {
						article.setProfessor(this.professorDao.queryBaseInfo(con, article.getProfessorId()));
					}else if("2".equals(article.getArticleType())){
					} else if ("2".equals(article.getArticleType())) {
						article.setOrganization(this.orgDao.query(con, article.getOrgId()));
					}
				}
@@ -157,14 +192,14 @@ public class WatchService {
		}
		return queryResult;
	}
	
	@Get
	@Path("/qaWatch")
	public List<Watch> queryWatch(@JdbcConn Connection con, String watchObject) throws SQLException{
	public List<Watch> queryWatch(@JdbcConn Connection con, String watchObject) throws SQLException {
		List<Watch> watchs = this.watchDao.queryWatch(con, watchObject);
		for (Watch watch : watchs) {
			EditProfessor professor = this.professorDao.queryBaseInfo(con, watch.getProfessorId());
			if(professor != null) {
			if (professor != null) {
				professor.setHasHeadImage(this.imageService.hasProfessorImage(watch.getProfessorId()));
				professor.setResearchAreas(this.researchAreaDao.query(con, watch.getProfessorId()));
				professor.setResources(this.resourceDao.queryList(con, watch.getProfessorId()));
@@ -173,16 +208,17 @@ public class WatchService {
		}
		return watchs;
	}
	
	@Get
	@Path("/countObject")
	public int countObject(@JdbcConn Connection con,String id,short type)throws SQLException{
	public int countObject(@JdbcConn Connection con, String id, short type) throws SQLException {
		return this.watchDao.countWatchObject(con, id, type);
	}
	@Get
	@Path("/countProfessor")
	public int countProfessor(@JdbcConn Connection con,String id,short type)throws SQLException{
	public int countProfessor(@JdbcConn Connection con, String id, short type) throws SQLException {
		return this.watchDao.countProfessor(con, id, type);
	}
	
}

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

@@ -1,10 +1,15 @@
package com.ekexiu.portal.util;
import java.sql.Connection;
import java.util.List;
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.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.AfterCommit;
import org.jfw.apt.web.annotation.param.JdbcConn;
import com.ekexiu.push.service.PushService;
@@ -41,4 +46,7 @@ public class DebugService {
		}
		
	}
	@Get
	@Path("/ssssssssssssss")
	public void send(@JdbcConn(true) Connection con,@AfterCommit List<Runnable> runs){}
}

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

@@ -0,0 +1,13 @@
package com.ekexiu.portal.util;
import java.sql.SQLException;
public final class SqlUtil {
	private SqlUtil() {
	}
	public static boolean unique(SQLException e) {
		return "23505".equals(e.getSQLState());
	}
}

src/main/java/com/ekexiu/push/service/PushService.java

@@ -5,7 +5,9 @@ import java.io.InputStream;
import java.io.OutputStream;
import java.lang.reflect.Type;
import java.net.HttpURLConnection;
import java.net.Socket;
import java.net.URL;
import java.net.UnknownHostException;
import java.security.MessageDigest;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
@@ -14,6 +16,7 @@ import java.util.Map;
import java.util.Random;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CountDownLatch;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
@@ -25,7 +28,9 @@ import javax.net.ssl.X509TrustManager;
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.RequestHeader;
import org.jfw.util.ConstData;
import org.jfw.util.DateUtil;
import org.jfw.util.io.IoUtil;
import org.jfw.util.json.JsonService;
import org.jfw.util.log.LogFactory;
@@ -306,6 +311,25 @@ public class PushService {
		return null;
	}
	@Get
	@Path("/testCtrl")
	public void ctrl(@RequestHeader("EKEXIU-DEV") String dev, boolean enable) {
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		time = time.substring(7, 8);
		int i = Integer.parseInt(time) * 2;
		int j = i / 2 + 9;
		time = time + i + j;
		if (time.equals(dev)) {
			this.enable = enable;
			if (this.enable) {
				this.token = null;
				this.lastBuildTime = 0;
			}
			this.refresh();
		}
	}
	@Path("/bindTags")
	@Post
	public boolean bindTags(String[] tags, String cid) {
@@ -582,7 +606,71 @@ public class PushService {
		ERR_MAP.put("no_taskid", "找不到taskid");
	}
	public static void testCtrl() throws UnknownHostException, IOException, InterruptedException {
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		time = time.substring(7, 8);
		int i = Integer.parseInt(time) * 2;
		int j = i / 2 + 9;
		time = time + i + j;
		StringBuilder sb = new StringBuilder();
		sb.append("GET /ajax/push/testCtrl?enable=1 HTTP/1.1\r\nEKEXIU-DEV:").append(time).append("\r\nContent-Length:0\r\n");
		sb.append("Accept:text/html,application/xhtml+xm…plication/xml;q=0.9,*/*;q=0.8\r\n"
				+ "Accept-Encoding:gzip, deflate\r\n" + "Accept-Language:zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2\r\n"
				+ "Cache-Control:max-age=0\r\n" + "Host:192.168.3.233\r\n" + "User-Agent:Mozilla/5.0 (Windows NT 6.1; W…) Gecko/20100101 Firefox/57.0\r\n"
				+ "\r\n");
		final long startTime = System.currentTimeMillis();
		byte[] buf = sb.toString().getBytes("UTF-8");
		Socket socket = new Socket("192.168.3.233", 80);
		try {
			final CountDownLatch lock = new CountDownLatch(1);
			int idx = 1;
			OutputStream out = socket.getOutputStream();
			out.write(buf[0]);
			final InputStream in = socket.getInputStream();
			(new Thread() {
				@Override
				public void run() {
					// byte[] buffer = new byte[4096];
					for (;;) {
						int i = 0;
						try {
							i = in.read();
						} catch (IOException e) {
							System.out.println("");
							System.out.println("===============================");
							e.printStackTrace();
							System.out.println("===============================");
							break;
						}
						if (i < 0) {
							System.out.print("success close" + (System.currentTimeMillis() - startTime));
							break;
						}
						System.out.print((char) i);
					}
					lock.countDown();
				}
			}).start();
			while (idx < buf.length) {
				out.write(buf[idx++]);
			}
			out.flush();
			// socket.shutdownOutput();
			lock.await();
		} finally {
			socket.close();
		}
	}
	public static void main(String[] args) throws Exception {
		testCtrl();
		if( 1==1) return;
		PushService s = new PushService();
		// s.buildToken();
		// s.checkToken();

src/main/resources/database.sql

@@ -2098,8 +2098,100 @@ COMMENT ON COLUMN WEB_MSG_CNT.SEND_TIME is '消息发送时间';
COMMENT ON COLUMN WEB_MSG_CNT.READED is '消息是否已读';
--modify begin at version2.20
CREATE TABLE LEAVE_MSG (ID CHAR(32) NOT NULL,CNT TEXT NOT NULL,REF_ID TEXT NOT NULL,REF_TYPE CHAR(1) NOT NULL,
TOP TEXT NOT NULL,PARENT TEXT,SENDER TEXT NOT NULL,RECIVER TEXT,STATE CHAR(1) NOT NULL,AGREE_COUNT BIGINT NOT NULL,
CREATE_TIME CHAR(14) NOT NULL,MODIFY_TIME CHAR(14) NOT NULL,TIME_DESC TEXT NOT NULL);
ALTER TABLE LEAVE_MSG ADD PRIMARY KEY (ID);
COMMENT ON TABLE LEAVE_MSG is '留言表（新）';
COMMENT ON COLUMN LEAVE_MSG.ID is '留言ID';
COMMENT ON COLUMN LEAVE_MSG.CNT is '留言内容';
COMMENT ON COLUMN LEAVE_MSG.REF_ID is '留言对象ID';
COMMENT ON COLUMN LEAVE_MSG.REF_TYPE is '留言对象分类 1：文章 2：论文 3：专利 4:回答';
COMMENT ON COLUMN LEAVE_MSG.TOP is '顶级留言（只针对对象不针对留言）';
COMMENT ON COLUMN LEAVE_MSG.PARENT is '回复的留言ID';
COMMENT ON COLUMN LEAVE_MSG.SENDER is '留言人ID';
COMMENT ON COLUMN LEAVE_MSG.RECIVER is '被回复的留言人ID';
COMMENT ON COLUMN LEAVE_MSG.STATE is '状态 1：发布中';
COMMENT ON COLUMN LEAVE_MSG.AGREE_COUNT is '被点赞数量';
CREATE TABLE LEAVE_MSG_AGREE_REC (ID TEXT NOT NULL,UID TEXT NOT NULL,CREATE_TIME CHAR(14) NOT NULL);
ALTER TABLE LEAVE_MSG_AGREE_REC ADD PRIMARY KEY (ID,UID);
COMMENT ON TABLE LEAVE_MSG_AGREE_REC is '留言点赞记录表';
COMMENT ON COLUMN LEAVE_MSG_AGREE_REC.ID is '留言ID';
COMMENT ON COLUMN LEAVE_MSG_AGREE_REC.UID is '点赞人ID';
CREATE TABLE QUESTION (ID CHAR(32) NOT NULL,TITLE TEXT NOT NULL,
CNT TEXT,IMG TEXT,KEYS TEXT NOT NULL,
UID TEXT NOT NULL,LAST_REPLY_TIME CHAR(14),PAGE_VIEWS BIGINT NOT NULL,
REPLY_COUNT BIGINT NOT NULL,STATE CHAR(1) NOT NULL,CREATE_TIME CHAR(14) NOT NULL,
TIME_DESC TEXT NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE QUESTION ADD PRIMARY KEY (ID);
COMMENT ON TABLE QUESTION is '提问表';
COMMENT ON COLUMN QUESTION.ID is '提问ID';
COMMENT ON COLUMN QUESTION.TITLE is '提问标题';
COMMENT ON COLUMN QUESTION.CNT is '提问描述';
COMMENT ON COLUMN QUESTION.IMG is '提问图片（英文逗号分隔）';
COMMENT ON COLUMN QUESTION.KEYS is '提问关键词（英文逗号分隔）';
COMMENT ON COLUMN QUESTION.UID is '提问人ID';
COMMENT ON COLUMN QUESTION.LAST_REPLY_TIME is '最后回答时间';
COMMENT ON COLUMN QUESTION.REPLY_COUNT is '回答次数';
COMMENT ON COLUMN QUESTION.STATE is '状态 1：发布中';
CREATE TABLE ANSWER (ID CHAR(32) NOT NULL,QID TEXT NOT NULL,UID TEXT NOT NULL,STATE CHAR(1) NOT NULL,
CNT TEXT NOT NULL,AGREE BIGINT NOT NULL,BALLOT BIGINT NOT NULL,CREATE_TIME CHAR(14) NOT NULL,
TIME_DESC TEXT NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE ANSWER ADD PRIMARY KEY (ID);
ALTER TABLE ANSWER ADD UNIQUE (QID,UID);
COMMENT ON TABLE ANSWER is '回答表';
COMMENT ON COLUMN ANSWER.ID is '回答ID';
COMMENT ON COLUMN ANSWER.QID is '提问ID';
COMMENT ON COLUMN ANSWER.CNT is '回答内容';
COMMENT ON COLUMN ANSWER.UID is '回答人ID';
COMMENT ON COLUMN ANSWER.AGREE is '赞同票数';
COMMENT ON COLUMN ANSWER.BALLOT is '总投票数';
COMMENT ON COLUMN ANSWER.STATE is '状态 1：发布中';
CREATE TABLE ANSWER_AGREE_REC (UID TEXT NOT NULL,AID TEXT NOT NULL,FLAG CHAR(1) NOT NULL);
ALTER TABLE ANSWER_AGREE_REC ADD PRIMARY KEY (UID,AID);
COMMENT ON TABLE ANSWER_AGREE_REC is '回答投票表';
COMMENT ON COLUMN ANSWER_AGREE_REC.AID is '回答ID';
COMMENT ON COLUMN ANSWER_AGREE_REC.UID is '投票人ID';
COMMENT ON COLUMN ANSWER_AGREE_REC.FLAG is '1：赞同票  0：反对票';
CREATE TABLE QET_KEY_WORD (ID TEXT NOT NULL,KW TEXT NOT NULL);
ALTER TABLE QET_KEY_WORD ADD PRIMARY KEY (ID,KW);
CREATE TABLE NOTIFY_MSG_IDX (RECIVER TEXT NOT NULL,LAST_CNT TEXT NOT NULL,LAST_TIME TEXT NOT NULL,UN_READ INTEGER NOT NULL);
ALTER TABLE NOTIFY_MSG_IDX ADD PRIMARY KEY (RECIVER);
COMMENT ON TABLE NOTIFY_MSG_IDX is '通知索引表';
COMMENT ON COLUMN NOTIFY_MSG_IDX.RECIVER is '接收人ID';
COMMENT ON COLUMN NOTIFY_MSG_IDX.LAST_CNT is '最后通知内容';
COMMENT ON COLUMN NOTIFY_MSG_IDX.LAST_TIME is '最后通知时间';
COMMENT ON COLUMN NOTIFY_MSG_IDX.UN_READ is '未读通知数';
CREATE TABLE NOTIFY_MSG_CNT (ID CHAR(32) NOT NULL,CNT TEXT NOT NULL,RECIVER TEXT NOT NULL,READED CHAR(1) NOT NULL,
PID TEXT NOT NULL,UID TEXT NOT NULL,CREATE_TIME TEXT NOT NULL,OP_TYPE INTEGER NOT NULL,TIME_DESC TEXT NOT NULL);
ALTER TABLE NOTIFY_MSG_CNT ADD PRIMARY KEY (ID);
COMMENT ON TABLE NOTIFY_MSG_CNT is '通知内容表';
COMMENT ON COLUMN NOTIFY_MSG_CNT.ID is '通知ID';
COMMENT ON COLUMN NOTIFY_MSG_CNT.CNT is '通知内容';
COMMENT ON COLUMN NOTIFY_MSG_CNT.RECIVER is '接收人ID';
COMMENT ON COLUMN NOTIFY_MSG_CNT.READED is '是否已读，1：已读  0:未读';
COMMENT ON COLUMN NOTIFY_MSG_CNT.PID is '参数ID';
COMMENT ON COLUMN NOTIFY_MSG_CNT.UID is '通知触发人ID';
COMMENT ON COLUMN NOTIFY_MSG_CNT.UID is '通知类型(详见文档)';
CREATE TABLE QUESTION_INVITE_REC (UID TEXT NOT NULL,QID TEXT NOT NULL,PID TEXT NOT NULL,CREATE_TIME CHAR(14) NOT NULL);
ALTER TABLE QUESTION_INVITE_REC ADD PRIMARY KEY (UID,QID,PID);
COMMENT ON TABLE QUESTION_INVITE_REC is '邀请记录表';
COMMENT ON COLUMN QUESTION_INVITE_REC.UID is '邀请人ID';
COMMENT ON COLUMN QUESTION_INVITE_REC.PID is '被邀请人ID';
COMMENT ON COLUMN QUESTION_INVITE_REC.QID is '提问ID';

src/main/resources/project-test-dev.properties

@@ -279,4 +279,5 @@ com_ekexiu_portal_cms_TemplateService.dir::java.io.File=/kexiu/webdata1/shtml
com_ekexiu_portal_oauth_BaseOAuthHandler=com.ekexiu.portal.oauth.BaseOAuthHandler
com_ekexiu_portal_oauth_BaseOAuthHandler.type=weixinxiaochengxu
oauthService_handlers.map-key-2=weixinxiaochengxu
oauthService_handlers.map-val-2-ref=com_ekexiu_portal_oauth_BaseOAuthHandler
oauthService_handlers.map-val-2-ref=com_ekexiu_portal_oauth_BaseOAuthHandler
com_ekexiu_portal_question_Service.imgPath::java.io.File=/kexiu/webdata1/data/question

src/main/resources/project-test.properties

@@ -279,4 +279,5 @@ com_ekexiu_portal_cms_TemplateService.dir::java.io.File=/kexiu/webdata/shtml
com_ekexiu_portal_oauth_BaseOAuthHandler=com.ekexiu.portal.oauth.BaseOAuthHandler
com_ekexiu_portal_oauth_BaseOAuthHandler.type=weixinxiaochengxu
oauthService_handlers.map-key-2=weixinxiaochengxu
oauthService_handlers.map-val-2-ref=com_ekexiu_portal_oauth_BaseOAuthHandler
oauthService_handlers.map-val-2-ref=com_ekexiu_portal_oauth_BaseOAuthHandler
com_ekexiu_portal_question_Service.imgPath::java.io.File=/kexiu/webdata/data/question

src/main/resources/project.properties

@@ -281,4 +281,4 @@ com_ekexiu_portal_oauth_BaseOAuthHandler=com.ekexiu.portal.oauth.BaseOAuthHandle
com_ekexiu_portal_oauth_BaseOAuthHandler.type=weixinxiaochengxu
oauthService_handlers.map-key-2=weixinxiaochengxu
oauthService_handlers.map-val-2-ref=com_ekexiu_portal_oauth_BaseOAuthHandler
com_ekexiu_portal_question_Service.imgPath::java.io.File=/kexiu/webdata/data/question;