From c20c3c10635ce78db4a86ce9c0bb1d02e90f525d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 08 八月 2023 17:40:42 +0800
Subject: [PATCH] 单例+缓存优化
---
test/l2_trade_test.py | 32 +++++++++++++++++---------------
1 files changed, 17 insertions(+), 15 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index 1026ecb..ac02c7b 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -32,7 +32,7 @@
RedisUtils.realse(redis_l2)
l2.l2_data_manager.TradePointManager().delete_buy_point(code)
big_money_num_manager.reset(code)
- RedisUtils.delete( redis_manager.RedisManager(2).getRedis(), "trade-state-{}".format(code))
+ RedisUtils.delete(redis_manager.RedisManager(2).getRedis(), "trade-state-{}".format(code))
trade_data_manager.PlaceOrderCountManager().clear_place_order_count(code)
redis_info = redis_manager.RedisManager(0).getRedis()
keys = RedisUtils.keys(redis_info, "*{}*".format(code), auto_free=False)
@@ -46,7 +46,6 @@
BuyL2SafeCountManager().clear_data(code)
transaction_progress.TradeBuyQueue().set_traded_index(code, 0)
-
class VirtualTrade(unittest.TestCase):
@@ -76,12 +75,13 @@
buy_progress_index = TradeBuyQueue().compute_traded_index(code, buy_one_price_,
buy_queue_result_list, exec_time)
if buy_progress_index is not None:
- l2.cancel_buy_strategy.HourCancelBigNumComputer.set_trade_progress(code, time_, buy_exec_index,
- buy_progress_index,
- l2.l2_data_util.local_today_datas.get(
- code),
- l2.l2_data_util.local_today_num_operate_map.get(
- code))
+ l2.cancel_buy_strategy.HourCancelBigNumComputer().set_trade_progress(code, time_,
+ buy_exec_index,
+ buy_progress_index,
+ l2.l2_data_util.local_today_datas.get(
+ code),
+ l2.l2_data_util.local_today_num_operate_map.get(
+ code))
log.logger_l2_trade_buy_queue.info("鑾峰彇鎴愪氦浣嶇疆鎴愬姛锛� code-{} index-{} 鏁版嵁-{}", code,
buy_progress_index,
json.dumps(buy_queue_result_list))
@@ -137,7 +137,8 @@
RealTimeKplMarketData().set_top_5_reasons(jingxuan_ranks)
RealTimeKplMarketData().set_top_5_industry(industry_ranks)
- LimitUpCodesPlateKeyManager().set_today_limit_up(KPLDataManager().get_from_file(kpl_util.KPLDataType.LIMIT_UP, tool.get_now_date_str()))
+ LimitUpCodesPlateKeyManager().set_today_limit_up(
+ KPLDataManager().get_from_file(kpl_util.KPLDataType.LIMIT_UP, tool.get_now_date_str()))
for indexs in pos_list:
l2_log.threadIds[code] = mock.Mock(
@@ -148,7 +149,8 @@
time_s = tool.get_time_as_second(time_) - i - 1
volumn = THSBuy1VolumnManager().get_buy_1_volumn(code, tool.time_seconds_format(time_s))
if volumn is not None:
- l2.cancel_buy_strategy.L2LimitUpMoneyStatisticUtil().verify_num(code, int(volumn), tool.time_seconds_format(time_s))
+ l2.cancel_buy_strategy.L2LimitUpMoneyStatisticUtil().verify_num(code, int(volumn),
+ tool.time_seconds_format(time_s))
break
# 璁剧疆濮斾拱闃熷垪
for i in range(0, len(buy_queues)):
@@ -176,11 +178,11 @@
l2.l2_data_util.load_num_operate_map(l2.l2_data_util.local_today_num_operate_map, code, total_datas, True)
buy_progress_index = 523
- l2.cancel_buy_strategy.HourCancelBigNumComputer.set_trade_progress(code, buy_progress_index,
- l2.l2_data_util.local_today_datas.get(
- code),
- l2.l2_data_util.local_today_num_operate_map.get(
- code))
+ l2.cancel_buy_strategy.HourCancelBigNumComputer().set_trade_progress(code, buy_progress_index,
+ l2.l2_data_util.local_today_datas.get(
+ code),
+ l2.l2_data_util.local_today_num_operate_map.get(
+ code))
# class TestTrade(unittest.TestCase):
--
Gitblit v1.8.0