From f8ff0e2645846ad96edb99045d7e642f97c8b7bb Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 29 九月 2024 10:33:02 +0800
Subject: [PATCH] bug修复

---
 third_data/third_blocks_manager.py |   32 ++++++++++++++++++++++++++++----
 1 files changed, 28 insertions(+), 4 deletions(-)

diff --git a/third_data/third_blocks_manager.py b/third_data/third_blocks_manager.py
index 5eb5910..d1ec317 100644
--- a/third_data/third_blocks_manager.py
+++ b/third_data/third_blocks_manager.py
@@ -4,7 +4,8 @@
 from itertools import combinations
 
 from db.mysql_data_delegate import Mysqldb
-from third_data import kpl_api
+from third_data import kpl_api, block_web_api
+from utils import middle_api_protocol
 
 SOURCE_TYPE_KPL = 1  # 涓滄柟璐㈠瘜
 SOURCE_TYPE_TDX = 2  # 閫氳揪淇�
@@ -190,8 +191,31 @@
         return self.__block_map.keys()
 
 
+def load_if_less(codes):
+    """
+    鍔犺浇
+    @param codes:
+    @return:
+    """
+    for code in codes:
+        source_blocks = CodeThirdBlocksManager().get_source_blocks_origin(code)
+        if source_blocks is None:
+            source_blocks = {}
+        all_source = {SOURCE_TYPE_EASTMONEY, SOURCE_TYPE_TDX, SOURCE_TYPE_THS}
+        sources = all_source - source_blocks.keys()
+        for source in sources:
+            try:
+                blocks = middle_api_protocol.request(middle_api_protocol.get_third_blocks(code, source))
+                if blocks:
+                    CodeThirdBlocksManager().set_blocks(code, blocks, source)
+            except:
+                pass
+
+
 if __name__ == '__main__':
     code = "000761"
-    blocks = kpl_api.getCodeJingXuanBlocks(code, jx=False)
-    blocks = set([b[1] for b in blocks])
-    print(CodeThirdBlocksManager().get_intersection_blocks_info(code, blocks))
+    try:
+        blocks = middle_api_protocol.request(middle_api_protocol.get_third_blocks(code, 4))
+        print(blocks)
+    except Exception as e:
+        print(e)

--
Gitblit v1.8.0