| | |
|---|
| | | from l2.l2_data_manager_new import L2TradeDataProcessor |
|---|
| | | from log_module.log import hx_logger_l2_upload, hx_logger_contact_debug, hx_logger_trade_callback, \ |
|---|
| | | hx_logger_l2_orderdetail, hx_logger_l2_transaction, hx_logger_l2_market_data, logger_l2_trade_buy_queue |
|---|
| | | from third_data import block_info, kpl_api |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager |
|---|
| | | from third_data import block_info, kpl_api, kpl_data_manager |
|---|
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager |
|---|
| | | from third_data.history_k_data_util import JueJinApi, HistoryKDatasUtils |
|---|
| | | from third_data.kpl_data_manager import KPLDataManager |
|---|
| | | from third_data.kpl_util import KPLDataType |
|---|
| | |
|---|
| | | limit_up_price, |
|---|
| | | sell_1_price, sell_1_volume // 100) |
|---|
| | | pre_close_price = round(float(limit_up_price) / 1.1, 2) |
|---|
| | | # 如果涨幅大于8%就读取板块 |
|---|
| | | # 如果涨幅大于7%就读取板块 |
|---|
| | | if (buy_1_price - pre_close_price) / pre_close_price > 0.07: |
|---|
| | | if not self.__KPLCodeJXBlockManager.get_jx_blocks(code): |
|---|
| | | blocks = kpl_api.getCodeJingXuanBlocks(code) |
|---|
| | | self.__KPLCodeJXBlockManager.save_jx_blocks(code, blocks) |
|---|
| | | # 更新板块信息 |
|---|
| | | yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes() |
|---|
| | | CodePlateKeyBuyManager.update_can_buy_blocks(code, |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.latest_origin_datas, |
|---|
| | | kpl_data_manager.KPLLimitUpDataRecordManager.total_datas, |
|---|
| | | yesterday_codes, |
|---|
| | | block_info.get_before_blocks_dict()) |
|---|
| | | |
|---|
| | | hx_logger_l2_market_data.info(f"{code}#{data}") |
|---|
| | | finally: |
|---|
