咨询多条件分页查询，咨询评价功能和感谢功能。

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

import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.util.PageQueryResult;
import com.ekexiu.portal.po.Consult;
import com.ekexiu.portal.po.Professor;
import com.ekexiu.portal.pojo.EditProfessor;
@DAO
	@Insert
	public abstract int insert(Connection con, Consult consult) throws SQLException;
	
	@Update
	public int updateFinishTime(Connection con,String consultId,int consultStatus) throws SQLException{
	public abstract int update(Connection con, Consult consult) throws SQLException;
        int _m_2 = 1;
	
        String sql ="UPDATE CONSULT SET FINISH_TIME= TO_CHAR(NOW(),'YYYYMMDDHH24MISS'),CONSULT_STATUS= ? WHERE CONSULT_ID = ?";
	@UpdateWith
        PreparedStatement ps = con.prepareStatement(sql);
	@From(Consult.class)
        try{
	public abstract int updateFinishTime(Connection con, String consultId, @Set String finishTime) throws SQLException;
        	ps.setInt(_m_2++, consultStatus);
            ps.setString(_m_2++,consultId);
            return ps.executeUpdate();
        }finally{
            try{ps.close();}catch(Exception _m_3){}
        }
    }
	
	public int updateRevoveryTime(Connection con,String consultId) throws SQLException{
        int _m_1 = 1;
        }
    }
	
	public int updateAssess(Connection con, String consultId, int assessStatus, int assessStar, String assessContant) throws SQLException{
        int _m_2 = 1;
        boolean _m_3 = null == assessContant;
        String sql ="UPDATE CONSULT SET ASSESS_TIME= TO_CHAR(NOW(),'YYYYMMDDHH24MISS'),ASSESS_CONTANT= ?,ASSESS_STAR= ?,ASSESS_STATUS= ? WHERE CONSULT_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            if(_m_3){
                ps.setNull(_m_2++,12);
            }else{
                ps.setString(_m_2++,assessContant);
            }
            ps.setInt(_m_2++,assessStar);
            ps.setInt(_m_2++, assessStatus);
            ps.setString(_m_2++,consultId);
            return ps.executeUpdate();
        }finally{
            try{ps.close();}catch(Exception _m_4){}
        }
    }
	
	public int updateThanks(Connection con,String consultId,int thanksStatus,BigDecimal thanksMoney) throws SQLException{
        int _m_2 = 1;
        boolean _m_3 = null == thanksMoney;
        String sql ="UPDATE CONSULT SET THANKS_TIME= TO_CHAR(NOW(),'YYYYMMDDHH24MISS'),THANKS_MONEY= ?,THANKS_STATUS= ? WHERE CONSULT_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            if(_m_3){
                ps.setNull(_m_2++,3);
            }else{
                ps.setBigDecimal(_m_2++,thanksMoney);
            }
            ps.setInt(_m_2++,thanksStatus);
            ps.setString(_m_2++,consultId);
            return ps.executeUpdate();
        }finally{
            try{ps.close();}catch(Exception _m_4){}
        }
    }
	
	@SelectOne
	@Nullable
	public abstract Consult query(Connection con, String consultId) throws SQLException;
	
	public PageQueryResult<Consult> queryPagePro(Connection con, String professorId, int consultStatus, int timeType, int sortType, int pageSize, int pageNo) throws SQLException{
	public Consult queryPro(Connection con,String consultId) throws SQLException{
        int _m_1 = 1;
        String sql = "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,CONSULT.CREATE_TIME,PROFESSOR.NAME FROM CONSULT LEFT JOIN PROFESSOR ON CONSULT.CONSULTANT_ID = PROFESSOR.ID WHERE CONSULT_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,consultId);
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    Consult _result = new Consult();
                    _result.setConsultId(rs.getString(1));
                    _result.setConsultType(rs.getString(2));
                    _result.setConsultTitle(rs.getString(3));
                    _result.setConsultContant(rs.getString(4));
                    _result.setProfessorId(rs.getString(5));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(6));
                    _result.setConsultStatus(rs.getInt(7));
                    String _m_2 = rs.getString(8);
                    if(rs.wasNull()){
                        _m_2 = null;
                    }
                    _result.setFinishTime(_m_2);
                    _result.setAssessStatus(rs.getInt(9));
                    _result.setAssessStar(rs.getInt(10));
                    String _m_3 = rs.getString(11);
                    if(rs.wasNull()){
                        _m_3 = null;
                    }
                    _result.setAssessContant(_m_3);
                    String _m_4 = rs.getString(12);
                    if(rs.wasNull()){
                        _m_4 = null;
                    }
                    _result.setAssessTime(_m_4);
                    _result.setThanksStatus(rs.getInt(13));
                    BigDecimal _m_5 = rs.getBigDecimal(14);
                    if(rs.wasNull()){
                        _m_5 = null;
                    }
                    _result.setThanksMoney(_m_5);
                    String _m_6 = rs.getString(15);
                    if(rs.wasNull()){
                        _m_6 = null;
                    }
                    _result.setThanksTime(_m_6);
                    _result.setRevoveryTime(rs.getString(16));
                    _result.setCreateTime(rs.getString(17));
                    professor.setName(rs.getString(18));
                    _result.setProfessor(professor);
                    return _result;
                }else{
                    return null;
                }
            }finally{
                try{rs.close();}catch(Exception _m_7){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_8){}
        }
    }
	
	public Consult queryCon(Connection con,String consultId) throws SQLException{
        int _m_1 = 1;
        String sql = "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,CONSULT.CREATE_TIME,PROFESSOR.NAME FROM CONSULT LEFT JOIN PROFESSOR ON CONSULT.PROFESSOR_ID = PROFESSOR.ID WHERE CONSULT_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,consultId);
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    Consult _result = new Consult();
                    _result.setConsultId(rs.getString(1));
                    _result.setConsultType(rs.getString(2));
                    _result.setConsultTitle(rs.getString(3));
                    _result.setConsultContant(rs.getString(4));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(5));
                    _result.setConsultantId(rs.getString(6));
                    _result.setConsultStatus(rs.getInt(7));
                    String _m_2 = rs.getString(8);
                    if(rs.wasNull()){
                        _m_2 = null;
                    }
                    _result.setFinishTime(_m_2);
                    _result.setAssessStatus(rs.getInt(9));
                    _result.setAssessStar(rs.getInt(10));
                    String _m_3 = rs.getString(11);
                    if(rs.wasNull()){
                        _m_3 = null;
                    }
                    _result.setAssessContant(_m_3);
                    String _m_4 = rs.getString(12);
                    if(rs.wasNull()){
                        _m_4 = null;
                    }
                    _result.setAssessTime(_m_4);
                    _result.setThanksStatus(rs.getInt(13));
                    BigDecimal _m_5 = rs.getBigDecimal(14);
                    if(rs.wasNull()){
                        _m_5 = null;
                    }
                    _result.setThanksMoney(_m_5);
                    String _m_6 = rs.getString(15);
                    if(rs.wasNull()){
                        _m_6 = null;
                    }
                    _result.setThanksTime(_m_6);
                    _result.setRevoveryTime(rs.getString(16));
                    _result.setCreateTime(rs.getString(17));
                    professor.setName(rs.getString(18));
                    _result.setProfessor(professor);
                    return _result;
                }else{
                    return null;
                }
            }finally{
                try{rs.close();}catch(Exception _m_7){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_8){}
        }
    }	
	
	public PageQueryResult<Consult> queryPagePro(Connection con, String professorId, int status, int timeType, int sortType, int pageSize, int pageNo) throws SQLException{
		PageQueryResult<Consult> queryResult = new PageQueryResult<Consult>();
		StringBuilder sql = new StringBuilder();
		sql.append(" WHERE CONSULT.PROFESSOR_ID = ? ");
		if(0 != consultStatus) {
		if(1 == status) {
			sql.append(" AND CONSULT_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();
		int totalSize = 0;
		try {
			ps.setString(paramIndex++, professorId);
			if(0 != consultStatus){
				ps.setInt(paramIndex++, consultStatus);
			}
			queryResult.setPageSize(pageSize);
			ResultSet resultSet = ps.executeQuery();
			try {
		ps = con.prepareStatement(sql.toString());
		try {
			ps.setString(paramIndex++, professorId);
			if(0 != consultStatus){
				ps.setInt(paramIndex++, consultStatus);
			}
			ResultSet rs = ps.executeQuery();
			try {
				List<Consult> _m_11 = new ArrayList<Consult>();
		}
	}
	
	public PageQueryResult<Consult> queryPageCon(Connection con, String consultantId, int consultStatus, int timeType, int sortType, int pageSize, int pageNo) throws SQLException{
	public PageQueryResult<Consult> queryPageCon(Connection con, String consultantId, int status, int timeType, int sortType, int pageSize, int pageNo) throws SQLException{
		PageQueryResult<Consult> queryResult = new PageQueryResult<Consult>();
		StringBuilder sql = new StringBuilder();
		sql.append(" WHERE CONSULT.CONSULTANT_ID = ? ");
		if(0 != consultStatus) {
		if(1 == status) {
			sql.append(" AND CONSULT_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();
		int totalSize = 0;
		try {
			ps.setString(paramIndex++, consultantId);
			if(0 != consultStatus){
				ps.setInt(paramIndex++, consultStatus);
			}
			queryResult.setPageSize(pageSize);
			ResultSet resultSet = ps.executeQuery();
			try {
				resultSet.next();
		ps = con.prepareStatement(sql.toString());
		try {
			ps.setString(paramIndex++, consultantId);
			if(0 != consultStatus){
				ps.setInt(paramIndex++, consultStatus);
			}
			ResultSet rs = ps.executeQuery();
			try {
				List<Consult> _m_11 = new ArrayList<Consult>();

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

package com.ekexiu.portal.service;
import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.operate.Put;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
		return consultId;
	}
	
	@Put
	@Path
	public void update(@JdbcConn(true) Connection con, Consult consult) throws SQLException {
		this.consultDao.update(con, consult);
	}
	
	@Post
	@Path("/finishTime")
	public void updateFinishTime(@JdbcConn(true) Connection con, String consultId, String finishTime) throws SQLException {
	public boolean updateFinishTime(@JdbcConn(true) Connection con, String consultId, int consultStatus) throws SQLException {
		Consult consult = this.consultDao.query(con, consultId);
		if(null == consult.getFinishTime()){
			this.consultDao.updateFinishTime(con, consultId, finishTime);
			this.consultDao.updateFinishTime(con, consultId,consultStatus);
			return true;
		}
		return false;
	}
	
	@Post
	@Path("/assess")
	public boolean updateAssess(@JdbcConn(true) Connection con, String consultId, int assessStatus, int assessStar, String assessContant) throws SQLException {
		Consult consult = this.consultDao.query(con, consultId);
		if(0 == consult.getAssessStatus()){
			this.consultDao.updateAssess(con, consultId, assessStatus, assessStar, assessContant);
			return true;
		}
		return false;
	}
	
	@Post
	@Path("/thanks")
	public boolean updateThanks(@JdbcConn(true) Connection con, String consultId, int thanksStatus, BigDecimal thanksMoney) throws SQLException {
		Consult consult = this.consultDao.query(con, consultId);
		if(0 == consult.getThanksStatus()){
			this.consultDao.updateThanks(con, consultId, thanksStatus, thanksMoney);
			return true;
		}
		return false;
	}
	
	@Get
	@Path("/qapro")
	public Consult queryPro(@JdbcConn Connection con, String consultId) throws SQLException {
		return this.consultDao.queryPro(con, consultId);
	}
	
	@Get
	@Path("/{consultId}")
	@Path("/qacon")
	public Consult query(@JdbcConn Connection con, @PathVar String consultId) throws SQLException {
	public Consult queryCon(@JdbcConn Connection con, String consultId) throws SQLException {
		return this.consultDao.query(con, consultId);
		return this.consultDao.queryCon(con, consultId);
	}
	
	@Get
	@Path("/pqpro")
	public PageQueryResult<Consult> queryPagePro(@JdbcConn Connection con, String professorId, 
			@DefaultValue("0") int consultStatus, @DefaultValue("0") int timeType, @DefaultValue("0") int sortType, 
			@DefaultValue("0") int status, @DefaultValue("0") int timeType, @DefaultValue("0") int sortType, 
			@DefaultValue("5") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
		return this.consultDao.queryPagePro(con, professorId, consultStatus, timeType, sortType, pageSize, pageNo);
		return this.consultDao.queryPagePro(con, professorId, status, timeType, sortType, pageSize, pageNo);
	}	
	
	@Get
	@Path("/pqcon")
	public PageQueryResult<Consult> queryPageCon(@JdbcConn Connection con, String consultantId, 
			@DefaultValue("0") int consultStatus, @DefaultValue("0") int timeType, @DefaultValue("0") int sortType, 
			@DefaultValue("0") int status, @DefaultValue("0") int timeType, @DefaultValue("0") int sortType, 
			@DefaultValue("5") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
		return this.consultDao.queryPageCon(con, consultantId, consultStatus, timeType, sortType, pageSize, pageNo);
		return this.consultDao.queryPageCon(con, consultantId, status, timeType, sortType, pageSize, pageNo);
	}
	
}