| | |
| | | from third_data.code_plate_key_manager import KPLCodeJXBlockManager |
| | | from trade import deal_big_money_manager, current_price_process_manager |
| | | |
| | | from trade.huaxin import huaxin_trade_api as trade_api, trade_api_server, huaxin_trade_api |
| | | from trade.huaxin import huaxin_trade_api as trade_api, trade_api_server, huaxin_trade_api, huaxin_trade_data_update |
| | | from utils import socket_util |
| | | |
| | | trade_data_request_queue = queue.Queue() |
| | |
| | | # 记录交易反馈日志 |
| | | hx_logger_trade_callback.info(data_json) |
| | | # 重新请求委托列表与资金 |
| | | trade_api_server.trade_data_request_queue.put_nowait({"type": "delegate_list"}) |
| | | trade_api_server.trade_data_request_queue.put_nowait({"type": "money"}) |
| | | trade_api_server.trade_data_request_queue.put_nowait({"type": "deal_list"}) |
| | | huaxin_trade_data_update.add_delegate_list() |
| | | huaxin_trade_data_update.add_deal_list() |
| | | huaxin_trade_data_update.add_money_list() |
| | | # print("响应结果:", data_json['data']) |
| | | finally: |
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |