| | |
| | | from log_module import async_log_util |
| | | from log_module.log import logger_trade |
| | | from trade import trade_record_log_util |
| | | from trade.buy_radical.block_special_codes_manager import BlockSpecialCodesManager |
| | | |
| | | __redis_manager = redis_manager.RedisManager(2) |
| | | |
| | |
| | | |
| | | |
| | | # 添加代码到禁止交易 |
| | | def add_to_forbidden_trade_codes(code): |
| | | def __add_to_forbidden_trade_codes(code): |
| | | gpcode_manager.BlackListCodeManager().add_code(code) |
| | | |
| | | |
| | |
| | | need_add = True |
| | | else: |
| | | # 检查是否在想买单中 |
| | | if gpcode_manager.WantBuyCodesManager().is_in_cache(code): |
| | | if gpcode_manager.HumanRemoveForbiddenManager().is_in_cache(code): |
| | | # 人为移除黑,不可再拉黑 |
| | | need_add = False |
| | | else: |
| | | need_add = True |
| | | |
| | | if need_add: |
| | | if not is_in_forbidden_trade_codes(code): |
| | | trade_record_log_util.add_forbidden_buy_log(code, msg) |
| | | add_to_forbidden_trade_codes(code) |
| | | __add_to_forbidden_trade_codes(code) |
| | | async_log_util.warning(logger_trade, f"{code}加入黑名单原因:{msg}") |
| | | |
| | | |