APP咨询搜索页按条件搜索咨询列表。

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

@@ -47,6 +47,14 @@ public abstract class ConsultDao {
        }
    }
	
	/**
	 * 更新完成时间和完成状态
	 * @param con 
	 * @param consultId 咨询ID
	 * @param consultStatus 咨询状态
	 * @return 
	 * @throws SQLException
	 */
	public int updateFinishTime(Connection con,String consultId,int consultStatus) throws SQLException{
        int _m_2 = 1;
        String sql ="UPDATE CONSULT SET FINISH_TIME= TO_CHAR(NOW(),'YYYYMMDDHH24MISS'),CONSULT_STATUS= ? WHERE CONSULT_ID = ?";
@@ -1208,4 +1216,210 @@ public abstract class ConsultDao {
		}
	}
	
	/**
	 * 按条件搜索所有咨询的接口
	 * @param con
	 * @param professorId 用户ID
	 * @param consultOrNeed 接受咨询或咨询别人的状态值，1-别人咨询我的，2-我咨询别人的,默认为0
	 * @param status 查询状态 0-全部，1-进行中，2-未感谢，3-未评价，4-已完成，默认为0
	 * @param timeType 排序类型 0-按发起时间，1-按最后回复时间，2-按完成时间，默认为0
	 * @param pageSize
	 * @param pageNo
	 * @return 返回咨询列表
	 * @throws SQLException
	 */
	public PageQueryResult<Consult> queryPageBase(Connection con, String professorId, int consultOrNeed, 
			int status, int timeType, int pageSize, int pageNo) throws SQLException{
		PageQueryResult<Consult> queryResult = new PageQueryResult<Consult>();
		StringBuilder sql = new StringBuilder();
		if(0 == consultOrNeed){
			sql.append(" WHERE PROFESSOR_ID = ? OR CONSULTANT_ID = ?");
		}else if(1 == consultOrNeed){
			sql.append(" WHERE PROFESSOR_ID = ? ");
		}else if(2 == consultOrNeed){
			sql.append(" WHERE CONSULTANT_ID = ? ");
		}
		if(1 == status) {
			sql.append(" AND CONSULT_STATUS = 0 ");
		}else if(2 == status) {
			sql.append(" AND CONSULT_STATUS = 1 AND THANKS_STATUS = 0 ");
		}else if(3 == status) {
			sql.append(" AND CONSULT_STATUS = 1 AND ASSESS_STATUS = 0 ");
		}else if(4 == status) {
			sql.append(" AND CONSULT_STATUS = 1 ");
		}
		StringBuilder whereSql = sql;
		sql = new StringBuilder();
		sql.append("SELECT COUNT(1) FROM CONSULT");
		if (whereSql.length() > 0) {
			sql.append(whereSql);
		}
		PreparedStatement ps = con.prepareStatement(sql.toString());
		int paramIndex = 1;
		int totalSize = 0;
		try {
			ps.setString(paramIndex++, professorId);
			if(0 == consultOrNeed){
				ps.setString(paramIndex++, professorId);
			}
			queryResult.setPageSize(pageSize);
			ResultSet resultSet = ps.executeQuery();
			try {
				resultSet.next();
				totalSize = resultSet.getInt(1);
			} finally {
				try {
					resultSet.close();
				} catch (Exception _m_6) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception _m_7) {
			}
		}
		queryResult.setTotal(totalSize);
		if (0 == totalSize) {
			queryResult.setPageNo(1);
			queryResult.setData(Collections.<Consult> emptyList());
			return queryResult;
		}
		paramIndex = 1;
		if (1 == pageNo) {
			queryResult.setPageNo(1);
			sql = new StringBuilder();
			sql.append(" SELECT CONSULT_ID,CONSULT_TYPE,CONSULT_TITLE,CONSULT_CONTANT,PROFESSOR_ID,CONSULTANT_ID,"
					+ " CONSULT_STATUS,FINISH_TIME,ASSESS_STATUS,ASSESS_STAR,ASSESS_CONTANT,ASSESS_TIME,THANKS_STATUS,"
					+ " THANKS_MONEY,THANKS_TIME,REVOVERY_TIME,READ_STATUS,CREATE_TIME FROM CONSULT ");
			if (whereSql.length() > 0) {
				sql.append(whereSql);
			}
			if(0 == timeType) {
				sql.append(" ORDER BY CREATE_TIME ");
			}else if(1 == timeType) {
				sql.append(" ORDER BY REVOVERY_TIME DESC ");
			}else if(2 == timeType) {
				sql.append(" ORDER BY FINISH_TIME DESC ");
			}
			sql.append(" LIMIT ").append(pageSize);
		} else {
			int _pageSize = totalSize / pageSize;
			if (totalSize % pageSize != 0) {
				++_pageSize;
			}
			if (pageNo > _pageSize) {
				pageNo = _pageSize;
			}
			queryResult.setPageNo(pageNo);
			--pageNo;
			int _m_10 = (pageNo * pageSize);
			sql = new StringBuilder();
			sql.append(" SELECT CONSULT_ID,CONSULT_TYPE,CONSULT_TITLE,CONSULT_CONTANT,PROFESSOR_ID,CONSULTANT_ID,"
					+ " CONSULT_STATUS,FINISH_TIME,ASSESS_STATUS,ASSESS_STAR,ASSESS_CONTANT,ASSESS_TIME,THANKS_STATUS,"
					+ " THANKS_MONEY,THANKS_TIME,REVOVERY_TIME,READ_STATUS,CREATE_TIME FROM CONSULT ");
			if (whereSql.length() > 0) {
				sql.append(whereSql);
			}
			if(0 == timeType) {
				sql.append(" ORDER BY CREATE_TIME ");
			}else if(1 == timeType) {
				sql.append(" ORDER BY REVOVERY_TIME DESC ");
			}else if(2 == timeType) {
				sql.append(" ORDER BY FINISH_TIME DESC ");
			}
			sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(_m_10);
		}
		ps = con.prepareStatement(sql.toString());
		try {
			ps.setString(paramIndex++, professorId);
			if(0 == consultOrNeed){
				ps.setString(paramIndex++, professorId);
			}
			ResultSet rs = ps.executeQuery();
			try {
				List<Consult> _m_11 = new ArrayList<Consult>();
				queryResult.setData(_m_11);
				while (rs.next()) {
					Consult consult = new Consult();
					consult.setConsultId(rs.getString(1));
					consult.setConsultType(rs.getString(2));
					consult.setConsultTitle(rs.getString(3));
					consult.setConsultContant(rs.getString(4));
					consult.setProfessorId(rs.getString(5));
					consult.setConsultantId(rs.getString(6));
					Integer m1 = rs.getInt(7);
					if (rs.wasNull()) {
						m1 = null;
					}
					consult.setConsultStatus(m1);
					String m2 = rs.getString(8);
					if (rs.wasNull()) {
						m2 = null;
					}
					consult.setFinishTime(m2);
					Integer m3 = rs.getInt(9);
					if (rs.wasNull()) {
						m3 = null;
					}
					consult.setAssessStatus(m3);
					consult.setAssessStar(rs.getInt(10));
					String m5 = rs.getString(11);
					if (rs.wasNull()) {
						m5 = null;
					}
					consult.setAssessContant(m5);
					String m6 = rs.getString(12);
					if (rs.wasNull()) {
						m6 = null;
					}
					consult.setAssessTime(m6);
					Integer m7 = rs.getInt(13);
					if (rs.wasNull()) {
						m7 = null;
					}
					consult.setThanksStatus(m7);
					BigDecimal m8 = rs.getBigDecimal(14);
					if (rs.wasNull()) {
						m8 = null;
					}
					consult.setThanksMoney(m8);
					String m9 = rs.getString(15);
					if (rs.wasNull()) {
						m9 = null;
					}
					consult.setThanksTime(m9);
					consult.setRevoveryTime(rs.getString(16));
					consult.setReadStatus(rs.getInt(17));
					consult.setCreateTime(rs.getString(18));
					EditProfessor professor = new EditProfessor();
					if(0 == consultOrNeed){
						if(professorId.equals(consult.getProfessorId())){
							professor = this.professorDao.queryBaseInfo(con, consult.getConsultantId());
						}else if(professorId.equals(consult.getConsultantId())){
							professor = this.professorDao.queryBaseInfo(con, consult.getProfessorId());
						}
					}else if(1 == consultOrNeed){
						professor = this.professorDao.queryBaseInfo(con, consult.getConsultantId());
					}else if(2 == consultOrNeed){
						professor = this.professorDao.queryBaseInfo(con, consult.getProfessorId());
					}
					consult.setProfessor(professor);
					_m_11.add(consult);
				}
				return queryResult;
			} finally {
				try {
					rs.close();
				} catch (Exception _m_17) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception _m_18) {
			}
		}
	}
	
}

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

@@ -216,4 +216,21 @@ public class ConsultService {
		return this.consultDao.queryPageCon(con, consultantId, status, timeType, sortType, pageSize, pageNo);
	}
	
	@Get
	@Path("/pq")
	public PageQueryResult<Consult> queryPageBase(@JdbcConn Connection con, String professorId, 
			@DefaultValue("0") int consultOrNeed, @DefaultValue("0") int status, @DefaultValue("1") int timeType, 
			@DefaultValue("10") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
		PageQueryResult<Consult> queryResult = this.consultDao.queryPageBase(con, professorId, consultOrNeed, status, timeType, pageSize, pageNo);
		List<Consult> consults = queryResult.getData();
		if(consults != null){
			for (Consult consult : consults) {
				int hasHeadImage = this.imageService.hasProfessorImage(consult.getProfessorId());
				consult.getProfessor().setHasHeadImage(hasHeadImage);
			}
			queryResult.setData(consults);
		}
		return queryResult;
	}
	
}