11

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

@@ -100,4 +100,10 @@ public interface QuestionDao {
	@From(Answer.class)
	@IncludeFixSet
	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;
}

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

@@ -209,9 +209,29 @@ public class Service {
		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;
		}
		
		
		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);
	}
	/**
	 * 回答一个提问

src/main/resources/database.sql

@@ -2185,4 +2185,10 @@ 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';