| | |
| | | from log_module import async_log_util |
| | | from db import redis_manager_delegate as redis_manager, mysql_data_delegate as mysql_data |
| | | |
| | | from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out, logger_kpl_jx_in, logger_debug |
| | | from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out, logger_kpl_jx_in, logger_debug, \ |
| | | logger_kpl_latest_gaobiao |
| | | from third_data.kpl_util import KPLPlatManager |
| | | from trade import l2_trade_util, trade_constant |
| | | |
| | |
| | | block_codes[b].add(code) |
| | | print(block_codes) |
| | | cls.__watch_block_high_codes = block_codes |
| | | logger_kpl_latest_gaobiao.info(f"{block_codes}") |
| | | cls.__watch_high_codes.clear() |
| | | for b in block_codes: |
| | | cls.__watch_high_codes |= block_codes[b] |
| | |
| | | average_rate = total_rate / len(self.__watch_block_high_codes[b]) |
| | | if average_rate < 1: |
| | | forbidden_blocks.add(b) |
| | | async_log_util.info(logger_debug, f"板块平均涨幅 {b}-{average_rate}") |
| | | # async_log_util.info(logger_debug, f"板块平均涨幅 {b}-{average_rate}") |
| | | |
| | | self.__kpl_forbidden_plates_cache = forbidden_blocks |
| | | async_log_util.info(logger_debug, f"拉黑板块:{forbidden_blocks}") |