咨询页面查询当前咨询有几条未读消息。

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

@@ -1,6 +1,8 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.jfw.apt.orm.annotation.dao.DAO;
@@ -14,6 +16,25 @@ public abstract class TidingsDao {
	@Insert
	public abstract int insert(Connection con, Tidings tidings) throws SQLException;
	
	/**
	 * 查询未查看信息条数的接口 
	 * @param con
	 * @param consultId 咨询ID
	 * @param senderId 登录者ID
	 * @return 返回该咨询中对方发送过来未查看的信息条数
	 * @throws SQLException
	 */
	public int queryNotReadTidings(Connection con, String consultId, String senderId) throws SQLException {
		String sql = " SELECT COUNT(1) FROM TIDINGS WHERE READ_STATUS = 0 AND CONSULT_ID = ? AND SENDER_ID != ? ";
		PreparedStatement ps = con.prepareStatement(sql);
		ps.setString(1, consultId);
		ps.setString(2, senderId);
		ResultSet rs = ps.executeQuery();
		rs.next();
		int count = rs.getInt(1);
		return count;
	}
	
	public com.ekexiu.portal.po.Tidings query(java.sql.Connection con,java.lang.String tidingsId) throws java.sql.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 = ?";

src/main/java/com/ekexiu/portal/po/Tidings.java

@@ -3,6 +3,7 @@ package com.ekexiu.portal.po;
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.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
@@ -16,6 +17,7 @@ public class Tidings implements CreateTimeSupported {
	private String senderId;
	private String consultId;
	private String createTime;
	private int readStatus;
	private Professor professor;
	private Consult consult;
	
@@ -72,4 +74,12 @@ public class Tidings implements CreateTimeSupported {
		this.createTime = createTime;
	}
	
	@Column(handlerClass=IntHandler.class,dbType="INT",nullable=false,insertable=false,renewable=true,queryable=true)
	public int getReadStatus() {
		return readStatus;
	}
	public void setReadStatus(int readStatus) {
		this.readStatus = readStatus;
	}
	
}

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

@@ -47,6 +47,12 @@ public class TidingsService {
		return tidingsId;
	}
	
	@Get
	@Path("/qaNotReadTidings")
	public int queryNotReadTidings(@JdbcConn Connection con, String consultId, String senderId) throws SQLException {
		return this.tidingsDao.queryNotReadTidings(con, consultId, senderId);
	}
	
	@Get
	@Path("/{tidingsId}")
	public Tidings query(@JdbcConn Connection con, @PathVar String tidingsId) throws SQLException {