| | |
|---|
| | | from code_attribute.code_l1_data_manager import L1DataManager |
|---|
| | | from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager, \ |
|---|
| | | WantBuyCodesManager |
|---|
| | | from code_attribute.today_max_price_manager import MaxPriceInfoManager |
|---|
| | | from huaxin_client import l2_data_transform_protocol, l1_subscript_codes_manager |
|---|
| | | from huaxin_client.trade_transform_protocol import TradeResponse |
|---|
| | | from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, transaction_progress, \ |
|---|
| | |
|---|
| | | datas = data["data"] |
|---|
| | | cls.__save_l1_current_price(datas) |
|---|
| | | cls.__process_buy_open_limit_up_datas(datas) |
|---|
| | | |
|---|
| | | try: |
|---|
| | | # 记录今日最高价 |
|---|
| | | # 09:25之后才开始记录 |
|---|
| | | if datas and tool.get_now_time_str() > '09:25:00': |
|---|
| | | for d in datas: |
|---|
| | | MaxPriceInfoManager().set_price_info(d[0], price=d[1], time=l2_huaxin_util.convert_time(d[9])) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | |
|---|
| | | # 根据高标的实时涨幅计算拉黑板块 |
|---|
| | | rate_dict = {d[0]: d[2] for d in datas} |
|---|
| | | cls.__process_l1_data_thread_pool.submit( |
|---|
