refactor(UtmDataInputStatusService): improve handling of last processed timestamp

Author: mjabascal10

backend/src/main/java/com/park/utmstack/service/UtmDataInputStatusService.java

@@ -485,14 +485,14 @@ private Map<String, StatisticDocument> getLatestStatisticsByDataSource() {
             }
         });
 
-        Instant lastTimestamp = result.values().stream()
+        Optional<Instant> maybeLastTimestamp = result.values().stream()
                 .map(doc -> Instant.parse(doc.getTimestamp()))
-                .max(Instant::compareTo)
-                .orElse(Instant.now());
+                .max(Instant::compareTo);
 
-        checkpoint.setLastProcessedTimestamp(lastTimestamp);
-
-        this.checkpointRepository.save(checkpoint);
+        if (maybeLastTimestamp.isPresent()) {
+            checkpoint.setLastProcessedTimestamp(maybeLastTimestamp.get());
+            this.checkpointRepository.save(checkpoint);
+        }
 
         return result;
     }

backend/src/main/resources/config/liquibase/changelog/20260210009_update_data_input_status_checkpoint.xml

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="utf-8"?>
+<databaseChangeLog
+        xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.5.xsd">
+
+    <changeSet id="20260210009" author="Manuel">
+
+        <sql dbms="postgresql" splitStatements="true" stripComments="true">
+            <![CDATA[
+
+            UPDATE utm_data_input_status_checkpoint
+            SET last_processed_timestamp = NOW() - INTERVAL '12 hours'
+            WHERE id = 1;
+
+            ]]>
+        </sql>
+
+    </changeSet>
+</databaseChangeLog>

backend/src/main/resources/config/liquibase/master.xml

@@ -403,6 +403,8 @@
 
     <include file="/config/liquibase/changelog/20260210008_update_filter_windows_events.xml" relativeToChangelogFile="false"/>
 
+    <include file="/config/liquibase/changelog/20260210009_update_data_input_status_checkpoint.xml" relativeToChangelogFile="false"/>
+
 
 
 </databaseChangeLog>