redis批量提交数据

Administrator

2023-08-07 e0ca7b43c17ebe25e718d5ca229c989f48340015

 l2/cancel_buy_strategy.py

@@ -27,6 +27,7 @@


class SecondCancelBigNumComputer:
    __db = 0
    __redis_manager = redis_manager.RedisManager(0)
    __sCancelParamsManager = l2_trade_factor.SCancelParamsManager
    __s_big_num_cancel_compute_data_cache = {}
@@ -66,7 +67,7 @@
        CodeDataCacheUtil.clear_cache(cls.__s_big_num_cancel_compute_data_cache, code)
        ks = ["s_big_num_cancel_compute_data-{}".format(code)]
        for key in ks:
            RedisUtils.delete_async(cls.__get_redis(), key)
            RedisUtils.delete_async(cls.__db, key)

    @classmethod
    def clear_data(cls):
@@ -749,6 +750,7 @@
# 计算 成交位->真实下单位置 总共还剩下多少手没有撤单
# 成交位变化之后重新计算
class DCancelBigNumComputer:
    __db = 0
    __redis_manager = redis_manager.RedisManager(0)
    __cancel_real_order_index_cache = {}

@@ -764,7 +766,7 @@
    @classmethod
    def __del_real_order_index(cls, code):
        CodeDataCacheUtil.clear_cache(cls.__cancel_real_order_index_cache, code)
        RedisUtils.delete_async(cls.__get_redis(), f"d_cancel_real_order_index-{code}")
        RedisUtils.delete_async(cls.__db, f"d_cancel_real_order_index-{code}")

    @classmethod
    def __get_real_order_index(cls, code):
@@ -846,6 +848,7 @@
# ---------------------------------L撤-------------------------------
# 计算成交位置之后的大单（特定笔数）的撤单比例
class LCancelBigNumComputer:
    __db = 0
    __redis_manager = redis_manager.RedisManager(0)
    __last_trade_progress_dict = {}
    __cancel_watch_index_cache = {}
@@ -882,7 +885,7 @@
    @classmethod
    def del_watch_index(cls, code):
        CodeDataCacheUtil.clear_cache(cls.__cancel_watch_index_cache, code)
        RedisUtils.delete_async(cls.__get_redis(), f"l_cancel_watch_index-{code}")
        RedisUtils.delete_async(cls.__db, f"l_cancel_watch_index-{code}")

    @classmethod
    def clear(cls, code=None):