| | |
|---|
| | | from http.server import BaseHTTPRequestHandler |
|---|
| | | import dask |
|---|
| | | |
|---|
| | | from log_module.log import logger_system |
|---|
| | | from log_module.log import logger_system, logger_debug |
|---|
| | | from utils import global_util, tool |
|---|
| | | from code_attribute import gpcode_manager |
|---|
| | | from log_module import log, log_analyse, log_export |
|---|
| | |
|---|
| | | for code in add_codes: |
|---|
| | | # 根据涨停原因判断是否可以买 |
|---|
| | | if code.find("00") == 0 or code.find("60") == 0: |
|---|
| | | try: |
|---|
| | | # 判断是否下单 |
|---|
| | | trade_state = trade_manager.CodesTradeStateManager().get_trade_state(code) |
|---|
| | | if trade_state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER or trade_state == trade_manager.TRADE_STATE_BUY_DELEGATED: |
|---|
| | |
|---|
| | | yesterday_current_limit_up_codes, |
|---|
| | | before_blocks_dict): |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, f"涨停原因（{ limit_up_reasons.get(code)}）不是老大撤单", "板块撤") |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.save_record(tool.get_now_date_str(), result_list_) |
|---|
| | | self.__kplDataManager.save_data(type_, result_list_) |
|---|
| | | |
|---|
