redis批量提交数据

Administrator

2023-08-07 e0ca7b43c17ebe25e718d5ca229c989f48340015

 l2/safe_count_manager.py

@@ -16,6 +16,7 @@


class BuyL2SafeCountManager(object):
    __db = 0
    __redis_manager = redis_manager.RedisManager(0)

    def __init__(self):
@@ -29,7 +30,7 @@
        key = "safe_count_l2-{}-{}".format(code, last_buy_single_index)
        tool.CodeDataCacheUtil.set_cache(safe_count_l2_cache, f"{code}-{last_buy_single_index}",
                                         (last_buy_single_index, process_index, buy_num, cancel_num))
        RedisUtils.setex_async(self.__getRedis(), key, tool.get_expire(),
        RedisUtils.setex_async(self.__db, key, tool.get_expire(),
                               json.dumps((last_buy_single_index, process_index, buy_num, cancel_num)))

    # 返回数据与更新时间
@@ -91,7 +92,7 @@

        tool.CodeDataCacheUtil.clear_cache(latest_place_order_info_cache, code)
        key = f"latest_place_order_info-{code}"
        RedisUtils.delete_async(self.__getRedis(), key)
        RedisUtils.delete_async(self.__db, key)

    # 获取基础的安全笔数
    def __get_base_save_count(self, code, is_first):