From 2f4bf81b042d24d5fbbd2fa7ec3672a06b211264 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 21 三月 2025 15:41:17 +0800
Subject: [PATCH] 根据板块成分股来获取新题材的成分股/成交数据处理优化

---
 third_data/kpl_api.py |   37 ++++++++++++++++++++++++++++++++++---
 1 files changed, 34 insertions(+), 3 deletions(-)

diff --git a/third_data/kpl_api.py b/third_data/kpl_api.py
index ea1fbac..689facd 100644
--- a/third_data/kpl_api.py
+++ b/third_data/kpl_api.py
@@ -5,7 +5,7 @@
 
 import constant
 from third_data import kpl_util
-from utils import middle_api_protocol
+from utils import middle_api_protocol, tool
 
 # 绔炰环
 DABAN_TYPE_BIDDING = 8
@@ -299,6 +299,37 @@
     return int(data["info"]["strong"])
 
 
+def request_new_blocks_codes(blocks_info):
+    """
+    璇锋眰鏂版澘鍧楃殑浠g爜
+    @param blocks_info:[(鏉垮潡鍚嶇О,鏉垮潡浠g爜)]
+    @return:
+    """
+    yesterday_codes = set()
+    for bi in blocks_info:
+        result = getCodesByPlate(bi[1])
+        result = json.loads(result)
+        code_info_list = []
+        for d in result["list"]:
+            if d[0] in yesterday_codes:
+                continue
+            # 娑ㄥ箙瑕佸ぇ浜�5%
+            rate = d[6] / int(round((tool.get_limit_up_rate(d[0]) - 1) * 10))
+            if rate < 5:
+                continue
+            # 鏍煎紡锛�(浠g爜,娑ㄥ箙)
+            code_info_list.append((d[0], d[6]))
+        if code_info_list:
+            # 灏嗕唬鐮佸姞鍏ユ柊棰樻潗
+            for x in code_info_list:
+                print("娣诲姞", x)
+
+
 if __name__ == "__main__":
-    result =getHistoryLimitUpInfo("2024-02-19")
-    print(result)
+    request_new_blocks_codes([("鏈哄櫒浜�", "801159")])
+    # result = getCodesByPlate("801159")  # getHistoryLimitUpInfo("2024-02-19")
+    # result = json.loads(result)
+    # for d in result["list"]:
+    #     print(d)
+    #
+    # print(result)

--
Gitblit v1.8.0