From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
test/l2_trade_test.py | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index b8ceded..da89dd2 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -9,6 +9,7 @@
from unittest import mock
from code_attribute import big_money_num_manager, gpcode_manager
+from db.redis_manager import RedisUtils
from log_module import log
from utils import tool
from db import redis_manager
@@ -27,20 +28,20 @@
redis_l2 = redis_manager.RedisManager(1).getRedis()
keys = ["buy1_volumn_latest_info-{}", "m_big_money_begin-{}", "m_big_money_process_index-{}"]
for k in keys:
- redis_l2.delete(k.format(code))
+ RedisUtils.delete(redis_l2, k.format(code))
l2.l2_data_manager.TradePointManager.delete_buy_point(code)
big_money_num_manager.reset(code)
redis_trade = redis_manager.RedisManager(2).getRedis()
- redis_trade.delete("trade-state-{}".format(code))
+ RedisUtils.delete( redis_trade, "trade-state-{}".format(code))
trade_data_manager.placeordercountmanager.clear_place_order_count(code)
redis_info = redis_manager.RedisManager(0).getRedis()
- keys = redis_info.keys("*{}*".format(code))
+ keys = RedisUtils.keys(redis_info, "*{}*".format(code))
for k in keys:
if k.find("pre") is not None:
continue
if k.find("zyltgb") is not None:
continue
- redis_info.delete(k)
+ RedisUtils.delete(redis_info, k)
BuyL2SafeCountManager().clear_data(code)
transaction_progress.TradeBuyQueue().set_traded_index(code, 0)
--
Gitblit v1.8.0