--add ProScoreTaskJobEntry.java;

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

@@ -0,0 +1,70 @@
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 ProScoreTaskJobEntry implements Runnable {
	private static Logger logger = Logger.getLogger(ProScoreTaskJobEntry.class);
	private String taskTime;
	private long delayTime;
	@Autowrie("dataSource")
	private DataSource dataSource;
	@Autowrie
	private 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;
	}
	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;
	}
	@Override
	public void run() {
		try {
			Connection con =dataSource.getConnection();
			try{
				professorService.updateScorePercent(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/job/TaskJob.java

@@ -22,6 +22,7 @@ public class TaskJob implements AfterBeanFactory {
	public void handle(BeanFactory bf) throws Throwable {
	
		TaskJobEntry tje = (TaskJobEntry) bf.getBean("com_ekexiu_portal_job_TaskJobEntry");
		ProScoreTaskJobEntry pstje = (ProScoreTaskJobEntry) bf.getBean("com_ekexiu_portal_job_ProScoreTaskJobEntry");
//		UserLogTaskJobEntry ultje = (UserLogTaskJobEntry) bf.getBean("com_ekexiu_portal_job_UserLogTaskJobEntry");
		DictTaskJobEntry dtje =(DictTaskJobEntry) bf.getBean("com_ekexiu_portal_job_DictTaskJobEntry");
		final WeixinService weixin =(WeixinService)bf.getBean("com_ekexiu_portal_service_WeixinService");
@@ -34,6 +35,11 @@ public class TaskJob implements AfterBeanFactory {
        this.service = JfwAppContext.getScheduledExecutorService();
        // 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间  
		service.scheduleAtFixedRate(tje, taskTime, delayTime, TimeUnit.MILLISECONDS);
		
		long pstjeTask = getTimeMillis(pstje.getTaskTime());
		long pstjeTaskTime = pstjeTask - System.currentTimeMillis();
		pstjeTaskTime = pstjeTaskTime > 0 ? pstjeTaskTime : pstjeTaskTime + pstje.getDelayTime();
		service.scheduleAtFixedRate(pstje, pstjeTaskTime, pstje.getDelayTime(), TimeUnit.MILLISECONDS);
//		service.scheduleAtFixedRate(ultje, taskTime, delayTime, TimeUnit.MILLISECONDS);
		service.scheduleAtFixedRate(dtje, 1, dtje.getDelayTime(), TimeUnit.SECONDS);
		service.scheduleAtFixedRate(new Runnable() {

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

@@ -0,0 +1,19 @@
package com.ekexiu.portal.pojo;
public class InviteUserScore {
	private String inviteUser;
	private int score;
	public String getInviteUser() {
		return inviteUser;
	}
	public void setInviteUser(String inviteUser) {
		this.inviteUser = inviteUser;
	}
	public int getScore() {
		return score;
	}
	public void setScore(int score) {
		this.score = score;
	}
	
}