redis批量提交数据

Administrator

2023-08-07 e8ea6340db725a3b36a78e090fc6f97a90900264

 l2/cancel_buy_strategy.py

@@ -66,7 +66,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(cls.__get_redis(), key)
            RedisUtils.delete_async(cls.__get_redis(), key)

    @classmethod
    def clear_data(cls):
@@ -762,6 +762,11 @@
        RedisUtils.setex(cls.__get_redis(), f"d_cancel_real_order_index-{code}", tool.get_expire(), f"{index}")

    @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}")

    @classmethod
    def __get_real_order_index(cls, code):
        val = RedisUtils.get(cls.__get_redis(), f"d_cancel_real_order_index-{code}")
        if val:
@@ -780,14 +785,13 @@
    @classmethod
    def clear(cls, code=None):
        if code:
            RedisUtils.delete(cls.__get_redis(), f"d_cancel_real_order_index-{code}")
            cls.__del_real_order_index(code)
        else:
            keys = RedisUtils.keys(cls.__get_redis(), "d_cancel_real_order_index-*")
            if keys:
                for k in keys:
                    code = k.replace("d_cancel_real_order_index-", "")
                    CodeDataCacheUtil.clear_cache(cls.__cancel_real_order_index_cache, code)
                    RedisUtils.delete(cls.__get_redis(), k)
                    cls.__del_real_order_index(code)

    # 设置成交位
    @classmethod
@@ -878,7 +882,7 @@
    @classmethod
    def del_watch_index(cls, code):
        CodeDataCacheUtil.clear_cache(cls.__cancel_watch_index_cache, code)
        RedisUtils.delete(cls.__get_redis(), f"l_cancel_watch_index-{code}")
        RedisUtils.delete_async(cls.__get_redis(), f"l_cancel_watch_index-{code}")

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