--update queryCountByStatus();

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

@@ -9,15 +9,19 @@ import java.util.Collections;
import java.util.List;
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.OrderBy;
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.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.util.PageQueryResult;
import org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.po.Demand;
@@ -34,24 +38,10 @@ public abstract class DemandDao {
	@Nullable
	public abstract Demand queryOne(Connection con,String demandId)throws SQLException;
	
	public int queryCountByStatus(Connection con,String demander,String demandStatus)throws SQLException{
		String sql = " SELECT COUNT(1) FROM DEMAND WHERE DEMANDER = ? AND DEMAND_STATUS = ? ";
		PreparedStatement ps = con.prepareStatement(sql);
		int index = 1;
		try {
			ps.setString(index++, demander);
			ps.setString(index++, demandStatus);
			ResultSet rs = ps.executeQuery();
			try {
				rs.next();
				return rs.getInt(1);
			} finally {
				try{rs.close();}catch(Exception e1){}
			}
		} finally {
            try{ps.close();}catch(Exception e2){}
        }
	}
	@QueryVal
	@Column(handlerClass=IntHandler.class,value="COUNT(1)")
	@From(Demand.class)
	public abstract int queryCountByStatus(Connection con,String demander,String demandStatus)throws SQLException, JfwBaseException;
	
	@SelectList
	@OrderBy("ORDER BY CREATE_TIME DESC")

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

@@ -15,6 +15,7 @@ import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.dao.DemandDao;
import com.ekexiu.portal.dao.DemandSubOrIndusDao;
@@ -107,10 +108,11 @@ public class DemandService {
	 * @param demander 发布者ID
	 * @return 返回状态发布中的需求总数
	 * @throws SQLException
	 * @throws JfwBaseException 
	 */
	@Get
	@Path("/queryPublish")
	public int queryPublish(@JdbcConn Connection con,String demander)throws SQLException{
	public int queryPublish(@JdbcConn Connection con,String demander)throws SQLException, JfwBaseException{
		return this.demandDao.queryCountByStatus(con, demander, "1");
	}