trade_queue_manager.py
@@ -28,6 +28,10 @@ return int(val) return None def __del_max_buy1_volume(self, code): key = "max_buy1_volumn-{}".format(code) val = self.__get_redis().delete(key) def __save_recod(self, code, time_str, volumn): # 保存每一次的 @@ -155,6 +159,10 @@ return -1 return val def clear_max_buy1_volume(self, code): self.__del_max_buy1_volume(code) class JueJinBuy1VolumnManager: __redisManager = redis_manager.RedisManager(1)