环境信息添加自由流通量

Administrator

2024-06-07 663fd14df951defdc8b0bf833ed5e798c2ff52cd

环境信息添加自由流通量

 code_attribute/gpcode_manager.py

@@ -36,7 +36,7 @@
    def get_code_name(cls, code):
        if code in cls.__code_name_dict:
            return cls.__code_name_dict[code]
        fresults = cls.__mysqldb.select_one(f"select code_name from code_name where code = {code}")
        fresults = cls.__mysqldb.select_one(f"select code_name from code_name where code = '{code}'")
        if fresults:
            cls.__code_name_dict[code] = fresults[0]
            return fresults[0]
@@ -45,11 +45,11 @@
    @classmethod
    def add_code_name(cls, code, name):
        cls.__code_name_dict[code] = name
        fresults = cls.__mysqldb.select_one(f"select code_name from code_name where code = {code}")
        fresults = cls.__mysqldb.select_one(f"select code_name from code_name where code = '{code}'")
        if fresults:
            cls.__mysqldb.execute(f"update code_name set code_name ='{name}', update_time = now() where code= {code}")
            cls.__mysqldb.execute(f"update code_name set code_name ='{name}', update_time = now() where code= '{code}'")
        else:
            cls.__mysqldb.execute(f"insert into code_name(code,code_name,update_time ) values({code},'{name}',now())")
            cls.__mysqldb.execute(f"insert into code_name(code,code_name,update_time ) values('{code}','{name}',now())")

    @classmethod
    def add_first_code_name(cls, code, name):

 test/test.py

@@ -1,3 +1,4 @@
from code_attribute.gpcode_manager import CodesNameManager
from huaxin_client import l1_subscript_codes_manager
from third_data.history_k_data_util import JueJinHttpApi
from utils import tool
@@ -20,13 +21,6 @@


if __name__ == "__main__":
    print(25e8)
    # results = JueJinHttpApi.get_exchanges_codes("SHSE,SZSE", sec_types=[8], skip_suspended=True, skip_st=True,
    #                                             fields="symbol, sec_type, sec_id,sec_name, underlying_symbol, delisted_date")
    # fresults = []
    # for r in results:
    #     tool.get_now_date_str()
    #     if int(tool.get_now_date_str('%Y%m%d')) >= int(r['delisted_date'].strftime('%Y%m%d')):
    #         continue
    #     fresults.append(r)
    # print(len(fresults))
    CodesNameManager.add_code_name("000333", "美的集团")
    CodesNameManager.add_code_name("000333", "美的集团")
    print(CodesNameManager.list_code_name_dict())

 trade/huaxin/huaxin_trade_server.py

@@ -1067,10 +1067,20 @@
                logger_debug.exception(e)
                fdata["trade_channel_access"] = 0


            # 获取CPU与内存适用情况
            memory_info = psutil.virtual_memory()
            cpu_percent = psutil.cpu_percent(interval=1)
            fdata["device"] = {"cpu": cpu_percent, "memery": memory_info.percent}

            # 获取今日自由流通量的更新
            try:
                count = ZYLTGBUtil.count_today_updated_volume_codes()
                fdata["today_zylt_updated_count"] = count
            except Exception as e:
                logger_debug.exception(e)
                fdata["today_zylt_updated_count"] = -1

            # 获取交易通道
            result = {"code": 0, "data": fdata, "msg": ""}
            print("OnGetEnvInfo 成功")