资源申请的查询接口（待测试）

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

import java.util.Collections;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
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.DeleteWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.util.PageQueryResult;
import com.ekexiu.portal.po.Image;
import com.ekexiu.portal.po.Operation;
import com.ekexiu.portal.po.Professor;
import com.ekexiu.portal.po.Resource;
@DAO
public abstract class OperationDao {
	@Autowrie
	private ImageDao imageDao;
	
	public ImageDao getImageDao() {
		return imageDao;
	}
	public void setImageDao(ImageDao imageDao) {
		this.imageDao = imageDao;
	}
	@Insert
	public abstract int insert(Connection con, Operation operation) throws SQLException;
	
	@From(Operation.class)
	public abstract int updatePayMethod(Connection con, String operationId, @Set String payMethod) throws SQLException;
	
	public com.ekexiu.portal.po.Operation query(java.sql.Connection con,java.lang.String operationId) throws java.sql.SQLException{
	public Operation query(Connection con,String operationId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,OPERATION_ID,OPERATION_STATUS,DEMAND_ID,DETAIL_DEMAND,DELIVER_TIME,OPERATION.RESOURCE_ID,DEAL_PRICE,DEAL_TIME,PAY_METHOD,P1.NAME,RESOURCE_NAME,RESOURCE.PROFESSOR_ID,P2.NAME,APPLYSQUARE FROM OPERATION INNER JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID INNER JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID INNER JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID WHERE OPERATION_ID = ?";
        java.sql.PreparedStatement ps = con.prepareStatement(sql);
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,operationId);
            java.sql.ResultSet rs = ps.executeQuery();
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    com.ekexiu.portal.po.Operation _result = new com.ekexiu.portal.po.Operation();
                    Operation _result = new Operation();
                    _result.setReplyNotes(rs.getString(1));
                    _result.setCreateTime(rs.getString(2));
                    _result.setOperationId(rs.getString(3));
        }
    }
	
	public java.util.List<com.ekexiu.portal.po.Operation> query(java.sql.Connection con) throws java.sql.SQLException{
	public List<Operation> query(Connection con) throws SQLException{
        String sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,OPERATION_ID,OPERATION_STATUS,DEMAND_ID,DETAIL_DEMAND,DELIVER_TIME,OPERATION.RESOURCE_ID,DEAL_PRICE,DEAL_TIME,PAY_METHOD,P1.NAME,RESOURCE_NAME,RESOURCE.PROFESSOR_ID,P2.NAME,APPLYSQUARE FROM OPERATION INNER JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID INNER JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID INNER JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID";
        java.sql.PreparedStatement ps = con.prepareStatement(sql);
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            java.sql.ResultSet rs = ps.executeQuery();
            ResultSet rs = ps.executeQuery();
            try{
                java.util.List<com.ekexiu.portal.po.Operation> _result = new java.util.ArrayList<com.ekexiu.portal.po.Operation>();
                List<Operation> _result = new ArrayList<Operation>();
                while(rs.next()){
                    com.ekexiu.portal.po.Operation _obj =  new com.ekexiu.portal.po.Operation();
                    Operation _obj =  new Operation();
                    _obj.setReplyNotes(rs.getString(1));
                    _obj.setCreateTime(rs.getString(2));
                    _obj.setOperationId(rs.getString(3));
//	 * @param con
//	 * @param demandId 请求者ID
//	 * @return
//	 * @throws java.sql.SQLException
//	 * @throws SQLException
//	 */
//	public java.util.List<com.ekexiu.portal.po.Operation> queryDem(java.sql.Connection con,java.lang.String demandId) throws java.sql.SQLException{
//	public List<Operation> queryDem(Connection con,String demandId) throws SQLException{
//        int _m_1 = 1;
//        String sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,OPERATION_ID,OPERATION_STATUS,DEMAND_ID,DETAIL_DEMAND,DELIVER_TIME,OPERATION.RESOURCE_ID,DEAL_PRICE,DEAL_TIME,PAY_METHOD,P1.NAME,RESOURCE_NAME,RESOURCE.PROFESSOR_ID,P2.NAME,APPLYSQUARE FROM OPERATION INNER JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID INNER JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID INNER JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID WHERE DEMAND_ID = ?";
//        java.sql.PreparedStatement ps = con.prepareStatement(sql);
//        PreparedStatement ps = con.prepareStatement(sql);
//        try{
//            ps.setString(_m_1++,demandId);
//            java.sql.ResultSet rs = ps.executeQuery();
//            ResultSet rs = ps.executeQuery();
//            try{
//                java.util.List<com.ekexiu.portal.po.Operation> _result = new java.util.ArrayList<com.ekexiu.portal.po.Operation>();
//                List<Operation> _result = new ArrayList<Operation>();
//                while(rs.next()){
//                    com.ekexiu.portal.po.Operation _obj =  new com.ekexiu.portal.po.Operation();
//                    Operation _obj =  new Operation();
//                    _obj.setReplyNotes(rs.getString(1));
//                    _obj.setCreateTime(rs.getString(2));
//                    _obj.setOperationId(rs.getString(3));
//        }
//    }
	
	public PageQueryResult<Operation> queryPro(Connection con, @Nullable String id,int pageSize,int pageNo) throws SQLException{
        int _m_1 = 0;
        PageQueryResult<Operation> _result = new PageQueryResult<Operation>();
        int _m_3 = 1;
        boolean _m_2 = null == id;
        StringBuilder sql = new StringBuilder();
        boolean _m_5 = true;
        if(!_m_2){
            _m_5 =  false;
            sql.append(" WHERE O.RESOURCE_ID IN (SELECT R.RESOURCE_ID FROM RESOURCE WHERE R.PROFESSOR_ID = ?)");
        }
        if(!_m_2){
            if(_m_5){
                _m_5 =  false;
                sql.append(" WHERE (O.DEMAND_ID = ?) ");
            }else{
                sql.append(" OR (O.DEMAND_ID = ?) ");
            }
        }
        StringBuilder _m_4 = sql;
        sql = new StringBuilder();
        sql.append("SELECT COUNT(1) FROM OPERATION");
        if(_m_4.length()>0){
            sql.append(_m_4);
        }
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
            if(!_m_2){
                ps.setString(_m_3++,id);
            }
            if(!_m_2){
                ps.setString(_m_3++,id);
            }
            _result.setPageSize(pageSize);
            ResultSet _pageRs = ps.executeQuery();
            try{
                _pageRs.next();
                _m_1 = _pageRs.getInt(1);
            }finally{
                try{_pageRs.close();}catch(Exception _m_6){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_7){}
        }
        _result.setTotal(_m_1);
        if(0== _m_1){
            _result.setPageNo(1);
            _result.setData(Collections.<Operation>emptyList());
            return _result;
        }
        _m_3 = 1;
        boolean _m_8 = (1 == pageNo);
        if(_m_8){
            _result.setPageNo(1);
            sql = new StringBuilder();
            sql.append("SELECT REPLY_NOTES,APPLYSQUARE,OPERATION_ID,OPERATION_STATUS,DEMAND_ID,DETAIL_DEMAND,DELIVER_TIME,O.RESOURCE_ID,DEAL_PRICE,DEAL_TIME,PAY_METHOD,O.CREATE_TIME,R.RESOURCE_NAME,SUPPORTED_SERVICES,R.DESCP,R.PROFESSOR_ID,P1.NAME,P2.NAME FROM OPERATION O LEFT JOIN RESOURCE R ON O.RESOURCE_ID = R.RESOURCE_ID LEFT JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID LEFT JOIN PROFESSOR P2 ON R.PROFESSOR_ID = P2.ID");
            if(_m_4.length()>0){
                sql.append(_m_4);
            }
            sql.append(" ORDER BY O.CREATE_TIME DESC ");
            sql.append(" LIMIT ").append(pageSize);
        }else{
            int _m_9 = _m_1 / pageSize;
            if(_m_1 % pageSize != 0){
                ++_m_9;
            }
            if(pageNo > _m_9){
                pageNo = _m_9;
            }
            _result.setPageNo(pageNo);
            --pageNo;
            int _m_10 = (pageNo * pageSize);
            sql = new StringBuilder();
            sql.append("SELECT REPLY_NOTES,APPLYSQUARE,OPERATION_ID,OPERATION_STATUS,DEMAND_ID,DETAIL_DEMAND,DELIVER_TIME,O.RESOURCE_ID,DEAL_PRICE,DEAL_TIME,PAY_METHOD,O.CREATE_TIME,R.RESOURCE_NAME,SUPPORTED_SERVICES,R.DESCP,R.PROFESSOR_ID,P1.NAME,P2.NAME FROM OPERATION O LEFT JOIN RESOURCE R ON O.RESOURCE_ID = R.RESOURCE_ID LEFT JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID LEFT JOIN PROFESSOR P2 ON R.PROFESSOR_ID = P2.ID");
            if(_m_4.length()>0){
                sql.append(_m_4);
            }
            sql.append(" ORDER BY O.CREATE_TIME DESC ");
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(_m_10);
        }
        ps = con.prepareStatement(sql.toString());
        try{
            if(!_m_2){
                ps.setString(_m_3++,id);
            }
            if(!_m_2){
                ps.setString(_m_3++,id);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Operation> _m_11 = new ArrayList<Operation>();
                _result.setData(_m_11);
                int _m_12 = 0;
                while((_m_12<pageSize) && rs.next()){
                    ++_m_12;
                    Operation _obj =  new Operation();
                    String _m_13 = rs.getString(1);
                    if(rs.wasNull()){
                        _m_13 = null;
                    }
                    _obj.setReplyNotes(_m_13);
                    String _m_14 = rs.getString(2);
                    if(rs.wasNull()){
                        _m_14 = null;
                    }
                    _obj.setApplysquare(_m_14);
                    _obj.setOperationId(rs.getString(3));
                    _obj.setOperationStatus(rs.getInt(4));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(5));
                    _obj.setDetailDemand(rs.getString(6));
                    _obj.setDeliverTime(rs.getString(7));
                    Resource resource = new Resource();
                    resource.setResourceId(rs.getString(8));
                    java.math.BigDecimal _m_15 = rs.getBigDecimal(9);
                    if(rs.wasNull()){
                        _m_15 = null;
                    }
                    _obj.setDealPrice(_m_15);
                    String _m_16 = rs.getString(10);
                    if(rs.wasNull()){
                        _m_16 = null;
                    }
                    _obj.setDealTime(_m_16);
                    String _m_17 = rs.getString(11);
                    if(rs.wasNull()){
                        _m_17 = null;
                    }
                    _obj.setPayMethod(_m_17);
                    _obj.setCreateTime(rs.getString(12));
                    resource.setResourceName(rs.getString(13));
                    resource.setSupportedServices(rs.getString(14));
                    resource.setDescp(rs.getString(15));
                    Professor professor2 = new Professor();
                    professor2.setId(rs.getString(16));
                    List<Image> images = this.imageDao.queryRes(con, _obj.getResourceId());
                    resource.setImages(images);
                    professor.setName(rs.getString(17));
                    _obj.setProfessor(professor);
                    professor2.setName(rs.getString(18));
                    resource.setProfessor(professor2);
                    _obj.setResource(resource);
                    _m_11.add(_obj);
                }
                return _result;
            }finally{
                try{rs.close();}catch(Exception _m_18){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_19){}
        }
    }
	
	/**
	 * 分页按资源申请者ID查资源申请
	 * @param con
//	 * @param con
//	 * @param resourceId 资源ID
//	 * @return
//	 * @throws java.sql.SQLException
//	 * @throws SQLException
//	 */
//	public java.util.List<com.ekexiu.portal.po.Operation> queryRes(java.sql.Connection con,java.lang.String resourceId) throws java.sql.SQLException{
//	public List<Operation> queryRes(Connection con,String resourceId) throws SQLException{
//		int _m_1 = 1;
//		String sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,OPERATION_ID,OPERATION_STATUS,DEMAND_ID,DETAIL_DEMAND,DELIVER_TIME,OPERATION.RESOURCE_ID,DEAL_PRICE,DEAL_TIME,PAY_METHOD,P1.NAME,RESOURCE_NAME,RESOURCE.PROFESSOR_ID,P2.NAME,APPLYSQUARE FROM OPERATION INNER JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID INNER JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID INNER JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID WHERE OPERATION.RESOURCE_ID = ?";
//		java.sql.PreparedStatement ps = con.prepareStatement(sql);
//		PreparedStatement ps = con.prepareStatement(sql);
//		try{
//			ps.setString(_m_1++,resourceId);
//			java.sql.ResultSet rs = ps.executeQuery();
//			ResultSet rs = ps.executeQuery();
//			try{
//				java.util.List<com.ekexiu.portal.po.Operation> _result = new java.util.ArrayList<com.ekexiu.portal.po.Operation>();
//				List<Operation> _result = new ArrayList<Operation>();
//				while(rs.next()){
//					com.ekexiu.portal.po.Operation _obj =  new com.ekexiu.portal.po.Operation();
//					Operation _obj =  new Operation();
//					_obj.setReplyNotes(rs.getString(1));
//					_obj.setCreateTime(rs.getString(2));
//					_obj.setOperationId(rs.getString(3));
	 * @param pageSize 每页记录数
	 * @param pageNo 当前页码
	 * @return
	 * @throws java.sql.SQLException
	 * @throws SQLException
	 */
	public org.jfw.util.PageQueryResult<com.ekexiu.portal.po.Operation> queryPage(java.sql.Connection con,java.lang.String professorName,java.lang.String resourceName,java.lang.String firstTime,java.lang.String lastTime,java.math.BigDecimal lowPrice,java.math.BigDecimal highPrice,int pageSize,int pageNo) throws java.sql.SQLException{
	public PageQueryResult<Operation> queryPage(Connection con,String professorName,String resourceName,String firstTime,String lastTime,java.math.BigDecimal lowPrice,java.math.BigDecimal highPrice,int pageSize,int pageNo) throws SQLException{
        int _m_1 = 0;
        org.jfw.util.PageQueryResult<com.ekexiu.portal.po.Operation> _result = new org.jfw.util.PageQueryResult<com.ekexiu.portal.po.Operation>();
        PageQueryResult<Operation> _result = new PageQueryResult<Operation>();
        int _m_3 = 1;
        boolean _m1 = null == professorName;
        boolean _m2 = null == resourceName;
        if(_m_4.length()>0){
            sql.append(_m_4);
        }
        java.sql.PreparedStatement ps = con.prepareStatement(sql.toString());
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
            if(!_m1){
                ps.setString(_m_3++,professorName);
                ps.setBigDecimal(_m_3++,highPrice);
            }
            _result.setPageSize(pageSize);
            java.sql.ResultSet _pageRs = ps.executeQuery();
            ResultSet _pageRs = ps.executeQuery();
            try{
                _pageRs.next();
                _m_1 = _pageRs.getInt(1);
        _result.setTotal(_m_1);
        if(0== _m_1){
            _result.setPageNo(1);
            _result.setData(java.util.Collections.<com.ekexiu.portal.po.Operation>emptyList());
            _result.setData(Collections.<Operation>emptyList());
            return _result;
        }
        _m_3 = 1;
            if(!_m6){
                ps.setBigDecimal(_m_3++,highPrice);
            }
            java.sql.ResultSet rs = ps.executeQuery();
            ResultSet rs = ps.executeQuery();
            try{
                java.util.List<com.ekexiu.portal.po.Operation> _m_11 = new java.util.ArrayList<com.ekexiu.portal.po.Operation>();
                List<Operation> _m_11 = new ArrayList<Operation>();
                _result.setData(_m_11);
                int _m_12 = 0;
                while((_m_12<pageSize) && rs.next()){
                    ++_m_12;
                    com.ekexiu.portal.po.Operation _obj =  new com.ekexiu.portal.po.Operation();
                    Operation _obj =  new Operation();
                    _obj.setReplyNotes(rs.getString(1));
                    _obj.setCreateTime(rs.getString(2));
                    _obj.setOperationId(rs.getString(3));

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

        boolean _m_7 = true;
        if(!_m_2){
            _m_7 =  false;
            sql.append(" WHERE RESOURCE_NAME LIKE ?");
            sql.append(" WHERE (RESOURCE_NAME LIKE ?) ");
        }
        if(!_m_2){
            if(_m_7){
                _m_7 =  false;
                sql.append(" WHERE SUPPORTED_SERVICES LIKE ?");
                sql.append(" WHERE (SUPPORTED_SERVICES LIKE ?) ");
            }else{
                sql.append(" OR SUPPORTED_SERVICES LIKE ?");
                sql.append(" OR (SUPPORTED_SERVICES LIKE ?) ");
            }
        }
        if(!_m_2){
            if(_m_7){
                _m_7 =  false;
                sql.append(" WHERE RESOURCE.DESCP LIKE ?");
                sql.append(" WHERE (RESOURCE.DESCP LIKE ?) ");
            }else{
                sql.append(" OR RESOURCE.DESCP LIKE ?");
                sql.append(" OR (RESOURCE.DESCP LIKE ?) ");
            }
        }
        if(!_m_2){
            if(_m_7){
                _m_7 =  false;
                sql.append(" WHERE COOPERATION_NOTES LIKE ?");
                sql.append(" (WHERE COOPERATION_NOTES LIKE ?) ");
            }else{
                sql.append(" OR COOPERATION_NOTES LIKE ?");
                sql.append(" OR (COOPERATION_NOTES LIKE ?) ");
            }
        }
        if(!_m_2){
            if(_m_7){
                _m_7 =  false;
                sql.append(" WHERE RESOURCE.SUBJECT LIKE ?");
            }else{
                sql.append(" OR RESOURCE.SUBJECT LIKE ?");
            }
        }
        if(!_m_2){
        	if(_m_7){
        		_m_7 =  false;
        		sql.append(" WHERE RESOURCE.INDUSTRY LIKE ?");
        	}else{
        		sql.append(" OR RESOURCE.INDUSTRY LIKE ?");
        	}
        }
        if(!_m_4){
            if(_m_7){
                _m_7 =  false;
                sql.append(" WHERE RESOURCE.SUBJECT = ?");
                sql.append(" WHERE (RESOURCE.SUBJECT LIKE ?) ");
            }else{
                sql.append(" OR RESOURCE.SUBJECT = ?");
                sql.append(" AND (RESOURCE.SUBJECT LIKE ?) ");
            }
        }
        if(!_m_5){
            if(_m_7){
                _m_7 =  false;
                sql.append(" WHERE RESOURCE.INDUSTRY = ?");
                sql.append(" WHERE (RESOURCE.INDUSTRY LIKE ?) ");
            }else{
                sql.append(" OR RESOURCE.INDUSTRY = ?");
                sql.append(" AND (RESOURCE.INDUSTRY LIKE ?) ");
            }
        }
        StringBuilder _m_6 = sql;
            if(!_m_2){
                ps.setString(_m_3++,key);
            }
            if(!_m_2){
            	ps.setString(_m_3++,key);
            }
            if(!_m_2){
            	ps.setString(_m_3++,key);
            }
            if(!_m_4){
                ps.setString(_m_3++,subject);
            }
            if(!_m_2){
                ps.setString(_m_3++,key);
            }
            if(!_m_2){
            	ps.setString(_m_3++,key);
            }
            if(!_m_2){
            	ps.setString(_m_3++,key);
            }
            if(!_m_4){
                ps.setString(_m_3++,subject);
            }

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

//		return this.operationDao.queryDem(con, demandId);
//	}
	
	@Get
	@Path("/pqpro")
	public PageQueryResult<Operation> quetyPro(@JdbcConn(false) Connection con, @Nullable String id, 
			@DefaultValue("3") int pageSize, @DefaultValue("1") int pageNo) throws SQLException {
		return this.operationDao.queryPro(con, id, pageSize, pageNo);
	}
	
	@Get
	@Path("/pqdem")
	public PageQueryResult<Operation> queryDemPage(@JdbcConn Connection con, String demandId,