From 27e49e5782e07566aac42d6363bd5233bf5e396d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 16 五月 2024 19:19:51 +0800
Subject: [PATCH] 可转债仿真交易/print方法替换
---
cb_main.py | 39 ++++++++++++++++++++++++++++++++++++++-
1 files changed, 38 insertions(+), 1 deletions(-)
diff --git a/cb_main.py b/cb_main.py
index fd7eceb..3f2cd84 100644
--- a/cb_main.py
+++ b/cb_main.py
@@ -2,10 +2,47 @@
鍙浆鍊哄叆鍙ｅ嚱鏁�
"""
import constant
+from log_module.log import logger_debug
+
constant.LOG_DIR = "logs_cb"
from huaxin_client.cb import l2_client_for_cb
-from utils import middle_api_protocol
+from utils import middle_api_protocol, outside_api_command_manager
+
+
+def command_callback(client_id, request_id, data):
+ """
+ 鍛戒护鍥炶皟
+ :param client_id:
+ :param request_id:
+ :param data: json鏍煎紡鏁版嵁
+ :return:
+ """
+ type_ = data.get('type')
+ if type_ == outside_api_command_manager.API_TYPE_TRADE:
+ # 浜ゆ槗
+ pass
+ elif type_ == "get_code_position_info":
+ # 鏌ヨ姝や粨
+ pass
+ elif type_ == "get_code_position_info":
+ # 鏌ヨ姝や粨
+ pass
+ elif type_ == outside_api_command_manager.API_TYPE_COMMON_REQUEST:
+ # 甯歌鎺ュ彛
+ ctype = data['ctype']
+ if ctype == 'get_account_money':
+ # 鑾峰彇璐︽埛璧勯噾
+ pass
+ logger_debug.info(f"鎺ユ敹鍒板懡浠わ細{request_id} - f{client_id} - {data}")
+
if __name__ == '__main__':
middle_api_protocol.SERVER_PORT = 10008
+ middle_api_protocol.SERVER_HOST = "43.138.167.68"
+ # middle_api_protocol.SERVER_HOST = "192.168.3.122"
+ manager = outside_api_command_manager.NewApiCommandManager()
+ manager.init(middle_api_protocol.SERVER_HOST, middle_api_protocol.SERVER_PORT,
+ command_callback, [("trade_cb", 20)])
+ manager.run(blocking=False)
+
l2_client_for_cb.run()
--
Gitblit v1.8.0