From cf32945520de905d86f87c04cad426a7402d12d8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 十一月 2024 17:12:20 +0800
Subject: [PATCH] 删除原有的资金净流入统计方式
---
third_data/kpl_data_manager.py | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index 4de7470..149b542 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -487,17 +487,17 @@
logger_debug.info("浠诲姟淇-寮�鐩樺暒锛氭定鍋滃垪琛�")
# 澶т簬20s灏遍渶瑕佹洿鏂�
threading.Thread(target=cls.run_limit_up_task, daemon=True).start()
- key = "jingxuan_rank"
- if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:
- logger_debug.info("浠诲姟淇-寮�鐩樺暒锛氱簿閫夋祦鍏ュ垪琛�")
- # 澶т簬20s灏遍渶瑕佹洿鏂�
- threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()
-
- key = "jingxuan_rank_out"
- if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:
- logger_debug.info("浠诲姟淇-寮�鐩樺暒锛氱簿閫夋祦鍑哄垪琛�")
- # 澶т簬20s灏遍渶瑕佹洿鏂�
- threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()
+ # key = "jingxuan_rank"
+ # if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:
+ # logger_debug.info("浠诲姟淇-寮�鐩樺暒锛氱簿閫夋祦鍏ュ垪琛�")
+ # # 澶т簬20s灏遍渶瑕佹洿鏂�
+ # threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()
+ #
+ # key = "jingxuan_rank_out"
+ # if key not in cls.__latest_update_time_dict or time.time() - cls.__latest_update_time_dict[key] > 20:
+ # logger_debug.info("浠诲姟淇-寮�鐩樺暒锛氱簿閫夋祦鍑哄垪琛�")
+ # # 澶т簬20s灏遍渶瑕佹洿鏂�
+ # threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()
@classmethod
def run_limit_up_task(cls):
@@ -602,8 +602,8 @@
threading.Thread(target=cls.run_limit_up_task, daemon=True).start()
# threading.Thread(target=get_bidding_money, daemon=True).start()
# threading.Thread(target=get_market_industry, daemon=True).start()
- threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()
- threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()
+ # threading.Thread(target=cls.run_market_jingxuan_in, daemon=True).start()
+ # threading.Thread(target=cls.run_market_jingxuan_out, daemon=True).start()
@tool.singleton
--
Gitblit v1.8.0