From 3bfb96d2f2664d906409334f3790eace14075301 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 26 六月 2024 10:11:04 +0800
Subject: [PATCH] 日志添加

---
 utils/output_data_util.py |   26 +++++++++++++++-----------
 1 files changed, 15 insertions(+), 11 deletions(-)

diff --git a/utils/output_data_util.py b/utils/output_data_util.py
index eb819ce..872e961 100644
--- a/utils/output_data_util.py
+++ b/utils/output_data_util.py
@@ -1,3 +1,4 @@
+from log_module.log import logger_debug
 from third_data import kpl_data_manager, kpl_block_util
 from trade.l2_transaction_data_manager import HuaXinBuyOrderManager
 from utils import tool, output_util
@@ -41,18 +42,21 @@
     if latest_datas is None:
         latest_datas = []
     for b in blocks:
-        current_codes = kpl_data_manager.KPLLimitUpDataRecordManager.get_current_codes_by_block(b)
-        current_codes_count = 0 if not current_codes else len(current_codes)
-        temp_records = []
-        for r in limit_up_records_data:
-            temp_blocks = {r[2]}
-            temp_blocks |= set(r[6].split("銆�"))
-            if b in temp_blocks:
-                temp_records.append(r)
-        rank = kpl_block_util.get_code_current_rank(code, b, latest_datas, code_limit_up_reasons_dict, [], [], [], 0)
+        try:
+            current_codes = kpl_data_manager.KPLLimitUpDataRecordManager.get_current_codes_by_block(b)
+            current_codes_count = 0 if not current_codes else len(current_codes)
+            temp_records = []
+            for r in limit_up_records_data:
+                temp_blocks = {r[2]}
+                temp_blocks |= set(r[6].split("銆�"))
+                if b in temp_blocks:
+                    temp_records.append(r)
+            rank = kpl_block_util.get_code_current_rank(code, b, latest_datas, code_limit_up_reasons_dict, [], [], [], 0)
 
-        blockInfos.append({"name": b, "totalLimitUpCount": len(temp_records),
-                           "openLimitUpCount": len(temp_records) - current_codes_count, "rank": rank[0] + 1})
+            blockInfos.append({"name": b, "totalLimitUpCount": len(temp_records),
+                               "openLimitUpCount": len(temp_records) - current_codes_count, "rank": rank[0] + 1})
+        except:
+            logger_debug.error(f"blocks:{blocks}")
 
     # 缁熻鏉垮潡鐨�
     fresults["blockInfos"] = blockInfos

--
Gitblit v1.8.0