From 8ef576b9a1809dd52dacaafe960db456b09e9e0b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 30 三月 2023 18:24:21 +0800
Subject: [PATCH] 看盘界面调整
---
l2/l2_data_manager_new.py | 17 +++++++++++++----
1 files changed, 13 insertions(+), 4 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 25164f1..fb4bd7c 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -164,6 +164,16 @@
__l2PlaceOrderParamsManagerDict = {}
__last_buy_single_dict = {}
+ # 鑾峰彇浠ｇ爜璇勫垎
+ @classmethod
+ def get_code_scores(cls):
+ score_dict = {}
+ for code in cls.__l2PlaceOrderParamsManagerDict:
+ score = cls.__l2PlaceOrderParamsManagerDict[code].score
+ score_dict[code] = score
+ return score_dict
+
+
@classmethod
# 鏁版嵁澶勭悊鍏ュ彛
# datas: 鏈鎴浘鏁版嵁
@@ -242,7 +252,6 @@
volume_rate,
volume_rate_index,
score)
- l2_log.debug(code, "閲忔瘮锛歿}锛岄噺绱㈠紩锛歿}", volume_rate, volume_rate_index)
cls.volume_rate_info[code] = (volume_rate, volume_rate_index)
latest_time = add_datas[len(add_datas) - 1]["val"]["time"]
@@ -755,8 +764,8 @@
new_get_single = True
num = 0
count = 0
- l2_log.debug(code, "鑾峰彇鍒颁拱鍏ヤ俊鍙疯捣濮嬬偣锛歿} ,璁＄畻鑼冨洿锛歿}-{} 锛屾暟鎹細{}", buy_single_index, compute_start_index,
- compute_end_index, total_datas[buy_single_index])
+ l2_log.debug(code, "鑾峰彇鍒颁拱鍏ヤ俊鍙疯捣濮嬬偣锛歿} ,璁＄畻鑼冨洿锛歿}-{} 锛岄噺姣旓細{}锛屾暟鎹細{}", buy_single_index, compute_start_index,
+ compute_end_index, cls.volume_rate_info[code], total_datas[buy_single_index])
# 濡傛灉鏄粖澶╃涓�娆℃湁涓嬪崟寮�濮嬩俊鍙凤紝闇�瑕佽缃ぇ鍗曡捣濮嬬偣
cls.l2BigNumForMProcessor.set_begin_pos(code, buy_single_index)
@@ -804,7 +813,7 @@
if compute_index is not None:
l2_log.debug(code, "鑾峰彇鍒颁拱鍏ユ墽琛屼綅缃細{} m鍊硷細{} 绾拱鎵嬫暟锛歿} 绾拱鍗曟暟锛歿} 鏁版嵁锛歿} ,閲忔瘮:{} ", compute_index, threshold_money,
buy_nums,
- buy_count, total_datas[compute_index], cls.volume_rate_info[code][0])
+ buy_count, total_datas[compute_index], cls.volume_rate_info[code])
f1 = dask.delayed(cls.__save_order_begin_data)(code, buy_single_index, compute_index, compute_index,
buy_nums, buy_count, max_num_set_new,
--
Gitblit v1.8.0