--add queryPage();update insert();update queryOne();

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

@@ -1,7 +1,11 @@
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.Nullable;
@@ -16,8 +20,10 @@ 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.Set;
import org.jfw.util.PageQueryResult;
import com.ekexiu.portal.po.Article;
import com.ekexiu.portal.pojo.FindInfo;
@DAO
public abstract class ArticleDao {
@@ -48,8 +54,95 @@ public abstract class ArticleDao {
	@OrderBy(" ORDER BY MODIFY_TIME DESC ")
	public abstract List<Article> queryPro(Connection con, String professorId) throws SQLException;
	
	@SelectList
	@OrderBy(" ORDER BY MODIFY_TIME DESC")
	public abstract List<Article> queryOrg(Connection con, String orgId) throws SQLException;
	
	@SelectOne
	@Nullable
	public abstract Article queryOne(Connection con, String articleId) throws SQLException;
	
	public PageQueryResult<FindInfo> queryPage(Connection con,int pageSize,int pageNo) throws SQLException{
        int total = 0;
        PageQueryResult<FindInfo> queryResult = new PageQueryResult<FindInfo>();
        String sql = null;
        sql = "SELECT SUM(NUM) FROM (SELECT COUNT(1) NUM FROM ARTICLE UNION ALL SELECT COUNT(1) NUM FROM RESOURCE) TBL";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
        	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.<FindInfo>emptyList());
            return queryResult;
        }
        boolean firstPage = (1 == pageNo);
        if(firstPage){
        	queryResult.setPageNo(1);
        	sql = "SELECT ARTICLE_ID,ARTICLE_TITLE,ARTICLE_IMG,ARTICLE_TYPE,CREATE_TIME,ORG_ID,PROFESSOR_ID FROM ARTICLE"
                	+ " UNION ALL SELECT RESOURCE_ID,RESOURCE_NAME,NULL,'3',CREATE_TIME,NULL,PROFESSOR_ID FROM RESOURCE";
            sql = sql + " ORDER BY 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 ARTICLE_ID,ARTICLE_TITLE,ARTICLE_IMG,ARTICLE_TYPE,CREATE_TIME,ORG_ID,PROFESSOR_ID FROM ARTICLE"
                	+ " UNION ALL SELECT RESOURCE_ID,RESOURCE_NAME,NULL,'3',CREATE_TIME,NULL,PROFESSOR_ID FROM RESOURCE";
            sql = sql + " ORDER BY CREATE_TIME DESC ";
            sql = sql + " LIMIT " + pageSize+ " OFFSET " + offset;
        }
        ps = con.prepareStatement(sql);
        try{
            ResultSet rs = ps.executeQuery();
            try{
                List<FindInfo> findInfos = new ArrayList<FindInfo>();
                queryResult.setData(findInfos);
                int size = 0;
                while((size<pageSize) && rs.next()){
                    ++size;
                    FindInfo findInfo =  new FindInfo();
                    findInfo.setId(rs.getString(1));
                    findInfo.setName(rs.getString(2));
                    String image = rs.getString(3);
                    if(rs.wasNull()){
                    	image = null;
                    }
                    findInfo.setImage(image);
                    findInfo.setType(rs.getString(4));
                    findInfo.setCreateTime(rs.getString(5));
                    String orgId = rs.getString(6);
                    if(rs.wasNull()){
                    	findInfo.setOwner(rs.getString(7));
                    }else{
                    	findInfo.setOwner(orgId);
                    }
                    findInfos.add(findInfo);
                }
                return queryResult;
            }finally{
                try{rs.close();}catch(Exception e3){}
            }
        }finally{
            try{ps.close();}catch(Exception e4){}
        }
    }
}

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

@@ -3,6 +3,7 @@ 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.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@@ -21,6 +22,8 @@ public class Article implements CreateTimeSupported, ModifyTimeSupported {
	private String createTime;
	private String modifyTime;
	private String articleImg;
	private String orgId;
	private String articleType;
	private EditProfessor professor;
	
	@Column(DE.id_32)
@@ -30,7 +33,7 @@ public class Article implements CreateTimeSupported, ModifyTimeSupported {
	public void setArticleId(String articleId) {
		this.articleId = articleId;
	}
	@Column(DE.id_32)
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(32)",nullable=true,renewable=false)
	public String getProfessorId() {
		return professorId;
	}
@@ -90,5 +93,19 @@ public class Article implements CreateTimeSupported, ModifyTimeSupported {
	public void setProfessor(EditProfessor professor) {
		this.professor = professor;
	}
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(32)",nullable=true,renewable=false)
	public String getOrgId() {
		return orgId;
	}
	public void setOrgId(String orgId) {
		this.orgId = orgId;
	}
	@Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(1)",nullable=true,renewable=false)
	public String getArticleType() {
		return articleType;
	}
	public void setArticleType(String articleType) {
		this.articleType = articleType;
	}
}

src/main/java/com/ekexiu/portal/pojo/FindInfo.java

@@ -0,0 +1,47 @@
package com.ekexiu.portal.pojo;
public class FindInfo {
	private String id;
	private String name;
	private String createTime;
	private String owner;
	private String type;
	private String image;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getOwner() {
		return owner;
	}
	public void setOwner(String owner) {
		this.owner = owner;
	}
	public String getType() {
		return type;
	}
	public void setType(String type) {
		this.type = type;
	}
	public String getImage() {
		return image;
	}
	public void setImage(String image) {
		this.image = image;
	}
	
}

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

@@ -14,21 +14,27 @@ import java.util.Date;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
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.JpgUtil;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import com.ekexiu.portal.dao.ArticleDao;
import com.ekexiu.portal.dao.LeaveWordDao;
import com.ekexiu.portal.dao.OrgDao;
import com.ekexiu.portal.dao.ProfessorDao;
import com.ekexiu.portal.dao.ResearchAreaDao;
import com.ekexiu.portal.dao.ResourceDao;
import com.ekexiu.portal.po.Article;
import com.ekexiu.portal.pojo.EditOrganization;
import com.ekexiu.portal.pojo.EditProfessor;
import com.ekexiu.portal.pojo.FindInfo;
@Path("/article")
public class ArticleService {
@@ -47,6 +53,10 @@ public class ArticleService {
	private ImageService imageService;
	@Autowrie
	private ResearchAreaDao researchAreaDao;
	@Autowrie
	private LeaveWordDao leaveWordDao;
	@Autowrie
	private OrgDao orgDao;
	public String getDateFormat() {
		return dateFormat;
@@ -120,6 +130,22 @@ public class ArticleService {
		this.researchAreaDao = researchAreaDao;
	}
	public LeaveWordDao getLeaveWordDao() {
		return leaveWordDao;
	}
	public void setLeaveWordDao(LeaveWordDao leaveWordDao) {
		this.leaveWordDao = leaveWordDao;
	}
	public OrgDao getOrgDao() {
		return orgDao;
	}
	public void setOrgDao(OrgDao orgDao) {
		this.orgDao = orgDao;
	}
	private byte[] resImage(byte[] src, int maxLen) throws IOException {
		ByteArrayInputStream in = new ByteArrayInputStream(src);
		ByteArrayOutputStream out = new ByteArrayOutputStream();
@@ -172,6 +198,13 @@ public class ArticleService {
			article.setArticleImg(this.createDate()+"/"+articleId+"."+JPG);
		}
		article.setArticleId(articleId);
		if(article.getProfessorId() != null && article.getOrgId() == null){
			article.setArticleType("1");
		}else if(article.getProfessorId() == null && article.getOrgId() != null){
			article.setArticleType("2");
		}else{
			throw new JfwBaseException(-1, "错误参数：文章发布者ID");
		}
		this.articleDao.insert(con, article);
		return articleId;
	}
@@ -193,26 +226,47 @@ public class ArticleService {
		return this.articleDao.queryPro(con, professorId);
	}
	
	@Get
	@Path("/qaOrg")
	public List<Article> queryOrg(@JdbcConn Connection con,String orgId)throws SQLException{
		return this.articleDao.queryOrg(con, orgId);
	}
	
	@Get
	@Path("/query")
	public Article queryOne(@JdbcConn Connection con, String articleId) throws SQLException{
		Article article = this.articleDao.queryOne(con, articleId);
		if(article != null){
			EditProfessor professor = this.professorDao.queryBaseInfo(con, article.getProfessorId());
			if(professor != null){
				professor.setHasHeadImage(this.imageService.hasProfessorImage(professor.getId()));
				professor.setResearchAreas(this.researchAreaDao.query(con, professor.getId()));
				professor.setResources(this.resourceDao.queryPro(con, professor.getId()));
			if(article.getProfessorId() != null){
				EditProfessor professor = this.professorDao.queryBaseInfo(con, article.getProfessorId());
				if(professor != null){
					professor.setHasHeadImage(this.imageService.hasProfessorImage(professor.getId()));
					professor.setResearchAreas(this.researchAreaDao.query(con, professor.getId()));
					professor.setResources(this.resourceDao.queryPro(con, professor.getId()));
				}
				article.setProfessor(professor);
			}else if(article.getOrgId() != null){
				EditOrganization organization = this.orgDao.queryEditOrg(con, article.getOrgId());
				if(organization != null){
					organization.setHasOrgLogo(this.imageService.hasOrgLogo(organization.getId()));
				}
			}
			article.setProfessor(professor);
		}
		return article;
	}
	
	@Get
	@Path("/pqFind")
	public PageQueryResult<FindInfo> queryPage(@JdbcConn Connection con,@DefaultValue("10") int pageSize,@DefaultValue("1") int pageNo)throws SQLException{
		PageQueryResult<FindInfo> queryResult = this.articleDao.queryPage(con, pageSize, pageNo);
		return queryResult;
	}
	
	@Post
	@Path("/delete")
	public void delete(@JdbcConn(true) Connection con, String articleId) throws SQLException{
		this.articleDao.delete(con, articleId);
		this.leaveWordDao.deleteArticle(con, articleId);
	}
}