| | |
|---|
| | | |
|---|
| | | from trade import bidding_money_manager, trade_manager, l2_trade_util |
|---|
| | | from trade.l2_trade_util import BlackListCodeManager |
|---|
| | | import concurrent.futures |
|---|
| | | |
|---|
| | | |
|---|
| | | class DataServer(BaseHTTPRequestHandler): |
|---|
| | |
|---|
| | | __jingxuan_cache_dict = {} |
|---|
| | | __industry_cache_dict = {} |
|---|
| | | __latest_limit_up_codes_set = set() |
|---|
| | | __data_process_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10) |
|---|
| | | |
|---|
| | | def __get_limit_up_list(self): |
|---|
| | | # 统计目前为止的代码涨停数量（分涨停原因） |
|---|
| | |
|---|
| | | limit_up_record_datas, |
|---|
| | | yesterday_current_limit_up_codes, |
|---|
| | | before_blocks_dict): |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, f"涨停原因（{ limit_up_reasons.get(code)}）不是老大撤单", "板块撤") |
|---|
| | | pass |
|---|
| | | # TODO 测试暂时注释 |
|---|
| | | # 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) |
|---|
| | | elif type_ == KPLDataType.LIMIT_UP.value: |
|---|
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP) |
|---|
| | | threading.Thread(target=lambda: do_limit_up(result_list), daemon=True).start() |
|---|
| | | self.__data_process_thread_pool.submit(lambda: do_limit_up(result_list)) |
|---|
| | | elif type_ == KPLDataType.OPEN_LIMIT_UP.value: |
|---|
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP) |
|---|
| | | if result_list: |
|---|
