修改分布式锁调用代码

调整事务执行时长

examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/pipeline/AfterHandInExamExecutor.java

@@ -46,7 +46,7 @@ public class AfterHandInExamExecutor implements NodeExecuter<Long, ExamRecordDat
 
         try {
             //添加考试控制全局锁
-            SequenceLockHelper.getLock(sequenceLockKey);
+            SequenceLockHelper.getLockSimple(sequenceLockKey);
 
             List<KeyValuePair<Long, ExamRecordData>> resultList = new ArrayList<>();
             KeyValuePair<Long, ExamRecordData> keyValuePair = new KeyValuePair<>(key, examRecordData);
@@ -85,7 +85,7 @@ public class AfterHandInExamExecutor implements NodeExecuter<Long, ExamRecordDat
             resultList.add(keyValuePair);
             return resultList;
         } finally {
-            SequenceLockHelper.releaseLock(sequenceLockKey);
+            SequenceLockHelper.releaseLockSimple(sequenceLockKey);
         }
     }
 

examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/pipeline/ClearExamDataCacheExecutor.java

@@ -37,7 +37,7 @@ public class ClearExamDataCacheExecutor implements NodeExecuter<Long, ExamRecord
 
         try {
             //添加考试控制全局锁
-            SequenceLockHelper.getLock(sequenceLockKey);
+            SequenceLockHelper.getLockSimple(sequenceLockKey);
 
             //只有已同步成功的数据，才执行清理操作
             if (SyncStatus.SYNCED == examRecordData.getSyncStatus()) {
@@ -46,7 +46,7 @@ public class ClearExamDataCacheExecutor implements NodeExecuter<Long, ExamRecord
 
             return null;
         } finally {
-            SequenceLockHelper.releaseLock(sequenceLockKey);
+            SequenceLockHelper.releaseLockSimple(sequenceLockKey);
         }
     }
 

examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/pipeline/HandInExamExecutor.java

@@ -45,7 +45,7 @@ public class HandInExamExecutor implements NodeExecuter<Long, ExamRecordData, Lo
 
         try {
             //添加考试控制全局锁
-            SequenceLockHelper.getLock(sequenceLockKey);
+            SequenceLockHelper.getLockSimple(sequenceLockKey);
 
             List<KeyValuePair<Long, ExamRecordData>> resultList = new ArrayList<>();
             KeyValuePair<Long, ExamRecordData> keyValuePair = new KeyValuePair<>(key, examRecordData);
@@ -76,7 +76,7 @@ public class HandInExamExecutor implements NodeExecuter<Long, ExamRecordData, Lo
             resultList.add(keyValuePair);
             return resultList;
         } finally {
-            SequenceLockHelper.releaseLock(sequenceLockKey);
+            SequenceLockHelper.releaseLockSimple(sequenceLockKey);
         }
     }
 

examcloud-core-oe-task-service/src/main/java/cn/com/qmth/examcloud/core/oe/task/service/pipeline/SyncExamDataExecutor.java

@@ -63,7 +63,7 @@ public class SyncExamDataExecutor implements NodeExecuter<Long, ExamRecordData,
 
         try {
             //添加考试控制全局锁
-            SequenceLockHelper.getLock(sequenceLockKey);
+            SequenceLockHelper.getLockSimple(sequenceLockKey);
 
             //如果已同步，直接返回
             if (SyncStatus.SYNCED == examRecordData.getSyncStatus()) {
@@ -106,7 +106,7 @@ public class SyncExamDataExecutor implements NodeExecuter<Long, ExamRecordData,
 
             return resultList;
         } finally {
-            SequenceLockHelper.releaseLock(sequenceLockKey);
+            SequenceLockHelper.releaseLockSimple(sequenceLockKey);
         }
     }
 

examcloud-core-oe-task-starter/src/main/java/cn/com/qmth/examcloud/core/oe/task/starter/config/StreamTaskExecutor.java

@@ -35,7 +35,7 @@ public class StreamTaskExecutor implements ApplicationRunner {
     private ClearExamDataCacheExecutor clearExamDataCacheExecutor;
 
     private static Integer DEFAULT_GAIN_EXAM_DATA_EXECUTOR_SLEEP_SECONDS = 0;
-    private static Integer DEFAULT_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS = 5 * 60;
+    private static Integer DEFAULT_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS = 10;
     private static Integer DEFAULT_AFTER_HAND_IN_EXAM_EXECUTOR_SLEEP_SECONDS = 5;
     private static Integer DEFAULT_SYNC_EXAM_DATA_EXECUTOR_SLEEP_SECONDS = 5;
     private static Integer DEFAULT_CLEAR_EXAM_DATA_CACHE_EXECUTOR_SLEEP_SECONDS = 5;