From 395177f457b819d46743a98621c9baa6a9c522b9 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期六, 15 六月 2024 09:14:19 +0800
Subject: [PATCH] 测试NGTS
---
huaxin_client/l2_client.py | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index ae2f8e1..c9a6473 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -17,7 +17,8 @@
from huaxin_client.l2_data_manager import L2DataUploadManager
from log_module import log, async_log_util
from log_module.async_log_util import huaxin_l2_log
-from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_l2_codes_subscript
+from log_module.log import logger_local_huaxin_l2_subscript, logger_system, logger_l2_codes_subscript, \
+ logger_local_huaxin_l2_transaction
from utils import tool
###B绫�###
@@ -216,6 +217,8 @@
print("----L2琛屾儏鐧诲綍鎴愬姛----")
self.is_login = True
logger_system.info(f"L2琛屾儏鐧诲綍鎴愬姛")
+ # TODO 娴嬭瘯
+ self.__subscribe(["600355"])
# 鍒濆璁剧疆鍊�
if tool.trade_time_sub(tool.get_now_time_str(), "09:20:00") > 0:
threading.Thread(
@@ -258,7 +261,7 @@
def OnRspSubNGTSTick(self, pSpecificSecurity, pRspInfo, nRequestID, bIsLast):
async_log_util.info(logger_local_huaxin_l2_subscript,
- f"璁㈤槄缁撴灉锛歿pSpecificSecurity['SecurityID']} {pRspInfo['ErrorID']} {pRspInfo['ErrorMsg']}")
+ f"NGTS璁㈤槄缁撴灉锛歿pSpecificSecurity['SecurityID']} {pRspInfo['ErrorID']} {pRspInfo['ErrorMsg']}")
if pRspInfo["ErrorID"] == 0:
print("璁㈤槄鎴愬姛")
self.subscripted_codes.add(pSpecificSecurity['SecurityID'])
@@ -269,6 +272,7 @@
def OnRspUnSubNGTSTick(self, pSpecificSecurity, pRspInfo, nRequestID, bIsLast):
try:
code = pSpecificSecurity['SecurityID']
+ logger_local_huaxin_l2_subscript.info(f"NGTS鍙栨秷璁㈤槄锛歿code}")
self.subscripted_codes.discard(code)
if bIsLast == 1:
print("鍙栨秷璁㈤槄鍝嶅簲缁撴潫", self.subscripted_codes)
@@ -387,6 +391,8 @@
@return:
"""
try:
+ # TODO:娴嬭瘯
+ logger_local_huaxin_l2_transaction.info(f"{pTick}")
if pTick['TickType'] == b'T':
# 鎴愪氦
item = {"SecurityID": pTick['SecurityID'], "TradePrice": pTick['Price'],
--
Gitblit v1.8.0