Administrator
2024-12-31 76010afecab7ec83f480bca21cacf619b0279b5b
取消测试
2个文件已修改
14 ■■■■■ 已修改文件
api/outside_api_command_callback.py 4 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
third_data/history_k_data_util.py 10 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
api/outside_api_command_callback.py
@@ -545,12 +545,14 @@
            # 获取今日K线的更新数量
            try:
                dates = HistoryKDatasUtils.get_latest_trading_date_cache(5)
                logger_debug.info(f"获取到的交易日:{dates}")
                latest_trading_date = None
                if dates:
                    latest_trading_date = dates[0]
                if latest_trading_date is None:
                    raise Exception("没有获取到上一个交易日的日期")
                # 4点之后改为获取今日的数据
                if tool.get_now_time_as_int()>160000:
                    latest_trading_date = tool.get_now_date_str()
                codes = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
                count = len(codes)
                logger_debug.info(f"K线代码数量:{count}")
third_data/history_k_data_util.py
@@ -261,6 +261,11 @@
    # 获取最近的交易日
    @classmethod
    def get_latest_trading_date(cls, day_count):
        """
       获取最近几个交易日(不包含今天)
        @param day_count:
        @return:
        """
        now_day = tool.get_now_date_str()
        days = []
        for i in range(day_count):
@@ -271,6 +276,11 @@
    @classmethod
    def get_latest_trading_date_cache(cls, day_count):
        """
        获取最近几个交易日(不包含今天)
        @param day_count:
        @return:
        """
        key = f"{tool.get_now_date_str()}-{day_count}"
        if key in cls.__latest_trading_date_cache:
            return cls.__latest_trading_date_cache[key]