| | |
|---|
| | | """ |
|---|
| | | 华鑫交易数据更新 |
|---|
| | | """ |
|---|
| | | import json |
|---|
| | | import queue |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | |
|---|
| | | gpcode_manager.request_price_pre(need_update_codes) |
|---|
| | | queue_l1_trade_r_strategy_w.put_nowait( |
|---|
| | | {"type": "set_target_codes", "data": list(position_codes)}) |
|---|
| | | queue_strategy_w_l2_r.put_nowait( |
|---|
| | | {"type": "l2_cmd", "data": list(position_codes)}) |
|---|
| | | queue_strategy_w_l2_r.put_nowait(json.dumps( |
|---|
| | | {"type": "l2_cmd", "data": list(position_codes)})) |
|---|
| | | # 9点25之前需要订阅持仓票 |
|---|
| | | __process_thread_pool.submit(huaxin_trade_record_manager.PositionManager.add, datas) |
|---|
| | | async_log_util.info(hx_logger_trade_debug, f"获取交易数据成功：{type_}") |
|---|
