11

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

@@ -0,0 +1,150 @@
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;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Table
public class LeaveMsg implements CreateTimeSupported,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  acceptCount;
	
	/**
	 * 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;
	}
	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 getAcceptCount() {
		return acceptCount;
	}
	public void setAcceptCount(long acceptCount) {
		this.acceptCount = acceptCount;
	}
}

src/main/java/com/ekexiu/portal/leavemsg/LeaveMsgApRec.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 LeaveMsgApRec  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.annotation.dao.param.GtEq;
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("ACCEPT_COUNT = ACCEPT_COUNT + 1")
	@IncludeFixSet
	int incAccept(Connection con, String id) throws SQLException;
	@LimitSelect
	@Where("STATE='1'")
	@OrderBy("ORDER BY GREATE_TIME ASC,ID ASC")
	List<LeaveMsg> query(Connection con, String refId, String refType, @GtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@Nullable
	@SelectOne
	LeaveMsg query(Connection con, String id) throws SQLException;
	@Insert
	int insert(Connection con, LeaveMsgApRec rec) throws SQLException;
	@Nullable
	@SelectOne
	LeaveMsgApRec queryAcceptRec(Connection con, String id, String uid) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY GREATE_TIME ASC,ID ASC")
	List<LeaveMsg> queryWithParent(Connection con, String parent, @GtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY GREATE_TIME ASC,ID 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,
			@GtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@QueryVal
	@From(LeaveMsg.class)
	@DefaultValue("0")
	@Column(value="COUNT(ID)",handlerClass=IntHandler.class)
	int queryCount(Connection con,String refType,String refId) throws SQLException;
	
	
}

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

@@ -0,0 +1,315 @@
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.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.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
@Path("/leavemsg")
public class Service {
	@Autowrie
	private LeaveMsgDao leaveMsgDao;
	public LeaveMsgDao getLeaveMsgDao() {
		return leaveMsgDao;
	}
	public void setLeaveMsgDao(LeaveMsgDao leaveMsgDao) {
		this.leaveMsgDao = leaveMsgDao;
	}
	public String getSubjectTitle(Connection con, String type, String id) throws SQLException {
		return null;
	}
	/**
	 * 新增一顶级留言
	 * 
	 * @param con
	 * @param msg
	 *            cnt
	 * @param title
	 *            文章标题 论文标题 专利标题 提问
	 * @param uname
	 *            发送人名称
	 * @param runs
	 * @return
	 * @throws SQLException
	 */
	@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 title, String uname, @AfterCommit List<Runnable> runs) throws SQLException {
		String id = StringUtil.buildUUID();
		msg.setId(id);
		msg.setTop(id);
		msg.setState("1");
		msg.setParent(null);
		msg.setAcceptCount(0);
		runs.add(new Runnable() {
			@Override
			public void run() {
				// TODO: send notify
			}
		});
		leaveMsgDao.insert(con, msg);
		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, @Nullable String title, 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.setAcceptCount(0);
		if (title == null) {
			title = this.getSubjectTitle(con, msg.getRefType(), msg.getRefId());
			if (title == null || title.isEmpty()) {
				title = "<<丢失的数据>>";
			}
		}
		runs.add(new Runnable() {
			@Override
			public void run() {
				// TODO: send notify
			}
		});
		leaveMsgDao.insert(con, msg);
		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 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("/accept")
	public void accept(@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");
		}
		LeaveMsgApRec lmar = new LeaveMsgApRec();
		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 accept");
			}
			throw e;
		}
		if (leaveMsgDao.incAccept(con, id) > 0) {
			runs.add(new Runnable() {
				@Override
				public void run() {
					// TODO: send notify
				}
			});
		}
	}
	/**
	 * 是否对指定留言点过赞
	 * 
	 * @param con
	 * @param id
	 *            留言 ID
	 * @param uid
	 *            用户ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/accept")
	public boolean accept(@JdbcConn Connection con, String id, String uid) throws SQLException {
		return null != leaveMsgDao.queryAcceptRec(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", "0", Integer.MAX_VALUE);
			ret.add(0, msg);
		} else {
			ret = leaveMsgDao.queryWithTop(con, msg.getId(), msg.getSender(), msg.getReciver(), "0", "0", Integer.MAX_VALUE);
		}
		return ret;
	}
}

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

@@ -0,0 +1,119 @@
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;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Uniques({@Unique(clolumns={"qid","uid"},name="UNI_ANSWER_QID_UID")})
@Table
public class Answer  implements CreateTimeSupported,ModifyTimeSupported{
	private String id;
	private String qid;
	private String uid;
	private String state;
	private String cnt;
	
	private long accept;
	private long  ballot;
	private String createTime;
	private String modifyTime;
	/**
	 * 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 getAccept() {
		return accept;
	}
	public void setAccept(long accept) {
		this.accept = accept;
	}
	/**
	 * 总数投票数
	 * @return
	 */
	@Column(DE.long_de)
	public long getBallot() {
		return ballot;
	}
	public void setBallot(long ballot) {
		this.ballot = ballot;
	}
	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;
	}
	
	
	
	
	
}

src/main/java/com/ekexiu/portal/question/AnswerAcceptRec.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 AnswerAcceptRec{
	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,136 @@
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.CreateTimeSupported;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Table
public class Question implements CreateTimeSupported,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;
	
	/**
	 * 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;
	}
	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,108 @@
package com.ekexiu.portal.question;
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.Batch;
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.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.GreaterThan;
import org.jfw.apt.orm.annotation.dao.param.In;
import org.jfw.apt.orm.annotation.dao.param.LtEq;
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.IntHandler;
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;
	@Insert
	@Batch
	int[] insert(Connection con, QetKeyWord[] kws) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	List<Question> query(Connection con, @Nullable String state, String uid, @LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@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,
			@LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@SelectOne
	@Nullable
	Question query(Connection con, String id) throws SQLException;
	@SelectList
	List<Question> query(Connection con, @In String[] id) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> answerSelf(Connection con, String uid, @LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@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,
			@LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	List<Answer> byQes(Connection con, String qid, @LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@LimitQuery
	@OrderBy("ORDER BY SCORE DESC,ID ASC")
	List<SortedAnswwer> byQes(Connection con, String qid, @SqlColumn(handlerClass = IntHandler.class, value = { "10000 * ACCEPT / BALLOT <= ?  " }) int score, @GreaterThan String id, int rows) throws SQLException;
	@Insert
	int insert(Connection con,AnswerAcceptRec aar)throws SQLException;
	@UpdateWith
	@From(AnswerAcceptRec.class)
	@Where("FLAG<>'1'")
	@SetSentence("FLAG='1'")
	int accept(Connection con,String uid,String aid)throws SQLException;
	@UpdateWith
	@From(AnswerAcceptRec.class)
	@Where("FLAG='1'")
	@SetSentence("FLAG='0'")
	int unAccept(Connection con,String uid,String aid)throws SQLException;
	
	@UpdateWith
	@From(Answer.class)
	int update(Connection con,String id, @Set( " = ACCEPT +?" ) long accept,@Set("=BALLOT+?") long ballot)throws SQLException;
	
	
	@Insert
	int insert(Connection con, Answer answer) throws SQLException;
	@UpdateWith
	@From(Answer.class)
	@IncludeFixSet
	int updateAnswer(Connection con, String id, @Set String cnt) throws SQLException;
}

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

@@ -0,0 +1,617 @@
package com.ekexiu.portal.question;
import java.io.File;
import java.io.FileOutputStream;
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.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.ListUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
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.util.SqlUtil;
@Path("/question")
public class Service {
	private static final AtomicInteger FN_IDX = new AtomicInteger(1);
	@Autowrie
	private QuestionDao questionDao;
	private File imgPath;
	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();
		}
	}
	/**
	 * 新增一提问
	 * 
	 * @param con
	 * @param q
	 *            title 标题 ，cnt 描述 img 图片 以英文逗号分隔， keys 关键字 以英文逗号分隔 ，uid 用户ID
	 * @return
	 * @throws SQLException
	 */
	@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 {
		String id = StringUtil.buildUUID();
		q.setId(id);
		q.setReplyCount(0);
		q.setState("1");
		List<String> kws = ListUtil.splitTrimExcludeEmpty(q.getKeys(), ',');
		if (kws.isEmpty())
			throw new IllegalArgumentException("param keys invalid");
		questionDao.insert(con, q);
		questionDao.insert(con, build(id, kws));
		return id;
	}
	/**
	 * 默认的邀请专家
	 * 
	 * @param con
	 * @param id
	 *            提问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 @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 kw in (select kw from pro_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, id);
						ps.setInt(2, count);
						ps.setString(3, pid);
						ps.setInt(4, rows);
					}
				});
	}
	/**
	 * 邀请专家回答提问
	 * 
	 * @param con
	 * @param id
	 *            提问id
	 * @param pid
	 *            专家id(被邀请人)
	 * @param uid
	 *            操作人（邀请人
	 * @param uname
	 *            操作人（邀请人）姓名
	 * @return
	 * @throws SQLException
	 * @throws JfwBaseException
	 */
	@Post
	@Path("/invite")
	public boolean invite(@JdbcConn Connection con, String id, String pid, String uid, String uname) throws SQLException, JfwBaseException {
		Question q = questionDao.query(con, id);
		if (q == null) {
			throw new JfwBaseException(50000, "question[" + id + "] not found");
		}
		// TODO: send notify
		return true;
	}
	/**
	 * 回答一个提问
	 * 
	 * @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) throws SQLException, JfwBaseException {
		Question q = questionDao.query(con, qid);
		if (q == null) {
			throw new JfwBaseException(50000, "question[" + qid + "] not found");
		}
		String id = StringUtil.buildUUID();
		Answer a = new Answer();
		a.setId(id);
		a.setAccept(0);
		a.setBallot(0);
		a.setCnt(cnt);
		a.setQid(qid);
		a.setState("1");
		a.setUid(uid);
		try {
			questionDao.insert(con, a);
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				throw new JfwBaseException(50001, "duplicate answer");
			}
			throw e;
		}
		return id;
	}
	/**
	 * 修改一个回答
	 * 
	 * @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> queryOne(@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("\"0\"") 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("\"0\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.query(con, "1", uid, 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("/watch")
	public List<Question> watch(@JdbcConn Connection con, String uid, @DefaultValue("\"0\"") 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/my")
	public List<Answer> answerSelf(@JdbcConn Connection con, String uid, @DefaultValue("\"0\"") 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/my")
	public List<Answer> answerWatch(@JdbcConn Connection con, String uid, @DefaultValue("\"0\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.watchAnswer(con, uid, 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("\"0\"") 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("100000") int score, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.byQes(con, qid, score, id, rows);
	}
	/**
	 * 我的回答总点赞数
	 * 
	 * @param con
	 * @param id
	 *            用户ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/answer/my/accept/count")
	public int queryCountWithMyAnswer(@JdbcConn Connection con, final String id) throws SQLException {
		return JdbcUtil.queryInt(con, "SELECT COUNT(ACCEPT) FROM ANSWER WHERE UID=?", new PreparedStatementConfig() {
			@Override
			public void config(PreparedStatement ps) throws SQLException {
				ps.setString(1, id);
			}
		}, 0);
	}
	
	@Post
	@Path("/answer/accept")
	public void accept(@JdbcConn(true) Connection con,String id,String uid,String uname,@AfterCommit List<Runnable> runs)throws SQLException, JfwBaseException{
		AnswerAcceptRec aar = new AnswerAcceptRec();
		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();
			}
			throw e;
		}
		if(inserted){
			questionDao.update(con, id, 1, 1);
		}else{
			if(questionDao.accept(con, uid, id) >0){
				questionDao.update(con,id,1,0);
			}else{
				throw new JfwBaseException(50001,"duplicate answer accept");
			}
			
		}
		runs.add(new Runnable(){
			@Override
			public void run() {
				// TODO send notify
			}});
	}
	@Post
	@Path("/answer/unAccept")
	public void unAccept(@JdbcConn(true) Connection con,String id,String uid,String uname,@AfterCommit List<Runnable> runs)throws SQLException, JfwBaseException{
		AnswerAcceptRec aar = new AnswerAcceptRec();
		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();
			}
			throw e;
		}
		if(inserted){
			questionDao.update(con, id, 0, 1);
		}else{
			if(questionDao.unAccept(con, uid, id) >0){
				questionDao.update(con,id,-1,0);
			}else{
				throw new JfwBaseException(50001,"duplicate answer unaccept");
			}
		}
		runs.add(new Runnable(){
			@Override
			public void run() {
				// TODO send notify
			}});
	}
	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,20 @@
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;
@ExtendTable
public class SortedAnswwer extends Answer {
	private long score ;
	@CalcColumn(nullable=false,handlerClass=LongHandler.class,column="10000 * accept / ballot SCORE")
	public long getScore() {
		return score;
	}
	public void setScore(long score) {
		this.score = score;
	}
   
}

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/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;