| | |
|---|
| | | # 设置首板未筛选的目标票 |
|---|
| | | 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) |
|---|
| | |
|---|
| | | 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: |
|---|
| | | redis.connection_pool.disconnect() |
|---|
| | | RedisUtils.realse(redis) |
|---|
| | | |
|---|
| | | |
|---|
| | | def clear_first_no_screen_codes(): |
|---|
| | |
|---|
| | | for code in codes: |
|---|
| | | RedisUtils.srem(redis, "first_no_screen_codes", code, auto_free= False) |
|---|
| | | finally: |
|---|
| | | redis.connection_pool.disconnect() |
|---|
| | | 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]) |
|---|
