| | |
|---|
| | | from log_module.log import logger_debug |
|---|
| | | from middle_l1_data_server import L1DataManager |
|---|
| | | from output import push_msg_manager |
|---|
| | | from trade import huaxin_trade_api |
|---|
| | | from utils import socket_util, kpl_api_util, hosting_api_util, kp_client_msg_manager, global_data_cache_util, tool |
|---|
| | | from utils.juejin_util import JueJinHttpApi |
|---|
| | | |
|---|
| | |
|---|
| | | sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8'))) |
|---|
| | | elif data_json["type"] == 'l1_data': |
|---|
| | | datas = data_json["data"] |
|---|
| | | L1DataManager.add_datas(datas) |
|---|
| | | L1DataManager().add_datas(datas) |
|---|
| | | break |
|---|
| | | elif data_json["type"] == "simulation_trade": |
|---|
| | | datas = data_json["data"] |
|---|
| | | ctype = datas["ctype"] |
|---|
| | | data = datas["data"] |
|---|
| | | result = huaxin_trade_api.request(ctype,data) |
|---|
| | | result_str = json.dumps({"code": 0, "data": result}, default=str) |
|---|
| | | sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8'))) |
|---|
| | | |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | log.logger_tuoguan_request_debug.exception(e) |
|---|
| | | finally: |
|---|
