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/l2_data_manager_new.py | 11 ++++++-----
1 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index bfc7387..e7d7dbd 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -5,6 +5,7 @@
from code_attribute import big_money_num_manager, code_volumn_manager, code_data_util, industry_codes_sort, \
limit_up_time_manager, global_data_loader, gpcode_manager
import constant
+from db.redis_manager import RedisUtils
from l2.huaxin import l2_huaxin_util, huaxin_delegate_postion_manager
from third_data import kpl_data_manager, block_info
from utils import global_util, ths_industry_util, tool
@@ -69,12 +70,12 @@
if self.__get_begin_pos(code) is None:
# 淇濆瓨浣嶇疆
key = "m_big_money_begin-{}".format(code)
- self.__get_redis().setex(key, tool.get_expire(), index)
+ RedisUtils.setex( self.__get_redis(), key, tool.get_expire(), index)
# 鑾峰彇璁＄畻寮�濮嬩綅缃�
def __get_begin_pos(self, code):
key = "m_big_money_begin-{}".format(code)
- val = self.__get_redis().get(key)
+ val = RedisUtils.get(self.__get_redis(),key)
if val is None:
return None
return int(val)
@@ -82,17 +83,17 @@
# 娓呴櫎宸茬粡澶勭悊鐨勬暟鎹�
def clear_processed_end_index(self, code):
key = "m_big_money_process_index-{}".format(code)
- self.__get_redis().delete(key)
+ RedisUtils.delete(self.__get_redis(), key)
# 娣诲姞宸茬粡澶勭悊杩囩殑鍗�
def __set_processed_end_index(self, code, index):
key = "m_big_money_process_index-{}".format(code)
- self.__get_redis().setex(key, tool.get_expire(), index)
+ RedisUtils.setex(self.__get_redis(), key, tool.get_expire(), index)
# 鏄惁宸茬粡澶勭悊杩�
def __get_processed_end_index(self, code):
key = "m_big_money_process_index-{}".format(code)
- val = self.__get_redis().get(key)
+ val = RedisUtils.get(self.__get_redis(), key)
if val is None:
return None
return int(val)
--
Gitblit v1.8.0