添加计算专家平均星级的定时任务，每天晚上2点更新专家平均星级。

src/main/java/com/ekexiu/portal/job/TaskJob.java

@@ -0,0 +1,32 @@
package com.ekexiu.portal.job;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import org.jfw.apt.annotation.Bean;
import org.jfw.util.bean.AfterBeanFactory;
import org.jfw.util.bean.BeanFactory;
@Bean
public class TaskJob implements AfterBeanFactory {
	
	@Override
	public void handle(BeanFactory bf) throws Throwable {
	
		TaskJobEntry tje = (TaskJobEntry) bf.getBean("com_ekexiu_portal_job_TaskJobEntry");
		long delayTime = tje.getDelayTime();
		SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
		Date date = sdf.parse(tje.getTaskTime());
		long task = date.getTime();
		long taskTime = task - System.currentTimeMillis();
		taskTime = taskTime > 0 ? taskTime : delayTime + taskTime;
		
        ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
        // 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间  
//        service.scheduleAtFixedRate(tje, tje.getStartTime(), tje.getIntervalTime(), TimeUnit.SECONDS);
        service.scheduleAtFixedRate(tje, taskTime, delayTime, TimeUnit.MILLISECONDS);
	} 
}

src/main/java/com/ekexiu/portal/job/TaskJobEntry.java

@@ -0,0 +1,69 @@
package com.ekexiu.portal.job;
import java.sql.Connection;
import java.text.SimpleDateFormat;
import java.util.Date;
import javax.sql.DataSource;
import org.apache.log4j.Logger;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Bean;
import com.ekexiu.portal.service.ProfessorService;
@Bean
public class TaskJobEntry implements Runnable{
	private static Logger logger = Logger.getLogger(TaskJobEntry.class);
	private String taskTime;
	private long delayTime;
	@Autowrie("dataSource")
	private DataSource dataSource;
	@Autowrie
	private ProfessorService professorService;
	public DataSource getDataSource() {
		return dataSource;
	}
	public void setDataSource(DataSource dataSource) {
		this.dataSource = dataSource;
	}
	public ProfessorService getProfessorService() {
		return professorService;
	}
	public void setProfessorService(ProfessorService professorService) {
		this.professorService = professorService;
	}
	public String getTaskTime() {
		return taskTime;
	}
	public void setTaskTime(String taskTime) {
		this.taskTime = taskTime;
	}
	public long getDelayTime() {
		return delayTime;
	}
	public void setDelayTime(long delayTime) {
		this.delayTime = delayTime;
	}
	@Override
	public void run() {
		try {
			Connection con =dataSource.getConnection();
			try{
				professorService.updateStarAvg(con);
                con.commit();
                SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                logger.info("执行定时任务，更新专家平均星级"+df.format(new Date()));
            }catch(Exception e){
                try{con.rollback();
                }catch(Exception e1){e1.printStackTrace();}
            }finally{
                try{con.close();
                }catch(Exception e){e.printStackTrace();} 
            }
		} catch (Exception e) {
			e.printStackTrace();
		}
		
	}
	
}

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

@@ -258,7 +258,7 @@ public class ProfessorService {
		return this.professorDao.query(con);
	}
	
	public boolean updateStarAvg(Connection con) throws SQLException {
	public void updateStarAvg(Connection con) throws SQLException {
		try {
			List<Professor> professors = this.professorDao.queryStar(con);
			BigDecimal bigStar = this.professorDao.queryBigStar(con);
@@ -271,11 +271,9 @@ public class ProfessorService {
				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;
		}
	}
	

src/main/java/com/ekexiu/portal/util/Calculate.java

@@ -6,8 +6,8 @@ import org.jfw.apt.annotation.Bean;
@Bean
public class Calculate {
	private double starWeight = 0.5;
	private double consultWeight = 0.5;
	private double starWeight;
	private double consultWeight;
	
	public double getStarWeight() {
		return starWeight;
@@ -57,7 +57,8 @@ public class Calculate {
	}
	
	public static BigDecimal div(BigDecimal d1,BigDecimal d2) {
		return d1.divide(d2);
		//指定除法计算结果的精度为2，四舍五入。
		return d1.divide(d2, 2, BigDecimal.ROUND_HALF_UP);
	}
	
}