将华鑫订单交易成功独立出来处理

Administrator

2023-09-25 c0bcfe746b97bc126636a658b1f01fc6a51f9f95

 huaxin_client/trade_client.py

@@ -2,6 +2,7 @@
import concurrent.futures
import json
import logging
import multiprocessing
import os
import threading
import time
@@ -1013,7 +1014,7 @@
        # 采用的是socket通信
        sk.sendall(socket_util.load_header(data.encode('utf-8')))
    else:
        strategy_pipe.send(data)
        queue_strategy_trade_write.put_nowait(data)


# 交易反馈回调
@@ -1069,7 +1070,9 @@

addr, port = constant.SERVER_IP, constant.SERVER_PORT

def run(trade_response_: TradeResponse = None, pipe_l2=None, pipe_strategy=None, queue_strategy_trade=None):

def run(trade_response_: TradeResponse = None, pipe_l2=None, queue_strategy_trade_write_=None,
        queue_strategy_trade_read=None):
    try:
        logger_system.info("交易进程ID：{}", os.getpid())
        logger_system.info(f"trade 线程ID:{tool.get_thread_id()}")
@@ -1077,8 +1080,8 @@
        global l2pipe
        l2pipe = pipe_l2

        global strategy_pipe
        strategy_pipe = pipe_strategy
        global queue_strategy_trade_write
        queue_strategy_trade_write = queue_strategy_trade_write_

        global trade_response
        trade_response = trade_response_
@@ -1088,7 +1091,7 @@

        global tradeCommandManager
        tradeCommandManager = command_manager.TradeCommandManager()
        tradeCommandManager.init(MyTradeActionCallback(), l2pipe, pipe_strategy, queue_strategy_trade)
        tradeCommandManager.init(MyTradeActionCallback(), l2pipe, queue_strategy_trade_read)
        logger_system.info("华鑫交易服务启动")
        tradeCommandManager.run()
    except Exception as e: