From b6011a89140258b62fa8538c156990d1fbe6648a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 17 八月 2023 10:33:56 +0800
Subject: [PATCH] ++++++++++++++++ bug修复
---
l2/l2_data_manager_new.py | 22 ++++++++++++++--------
1 files changed, 14 insertions(+), 8 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index a2ce51c..bd63ded 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -489,12 +489,12 @@
# S鎾�
# @dask.delayed
- def s_cancel():
+ def s_cancel(_buy_single_index,_buy_exec_index):
_start_time = round(t.time() * 1000)
# S鎾ゅ崟璁＄畻锛岀湅绉掔骇澶у崟鎾ゅ崟
try:
- b_need_cancel, b_cancel_data = cls.__SecondCancelBigNumComputer.need_cancel(code, buy_single_index,
- buy_exec_index, start_index,
+ b_need_cancel, b_cancel_data = cls.__SecondCancelBigNumComputer.need_cancel(code, _buy_single_index,
+ _buy_exec_index, start_index,
end_index, total_data,
code_volumn_manager.get_volume_rate_index(
buy_volume_rate),
@@ -505,6 +505,8 @@
return b_cancel_data, "S澶у崟鎾ら攢姣斾緥瑙﹀彂闃堝��"
except Exception as e:
logging.exception(e)
+ logger_l2_error.error(f"鍙傛暟锛歜uy_single_index-{_buy_single_index} buy_exec_index-{_buy_exec_index}")
+ logger_l2_error.exception(e)
finally:
l2_data_log.l2_time(code, round(t.time() * 1000) - _start_time,
"宸蹭笅鍗�-s绾уぇ鍗曚及绠�")
@@ -512,11 +514,11 @@
# H鎾�
# @dask.delayed
- def h_cancel():
+ def h_cancel(_buy_single_index,_buy_exec_index):
_start_time = round(t.time() * 1000)
try:
- b_need_cancel, b_cancel_data = cls.__HourCancelBigNumComputer.need_cancel(code, buy_single_index,
- buy_exec_index, start_index,
+ b_need_cancel, b_cancel_data = cls.__HourCancelBigNumComputer.need_cancel(code, _buy_single_index,
+ _buy_exec_index, start_index,
end_index, total_data,
local_today_num_operate_map.get(
code),
@@ -528,17 +530,19 @@
return b_cancel_data, "H鎾ら攢姣斾緥瑙﹀彂闃堝��"
except Exception as e:
logging.exception(e)
+ logger_l2_error.error(f"鍙傛暟锛歜uy_single_index-{_buy_single_index} buy_exec_index-{_buy_exec_index}")
+ logger_l2_error.exception(e)
finally:
l2_data_log.l2_time(code, round(t.time() * 1000) - _start_time, "宸蹭笅鍗�-H鎾ゅぇ鍗曡绠�")
return None, ""
# L鎾�
# @dask.delayed
- def l_cancel():
+ def l_cancel(_buy_single_index,_buy_exec_index):
_start_time = round(t.time() * 1000)
try:
b_need_cancel, b_cancel_data = cls.__LCancelBigNumComputer.need_cancel(code,
- buy_exec_index, start_index,
+ _buy_exec_index, start_index,
end_index, total_data,
local_today_num_operate_map.get(
code), is_first_code)
@@ -546,6 +550,8 @@
return b_cancel_data, "L鎾ら攢姣斾緥瑙﹀彂闃堝��"
except Exception as e:
logging.exception(e)
+ logger_l2_error.error(f"鍙傛暟锛歜uy_single_index-{_buy_single_index} buy_exec_index-{_buy_exec_index}")
+ logger_l2_error.exception(e)
finally:
l2_data_log.l2_time(code, round(t.time() * 1000) - _start_time, "宸蹭笅鍗�-L鎾ゅぇ鍗曡绠�")
return None, ""
--
Gitblit v1.8.0