|
@@ -24,14 +24,15 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
/**
|
|
|
* 分片按考试记录ID取需要待处理的记录
|
|
|
*
|
|
|
- * @param shardTotal 分片总数
|
|
|
- * @param shardIndex 当前分片索引
|
|
|
- * @param batchSize 批量条数
|
|
|
+ * @param shardTotal 分片总数
|
|
|
+ * @param shardIndex 当前分片索引
|
|
|
+ * @param batchSize 批量条数
|
|
|
+ * @param maxErrorNum 最大重试错误次数
|
|
|
* @return
|
|
|
*/
|
|
|
@Query(value = "select exam_record_data_id from ec_oet_exam_capture_queue" +
|
|
|
- " where mod(exam_record_data_id,?1)=?2 group by exam_record_data_id limit ?3", nativeQuery = true)
|
|
|
- List<Long> findQueuesGroupByExamRecordDataId(Integer shardTotal, Integer shardIndex, Integer batchSize);
|
|
|
+ " where mod(exam_record_data_id,?1)=?2 and error_num < ?4 group by exam_record_data_id limit ?3", nativeQuery = true)
|
|
|
+ List<Long> findQueuesGroupByExamRecordDataId(Integer shardTotal, Integer shardIndex, Integer batchSize, Integer maxErrorNum);
|
|
|
|
|
|
/**
|
|
|
* @param limit 一次取值数量
|