bug修复

Administrator

2025-06-11 01696a5d8c2c3cf3062aa6a8ccbf123547c2dbf0

 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


# 加载名称代码隐射
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)
    global_util.today_limit_up_codes.update(__dict)