From b51b2ae184fad5aaf37a78903987e064f192d430 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 26 五月 2025 11:35:20 +0800
Subject: [PATCH] 大单解析修改

---
 code_attribute/global_data_loader.py |   30 ++++++++++++++++++++++++------
 1 files changed, 24 insertions(+), 6 deletions(-)

diff --git a/code_attribute/global_data_loader.py b/code_attribute/global_data_loader.py
index de9ffd8..62fde4c 100644
--- a/code_attribute/global_data_loader.py
+++ b/code_attribute/global_data_loader.py
@@ -1,4 +1,6 @@
 from code_attribute import code_volumn_manager, gpcode_manager
+from db.mysql_data_delegate import Mysqldb
+from log_module.log import logger_codes_zyltgb
 from utils import global_util, ths_industry_util
 from code_attribute.code_data_util import ZYLTGBUtil
 
@@ -28,6 +30,19 @@
             global_util.zyltgb_map[code] = result
 
 
+def load_zyltgb_volume_from_db():
+    # 鎷夊彇鑷敱娴侀�氶噺
+    mysqldb = Mysqldb()
+    fresults = mysqldb.select_all("select code, zylt_volume from kpl_zylt_volume")
+    if fresults:
+        for result in fresults:
+            global_util.zylt_volume_map[result[0]] = result[1]
+        try:
+            logger_codes_zyltgb.info(f"{global_util.zylt_volume_map}")
+        except:
+            pass
+
+
 # 鍔犺浇鍚嶇О浠g爜闅愬皠
 def load_name_codes():
     dict_ = gpcode_manager.get_name_codes()
@@ -40,11 +55,14 @@
 def load_volumn():
     codes = gpcode_manager.get_gp_list()
     for code in codes:
-        max60, yesterday = code_volumn_manager.get_histry_volumn(code)
-        today = code_volumn_manager.get_today_volumn(code)
-        global_util.max60_volumn[code] = max60
-        global_util.yesterday_volumn[code] = yesterday
-        global_util.today_volumn[code] = today
+        try:
+            max60, yesterday = code_volumn_manager.CodeVolumeManager().get_histry_volumn(code)
+            today = code_volumn_manager.CodeVolumeManager().get_today_volumn(code)
+            global_util.max60_volumn[code] = max60
+            global_util.yesterday_volumn[code] = yesterday
+            global_util.today_volumn[code] = today
+        except:
+            pass
 
 
 # 娣诲姞浠婃棩娑ㄥ仠鏁版嵁
@@ -58,4 +76,4 @@
     for data in datas:
         __dict[data["code"]] = data
     # print(__dict)
-    global_util.today_limit_up_codes.update(__dict)
\ No newline at end of file
+    global_util.today_limit_up_codes.update(__dict)

--
Gitblit v1.8.0