| | |
| | | finally: |
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |
| | | elif data_json["type"] == "trade_callback": |
| | | try: |
| | | # 交易回调 |
| | | data_json = data_json["data"] |
| | | type_ = data_json["type"] |
| | |
| | | trade_api_server.trade_data_request_queue.put_nowait({"type": "money"}) |
| | | trade_api_server.trade_data_request_queue.put_nowait({"type": "deal_list"}) |
| | | # print("响应结果:", data_json['data']) |
| | | finally: |
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |
| | | elif data_json["type"] == "l2_order": |
| | | # L2逐笔委托 |
| | | data = data_json["data"] |