From 0bc0d21140904ad09cae456ea83b62cfbc4063ac Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 06 十一月 2024 16:49:48 +0800
Subject: [PATCH] bug修复

---
 output/code_info_output.py |   21 +++++++++++++--------
 1 files changed, 13 insertions(+), 8 deletions(-)

diff --git a/output/code_info_output.py b/output/code_info_output.py
index b80723a..5d8b97d 100644
--- a/output/code_info_output.py
+++ b/output/code_info_output.py
@@ -15,6 +15,7 @@
 from l2.l2_data_manager import OrderBeginPosInfo
 from l2.l2_data_util import L2DataUtil
 from third_data.code_plate_key_manager import KPLCodeJXBlockManager
+from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager
 from utils import global_util, tool
 from log_module import log, log_export
 from l2 import l2_data_manager, l2_data_util, transaction_progress, l2_data_manager_new, code_price_manager
@@ -114,7 +115,8 @@
 
         # 鑾峰彇閲忓弬鑰冩棩鏈�
         try:
-            volume_refer_date, volume_refer_date_distance = code_volumn_manager.CodeVolumeManager().get_volume_refer_date(code)
+            volume_refer_date, volume_refer_date_distance = code_volumn_manager.CodeVolumeManager().get_volume_refer_date(
+                code)
             params["trade_data"]["volume_refer_date"] = volume_refer_date
         except:
             pass
@@ -296,10 +298,17 @@
     __start_time = time.time()
 
     # 鑾峰彇浠g爜鐨勫巻鍙叉定鍋滄暟鎹�,(娑ㄥ仠鍘熷洜,鏃ユ湡,鏉垮潡)
-    code_records = KPLLimitUpDataRecordManager.get_latest_infos(code, 4, False)[:2]
+    # code_records = KPLLimitUpDataRecordManager.get_latest_infos(code, 4, False)[:2]
+    # if code_records:
+    #     code_records = [(format_plate_output(k[0]), k[1], [format_plate_output(k1) for k1 in k[2].split("銆�")]) for k in
+    #                     code_records]
+    # 淇敼鍘嗗彶
+    code_records = LimitUpCodesBlockRecordManager().get_radical_buy_blocks_origin_data(code)
     if code_records:
-        code_records = [(format_plate_output(k[0]), k[1], [format_plate_output(k1) for k1 in k[2].split("銆�")]) for k in
-                        code_records]
+        code_records = [(f"{x[0]}x{x[1]}", x[2], '') for x in code_records]
+    else:
+        code_records = []
+
     params["kpl_code_info"]["code_records"] = code_records
 
     if not KPLLimitUpDataRecordManager.total_datas:
@@ -495,10 +504,6 @@
     records_new.reverse()
     records_new_data.reverse()
     return break_time, records_new, records_new_data
-
-
-
-
 
 
 # 杩斿洖鍐呭[锛堢被鍨�,buy_single_index,indexes锛塢

--
Gitblit v1.8.0