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/safe_count_manager.py | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/l2/safe_count_manager.py b/l2/safe_count_manager.py
index bd2ed3e..d7b7f20 100644
--- a/l2/safe_count_manager.py
+++ b/l2/safe_count_manager.py
@@ -16,6 +16,7 @@
class BuyL2SafeCountManager(object):
+ __db = 0
__redis_manager = redis_manager.RedisManager(0)
def __init__(self):
@@ -29,7 +30,7 @@
key = "safe_count_l2-{}-{}".format(code, last_buy_single_index)
tool.CodeDataCacheUtil.set_cache(safe_count_l2_cache, f"{code}-{last_buy_single_index}",
(last_buy_single_index, process_index, buy_num, cancel_num))
- RedisUtils.setex_async(self.__getRedis(), key, tool.get_expire(),
+ RedisUtils.setex_async(self.__db, key, tool.get_expire(),
json.dumps((last_buy_single_index, process_index, buy_num, cancel_num)))
# 杩斿洖鏁版嵁涓庢洿鏂版椂闂�
@@ -91,7 +92,7 @@
tool.CodeDataCacheUtil.clear_cache(latest_place_order_info_cache, code)
key = f"latest_place_order_info-{code}"
- RedisUtils.delete_async(self.__getRedis(), key)
+ RedisUtils.delete_async(self.__db, key)
# 鑾峰彇鍩虹鐨勫畨鍏ㄧ瑪鏁�
def __get_base_save_count(self, code, is_first):
--
Gitblit v1.8.0