02

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

@@ -166,6 +166,9 @@ public interface QuestionDao {
	
	@SelectOne
	@Nullable
	@Where("FLAG='1'")
	AnswerAgreeRec isAgree(Connection con,String uid,String aid)throws SQLException;
	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;
}

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

@@ -630,11 +630,43 @@ public class Service {
		}
		notifyService.notify(con, a.getUid(), uid, uname, a.getId(), q.getTitle(), NotifyType.ACCEPT_ANSWER, runs);
	}
	
	
	@Post
	@Path("/answer/aagree/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 boolean isAgree(@JdbcConn Connection con, String aid, String uid) throws SQLException {
		return null != questionDao.isAgree(con, uid, aid);
	public AnswerAgreeRec isAgree(@JdbcConn Connection con, String aid, String uid) throws SQLException {
		return questionDao.queryAswerAgreRec(con, uid, aid);
	}
	@Get
@@ -658,8 +690,8 @@ public class Service {
	}
	@Post
	@Path("/answer/unAgree")
	public void unAgree(@JdbcConn(true) Connection con, String id, String uid, String uname, @AfterCommit List<Runnable> runs)
	@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);
@@ -682,16 +714,9 @@ public class Service {
			if (questionDao.unAgree(con, uid, id) > 0) {
				questionDao.update(con, id, -1, 0);
			} else {
				throw new JfwBaseException(50001, "duplicate answer unagree");
				throw new JfwBaseException(50001, "duplicate answer oppose");
			}
		}
		runs.add(new Runnable() {
			@Override
			public void run() {
				// TODO send notify
			}
		});
	}
	public QetKeyWord[] build(String id, List<String> ss) {