我的关注功能。

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

@@ -72,6 +72,51 @@ public abstract class ResourceDao {
	@From(Resource.class)
	public abstract int updateCooperationNotes(Connection con,String resourceId,@Set String cooperationNotes) throws SQLException;
	
	/**
	 * 查询资源基础信息(ID,名称,学术领域,应用行业,可提供服务,发布者ID,资源图片)
	 * @param con
	 * @param resourceId 资源ID
	 * @return 返回资源基础信息
	 * @throws SQLException
	 */
	public Resource queryBaseInfo(Connection con,String resourceId) throws SQLException{
        List<Image> images = this.imageDao.queryRes(con, resourceId);
        String sql = "SELECT RESOURCE_ID,RESOURCE_NAME,SUBJECT,INDUSTRY,SUPPORTED_SERVICES,PROFESSOR_ID"
        		+ " FROM RESOURCE WHERE RESOURCE_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(1,resourceId);
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    Resource resource = new Resource();
                    resource.setResourceId(rs.getString(1));
                    resource.setResourceName(rs.getString(2));
                    String m1 = rs.getString(3);
                    if(rs.wasNull()){
                        m1 = null;
                    }
                    resource.setSubject(m1);
                    String m2 = rs.getString(4);
                    if(rs.wasNull()){
                        m2 = null;
                    }
                    resource.setIndustry(m2);
                    resource.setSupportedServices(rs.getString(5));
                    resource.setProfessorId(rs.getString(6));
                    resource.setImages(images);
                    return resource;
                }else{
                    return null;
                }
            }finally{
                try{rs.close();}catch(Exception e1){}
            }
        }finally{
            try{ps.close();}catch(Exception e2){}
        }
    }
	
	public Resource query(Connection con,String resourceId) throws SQLException{
        List<Image> images = this.imageDao.queryRes(con, resourceId);
		int _m_1 = 1;

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

@@ -0,0 +1,45 @@
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 com.ekexiu.portal.po.Watch;
@DAO
public abstract class WatchDao {
	@Insert
	public abstract int insert(Connection con, Watch watch) throws SQLException;
	
	@DeleteWith
	@From(Watch.class)
	public abstract int delete(Connection con, String professorId, String watchObject) throws SQLException;
	
	@DeleteWith
	@From(Watch.class)
	public abstract int deletePro(Connection con, String professorId) throws SQLException;
	
	@DeleteWith
	@From(Watch.class)
	public abstract int deleteWatch(Connection con, String watchObject) throws SQLException;
	
//	@Nullable
//	@SelectOne
//	public abstract Watch queryOne(Connection con, String professorId, String watchObject) throws SQLException;
	
	@SelectList
	@OrderBy(" ORDER BY CREATE_TIME DESC ")
	public abstract List<Watch> queryPro(Connection con, String professorId, Integer watchType) throws SQLException;
	
	@SelectList
	@OrderBy(" ORDER BY CREATE_TIME DESC ")
	public abstract List<Watch> queryWatch(Connection con, String watchObject) throws SQLException;
	
}

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

@@ -218,7 +218,7 @@ public class Professor implements CreateTimeSupported, ModifyTimeSupported{
		this.starLevel = starLevel;
	}
	@Column(handlerClass=WIntHandler.class,dbType="INT",insertable=false,nullable=true,renewable=true,queryable=true)
	@Column(handlerClass=WIntHandler.class,dbType="INT",insertable=false,nullable=false,renewable=true,queryable=true)
	public Integer getConsultCount() {
		return consultCount;
	}

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

@@ -0,0 +1,69 @@
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.annotation.entry.Unique;
import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.defaultImpl.WIntHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.pojo.EditProfessor;
@Uniques(@Unique(clolumns = { "professorId","watchObject","watchType" }, name = "WATCH_RELATION_UQ"))
@PrimaryKey({"professorId","watchObject"})
@Table
public class Watch implements CreateTimeSupported {
	private String professorId;
	private String watchObject;
	private String createTime;
	private Integer watchType;
	private EditProfessor professor;
	private Resource resource;
	
	public EditProfessor getProfessor() {
		return professor;
	}
	public void setProfessor(EditProfessor professor) {
		this.professor = professor;
	}
	public Resource getResource() {
		return resource;
	}
	public void setResource(Resource resource) {
		this.resource = resource;
	}
	
	@Column(DE.id_32)
	public String getProfessorId() {
		return professorId;
	}
	public void setProfessorId(String professorId) {
		this.professorId = professorId;
	}
	
	@Column(DE.id_32)
	public String getWatchObject() {
		return watchObject;
	}
	public void setWatchObject(String watchObject) {
		this.watchObject = watchObject;
	}
	
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	
	@Column(handlerClass=WIntHandler.class,dbType="INT",insertable=true,nullable=false,renewable=true,queryable=true)
	public Integer getWatchType() {
		return watchType;
	}
	public void setWatchType(Integer watchType) {
		this.watchType = watchType;
	}
	
}

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

@@ -32,6 +32,7 @@ import com.ekexiu.portal.dao.ProjectDao;
import com.ekexiu.portal.dao.ResearchAreaDao;
import com.ekexiu.portal.dao.ResearchAreaLogDao;
import com.ekexiu.portal.dao.ResourceDao;
import com.ekexiu.portal.dao.WatchDao;
import com.ekexiu.portal.po.Professor;
import com.ekexiu.portal.pojo.EditProfessor;
import com.ekexiu.portal.pojo.ProfessorInfo;
@@ -39,6 +40,8 @@ import com.ekexiu.portal.util.Calculate;
@Path("/professor")
public class ProfessorService {
	@Autowrie
	private WatchDao watchDao;
	@Autowrie
	private Calculate calculate;
	@Autowrie
@@ -69,6 +72,14 @@ public class ProfessorService {
	private ProjectDao projectDao;
	
	public WatchDao getWatchDao() {
		return watchDao;
	}
	public void setWatchDao(WatchDao watchDao) {
		this.watchDao = watchDao;
	}
	public Calculate getCalculate() {
		return calculate;
	}
@@ -247,21 +258,25 @@ public class ProfessorService {
		return this.professorDao.query(con);
	}
	
	@Post
	@Path("/updateStarAvg")
	public boolean updateStarAvg(@JdbcConn(true) Connection con) throws SQLException {
		List<Professor> professors = this.professorDao.queryStar(con);
		BigDecimal bigStar = this.professorDao.queryBigStar(con);
		BigDecimal smallStar = this.professorDao.querySmallStar(con);
		BigDecimal bigConsult = this.professorDao.queryBigConsult(con);
		BigDecimal smallConsult = this.professorDao.querySmallConsult(con);
		for (Professor professor : professors) {
			BigDecimal star = professor.getStarLevel();
			BigDecimal consult = new BigDecimal(professor.getConsultCount());
			BigDecimal avgStar = this.calculate.calcAvgStar(bigStar, smallStar, bigConsult, smallConsult, star, consult);
			this.professorDao.updateStarAvg(con, professor.getId(), avgStar);
	public boolean updateStarAvg(Connection con) throws SQLException {
		try {
			List<Professor> professors = this.professorDao.queryStar(con);
			BigDecimal bigStar = this.professorDao.queryBigStar(con);
			BigDecimal smallStar = this.professorDao.querySmallStar(con);
			BigDecimal bigConsult = this.professorDao.queryBigConsult(con);
			BigDecimal smallConsult = this.professorDao.querySmallConsult(con);
			for (Professor professor : professors) {
				BigDecimal star = professor.getStarLevel();
				BigDecimal consult = new BigDecimal(professor.getConsultCount());
				BigDecimal avgStar = this.calculate.calcAvgStar(bigStar, smallStar, bigConsult, smallConsult, star, consult);
				this.professorDao.updateStarAvg(con, professor.getId(), avgStar);
			}
			return true;
		} catch (Exception e) {
			con.rollback();
			e.printStackTrace();
			return false;
		}
		return true;
	}
	
	@Get
@@ -345,6 +360,8 @@ public class ProfessorService {
		this.patentDao.delete(con, id);
		this.honorDao.delete(con, id);
		this.projectDao.delete(con, id);
		this.watchDao.deletePro(con, id);
		this.watchDao.deleteWatch(con, id);
	}
	
	@Get

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

@@ -20,11 +20,14 @@ import org.jfw.util.StringUtil;
import com.ekexiu.portal.dao.ImageDao;
import com.ekexiu.portal.dao.OperationDao;
import com.ekexiu.portal.dao.ResourceDao;
import com.ekexiu.portal.dao.WatchDao;
import com.ekexiu.portal.po.Operation;
import com.ekexiu.portal.po.Resource;
@Path("/resource")
public class ResourceService {
	@Autowrie
	private WatchDao watchDao;
	@Autowrie
	private ImageDao imageDao;
	@Autowrie
@@ -34,6 +37,14 @@ public class ResourceService {
	@Autowrie
	private OperationDao operationDao;
	public WatchDao getWatchDao() {
		return watchDao;
	}
	public void setWatchDao(WatchDao watchDao) {
		this.watchDao = watchDao;
	}
	public OperationDao getOperationDao() {
		return operationDao;
	}
@@ -145,6 +156,7 @@ public class ResourceService {
		if(operations.isEmpty()){
			this.imageDao.deleteRes(con, resourceId);
			this.resourceDao.delete(con, resourceId);
			this.watchDao.deleteWatch(con, resourceId);
			return true;
		}else{
			return false;

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

@@ -0,0 +1,115 @@
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.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 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.Resource;
import com.ekexiu.portal.po.Watch;
import com.ekexiu.portal.pojo.EditProfessor;
@Path("/watch")
public class WatchService {
	@Autowrie
	private WatchDao watchDao;
	@Autowrie
	private ProfessorDao professorDao;
	@Autowrie
	private ResourceDao resourceDao;
	@Autowrie
	private ImageService imageService;
	@Autowrie
	private ResearchAreaDao researchAreaDao;
	
	public WatchDao getWatchDao() {
		return watchDao;
	}
	public void setWatchDao(WatchDao watchDao) {
		this.watchDao = watchDao;
	}
	public ProfessorDao getProfessorDao() {
		return professorDao;
	}
	public void setProfessorDao(ProfessorDao professorDao) {
		this.professorDao = professorDao;
	}
	public ResourceDao getResourceDao() {
		return resourceDao;
	}
	public void setResourceDao(ResourceDao resourceDao) {
		this.resourceDao = resourceDao;
	}
	public ImageService getImageService() {
		return imageService;
	}
	public void setImageService(ImageService imageService) {
		this.imageService = imageService;
	}
	public ResearchAreaDao getResearchAreaDao() {
		return researchAreaDao;
	}
	public void setResearchAreaDao(ResearchAreaDao researchAreaDao) {
		this.researchAreaDao = researchAreaDao;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Watch watch) throws SQLException{
		this.watchDao.insert(con, watch);
		return watch.getWatchObject();
	}
	
	@Delete
	@Path("/delete")
	public void delete(@JdbcConn(true) Connection con, String professorId, String watchObject) throws SQLException{
		this.watchDao.delete(con, professorId, watchObject);
	}
	
	@Get
	@Path("/qaPro")
	public List<Watch> queryPro(@JdbcConn Connection con, String professorId, Integer watchType) throws SQLException{
		List<Watch> watchs = this.watchDao.queryPro(con, professorId, watchType);
		if(1 == watchType){
			for (Watch watch : watchs) {
				EditProfessor professor = this.professorDao.queryBaseInfo(con, watch.getWatchObject());
				professor.setHasHeadImage(this.imageService.hasProfessorImage(watch.getWatchObject()));
				professor.setResearchAreas(this.researchAreaDao.query(con, watch.getWatchObject()));
				professor.setResources(this.resourceDao.queryList(con, watch.getWatchObject()));
				watch.setProfessor(professor);
			}
		}else if(2 == watchType){
			for (Watch watch : watchs) {
				Resource resource = this.resourceDao.queryBaseInfo(con, watch.getWatchObject());
				resource.setProfessor(this.professorDao.queryBaseInfo(con, resource.getProfessorId()));
				watch.setResource(resource);
			}
		}
		return watchs;
	}
	
	@Get
	@Path("/qaWatch")
	public List<Watch> queryWatch(@JdbcConn Connection con, String watchObject) throws SQLException{
		List<Watch> watchs = this.watchDao.queryWatch(con, watchObject);
		for (Watch watch : watchs) {
			EditProfessor professor = this.professorDao.queryBaseInfo(con, watch.getProfessorId());
			professor.setHasHeadImage(this.imageService.hasProfessorImage(watch.getProfessorId()));
			professor.setResearchAreas(this.researchAreaDao.query(con, watch.getProfessorId()));
			professor.setResources(this.resourceDao.queryList(con, watch.getProfessorId()));
			watch.setProfessor(professor);
		}
		return watchs;
	}
	
}