报表计算重置动作放在任务执行之前

examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/job/ReportsComputeTask.java

@@ -21,6 +21,9 @@ public class ReportsComputeTask extends AbstractTask {
 	
 	@Override
 	public void run(ScheduleJob scheduleJob) throws Exception {
+		//每次运行任务之前重置计算中和待终止的任务
+		reportsComputeService.initReportsCompute();
+		//取待处理的数据
 		int c=reportsComputeService.getTodoDataCount();
 		if(c>0) {
 			ReportsComputeProducer pro=new ReportsComputeProducer();

examcloud-task-starter/src/main/java/cn/com/qmth/examcloud/task/starter/config/SystemStartup.java

@@ -12,7 +12,6 @@ import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
 
 import cn.com.qmth.examcloud.commons.exception.ExamCloudRuntimeException;
-import cn.com.qmth.examcloud.task.service.ReportsComputeService;
 import cn.com.qmth.examcloud.web.bootstrap.PropertyHolder;
 
 /**
@@ -29,9 +28,6 @@ public class SystemStartup implements ApplicationRunner {
 	@Autowired
 	private DiscoveryClient discoveryClient;
 
-	@Autowired
-	private ReportsComputeService reportsComputeService;
-
 	public void start() {
 
 		String appName = PropertyHolder.getString("spring.application.name");
@@ -41,8 +37,6 @@ public class SystemStartup implements ApplicationRunner {
 				throw new ExamCloudRuntimeException("multiple task instances!");
 			}
 		}
-		// 初始化任务数据
-		initJobData();
 
 	}
 
@@ -51,8 +45,4 @@ public class SystemStartup implements ApplicationRunner {
 		start();
 	}
 
-	private void initJobData() {
-		// 成绩统计报表计算任务数据状态重置
-		reportsComputeService.initReportsCompute();
-	}
 }