| | |
| | | # 设置首板未筛选的目标票 |
| | | import json |
| | | |
| | | from db.redis_manager import RedisUtils |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from utils import tool |
| | | from db import redis_manager |
| | | from db import redis_manager_delegate as redis_manager |
| | | from third_data import block_info |
| | | |
| | | __redisManager = redis_manager.RedisManager(0) |
| | |
| | | # 添加进首板未筛选票 |
| | | def __add_first_no_screen_codes(codes): |
| | | redis = __redisManager.getRedis() |
| | | if codes: |
| | | for code in codes: |
| | | RedisUtils.sadd(redis, "first_no_screen_codes", code) |
| | | RedisUtils.expire(redis, "first_no_screen_codes", tool.get_expire()) |
| | | try: |
| | | if codes: |
| | | for code in codes: |
| | | RedisUtils.sadd(redis, "first_no_screen_codes", code, auto_free=False) |
| | | RedisUtils.expire(redis, "first_no_screen_codes", tool.get_expire(), auto_free=False) |
| | | finally: |
| | | RedisUtils.realse(redis) |
| | | |
| | | |
| | | def clear_first_no_screen_codes(): |
| | | redis = __redisManager.getRedis() |
| | | RedisUtils.delete(redis, "first_no_screen_codes") |
| | | RedisUtils.delete(__redisManager.getRedis(), "first_no_screen_codes") |
| | | |
| | | |
| | | def __remove_first_no_screen_codes(codes): |
| | | redis = __redisManager.getRedis() |
| | | if codes: |
| | | for code in codes: |
| | | RedisUtils.srem(redis, "first_no_screen_codes", code) |
| | | try: |
| | | if codes: |
| | | for code in codes: |
| | | RedisUtils.srem(redis, "first_no_screen_codes", code, auto_free= False) |
| | | finally: |
| | | RedisUtils.realse(redis) |
| | | |
| | | |
| | | def __get_first_no_screen_codes(): |
| | |
| | | return True, "炸板后,60分钟内都未回封" |
| | | if now_rate <= 6: |
| | | return True, "炸板后,涨幅小于6%" |
| | | # TODO 是否有同概念的票已经买入成功 |
| | | blocks = block_info.get_code_blocks(code) |
| | | if blocks and len(blocks) == 1: |
| | | codes = block_info.get_block_codes(blocks[0]) |