Administrator
2023-07-26 6da815f5ecdedca45e8fc99989115fbf2b9b570c
trade/huaxin/trade_server.py
@@ -21,7 +21,7 @@
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()
@@ -150,9 +150,9 @@
                            # 记录交易反馈日志
                            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')))