"""
|
可转债入口函数
|
"""
|
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, 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()
|
