diff --git a/src/main/java/cn/lihongjie/coal/pdcDeviceRealTimeData/repository/PdcDeviceRealTimeDataRepository.java b/src/main/java/cn/lihongjie/coal/pdcDeviceRealTimeData/repository/PdcDeviceRealTimeDataRepository.java
index 65d31f1d..cbe67044 100644
--- a/src/main/java/cn/lihongjie/coal/pdcDeviceRealTimeData/repository/PdcDeviceRealTimeDataRepository.java
+++ b/src/main/java/cn/lihongjie/coal/pdcDeviceRealTimeData/repository/PdcDeviceRealTimeDataRepository.java
@@ -15,7 +15,7 @@ public interface PdcDeviceRealTimeDataRepository
 
     @Query(
             value =
-                    "select dd.id from t_pdc_device_real_time_data dd inner join t_pdc_device d on dd.device_id = d.id where d.id in :deviceIds  and (extract(epoch from (now() - dd.last_save_time)) / 60) >= d.data_save_interval ",
+                    "select dd.id from t_pdc_device_real_time_data dd inner join t_pdc_device d on dd.device_id = d.id where d.id in :deviceIds  and (extract(epoch from (now() - dd.last_save_time)) / 60) >= d.data_save_interval and (extract(epoch from (now() - dd.time)) / 60) <= 3 * d.data_save_interval",
             nativeQuery = true)
     List<String> findNeedToSaveData(List<String> deviceIds);