--add agree();add unAgree();

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

@@ -0,0 +1,31 @@
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.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import com.ekexiu.portal.po.ArticleAgree;
@DAO
public abstract class ArcicleAgreeDao {
	@Insert
	public abstract int insert(Connection con,ArticleAgree articleAgree)throws SQLException;
	
	@DeleteWith
	@From(ArticleAgree.class)
	public abstract int deleteAgree(Connection con,String operateId,String articleId)throws SQLException;
	
	@DeleteWith
	@From(ArticleAgree.class)
	public abstract int delete(Connection con,String articleId)throws SQLException;
	
	@SelectList
	public abstract List<ArticleAgree> query(Connection con,String articleId)throws SQLException;
	
}

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

@@ -13,6 +13,7 @@ import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.Dynamic;
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.SetSentence;
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.LimitSelect;
@@ -36,6 +37,16 @@ public abstract class ArticleDao {
	@Dynamic
	public abstract int update(Connection con, Article article) throws SQLException;
	
	@UpdateWith
	@From(Article.class)
	@SetSentence("ARTICLE_AGREE = ARTICLE_AGREE + 1")
	public abstract int incAgree(Connection con,String articleId) throws SQLException;
	
	@UpdateWith
	@From(Article.class)
	@SetSentence("ARTICLE_AGREE = ARTICLE_AGREE - 1")
	public abstract int decAgree(Connection con,String articleId) throws SQLException;
	
	@UpdateWith
	@From(Article.class)
	public abstract int updateSubject(Connection con, @Set String subject, String articleId) throws SQLException;

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

@@ -33,57 +33,57 @@ public abstract class ResearchAreaLogDao {
	public abstract int delete(Connection con,String professorId)throws SQLException;
	
	public List<EditResearchAreaLog> queryLimit(Connection con,String professorId,String caption,String createTime,int rows) throws SQLException{
        int _m_1 = 1;
        int index = 1;
        String sql = "SELECT OPRETE_PROFESSOR_ID,CREATE_TIME,PROFESSOR_ID,CAPTION FROM RESEARCH_AREA_LOG "
        		+ " WHERE CREATE_TIME < ? AND CAPTION = ? AND PROFESSOR_ID = ? ORDER BY CREATE_TIME DESC LIMIT "+rows;
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,createTime);
            ps.setString(_m_1++,caption);
            ps.setString(_m_1++,professorId);
            ps.setString(index++,createTime);
            ps.setString(index++,caption);
            ps.setString(index++,professorId);
            ResultSet rs = ps.executeQuery();
            try{
                List<EditResearchAreaLog> _result = new ArrayList<EditResearchAreaLog>();
                List<EditResearchAreaLog> areaLogs = new ArrayList<EditResearchAreaLog>();
                while(rs.next()){
                	EditResearchAreaLog _obj =  new EditResearchAreaLog();
                    _obj.setOpreteProfessorId(rs.getString(1));
                    _obj.setCreateTime(rs.getString(2));
                    _obj.setProfessorId(rs.getString(3));
                    _obj.setCaption(rs.getString(4));
                    _result.add(_obj);
                	EditResearchAreaLog areaLog =  new EditResearchAreaLog();
                	areaLog.setOpreteProfessorId(rs.getString(1));
                	areaLog.setCreateTime(rs.getString(2));
                	areaLog.setProfessorId(rs.getString(3));
                	areaLog.setCaption(rs.getString(4));
                    areaLogs.add(areaLog);
                }
                return _result;
                return areaLogs;
            }finally{
                try{rs.close();}catch(Exception _m_2){}
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_3){}
            try{ps.close();}catch(Exception e2){}
        }
    }
	
	public List<EditResearchAreaLog> query(Connection con,String professorId) throws SQLException{
        int _m_1 = 1;
        int index = 1;
        String sql = "SELECT OPRETE_PROFESSOR_ID,CREATE_TIME,PROFESSOR_ID,CAPTION FROM RESEARCH_AREA_LOG WHERE PROFESSOR_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,professorId);
            ps.setString(index++,professorId);
            ResultSet rs = ps.executeQuery();
            try{
                List<EditResearchAreaLog> _result = new ArrayList<EditResearchAreaLog>();
                List<EditResearchAreaLog> areaLogs = new ArrayList<EditResearchAreaLog>();
                while(rs.next()){
                	EditResearchAreaLog log =  new EditResearchAreaLog();
                	log.setOpreteProfessorId(rs.getString(1));
                	log.setCreateTime(rs.getString(2));
                	log.setProfessorId(rs.getString(3));
                	log.setCaption(rs.getString(4));
                    _result.add(log);
                	areaLogs.add(log);
                }
                return _result;
                return areaLogs;
            }finally{
                try{rs.close();}catch(Exception _m_2){}
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_3){}
            try{ps.close();}catch(Exception e2){}
        }
    }

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

@@ -0,0 +1,36 @@
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;
@Table
@PrimaryKey({"operateId","articleId"})
public class ArticleAgree implements CreateTimeSupported {
	private String operateId;
	private String articleId;
	private String createTime;
	@Column(DE.id_32)
	public String getOperateId() {
		return operateId;
	}
	public void setOperateId(String operateId) {
		this.operateId = operateId;
	}
	@Column(DE.id_32)
	public String getArticleId() {
		return articleId;
	}
	public void setArticleId(String articleId) {
		this.articleId = articleId;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
}

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

@@ -25,13 +25,17 @@ import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import com.ekexiu.portal.dao.ArcicleAgreeDao;
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.dao.WatchDao;
import com.ekexiu.portal.po.Article;
import com.ekexiu.portal.po.ArticleAgree;
import com.ekexiu.portal.po.Image;
import com.ekexiu.portal.pojo.FindInfo;
@Path("/article")
@@ -45,17 +49,23 @@ public class ArticleService {
	@Autowrie
	private ArticleDao articleDao;
	@Autowrie
	private ArcicleAgreeDao articleAgreeDao;
	@Autowrie
	private ProfessorDao professorDao;
	@Autowrie
	private ResourceDao resourceDao;
	@Autowrie
	private ImageService imageService;
	@Autowrie
	private ImagesService imagesService;
	@Autowrie
	private ResearchAreaDao researchAreaDao;
	@Autowrie
	private LeaveWordDao leaveWordDao;
	@Autowrie
	private OrgDao orgDao;
	@Autowrie
	private WatchDao watchDao;
	public String getDateFormat() {
		return dateFormat;
@@ -97,6 +107,14 @@ public class ArticleService {
		this.articleDao = articleDao;
	}
	
	public ArcicleAgreeDao getArticleAgreeDao() {
		return articleAgreeDao;
	}
	public void setArticleAgreeDao(ArcicleAgreeDao articleAgreeDao) {
		this.articleAgreeDao = articleAgreeDao;
	}
	public ProfessorDao getProfessorDao() {
		return professorDao;
	}
@@ -121,6 +139,14 @@ public class ArticleService {
		this.imageService = imageService;
	}
	public ImagesService getImagesService() {
		return imagesService;
	}
	public void setImagesService(ImagesService imagesService) {
		this.imagesService = imagesService;
	}
	public ResearchAreaDao getResearchAreaDao() {
		return researchAreaDao;
	}
@@ -145,6 +171,14 @@ public class ArticleService {
		this.orgDao = orgDao;
	}
	public WatchDao getWatchDao() {
		return watchDao;
	}
	public void setWatchDao(WatchDao watchDao) {
		this.watchDao = watchDao;
	}
	private byte[] resImage(byte[] src, int maxLen) throws IOException {
		ByteArrayInputStream in = new ByteArrayInputStream(src);
		ByteArrayOutputStream out = new ByteArrayOutputStream();
@@ -197,6 +231,7 @@ public class ArticleService {
			article.setArticleImg(this.createDate()+"/"+articleId+"."+JPG);
		}
		article.setArticleId(articleId);
		article.setArticleAgree(0);
		if(article.getProfessorId() != null && article.getOrgId() == null){
			article.setArticleType("1");
		}else if(article.getProfessorId() == null && article.getOrgId() != null){
@@ -219,6 +254,25 @@ public class ArticleService {
		this.articleDao.update(con, article);
	}
	
	@Post
	@Path("/agree")
	public void agree(@JdbcConn(true) Connection con,String operateId,String articleId)throws SQLException{
		if(this.articleDao.incAgree(con, articleId) > 0){
			ArticleAgree articleAgree = new ArticleAgree();
			articleAgree.setOperateId(operateId);
			articleAgree.setArticleId(articleId);
			this.articleAgreeDao.insert(con, articleAgree);
		}
	}
	
	@Post
	@Path("/unAgree")
	public void unAgree(@JdbcConn(true) Connection con,String operateId,String articleId)throws SQLException{
		if(this.articleDao.decAgree(con, articleId) > 0){
			this.articleAgreeDao.deleteAgree(con, operateId, articleId);
		}
	}
	
	@Get
	@Path("/qaPro")
	public List<Article> queryPro(@JdbcConn Connection con, String professorId) throws SQLException{
@@ -247,6 +301,16 @@ public class ArticleService {
	@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);
		List<FindInfo> findInfos = queryResult.getData();
		for (FindInfo findInfo : findInfos) {
			if("3".equals(findInfo.getType())){
				List<Image> images = this.imagesService.queryRes(con, findInfo.getId());
				if(images.size() > 0){
					findInfo.setImage(findInfo.getId()+".jpg");
				}
			}
		}
		queryResult.setData(findInfos);
		return queryResult;
	}
	
@@ -255,6 +319,8 @@ public class ArticleService {
	public void delete(@JdbcConn(true) Connection con, String articleId) throws SQLException{
		this.articleDao.delete(con, articleId);
		this.leaveWordDao.deleteArticle(con, articleId);
		this.articleAgreeDao.delete(con, articleId);
		this.watchDao.deleteWatch(con, articleId);
	}
}