11

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

@@ -11,7 +11,7 @@ import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Uniques({@Unique(clolumns={"qid","uid"},name="UNI_ANSWER_QID_UID")})
@Table
public class Answer  implements ModifyTimeSupported{
public class Answer {
	private String id;
	private String qid;
	private String uid;
@@ -114,6 +114,7 @@ public class Answer  implements ModifyTimeSupported{
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(DE.text_de)
	public String getModifyTime() {
		return modifyTime;
	}

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

@@ -42,6 +42,13 @@ public interface QuestionDao {
	@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")
@@ -78,6 +85,12 @@ public interface QuestionDao {
	@SetSentence("STATE='0'")
	@Where("STATE ='1'")
	int logicDeleteAnswer(Connection con,String id)throws SQLException;
	
	@UpdateWith
	@From(Answer.class)
	@SetSentence("STATE='1'")
	@Where("STATE <>'1'")
	int unDeleteAnswer(Connection con,String id,String qid)throws SQLException;
	
	@SelectOne
@@ -141,7 +154,8 @@ public interface QuestionDao {
	@UpdateWith
	@From(Answer.class)
	@IncludeFixSet
	@Where("STATE='1'")
	@SetSentence("MODIFY_TIME=TO_CHAR(NOW(),'YYYYMMDDHH24MISS')")
	int updateAnswer(Connection con, String id, @Set String cnt) throws SQLException;
	
	@Insert

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

@@ -5,6 +5,7 @@ import com.ekexiu.portal.notify.NotifyType;
import com.ekexiu.portal.util.SqlUtil;
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;
@@ -147,7 +148,7 @@ public class Service {
		q.setPageViews(0);
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		q.setCreateTime(time);
		q.setTimeDesc(time+id);
		q.setTimeDesc(time + id);
		List<String> kws = ListUtil.splitTrimExcludeEmpty(q.getKeys(), ',');
		if (kws.isEmpty())
			throw new IllegalArgumentException("param keys invalid");
@@ -155,10 +156,10 @@ public class Service {
		questionDao.insert(con, build(id, kws));
		return id;
	}
	
	@Path("/pageViews")
	@Post
	public void incQuestionPageView(@JdbcConn(true) Connection con,String qid)throws SQLException{
	public void incQuestionPageView(@JdbcConn(true) Connection con, String qid) throws SQLException {
		questionDao.incQuestionPageViews(con, qid);
	}
@@ -279,7 +280,8 @@ public class Service {
		a.setState("1");
		a.setUid(uid);
		a.setCreateTime(time);
		a.setTimeDesc(time+id);
		a.setTimeDesc(time + id);
		a.setModifyTime(time);
		try {
			questionDao.insert(con, a);
		} catch (SQLException e) {
@@ -295,8 +297,13 @@ public class Service {
	@Get
	@Path("/answer")
	public Answer answer(@JdbcConn Connection con, String id) throws SQLException {
		return questionDao.queryAnswer(con, id);
	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
@@ -578,13 +585,23 @@ public class Service {
	@Get
	@Path("/answer/delete")
	public int logicDelete(@JdbcConn(true) Connection con, String id) throws SQLException {
		if(questionDao.logicDeleteAnswer(con, id)>0){
		if (questionDao.logicDeleteAnswer(con, id) > 0) {
			questionDao.deccQuestionReply(con, id);
			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/unAgree")
	public void unAgree(@JdbcConn(true) Connection con, String id, String uid, String uname, @AfterCommit List<Runnable> runs)