redis批量提交数据

Administrator

2023-08-07 d195d58dacca8396b4cacd609c008d029598e9e5

redis批量提交数据

 l2/l2_data_manager_new.py

@@ -58,6 +58,7 @@

# m值大单处理
m_big_money_begin_cache={}
m_big_money_process_index_cache={}
class L2BigNumForMProcessor:

    def __init__(self):
@@ -93,11 +94,13 @@

    # 清除已经处理的数据
    def clear_processed_end_index(self, code):
        tool.CodeDataCacheUtil.clear_cache(m_big_money_process_index_cache, code)
        key = "m_big_money_process_index-{}".format(code)
        RedisUtils.delete(self.__get_redis(), key)

    # 添加已经处理过的单
    def __set_processed_end_index(self, code, index):
        tool.CodeDataCacheUtil.set_cache(m_big_money_process_index_cache,code,index)
        key = "m_big_money_process_index-{}".format(code)
        RedisUtils.setex(self.__get_redis(), key, tool.get_expire(), index)

@@ -109,6 +112,15 @@
            return None
        return int(val)

    def __get_processed_end_index_cache(self, code):
        cache_result = tool.CodeDataCacheUtil.get_cache(m_big_money_process_index_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_processed_end_index(code)
        tool.CodeDataCacheUtil.set_cache(m_big_money_process_index_cache, code, val)
        return val


    # 处理大单
    def process(self, code, start_index, end_index, limit_up_price):

@@ -117,7 +129,7 @@
            # 没有获取到开始买入信号
            return
        # 上次处理到的坐标
        processed_index = self.__get_processed_end_index(code)
        processed_index = self.__get_processed_end_index_cache(code)
        if processed_index is None:
            processed_index = 0
        if processed_index >= end_index: