api/outside_api_command_callback.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
third_data/history_k_data_util.py | ●●●●● 补丁 | 查看 | 原始文档 | 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]