我的工作台查询几项合作正在进行。

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

@@ -64,6 +64,24 @@ public abstract class OperationDao {
	@From(Operation.class)
	public abstract int updatePayMethod(Connection con, String operationId, @Set String payMethod) throws SQLException;
	
	/**
	 * 查询有多少资源合作正在进行
	 * @param con
	 * @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 = ?) ";
		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;
	}
	
	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 = ?";

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

@@ -49,6 +49,12 @@ public class OperationService {
		this.operationDao.update(con, operation);
	}
	
	@Get
	@Path("/qaOnGoingOper")
	public int queryOnGoingOper(@JdbcConn Connection con, @Nullable String professorId) throws SQLException {
		return this.operationDao.queryOnGoingOper(con, professorId);
	}
	
	@Get
	@Path("/{operationId}")
	public Operation query(@JdbcConn Connection con, @PathVar String operationId) throws SQLException{