From f273791e2337215a2a3bd7e3c46c23c69bcb1c7c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 23 八月 2023 12:12:16 +0800
Subject: [PATCH] bug修复
---
trade/huaxin/trade_server.py | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/trade/huaxin/trade_server.py b/trade/huaxin/trade_server.py
index 7aad862..b0ff212 100644
--- a/trade/huaxin/trade_server.py
+++ b/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):
# 鎵ц涓�浜涘垵濮嬪寲鏁版嵁
--
Gitblit v1.8.0