From 6ebf3a8a4a1b48547633de879a26014b77feec46 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 28 十二月 2023 16:25:40 +0800
Subject: [PATCH] 输出api修改/市场行情设置

---
 third_data/kpl_data_manager.py |   27 ++++++++++++++++-----------
 1 files changed, 16 insertions(+), 11 deletions(-)

diff --git a/third_data/kpl_data_manager.py b/third_data/kpl_data_manager.py
index fe2bb34..66d33b6 100644
--- a/third_data/kpl_data_manager.py
+++ b/third_data/kpl_data_manager.py
@@ -47,7 +47,7 @@
     __kplPlatManager = KPLPlatManager()
     __LimitUpCodesPlateKeyManager = LimitUpCodesPlateKeyManager()
     __CodesPlateKeysManager = CodesHisReasonAndBlocksManager()
-    __current_code_reason_dict = {}
+    __current_code_reasons_dict = {}
     __current_reason_codes_dict = {}
     __records_cache = {}
 
@@ -81,15 +81,20 @@
             cls.latest_origin_datas = records
             cls.__LimitUpCodesPlateKeyManager.set_today_limit_up([(r[0], r[5]) for r in records])
 
-        code_reason_dict = {}
-        reason_code_dict = {}
+        code_reasons_dict = {}
+        reason_codes_dict = {}
         for d in records:
-            code_reason_dict[d[0]] = d[5]
-            if d[5] not in reason_code_dict:
-                reason_code_dict[d[5]] = set()
-            reason_code_dict[d[5]].add(d[0])
-        cls.__current_code_reason_dict = code_reason_dict
-        cls.__current_reason_codes_dict = reason_code_dict
+            # 娑ㄥ仠鍘熷洜 + 鎺ㄨ崘鍘熷洜
+            bs = {d[5]}
+            if d[6]:
+                bs |= set(d[6].split("銆�"))
+            code_reasons_dict[d[0]] = bs
+            for b in bs:
+                if b not in reason_codes_dict:
+                    reason_codes_dict[b] = set()
+                reason_codes_dict[b].add(d[0])
+        cls.__current_code_reasons_dict = code_reasons_dict
+        cls.__current_reason_codes_dict = reason_codes_dict
 
         # 娑ㄥ仠鏁版嵁璁板綍
         mysqldb = mysql_data.Mysqldb()
@@ -213,8 +218,8 @@
         return bs
 
     @classmethod
-    def get_current_block(cls, code):
-        return cls.__current_code_reason_dict.get(code)
+    def get_current_blocks(cls, code):
+        return cls.__current_code_reasons_dict.get(code)
 
     @classmethod
     def get_current_codes_by_block(cls, block):

--
Gitblit v1.8.0