From 8595dc22aa9dde6aba6d0f8cdcf1656a8a59513b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 18:05:10 +0800
Subject: [PATCH] redis封装
---
trade/trade_data_manager.py | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/trade/trade_data_manager.py b/trade/trade_data_manager.py
index 800d9c1..6d7e1b3 100644
--- a/trade/trade_data_manager.py
+++ b/trade/trade_data_manager.py
@@ -69,7 +69,7 @@
@classmethod
def get_buy_position_info(cls, code):
redis = cls.redisManager.getRedis()
- val_str = RedisUtils.get(redis,"buy_position_info-{}".format(code))
+ val_str = RedisUtils.get(redis, "buy_position_info-{}".format(code))
if val_str is None:
return None, None, None, None
else:
@@ -80,7 +80,7 @@
@classmethod
def remove_buy_position_info(cls, code):
redis = cls.redisManager.getRedis()
- RedisUtils.delete( redis,"buy_position_info-{}".format(code))
+ RedisUtils.delete(redis, "buy_position_info-{}".format(code))
# 璁剧疆涔板叆纭鐐逛俊鎭�
@classmethod
@@ -169,11 +169,11 @@
# 淇濆瓨璺屼环鐨勬椂闂�
def __save_down_price_time(self, code, time_str):
key = "under_water_last_time-{}".format(code)
- RedisUtils.setex(self.__get_redis(),key, tool.get_expire(), time_str)
+ RedisUtils.setex(self.__get_redis(), key, tool.get_expire(), time_str)
def __remove_down_price_time(self, code):
key = "under_water_last_time-{}".format(code)
- RedisUtils.delete( self.__get_redis(), key)
+ RedisUtils.delete(self.__get_redis(), key)
def __get_last_down_price_time(self, code):
key = "under_water_last_time-{}".format(code)
@@ -182,7 +182,7 @@
def __increment_down_price_time(self, code, seconds):
key = "under_water_seconds-{}".format(code)
RedisUtils.incrby(
- self.__get_redis(),key, seconds)
+ self.__get_redis(), key, seconds)
# 璁剧疆涓け鏁堟椂闂�
RedisUtils.expire(self.__get_redis(), key, tool.get_expire())
@@ -203,17 +203,17 @@
def __save_current_price_codes_count(self, count):
key = "current_price_codes_count"
- RedisUtils.setex(self.__get_redis(),key, 10, count)
+ RedisUtils.setex(self.__get_redis(), key, 10, count)
def __get_current_price_codes_count(self):
key = "current_price_codes_count"
- count = RedisUtils.get(self.__get_redis(),key)
+ count = RedisUtils.get(self.__get_redis(), key)
return 0 if count is None else count
# 淇濆瓨褰撳墠娑ㄥ箙
def __save_current_rate(self, code, rate):
key = "code_current_rate-{}".format(code)
- RedisUtils.setex(self.__get_redis(),key, tool.get_expire(), rate)
+ RedisUtils.setex(self.__get_redis(), key, tool.get_expire(), rate)
# 鑾峰彇褰撳墠娑ㄥ箙
def __get_current_rate(self, code):
--
Gitblit v1.8.0