| | |
| | | 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] |