改变目录

Administrator

2023-08-21 a019311b0edee6df82a8ec7c0b28b06b22aa4d31

 trade/huaxin/trade_server.py

@@ -12,7 +12,7 @@

import dask
import psutil
import huaxin_api.constant
import huaxin_client.constant
from line_profiler import LineProfiler

import constant
@@ -21,7 +21,7 @@
from code_attribute import gpcode_manager
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from huaxin_api.client_network import SendResponseSkManager
from huaxin_client.client_network import SendResponseSkManager
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, l2_data_manager, transaction_progress
from l2.cancel_buy_strategy import HourCancelBigNumComputer, LCancelBigNumComputer, DCancelBigNumComputer
from l2.huaxin import huaxin_target_codes_manager
@@ -383,8 +383,8 @@
class OutsideApiCommandCallback(outside_api_command_manager.ActionCallback):
    @classmethod
    def __send_response(cls, data_bytes):
        sk = SendResponseSkManager.create_send_response_sk(addr=huaxin_api.constant.SERVER_IP,
                                                           port=huaxin_api.constant.SERVER_PORT)
        sk = SendResponseSkManager.create_send_response_sk(addr=huaxin_client.constant.SERVER_IP,
                                                           port=huaxin_client.constant.SERVER_PORT)
        try:
            data_bytes = socket_util.load_header(data_bytes)
            sk.sendall(data_bytes)