diff --git a/app/core/launcher.py b/app/core/launcher.py index 45a7e1a..e979cca 100644 --- a/app/core/launcher.py +++ b/app/core/launcher.py @@ -56,7 +56,7 @@ def start(): # 启动降雨站点监测 logger.info("启动降雨站点监测服务...") - rainfall_manager.monitoring_rainfall_station_id('2025-08-20 12:00:00') + rainfall_manager.monitoring_rainfall_station_id('2025-09-16 20:00:00') # 阻塞主线程,防止程序立即退出 block_main_thread() diff --git a/app/services/rainfall_grid_service.py b/app/services/rainfall_grid_service.py index 4d7a454..13c4f97 100644 --- a/app/services/rainfall_grid_service.py +++ b/app/services/rainfall_grid_service.py @@ -386,6 +386,7 @@ class RainfallGridService: """ try: redis_key = settings.REDIS_RAIN_STATION_GRID_KEY + redis_identifier_key = settings.REDIS_RAIN_STATION_IDENTIFIER_KEY # 处理query_time,可能是datetime对象或字符串 if isinstance(query_time, datetime): @@ -416,6 +417,7 @@ class RainfallGridService: # 存储到Redis redis_helper.set(redis_key, json.dumps(grid_info)) + redis_helper.set(redis_identifier_key, max_id) self.logger.info(f"栅格信息已存储到Redis,key: {redis_key}, id: {max_id}") diff --git a/settings.toml b/settings.toml index f1d8fef..d6e9ac1 100644 --- a/settings.toml +++ b/settings.toml @@ -6,6 +6,8 @@ LOG_DIR = "logs" RAIN_STATION_GRID_DIR = "/xian/rainfall/grid/images/:id" # 雨量站栅格存储redis的key REDIS_RAIN_STATION_GRID_KEY = "xian:rainfall:rain_station_grid" +# 雨量站存储标识符的redis的key +REDIS_RAIN_STATION_IDENTIFIER_KEY = "xian:rainfall:rain_station_identifier" # 开发环境 [development]