redis封装

Administrator

2023-08-02 32f47c162b6638a186135ae1267c870233ec21f9

 l2/transaction_progress.py

@@ -30,7 +30,7 @@
    # 返回数据与更新时间
    def __get_buy_queue_data(self, code):
        key = "trade_buy_queue_data-{}".format(code)
        val = self.__getRedis().get(key)
        val = RedisUtils.get(self.__getRedis(), key)
        if val is None:
            return None, None
        val = json.loads(val)
@@ -43,7 +43,7 @@

    def __get_buy_progress_index(self, code):
        key = "trade_buy_progress_index-{}".format(code)
        val = self.__getRedis().get(key)
        val = RedisUtils.get(self.__getRedis(), key)
        if val is None:
            return None, True
        val = json.loads(val)
@@ -57,7 +57,7 @@
    def __get_latest_not_limit_up_time(self, code):
        key = "latest_not_limit_up_time-{}".format(code)
        if not constant.TEST:
            return self.__getRedis().get(key)
            return RedisUtils.get(self.__getRedis(), key)
        return None

    # 保存数据,返回保存数据的条数