我的工作台最新回复。

src/main/java/com/ekexiu/portal/dao/TidingsDao.java

@@ -8,8 +8,10 @@ import java.sql.SQLException;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import com.ekexiu.portal.po.Consult;
import com.ekexiu.portal.po.Professor;
import com.ekexiu.portal.po.Tidings;
import com.ekexiu.portal.pojo.EditProfessor;
@DAO
public abstract class TidingsDao {
@@ -48,6 +50,62 @@ public abstract class TidingsDao {
		return count;
	}
	
	/**
	 * 我的工作台最新回复
	 * @param con
	 * @param consultantId 咨询者ID
	 * @return 返回最新回复信息
	 * @throws SQLException
	 */
	public Tidings queryNewReply(Connection con, String consultantId) throws SQLException{
		int _m_1 = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,TIDINGS.CONSULT_ID,TIDINGS.CREATE_TIME,"
        		+ " TIDINGS.READ_STATUS,CONSULT.CONSULT_TITLE,CONSULT.CREATE_TIME,PROFESSOR.NAME,PROFESSOR.OFFICE,"
        		+ " PROFESSOR.DEPARTMENT,PROFESSOR.TITLE,PROFESSOR.ADDRESS,ORGANIZATION.NAME "
        		+ " FROM TIDINGS LEFT JOIN CONSULT ON TIDINGS.CONSULT_ID = CONSULT.CONSULT_ID "
        		+ " LEFT JOIN PROFESSOR ON CONSULT.PROFESSOR_ID = PROFESSOR.ID "
        		+ " LEFT JOIN ORGANIZATION ON PROFESSOR.ORG_ID = ORGANIZATION.ID "
        		+ " WHERE TIDINGS.CREATE_TIME IN "
        		+ " (SELECT MAX(TIDINGS.CREATE_TIME) FROM TIDINGS LEFT JOIN CONSULT ON TIDINGS.CONSULT_ID = CONSULT.CONSULT_ID "
        		+ " AND (TIDINGS.READ_STATUS = 0) AND (CONSULTANT_ID = ?) AND (SENDER_ID != ?)) ";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,consultantId);
            ps.setString(_m_1++,consultantId);
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                	Tidings tidings = new Tidings();
                	tidings.setTidingsId(rs.getString(1));
                	tidings.setTidingsContant(rs.getString(2));
                	EditProfessor professor = new EditProfessor();
                	professor.setId(rs.getString(3));
                	Consult consult = new Consult();
                	consult.setConsultId(rs.getString(4));
                	tidings.setCreateTime(rs.getString(5));
                	tidings.setReadStatus(rs.getShort(6));
                	consult.setConsultTitle(rs.getString(7));
                	consult.setCreateTime(rs.getString(8));
                	professor.setName(rs.getString(9));
                	professor.setOffice(rs.getString(10));
                	professor.setDepartment(rs.getString(11));
                	professor.setTitle(rs.getString(12));
                	professor.setAddress(rs.getString(13));
                	professor.setOrgName(rs.getString(14));
                	tidings.setProfessor(professor);
                	tidings.setConsult(consult);
                	return tidings;
                }else{
                    return null;
                }
            }finally{
                try{rs.close();}catch(Exception _m_8){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_9){}
        }
	}
	
	/**
	 * 咨询页面显示最后回复信息
	 * @param con
@@ -58,7 +116,8 @@ public abstract class TidingsDao {
	 */
	public Tidings queryLastRevovery(Connection con,String consultId,String senderId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,CONSULT_ID,CREATE_TIME FROM TIDINGS WHERE CREATE_TIME IN (SELECT MAX(CREATE_TIME) FROM TIDINGS WHERE (CONSULT_ID = ?) AND (SENDER_ID != ?)) ";
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,CONSULT_ID,CREATE_TIME FROM TIDINGS "
        		+ " WHERE CREATE_TIME IN (SELECT MAX(CREATE_TIME) FROM TIDINGS WHERE (CONSULT_ID = ?) AND (SENDER_ID != ?)) ";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,consultId);
@@ -86,7 +145,8 @@ public abstract class TidingsDao {
	
	public Tidings query(Connection con,String tidingsId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,CONSULT_ID,TIDINGS.CREATE_TIME,PROFESSOR.NAME FROM TIDINGS LEFT JOIN PROFESSOR ON SENDER_ID = PROFESSOR.ID WHERE TIDINGS_ID = ?";
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,CONSULT_ID,TIDINGS.CREATE_TIME,PROFESSOR.NAME "
        		+ " FROM TIDINGS LEFT JOIN PROFESSOR ON SENDER_ID = PROFESSOR.ID WHERE TIDINGS_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,tidingsId);
@@ -116,7 +176,8 @@ public abstract class TidingsDao {
	
	public java.util.List<Tidings> queryCon(Connection con,String consultId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,TIDINGS.CONSULT_ID,TIDINGS.CREATE_TIME,PROFESSOR.NAME FROM TIDINGS LEFT JOIN PROFESSOR ON SENDER_ID = PROFESSOR.ID WHERE TIDINGS.CONSULT_ID = ? ORDER BY TIDINGS.CREATE_TIME";
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,TIDINGS.CONSULT_ID,TIDINGS.CREATE_TIME,PROFESSOR.NAME "
        		+ " FROM TIDINGS LEFT JOIN PROFESSOR ON SENDER_ID = PROFESSOR.ID WHERE TIDINGS.CONSULT_ID = ? ORDER BY TIDINGS.CREATE_TIME";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,consultId);

src/main/java/com/ekexiu/portal/service/TidingsService.java

@@ -54,6 +54,12 @@ public class TidingsService {
		return this.tidingsDao.queryNotReadTidings(con, consultId, senderId);
	}
	
	@Get
	@Path("/qaNewReply")
	public Tidings queryNewReply(@JdbcConn Connection con, String consultantId) throws SQLException {
		return this.tidingsDao.queryNewReply(con, consultantId);
	}
	
	@Get
	@Path("/qaLastRevovery")
	public Tidings queryLastRevovery(@JdbcConn Connection con, String consultId, String senderId) throws SQLException {