diff --git a/threecolor-modbus-collector/src/main/java/com/xujie/modbus/mapper/ThreeColorLampDownlogMapper.java b/threecolor-modbus-collector/src/main/java/com/xujie/modbus/mapper/ThreeColorLampDownlogMapper.java
index 8e394a1..263a76d 100644
--- a/threecolor-modbus-collector/src/main/java/com/xujie/modbus/mapper/ThreeColorLampDownlogMapper.java
+++ b/threecolor-modbus-collector/src/main/java/com/xujie/modbus/mapper/ThreeColorLampDownlogMapper.java
@@ -28,6 +28,14 @@ public interface ThreeColorLampDownlogMapper extends BaseMapper<ThreeColorLampDo
                                @Param("orderNo") String orderNo,
                                @Param("runTime") int runTime);
 
-    ThreeColorLampDownlog selectThreeColorLampDownlogStartTime(String site, String resourceId, String seqNo);
+    /**
+     * 在 seq 维度的 downlog 中，若传入 lamp 窗口内最早采集时间，则只保留
+     * FORMAT(该时间,'yyyy-MM-dd HH:mm') &lt;= FORMAT(start_date,'yyyy-MM-dd HH:mm') 的记录，
+     * 并取 start_date 最早的一条；未传入时保持原逻辑（按 start_date 最晚一条）。
+     */
+    ThreeColorLampDownlog selectThreeColorLampDownlogStartTime(@Param("site") String site,
+                                                               @Param("resourceId") String resourceId,
+                                                               @Param("seqNo") String seqNo,
+                                                               @Param("lampEarliestCreateDate") Date lampEarliestCreateDate);
 
 }
diff --git a/threecolor-modbus-collector/src/main/java/com/xujie/modbus/service/impl/ModbusCollectServiceImpl.java b/threecolor-modbus-collector/src/main/java/com/xujie/modbus/service/impl/ModbusCollectServiceImpl.java
index d06eae8..46f08f2 100644
--- a/threecolor-modbus-collector/src/main/java/com/xujie/modbus/service/impl/ModbusCollectServiceImpl.java
+++ b/threecolor-modbus-collector/src/main/java/com/xujie/modbus/service/impl/ModbusCollectServiceImpl.java
@@ -84,6 +84,17 @@ public class ModbusCollectServiceImpl
         });
     }
 
+    /** colorLampLisByTime 中非空 createDate 的最早值，供 downlog 按分钟对齐筛选。 */
+    private static Date earliestLampCreateDate(List<ThreeColorLamp> lamps) {
+        if (lamps == null || lamps.isEmpty()) {
+            return null;
+        }
+        return lamps.stream()
+                .map(ThreeColorLamp::getCreateDate)
+                .filter(Objects::nonNull)
+                .min(Date::compareTo)
+                .orElse(null);
+    }
 
     @Override
     public void handleSignal(DeviceInfo deviceInfo) {
@@ -404,8 +415,8 @@ public class ModbusCollectServiceImpl
                                         Date currentTime = new Date();
                                         Date fiveMinutesAgo = new Date(currentTime.getTime() - failureTime * 60 * 1000);
                                         //sfdcTimeHist.setEventTime(fiveMinutesAgo);
-                                        ThreeColorLampDownlog sfdcTimeHistStartTime =threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(),resourceScheduled.getSeqNo()) ;
-                                        sfdcTimeHist.setEventTime(sfdcTimeHistStartTime.getStartDate() == null?fiveMinutesAgo:sfdcTimeHistStartTime.getStartDate());
+                                        ThreeColorLampDownlog sfdcTimeHistStartTime = threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(), resourceScheduled.getSeqNo(), earliestLampCreateDate(colorLampLisByTime));
+                                        sfdcTimeHist.setEventTime(sfdcTimeHistStartTime == null || sfdcTimeHistStartTime.getStartDate() == null ? fiveMinutesAgo : sfdcTimeHistStartTime.getStartDate());
                                         sfdcTimeHist.setEnteredBy(null);
                                         sfdcTimeHist.setEventDesc(null);
                                         sfdcTimeHist.setDowntimeCode(null);
@@ -461,8 +472,8 @@ public class ModbusCollectServiceImpl
                                             Date currentTime = new Date();
                                             Date fiveMinutesAgo = new Date(currentTime.getTime() - failureTime * 60 * 1000);
                                             //sfdcTimeHist.setEventTime(fiveMinutesAgo);
-                                            ThreeColorLampDownlog sfdcTimeHistStartTime =threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(),resourceScheduled.getSeqNo()) ;
-                                            sfdcTimeHist.setEventTime(sfdcTimeHistStartTime.getStartDate() == null?fiveMinutesAgo:sfdcTimeHistStartTime.getStartDate());
+                                            ThreeColorLampDownlog sfdcTimeHistStartTime = threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(), resourceScheduled.getSeqNo(), earliestLampCreateDate(colorLampLisByTime));
+                                            sfdcTimeHist.setEventTime(sfdcTimeHistStartTime == null || sfdcTimeHistStartTime.getStartDate() == null ? fiveMinutesAgo : sfdcTimeHistStartTime.getStartDate());
                                             sfdcTimeHist.setEnteredBy(null);
                                             sfdcTimeHist.setEventDesc(null);
                                             sfdcTimeHist.setDowntimeCode(null);
@@ -553,8 +564,8 @@ public class ModbusCollectServiceImpl
                                     Date currentTime = new Date();
                                     Date fiveMinutesAgo = new Date(currentTime.getTime() - failureTime * 60 * 1000);
                                     //sfdcTimeHist.setEventTime(fiveMinutesAgo);
-                                    ThreeColorLampDownlog sfdcTimeHistStartTime =threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(),resourceScheduled.getSeqNo()) ;
-                                    sfdcTimeHist.setEventTime(sfdcTimeHistStartTime.getStartDate() == null?fiveMinutesAgo:sfdcTimeHistStartTime.getStartDate());
+                                    ThreeColorLampDownlog sfdcTimeHistStartTime = threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(), resourceScheduled.getSeqNo(), earliestLampCreateDate(colorLampLisByTime));
+                                    sfdcTimeHist.setEventTime(sfdcTimeHistStartTime == null || sfdcTimeHistStartTime.getStartDate() == null ? fiveMinutesAgo : sfdcTimeHistStartTime.getStartDate());
                                     sfdcTimeHist.setEnteredBy(null);
                                     sfdcTimeHist.setEventDesc(null);
                                     sfdcTimeHist.setDowntimeCode(null);
@@ -610,8 +621,8 @@ public class ModbusCollectServiceImpl
                                         Date currentTime = new Date();
                                         Date fiveMinutesAgo = new Date(currentTime.getTime() - failureTime * 60 * 1000);
                                         //sfdcTimeHist.setEventTime(fiveMinutesAgo);
-                                        ThreeColorLampDownlog sfdcTimeHistStartTime =threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(),resourceScheduled.getSeqNo()) ;
-                                        sfdcTimeHist.setEventTime(sfdcTimeHistStartTime.getStartDate() == null?fiveMinutesAgo:sfdcTimeHistStartTime.getStartDate());
+                                        ThreeColorLampDownlog sfdcTimeHistStartTime = threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(), resourceScheduled.getSeqNo(), earliestLampCreateDate(colorLampLisByTime));
+                                        sfdcTimeHist.setEventTime(sfdcTimeHistStartTime == null || sfdcTimeHistStartTime.getStartDate() == null ? fiveMinutesAgo : sfdcTimeHistStartTime.getStartDate());
                                         sfdcTimeHist.setEnteredBy(null);
                                         sfdcTimeHist.setEventDesc(null);
                                         sfdcTimeHist.setDowntimeCode(null);
@@ -702,8 +713,8 @@ public class ModbusCollectServiceImpl
                                     Date currentTime = new Date();
                                     Date fiveMinutesAgo = new Date(currentTime.getTime() - failureTime * 60 * 1000);
                                     //sfdcTimeHist.setEventTime(fiveMinutesAgo);
-                                    ThreeColorLampDownlog sfdcTimeHistStartTime =threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(),resourceScheduled.getSeqNo()) ;
-                                    sfdcTimeHist.setEventTime(sfdcTimeHistStartTime.getStartDate() == null?fiveMinutesAgo:sfdcTimeHistStartTime.getStartDate());
+                                    ThreeColorLampDownlog sfdcTimeHistStartTime = threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(), resourceScheduled.getSeqNo(), earliestLampCreateDate(colorLampLisByTime));
+                                    sfdcTimeHist.setEventTime(sfdcTimeHistStartTime == null || sfdcTimeHistStartTime.getStartDate() == null ? fiveMinutesAgo : sfdcTimeHistStartTime.getStartDate());
                                     sfdcTimeHist.setEnteredBy(null);
                                     sfdcTimeHist.setEventDesc(null);
                                     sfdcTimeHist.setDowntimeCode(null);
@@ -759,8 +770,8 @@ public class ModbusCollectServiceImpl
                                         Date currentTime = new Date();
                                         Date fiveMinutesAgo = new Date(currentTime.getTime() - failureTime * 60 * 1000);
                                         // sfdcTimeHist.setEventTime(fiveMinutesAgo);
-                                        ThreeColorLampDownlog sfdcTimeHistStartTime =threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(),resourceScheduled.getSeqNo()) ;
-                                        sfdcTimeHist.setEventTime(sfdcTimeHistStartTime.getStartDate() == null?fiveMinutesAgo:sfdcTimeHistStartTime.getStartDate());
+                                        ThreeColorLampDownlog sfdcTimeHistStartTime = threeColorLampDownlogMapper.selectThreeColorLampDownlogStartTime(folderLocation.getSite(), folderLocation.getResourceId(), resourceScheduled.getSeqNo(), earliestLampCreateDate(colorLampLisByTime));
+                                        sfdcTimeHist.setEventTime(sfdcTimeHistStartTime == null || sfdcTimeHistStartTime.getStartDate() == null ? fiveMinutesAgo : sfdcTimeHistStartTime.getStartDate());
                                         sfdcTimeHist.setEnteredBy(null);
                                         sfdcTimeHist.setEventDesc(null);
                                         sfdcTimeHist.setDowntimeCode(null);
diff --git a/threecolor-modbus-collector/src/main/resources/dao/ThreeColorLampDownlogMapper.xml b/threecolor-modbus-collector/src/main/resources/dao/ThreeColorLampDownlogMapper.xml
index 65c2db3..3aa9a18 100644
--- a/threecolor-modbus-collector/src/main/resources/dao/ThreeColorLampDownlogMapper.xml
+++ b/threecolor-modbus-collector/src/main/resources/dao/ThreeColorLampDownlogMapper.xml
@@ -63,7 +63,16 @@
         WHERE
         site = #{site} and resource_id = #{resourceId} and seq_no = #{seqNo}
         and start_date is not null
-        and end_date is null
-        ORDER BY start_date DESC
+        <if test="lampEarliestCreateDate != null">
+            AND FORMAT(#{lampEarliestCreateDate}, 'yyyy-MM-dd HH:mm') &lt;= FORMAT(start_date, 'yyyy-MM-dd HH:mm')
+        </if>
+        <choose>
+            <when test="lampEarliestCreateDate != null">
+                ORDER BY start_date ASC
+            </when>
+            <otherwise>
+                ORDER BY start_date DESC
+            </otherwise>
+        </choose>
     </select>
 </mapper>
\ No newline at end of file