From ba52d7ac92a36f413eacaa686f8535e859664ec6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 28 八月 2023 09:45:11 +0800
Subject: [PATCH] bug修改
---
l2/l2_data_manager_new.py | 32 ++++++++++++++------------------
1 files changed, 14 insertions(+), 18 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 775effb..decc883 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -7,6 +7,7 @@
import constant
from db.redis_manager_delegate import RedisUtils
from l2.huaxin import l2_huaxin_util, huaxin_delegate_postion_manager
+from log_module import async_log_util
from third_data import kpl_data_manager, block_info
from trade.deal_big_money_manager import DealComputeProgressManager
from utils import global_util, ths_industry_util, tool
@@ -311,8 +312,9 @@
# 鑾峰彇涓嬪崟浣嶇疆
place_order_index = huaxin_delegate_postion_manager.get_l2_place_order_position(code, datas)
if place_order_index:
- logger_l2_process.info("code:{} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{}", code, place_order_index)
cls.__DCancelBigNumComputer.set_real_order_index(code, place_order_index)
+ cls.__SecondCancelBigNumComputer.set_real_place_order_index(code, place_order_index)
+ async_log_util.info(logger_l2_process, "code:{} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{}", code, place_order_index)
__start_time = round(t.time() * 1000)
if len(datas) > 0:
cls.process_add_datas(code, datas, 0, __start_time)
@@ -416,9 +418,10 @@
if l2.l2_data_util.L2DataUtil.is_same_time(now_time_str, latest_time):
cls.__process_not_order(code, start_index, end_index, capture_timestamp, is_first_code)
- logger_l2_process.info("code:{} 澶勭悊鏁版嵁鑼冨洿: {}-{} 澶勭悊鏃堕棿:{} 鎴浘鏃堕棿鎴筹細{}", code, add_datas[0]["index"],
- add_datas[-1]["index"], round(t.time() * 1000) - __start_time,
- capture_timestamp)
+ async_log_util.info(logger_l2_process, "code:{} 澶勭悊鏁版嵁鑼冨洿: {}-{} 澶勭悊鏃堕棿:{} 鎴浘鏃堕棿鎴筹細{}", code,
+ add_datas[0]["index"],
+ add_datas[-1]["index"], round(t.time() * 1000) - __start_time,
+ capture_timestamp)
# __start_time = l2_data_log.l2_time(code, round(t.time() * 1000) - __start_time,
# "l2鏁版嵁澶勭悊鏃堕棿")
@@ -545,8 +548,8 @@
# 渚濇澶勭悊
cancel_data, cancel_msg = s_cancel(buy_single_index, buy_exec_index)
- if not cancel_data:
- cancel_data, cancel_msg = h_cancel(buy_single_index, buy_exec_index)
+ # if not cancel_data:
+ # cancel_data, cancel_msg = h_cancel(buy_single_index, buy_exec_index)
if not cancel_data:
cancel_data, cancel_msg = l_cancel(buy_single_index, buy_exec_index)
# l2_log.debug(code, "鎾ゅ崟璁＄畻缁撴潫")
@@ -1046,9 +1049,7 @@
cls.__save_order_begin_data(code, buy_single_index, compute_index, compute_index,
buy_nums, buy_count, max_num_set_new,
cls.volume_rate_info[code][0])
- l2_log.debug(code, "__save_order_begin_data")
cls.__LimitUpTimeManager.save_limit_up_time(code, total_datas[compute_index]["val"]["time"])
- l2_log.debug(code, "save_limit_up_time")
cls.__TradePointManager.delete_buy_cancel_point(code)
l2_log.debug(code, "delete_buy_cancel_point")
# 鐩存帴涓嬪崟
@@ -1075,7 +1076,6 @@
def __get_order_begin_pos(cls, code):
buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = cls.__TradePointManager.get_buy_compute_start_data_cache(
code)
- logger_debug.info(f"鑾峰彇涔板叆鎵ц浣嶇疆淇℃伅{code}:{buy_single_index}-{buy_exec_index}-{compute_index}-{num}-{count}")
return buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate
# 淇濆瓨涓嬪崟璧峰淇″彿
@@ -1155,10 +1155,6 @@
@classmethod
def __sum_buy_num_for_order_3(cls, code, compute_start_index, compute_end_index, origin_num, origin_count,
threshold_money, buy_single_index, max_num_set):
- def get_threshold_count():
- count = threshold_count
- return count
-
_start_time = t.time()
total_datas = local_today_datas[code]
# is_first_code = gpcode_manager.FirstCodeManager().is_in_first_record_cache(code)
@@ -1216,9 +1212,9 @@
# 鍙粺璁�59涓囦互涓婄殑閲戦
buy_nums += int(_val["num"]) * int(total_datas[i]["re"])
buy_count += int(total_datas[i]["re"])
- if buy_nums >= threshold_num and buy_count >= get_threshold_count():
- logger_l2_trade_buy.info(
- f"{code}鑾峰彇鍒颁拱鍏ユ墽琛岀偣锛歿i} 缁熻绾拱鎵嬫暟锛歿buy_nums} 鐩爣绾拱鎵嬫暟锛歿threshold_num} 缁熻绾拱鍗曟暟锛歿buy_count} 鐩爣绾拱鍗曟暟锛歿get_threshold_count()}, 澶у崟鏁伴噺锛歿len(max_buy_num_set)}")
+ if buy_nums >= threshold_num and buy_count >= threshold_count:
+ async_log_util.info(logger_l2_trade_buy,
+ f"{code}鑾峰彇鍒颁拱鍏ユ墽琛岀偣锛歿i} 缁熻绾拱鎵嬫暟锛歿buy_nums} 鐩爣绾拱鎵嬫暟锛歿threshold_num} 缁熻绾拱鍗曟暟锛歿buy_count} 鐩爣绾拱鍗曟暟锛歿threshold_count}, 澶у崟鏁伴噺锛歿len(max_buy_num_set)}")
elif L2DataUtil.is_limit_up_price_buy_cancel(_val):
if _val["num"] >= bigger_num:
# 鍙粺璁�59涓囦互涓婄殑閲戦
@@ -1257,13 +1253,13 @@
for i in max_buy_num_set:
max_buy_num_set_count += total_datas[i]["re"]
# 鏈夋挙鍗曚俊鍙凤紝涓斿皬浜庨槇鍊�
- if buy_nums >= threshold_num and buy_count >= get_threshold_count() and trigger_buy and max_buy_num_set_count >= big_num_count:
+ if buy_nums >= threshold_num and buy_count >= threshold_count and trigger_buy and max_buy_num_set_count >= big_num_count:
return i, buy_nums, buy_count, None, max_buy_num_set
l2_log.buy_debug(code, "灏氭湭鑾峰彇鍒颁拱鍏ユ墽琛岀偣锛岃捣濮嬭绠椾綅缃細{} 缁熻绾拱鎵嬫暟锛歿} 鐩爣绾拱鎵嬫暟锛歿} 缁熻绾拱鍗曟暟锛歿} 鐩爣绾拱鍗曟暟锛歿} 澶у崟鏁伴噺锛歿} 鐩爣澶у崟鏁伴噺锛歿}",
compute_start_index,
buy_nums,
- threshold_num, buy_count, get_threshold_count(), max_buy_num_set_count, big_num_count)
+ threshold_num, buy_count, threshold_count, max_buy_num_set_count, big_num_count)
return None, buy_nums, buy_count, None, max_buy_num_set
--
Gitblit v1.8.0