‘功能完善

Administrator

5 天以前 c05044c53a5d0213ef33b2b3bdbb57a328300ad2

‘功能完善

 api/outside_api_callback.py

@@ -3,10 +3,12 @@
import os
import threading

import constant

from api.outside_api_command_manager import ActionCallback
from huaxin_client import l1_subscript_codes_manager
from huaxin_client.client_network import SendResponseSkManager
from strategy import strategy_params_settings, env_info
from strategy import strategy_params_settings, env_info, strategy_manager
from strategy.env_info import RealTimeEnvInfo
from strategy.strategy_variable_factory import DataLoader
from third_data.history_k_data_manager import TradeDateManager
@@ -116,7 +118,7 @@
        else:
            # 如果在16:00之后采用下一个交易日
            day = TradeDateManager().get_next_trade_day(tool.get_now_date_str())
        __DataLoader = DataLoader(day)
        __DataLoader = DataLoader(self.now_day)
        threading.Thread(target=lambda: update(), daemon=True).start()
        return {"code": 0}

@@ -137,6 +139,13 @@
        threading.Thread(target=lambda: update(), daemon=True).start()
        return {"code": 0}

    def __on_init_data(self):
        try:
            strategy_manager.low_suction_strtegy.load_data()
            return {"code": 0}
        except Exception as e:
            return {"code": 1, "msg": str(e)}

    def OnCommonRequest(self, client_id, request_id, data):
        ctype = data["ctype"]
        result_json = {}
@@ -154,4 +163,7 @@
        elif ctype == 'update_kpl_code_jx_blocks_datas':
            # 更新开盘啦精选数据
            result_json = self.__on_update_kpl_code_jx_blocks_datas()
        elif ctype == 'init_datas':
            # 初始化数据
            result_json = self.__on_init_data()
        self.send_response(result_json, client_id, request_id)

 main.py

@@ -106,7 +106,6 @@

    # ----初始化------------
    __init()

    # 初始化数据
    strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str())
    logger_system.info("初始化策略对象成功")
@@ -115,4 +114,4 @@

    # -------启动L2 market订阅------
    __run_l2_market_subscript()
    print("启动完成")
    logger_system.info("系统结束")

 strategy/strategy_manager.py

@@ -151,7 +151,7 @@
            self.scripts = scripts
        self.settings = settings

        self.data_loader = DataLoader(self.now_day, cache_path=f"{constant.get_path_prefix()}/datas")
        self.data_loader = DataLoader(self.now_day)
        self.__LowSuctionOriginDataExportManager = LowSuctionOriginDataExportManager(self.now_day)
        if need_load_data:
            self.load_data()

 strategy/strategy_variable_factory.py

@@ -22,7 +22,7 @@
    数据加载器类，用于集中管理策略变量所需的各类数据加载逻辑
    """

    def __init__(self, now_day, cache_path="D:/datas"):
    def __init__(self, now_day, cache_path=f"{constant.get_path_prefix()}/datas"):
        """
        初始化数据加载器
        :param now_day: 当前日期，格式为"2025-01-01"
@@ -658,13 +658,10 @@
    plates = ["天然气", "军工"]
    print("==========新题材=======")
    for p in plates:
        codes = [x for x in results.get(p) ] # if get_zylt(x) < 31e8
        codes = [x for x in results.get(p)]  # if get_zylt(x) < 31e8
        print("======", p)
        for code in codes:
            print("\t\t", code, gpcode_manager.CodesNameManager().get_code_name(code))





if __name__ == "__main__":