redis封装

Administrator

2023-08-02 a3c05bddc4c61d63b804ee541cf6dd01717ba94d

 output/limit_up_data_filter.py

@@ -5,6 +5,7 @@
# 判断是龙几，判断是否涨停，判断是否炸板，加载分数

from code_attribute import code_volumn_manager, limit_up_time_manager, gpcode_manager
from db.redis_manager import RedisUtils
from utils import tool
from db import redis_manager
from third_data.kpl_data_manager import KPLDataManager
@@ -22,11 +23,11 @@
        return self.__redisManager.getRedis()

    def ignore_code(self, type, code):
        self.__get_redis().sadd(f"kp_ignore_codes_{type}", code)
        self.__get_redis().expire(f"kp_ignore_codes_{type}", tool.get_expire())
        RedisUtils.sadd(self.__get_redis(), f"kp_ignore_codes_{type}", code)
        RedisUtils.expire( self.__get_redis(), f"kp_ignore_codes_{type}", tool.get_expire())

    def list_ignore_codes(self, type):
        return self.__get_redis().smembers(f"kp_ignore_codes_{type}")
        return RedisUtils.smembers(self.__get_redis(), f"kp_ignore_codes_{type}")


# 获取涨停顺序（按涨停原因分组）