diff --git a/jeecg-module-weather/src/main/java/org/jeecg/service/impl/WeatherDataServiceImpl.java b/jeecg-module-weather/src/main/java/org/jeecg/service/impl/WeatherDataServiceImpl.java
index 8967656..6aaf7bc 100644
--- a/jeecg-module-weather/src/main/java/org/jeecg/service/impl/WeatherDataServiceImpl.java
+++ b/jeecg-module-weather/src/main/java/org/jeecg/service/impl/WeatherDataServiceImpl.java
@@ -787,6 +787,8 @@ public class WeatherDataServiceImpl extends ServiceImpl<WeatherDataMapper, Weath
 
         if (WeatherDataSourceEnum.PANGU.equals(dataTypeEnum)) {
             storagePath.append(systemStorageProperties.getPangu())
+                    .append(File.separator)
+                    .append(targetTime.getYear())
                     .append(File.separator)
                     .append(WeatherPrefixConstants.PANGU_PREFIX)
                     .append(targetTime.format(DateTimeFormatter.ofPattern("yyyyMMddHH")))
@@ -794,6 +796,8 @@ public class WeatherDataServiceImpl extends ServiceImpl<WeatherDataMapper, Weath
                     .append(WeatherFileSuffixEnum.GRIB.getValue());
         } else if (WeatherDataSourceEnum.CRA40.equals(dataTypeEnum)) {
             storagePath.append(systemStorageProperties.getCra40())
+                    .append(File.separator)
+                    .append(targetTime.getYear())
                     .append(File.separator)
                     .append(WeatherPrefixConstants.CRA40_PREFIX)
                     .append(Cra40FilePrefixEnum.getValueByKey(weatherType))
@@ -804,6 +808,8 @@ public class WeatherDataServiceImpl extends ServiceImpl<WeatherDataMapper, Weath
                     .append(WeatherFileSuffixEnum.GRIB2.getValue());
         } else if (WeatherDataSourceEnum.NCEP.equals(dataTypeEnum)) {
             storagePath.append(systemStorageProperties.getNcep())
+                    .append(File.separator)
+                    .append(targetTime.getYear())
                     .append(File.separator)
                     .append(targetTime.format(DateTimeFormatter.ofPattern("yyyyMMddHHmm")))
                     .append(".")