From e7c7efc9d6fc46a2925fa5b2b74358c68b007df2 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期一, 07 四月 2025 18:30:13 +0800
Subject: [PATCH] 并行批量处理L1数据/日志调整/初步集成L2数据
---
main.py | 31 +++++++++++++++++++++++++------
1 files changed, 25 insertions(+), 6 deletions(-)
diff --git a/main.py b/main.py
index 62e2901..7360a72 100644
--- a/main.py
+++ b/main.py
@@ -1,9 +1,6 @@
# coding=utf-8
from __future__ import print_function, absolute_import, unicode_literals
import logging
-import json
-import os.path
-# from log import logger
import threading
import time
@@ -11,7 +8,8 @@
# 寮曞叆鎺橀噾妗ユAPI
import utils.juejin_api
from db.redis_manager_delegate import RedisUtils
-from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_system
+from huaxin_client.l2_data_transform_protocol import L2DataCallBack
+from log_module.log import logger_common, logger_kpl_jingxuan_in, logger_system, logger_debug
# 寮曞叆寮�鐩樺暒API妯″潡
# 寮曞叆鍏ㄥ眬鍙橀噺妯″潡
# 寮曞叆瀹氭椂鍣ㄦā鍧�
@@ -23,7 +21,7 @@
from huaxin_client import l2_market_client
from log_module import async_log_util
from trade import huaxin_trade_data_update
-from utils import hx_qc_value_util
+from utils import hx_qc_value_util, huaxin_util
# 寮曞叆琛屾儏璁㈤槄妯″潡
# import subscribe_market
@@ -95,6 +93,7 @@
# print(f"all_stocks_all_K_line_property_dict== {type(data_cache.all_stocks_all_K_line_property_dict)}")
# 鑾峰彇瀹炴椂澶х洏鎸囨暟琛屾儏绾跨▼
threading.Thread(target=lambda: instant_time_market.index_market_current(), daemon=True).start()
+
# instant_time_market.index_market_trend()
# 寮�鐩樺暒鐨勬定鍋滄蹇电殑鍥炶皟鍑芥暟
@@ -165,9 +164,29 @@
else:
instant_time_market.set_current_info(datas)
+
+ class MyL2DataCallback(L2DataCallBack):
+
+ def OnL2Transaction(self, code, datas):
+ if datas:
+ # 鑾峰彇鏈�杩戠殑鎴愪氦浠�
+ price, time_str = datas[-1][1], huaxin_util.convert_time(datas[-1][3])
+ pass
+
+ def OnMarketData(self, code, datas):
+ # logger_debug.info(f"鏀跺埌L2Market鏁版嵁锛歿datas}")
+ for d in datas:
+ code = d["securityID"]
+ buy1 = d["buy"][0]
+
+ def OnRealTimeBuy1Info(self, code, buy1_info):
+ # buy1_info: [涔�1鏃堕棿,涔�1浠锋牸, 鍘熷涔�1閲�, 瀹炴椂涔�1閲廬
+ async_log_util.info(logger_debug, f"OnRealTimeBuy1Info锛歿code}-{buy1_info}")
+ # L1DataProcessor.excute_sell_rule(code, buy1_info[3], buy1_info[1], "l2-real")
+
+
# 鍔犺浇寮�鐩樺暒鏉垮潡鏃ュ織鏁版嵁
kpl_data_manager.KPLStockOfMarketsPlateLogManager()
-
# 鍚姩寮傛鏃ュ織
threading.Thread(target=async_log_util.run_sync, daemon=True).start()
--
Gitblit v1.8.0