浏览代码

update logs

deason 10 月之前
父节点
当前提交
9cd79d8d8f

+ 2 - 2
examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/job/AfterHandInExamJobHandler.java

@@ -41,12 +41,12 @@ public class AfterHandInExamJobHandler {
 
             pageNo++;
             sumTodoSize += todoList.size();
-            log.warn("   分片任务_交卷后_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
-
             if (CollectionUtils.isEmpty(todoList)) {
+                log.warn("   分片任务_交卷后_{}_{} 本次处理考试记录数:{}", shardTotal, shardIndex, sumTodoSize);
                 break;
             }
 
+            log.warn("   分片任务_交卷后_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
             int curTodoIndex = 0;
             for (ExamRecordDataEntity data : todoList) {
                 final String lockKey = CacheConstants.LOCK_EXAM_CONTROL + data.getStudentId();

+ 2 - 2
examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/job/BeforeHandInExamJobHandler.java

@@ -59,12 +59,12 @@ public class BeforeHandInExamJobHandler {
 
             pageNo++;
             sumTodoSize += todoList.size();
-            log.warn("  分片任务_交卷前_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
-
             if (CollectionUtils.isEmpty(todoList)) {
+                log.warn("  分片任务_交卷前_{}_{} 本次处理考试记录数:{}", shardTotal, shardIndex, sumTodoSize);
                 break;
             }
 
+            log.warn("  分片任务_交卷前_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
             for (ExamRecordDataEntity data : todoList) {
                 final String lockKey = CacheConstants.LOCK_EXAM_CONTROL + data.getStudentId();
                 try {

+ 2 - 2
examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/job/SyncExamRecordDataJobHandler.java

@@ -71,12 +71,12 @@ public class SyncExamRecordDataJobHandler {
 
             pageNo++;
             sumTodoSize += todoList.size();
-            log.warn("分片任务_同步归档_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
-
             if (CollectionUtils.isEmpty(todoList)) {
+                log.warn("分片任务_同步归档_{}_{} 本次处理考试记录数:{}", shardTotal, shardIndex, sumTodoSize);
                 break;
             }
 
+            log.warn("分片任务_同步归档_{}_{} pageNo:{} 当前条数:{} 累计条数:{}", shardTotal, shardIndex, pageNo, todoList.size(), sumTodoSize);
             for (ExamRecordDataEntity data : todoList) {
                 final String lockKey = CacheConstants.LOCK_EXAM_CONTROL + data.getStudentId();
                 try {