--add demand.java

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

@@ -0,0 +1,101 @@
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.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
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.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import com.ekexiu.portal.po.Demand;
@DAO
public abstract class DemandDao {
	@Insert
	public abstract int insert(Connection con,Demand demand)throws SQLException;
	
	@SelectOne
	@Nullable
	public abstract Demand queryOne(Connection con,String demandId)throws SQLException;
	
	@SelectList
	@OrderBy("ORDER BY CREATE_TIME DESC")
	public abstract List<Demand> queryByDemander(Connection con,String demander)throws SQLException;
	
	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> _result = 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));
                    _result.add(demand);
                }
                return _result;
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
	
}

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

@@ -0,0 +1,16 @@
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/po/Demand.java

@@ -0,0 +1,94 @@
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;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.pojo.EditProfessor;
@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 long orderKey;
	private EditProfessor professor;
	
	public EditProfessor getProfessor() {
		return professor;
	}
	public void setProfessor(EditProfessor professor) {
		this.professor = professor;
	}
	@Column(DE.id_32)
	public String getDemandId() {
		return demandId;
	}
	public void setDemandId(String demandId) {
		this.demandId = demandId;
	}
	@Column(DE.id_32)
	public String getDemander() {
		return demander;
	}
	public void setDemander(String demander) {
		this.demander = demander;
	}
	@Column(DE.singleChar)
	public String getDemandAim() {
		return demandAim;
	}
	public void setDemandAim(String demandAim) {
		this.demandAim = demandAim;
	}
	@Column(DE.singleChar)
	public String getDemandType() {
		return demandType;
	}
	public void setDemandType(String demandType) {
		this.demandType = demandType;
	}
	@Column(DE.string_de)
	public String getDemandTitle() {
		return demandTitle;
	}
	public void setDemandTitle(String demandTitle) {
		this.demandTitle = demandTitle;
	}
	@Column(DE.Text_de)
	public String getDemandContent() {
		return demandContent;
	}
	public void setDemandContent(String demandContent) {
		this.demandContent = demandContent;
	}
	@Column(DE.singleChar)
	public String getDemandStatus() {
		return demandStatus;
	}
	public void setDemandStatus(String demandStatus) {
		this.demandStatus = demandStatus;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(DE.long_de)
	public long getOrderKey() {
		return orderKey;
	}
	public void setOrderKey(long orderKey) {
		this.orderKey = orderKey;
	}
	
}

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

@@ -0,0 +1,43 @@
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

@@ -0,0 +1,117 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
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.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.util.StringUtil;
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";
	
	@Autowrie
	private DemandDao demandDao;
	@Autowrie
	private DemandSubOrIndusDao demandSubOrIndusDao;
	@Autowrie
	private ProfessorDao professorDao;
	@Autowrie
	private ImageService imageService;
	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;
	}
	
	@Post
	@Path
	public void insert(@JdbcConn(true) Connection con,Demand demand,@Nullable String[] args)throws SQLException{
		String demandId = StringUtil.buildUUID();
		demand.setDemandId(demandId);
		demand.setDemandStatus("1");
		demand.setOrderKey(System.nanoTime());
		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);
			}
		}
	}
	
	@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);
		return demand;
	}
	
	@Get
	@Path("/byDemander")
	public List<Demand> queryByDemander(@JdbcConn Connection con,String demander)throws SQLException{
		List<Demand> demands = this.demandDao.queryByDemander(con, demander);
		return demands;
	}
	
	@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;
	}
}