From 48fb7a00951f91bdc707e5dd2d196e5bccb752c3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 18 六月 2025 18:41:30 +0800
Subject: [PATCH] 异常保护
---
output/code_info_output.py | 22 ++++++++++++----------
1 files changed, 12 insertions(+), 10 deletions(-)
diff --git a/output/code_info_output.py b/output/code_info_output.py
index 5d8b97d..c4b5844 100644
--- a/output/code_info_output.py
+++ b/output/code_info_output.py
@@ -16,6 +16,7 @@
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 trade.buy_radical.block_special_codes_manager import BlockSpecialCodesManager
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
@@ -80,7 +81,6 @@
code_extra_infos.append("鏆備笉涔�")
params["code"] = code
params["code_name"] = f"{gpcode_manager.get_code_name(code)} {code} 锛坽','.join(code_extra_infos)}锛�"
-
total_datas = l2_data_util.local_today_datas.get(code)
if total_datas is None:
total_datas = []
@@ -298,16 +298,16 @@
__start_time = time.time()
# 鑾峰彇浠ｇ爜鐨勫巻鍙叉定鍋滄暟鎹�,(娑ㄥ仠鍘熷洜,鏃ユ湡,鏉垮潡)
- # 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)
+ code_records = KPLLimitUpDataRecordManager.get_latest_infos(code, 4, False)[:2]
if code_records:
- code_records = [(f"{x[0]}x{x[1]}", x[2], '') for x in code_records]
- else:
- 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 = [(f"{x[0]}x{x[1]}", x[2], '') for x in code_records]
+ # else:
+ # code_records = []
params["kpl_code_info"]["code_records"] = code_records
@@ -494,6 +494,8 @@
elif type == trade_record_log_util.TYPE_CANCEL:
load_cancel_watch_index(latest_cancel_watch_index_dict)
records_new_data.append((time_, "鎾ゅ崟", f"鍘熷洜锛歿data['msg']}", []))
+ elif type == trade_record_log_util.TYPE_ACTION:
+ records_new_data.append((time_, data['type'], f"{data['msg']}", []))
load_cancel_watch_index(latest_cancel_watch_index_dict)
records_new_data.sort(key=lambda x: x[0])
if records_new_data:
--
Gitblit v1.8.0