From 806e1c7b2296bf615faeddb5a78512ef61b52389 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 八月 2025 18:20:21 +0800
Subject: [PATCH] 测试资金明细
---
output/code_info_output.py | 25 ++++++++++++++++---------
1 files changed, 16 insertions(+), 9 deletions(-)
diff --git a/output/code_info_output.py b/output/code_info_output.py
index fd70507..c4b5844 100644
--- a/output/code_info_output.py
+++ b/output/code_info_output.py
@@ -15,6 +15,8 @@
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 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
@@ -79,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 = []
@@ -88,7 +89,7 @@
if is_target_code:
limit_up_price = gpcode_manager.get_limit_up_price(code)
limit_up_time = limit_up_time_manager.LimitUpTimeManager().get_limit_up_time_cache(code)
- volume_rate, volume_info = code_volumn_manager.get_volume_rate(code, with_info=True)
+ volume_rate, volume_info = code_volumn_manager.CodeVolumeManager().get_volume_rate(code, with_info=True)
################################涔板墠璇勫垎################################
@@ -102,7 +103,7 @@
# 鑾峰彇涔板叆鎰忔効
__L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, True, volume_rate,
- code_volumn_manager.get_volume_rate_index(
+ code_volumn_manager.CodeVolumeManager().get_volume_rate_index(
volume_rate),
None)
# 鏄惁鍙互涔板叆鐨勪俊鎭�
@@ -114,7 +115,8 @@
# 鑾峰彇閲忓弬鑰冩棩鏈�
try:
- volume_refer_date, volume_refer_date_distance = code_volumn_manager.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
@@ -125,7 +127,7 @@
params["trade_data"]["special_info"] = k_format[8]
__base_L2PlaceOrderParamsManager = l2_trade_factor.L2PlaceOrderParamsManager(code, False, volume_rate,
- code_volumn_manager.get_volume_rate_index(
+ code_volumn_manager.CodeVolumeManager().get_volume_rate_index(
volume_rate),
None)
if -1 < __L2PlaceOrderParamsManager.score_index < 3:
@@ -300,6 +302,13 @@
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 = [(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:
@@ -485,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:
@@ -495,10 +506,6 @@
records_new.reverse()
records_new_data.reverse()
return break_time, records_new, records_new_data
-
-
-
-
# 杩斿洖鍐呭[锛堢被鍨�,buy_single_index,indexes锛塢
--
Gitblit v1.8.0