From 93fde21f8d713cce62479dac9a1eb74f13bcdc83 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 07 十一月 2023 18:24:24 +0800
Subject: [PATCH] bug修复
---
test/l2_trade_test.py | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index 3cc16aa..fedc498 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -87,7 +87,7 @@
def test_trade(self):
threading.Thread(target=async_log_util.run_sync, daemon=True).start()
- code = "600203"
+ code = "000026"
clear_trade_data(code)
l2.l2_data_util.load_l2_data(code)
total_datas = deepcopy(l2.l2_data_util.local_today_datas[code])
@@ -136,6 +136,7 @@
# 鑾峰彇浜ゆ槗杩涘害
trade_progress_list, buy_queues = log_export.get_trade_progress(code)
+ trade_progress_list.reverse()
# jingxuan_ranks = KPLDataManager().get_from_file(kpl_util.KPLDataType.JINGXUAN_RANK, tool.get_now_date_str())
# industry_ranks = KPLDataManager().get_from_file(kpl_util.KPLDataType.INDUSTRY_RANK, tool.get_now_date_str())
# RealTimeKplMarketData().set_top_5_reasons(jingxuan_ranks)
@@ -175,7 +176,7 @@
print("----------------澶勭悊浣嶇疆", indexs)
for l2_m in l2_market_datas:
- if l2_m["dataTimeStamp"] < int(total_datas[indexs[0]]["val"]["time"].replace(":", "")):
+ if int(str(l2_m["dataTimeStamp"])[:-3]) < int(total_datas[indexs[0]]["val"]["time"].replace(":", "")):
time_str = f"{l2_m['dataTimeStamp']}"
if time_str.startswith("9"):
time_str = "0" + time_str
@@ -185,6 +186,11 @@
l2_m["totalAskVolume"] * l2_m["avgAskPrice"])
break
+ for tp in trade_progress_list:
+ if int(tp[1].replace(":", "")) < int(total_datas[indexs[0]]["val"]["time"].replace(":", "")):
+ TradeBuyQueue().set_traded_index(code, tp[0])
+ break
+
l2.l2_data_manager_new.L2TradeDataProcessor.process_add_datas(code, total_datas[indexs[0]:indexs[1] + 1], 0,
0)
--
Gitblit v1.8.0