Merge branch 'hotfix/2025-02' into feature/uat-tmp

@@ -3775,7 +3775,10 @@ def fsm_compare(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=
     
     
     compare_log.info('[fsm thread]')
     compare_log.info('[fsm thread]')
     #pool = ThreadPoolExecutor(max_workers=6, thread_name_prefix="fsm_thread_")
     #pool = ThreadPoolExecutor(max_workers=6, thread_name_prefix="fsm_thread_")
-    pool.submit(fsm_compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms)
+    try:
+        pool.submit(fsm_compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms)
+    except Exception as e:
+        compare_log.info('[fsm thread fail] [error={0}]'.format(traceback.format_exc()))
     #pool.shutdown(wait=True)
     #pool.shutdown(wait=True)
     
     
 
 
@@ -3785,10 +3788,14 @@ def fsm_compare_thread(application_id, application_entity, uniq_seq, ocr_res_id,
                                            is_ca, is_cms))
                                            is_ca, is_cms))
 
 
     # 查看此订单号下是否有未完成的文件，如果有，等1分钟
     # 查看此订单号下是否有未完成的文件，如果有，等1分钟
-    doc_wait_file_class = HILDoc if application_entity == consts.HIL_PREFIX else AFCDoc
-    doc_wait_file_result = doc_wait_file_class.objects.filter(application_id=application_id, status=1).first()
-    compare_log.info('doc_wait_file_result:{0}'.format(doc_wait_file_result))
-    compare_log.info('{0} [comparison unfinished file check] [entity={1}] [id={2}] [doc_wait_file_result={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result))
+    try:
+        doc_wait_file_class = HILDoc if application_entity == consts.HIL_PREFIX else AFCDoc
+        doc_wait_file_result = doc_wait_file_class.objects.filter(application_id=application_id, status=1).first()
+        compare_log.info('doc_wait_file_result:{0}'.format(doc_wait_file_result))
+        compare_log.info('{0} [comparison unfinished file check] [entity={1}] [id={2}] [doc_wait_file_result={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result))
+    except Exception as e:
+        doc_wait_file_result = None
+        compare_log.info('[get doc_wait_file_result fail] [error={0}]'.format(traceback.format_exc()))
     if doc_wait_file_result is not None:
     if doc_wait_file_result is not None:
         # 实时查询延迟时间
         # 实时查询延迟时间
         try:
         try:
@@ -3853,7 +3860,10 @@ def compare(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True
 
 
     compare_log.info('[non fsm thread]')
     compare_log.info('[non fsm thread]')
     #pool = ThreadPoolExecutor(max_workers=6, thread_name_prefix="non_fsm_thread_")
     #pool = ThreadPoolExecutor(max_workers=6, thread_name_prefix="non_fsm_thread_")
-    pool.submit(compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms)
+    try:
+        pool.submit(compare_thread, application_id, application_entity, uniq_seq, ocr_res_id, is_ca, is_cms)
+    except Exception as e:
+        compare_log.info('[non fsm thread fail] [error={0}]'.format(traceback.format_exc()))
     #pool.shutdown(wait=True)
     #pool.shutdown(wait=True)
 
 
 def compare_thread(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True, is_cms=False):
 def compare_thread(application_id, application_entity, uniq_seq, ocr_res_id, is_ca=True, is_cms=False):
@@ -3903,10 +3913,14 @@ def compare_thread(application_id, application_entity, uniq_seq, ocr_res_id, is_
         return
         return
 
 
     # 查看此订单号下是否有未完成的文件，如果有，等?分钟
     # 查看此订单号下是否有未完成的文件，如果有，等?分钟
-    doc_wait_file_class = HILDoc if application_entity == consts.HIL_PREFIX else AFCDoc
-    doc_wait_file_result = doc_wait_file_class.objects.filter(application_id=application_id, status=1).first()
-    compare_log.info('doc_wait_file_result:{0}'.format(doc_wait_file_result))
-    compare_log.info('{0} [comparison unfinished file check] [entity={1}] [id={2}] [doc_wait_file_result={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result))
+    try:
+        doc_wait_file_class = HILDoc if application_entity == consts.HIL_PREFIX else AFCDoc
+        doc_wait_file_result = doc_wait_file_class.objects.filter(application_id=application_id, status=1).first()
+        compare_log.info('doc_wait_file_result:{0}'.format(doc_wait_file_result))
+        compare_log.info('{0} [comparison unfinished file check] [entity={1}] [id={2}] [doc_wait_file_result={3}]'.format(log_base, application_entity, application_id, doc_wait_file_result))
+    except Exception as e:
+        doc_wait_file_result = None
+        compare_log.info('[get doc_wait_file_result fail] [error={0}]'.format(traceback.format_exc()))
     if doc_wait_file_result is not None:
     if doc_wait_file_result is not None:
         # 实时查询延迟时间
         # 实时查询延迟时间
         try:
         try: