From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
l2/transaction_progress.py | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/l2/transaction_progress.py b/l2/transaction_progress.py
index bd4f7db..c11ff35 100644
--- a/l2/transaction_progress.py
+++ b/l2/transaction_progress.py
@@ -8,6 +8,7 @@
import constant
from db import redis_manager
+from db.redis_manager import RedisUtils
from utils import tool
import l2.l2_data_util
from log_module.log import logger_l2_trade_buy_queue, logger_l2_trade_buy_progress
@@ -24,7 +25,7 @@
def __save_buy_queue_data(self, code, num_list):
key = "trade_buy_queue_data-{}".format(code)
- self.__getRedis().setex(key, tool.get_expire(), json.dumps((num_list, tool.get_now_time_str())))
+ RedisUtils.setex(self.__getRedis(), key, tool.get_expire(), json.dumps((num_list, tool.get_now_time_str())))
# 杩斿洖鏁版嵁涓庢洿鏂版椂闂�
def __get_buy_queue_data(self, code):
@@ -37,7 +38,7 @@
def __save_buy_progress_index(self, code, index, is_default):
key = "trade_buy_progress_index-{}".format(code)
- self.__getRedis().setex(key, tool.get_expire(), json.dumps((index, is_default)))
+ RedisUtils.setex(self.__getRedis(), key, tool.get_expire(), json.dumps((index, is_default)))
# 杩斿洖鏁版嵁涓庢洿鏂版椂闂�
def __get_buy_progress_index(self, code):
@@ -51,7 +52,7 @@
# 鏈�杩戠殑闈炴定鍋滀拱1鐨勬椂闂�
def __save_latest_not_limit_up_time(self, code, time_str):
key = "latest_not_limit_up_time-{}".format(code)
- self.__getRedis().setex(key, tool.get_expire(), time_str)
+ RedisUtils.setex(self.__getRedis(), key, tool.get_expire(), time_str)
def __get_latest_not_limit_up_time(self, code):
key = "latest_not_limit_up_time-{}".format(code)
--
Gitblit v1.8.0