| | |
|---|
| | | request_id) |
|---|
| | | |
|---|
| | | def OnTest(self, client_id, request_id, data): |
|---|
| | | logger_local_huaxin_trade_debug.info(f"测试通道：client_id-{client_id} request_id-{request_id} data-{data}") |
|---|
| | | send_response( |
|---|
| | | json.dumps({"type": "response", "data": {"code": 0, "data": data}, "client_id": client_id, |
|---|
| | | "request_id": request_id}), type, client_id, request_id) |
|---|
| | | "request_id": request_id}), type, client_id, request_id,show_log=False) |
|---|
| | | |
|---|
| | | |
|---|
| | | def __init_trade_data_server(): |
|---|
| | |
|---|
| | | sk.close() |
|---|
| | | |
|---|
| | | |
|---|
| | | def send_response(data, type, _client_id, _request_id): |
|---|
| | | def send_response(data, type, _client_id, _request_id,show_log=True): |
|---|
| | | logger_local_huaxin_trade_debug.debug(f"回调返回内容：{data}") |
|---|
| | | strategy_pipe.send(data) |
|---|
| | | |
|---|
