|
@@ -33,7 +33,7 @@ import java.util.List;
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 同步考试记录数据任务
|
|
|
|
|
|
+ * 交卷后同步考试记录数据任务
|
|
*/
|
|
*/
|
|
@Component
|
|
@Component
|
|
public class SyncExamRecordDataJobHandler {
|
|
public class SyncExamRecordDataJobHandler {
|
|
@@ -72,11 +72,11 @@ public class SyncExamRecordDataJobHandler {
|
|
pageNo++;
|
|
pageNo++;
|
|
sumTodoSize += todoList.size();
|
|
sumTodoSize += todoList.size();
|
|
if (CollectionUtils.isEmpty(todoList)) {
|
|
if (CollectionUtils.isEmpty(todoList)) {
|
|
- log.warn("分片任务_同步归档_{}_{} 本次处理考试记录数:{}", shardTotal, shardIndex, sumTodoSize);
|
|
|
|
|
|
+ log.warn("分片任务_交卷后同步_{}_{} 本次处理考试记录数:{}", shardTotal, shardIndex, sumTodoSize);
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
|
|
|
|
- log.warn("分片任务_同步归档_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
|
|
|
|
|
|
+ log.warn("分片任务_交卷后同步_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
|
|
for (ExamRecordDataEntity data : todoList) {
|
|
for (ExamRecordDataEntity data : todoList) {
|
|
final String lockKey = CacheConstants.LOCK_EXAM_CONTROL + data.getStudentId();
|
|
final String lockKey = CacheConstants.LOCK_EXAM_CONTROL + data.getStudentId();
|
|
try {
|
|
try {
|