소스 검색

增加task

chenken 6 년 전
부모
커밋
60d64a373b

+ 11 - 1
examcloud-task-service/pom.xml

@@ -29,6 +29,16 @@
 			<artifactId>examcloud-commons-api-client</artifactId>
 			<version>${examcloud.version}</version>
 		</dependency>
-
+		<dependency>
+			<groupId>cn.com.qmth.examcloud.rmi</groupId>
+			<artifactId>examcloud-core-oe-student-api-client</artifactId>
+			<version>${examcloud.version}</version>
+		</dependency>
+		
+		<dependency>
+			<groupId>cn.com.qmth.examcloud.rmi</groupId>
+			<artifactId>examcloud-core-oe-student-face-api-client</artifactId>
+			<version>${examcloud.version}</version>
+		</dependency>
 	</dependencies>
 </project>

+ 39 - 0
examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/job/ChangeExamCaptureQueueStatusTask.java

@@ -0,0 +1,39 @@
+package cn.com.qmth.examcloud.task.service.job;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import cn.com.qmth.examcloud.core.oe.student.api.OeStudentExamRecordCloudService;
+import cn.com.qmth.examcloud.core.oe.student.face.api.ExamCaptureQueueCloudService;
+import cn.com.qmth.examcloud.task.base.AbstractTask;
+import cn.com.qmth.examcloud.task.base.ScheduleJob;
+import cn.com.qmth.examcloud.task.base.TaskTracker;
+
+/**
+ * 
+ * @author  	chenken
+ * @date    	2018年9月22日 下午2:25:22
+ * @company 	QMTH
+ * @description 将超过XX分钟,还在处理中抓拍照片的状态修改为未处理
+ */
+@Component("changeExamCaptureQueueStatusTask")
+public class ChangeExamCaptureQueueStatusTask extends AbstractTask{
+	
+	@Autowired
+	TaskTracker taskTracker;
+	
+	@Autowired
+	private ExamCaptureQueueCloudService examCaptureQueueCloudService;
+	
+	@Override
+	public void run(ScheduleJob scheduleJob) throws Exception {
+		examCaptureQueueCloudService.changeExamCaptureQueueStatus();
+	}
+
+	@Override
+	public TaskTracker getTaskTracker() {
+		return taskTracker;
+	}
+	
+	
+}

+ 8 - 5
examcloud-task-service/src/main/java/cn/com/qmth/examcloud/task/service/job/OeCleanExamRecordTask.java

@@ -3,6 +3,7 @@ package cn.com.qmth.examcloud.task.service.job;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import cn.com.qmth.examcloud.core.oe.student.api.OeStudentExamRecordCloudService;
 import cn.com.qmth.examcloud.task.base.AbstractTask;
 import cn.com.qmth.examcloud.task.base.ScheduleJob;
 import cn.com.qmth.examcloud.task.base.TaskTracker;
@@ -18,16 +19,18 @@ import cn.com.qmth.examcloud.task.base.TaskTracker;
 public class OeCleanExamRecordTask extends AbstractTask {
 
 	@Autowired
-	TaskTracker TaskTracker;
-
+	TaskTracker taskTracker;
+	
+	@Autowired
+	private OeStudentExamRecordCloudService oeStudentExamRecordCloudService;
+	
 	@Override
 	public void run(ScheduleJob scheduleJob) throws Exception {
-
-		// 重新写
+		oeStudentExamRecordCloudService.cleanExamRecords();
 	}
 
 	@Override
 	public TaskTracker getTaskTracker() {
-		return TaskTracker;
+		return taskTracker;
 	}
 }