111

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

@@ -1,27 +1,32 @@
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.Collections;
import java.util.List;
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.IncludeFixSet;
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.PageSelect;
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.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.LessThan;
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 org.jfw.util.exception.JfwBaseException;
import com.ekexiu.portal.po.Demand;
@@ -30,457 +35,539 @@ public abstract class DemandDao {
	@Insert
	public abstract int insert(Connection con,Demand demand)throws SQLException;
	
	@Update
	@Where("STATE IN ('0','1')")
	public abstract int update(Connection con,Demand demand) throws SQLException;
	
	
	@UpdateWith
	@Where("STATE IN ('0','1')")
	@SetSentence("STATE='3'")
	@IncludeFixSet
	@From(Demand.class)
	public abstract int updateDemandStatus(Connection con,String demandId,@Set String demandStatus,@Set String closeTime)throws SQLException;
	public abstract int close(Connection con,String id,@Set String modifier)throws SQLException;
	
	@SelectOne
	@Nullable
	public abstract Demand queryOne(Connection con,String demandId)throws SQLException;
	@UpdateWith
	@Where("STATE IN ('0','1')")
	@SetSentence("STATE='3'")
	@IncludeFixSet
	@From(Demand.class)
	public abstract int closeByCreator(Connection con,String creator,@Set String modifier)throws SQLException;
	
	@QueryVal
	@Column(handlerClass=IntHandler.class,value="COUNT(1)")
	
	
	
	@UpdateWith
	@Where("STATE IN ('0','1')")
	@SetSentence("STATE='2'")
	@IncludeFixSet
	@From(Demand.class)
	public abstract int over(Connection con,String id,@Set String modifier)throws SQLException;
	
	@UpdateWith
	@Where("STATE IN ('0','1')")
	@SetSentence("STATE='1'")
	@IncludeFixSet
	@From(Demand.class)
	public abstract int defer(Connection con,String id,@Set String modifier,@Set String invalidDay)throws SQLException;
	
	
	
	@UpdateWith
	@Where("STATE ='1'")
	@SetSentence("STATE='0'")
	@From(Demand.class)
	public abstract int queryCountByStatus(Connection con,String demander,String demandStatus)throws SQLException, JfwBaseException;
	public abstract int invalid(Connection con,@LessThan String invalidDay)throws SQLException;
	
	
	@QueryVal
	@Column(handlerClass=IntHandler.class,value="COUNT(1)")
	@From(Demand.class)
	public abstract int queryCountStatus(Connection con,String demandStatus)throws SQLException, JfwBaseException;
	@DefaultValue("0")
	public abstract int cnt(Connection con,@Nullable @In String[] state,@Nullable String creator,@Nullable String orgId)throws SQLException;
	
	@SelectOne
	@Nullable
	public abstract Demand query(Connection con,String id)throws SQLException;
	@SelectOne
	@Nullable
	public abstract Demand query(Connection con,long shareId)throws SQLException;
	
	@SelectList
	@OrderBy("ORDER BY CREATE_TIME DESC")
	public abstract List<Demand> queryForOrg(Connection con,String orgId)throws SQLException;
	
	@SelectList
	@OrderBy("ORDER BY CREATE_TIME DESC")
	public abstract List<Demand> queryByDemander(Connection con,String demander)throws SQLException;
	public abstract List<Demand> query(Connection con,@In String[] id)throws SQLException;
	
	public PageQueryResult<Demand> pageQueryByDemander(Connection con,String demander,String demandStatus,int sortType,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<Demand> queryResult = new PageQueryResult<Demand>();
        int index = 1;
        boolean hasDemandStatus = null != demandStatus;
        StringBuilder sql = new StringBuilder();
        sql.append(" WHERE DEMANDER = ?");
        if(hasDemandStatus){
            sql.append(" AND DEMAND_STATUS = ?");
        }
        StringBuilder whereSql = sql;
        sql = new StringBuilder();
        sql.append("SELECT COUNT(1) FROM DEMAND");
        sql.append(whereSql);
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
            ps.setString(index++,demander);
            if(hasDemandStatus){
                ps.setString(index++,demandStatus);
            }
            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.<Demand>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
            sql = new StringBuilder();
            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME FROM DEMAND");
            sql.append(whereSql);
            sql.append(" ORDER BY CREATE_TIME");
            if(sortType == 0){
            	sql.append(" DESC ");
            }
            sql.append(" LIMIT ").append(pageSize);
        }else{
            int pageNumber = total / pageSize;
            if(total % pageSize != 0){
                ++pageNumber;
            }
            if(pageNo > pageNumber){
                pageNo = pageNumber;
            }
            queryResult.setPageNo(pageNo);
            --pageNo;
            int offset = (pageNo * pageSize);
            sql = new StringBuilder();
            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME FROM DEMAND");
            sql.append(whereSql);
            sql.append(" ORDER BY CREATE_TIME");
            if(sortType == 0){
            	sql.append(" DESC ");
            }
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
        }
        ps = con.prepareStatement(sql.toString());
        try{
            ps.setString(index++,demander);
            if(hasDemandStatus){
                ps.setString(index++,demandStatus);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Demand> demands = new ArrayList<Demand>();
                queryResult.setData(demands);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Demand demand =  new Demand();
                    demand.setDemandId(rs.getString(1));
                    demand.setDemander(rs.getString(2));
                    demand.setDemandAim(rs.getString(3));
                    demand.setDemandType(rs.getString(4));
                    demand.setDemandTitle(rs.getString(5));
                    String demandContent = rs.getString(6);
                    if(rs.wasNull()){
                    	demandContent = null;
                    }
                    demand.setDemandContent(demandContent);
                    demand.setDemandStatus(rs.getString(7));
                    String closeTime = rs.getString(8);
                    if(rs.wasNull()){
                    	closeTime = null;
                    }
                    demand.setCloseTime(closeTime);
                    demand.setOrderKey(rs.getLong(9));
                    demand.setCreateTime(rs.getString(10));
                    demands.add(demand);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	@UpdateWith
	@From(Demand.class)
	@SetSentence("PAGE_VIEWS=PAGE_VIEWS+1")
	public abstract int incPageViews(Connection con,String id)throws SQLException;
	
	
	
	@PageSelect
	@OrderBy(" ORDER BY STATE ASC,CREATE_TIME DESC")
	public abstract PageQueryResult<Demand> pageQuery(Connection con,@Nullable @In String[] state,@Nullable String creator,@Nullable String orgId,int pageSize,int pageNo) throws SQLException;
	
	
	@PageSelect
	@OrderBy(" ORDER BY CREATE_TIME DESC")
	public abstract PageQueryResult<Demand> pageQuery(Connection con,@GroupSqlColumn(value={"TITLE LIKE ?","DESCP LIKE ?"},handlerClass=StringHandler.class,isAnd=false ,force =false)  @Nullable String key,int pageSize,int pageNo) throws SQLException;
	
	
	public PageQueryResult<Demand> pageQuery(Connection con,String demandStatus,String demandAim,int sortType,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<Demand> queryResult = new PageQueryResult<Demand>();
        int index = 1;
        boolean hasDemandAim = null != demandAim;
        StringBuilder sql = new StringBuilder();
        sql.append(" WHERE DEMAND_STATUS = ?");
        if(hasDemandAim){
            sql.append(" AND DEMAND_AIM = ?");
        }
        StringBuilder whereSql = sql;
        sql = new StringBuilder();
        sql.append("SELECT COUNT(1) FROM DEMAND");
        if(whereSql.length()>0){
            sql.append(whereSql);
        }
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
        	ps.setString(index++, demandStatus);
            if(hasDemandAim){
                ps.setString(index++,demandAim);
            }
            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.<Demand>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
            sql = new StringBuilder();
            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
            if(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY CREATE_TIME");
            if(sortType == 0){
            	sql.append(" 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 DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
            if(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY CREATE_TIME");
            if(sortType == 0){
            	sql.append(" DESC ");
            }
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
        }
        ps = con.prepareStatement(sql.toString());
        try{
        	ps.setString(index++, demandStatus);
            if(hasDemandAim){
                ps.setString(index++,demandAim);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Demand> demands = new ArrayList<Demand>();
                queryResult.setData(demands);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Demand demand =  new Demand();
                    demand.setDemandId(rs.getString(1));
                    demand.setDemander(rs.getString(2));
                    demand.setDemandAim(rs.getString(3));
                    demand.setDemandType(rs.getString(4));
                    demand.setDemandTitle(rs.getString(5));
                    String demandContent = rs.getString(6);
                    if(rs.wasNull()){
                        demandContent = null;
                    }
                    demand.setDemandContent(demandContent);
                    demand.setDemandStatus(rs.getString(7));
                    String closeTime = rs.getString(8);
                    if(rs.wasNull()){
                    	closeTime = null;
                    }
                    demand.setCloseTime(closeTime);
                    demand.setOrderKey(rs.getLong(9));
                    demand.setCreateTime(rs.getString(10));
                    String orgId = rs.getString(11);
                    if(rs.wasNull()){
                    	orgId = null;
                    }
                    demand.setOrgId(orgId);
                    demands.add(demand);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	
	public PageQueryResult<Demand> pageQueryOrg(Connection con,String orgId,String demandStatus,int sortType,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<Demand> queryResult = new PageQueryResult<Demand>();
        int index = 1;
        boolean hasDemandStatus = null != demandStatus;
        StringBuilder sql = new StringBuilder();
        sql.append(" WHERE DEMAND_TYPE = '2' AND ORG_ID = ? ");
        if(hasDemandStatus){
            sql.append(" AND DEMAND_STATUS = ?");
        }
        StringBuilder whereSql = sql;
        sql = new StringBuilder();
        sql.append("SELECT COUNT(1) FROM DEMAND");
        if(whereSql.length()>0){
            sql.append(whereSql);
        }
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
        	ps.setString(index++, orgId);
            if(hasDemandStatus){
                ps.setString(index++,demandStatus);
            }
            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.<Demand>emptyList());
            return queryResult;
        }
        index = 1;
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
            sql = new StringBuilder();
            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
            if(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY CREATE_TIME");
            if(sortType == 0){
            	sql.append(" 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 DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
            if(whereSql.length()>0){
                sql.append(whereSql);
            }
            sql.append(" ORDER BY CREATE_TIME");
            if(sortType == 0){
            	sql.append(" DESC ");
            }
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
        }
        ps = con.prepareStatement(sql.toString());
        try{
        	ps.setString(index++, orgId);
            if(hasDemandStatus){
                ps.setString(index++,demandStatus);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Demand> demands = new ArrayList<Demand>();
                queryResult.setData(demands);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    Demand demand =  new Demand();
                    demand.setDemandId(rs.getString(1));
                    demand.setDemander(rs.getString(2));
                    demand.setDemandAim(rs.getString(3));
                    demand.setDemandType(rs.getString(4));
                    demand.setDemandTitle(rs.getString(5));
                    String demandContent = rs.getString(6);
                    if(rs.wasNull()){
                        demandContent = null;
                    }
                    demand.setDemandContent(demandContent);
                    demand.setDemandStatus(rs.getString(7));
                    String closeTime = rs.getString(8);
                    if(rs.wasNull()){
                    	closeTime = null;
                    }
                    demand.setCloseTime(closeTime);
                    demand.setOrderKey(rs.getLong(9));
                    demand.setCreateTime(rs.getString(10));
                    String orgid = rs.getString(11);
                    if(rs.wasNull()){
                    	orgid = null;
                    }
                    demand.setOrgId(orgid);
                    demands.add(demand);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
	
	public List<Demand> queryByStatus(Connection con,String demandStatus,String demandAim,String subject,String industry,String createTime,long orderKey,int rows,int sortType) throws SQLException{
        StringBuilder sql = new StringBuilder();
        sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,ORDER_KEY,CREATE_TIME FROM DEMAND ");
        boolean hasDemandAim = null != demandAim;
        boolean hasSubject = null !=subject;
        boolean hasIndustry = null != industry;
        sql.append(" WHERE DEMAND_STATUS = ? AND ORDER_KEY < ? AND CREATE_TIME < ? ");
        if(hasDemandAim){
        	sql.append(" AND DEMAND_AIM = ? ");
        }
        if(hasSubject){
        	sql.append(" AND DEMAND_ID IN (SELECT DEMAND_ID FROM DEMAND_SUB_OR_INDUS WHERE SUB_OR_INDUS LIKE ?) ");
        }
        if(hasIndustry){
        	sql.append(" AND DEMAND_ID IN (SELECT DEMAND_ID FROM DEMAND_SUB_OR_INDUS WHERE SUB_OR_INDUS LIKE ?) ");
        }
        sql.append(" ORDER BY CREATE_TIME ");
        if(sortType == 0){
        	sql.append(" DESC ");
        }
        sql.append(" ,ORDER_KEY ");
        if(sortType == 0){
        	sql.append(" DESC ");
        }
        sql.append(" LIMIT ").append(rows);
        int index = 1;
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try{
        	ps.setString(index++, demandStatus);
            ps.setLong(index++,orderKey);
            ps.setString(index++,createTime);
            if(hasDemandAim){
            	ps.setString(index++,demandAim);
            }
            if(hasSubject){
            	ps.setString(index++,subject);
            }
            if(hasIndustry){
            	ps.setString(index++,industry);
            }
            ResultSet rs = ps.executeQuery();
            try{
                List<Demand> demands = new ArrayList<Demand>();
                while(rs.next()){
                    Demand demand =  new Demand();
                    demand.setDemandId(rs.getString(1));
                    demand.setDemander(rs.getString(2));
                    demand.setDemandAim(rs.getString(3));
                    demand.setDemandType(rs.getString(4));
                    demand.setDemandTitle(rs.getString(5));
                    String content = rs.getString(6);
                    if(rs.wasNull()){
                    	content = null;
                    }
                    demand.setDemandContent(content);
                    demand.setDemandStatus(rs.getString(7));
                    demand.setOrderKey(rs.getLong(8));
                    demand.setCreateTime(rs.getString(9));
                    demands.add(demand);
                }
                return demands;
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
//	
//	@UpdateWith
//	@From(Demand.class)
//	public abstract int updateDemandStatus(Connection con,String demandId,@Set String demandStatus,@Set String closeTime)throws SQLException;
//	
//	@SelectOne
//	@Nullable
//	public abstract Demand queryOne(Connection con,String demandId)throws SQLException;
//	
//	@QueryVal
//	@Column(handlerClass=IntHandler.class,value="COUNT(1)")
//	@From(Demand.class)
//	public abstract int queryCountByStatus(Connection con,String demander,String demandStatus)throws SQLException, JfwBaseException;
//	
//	@QueryVal
//	@Column(handlerClass=IntHandler.class,value="COUNT(1)")
//	@From(Demand.class)
//	public abstract int queryCountStatus(Connection con,String demandStatus)throws SQLException, JfwBaseException;
//	
//	@SelectList
//	@OrderBy("ORDER BY CREATE_TIME DESC")
//	public abstract List<Demand> queryForOrg(Connection con,String orgId)throws SQLException;
//	
//	@SelectList
//	@OrderBy("ORDER BY CREATE_TIME DESC")
//	public abstract List<Demand> queryByDemander(Connection con,String demander)throws SQLException;
//	
//	public PageQueryResult<Demand> pageQueryByDemander(Connection con,String demander,String demandStatus,int sortType,int pageSize,int pageNo) throws SQLException{
//        int total = 0;
//        PageQueryResult<Demand> queryResult = new PageQueryResult<Demand>();
//        int index = 1;
//        boolean hasDemandStatus = null != demandStatus;
//        StringBuilder sql = new StringBuilder();
//        sql.append(" WHERE DEMANDER = ?");
//        if(hasDemandStatus){
//            sql.append(" AND DEMAND_STATUS = ?");
//        }
//        StringBuilder whereSql = sql;
//        sql = new StringBuilder();
//        sql.append("SELECT COUNT(1) FROM DEMAND");
//        sql.append(whereSql);
//        PreparedStatement ps = con.prepareStatement(sql.toString());
//        try{
//            ps.setString(index++,demander);
//            if(hasDemandStatus){
//                ps.setString(index++,demandStatus);
//            }
//            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.<Demand>emptyList());
//            return queryResult;
//        }
//        index = 1;
//        boolean firstPage = (1 == pageNo);
//        if(firstPage){
//        	queryResult.setPageNo(1);
//            sql = new StringBuilder();
//            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME FROM DEMAND");
//            sql.append(whereSql);
//            sql.append(" ORDER BY CREATE_TIME");
//            if(sortType == 0){
//            	sql.append(" DESC ");
//            }
//            sql.append(" LIMIT ").append(pageSize);
//        }else{
//            int pageNumber = total / pageSize;
//            if(total % pageSize != 0){
//                ++pageNumber;
//            }
//            if(pageNo > pageNumber){
//                pageNo = pageNumber;
//            }
//            queryResult.setPageNo(pageNo);
//            --pageNo;
//            int offset = (pageNo * pageSize);
//            sql = new StringBuilder();
//            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME FROM DEMAND");
//            sql.append(whereSql);
//            sql.append(" ORDER BY CREATE_TIME");
//            if(sortType == 0){
//            	sql.append(" DESC ");
//            }
//            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
//        }
//        ps = con.prepareStatement(sql.toString());
//        try{
//            ps.setString(index++,demander);
//            if(hasDemandStatus){
//                ps.setString(index++,demandStatus);
//            }
//            ResultSet rs = ps.executeQuery();
//            try{
//                List<Demand> demands = new ArrayList<Demand>();
//                queryResult.setData(demands);
//                int size = 0;
//                while((size<pageSize) && rs.next()){
//                    ++size;
//                    Demand demand =  new Demand();
//                    demand.setDemandId(rs.getString(1));
//                    demand.setDemander(rs.getString(2));
//                    demand.setDemandAim(rs.getString(3));
//                    demand.setDemandType(rs.getString(4));
//                    demand.setDemandTitle(rs.getString(5));
//                    String demandContent = rs.getString(6);
//                    if(rs.wasNull()){
//                    	demandContent = null;
//                    }
//                    demand.setDemandContent(demandContent);
//                    demand.setDemandStatus(rs.getString(7));
//                    String closeTime = rs.getString(8);
//                    if(rs.wasNull()){
//                    	closeTime = null;
//                    }
//                    demand.setCloseTime(closeTime);
//                    demand.setOrderKey(rs.getLong(9));
//                    demand.setCreateTime(rs.getString(10));
//                    demands.add(demand);
//                }
//                return queryResult;
//            }finally{
//                try{rs.close();}catch(Exception e3){}
//            }
//        }finally{
//            try{ps.close();}catch(Exception e4){}
//        }
//    }
//	
//	public PageQueryResult<Demand> pageQuery(Connection con,String demandStatus,String demandAim,int sortType,int pageSize,int pageNo) throws SQLException{
//        int total = 0;
//        PageQueryResult<Demand> queryResult = new PageQueryResult<Demand>();
//        int index = 1;
//        boolean hasDemandAim = null != demandAim;
//        StringBuilder sql = new StringBuilder();
//        sql.append(" WHERE DEMAND_STATUS = ?");
//        if(hasDemandAim){
//            sql.append(" AND DEMAND_AIM = ?");
//        }
//        StringBuilder whereSql = sql;
//        sql = new StringBuilder();
//        sql.append("SELECT COUNT(1) FROM DEMAND");
//        if(whereSql.length()>0){
//            sql.append(whereSql);
//        }
//        PreparedStatement ps = con.prepareStatement(sql.toString());
//        try{
//        	ps.setString(index++, demandStatus);
//            if(hasDemandAim){
//                ps.setString(index++,demandAim);
//            }
//            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.<Demand>emptyList());
//            return queryResult;
//        }
//        index = 1;
//        boolean firstPage = (1 == pageNo);
//        if(firstPage){
//        	queryResult.setPageNo(1);
//            sql = new StringBuilder();
//            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
//            if(whereSql.length()>0){
//                sql.append(whereSql);
//            }
//            sql.append(" ORDER BY CREATE_TIME");
//            if(sortType == 0){
//            	sql.append(" 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 DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
//            if(whereSql.length()>0){
//                sql.append(whereSql);
//            }
//            sql.append(" ORDER BY CREATE_TIME");
//            if(sortType == 0){
//            	sql.append(" DESC ");
//            }
//            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
//        }
//        ps = con.prepareStatement(sql.toString());
//        try{
//        	ps.setString(index++, demandStatus);
//            if(hasDemandAim){
//                ps.setString(index++,demandAim);
//            }
//            ResultSet rs = ps.executeQuery();
//            try{
//                List<Demand> demands = new ArrayList<Demand>();
//                queryResult.setData(demands);
//                int size = 0;
//                while((size<pageSize) && rs.next()){
//                    ++size;
//                    Demand demand =  new Demand();
//                    demand.setDemandId(rs.getString(1));
//                    demand.setDemander(rs.getString(2));
//                    demand.setDemandAim(rs.getString(3));
//                    demand.setDemandType(rs.getString(4));
//                    demand.setDemandTitle(rs.getString(5));
//                    String demandContent = rs.getString(6);
//                    if(rs.wasNull()){
//                        demandContent = null;
//                    }
//                    demand.setDemandContent(demandContent);
//                    demand.setDemandStatus(rs.getString(7));
//                    String closeTime = rs.getString(8);
//                    if(rs.wasNull()){
//                    	closeTime = null;
//                    }
//                    demand.setCloseTime(closeTime);
//                    demand.setOrderKey(rs.getLong(9));
//                    demand.setCreateTime(rs.getString(10));
//                    String orgId = rs.getString(11);
//                    if(rs.wasNull()){
//                    	orgId = null;
//                    }
//                    demand.setOrgId(orgId);
//                    demands.add(demand);
//                }
//                return queryResult;
//            }finally{
//                try{rs.close();}catch(Exception e3){}
//            }
//        }finally{
//            try{ps.close();}catch(Exception e4){}
//        }
//    }
//	
//	public PageQueryResult<Demand> pageQueryOrg(Connection con,String orgId,String demandStatus,int sortType,int pageSize,int pageNo) throws SQLException{
//        int total = 0;
//        PageQueryResult<Demand> queryResult = new PageQueryResult<Demand>();
//        int index = 1;
//        boolean hasDemandStatus = null != demandStatus;
//        StringBuilder sql = new StringBuilder();
//        sql.append(" WHERE DEMAND_TYPE = '2' AND ORG_ID = ? ");
//        if(hasDemandStatus){
//            sql.append(" AND DEMAND_STATUS = ?");
//        }
//        StringBuilder whereSql = sql;
//        sql = new StringBuilder();
//        sql.append("SELECT COUNT(1) FROM DEMAND");
//        if(whereSql.length()>0){
//            sql.append(whereSql);
//        }
//        PreparedStatement ps = con.prepareStatement(sql.toString());
//        try{
//        	ps.setString(index++, orgId);
//            if(hasDemandStatus){
//                ps.setString(index++,demandStatus);
//            }
//            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.<Demand>emptyList());
//            return queryResult;
//        }
//        index = 1;
//        boolean firstPage = (1 == pageNo);
//        if(firstPage){
//        	queryResult.setPageNo(1);
//            sql = new StringBuilder();
//            sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
//            if(whereSql.length()>0){
//                sql.append(whereSql);
//            }
//            sql.append(" ORDER BY CREATE_TIME");
//            if(sortType == 0){
//            	sql.append(" 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 DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,CLOSE_TIME,ORDER_KEY,CREATE_TIME,ORG_ID FROM DEMAND");
//            if(whereSql.length()>0){
//                sql.append(whereSql);
//            }
//            sql.append(" ORDER BY CREATE_TIME");
//            if(sortType == 0){
//            	sql.append(" DESC ");
//            }
//            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
//        }
//        ps = con.prepareStatement(sql.toString());
//        try{
//        	ps.setString(index++, orgId);
//            if(hasDemandStatus){
//                ps.setString(index++,demandStatus);
//            }
//            ResultSet rs = ps.executeQuery();
//            try{
//                List<Demand> demands = new ArrayList<Demand>();
//                queryResult.setData(demands);
//                int size = 0;
//                while((size<pageSize) && rs.next()){
//                    ++size;
//                    Demand demand =  new Demand();
//                    demand.setDemandId(rs.getString(1));
//                    demand.setDemander(rs.getString(2));
//                    demand.setDemandAim(rs.getString(3));
//                    demand.setDemandType(rs.getString(4));
//                    demand.setDemandTitle(rs.getString(5));
//                    String demandContent = rs.getString(6);
//                    if(rs.wasNull()){
//                        demandContent = null;
//                    }
//                    demand.setDemandContent(demandContent);
//                    demand.setDemandStatus(rs.getString(7));
//                    String closeTime = rs.getString(8);
//                    if(rs.wasNull()){
//                    	closeTime = null;
//                    }
//                    demand.setCloseTime(closeTime);
//                    demand.setOrderKey(rs.getLong(9));
//                    demand.setCreateTime(rs.getString(10));
//                    String orgid = rs.getString(11);
//                    if(rs.wasNull()){
//                    	orgid = null;
//                    }
//                    demand.setOrgId(orgid);
//                    demands.add(demand);
//                }
//                return queryResult;
//            }finally{
//                try{rs.close();}catch(Exception e3){}
//            }
//        }finally{
//            try{ps.close();}catch(Exception e4){}
//        }
//    }
//	
//	public List<Demand> queryByStatus(Connection con,String demandStatus,String demandAim,String subject,String industry,String createTime,long orderKey,int rows,int sortType) throws SQLException{
//        StringBuilder sql = new StringBuilder();
//        sql.append("SELECT DEMAND_ID,DEMANDER,DEMAND_AIM,DEMAND_TYPE,DEMAND_TITLE,DEMAND_CONTENT,DEMAND_STATUS,ORDER_KEY,CREATE_TIME FROM DEMAND ");
//        boolean hasDemandAim = null != demandAim;
//        boolean hasSubject = null !=subject;
//        boolean hasIndustry = null != industry;
//        sql.append(" WHERE DEMAND_STATUS = ? AND ORDER_KEY < ? AND CREATE_TIME < ? ");
//        if(hasDemandAim){
//        	sql.append(" AND DEMAND_AIM = ? ");
//        }
//        if(hasSubject){
//        	sql.append(" AND DEMAND_ID IN (SELECT DEMAND_ID FROM DEMAND_SUB_OR_INDUS WHERE SUB_OR_INDUS LIKE ?) ");
//        }
//        if(hasIndustry){
//        	sql.append(" AND DEMAND_ID IN (SELECT DEMAND_ID FROM DEMAND_SUB_OR_INDUS WHERE SUB_OR_INDUS LIKE ?) ");
//        }
//        sql.append(" ORDER BY CREATE_TIME ");
//        if(sortType == 0){
//        	sql.append(" DESC ");
//        }
//        sql.append(" ,ORDER_KEY ");
//        if(sortType == 0){
//        	sql.append(" DESC ");
//        }
//        sql.append(" LIMIT ").append(rows);
//        int index = 1;
//        PreparedStatement ps = con.prepareStatement(sql.toString());
//        try{
//        	ps.setString(index++, demandStatus);
//            ps.setLong(index++,orderKey);
//            ps.setString(index++,createTime);
//            if(hasDemandAim){
//            	ps.setString(index++,demandAim);
//            }
//            if(hasSubject){
//            	ps.setString(index++,subject);
//            }
//            if(hasIndustry){
//            	ps.setString(index++,industry);
//            }
//            ResultSet rs = ps.executeQuery();
//            try{
//                List<Demand> demands = new ArrayList<Demand>();
//                while(rs.next()){
//                    Demand demand =  new Demand();
//                    demand.setDemandId(rs.getString(1));
//                    demand.setDemander(rs.getString(2));
//                    demand.setDemandAim(rs.getString(3));
//                    demand.setDemandType(rs.getString(4));
//                    demand.setDemandTitle(rs.getString(5));
//                    String content = rs.getString(6);
//                    if(rs.wasNull()){
//                    	content = null;
//                    }
//                    demand.setDemandContent(content);
//                    demand.setDemandStatus(rs.getString(7));
//                    demand.setOrderKey(rs.getLong(8));
//                    demand.setCreateTime(rs.getString(9));
//                    demands.add(demand);
//                }
//                return demands;
//            }finally{
//                try{rs.close();}catch(Exception e1){}
//            }
//        }finally{
//            try{ps.close();}catch(Exception e2){}
//        }
//    }
	
}

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

@@ -1,16 +0,0 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import com.ekexiu.portal.po.DemandSubOrIndus;
@DAO
public abstract class DemandSubOrIndusDao {
	@Insert
	public abstract int insert(Connection con,DemandSubOrIndus demandSubOrIndus)throws SQLException;
	
}

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

@@ -33,4 +33,8 @@ public interface PaperAuthorDao {
	
	
	
	@UpdateWith
	@From(PaperAuthor.class)
	@SetSentence("PROFESSOR_ID='################################'")
	int cAss(Connection con,String professorId)throws SQLException;
}

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

@@ -29,4 +29,9 @@ public interface PatentAuthorDao {
	@From(PatentAuthor.class)
	@SetSentence("PROFESSOR_ID='################################'")
	int update(Connection con,String patentId,String professorId)throws SQLException;
	
	@UpdateWith
	@From(PatentAuthor.class)
	@SetSentence("PROFESSOR_ID='################################'")
	int cAss(Connection con,String professorId)throws SQLException;
}

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

@@ -73,6 +73,10 @@ public abstract class ProfessorDao {
		}
	}
	@UpdateWith
	@From(Professor.class)
	public abstract int updateOrg(Connection con,@Set String orgId,String id)throws SQLException;
	@SelectOne
	@Nullable
	public abstract Professor query(Connection con, long shareId) throws SQLException;

src/main/java/com/ekexiu/portal/job/DemandInvalidJob.java

@@ -0,0 +1,58 @@
package com.ekexiu.portal.job;
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.DateUtil;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.portal.dao.DemandDao;
@Bean
public class DemandInvalidJob implements Runnable {
	@Autowrie("dataSource")
	private DataSource dataSource;
	@Autowrie
	private DemandDao demandDao;
	private String lastDay;
	synchronized private void hand() {
		String cday = DateUtil.formatDate(System.currentTimeMillis());
		if (!cday.equals(lastDay)) {
			try {
				Connection con = this.dataSource.getConnection();
				try {
					boolean ac = con.getAutoCommit();
					try {
						con.setAutoCommit(false);
						try {
							demandDao.invalid(con, cday);
							con.commit();
							lastDay = cday;
						} catch (SQLException se) {
							JdbcUtil.rollback(con);
							throw se;
						}
					} finally {
						con.setAutoCommit(ac);
					}
				} finally {
					JdbcUtil.close(con);
				}
			} catch (Throwable thr) {
			}
		}
	}
	@Override
	public void run() {
		this.hand();
	}
}

src/main/java/com/ekexiu/portal/job/TaskJob.java

@@ -31,6 +31,8 @@ public class TaskJob implements AfterBeanFactory {
		final WeixinService weixin =(WeixinService)bf.getBean("com_ekexiu_portal_service_WeixinService");
		final PushService pushService =(PushService)bf.getBean("com_ekexiu_push_service_PushService");
		
		DemandInvalidJob dij = (DemandInvalidJob)bf.getBean("com_ekexiu_portal_job_DemandInvalidJob");
		
		long delayTime = tje.getDelayTime();
		long task = getTimeMillis(tje.getTaskTime());
		long taskTime = task - System.currentTimeMillis();
@@ -67,7 +69,8 @@ public class TaskJob implements AfterBeanFactory {
			public void run() {
				pushService.refresh();				
			}
		}, 0, 2,TimeUnit.SECONDS);
		}, 0, 2,TimeUnit.SECONDS);		
		service.scheduleAtFixedRate(dij, 0, 5,TimeUnit.MINUTES);
	}
	private static long getTimeMillis(String time) {  
	    try {  

src/main/java/com/ekexiu/portal/po/Demand.java

@@ -4,89 +4,169 @@ import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.defaultImpl.LongHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.pojo.EditOrganization;
import com.ekexiu.portal.pojo.EditProfessor;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@Table
@PrimaryKey("demandId")
public class Demand implements CreateTimeSupported {
	private String demandId;
	private String demander;
	private String demandAim;
	private String demandType;
	private String demandTitle;
	private String demandContent;
	private String demandStatus;
	private String createTime;
	private String closeTime;
	private long orderKey;
@PrimaryKey("id")
public class Demand implements CreateTimeSupported,ModifyTimeSupported {
	private String id;
	private String title;
	private String province;
	private String city;
	private String cost;
	private String duration;
	private String invalidDay;
	private String contactNum;
	
	private String state;
	private String orgId;
	private EditProfessor professor;
	private EditOrganization organization;
	private String modifier;
	private String creator;
	private String createTime;
	private String modifyTime;
	private String descp;
	
	public EditProfessor getProfessor() {
		return professor;
	}
	public void setProfessor(EditProfessor professor) {
		this.professor = professor;
	}
	public EditOrganization getOrganization() {
		return organization;
	}
	public void setOrganization(EditOrganization organization) {
		this.organization = organization;
	}
	
	private long pageViews;
	private long shareId;
	
	/**
	 * id 主键
	 * @return
	 */
	@Column(DE.id_32)
	public String getDemandId() {
		return demandId;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	/**
	 * 需求主题
	 * @return
	 */
	@Column(dbType="TEXT",handlerClass=StringHandler.class,insertable=true,nullable=false,queryable=true,renewable=false)
	public String getTitle() {
		return title;
	}
	public void setTitle(String title) {
		this.title = title;
	}
	/**
	 * 所在省份
	 * @return
	 */
	@Column(DE.text_de)
	public String getProvince() {
		return province;
	}
	public void setProvince(String province) {
		this.province = province;
	}
	/**
	 * 所在省份
	 * @return
	 */
	@Column(DE.Text_de)
	public String getCity() {
		return city;
	}
	public void setDemandId(String demandId) {
		this.demandId = demandId;
	public void setCity(String city) {
		this.city = city;
	}
	@Column(DE.id_32)
	public String getDemander() {
		return demander;
	/**
	 * 费用预算
	 * @return
	 */
	@Column(DE.singleChar)
	public String getCost() {
		return cost;
	}
	public void setDemander(String demander) {
		this.demander = demander;
	public void setCost(String cost) {
		this.cost = cost;
	}
	/**
	 * 预期时长 
	 * @return
	 */
	@Column(DE.singleChar)
	public String getDemandAim() {
		return demandAim;
	public String getDuration() {
		return duration;
	}
	public void setDuration(String duration) {
		this.duration = duration;
	}
	/**
	 * 有效期
	 * @return
	 */
	@Column(DE.date_de)
	public String getInvalidDay() {
		return invalidDay;
	}
	public void setDemandAim(String demandAim) {
		this.demandAim = demandAim;
	public void setInvalidDay(String invalidDay) {
		this.invalidDay = invalidDay;
	}
	/**
	 * 联系电话
	 * @return
	 */
	@Column(DE.text_de)
	public String getContactNum() {
		return contactNum;
	}
	public void setContactNum(String contactNum) {
		this.contactNum = contactNum;
	}
	/**
	 * 状态  0:过期的,1:发布中的 2:完成的 3:关闭的,
	 * @return
	 */
	@Column(DE.singleChar)
	public String getDemandType() {
		return demandType;
	public String getState() {
		return state;
	}
	public void setDemandType(String demandType) {
		this.demandType = demandType;
	public void setState(String state) {
		this.state = state;
	}
	@Column(DE.string_de)
	public String getDemandTitle() {
		return demandTitle;
	/**
	 * 发布人发布时所在机构ID
	 * @return
	 */
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(32)",insertable=true,nullable=false,queryable=true,renewable=false)
	public String getOrgId() {
		return orgId;
	}
	public void setDemandTitle(String demandTitle) {
		this.demandTitle = demandTitle;
	public void setOrgId(String orgId) {
		this.orgId = orgId;
	}
	@Column(DE.Text_de)
	public String getDemandContent() {
		return demandContent;
	/**
	 * 最后修改人
	 * @return
	 */
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(32)",insertable=true,nullable=false,queryable=true,renewable=true)	
	public String getModifier() {
		return modifier;
	}
	public void setDemandContent(String demandContent) {
		this.demandContent = demandContent;
	public void setModifier(String modifier) {
		this.modifier = modifier;
	}
	@Column(DE.singleChar)
	public String getDemandStatus() {
		return demandStatus;
	/**
	 * 发布人ID
	 * @return
	 */
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(32)",insertable=true,nullable=false,queryable=true,renewable=false)	
	public String getCreator() {
		return creator;
	}
	public void setDemandStatus(String demandStatus) {
		this.demandStatus = demandStatus;
	public void setCreator(String creator) {
		this.creator = creator;
	}
	public String getCreateTime() {
		return createTime;
@@ -94,26 +174,34 @@ public class Demand implements CreateTimeSupported {
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(14)",insertable=true,nullable=true,queryable=true,renewable=false)
	public String getCloseTime() {
		return closeTime;
	public String getModifyTime() {
		return modifyTime;
	}
	public void setCloseTime(String closeTime) {
		this.closeTime = closeTime;
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	@Column(DE.long_de)
	public long getOrderKey() {
		return orderKey;
	/**
	 * 内容
	 */
	@Column(handlerClass=StringHandler.class,dbType="TEXT",insertable=true,nullable=false,renewable=true,queryable=true)
	public String getDescp() {
		return descp;
	}
	public void setOrderKey(long orderKey) {
		this.orderKey = orderKey;
	public void setDescp(String descp) {
		this.descp = descp;
	}
	@Column(value=DE.id_32,nullable=true)
	public String getOrgId() {
		return orgId;
	@Column(handlerClass=LongHandler.class,dbType="INT8",fixSqlValueWithInsert="0",insertable=true,nullable=false,renewable=false,queryable=true)
	public long getPageViews() {
		return pageViews;
	}
	public void setOrgId(String orgId) {
		this.orgId = orgId;
	public void setPageViews(long pageViews) {
		this.pageViews = pageViews;
	}
	@Column(DE.bigSerial)
	public long getShareId() {
		return shareId;
	}
	public void setShareId(long shareId) {
		this.shareId = shareId;
	}
	
}

src/main/java/com/ekexiu/portal/po/DemandSubOrIndus.java

@@ -1,43 +0,0 @@
package com.ekexiu.portal.po;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table
@PrimaryKey("id")
public class DemandSubOrIndus{
	private String id;
	private int sort;
	private String subOrIndus;
	private String demandId;
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(DE.int_de)
	public int getSort() {
		return sort;
	}
	public void setSort(int sort) {
		this.sort = sort;
	}
	@Column(DE.string_de)
	public String getSubOrIndus() {
		return subOrIndus;
	}
	public void setSubOrIndus(String subOrIndus) {
		this.subOrIndus = subOrIndus;
	}
	@Column(DE.id_32)
	public String getDemandId() {
		return demandId;
	}
	public void setDemandId(String demandId) {
		this.demandId = demandId;
	}
}

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

@@ -2,8 +2,6 @@ package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
@@ -13,212 +11,197 @@ import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.RequestParam;
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;
import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.po.Demand;
import com.ekexiu.portal.po.DemandSubOrIndus;
import com.ekexiu.portal.pojo.EditProfessor;
@Path("/demand")
public class DemandService {
	public static final String MAX_CREATETIME="9";
	
	public static final String MAX_CREATETIME = "9";
	@Autowrie
	private DemandDao demandDao;
	@Autowrie
	private DemandSubOrIndusDao demandSubOrIndusDao;
	@Autowrie
	private ProfessorDao professorDao;
	@Autowrie
	private ImageService imageService;
	@Autowrie
	private OrgService orgService;
	@Autowrie
	private GrowthLogService growthLogService;
	
	public DemandDao getDemandDao() {
		return demandDao;
	}
	public void setDemandDao(DemandDao demandDao) {
		this.demandDao = demandDao;
	}
	public DemandSubOrIndusDao getDemandSubOrIndusDao() {
		return demandSubOrIndusDao;
	}
	public void setDemandSubOrIndusDao(DemandSubOrIndusDao demandSubOrIndusDao) {
		this.demandSubOrIndusDao = demandSubOrIndusDao;
	}
	public ProfessorDao getProfessorDao() {
		return professorDao;
	}
	public void setProfessorDao(ProfessorDao professorDao) {
		this.professorDao = professorDao;
	}
	public ImageService getImageService() {
		return imageService;
	}
	public void setImageService(ImageService imageService) {
		this.imageService = imageService;
	}
	public OrgService getOrgService() {
		return orgService;
	}
	public void setOrgService(OrgService orgService) {
		this.orgService = orgService;
	}
	public GrowthLogService getGrowthLogService() {
		return growthLogService;
	}
	public void setGrowthLogService(GrowthLogService growthLogService) {
		this.growthLogService = growthLogService;
	}
	
	/**
	 * 发布需求
	 * @param con
	 * @param demand  
	 * @throws SQLException
	 */
	@Post
	@Path
	public void insert(@JdbcConn(true) Connection con,Demand demand,@Nullable String[] args)throws SQLException{
	public String  insert(@JdbcConn(true) Connection con,@RequestParam(excludeFields={"id","state","createTime","modifyTime","shareId","pageViews","modifier"})  Demand demand)throws SQLException{
		String demandId = StringUtil.buildUUID();
		demand.setDemandId(demandId);
		demand.setDemandStatus("1");
		demand.setOrderKey(System.nanoTime());
		demand.setId(demandId);
		demand.setState("1");
		if(demand.getCost()==null){
			demand.setCost("0");
		}
		if(demand.getDuration()==null){
			demand.setDuration("0");
		}
		demand.setModifier(demand.getCreator());
		this.demandDao.insert(con, demand);
		if(args != null){
			for (int i = 0; i < args.length; i++) {
				DemandSubOrIndus subOrIndus = new DemandSubOrIndus();
				subOrIndus.setId(StringUtil.buildUUID());
				subOrIndus.setSort(i+1);
				subOrIndus.setSubOrIndus(args[i]);
				subOrIndus.setDemandId(demandId);
				this.demandSubOrIndusDao.insert(con, subOrIndus);
			}
		return demandId;
	}
	/**
	 * 修改需求
	 * @param con
	 * @param demand
	 * @throws SQLException
	 */
	@Post
	@Path("/modify")
	public boolean update(@JdbcConn(true) Connection con,@RequestParam(excludeFields={"state","createTime","modifyTime","title","descp","orgId","creator","pageViews","shareId"}) Demand demand)throws SQLException{
		if(demand.getCost()==null){
			demand.setCost("0");
		}
		if(demand.getDuration()==null){
			demand.setDuration("0");
		}
//		if("1".equals(demand.getDemandType())){
//			//发布个人需求给发布者增加积分
//			this.growthLogService.addProDemand(con, demand.getDemander());
//		}else if("2".equals(demand.getDemandType())){
//			//发布企业需求给发布者增加积分
//			this.growthLogService.addOrgDemand(con, demand.getDemander());
//		}
		demand.setState("1");
		return this.demandDao.update(con, demand)>0;	
	}
	
	/**
	 * 完成需求
	 * @param con
	 * @param id  需求ID
	 * @param uid 操作用户ID
	 * @return
	 * @throws SQLException
	 */
	@Post
	@Path("/over")
	public boolean over(@JdbcConn(true) Connection con,String id,String uid)throws SQLException{
		return this.demandDao.over(con, id, uid)>0;
	}
	/**
	 * 关闭需求
	 * @param con
	 * @param id 需求ID
	 * @param uid 需求ID
	 * @return
	 * @throws SQLException
	 */
	@Post
	@Path("/close")
	public void closeDemand(@JdbcConn(true) Connection con,String demandId)throws SQLException{
		SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
		String closeTime = sdf.format(new Date());
		//更新需求状态为关闭-0
		this.demandDao.updateDemandStatus(con, demandId, "0", closeTime);
	public boolean close(@JdbcConn(true) Connection con,String id,String uid)throws SQLException{
		return this.demandDao.close(con, id, uid)>0;
	}
	
	@Get
	@Path("/queryOne")
	public Demand queryOne(@JdbcConn Connection con,String demandId)throws SQLException{
		Demand demand = this.demandDao.queryOne(con, demandId);
		EditProfessor professor = this.professorDao.queryBaseInfo(con, demand.getDemander());
		if(professor != null){
			professor.setHasHeadImage(this.imageService.hasProfessorImage(demand.getDemander()));
		}
		demand.setProfessor(professor);
		if(demand.getOrgId() != null){
			demand.setOrganization(this.orgService.query(con, demand.getOrgId()));
		}
		return demand;
	/**
	 * 延期需求
	 * @param con
	 * @param id 需求ID
	 * @param uid 操作用户ID
	 * @param day 延期日期 YYYYMMD
	 * @return
	 * @throws SQLException
	 */
	@Post
	@Path("/defer")
	public boolean defer(@JdbcConn(true) Connection con,String id,String uid,String day)throws SQLException{
		return this.demandDao.defer(con, id,uid,day)>0;
	}
	
	/**
	 * 查询我发布中的需求总数
	 * 增加浏览量
	 * @param con
	 * @param demander 发布者ID
	 * @return 返回状态发布中的需求总数
	 * @param id 需求ID
	 * @throws SQLException
	 * @throws JfwBaseException 
	 */
	@Get
	@Path("/queryMyPublish")
	public int queryMyPublish(@JdbcConn Connection con,String demander)throws SQLException, JfwBaseException{
		return this.demandDao.queryCountByStatus(con, demander, "1");
	@Post
	@Path("/incPageViews")
	public void incPageViews(@JdbcConn(true) Connection con,String id)throws SQLException{
		this.demandDao.incPageViews(con, id);
	}
	
	/**
	 * 查询需求数量
	 * @param con
	 * @param state  需求状态
	 * @param uid    发布者ID
	 * @param oid   发布者发布时机构ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/queryPublish")
	public int queryPublish(@JdbcConn Connection con)throws SQLException, JfwBaseException{
		return this.demandDao.queryCountStatus(con, "1");
	@Path("/qc")
	public int queryCount(@JdbcConn Connection con,@Nullable String[] state,@Nullable String uid,@Nullable String oid)throws SQLException{
		return this.demandDao.cnt(con, state, uid,oid);
	}
	
	/**
	 * 查询需求
	 * @param con
	 * @param id  需求ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/qaForOrg")
	public List<Demand> queryForOrg(@JdbcConn Connection con,String orgId)throws SQLException{
		return this.demandDao.queryForOrg(con, orgId);
	@Path("/qo")
	public Demand queryOne(@JdbcConn Connection con, String id)throws SQLException{
		return this.demandDao.query(con, id);
	}
	
	/**
	 * 根据分享ID 查询需求
	 * @param con
	 * @param id 分享ID
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/byDemander")
	public List<Demand> queryByDemander(@JdbcConn Connection con,String demander)throws SQLException{
		List<Demand> demands = this.demandDao.queryByDemander(con, demander);
		return demands;
	@Path("/byShareId")
	public Demand queryByShareId(@JdbcConn Connection con ,long id)throws SQLException{
		return this.demandDao.query(con, id);
	}
	
	/**
	 * 查询需求列表
	 * @param con
	 * @param id 需求ID 数组
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/pqDemander")
	public PageQueryResult<Demand> pageQueryByDemander(@JdbcConn Connection con,String demander,@Nullable String demandStatus,
			@DefaultValue("0") int sortType,@DefaultValue("5") int pageSize,@DefaultValue("1") int pageNo)throws SQLException{
		return this.demandDao.pageQueryByDemander(con, demander, demandStatus, sortType, pageSize, pageNo);
	@Path("/qm")
	public List<Demand> queryOne(@JdbcConn Connection con, String[] id)throws SQLException{
		return this.demandDao.query(con, id);
	}
	
	/**
	 * 分页查询需求(按状态及发布时间排序)
	 * @param con
	 * @param state
	 * @param uid
	 * @param oid
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/pq")
	public PageQueryResult<Demand> pageQuery(@JdbcConn Connection con,@Nullable String demandAim,
			@DefaultValue("0") int sortType,@DefaultValue("5") int pageSize,@DefaultValue("1") int pageNo)throws SQLException{
		PageQueryResult<Demand> queryResult = this.demandDao.pageQuery(con, "1", demandAim, sortType, pageSize, pageNo);
		List<Demand> demands = queryResult.getData();
		for (Demand demand : demands) {
			EditProfessor professor = this.professorDao.queryBaseInfo(con, demand.getDemander());
			if(professor != null){
				professor.setHasHeadImage(this.imageService.hasProfessorImage(demand.getDemander()));
			}
			demand.setProfessor(professor);
		}
		queryResult.setData(demands);
		return queryResult;
	}
	
	@Get
	@Path("/pqOrg")
	public PageQueryResult<Demand> pageQueryOrg(@JdbcConn Connection con,String orgId,@Nullable String demandStatus,
			@DefaultValue("0") int sortType,@DefaultValue("5") int pageSize,@DefaultValue("1") int pageNo)throws SQLException{
		PageQueryResult<Demand> queryResult = this.demandDao.pageQueryOrg(con, orgId, demandStatus, sortType, pageSize, pageNo);
		List<Demand> demands = queryResult.getData();
		for (Demand demand : demands) {
			EditProfessor professor = this.professorDao.queryBaseInfo(con, demand.getDemander());
			if(professor != null){
				professor.setHasHeadImage(this.imageService.hasProfessorImage(demand.getDemander()));
			}
			demand.setProfessor(professor);
		}
		queryResult.setData(demands);
		return queryResult;
	public PageQueryResult<Demand> query(@JdbcConn Connection con,@Nullable String[] state,@Nullable String uid,@Nullable String oid,@DefaultValue("1") int pageNo,@DefaultValue("5") int pageSize)throws SQLException{
		return this.demandDao.pageQuery(con, state, uid, oid,pageSize,pageNo);
	}
	
	/**
	 * 分页查询需求(按发布时间排序)
	 * @param con
	 * @param state
	 * @param uid
	 * @param oid
	 * @return
	 * @throws SQLException
	 */
	@Get
	@Path("/ql")
	public List<Demand> queryByStatus(@JdbcConn Connection con,@Nullable String demandAim,@Nullable String subject,
			@Nullable String industry,@DefaultValue("com.ekexiu.portal.service.DemandService.MAX_CREATETIME") String createTime,
			@DefaultValue("Long.MAX_VALUE") long orderKey,@DefaultValue("20") int rows,@DefaultValue("0") int sortType)throws SQLException{
		if(subject != null) subject = "%"+subject+"%";
		if(industry != null) industry = "%"+industry+"%";
		List<Demand> demands = this.demandDao.queryByStatus(con, "1", demandAim, subject, industry, createTime, orderKey, rows, sortType);
		for (Demand demand : demands) {
			EditProfessor professor = this.professorDao.queryBaseInfo(con, demand.getDemander());
			if(professor != null){
				professor.setHasHeadImage(this.imageService.hasProfessorImage(demand.getDemander()));
			}
			demand.setProfessor(professor);
		}
		return demands;
	@Path("/search")
	public PageQueryResult<Demand> query(@JdbcConn Connection con,@Nullable String key,@DefaultValue("1") int pageNo,@DefaultValue("5") int pageSize)throws SQLException{
		return this.demandDao.pageQuery(con, key==null?key:("%"+key+"%"),pageSize,pageNo);
	}
}

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

@@ -20,7 +20,6 @@ import com.ekexiu.portal.dao.PpaperDao;
import com.ekexiu.portal.po.PaperAgree;
import com.ekexiu.portal.po.PaperAuthor;
import com.ekexiu.portal.po.Ppaper;
import com.ekexiu.portal.po.Ppatent;
import com.ekexiu.portal.pojo.AssedPaper;
@Path("/ppaper")

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

@@ -30,12 +30,15 @@ import org.jfw.util.StringUtil;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.portal.dao.ArticleDao;
import com.ekexiu.portal.dao.DemandDao;
import com.ekexiu.portal.dao.HonorDao;
import com.ekexiu.portal.dao.ImageDao;
import com.ekexiu.portal.dao.OrgDao;
import com.ekexiu.portal.dao.OrgResStaffDao;
import com.ekexiu.portal.dao.PaperAuthorDao;
import com.ekexiu.portal.dao.PaperDao;
import com.ekexiu.portal.dao.PartTimeJobDao;
import com.ekexiu.portal.dao.PatentAuthorDao;
import com.ekexiu.portal.dao.PatentDao;
import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.ProfessorEduBgDao;
@@ -98,10 +101,41 @@ public class ProfessorService {
	private ProjectDao projectDao;
	@Autowrie
	private OrgResStaffDao orgResStaffDao;
	@Autowrie
	private PatentAuthorDao patentAuthorDao;
	@Autowrie
	private PaperAuthorDao paperAuthorDao;
	@Autowrie
	private KeyWordService keyWordService;
	@Autowrie
	private DemandDao demandDao;
	public DemandDao getDemandDao() {
		return demandDao;
	}
	public void setDemandDao(DemandDao demandDao) {
		this.demandDao = demandDao;
	}
	public PatentAuthorDao getPatentAuthorDao() {
		return patentAuthorDao;
	}
	public void setPatentAuthorDao(PatentAuthorDao patentAuthorDao) {
		this.patentAuthorDao = patentAuthorDao;
	}
	public PaperAuthorDao getPaperAuthorDao() {
		return paperAuthorDao;
	}
	public void setPaperAuthorDao(PaperAuthorDao paperAuthorDao) {
		this.paperAuthorDao = paperAuthorDao;
	}
	public KeyWordService getKeyWordService() {
		return keyWordService;
	}
@@ -317,6 +351,26 @@ public class ProfessorService {
		return professor.getId();
	}
	@Post
	@Path("/org")
	public boolean updateOrgid(@JdbcConn(true) Connection con, String id, String name) throws SQLException, IOException {
		Professor p = this.professorDao.query(con, id);
		if (p != null) {
			String oid = this.orgService.createOrganization(con, name);
			String old = p.getOrgId();
			if (!oid.equals(old)) {
				this.professorDao.updateOrg(con, oid, id);
				if (old != null) {
					this.professorDao.updateOrgAuth(con, id, "0");
					this.demandDao.closeByCreator(con,id, id);
					this.orgResStaffDao.deletePro(con, id);
				}
				return true;
			}
		}
		return false;
	}
	@Put
	@Path
	public void update(@JdbcConn(true) Connection con, @RequestBody EditProfessor professor) throws SQLException, IOException {
@@ -326,7 +380,23 @@ public class ProfessorService {
			} else {
				professor.setOrgId(this.orgService.createOrganization(con, professor.getOrgName()));
			}
		this.professorDao.update(con, professor);
		Professor op = this.professorDao.query(con, professor.getId());
		String old_oid = op.getOrgId();
		String new_oid = professor.getOrgId();
		if (this.professorDao.update(con, professor) > 0) {
			if (!professor.getName().equals(op.getName())) {
				this.paperAuthorDao.cAss(con, professor.getId());
				this.patentAuthorDao.cAss(con, professor.getId());
			}
			if (old_oid != null && (!old_oid.equals(new_oid))) {
				this.professorDao.updateOrgAuth(con, op.getId(), "0");
				this.demandDao.closeByCreator(con, op.getId(), op.getId());
				this.orgResStaffDao.deletePro(con, op.getId());
			}
		}
		;
	}
	@Post
@@ -338,7 +408,22 @@ public class ProfessorService {
			} else {
				professor.setOrgId(this.orgService.createOrganization(con, professor.getOrgName()));
			}
		this.professorDao.update(con, professor);
		Professor op = this.professorDao.query(con, professor.getId());
		String old_oid = op.getOrgId();
		String new_oid = professor.getOrgId();
		if (this.professorDao.update(con, professor) > 0) {
			if (!professor.getName().equals(op.getName())) {
				this.paperAuthorDao.cAss(con, professor.getId());
				this.patentAuthorDao.cAss(con, professor.getId());
			}
			if (old_oid != null && (!old_oid.equals(new_oid))) {
				this.professorDao.updateOrgAuth(con, op.getId(), "0");
				this.demandDao.closeByCreator(con, op.getId(), op.getId());
				this.orgResStaffDao.deletePro(con, op.getId());
			}
		}
		;
	}
	@Get
@@ -734,6 +819,7 @@ public class ProfessorService {
	/**
	 * 增加用户浏览量
	 * 
	 * @param con
	 * @param id
	 * @throws SQLException
@@ -743,56 +829,56 @@ public class ProfessorService {
	public void incPageViews(@JdbcConn(true) Connection con, String id) throws SQLException {
		this.professorDao.incPageViews(con, id);
	}
	
	@Get
	@Path("/ralateProfessors")
	public List<Professor> ralateArticles(@JdbcConn Connection con,String professorId,@DefaultValue("5") int rows)throws SQLException{
	public List<Professor> ralateArticles(@JdbcConn Connection con, String professorId, @DefaultValue("5") int rows) throws SQLException {
		String[] ids = this.professorDao.queryProfessorIdWithSameKeyWord(con, professorId, rows);
		if(ids!=null){
			 List<Professor> ret = this.professorDao.query(con,ids);
			 return ret;
		if (ids != null) {
			List<Professor> ret = this.professorDao.query(con, ids);
			return ret;
		}
		return Collections.<Professor>emptyList();
		return Collections.<Professor> emptyList();
	}
	
	@Get
	@Path("/coadjutant")
	public List<Map<String,Object>> queryCoadjutant(@JdbcConn Connection con,String id,@DefaultValue("5") int rows)throws SQLException{
		PreparedStatement ps = con.prepareStatement("SELECT professor_id,SUM (patent_count) patent_count,	SUM (paper_count) paper_count, "+
	    "SUM (tc) tc FROM ((SELECT professor_id,COUNT (1) patent_count,0 paper_count,COUNT (1) tc FROM patent_author WHERE patent_id IN ("+
		"SELECT DISTINCT patent_id FROM patent_author WHERE professor_id = ? ) AND professor_id <> ? AND professor_id <> '################################' "+
		"GROUP BY professor_id) UNION ALL (SELECT professor_id,0 patent_count,COUNT (1) paper_count,COUNT (1) tc	FROM paper_author WHERE paper_id IN (	SELECT DISTINCT "+
		"paper_id FROM paper_author WHERE professor_id = ? ) AND professor_id <>?  AND professor_id <> '################################' GROUP BY professor_id ) "
		+") _T_ GROUP BY professor_id ORDER BY tc DESC LIMIT ?");
		try{
			ps.setString(1,id);
			ps.setString(2,id);
			ps.setString(3,id);
			ps.setString(4,id);
			ps.setInt(5,rows);
	public List<Map<String, Object>> queryCoadjutant(@JdbcConn Connection con, String id, @DefaultValue("5") int rows) throws SQLException {
		PreparedStatement ps = con.prepareStatement("SELECT professor_id,SUM (patent_count) patent_count,	SUM (paper_count) paper_count, "
				+ "SUM (tc) tc FROM ((SELECT professor_id,COUNT (1) patent_count,0 paper_count,COUNT (1) tc FROM patent_author WHERE patent_id IN ("
				+ "SELECT DISTINCT patent_id FROM patent_author WHERE professor_id = ? ) AND professor_id <> ? AND professor_id <> '################################' "
				+ "GROUP BY professor_id) UNION ALL (SELECT professor_id,0 patent_count,COUNT (1) paper_count,COUNT (1) tc	FROM paper_author WHERE paper_id IN (	SELECT DISTINCT "
				+ "paper_id FROM paper_author WHERE professor_id = ? ) AND professor_id <>?  AND professor_id <> '################################' GROUP BY professor_id ) "
				+ ") _T_ GROUP BY professor_id ORDER BY tc DESC LIMIT ?");
		try {
			ps.setString(1, id);
			ps.setString(2, id);
			ps.setString(3, id);
			ps.setString(4, id);
			ps.setInt(5, rows);
			ResultSet rs = ps.executeQuery();
			try{
				List<Map<String,Object>> ret = new ArrayList<Map<String,Object>>();
				while(rs.next()){
					Map<String,Object> row = new HashMap<String,Object>();
			try {
				List<Map<String, Object>> ret = new ArrayList<Map<String, Object>>();
				while (rs.next()) {
					Map<String, Object> row = new HashMap<String, Object>();
					ret.add(row);
					row.put("professorId",rs.getString(1));
					row.put("patentCount",rs.getInt(2));
					row.put("paperCount",rs.getInt(3));
					row.put("professorId", rs.getString(1));
					row.put("patentCount", rs.getInt(2));
					row.put("paperCount", rs.getInt(3));
				}
				return ret;
			}finally{
			} finally {
				JdbcUtil.close(rs);
			}
		}finally{
		} finally {
			JdbcUtil.close(ps);
		}
	}
	
//	
//	
//	@Get
//	@Path("/articleRef")
	//
	//
	// @Get
	// @Path("/articleRef")
	public static void main(String[] args) throws Exception {
		// Connection con =

src/main/resources/database.sql

@@ -2021,7 +2021,49 @@ COMMENT ON COLUMN discover_banner.modify_time IS '修改时间';
COMMENT ON COLUMN discover_banner.modifier IS '最后修改人ID';
COMMENT ON COLUMN discover_banner.create_time IS '创建时间';
COMMENT ON COLUMN discover_banner.creator IS '创建人ID';
COMMENT ON COLUMN public.discover_banner.location IS '显示位置';
COMMENT ON COLUMN discover_banner.location IS '显示位置';
  --- modify begin at version 2.0
  drop table DEMAND_SUB_OR_INDUS;
  drop table DEMAND;
  CREATE TABLE DEMAND (
  	ID CHAR(32) NOT NULL,
  	TITLE TEXT NOT NULL,
  	PROVINCE TEXT NOT NULL,
  	CITY TEXT,
  	COST CHAR(1) NOT NULL,
  	DURATION CHAR(1) NOT NULL,
  	INVALID_DAY CHAR(8) NOT NULL,
  	CONTACT_NUM TEXT NOT NULL,
  	STATE CHAR(1) NOT NULL,
  	ORG_ID CHAR(32) NOT NULL,
  	MODIFIER CHAR(32) NOT NULL,
  	CREATOR CHAR(32) NOT NULL,
  	DESCP TEXT NOT NULL,
  	PAGE_VIEWS INT8 NOT NULL,
  	SHARE_ID bigserial NOT NULL,
  	CREATE_TIME CHAR(14) NOT NULL,
  	MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE DEMAND ADD PRIMARY KEY (ID);
COMMENT ON TABLE DEMAND IS '需求';
COMMENT ON COLUMN  DEMAND.ID          IS '需求ID';
COMMENT ON COLUMN  DEMAND.TITLE       IS '主题';
COMMENT ON COLUMN  DEMAND.PROVINCE    IS '省份';
COMMENT ON COLUMN  DEMAND.CITY        IS '城市';
COMMENT ON COLUMN  DEMAND.COST        IS '费用预算';
COMMENT ON COLUMN  DEMAND.DURATION    IS '预计时长';
COMMENT ON COLUMN  DEMAND.INVALID_DAY IS '有效期';
COMMENT ON COLUMN  DEMAND.CONTACT_NUM IS '联系电话';
COMMENT ON COLUMN  DEMAND.STATE       IS '状态';
COMMENT ON COLUMN  DEMAND.ORG_ID      IS '发布人发布时机构ID';
COMMENT ON COLUMN  DEMAND.MODIFIER    IS '最后修改人';
COMMENT ON COLUMN  DEMAND.CREATOR     IS '发布人';
COMMENT ON COLUMN  DEMAND.DESCP       IS '内容';
COMMENT ON COLUMN  DEMAND.PAGE_VIEWS  IS '浏览量';
COMMENT ON COLUMN  DEMAND.SHARE_ID    IS '分享ID';
COMMENT ON COLUMN  DEMAND.CREATE_TIME IS '发布时间';
COMMENT ON COLUMN  DEMAND.MODIFY_TIME IS '最后修改时间，=完成时间 =关闭时间';