From 27e49e5782e07566aac42d6363bd5233bf5e396d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 16 五月 2024 19:19:51 +0800
Subject: [PATCH] 可转债仿真交易/print方法替换
---
huaxin_client/l1_client_for_output.py | 36 ++++++++++++++++++------------------
1 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/huaxin_client/l1_client_for_output.py b/huaxin_client/l1_client_for_output.py
index 7288698..83519c3 100644
--- a/huaxin_client/l1_client_for_output.py
+++ b/huaxin_client/l1_client_for_output.py
@@ -8,7 +8,7 @@
import xmdapi
from huaxin_client import l1_subscript_codes_manager
-from log_module.log import logger_system, logger_local_huaxin_l1
+from log_module.log import logger_system, logger_local_huaxin_l1, printlog
################B绫�##################
from utils import socket_util, tool
@@ -44,7 +44,7 @@
self.__api = api
def OnFrontConnected(self):
- print("OnFrontConnected")
+ printlog("OnFrontConnected")
# 璇锋眰鐧诲綍锛岀洰鍓嶆湭鏍￠獙鐧诲綍鐢ㄦ埛锛岃姹傚煙缃┖鍗冲彲
login_req = xmdapi.CTORATstpReqUserLoginField()
@@ -52,24 +52,24 @@
def subscribe_codes(self, codes_sh, codes_sz):
# 閲嶆柊璁㈤槄浠ｇ爜
- print(f"璁㈤槄鏁伴噺锛歴h-{len(codes_sh)} sz-{len(codes_sz)}")
+ printlog(f"璁㈤槄鏁伴噺锛歴h-{len(codes_sh)} sz-{len(codes_sz)}")
if codes_sh:
ret = self.__api.SubscribeMarketData(codes_sh, xmdapi.TORA_TSTP_EXD_SSE)
if ret != 0:
- print('SubscribeMarketData fail, ret[%d]' % ret)
+ printlog('SubscribeMarketData fail, ret[%d]' % ret)
else:
- print('SubscribeMarketData success, ret[%d]' % ret)
+ printlog('SubscribeMarketData success, ret[%d]' % ret)
if codes_sz:
ret = self.__api.SubscribeMarketData(codes_sz, xmdapi.TORA_TSTP_EXD_SZSE)
if ret != 0:
- print('SubscribeMarketData fail, ret[%d]' % ret)
+ printlog('SubscribeMarketData fail, ret[%d]' % ret)
else:
- print('SubscribeMarketData success, ret[%d]' % ret)
+ printlog('SubscribeMarketData success, ret[%d]' % ret)
def OnRspUserLogin(self, pRspUserLoginField, pRspInfoField, nRequestID):
if pRspInfoField.ErrorID == 0:
- print('Login success! [%d]' % nRequestID)
+ printlog('Login success! [%d]' % nRequestID)
'''
璁㈤槄琛屾儏
@@ -82,27 +82,27 @@
# sub_arr = [b'600004']
# ret = self.__api.UnSubscribeMarketData(sub_arr, xmdapi.TORA_TSTP_EXD_SSE)
# if ret != 0:
- # print('UnSubscribeMarketData fail, ret[%d]' % ret)
+ # printlog('UnSubscribeMarketData fail, ret[%d]' % ret)
# else:
- # print('SubscribeMarketData success, ret[%d]' % ret)
+ # printlog('SubscribeMarketData success, ret[%d]' % ret)
else:
- print('Login fail!!! [%d] [%d] [%s]'
+ printlog('Login fail!!! [%d] [%d] [%s]'
% (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
def OnRspSubMarketData(self, pSpecificSecurityField, pRspInfoField):
if pRspInfoField.ErrorID == 0:
- print('OnRspSubMarketData: OK!')
+ printlog('OnRspSubMarketData: OK!')
else:
- print('OnRspSubMarketData: Error! [%d] [%s]'
+ printlog('OnRspSubMarketData: Error! [%d] [%s]'
% (pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
def OnRspUnSubMarketData(self, pSpecificSecurityField, pRspInfoField):
if pRspInfoField.ErrorID == 0:
- print('OnRspUnSubMarketData: OK!')
+ printlog('OnRspUnSubMarketData: OK!')
else:
- print('OnRspUnSubMarketData: Error! [%d] [%s]'
+ printlog('OnRspUnSubMarketData: Error! [%d] [%s]'
% (pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
def OnRtnMarketData(self, pMarketDataField):
@@ -130,7 +130,7 @@
def __upload_codes_info(datas):
- print("涓婁紶鏁版嵁鏁伴噺", len(datas))
+ printlog("涓婁紶鏁版嵁鏁伴噺", len(datas))
# if not tool.is_trade_time():
# return
data_bytes = socket_util.load_header(json.dumps({"type": "l1_data", "data": datas}).encode("utf-8"))
@@ -166,7 +166,7 @@
def test_add_datas():
while True:
- print("鍙戦�佹祴璇曟暟鎹�")
+ printlog("鍙戦�佹祴璇曟暟鎹�")
level1_data_queue.put_nowait(("000948", 12.91, 14.20, int(34.60 * 10000), int(4.9 * 1e8),
[(12.91, 100), (12.90, 100), (12.89, 100), (12.88, 100), (12.87, 100)],
[(12.91, 100), (12.90, 100), (12.89, 100), (12.88, 100), (12.87, 100)],
@@ -188,7 +188,7 @@
time.sleep(4)
logger_system.info(f"鑾峰彇L1璁㈤槄鐩爣绁ㄦ暟閲忥細sh-{len(codes_sh)} sz-{len(codes_sz)}")
# 鎵撳嵃鎺ュ彛鐗堟湰鍙�
- print(xmdapi.CTORATstpXMdApi_GetApiVersion())
+ printlog(xmdapi.CTORATstpXMdApi_GetApiVersion())
# 鍒涘缓鎺ュ彛瀵硅薄
api = xmdapi.CTORATstpXMdApi_CreateTstpXMdApi(xmdapi.TORA_TSTP_MST_MCAST)
--
Gitblit v1.8.0