bug修复

Administrator

2023-08-23 f273791e2337215a2a3bd7e3c46c23c69bcb1c7c

 trade/huaxin/trade_server.py

@@ -21,6 +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_client import l1_subscript_codes_manager
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
@@ -217,8 +218,7 @@
                                            code)
                                        logger_l2_trade_buy_queue.info("获取成交位置成功： code-{} index-{}", code,
                                                                       buy_progress_index)
                                        buy_time = total_datas[buy_progress_index]["val"][
                                            "time"]
                                        buy_time = total_datas[buy_progress_index]["val"]["time"]
                                        limit_up_price = gpcode_manager.get_limit_up_price(code)
                                        if buy_exec_index:
                                            need_cancel, msg = DCancelBigNumComputer().set_trade_progress(code,
@@ -680,6 +680,14 @@
        except Exception as e:
            self.send_response({"code": 1, "msg": str(e)}, client_id, request_id)

    # 同步L2订阅代码
    def OnSyncL2SubscriptCodes(self, client_id, request_id):
        codes_sh, codes_sz = l1_subscript_codes_manager.request_l1_subscript_target_codes()
        if codes_sh and codes_sz:
            l1_subscript_codes_manager.save_codes(codes_sh, codes_sz)
        result = {"code": 0, "data": {"codes_sh": len(codes_sh), "codes_sz": len(codes_sz)}}
        self.send_response(result, client_id, request_id)


def run(pipe_trade, pipe_l1):
    # 执行一些初始化数据