| | |
|---|
| | | from l2.huaxin import huaxin_target_codes_manager |
|---|
| | | from l2.l2_transaction_data_manager import HuaXinBuyOrderManager |
|---|
| | | from log_module.log import logger_system, logger_debug, logger_kpl_limit_up, logger_request_api, \ |
|---|
| | | logger_kpl_market_strong |
|---|
| | | logger_kpl_market_strong, logger_kpl_new_blocks |
|---|
| | | from third_data.custom_block_in_money_manager import CodeInMoneyManager |
|---|
| | | from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager, LimitUpDataConstant, \ |
|---|
| | | ContainsLimitupCodesBlocksManager |
|---|
| | |
|---|
| | | big_money_rate * 100 # 大单成交比 |
|---|
| | | ), |
|---|
| | | output_util.money_desc(deal_big_money_info[1]), |
|---|
| | | output_util.money_desc(deal_big_money_info[2])] |
|---|
| | | output_util.money_desc(deal_big_money_info[2]), |
|---|
| | | output_util.money_desc(deal_big_money_info[3]), |
|---|
| | | ] |
|---|
| | | if len(codes) == 1: |
|---|
| | | # 加载大单详情 |
|---|
| | | deal_big_order_detail_info = radical_buy_data_manager.get_l2_big_order_deal_info(code) |
|---|
| | |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes() |
|---|
| | | blocks = set() |
|---|
| | | for bi in blocks_info: |
|---|
| | | if bi[0] in blocks: |
|---|
| | | continue |
|---|
| | | blocks.add(bi[0]) |
|---|
| | | result = kpl_api.getCodesByPlate(bi[1]) |
|---|
| | | result = json.loads(result) |
|---|
| | | code_info_list = [] |
|---|
| | |
|---|
| | | continue |
|---|
| | | # 格式：(代码,涨幅) |
|---|
| | | code_info_list.append((d[0], d[6])) |
|---|
| | | # 保存新题材 |
|---|
| | | datas = [(d[0], d[6]) for d in result["list"]] |
|---|
| | | async_log_util.info(logger_kpl_new_blocks, f"{(tool.get_thread_id() ,bi, datas)}") |
|---|
| | | if code_info_list: |
|---|
| | | # 将代码加入新题材 |
|---|
| | | new_block_processor.process_new_block_by_component_codes(bi[0], |
|---|
