--add Article.class

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

@@ -0,0 +1,47 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
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.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import com.ekexiu.portal.po.Article;
@DAO
public abstract class ArticleDao {
	@Insert
	public abstract int insert(Connection con, Article article) throws SQLException;
	
	@Update
	public abstract int update(Connection con, Article article) throws SQLException;
	
	@UpdateWith
	@From(Article.class)
	public abstract int updateSubject(Connection con, @Set String subject, String articleId) throws SQLException;
	
	@UpdateWith
	@From(Article.class)
	public abstract int updateIndustry(Connection con, @Set String industry, String articleId) throws SQLException;
	
	@DeleteWith
	@From(Article.class)
	public abstract int delete(Connection con, String articleId) throws SQLException;
	
	@DeleteWith
	@From(Article.class)
	public abstract int deletePro(Connection con, String professorId) throws SQLException;
	
	@SelectList
	@OrderBy(" ORDER BY CREATE_TIME DESC ")
	public abstract List<Article> queryPro(Connection con, String professorId) throws SQLException;
}

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

@@ -0,0 +1,86 @@
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.basepo.ModifyTimeSupported;
@Table
@PrimaryKey("articleId")
public class Article implements CreateTimeSupported, ModifyTimeSupported {
	private String articleId;
	private String professorId;
	private String articleTitle;
	private String articleContent;
	private String subject;
	private String industry;
	private String createTime;
	private String modifyTime;
	private String articleImg;
	
	@Column(DE.id_32)
	public String getArticleId() {
		return articleId;
	}
	public void setArticleId(String articleId) {
		this.articleId = articleId;
	}
	@Column(DE.id_32)
	public String getProfessorId() {
		return professorId;
	}
	public void setProfessorId(String professorId) {
		this.professorId = professorId;
	}
	@Column(value=DE.string_de,dbType="TEXT")
	public String getArticleTitle() {
		return articleTitle;
	}
	public void setArticleTitle(String articleTitle) {
		this.articleTitle = articleTitle;
	}
	@Column(value=DE.String_de,dbType="TEXT")
	public String getArticleContent() {
		return articleContent;
	}
	public void setArticleContent(String articleContent) {
		this.articleContent = articleContent;
	}
	@Column(value=DE.String_de,dbType="TEXT")
	public String getSubject() {
		return subject;
	}
	public void setSubject(String subject) {
		this.subject = subject;
	}
	@Column(value=DE.String_de,dbType="TEXT")
	public String getIndustry() {
		return industry;
	}
	public void setIndustry(String industry) {
		this.industry = industry;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	@Column(DE.String_de)
	public String getArticleImg() {
		return articleImg;
	}
	public void setArticleImg(String articleImg) {
		this.articleImg = articleImg;
	}
}

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

@@ -0,0 +1,165 @@
package com.ekexiu.portal.service;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
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;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Delete;
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.PathVar;
import org.jfw.util.JpgUtil;
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.po.Article;
@Path("/article")
public class ArticleService {
	private File tmpPath;
	private File articlePath;
	private int artMaxLen=640;
	private static final String JPG = "jpg";
	@Autowrie
	private ArticleDao articleDao;
	public File getTmpPath() {
		return tmpPath;
	}
	public void setTmpPath(File tmpPath) {
		this.tmpPath = tmpPath;
	}
	public File getArticlePath() {
		return articlePath;
	}
	public void setArticlePath(File articlePath) {
		this.articlePath = articlePath;
	}
	public int getArtMaxLen() {
		return artMaxLen;
	}
	public void setArtMaxLen(int artMaxLen) {
		this.artMaxLen = artMaxLen;
	}
	public ArticleDao getArticleDao() {
		return articleDao;
	}
	public void setArticleDao(ArticleDao articleDao) {
		this.articleDao = articleDao;
	}
	
	private byte[] resImage(byte[] src, int maxLen) throws IOException {
		ByteArrayInputStream in = new ByteArrayInputStream(src);
		ByteArrayOutputStream out = new ByteArrayOutputStream();
		JpgUtil.scalingZoom(in, out, maxLen);
		out.flush();
		return out.toByteArray();
	}
	
	private byte[] readTmpFile(String fn) throws JfwBaseException {
		File file = new File(this.tmpPath, fn);
		if (!file.exists())
			throw new JfwBaseException(90, "resource image not exists");
		try {
			InputStream in = new FileInputStream(file);
			ByteArrayOutputStream out = new ByteArrayOutputStream();
			IoUtil.copy(in, out, true, true);
			return out.toByteArray();
		} catch (IOException e) {
			throw new JfwBaseException(91, "read temp resource image error", e);
		}
	}
	
	private void saveArtImg(String fn, String id) throws JfwBaseException, IOException{
		byte[] src = this.readTmpFile(fn);
		src = JpgUtil.read(src);
		byte[] shareResImage = this.resImage(src, this.artMaxLen);
		File savePath = this.createDate(this.articlePath);
		IoUtil.saveStream(new FileOutputStream(new File(savePath, id + "." + JPG)), src, true);
		IoUtil.saveStream(new FileOutputStream(new File(savePath, id + "_s." + JPG)), shareResImage, true);
	}
	
	private File createDate(File path){
		SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-DD");
		String date = df.format(new Date());
		String datePath = path + "/" +  date;
		File dateFile = new File(datePath);
		if (!dateFile.exists()) {
			// 创建日期目录
			dateFile.mkdir();
		}
		return dateFile;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Article article) 
			throws SQLException, IOException, JfwBaseException{
		String articleId = StringUtil.buildUUID();
		if(article.getArticleImg() != null){
			this.saveArtImg(article.getArticleImg(), articleId);
			article.setArticleImg(this.createDate(this.articlePath)+"/"+articleId+"."+JPG);
		}
		article.setArticleId(articleId);
		this.articleDao.insert(con, article);
		return articleId;
	}
	
	@Post
	@Path("/updateArt")
	public void update(@JdbcConn(true) Connection con, Article article) 
			throws SQLException, JfwBaseException, IOException{
		if(article.getArticleImg() != null){
			this.saveArtImg(article.getArticleImg(), article.getArticleId());
			article.setArticleImg(this.createDate(this.articlePath)+"/"+article.getArticleId()+"."+JPG);
		}
		this.articleDao.update(con, article);
	}
	
	@Post
	@Path("/subject")
	public void updateSubject(@JdbcConn(true) Connection con, @Nullable String subject, String articleId) throws SQLException{
		this.articleDao.updateSubject(con, subject, articleId);
	}
	
	@Post
	@Path("/industry")
	public void updateIndustry(@JdbcConn(true) Connection con, @Nullable String industry, String articleId) throws SQLException{
		this.articleDao.updateIndustry(con, industry, articleId);
	}
	
	@Get
	@Path("/qaPro")
	public List<Article> queryPro(@JdbcConn Connection con, String professorId) throws SQLException{
		return this.articleDao.queryPro(con, professorId);
	}
	
	@Delete
	@Path("/{articleId}")
	public void delete(@JdbcConn(true) Connection con, @PathVar String articleId) throws SQLException{
		this.articleDao.delete(con, articleId);
	}
}