1

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

@@ -10,15 +10,22 @@ import java.util.Collections;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Column;
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.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryVal;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
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.GroupSqlColumn;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
import com.ekexiu.portal.po.Image;
@@ -30,7 +37,7 @@ import com.ekexiu.portal.po.Resource;
public abstract class OperationDao {
	@Autowrie
	private ImageDao imageDao;
	
	public ImageDao getImageDao() {
		return imageDao;
	}
@@ -41,833 +48,907 @@ public abstract class OperationDao {
	@Insert
	public abstract int insert(Connection con, Operation operation) throws SQLException;
	
	@Update
	public abstract int update(Connection con, Operation operation) throws SQLException;
	
	@UpdateWith
	@From(Operation.class)
	public abstract int updateDetailDemand(Connection con, String operationId, @Set String detailDemand) throws SQLException;
	
	@UpdateWith
	@From(Operation.class)
	public abstract int updateOperationStatus(Connection con, String operationId, @Set int operationStatus) throws SQLException;
	
	@UpdateWith
	@From(Operation.class)
	public abstract int updateDeliverTime(Connection con, String operationId, @Set String deliverTime) throws SQLException;
	
	@UpdateWith
	@From(Operation.class)
	public abstract int updateDealTime(Connection con, String operationId, @Set String dealTime) throws SQLException;
	
	@UpdateWith
	@From(Operation.class)
	public abstract int updatePayMethod(Connection con, String operationId, @Set String payMethod) throws SQLException;
	
	/**
	 * 查询有多少资源合作正在进行
	 * 
	 * @param con
	 * @param professorId 登陆者ID
	 * @param professorId
	 *            登陆者ID
	 * @return 返回正在合作的资源申请数量
	 * @throws SQLException
	 */
	public int queryOnGoingOper(Connection con, @Nullable String professorId) throws SQLException {
		String sql = " SELECT COUNT(1) FROM OPERATION O WHERE (OPERATION_STATUS IN (1,2,3,7)) "
				+ " AND (O.RESOURCE_ID IN (SELECT R.RESOURCE_ID FROM RESOURCE R WHERE R.PROFESSOR_ID = ?) "
				+ " OR O.DEMAND_ID = ?) ";
	@QueryVal
	@Column(value = "COUNT(1)", handlerClass = IntHandler.class)
	@From(Operation.class)
	@Where("OPERATION_STATUS IN (1,2,3,7)")
	@DefaultValue("0")
	public abstract int queryOnGoingOper(Connection con,
		@Nullable	 @GroupSqlColumn(value = { "RESOURCE_ID IN (SELECT R.RESOURCE_ID FROM RESOURCE R WHERE R.PROFESSOR_ID = ?)",
					"DEMAND_ID = ?" }, handlerClass = StringHandler.class, isAnd = false) String professorId)
			throws SQLException;
	public Operation query(Connection con, String operationId) throws SQLException {
		int index = 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 = ?";
		PreparedStatement ps = con.prepareStatement(sql);
		ps.setString(1, professorId);
		ps.setString(2, professorId);
		ResultSet rs = ps.executeQuery();
		rs.next();
		int count = rs.getInt(1);
		return count;
		try {
			ps.setString(index++, operationId);
			ResultSet rs = ps.executeQuery();
			try {
				if (rs.next()) {
					Operation operation = new Operation();
					operation.setReplyNotes(rs.getString(1));
					operation.setCreateTime(rs.getString(2));
					operation.setOperationId(rs.getString(3));
					operation.setOperationStatus(rs.getInt(4));
					Professor professor = new Professor();
					professor.setId(rs.getString(5));
					operation.setDetailDemand(rs.getString(6));
					operation.setDeliverTime(rs.getString(7));
					Resource resource = new Resource();
					resource.setResourceId(rs.getString(8));
					operation.setDealPrice(rs.getBigDecimal(9));
					operation.setDealTime(rs.getString(10));
					operation.setPayMethod(rs.getString(11));
					professor.setName(rs.getString(12));
					operation.setProfessor(professor);
					resource.setResourceName(rs.getString(13));
					Professor professor2 = new Professor();
					professor2.setId(rs.getString(14));
					professor2.setName(rs.getString(15));
					resource.setProfessor(professor2);
					operation.setResource(resource);
					operation.setApplysquare(rs.getString(16));
					return operation;
				} else {
					return null;
				}
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
	}
	
	public Operation query(Connection con,String operationId) throws SQLException{
        int index = 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 = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,operationId);
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    Operation operation = new Operation();
                    operation.setReplyNotes(rs.getString(1));
                    operation.setCreateTime(rs.getString(2));
                    operation.setOperationId(rs.getString(3));
                    operation.setOperationStatus(rs.getInt(4));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(5));
                    operation.setDetailDemand(rs.getString(6));
                    operation.setDeliverTime(rs.getString(7));
                    Resource resource = new Resource();
                    resource.setResourceId(rs.getString(8));
                    operation.setDealPrice(rs.getBigDecimal(9));
                    operation.setDealTime(rs.getString(10));
                    operation.setPayMethod(rs.getString(11));
                    professor.setName(rs.getString(12));
                    operation.setProfessor(professor);
                    resource.setResourceName(rs.getString(13));
                    Professor professor2 = new Professor();
                    professor2.setId(rs.getString(14));
                    professor2.setName(rs.getString(15));
                    resource.setProfessor(professor2);
                    operation.setResource(resource);
                    operation.setApplysquare(rs.getString(16));
                    return operation;
                }else{
                    return null;
                }
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
	
	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";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ResultSet rs = ps.executeQuery();
            try{
                List<Operation> operations = new ArrayList<Operation>();
                while(rs.next()){
                    Operation operation =  new Operation();
                    operation.setReplyNotes(rs.getString(1));
                    operation.setCreateTime(rs.getString(2));
                    operation.setOperationId(rs.getString(3));
                    operation.setOperationStatus(rs.getInt(4));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(5));
                    operation.setDetailDemand(rs.getString(6));
                    operation.setDeliverTime(rs.getString(7));
                    Resource resource = new Resource();
                    resource.setResourceId(rs.getString(8));
                    operation.setDealPrice(rs.getBigDecimal(9));
                    operation.setDealTime(rs.getString(10));
                    operation.setPayMethod(rs.getString(11));
                    professor.setName(rs.getString(12));
                    operation.setProfessor(professor);
                    resource.setResourceName(rs.getString(13));
                    Professor professor2 = new Professor();
                    professor2.setId(rs.getString(14));
                    professor2.setName(rs.getString(15));
                    resource.setProfessor(professor2);
                    operation.setResource(resource);
                    operation.setApplysquare(rs.getString(16));
                    operations.add(operation);
                }
                return operations;
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
	
	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";
		PreparedStatement ps = con.prepareStatement(sql);
		try {
			ResultSet rs = ps.executeQuery();
			try {
				List<Operation> operations = new ArrayList<Operation>();
				while (rs.next()) {
					Operation operation = new Operation();
					operation.setReplyNotes(rs.getString(1));
					operation.setCreateTime(rs.getString(2));
					operation.setOperationId(rs.getString(3));
					operation.setOperationStatus(rs.getInt(4));
					Professor professor = new Professor();
					professor.setId(rs.getString(5));
					operation.setDetailDemand(rs.getString(6));
					operation.setDeliverTime(rs.getString(7));
					Resource resource = new Resource();
					resource.setResourceId(rs.getString(8));
					operation.setDealPrice(rs.getBigDecimal(9));
					operation.setDealTime(rs.getString(10));
					operation.setPayMethod(rs.getString(11));
					professor.setName(rs.getString(12));
					operation.setProfessor(professor);
					resource.setResourceName(rs.getString(13));
					Professor professor2 = new Professor();
					professor2.setId(rs.getString(14));
					professor2.setName(rs.getString(15));
					resource.setProfessor(professor2);
					operation.setResource(resource);
					operation.setApplysquare(rs.getString(16));
					operations.add(operation);
				}
				return operations;
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
	}
	/**
	 * 搜索当前用户的所有资源申请（包括申请别人和别人申请自己的）
	 * 
	 * @param con
	 * @param id 登录用户ID
	 * @param id
	 *            登录用户ID
	 * @param pageSize
	 * @param pageNo
	 * @return 返回所有资源申请记录（包括申请别人和别人申请自己的）
	 * @throws SQLException
	 */
	public PageQueryResult<Operation> queryPro(Connection con, @Nullable String id,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
        int index = 1;
        boolean hasId = null != id;
        StringBuilder sql = new StringBuilder();
        if(hasId){
            sql.append(" WHERE O.RESOURCE_ID IN (SELECT R.RESOURCE_ID FROM RESOURCE R WHERE R.PROFESSOR_ID = ?) OR (O.DEMAND_ID = ?) ");
        }
        StringBuilder whereSql = sql;
        sql = new StringBuilder();
        sql.append(" SELECT COUNT(1) FROM OPERATION O ");
        if(whereSql.length()>0){
            sql.append(whereSql);
        }
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
            if(hasId){
                ps.setString(index++,id);
                ps.setString(index++,id);
            }
            queryResult.setPageSize(pageSize);
            ResultSet rs = ps.executeQuery();
            try{
                rs.next();
                total = rs.getInt(1);
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
        queryResult.setTotal(total);
        if(0== total){
        	queryResult.setPageNo(1);
        	queryResult.setData(Collections.<Operation>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.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(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY O.CREATE_TIME DESC ");
            sql.append(" LIMIT ").append(pageSize);
        }else{
            int pageNum = total / pageSize;
            if(total % pageSize != 0){
                ++pageNum;
            }
            if(pageNo > pageNum){
                pageNo = pageNum;
            }
            queryResult.setPageNo(pageNo);
            --pageNo;
            int offset = (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(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY O.CREATE_TIME DESC ");
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
        }
        ps = con.prepareStatement(sql.toString());
        try{
            if(hasId){
                ps.setString(index++,id);
                ps.setString(index++,id);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Operation> operations = new ArrayList<Operation>();
                queryResult.setData(operations);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Operation operation =  new Operation();
                    String replyNotes = rs.getString(1);
                    if(rs.wasNull()){
                    	replyNotes = null;
                    }
                    operation.setReplyNotes(replyNotes);
                    String applysqare = rs.getString(2);
                    if(rs.wasNull()){
                    	applysqare = null;
                    }
                    operation.setApplysquare(applysqare);
                    operation.setOperationId(rs.getString(3));
                    operation.setOperationStatus(rs.getInt(4));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(5));
                    operation.setDetailDemand(rs.getString(6));
                    operation.setDeliverTime(rs.getString(7));
                    Resource resource = new Resource();
                    resource.setResourceId(rs.getString(8));
                    BigDecimal dealPrice = rs.getBigDecimal(9);
                    if(rs.wasNull()){
                    	dealPrice = null;
                    }
                    operation.setDealPrice(dealPrice);
                    String dealTime = rs.getString(10);
                    if(rs.wasNull()){
                    	dealTime = null;
                    }
                    operation.setDealTime(dealTime);
                    String payMethod = rs.getString(11);
                    if(rs.wasNull()){
                    	payMethod = null;
                    }
                    operation.setPayMethod(payMethod);
                    operation.setCreateTime(rs.getString(12));
                    resource.setResourceName(rs.getString(13));
                    resource.setSupportedServices(rs.getString(14));
                    resource.setDescp(rs.getString(15));
                    List<Image> images = this.imageDao.queryRes(con, resource.getResourceId());
                    resource.setImages(images);
                    Professor professor2 = new Professor();
                    professor2.setId(rs.getString(16));
                    professor.setName(rs.getString(17));
                    operation.setProfessor(professor);
                    professor2.setName(rs.getString(18));
                    resource.setProfessor(professor2);
                    operation.setResource(resource);
                    operations.add(operation);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	
	public PageQueryResult<Operation> queryPro(Connection con, @Nullable String id, int pageSize, int pageNo) throws SQLException {
		int total = 0;
		PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
		int index = 1;
		boolean hasId = null != id;
		StringBuilder sql = new StringBuilder();
		if (hasId) {
			sql.append(" WHERE O.RESOURCE_ID IN (SELECT R.RESOURCE_ID FROM RESOURCE R WHERE R.PROFESSOR_ID = ?) OR (O.DEMAND_ID = ?) ");
		}
		StringBuilder whereSql = sql;
		sql = new StringBuilder();
		sql.append(" SELECT COUNT(1) FROM OPERATION O ");
		if (whereSql.length() > 0) {
			sql.append(whereSql);
		}
		PreparedStatement ps = con.prepareStatement(sql.toString());
		try {
			if (hasId) {
				ps.setString(index++, id);
				ps.setString(index++, id);
			}
			queryResult.setPageSize(pageSize);
			ResultSet rs = ps.executeQuery();
			try {
				rs.next();
				total = rs.getInt(1);
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
		queryResult.setTotal(total);
		if (0 == total) {
			queryResult.setPageNo(1);
			queryResult.setData(Collections.<Operation> emptyList());
			return queryResult;
		}
		index = 1;
		boolean firstPage = (1 == pageNo);
		if (firstPage) {
			queryResult.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 (whereSql.length() > 0) {
				sql.append(whereSql);
			}
			sql.append(" ORDER BY O.CREATE_TIME DESC ");
			sql.append(" LIMIT ").append(pageSize);
		} else {
			int pageNum = total / pageSize;
			if (total % pageSize != 0) {
				++pageNum;
			}
			if (pageNo > pageNum) {
				pageNo = pageNum;
			}
			queryResult.setPageNo(pageNo);
			--pageNo;
			int offset = (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 (whereSql.length() > 0) {
				sql.append(whereSql);
			}
			sql.append(" ORDER BY O.CREATE_TIME DESC ");
			sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
		}
		ps = con.prepareStatement(sql.toString());
		try {
			if (hasId) {
				ps.setString(index++, id);
				ps.setString(index++, id);
			}
			ResultSet rs = ps.executeQuery();
			try {
				List<Operation> operations = new ArrayList<Operation>();
				queryResult.setData(operations);
				int size = 0;
				while ((size < pageSize) && rs.next()) {
					++size;
					Operation operation = new Operation();
					String replyNotes = rs.getString(1);
					if (rs.wasNull()) {
						replyNotes = null;
					}
					operation.setReplyNotes(replyNotes);
					String applysqare = rs.getString(2);
					if (rs.wasNull()) {
						applysqare = null;
					}
					operation.setApplysquare(applysqare);
					operation.setOperationId(rs.getString(3));
					operation.setOperationStatus(rs.getInt(4));
					Professor professor = new Professor();
					professor.setId(rs.getString(5));
					operation.setDetailDemand(rs.getString(6));
					operation.setDeliverTime(rs.getString(7));
					Resource resource = new Resource();
					resource.setResourceId(rs.getString(8));
					BigDecimal dealPrice = rs.getBigDecimal(9);
					if (rs.wasNull()) {
						dealPrice = null;
					}
					operation.setDealPrice(dealPrice);
					String dealTime = rs.getString(10);
					if (rs.wasNull()) {
						dealTime = null;
					}
					operation.setDealTime(dealTime);
					String payMethod = rs.getString(11);
					if (rs.wasNull()) {
						payMethod = null;
					}
					operation.setPayMethod(payMethod);
					operation.setCreateTime(rs.getString(12));
					resource.setResourceName(rs.getString(13));
					resource.setSupportedServices(rs.getString(14));
					resource.setDescp(rs.getString(15));
					List<Image> images = this.imageDao.queryRes(con, resource.getResourceId());
					resource.setImages(images);
					Professor professor2 = new Professor();
					professor2.setId(rs.getString(16));
					professor.setName(rs.getString(17));
					operation.setProfessor(professor);
					professor2.setName(rs.getString(18));
					resource.setProfessor(professor2);
					operation.setResource(resource);
					operations.add(operation);
				}
				return queryResult;
			} finally {
				try {
					rs.close();
				} catch (Exception e3) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e4) {
			}
		}
	}
	/**
	 * 分页按资源申请者ID查资源申请
	 * 
	 * @param con
	 * @param demandId 资源申请者ID
	 * @param pageSize 每页记录数
	 * @param pageNo 当前页码
	 * @param demandId
	 *            资源申请者ID
	 * @param pageSize
	 *            每页记录数
	 * @param pageNo
	 *            当前页码
	 * @return 返回该用户ID申请的所有资源
	 * @throws SQLException
	 */
	public PageQueryResult<Operation> queryDemPage(Connection con,String demandId,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
        int index = 1;
        String sql = null;
        sql = "  WHERE OPERATION.DEMAND_ID = ?        ";
        String whereSql = sql;
        sql = "SELECT COUNT(1) FROM OPERATION";
        sql = sql + whereSql;
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,demandId);
            queryResult.setPageSize(pageSize);
            ResultSet rs = ps.executeQuery();
            try{
                rs.next();
                total = rs.getInt(1);
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
        queryResult.setTotal(total);
        if(0== total){
        	queryResult.setPageNo(1);
        	queryResult.setData(Collections.<Operation>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
            sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,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 "
            		+ " 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";
            sql = sql + whereSql;
            sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
            sql = sql + " LIMIT " + pageSize;
        }else{
            int pageNum = total / pageSize;
            if(total % pageSize != 0){
                ++pageNum;
            }
            if(pageNo > pageNum){
                pageNo = pageNum;
            }
            queryResult.setPageNo(pageNo);
            --pageNo;
            int offset = (pageNo * pageSize);
            sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,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 "
            		+ " 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";
            sql = sql + whereSql;
            sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
            sql = sql + " LIMIT " + pageSize+ " OFFSET "+ offset;
        }
        ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,demandId);
            ResultSet rs = ps.executeQuery();
            try{
                List<Operation> operations = new ArrayList<Operation>();
                queryResult.setData(operations);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Operation operation =  new Operation();
                    String replyNotes = rs.getString(1);
                    if(rs.wasNull()){
                    	replyNotes = null;
                    }
                    operation.setReplyNotes(replyNotes);
                    operation.setCreateTime(rs.getString(2));
                    String applysquare = rs.getString(3);
                    if(rs.wasNull()){
                    	applysquare = null;
                    }
                    operation.setApplysquare(applysquare);
                    operation.setOperationId(rs.getString(4));
                    operation.setOperationStatus(rs.getInt(5));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(6));
                    operation.setDetailDemand(rs.getString(7));
                    operation.setDeliverTime(rs.getString(8));
                    Resource resource = new Resource();
	public PageQueryResult<Operation> queryDemPage(Connection con, String demandId, int pageSize, int pageNo) throws SQLException {
		int total = 0;
		PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
		int index = 1;
		String sql = null;
		sql = "  WHERE OPERATION.DEMAND_ID = ?        ";
		String whereSql = sql;
		sql = "SELECT COUNT(1) FROM OPERATION";
		sql = sql + whereSql;
		PreparedStatement ps = con.prepareStatement(sql);
		try {
			ps.setString(index++, demandId);
			queryResult.setPageSize(pageSize);
			ResultSet rs = ps.executeQuery();
			try {
				rs.next();
				total = rs.getInt(1);
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
		queryResult.setTotal(total);
		if (0 == total) {
			queryResult.setPageNo(1);
			queryResult.setData(Collections.<Operation> emptyList());
			return queryResult;
		}
		index = 1;
		boolean firstPage = (1 == pageNo);
		if (firstPage) {
			queryResult.setPageNo(1);
			sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,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 " + " 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";
			sql = sql + whereSql;
			sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
			sql = sql + " LIMIT " + pageSize;
		} else {
			int pageNum = total / pageSize;
			if (total % pageSize != 0) {
				++pageNum;
			}
			if (pageNo > pageNum) {
				pageNo = pageNum;
			}
			queryResult.setPageNo(pageNo);
			--pageNo;
			int offset = (pageNo * pageSize);
			sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,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 " + " 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";
			sql = sql + whereSql;
			sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
			sql = sql + " LIMIT " + pageSize + " OFFSET " + offset;
		}
		ps = con.prepareStatement(sql);
		try {
			ps.setString(index++, demandId);
			ResultSet rs = ps.executeQuery();
			try {
				List<Operation> operations = new ArrayList<Operation>();
				queryResult.setData(operations);
				int size = 0;
				while ((size < pageSize) && rs.next()) {
					++size;
					Operation operation = new Operation();
					String replyNotes = rs.getString(1);
					if (rs.wasNull()) {
						replyNotes = null;
					}
					operation.setReplyNotes(replyNotes);
					operation.setCreateTime(rs.getString(2));
					String applysquare = rs.getString(3);
					if (rs.wasNull()) {
						applysquare = null;
					}
					operation.setApplysquare(applysquare);
					operation.setOperationId(rs.getString(4));
					operation.setOperationStatus(rs.getInt(5));
					Professor professor = new Professor();
					professor.setId(rs.getString(6));
					operation.setDetailDemand(rs.getString(7));
					operation.setDeliverTime(rs.getString(8));
					Resource resource = new Resource();
					resource.setResourceId(rs.getString(9));
                    BigDecimal dealPrice = rs.getBigDecimal(10);
                    if(rs.wasNull()){
                    	dealPrice = null;
                    }
                    operation.setDealPrice(dealPrice);
                    String dealTime = rs.getString(11);
                    if(rs.wasNull()){
                    	dealTime = null;
                    }
                    operation.setDealTime(dealTime);
                    String payMethod = rs.getString(12);
                    if(rs.wasNull()){
                    	payMethod = null;
                    }
                    operation.setPayMethod(payMethod);
                    professor.setName(rs.getString(13));
                    operation.setProfessor(professor);
					BigDecimal dealPrice = rs.getBigDecimal(10);
					if (rs.wasNull()) {
						dealPrice = null;
					}
					operation.setDealPrice(dealPrice);
					String dealTime = rs.getString(11);
					if (rs.wasNull()) {
						dealTime = null;
					}
					operation.setDealTime(dealTime);
					String payMethod = rs.getString(12);
					if (rs.wasNull()) {
						payMethod = null;
					}
					operation.setPayMethod(payMethod);
					professor.setName(rs.getString(13));
					operation.setProfessor(professor);
					resource.setResourceName(rs.getString(14));
					Professor professor2 = new Professor();
                    professor2.setId(rs.getString(15));
                    professor2.setName(rs.getString(16));
                    resource.setProfessor(professor2);
					professor2.setId(rs.getString(15));
					professor2.setName(rs.getString(16));
					resource.setProfessor(professor2);
					operation.setResource(resource);
					operations.add(operation);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	
				}
				return queryResult;
			} finally {
				try {
					rs.close();
				} catch (Exception e3) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e4) {
			}
		}
	}
	/**
	 * 分页按资源ID查资源申请，返回资申请人姓名和资源名称
	 * 
	 * @param con
	 * @param resourceId 资源ID
	 * @param pageSize 每页记录数
	 * @param pageNo 当前页码
	 * @param resourceId
	 *            资源ID
	 * @param pageSize
	 *            每页记录数
	 * @param pageNo
	 *            当前页码
	 * @return 返回当前资源ID下的所有资源申请记录
	 * @throws SQLException
	 */
	public PageQueryResult<Operation> queryResPage(Connection con,String resourceId,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
        int index = 1;
        String sql = null;
        sql = " WHERE OPERATION.RESOURCE_ID = ? ";
        String whereSql = sql;
        sql = "SELECT COUNT(1) FROM OPERATION";
        sql = sql + whereSql;
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,resourceId);
            queryResult.setPageSize(pageSize);
            ResultSet rs = ps.executeQuery();
            try{
                rs.next();
                total = rs.getInt(1);
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
        queryResult.setTotal(total);
        if(0== total){
        	queryResult.setPageNo(1);
        	queryResult.setData(Collections.<Operation>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
            sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,OPERATION.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 "
            		+ " 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 ";
            sql = sql + whereSql;
            sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
            sql = sql + " LIMIT " + pageSize;
        }else{
            int pageNum = total / pageSize;
            if(total % pageSize != 0){
                ++pageNum;
            }
            if(pageNo > pageNum){
                pageNo = pageNum;
            }
            queryResult.setPageNo(pageNo);
            --pageNo;
            int offset = (pageNo * pageSize);
            sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,OPERATION.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 "
            		+ " 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";
            sql = sql + whereSql;
            sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
            sql = sql + " LIMIT " + pageSize+ " OFFSET "+ offset;
        }
        ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,resourceId);
            ResultSet rs = ps.executeQuery();
            try{
                List<Operation> operations = new ArrayList<Operation>();
                queryResult.setData(operations);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Operation operation =  new Operation();
                    String replyNotes = rs.getString(1);
                    if(rs.wasNull()){
                    	replyNotes = null;
                    }
                    operation.setReplyNotes(replyNotes);
                    operation.setCreateTime(rs.getString(2));
                    String applyaquare = rs.getString(3);
                    if(rs.wasNull()){
                    	applyaquare = null;
                    }
                    operation.setApplysquare(applyaquare);
                    operation.setOperationId(rs.getString(4));
                    operation.setOperationStatus(rs.getInt(5));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(6));
                    operation.setDetailDemand(rs.getString(7));
                    operation.setDeliverTime(rs.getString(8));
                    Resource resource = new Resource();
	public PageQueryResult<Operation> queryResPage(Connection con, String resourceId, int pageSize, int pageNo) throws SQLException {
		int total = 0;
		PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
		int index = 1;
		String sql = null;
		sql = " WHERE OPERATION.RESOURCE_ID = ? ";
		String whereSql = sql;
		sql = "SELECT COUNT(1) FROM OPERATION";
		sql = sql + whereSql;
		PreparedStatement ps = con.prepareStatement(sql);
		try {
			ps.setString(index++, resourceId);
			queryResult.setPageSize(pageSize);
			ResultSet rs = ps.executeQuery();
			try {
				rs.next();
				total = rs.getInt(1);
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
		queryResult.setTotal(total);
		if (0 == total) {
			queryResult.setPageNo(1);
			queryResult.setData(Collections.<Operation> emptyList());
			return queryResult;
		}
		index = 1;
		boolean firstPage = (1 == pageNo);
		if (firstPage) {
			queryResult.setPageNo(1);
			sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,OPERATION.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 " + " 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 ";
			sql = sql + whereSql;
			sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
			sql = sql + " LIMIT " + pageSize;
		} else {
			int pageNum = total / pageSize;
			if (total % pageSize != 0) {
				++pageNum;
			}
			if (pageNo > pageNum) {
				pageNo = pageNum;
			}
			queryResult.setPageNo(pageNo);
			--pageNo;
			int offset = (pageNo * pageSize);
			sql = "SELECT REPLY_NOTES,OPERATION.CREATE_TIME,APPLYSQUARE,OPERATION.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 " + " 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";
			sql = sql + whereSql;
			sql = sql + "ORDER BY OPERATION.CREATE_TIME DESC";
			sql = sql + " LIMIT " + pageSize + " OFFSET " + offset;
		}
		ps = con.prepareStatement(sql);
		try {
			ps.setString(index++, resourceId);
			ResultSet rs = ps.executeQuery();
			try {
				List<Operation> operations = new ArrayList<Operation>();
				queryResult.setData(operations);
				int size = 0;
				while ((size < pageSize) && rs.next()) {
					++size;
					Operation operation = new Operation();
					String replyNotes = rs.getString(1);
					if (rs.wasNull()) {
						replyNotes = null;
					}
					operation.setReplyNotes(replyNotes);
					operation.setCreateTime(rs.getString(2));
					String applyaquare = rs.getString(3);
					if (rs.wasNull()) {
						applyaquare = null;
					}
					operation.setApplysquare(applyaquare);
					operation.setOperationId(rs.getString(4));
					operation.setOperationStatus(rs.getInt(5));
					Professor professor = new Professor();
					professor.setId(rs.getString(6));
					operation.setDetailDemand(rs.getString(7));
					operation.setDeliverTime(rs.getString(8));
					Resource resource = new Resource();
					resource.setResourceId(rs.getString(9));
                    BigDecimal dealPrice = rs.getBigDecimal(10);
                    if(rs.wasNull()){
                    	dealPrice = null;
                    }
                    operation.setDealPrice(dealPrice);
                    String dealTime = rs.getString(11);
                    if(rs.wasNull()){
                    	dealTime = null;
                    }
                    operation.setDealTime(dealTime);
                    String payMethod = rs.getString(12);
                    if(rs.wasNull()){
                    	payMethod = null;
                    }
                    operation.setPayMethod(payMethod);
                    professor.setName(rs.getString(13));
                    operation.setProfessor(professor);
					BigDecimal dealPrice = rs.getBigDecimal(10);
					if (rs.wasNull()) {
						dealPrice = null;
					}
					operation.setDealPrice(dealPrice);
					String dealTime = rs.getString(11);
					if (rs.wasNull()) {
						dealTime = null;
					}
					operation.setDealTime(dealTime);
					String payMethod = rs.getString(12);
					if (rs.wasNull()) {
						payMethod = null;
					}
					operation.setPayMethod(payMethod);
					professor.setName(rs.getString(13));
					operation.setProfessor(professor);
					resource.setResourceName(rs.getString(14));
					Professor professor2 = new Professor();
                    professor2.setId(rs.getString(15));
                    professor2.setName(rs.getString(16));
                    resource.setProfessor(professor2);
					professor2.setId(rs.getString(15));
					professor2.setName(rs.getString(16));
					resource.setProfessor(professor2);
					operation.setResource(resource);
					operations.add(operation);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	
				}
				return queryResult;
			} finally {
				try {
					rs.close();
				} catch (Exception e3) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e4) {
			}
		}
	}
	@SelectList
	public abstract List<Operation> queryResourceId(Connection con, String resourceId) throws SQLException;
	
	@DeleteWith
	@From(Operation.class)
	public abstract int delete(Connection con, String operationId) throws SQLException;
	
	/**
	 * 获取当前资源申请的状态值。
	 * 
	 * @param con
	 * @param operationId 资源申请ID
	 * @param operationId
	 *            资源申请ID
	 * @return 返回资源申请状态值
	 * @throws SQLException
	 */
	public int queryOper(Connection con, String operationId) throws SQLException{
	public int queryOper(Connection con, String operationId) throws SQLException {
		String sql = "SELECT OPERATION_STATUS FROM OPERATION WHERE OPERATION_ID = ?";
		PreparedStatement ps = con.prepareStatement(sql);
		try {
			ps.setString(1, operationId);
			ResultSet rs = ps.executeQuery();
			try{
			try {
				rs.next();
				return rs.getInt(1);
			}finally{
                try{rs.close();}catch(Exception e1){}
            }
		}finally{
            try{ps.close();}catch(Exception e2){}
        }
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
	}
	public int deleteDem(Connection con, String operationId, String demandId) throws SQLException {
		int index = 1;
		String sql = "DELETE FROM OPERATION WHERE OPERATION_STATUS = 1 AND DEMAND_ID = ? AND OPERATION_ID = ?";
		PreparedStatement ps = con.prepareStatement(sql);
		try {
			ps.setString(index++, demandId);
			ps.setString(index++, operationId);
			return ps.executeUpdate();
		} finally {
			try {
				ps.close();
			} catch (Exception e) {
			}
		}
	}
	
	public int deleteDem(Connection con,String operationId,String demandId) throws SQLException{
        int index = 1;
        String sql = "DELETE FROM OPERATION WHERE OPERATION_STATUS = 1 AND DEMAND_ID = ? AND OPERATION_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,demandId);
            ps.setString(index++,operationId);
            return ps.executeUpdate();
        }finally{
            try{ps.close();}catch(Exception e){}
        }
    }
	
	/**
	 * 分页查询资源申请 多条件模糊查询
	 * 
	 * @param con
	 * @param professorName 申请人姓名
	 * @param resourceName 资源名称
	 * @param firstTime 申请时间 查询初试时间
	 * @param lastTime 申请时间 查询结束时间
	 * @param lowPrice 成交价格 查询较低价格
	 * @param highPrice 成交时间 查询较高价格
	 * @param pageSize 每页记录数
	 * @param pageNo 当前页码
	 * @param professorName
	 *            申请人姓名
	 * @param resourceName
	 *            资源名称
	 * @param firstTime
	 *            申请时间 查询初试时间
	 * @param lastTime
	 *            申请时间 查询结束时间
	 * @param lowPrice
	 *            成交价格 查询较低价格
	 * @param highPrice
	 *            成交时间 查询较高价格
	 * @param pageSize
	 *            每页记录数
	 * @param pageNo
	 *            当前页码
	 * @return
	 * @throws 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 total = 0;
        PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
        int index = 1;
        boolean hasProName = null != professorName;
        boolean hasResName = null != resourceName;
        boolean hasFirstTime = null != firstTime;
        boolean hasLastTime = null != lastTime;
        boolean hasLowPrice = null != lowPrice;
        boolean hasHighPrice = null != highPrice;
        StringBuilder sql = new StringBuilder();
        boolean hasWhere = true;
        if(hasProName){
        	hasWhere =  false;
            sql.append(" WHERE DEMAND_ID (SELECT PROFESSOR.PROFESSOR.ID FROM PROFESSOR WHERE PROFESSOR.NAME LIKE ?)");
        }
        if(hasResName){
            if(hasWhere){
            	hasWhere =  false;
                sql.append(" WHERE OPERATION.RESOURCE_ID IN (SELECT RESOURCE.RESOURCE_ID FROM RESOURCE WHERE RESOURCE_NAME LIKE ?)");
            }else{
                sql.append(" OR OPERATION.RESOURCE_ID IN (SELECT RESOURCE.RESOURCE_ID FROM RESOURCE WHERE RESOURCE_NAME LIKE ?)");
            }
        }
        if(hasFirstTime){
            if(hasWhere){
            	hasWhere =  false;
                sql.append(" WHERE OPERATION.CREATE_TIME > ?");
            }else{
                sql.append(" AND OPERATION.CREATE_TIME > ?");
            }
        }
        if(hasLastTime){
            if(hasWhere){
            	hasWhere =  false;
                sql.append(" WHERE OPERATION.CREATE_TIME <= ?");
            }else{
                sql.append(" AND OPERATION.CREATE_TIME <= ?");
            }
        }
        if(hasLowPrice){
            if(hasWhere){
            	hasWhere =  false;
                sql.append(" WHERE DEAL_PRICE > ?");
            }else{
                sql.append(" AND DEAL_PRICE > ?");
            }
        }
        if(hasHighPrice){
            if(hasWhere){
            	hasWhere =  false;
                sql.append(" WHERE DEAL_PRICE <= ?");
            }else{
                sql.append(" AND DEAL_PRICE <= ?");
            }
        }
        StringBuilder whereSql = sql;
        sql = new StringBuilder();
        sql.append("SELECT COUNT(1) FROM OPERATION");
        if(whereSql.length()>0){
            sql.append(whereSql);
        }
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
            if(hasProName){
                ps.setString(index++,professorName);
            }
            if(hasResName){
                ps.setString(index++,resourceName);
            }
            if(hasFirstTime){
                ps.setString(index++,firstTime);
            }
            if(hasLastTime){
                ps.setString(index++,lastTime);
            }
            if(hasLowPrice){
                ps.setBigDecimal(index++,lowPrice);
            }
            if(hasHighPrice){
                ps.setBigDecimal(index++,highPrice);
            }
            queryResult.setPageSize(pageSize);
            ResultSet rs = ps.executeQuery();
            try{
                rs.next();
                total = rs.getInt(1);
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
        queryResult.setTotal(total);
        if(0== total){
        	queryResult.setPageNo(1);
        	queryResult.setData(Collections.<Operation>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
            sql = new StringBuilder();
            sql.append("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 LEFT JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID "
            		+ " LEFT JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID "
            		+ " LEFT JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID");
            if(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY OPERATION.CREATE_TIME");
            sql.append(" LIMIT ").append(pageSize);
        }else{
            int pageNum = total / pageSize;
            if(total % pageSize != 0){
                ++pageNum;
            }
            if(pageNo > pageNum){
                pageNo = pageNum;
            }
            queryResult.setPageNo(pageNo);
            --pageNo;
            int offset = (pageNo * pageSize);
            sql = new StringBuilder();
            sql.append("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 LEFT JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID "
            		+ " LEFT JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID "
            		+ " LEFT JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID");
            if(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY OPERATION.CREATE_TIME");
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
        }
        ps = con.prepareStatement(sql.toString());
        try{
            if(hasProName){
                ps.setString(index++,professorName);
            }
            if(hasResName){
                ps.setString(index++,resourceName);
            }
            if(hasFirstTime){
                ps.setString(index++,firstTime);
            }
            if(hasLastTime){
                ps.setString(index++,lastTime);
            }
            if(hasLowPrice){
                ps.setBigDecimal(index++,lowPrice);
            }
            if(hasHighPrice){
                ps.setBigDecimal(index++,highPrice);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Operation> operations = new ArrayList<Operation>();
                queryResult.setData(operations);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Operation operation =  new Operation();
                    operation.setReplyNotes(rs.getString(1));
                    operation.setCreateTime(rs.getString(2));
                    operation.setOperationId(rs.getString(3));
                    operation.setOperationStatus(rs.getInt(4));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(5));
                    operation.setDetailDemand(rs.getString(6));
                    operation.setDeliverTime(rs.getString(7));
                    Resource resource = new Resource();
                    resource.setResourceId(rs.getString(8));
                    operation.setDealPrice(rs.getBigDecimal(9));
                    operation.setDealTime(rs.getString(10));
                    operation.setPayMethod(rs.getString(11));
                    professor.setName(rs.getString(12));
                    operation.setProfessor(professor);
                    resource.setResourceName(rs.getString(13));
                    Professor professor2 = new Professor();
                    professor2.setId(rs.getString(14));
                    professor2.setName(rs.getString(15));
                    resource.setProfessor(professor2);
                    operation.setResource(resource);
                    operation.setApplysquare(rs.getString(16));
                    operations.add(operation);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	
	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 total = 0;
		PageQueryResult<Operation> queryResult = new PageQueryResult<Operation>();
		int index = 1;
		boolean hasProName = null != professorName;
		boolean hasResName = null != resourceName;
		boolean hasFirstTime = null != firstTime;
		boolean hasLastTime = null != lastTime;
		boolean hasLowPrice = null != lowPrice;
		boolean hasHighPrice = null != highPrice;
		StringBuilder sql = new StringBuilder();
		boolean hasWhere = true;
		if (hasProName) {
			hasWhere = false;
			sql.append(" WHERE DEMAND_ID (SELECT PROFESSOR.PROFESSOR.ID FROM PROFESSOR WHERE PROFESSOR.NAME LIKE ?)");
		}
		if (hasResName) {
			if (hasWhere) {
				hasWhere = false;
				sql.append(" WHERE OPERATION.RESOURCE_ID IN (SELECT RESOURCE.RESOURCE_ID FROM RESOURCE WHERE RESOURCE_NAME LIKE ?)");
			} else {
				sql.append(" OR OPERATION.RESOURCE_ID IN (SELECT RESOURCE.RESOURCE_ID FROM RESOURCE WHERE RESOURCE_NAME LIKE ?)");
			}
		}
		if (hasFirstTime) {
			if (hasWhere) {
				hasWhere = false;
				sql.append(" WHERE OPERATION.CREATE_TIME > ?");
			} else {
				sql.append(" AND OPERATION.CREATE_TIME > ?");
			}
		}
		if (hasLastTime) {
			if (hasWhere) {
				hasWhere = false;
				sql.append(" WHERE OPERATION.CREATE_TIME <= ?");
			} else {
				sql.append(" AND OPERATION.CREATE_TIME <= ?");
			}
		}
		if (hasLowPrice) {
			if (hasWhere) {
				hasWhere = false;
				sql.append(" WHERE DEAL_PRICE > ?");
			} else {
				sql.append(" AND DEAL_PRICE > ?");
			}
		}
		if (hasHighPrice) {
			if (hasWhere) {
				hasWhere = false;
				sql.append(" WHERE DEAL_PRICE <= ?");
			} else {
				sql.append(" AND DEAL_PRICE <= ?");
			}
		}
		StringBuilder whereSql = sql;
		sql = new StringBuilder();
		sql.append("SELECT COUNT(1) FROM OPERATION");
		if (whereSql.length() > 0) {
			sql.append(whereSql);
		}
		PreparedStatement ps = con.prepareStatement(sql.toString());
		try {
			if (hasProName) {
				ps.setString(index++, professorName);
			}
			if (hasResName) {
				ps.setString(index++, resourceName);
			}
			if (hasFirstTime) {
				ps.setString(index++, firstTime);
			}
			if (hasLastTime) {
				ps.setString(index++, lastTime);
			}
			if (hasLowPrice) {
				ps.setBigDecimal(index++, lowPrice);
			}
			if (hasHighPrice) {
				ps.setBigDecimal(index++, highPrice);
			}
			queryResult.setPageSize(pageSize);
			ResultSet rs = ps.executeQuery();
			try {
				rs.next();
				total = rs.getInt(1);
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}
		queryResult.setTotal(total);
		if (0 == total) {
			queryResult.setPageNo(1);
			queryResult.setData(Collections.<Operation> emptyList());
			return queryResult;
		}
		index = 1;
		boolean firstPage = (1 == pageNo);
		if (firstPage) {
			queryResult.setPageNo(1);
			sql = new StringBuilder();
			sql.append("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 LEFT JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID "
					+ " LEFT JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID " + " LEFT JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID");
			if (whereSql.length() > 0) {
				sql.append(whereSql);
			}
			sql.append(" ORDER BY OPERATION.CREATE_TIME");
			sql.append(" LIMIT ").append(pageSize);
		} else {
			int pageNum = total / pageSize;
			if (total % pageSize != 0) {
				++pageNum;
			}
			if (pageNo > pageNum) {
				pageNo = pageNum;
			}
			queryResult.setPageNo(pageNo);
			--pageNo;
			int offset = (pageNo * pageSize);
			sql = new StringBuilder();
			sql.append("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 LEFT JOIN PROFESSOR P1 ON DEMAND_ID = P1.ID "
					+ " LEFT JOIN RESOURCE ON OPERATION.RESOURCE_ID = RESOURCE.RESOURCE_ID " + " LEFT JOIN PROFESSOR P2 ON RESOURCE.PROFESSOR_ID = P2.ID");
			if (whereSql.length() > 0) {
				sql.append(whereSql);
			}
			sql.append(" ORDER BY OPERATION.CREATE_TIME");
			sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
		}
		ps = con.prepareStatement(sql.toString());
		try {
			if (hasProName) {
				ps.setString(index++, professorName);
			}
			if (hasResName) {
				ps.setString(index++, resourceName);
			}
			if (hasFirstTime) {
				ps.setString(index++, firstTime);
			}
			if (hasLastTime) {
				ps.setString(index++, lastTime);
			}
			if (hasLowPrice) {
				ps.setBigDecimal(index++, lowPrice);
			}
			if (hasHighPrice) {
				ps.setBigDecimal(index++, highPrice);
			}
			ResultSet rs = ps.executeQuery();
			try {
				List<Operation> operations = new ArrayList<Operation>();
				queryResult.setData(operations);
				int size = 0;
				while ((size < pageSize) && rs.next()) {
					++size;
					Operation operation = new Operation();
					operation.setReplyNotes(rs.getString(1));
					operation.setCreateTime(rs.getString(2));
					operation.setOperationId(rs.getString(3));
					operation.setOperationStatus(rs.getInt(4));
					Professor professor = new Professor();
					professor.setId(rs.getString(5));
					operation.setDetailDemand(rs.getString(6));
					operation.setDeliverTime(rs.getString(7));
					Resource resource = new Resource();
					resource.setResourceId(rs.getString(8));
					operation.setDealPrice(rs.getBigDecimal(9));
					operation.setDealTime(rs.getString(10));
					operation.setPayMethod(rs.getString(11));
					professor.setName(rs.getString(12));
					operation.setProfessor(professor);
					resource.setResourceName(rs.getString(13));
					Professor professor2 = new Professor();
					professor2.setId(rs.getString(14));
					professor2.setName(rs.getString(15));
					resource.setProfessor(professor2);
					operation.setResource(resource);
					operation.setApplysquare(rs.getString(16));
					operations.add(operation);
				}
				return queryResult;
			} finally {
				try {
					rs.close();
				} catch (Exception e3) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e4) {
			}
		}
	}
}

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

@@ -28,6 +28,7 @@ import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
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.GroupSqlColumn;
import org.jfw.apt.orm.annotation.dao.param.In;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.orm.annotation.dao.param.Set;
@@ -217,194 +218,18 @@ public abstract class OrgDao {
					"(ID IN (SELECT ORG_ID FROM RESOURCE WHERE RESOURCE_TYPE='2' AND RESOURCE_NAME LIKE ?) AND IS_JOIN ='1')",
					"(ID IN (SELECT ORG_ID FROM ARTICLE WHERE ARTICLE_TYPE='2' AND ARTICLE_TITLE LIKE ?) AND IS_JOIN ='1')" }) String kw,
			int pageSize, int pageNo) throws SQLException;
	
	
	public PageQueryResult<EditOrganization> queryByKwAndIndustryAndAddr(Connection con,String kw,String industry,String addr,int pageSize,int pageNo)throws SQLException{
		  int _m_1 = 0;
	        org.jfw.util.PageQueryResult<com.ekexiu.portal.pojo.EditOrganization> _result = new org.jfw.util.PageQueryResult<com.ekexiu.portal.pojo.EditOrganization>();
	        int _m_2 = 1;
	        String sql = null;
	        sql = "  WHERE INDUSTRY LIKE ? AND ADDR LIKE ? AND ((ID IN (SELECT ORG_ID FROM ARTICLE WHERE ARTICLE_TYPE='2' AND ARTICLE_TITLE LIKE ?) AND IS_JOIN ='1') OR (ID IN (SELECT ORG_ID FROM RESOURCE WHERE RESOURCE_TYPE='2' AND RESOURCE_NAME LIKE ?) AND IS_JOIN ='1') OR (industry LIKE ?  AND IS_JOIN ='1') OR (SUBJECT LIKE ? AND IS_JOIN ='1') OR (DESCP LIKE ?  AND IS_JOIN ='1') OR (FOR_SHORT LIKE ? AND IS_JOIN ='1') OR (NAME LIKE ? AND IS_JOIN ='1'))";
	        String _m_3 = sql;
	        sql = "SELECT COUNT(1) FROM ORGANIZATION";
	        sql = sql + _m_3;
	        java.sql.PreparedStatement ps = con.prepareStatement(sql);
	        try{
	            ps.setString(_m_2++,industry);	
	            ps.setString(_m_2++,addr);	        	
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            _result.setPageSize(pageSize);
	            java.sql.ResultSet _pageRs = ps.executeQuery();
	            try{
	                _pageRs.next();
	                _m_1 = _pageRs.getInt(1);
	            }finally{
	                try{_pageRs.close();}catch(Exception _m_4){}
	            }
	        }finally{
	            try{ps.close();}catch(Exception _m_5){}
	        }
	        _result.setTotal(_m_1);
	        if(0== _m_1){
	            _result.setPageNo(1);
	            _result.setData(java.util.Collections.<com.ekexiu.portal.pojo.EditOrganization>emptyList());
	            return _result;
	        }
	        _m_2 = 1;
	        boolean _m_6 = (1 == pageNo);
	        if(_m_6){
	            _result.setPageNo(1);
	            sql = "SELECT FOR_SHORT,ORG_URL,FOUND_TIME,PROVINCE,CITY,SUBJECT,INDUSTRY,ORG_SIZE,QUALIFICATION,IS_JOIN,AUTH_STATUS,ADDR,EMAIL,CONTACT_NUM,FIELD_OF_CUSTOMER,FIELD_OF_SUPPLIER,SORT_NUM,PAGE_VIEWS,SHARE_ID,ORG_ATTR,ID,NAME,ORG_TYPE,CREATE_TIME,MODIFY_TIME,DESCP FROM ORGANIZATION";
	            sql = sql + _m_3;
	            sql = sql + " ORDER BY SORT_NUM DESC,MODIFY_TIME DESC";
	            sql = sql + " LIMIT " + pageSize;
	        }else{
	            int _m_7 = _m_1 / pageSize;
	            if(_m_1 % pageSize != 0){
	                ++_m_7;
	            }
	            if(pageNo > _m_7){
	                pageNo = _m_7;
	            }
	            _result.setPageNo(pageNo);
	            --pageNo;
	            int _m_8 = (pageNo * pageSize);
	            sql = "SELECT FOR_SHORT,ORG_URL,FOUND_TIME,PROVINCE,CITY,SUBJECT,INDUSTRY,ORG_SIZE,QUALIFICATION,IS_JOIN,AUTH_STATUS,ADDR,EMAIL,CONTACT_NUM,FIELD_OF_CUSTOMER,FIELD_OF_SUPPLIER,SORT_NUM,PAGE_VIEWS,SHARE_ID,ORG_ATTR,ID,NAME,ORG_TYPE,CREATE_TIME,MODIFY_TIME,DESCP FROM ORGANIZATION";
	            sql = sql + _m_3;
	            sql = sql + " ORDER BY SORT_NUM DESC,MODIFY_TIME DESC";
	            sql = sql + " LIMIT " + pageSize+ " OFFSET "+_m_8;
	        }
	        ps = con.prepareStatement(sql);
	        try{
	            ps.setString(_m_2++,industry);	
	            ps.setString(_m_2++,addr);	   
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            ps.setString(_m_2++,kw);
	            java.sql.ResultSet rs = ps.executeQuery();
	            try{
	                java.util.List<com.ekexiu.portal.pojo.EditOrganization> _m_9 = new java.util.ArrayList<com.ekexiu.portal.pojo.EditOrganization>();
	                _result.setData(_m_9);
	                int _m_10 = 0;
	                while((_m_10<pageSize) && rs.next()){
	                    ++_m_10;
	                    com.ekexiu.portal.pojo.EditOrganization _obj =  new com.ekexiu.portal.pojo.EditOrganization();
	                    java.lang.String _m_11 = rs.getString(1);
	                    if(rs.wasNull()){
	                        _m_11 = null;
	                    }
	                    _obj.setForShort(_m_11);
	                    java.lang.String _m_12 = rs.getString(2);
	                    if(rs.wasNull()){
	                        _m_12 = null;
	                    }
	                    _obj.setOrgUrl(_m_12);
	                    java.lang.String _m_13 = rs.getString(3);
	                    if(rs.wasNull()){
	                        _m_13 = null;
	                    }
	                    _obj.setFoundTime(_m_13);
	                    java.lang.String _m_14 = rs.getString(4);
	                    if(rs.wasNull()){
	                        _m_14 = null;
	                    }
	                    _obj.setProvince(_m_14);
	                    java.lang.String _m_15 = rs.getString(5);
	                    if(rs.wasNull()){
	                        _m_15 = null;
	                    }
	                    _obj.setCity(_m_15);
	                    java.lang.String _m_16 = rs.getString(6);
	                    if(rs.wasNull()){
	                        _m_16 = null;
	                    }
	                    _obj.setSubject(_m_16);
	                    java.lang.String _m_17 = rs.getString(7);
	                    if(rs.wasNull()){
	                        _m_17 = null;
	                    }
	                    _obj.setIndustry(_m_17);
	                    java.lang.String _m_18 = rs.getString(8);
	                    if(rs.wasNull()){
	                        _m_18 = null;
	                    }
	                    _obj.setOrgSize(_m_18);
	                    java.lang.String _m_19 = rs.getString(9);
	                    if(rs.wasNull()){
	                        _m_19 = null;
	                    }
	                    _obj.setQualification(_m_19);
	                    _obj.setIsJoin(rs.getString(10));
	                    _obj.setAuthStatus(rs.getString(11));
	                    java.lang.String _m_20 = rs.getString(12);
	                    if(rs.wasNull()){
	                        _m_20 = null;
	                    }
	                    _obj.setAddr(_m_20);
	                    java.lang.String _m_21 = rs.getString(13);
	                    if(rs.wasNull()){
	                        _m_21 = null;
	                    }
	                    _obj.setEmail(_m_21);
	                    java.lang.String _m_22 = rs.getString(14);
	                    if(rs.wasNull()){
	                        _m_22 = null;
	                    }
	                    _obj.setContactNum(_m_22);
	                    java.lang.String _m_23 = rs.getString(15);
	                    if(rs.wasNull()){
	                        _m_23 = null;
	                    }
	                    _obj.setFieldOfCustomer(_m_23);
	                    java.lang.String _m_24 = rs.getString(16);
	                    if(rs.wasNull()){
	                        _m_24 = null;
	                    }
	                    _obj.setFieldOfSupplier(_m_24);
	                    _obj.setSortNum(rs.getLong(17));
	                    _obj.setPageViews(rs.getLong(18));
	                    _obj.setShareId(rs.getLong(19));
	                    java.lang.String _m_25 = rs.getString(20);
	                    if(rs.wasNull()){
	                        _m_25 = null;
	                    }
	                    _obj.setOrgAttr(_m_25);
	                    _obj.setId(rs.getString(21));
	                    _obj.setName(rs.getString(22));
	                    java.lang.String _m_26 = rs.getString(23);
	                    if(rs.wasNull()){
	                        _m_26 = null;
	                    }
	                    _obj.setOrgType(_m_26);
	                    _obj.setCreateTime(rs.getString(24));
	                    _obj.setModifyTime(rs.getString(25));
	                    java.lang.String _m_27 = rs.getString(26);
	                    if(rs.wasNull()){
	                        _m_27 = null;
	                    }
	                    _obj.setDescp(_m_27);
	                    _m_9.add(_obj);
	                }
	                return _result;
	            }finally{
	                try{rs.close();}catch(Exception _m_28){}
	            }
	        }finally{
	            try{ps.close();}catch(Exception _m_29){}
	        }
	    }
	
	
	@PageQuery
	@Select(Organization.class)
	@From(Organization.class)
	@OrderBy(" ORDER BY SORT_NUM DESC,MODIFY_TIME DESC")
	public abstract PageQueryResult<EditOrganization> queryByKwAndIndustryAndAddr(Connection con, 
			@GroupSqlColumn(isAnd=false, handlerClass = StringHandler.class, value = { "NAME LIKE ? AND IS_JOIN ='1'", "FOR_SHORT LIKE ? AND IS_JOIN ='1'",
					"DESCP LIKE ?  AND IS_JOIN ='1'", "SUBJECT LIKE ? AND IS_JOIN ='1' ", "industry LIKE ?  AND IS_JOIN ='1'",
					"ID IN (SELECT ORG_ID FROM RESOURCE WHERE RESOURCE_TYPE='2' AND RESOURCE_NAME LIKE ?) AND IS_JOIN ='1'",
					"ID IN (SELECT ORG_ID FROM ARTICLE WHERE ARTICLE_TYPE='2' AND ARTICLE_TITLE LIKE ?) AND IS_JOIN ='1'" })
		@Nullable	String kw, @Nullable String industry,@Nullable String addr, int pageSize,
			int pageNo) throws SQLException;
	@PageQuery
	@From(Organization.class)
@@ -412,46 +237,53 @@ public abstract class OrgDao {
	@Select(Organization.class)
	@Where("IS_JOIN ='1'")
	public abstract PageQueryResult<EditOrganization> query(Connection con, int pageSize, int pageNo) throws SQLException;
	
	
	@PageQuery
	@From(Organization.class)
	@OrderBy("ORDER BY SORT_NUM DESC,MODIFY_TIME DESC")
	@Select(Organization.class)
	@Where("IS_JOIN ='1'")
	public abstract PageQueryResult<EditOrganization> queryByIndustryAndAddr(Connection con,@Like String industry,@Like String addr,  int pageSize, int pageNo) throws SQLException;
	
	public abstract PageQueryResult<EditOrganization> queryByIndustryAndAddr(Connection con, @Like String industry, @Like String addr, int pageSize, int pageNo)
			throws SQLException;
	@QueryList
	@From(Organization.class)
	@Select(Organization.class)
	public abstract List<EditOrganization> query(Connection con,@In String[] id) throws SQLException;
	
	public abstract List<EditOrganization> query(Connection con, @In String[] id) throws SQLException;
	@LimitQuery
	@Select(Organization.class)
	@From(Organization.class)
	@OrderBy(" ORDER BY SORT_NUM DESC,PAGE_VIEWS DESC,SHARE_ID ASC")
	@Or
	public abstract List<EditOrganization> relateQuery(Connection con,@Nullable @SqlColumn(value={"(IS_JOIN='1' AND NAME LIKE ?)","(IS_JOIN='1' AND FOR_SHORT LIKE ?)"},handlerClass=StringHandler.class) String kw,int rows)throws SQLException;
	public abstract List<EditOrganization> relateQuery(Connection con, @Nullable @SqlColumn(value = { "(IS_JOIN='1' AND NAME LIKE ?)",
			"(IS_JOIN='1' AND FOR_SHORT LIKE ?)" }, handlerClass = StringHandler.class) String kw, int rows) throws SQLException;
	public String[] queryOrgIdWithSameKeyWord(Connection con,String id,int rows)throws SQLException{
	public String[] queryOrgIdWithSameKeyWord(Connection con, String id, int rows) throws SQLException {
		List<String> ret = new ArrayList<String>();
		String sql = "select id,count(1) sort from org_key_word where kw in (select kw from org_key_word where id=?) and id <>? group by id order by sort desc limit ?";
		PreparedStatement ps = con.prepareStatement(sql);
		try{
		try {
			ps.setString(1, id);
			ps.setString(2, id);
			ps.setInt(3, rows);
			ResultSet rs = ps.executeQuery();
			try{
				while(rs.next()){
			try {
				while (rs.next()) {
					ret.add(rs.getString(1));
				}
			}finally{
				try{rs.close();}catch(Exception e1){}
			} finally {
				try {
					rs.close();
				} catch (Exception e1) {
				}
			}
		} finally {
			try {
				ps.close();
			} catch (Exception e2) {
			}
		}finally{
			try{ps.close();}catch(Exception e2){}
		}
		return ret.isEmpty()?null:ret.toArray(new String[ret.size()]);		
		return ret.isEmpty() ? null : ret.toArray(new String[ret.size()]);
	}
}

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

@@ -56,19 +56,10 @@ public abstract class ProfessorDao {
	@Update
	public abstract int update(Connection con, Professor professor) throws SQLException;
	public int updateScoreValue(Connection con, String id, Integer scoreValue) throws SQLException {
		String sql = "UPDATE PROFESSOR SET SCORE_VALUE = SCORE_VALUE + " + scoreValue + " WHERE ID = '" + id + "'";
		PreparedStatement ps = con.prepareStatement(sql);
		try {
			return ps.executeUpdate();
		} finally {
			try {
				ps.close();
			} catch (Exception e) {
			}
		}
	}
	@UpdateWith
	@From(Professor.class)
	public abstract  int updateScoreValue(Connection con, String id,@Set("= SCORE_VALUE + ?") int scoreValue) throws SQLException;
	
	public int updateGrowthValue(Connection con, String id, Integer growthValue) throws SQLException {
		String sql = "UPDATE PROFESSOR SET GROWTH_VALUE = GROWTH_VALUE + " + growthValue + " WHERE ID = '" + id + "'";
		PreparedStatement ps = con.prepareStatement(sql);

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

@@ -1,16 +1,17 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
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.Select;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.LimitQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryList;
import org.jfw.apt.orm.annotation.dao.param.LessThan;
import com.ekexiu.portal.po.ResearchAreaLog;
import com.ekexiu.portal.pojo.EditResearchAreaLog;
@@ -32,59 +33,15 @@ public abstract class ResearchAreaLogDao {
	@From(ResearchAreaLog.class)
	public abstract int delete(Connection con,String professorId)throws SQLException;
	
	public List<EditResearchAreaLog> queryLimit(Connection con,String professorId,String caption,String createTime,int rows) throws SQLException{
        int index = 1;
        String sql = "SELECT OPRETE_PROFESSOR_ID,CREATE_TIME,PROFESSOR_ID,CAPTION FROM RESEARCH_AREA_LOG "
        		+ " WHERE CREATE_TIME < ? AND CAPTION = ? AND PROFESSOR_ID = ? ORDER BY CREATE_TIME DESC LIMIT "+rows;
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,createTime);
            ps.setString(index++,caption);
            ps.setString(index++,professorId);
            ResultSet rs = ps.executeQuery();
            try{
                List<EditResearchAreaLog> areaLogs = new ArrayList<EditResearchAreaLog>();
                while(rs.next()){
                	EditResearchAreaLog areaLog =  new EditResearchAreaLog();
                	areaLog.setOpreteProfessorId(rs.getString(1));
                	areaLog.setCreateTime(rs.getString(2));
                	areaLog.setProfessorId(rs.getString(3));
                	areaLog.setCaption(rs.getString(4));
                    areaLogs.add(areaLog);
                }
                return areaLogs;
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
	
	public List<EditResearchAreaLog> query(Connection con,String professorId) throws SQLException{
        int index = 1;
        String sql = "SELECT OPRETE_PROFESSOR_ID,CREATE_TIME,PROFESSOR_ID,CAPTION FROM RESEARCH_AREA_LOG WHERE PROFESSOR_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,professorId);
            ResultSet rs = ps.executeQuery();
            try{
                List<EditResearchAreaLog> areaLogs = new ArrayList<EditResearchAreaLog>();
                while(rs.next()){
                	EditResearchAreaLog log =  new EditResearchAreaLog();
                	log.setOpreteProfessorId(rs.getString(1));
                	log.setCreateTime(rs.getString(2));
                	log.setProfessorId(rs.getString(3));
                	log.setCaption(rs.getString(4));
                	areaLogs.add(log);
                }
                return areaLogs;
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
	@LimitQuery
	@From(ResearchAreaLog.class)
	@Select(ResearchAreaLog.class)	
	public abstract List<EditResearchAreaLog> queryLimit(Connection con,String professorId,String caption,@LessThan String createTime,int rows) throws SQLException;
	@QueryList
	@From(ResearchAreaLog.class)
	@Select(ResearchAreaLog.class)	
	public abstract List<EditResearchAreaLog> query(Connection con,String professorId) throws SQLException;
	
}

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

@@ -7,10 +7,18 @@ import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.orm.annotation.dao.Column;
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.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryVal;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import com.ekexiu.portal.po.Consult;
import com.ekexiu.portal.po.Tidings;
@@ -21,18 +29,13 @@ public abstract class TidingsDao {
	@Insert
	public abstract int insert(Connection con, Tidings tidings) throws SQLException;
	
	public int updateReadStatus(Connection con,String senderId,String consultId) throws SQLException{
        int index = 1;
        String sql ="UPDATE TIDINGS SET READ_STATUS = 1 WHERE READ_STATUS = 0 AND CONSULT_ID = ? AND SENDER_ID != ? ";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(index++,consultId);
            ps.setString(index++,senderId);
            return ps.executeUpdate();
        }finally{
            try{ps.close();}catch(Exception e){}
        }
    }
	@UpdateWith
	@From(Tidings.class)
	@Where("READ_STATUS = 0")
	@SetSentence("READ_STATUS = 1")
	public abstract int updateReadStatus(Connection con,String senderId,String consultId) throws SQLException;
	
	
	
	/**
	 * 查询当前咨询有几条未读消息
@@ -42,16 +45,13 @@ public abstract class TidingsDao {
	 * @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;
	}
	
	@QueryVal
	@Column(handlerClass=IntHandler.class,value="COUNT(1)")
	@From(Tidings.class)
	@Where("READ_STATUS = 0")
	@DefaultValue("0")
	public abstract int queryNotReadTidings(Connection con, String consultId, String senderId) throws SQLException;
	
	/**
	 * 我的工作台最新回复
@@ -107,6 +107,10 @@ public abstract class TidingsDao {
	 * @return 返回对方最后回复的信息
	 * @throws SQLException
	 */
//	@SelectOne
//	@Nullable
//	public abstract Tidings queryLastRevovery(Connection con,String consultId,String senderId) throws SQLException;
//	
	public Tidings queryLastRevovery(Connection con,String consultId,String senderId) throws SQLException{
        int index = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,CONSULT_ID,CREATE_TIME FROM TIDINGS "