| | |
|---|
| | | from cancel_strategy.s_l_h_cancel_strategy import HourCancelBigNumComputer, LCancelRateManager |
|---|
| | | from output.limit_up_data_filter import IgnoreCodeManager |
|---|
| | | from third_data import kpl_util, kpl_data_manager, kpl_api, block_info |
|---|
| | | from third_data.code_plate_key_manager import RealTimeKplMarketData, KPLPlateForbiddenManager |
|---|
| | | from third_data.code_plate_key_manager import RealTimeKplMarketData, KPLPlateForbiddenManager, LatestLimitUpBlockManager |
|---|
| | | from third_data.history_k_data_util import HistoryKDatasUtils |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager, KPLLimitUpDataRecordManager, \ |
|---|
| | | KPLCodeLimitUpReasonManager |
|---|
| | |
|---|
| | | msg_list.reverse() |
|---|
| | | msg_list = [f"{msg.split('|')[0]}{msg.split('|')[-1].split('-')[1].strip()}" for msg in msg_list] |
|---|
| | | response_data = json.dumps({"code": 0, "data": msg_list}) |
|---|
| | | elif url.path == "/statistic_latest_limit_up_block": |
|---|
| | | # 统计最近的涨停板块 |
|---|
| | | datas = LatestLimitUpBlockManager().statistics_limit_up_block_infos() |
|---|
| | | response_data = json.dumps({"code": 0, "data": datas}) |
|---|
| | | |
|---|
| | | async_log_util.info(logger_request_api, f"结束请求{tool.get_thread_id()}-{url}") |
|---|
| | | self.send_response(200) |
|---|
