From e0ca7b43c17ebe25e718d5ca229c989f48340015 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 16:16:30 +0800
Subject: [PATCH] redis批量提交数据
---
l2/cancel_buy_strategy.py | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/l2/cancel_buy_strategy.py b/l2/cancel_buy_strategy.py
index 72a137a..d089136 100644
--- a/l2/cancel_buy_strategy.py
+++ b/l2/cancel_buy_strategy.py
@@ -27,6 +27,7 @@
class SecondCancelBigNumComputer:
+ __db = 0
__redis_manager = redis_manager.RedisManager(0)
__sCancelParamsManager = l2_trade_factor.SCancelParamsManager
__s_big_num_cancel_compute_data_cache = {}
@@ -66,7 +67,7 @@
CodeDataCacheUtil.clear_cache(cls.__s_big_num_cancel_compute_data_cache, code)
ks = ["s_big_num_cancel_compute_data-{}".format(code)]
for key in ks:
- RedisUtils.delete_async(cls.__get_redis(), key)
+ RedisUtils.delete_async(cls.__db, key)
@classmethod
def clear_data(cls):
@@ -749,6 +750,7 @@
# 璁＄畻 鎴愪氦浣�->鐪熷疄涓嬪崟浣嶇疆 鎬诲叡杩樺墿涓嬪灏戞墜娌℃湁鎾ゅ崟
# 鎴愪氦浣嶅彉鍖栦箣鍚庨噸鏂拌绠�
class DCancelBigNumComputer:
+ __db = 0
__redis_manager = redis_manager.RedisManager(0)
__cancel_real_order_index_cache = {}
@@ -764,7 +766,7 @@
@classmethod
def __del_real_order_index(cls, code):
CodeDataCacheUtil.clear_cache(cls.__cancel_real_order_index_cache, code)
- RedisUtils.delete_async(cls.__get_redis(), f"d_cancel_real_order_index-{code}")
+ RedisUtils.delete_async(cls.__db, f"d_cancel_real_order_index-{code}")
@classmethod
def __get_real_order_index(cls, code):
@@ -846,6 +848,7 @@
# ---------------------------------L鎾�-------------------------------
# 璁＄畻鎴愪氦浣嶇疆涔嬪悗鐨勫ぇ鍗曪紙鐗瑰畾绗旀暟锛夌殑鎾ゅ崟姣斾緥
class LCancelBigNumComputer:
+ __db = 0
__redis_manager = redis_manager.RedisManager(0)
__last_trade_progress_dict = {}
__cancel_watch_index_cache = {}
@@ -882,7 +885,7 @@
@classmethod
def del_watch_index(cls, code):
CodeDataCacheUtil.clear_cache(cls.__cancel_watch_index_cache, code)
- RedisUtils.delete_async(cls.__get_redis(), f"l_cancel_watch_index-{code}")
+ RedisUtils.delete_async(cls.__db, f"l_cancel_watch_index-{code}")
@classmethod
def clear(cls, code=None):
--
Gitblit v1.8.0