|
@@ -29,7 +29,7 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
* @author lideyin
|
|
|
* @date 2019/7/31 16:40
|
|
|
*/
|
|
|
- @Query(value = "select * from ec_oe_exam_capture_queue "
|
|
|
+ @Query(value = "select * from ec_oet_exam_capture_queue "
|
|
|
+ " where status IN ('PENDING','PROCESS_FACE_COMPARE_FAILED') " +
|
|
|
" and (process_batch_num is null or (process_batch_num is not null and process_batch_num!=?2))"
|
|
|
+ " order by priority desc,id asc limit ?1", nativeQuery = true)
|
|
@@ -42,7 +42,7 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
* @param processBatchNum 批次号
|
|
|
* @return List<ExamCaptureQueueEntity>
|
|
|
*/
|
|
|
- @Query(value = "select * from ec_oe_exam_capture_queue "
|
|
|
+ @Query(value = "select * from ec_oet_exam_capture_queue "
|
|
|
+ " where status IN ('PROCESS_FACE_COMPARE_COMPLETE','PROCESS_FACELIVENESS_FAILED') and process_batch_num!=?2 "
|
|
|
+ " order by priority desc,id asc limit ?1", nativeQuery = true)
|
|
|
List<ExamCaptureQueueEntity> findNeedFacelivenessDetectExamCaptureQueuesLimit(Integer limit, String processBatchNum);
|
|
@@ -57,7 +57,7 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
* @param examRecordDataId
|
|
|
* @return
|
|
|
*/
|
|
|
- @Query(value = "select * from ec_oe_exam_capture_queue where exam_record_data_id=?1 limit 1", nativeQuery = true)
|
|
|
+ @Query(value = "select * from ec_oet_exam_capture_queue where exam_record_data_id=?1 limit 1", nativeQuery = true)
|
|
|
ExamCaptureQueueEntity existsUnhandledByExamRecordDataId(Long examRecordDataId);
|
|
|
|
|
|
/**
|
|
@@ -67,7 +67,7 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
*/
|
|
|
@Transactional
|
|
|
@Modifying
|
|
|
- @Query(value = "update ec_oe_exam_capture_queue set status = 'PROCESSING' where id = ?1", nativeQuery = true)
|
|
|
+ @Query(value = "update ec_oet_exam_capture_queue set status = 'PROCESSING' where id = ?1", nativeQuery = true)
|
|
|
void updateExamCaptureQueueStatusWithProcessing(Long id);
|
|
|
|
|
|
|
|
@@ -80,7 +80,7 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
*/
|
|
|
@Transactional
|
|
|
@Modifying
|
|
|
- @Query(value = "update ec_oe_exam_capture_queue set priority=?1 where exam_record_data_id=?2", nativeQuery = true)
|
|
|
+ @Query(value = "update ec_oet_exam_capture_queue set priority=?1 where exam_record_data_id=?2", nativeQuery = true)
|
|
|
void updateExamCaptureQueuePriority(int priority, Long examRecordDataId);
|
|
|
|
|
|
/**
|
|
@@ -92,13 +92,13 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
*/
|
|
|
@Transactional
|
|
|
@Modifying
|
|
|
- @Query(value = "update ec_oe_exam_capture_queue set error_msg=?2,`status`=?3,process_batch_num=?4,error_num=error_num+1,update_time=?5 where id=?1", nativeQuery = true)
|
|
|
+ @Query(value = "update ec_oet_exam_capture_queue set error_msg=?2,`status`=?3,process_batch_num=?4,error_num=error_num+1,update_time=?5 where id=?1", nativeQuery = true)
|
|
|
void saveExamCaptureQueueEntityByFailed(Long captureQueueId, String errorMsg, String status, String batchNumber,
|
|
|
Date updateDate);
|
|
|
|
|
|
@Transactional
|
|
|
@Modifying
|
|
|
- @Query(value = "update ec_oe_exam_capture_queue set is_pass=?2,is_stranger=?3,`status`=?4,face_compare_result=?5,face_compare_start_time=?6,update_time=?7 where id=?1", nativeQuery = true)
|
|
|
+ @Query(value = "update ec_oet_exam_capture_queue set is_pass=?2,is_stranger=?3,`status`=?4,face_compare_result=?5,face_compare_start_time=?6,update_time=?7 where id=?1", nativeQuery = true)
|
|
|
void saveExamCaptureQueueEntityBySuccessful(Long captureQueueId, Boolean isPass, Boolean isStranger, String status,
|
|
|
String faceCompareResult, Long faceCompareStartTime, Date updateDate);
|
|
|
|
|
@@ -109,6 +109,6 @@ public interface ExamCaptureQueueRepo extends JpaRepository<ExamCaptureQueueEnti
|
|
|
*/
|
|
|
@Transactional
|
|
|
@Modifying
|
|
|
- @Query(value = "update ec_oe_exam_capture_queue set process_batch_num=?2 where id=?1", nativeQuery = true)
|
|
|
+ @Query(value = "update ec_oet_exam_capture_queue set process_batch_num=?2 where id=?1", nativeQuery = true)
|
|
|
void updateProcessBatchNum(Long captureQueueId, String batchNum);
|
|
|
}
|