11

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

@@ -123,4 +123,9 @@ public interface QuestionDao {
	
	@SelectList
	List<QuestionInviteRec> queryInviteRec(Connection con,String qid,String uid,@In String[] pid)throws SQLException;
	
	@SelectOne
	@Nullable
	@Where("FLAG='1'")
	AnswerAgreeRec isAgree(Connection con,String uid,String aid)throws SQLException;
}

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

@@ -158,7 +158,7 @@ public class Service {
	 * @param id
	 *            提问ID
	 * @param uid
	 * 			  本人ID
	 *            本人ID
	 * @param count
	 *            limit 查询 返回最后一条的 kws ,首次不传
	 * @param pid
@@ -170,14 +170,14 @@ public class Service {
	 */
	@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,
	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(1, uid);
						ps.setString(2, id);
						ps.setInt(3, count);
						ps.setString(4, pid);
@@ -204,32 +204,32 @@ public class Service {
	 */
	@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 {
	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");
			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)){
		try {
			questionDao.insert(con, rec);
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				throw new JfwBaseException(50001, "duplicate invite");
			}
			throw e;
		}
		
		
		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{
	public List<QuestionInviteRec> queryInviteRec(@JdbcConn Connection con, String uid, String qid, String[] pid) throws SQLException {
		return questionDao.queryInviteRec(con, qid, uid, pid);
	}
@@ -278,16 +278,17 @@ public class Service {
		notifyService.notify(con, q.getUid(), uid, uname, qid, q.getTitle(), NotifyType.ANSWER_QUESTION, runs);
		return id;
	}
	@Get
	@Path("/answer")
	public Answer answer(@JdbcConn Connection con,String id)throws SQLException{
	public Answer answer(@JdbcConn Connection con, String id) throws SQLException {
		return questionDao.queryAnswer(con, id);
	}
	
	@Get
	@Path("/answer/exists")
	public boolean existsAnswer(@JdbcConn Connection con,String uid,String qid)throws SQLException{
		return null!=questionDao.answer(con, uid, qid);
	public boolean existsAnswer(@JdbcConn Connection con, String uid, String qid) throws SQLException {
		return null != questionDao.answer(con, uid, qid);
	}
	/**
@@ -340,7 +341,7 @@ public class Service {
	@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);
		return questionDao.query(con, "1", null, time + id, rows);
	}
	/**
@@ -362,7 +363,7 @@ public class Service {
	@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);
		return questionDao.query(con, "1", uid, time + id, rows);
	}
	/**
@@ -384,7 +385,7 @@ public class Service {
	@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);
		return questionDao.watch(con, uid, time + id, rows);
	}
	/**
@@ -406,7 +407,7 @@ public class Service {
	@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);
		return questionDao.answerSelf(con, uid, time + id, rows);
	}
	/**
@@ -428,13 +429,12 @@ public class Service {
	@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);
		return questionDao.watchAnswer(con, uid, time + id, rows);
	}
	
	/**
	 * 查询所有合法的回答（“发布中”的问题下的“发布中”的回答。);
	 * 按最新回答时间，由新到旧排序
	}）
	 * 查询所有合法的回答（“发布中”的问题下的“发布中”的回答。); 按最新回答时间，由新到旧排序 }）
	 * 
	 * @param con
	 * @param time
	 * @param id
@@ -444,10 +444,11 @@ public class Service {
	 */
	@Get
	@Path("/answer/byTime")
	public List<Answer> answerByTime(@JdbcConn Connection con,@DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
	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);
		return questionDao.answer(con, time + id, rows);
	}
	/**
	 * 指定提问的回答(按最新回答时间，由新到旧排序）
	 * 
@@ -467,7 +468,7 @@ public class Service {
	@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);
		return questionDao.byQes(con, qid, time + id, rows);
	}
	/**
@@ -489,12 +490,10 @@ public class Service {
	@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;
		String p = "000000" + score;
		p = p.substring(p.length() - 5) + id;
		return questionDao.byQesScore(con, qid, p, rows);
	}
	
	
	/**
	 * 我的回答总点赞数
@@ -540,8 +539,9 @@ public class Service {
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				con.rollback();
			} else {
				throw e;
			}
			throw e;
		}
		if (inserted) {
			questionDao.update(con, id, 1, 1);
@@ -555,12 +555,18 @@ public class Service {
		notifyService.notify(con, a.getUid(), uid, uname, a.getId(), q.getTitle(), NotifyType.ACCEPT_ANSWER, runs);
	}
	@Get
	@Path("/answer/agree")
	public boolean isAgree(@JdbcConn Connection con, String aid, String uid) throws SQLException {
		return null != questionDao.isAgree(con, uid, aid);
	}
	@Get
	@Path("/answer/delete")
	public int logicDelete(@JdbcConn(true) Connection con,String id)throws SQLException{
	public int logicDelete(@JdbcConn(true) Connection con, String id) throws SQLException {
		return questionDao.logicDeleteAnswer(con, id);
	}
	
	@Post
	@Path("/answer/unAgree")
	public void unAgree(@JdbcConn(true) Connection con, String id, String uid, String uname, @AfterCommit List<Runnable> runs)
@@ -576,8 +582,9 @@ public class Service {
		} catch (SQLException e) {
			if (SqlUtil.unique(e)) {
				con.rollback();
			} else {
				throw e;
			}
			throw e;
		}
		if (inserted) {
			questionDao.update(con, id, 0, 1);