#113 | Add an offset of 1millisec instead of 1sec

avniproject · Jan 8, 2024 · 47a2910 · 47a2910
1 parent b655a9c
commit 47a2910
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/amrit/src/main/java/org/avni_integration_service/amrit/worker/ErrorRecordWorker.java b/amrit/src/main/java/org/avni_integration_service/amrit/worker/ErrorRecordWorker.java
@@ -6,15 +6,15 @@
 import java.util.Date;
 
 public interface ErrorRecordWorker {
-    long SECONDS_TO_ADD = 1l;
+    long MILLI_SECONDS_TO_ADD = 1l;
 
     /**
      * Add an offset to avoid syncing the last Avni encounter to Goonj
      * @param status
      * @return EffectiveCutoffDateTime
      */
     default Date getEffectiveCutoffDateTime(IntegratingEntityStatus status) {
-        return new Date(status.getReadUptoDateTime().toInstant().plusSeconds(ErrorRecordWorker.SECONDS_TO_ADD)
+        return new Date(status.getReadUptoDateTime().toInstant().plusMillis(ErrorRecordWorker.MILLI_SECONDS_TO_ADD)
                 .toEpochMilli());
     }
 

diff --git a/.../src/main/java/org/avni_integration_service/goonj/worker/avni/GeneralEncounterWorker.java b/.../src/main/java/org/avni_integration_service/goonj/worker/avni/GeneralEncounterWorker.java
@@ -25,7 +25,7 @@
 import java.util.HashMap;
 
 public abstract class GeneralEncounterWorker implements ErrorRecordWorker {
-    public static final int SECONDS_TO_ADD = 1;
+    public static final int MILLI_SECONDS_TO_ADD = 1;
     private static final int INT_CONSTANT_ONE = 1;
     private final AvniEncounterRepository avniEncounterRepository;
     private final AvniSubjectRepository avniSubjectRepository;
@@ -85,7 +85,7 @@ public void processEncounters() throws Exception {
      * @return EffectiveCutoffDateTime
      */
     private Date getEffectiveCutoffDateTime(IntegratingEntityStatus status) {
-        return new Date(status.getReadUptoDateTime().toInstant().plusSeconds(SECONDS_TO_ADD)
+        return new Date(status.getReadUptoDateTime().toInstant().plusMillis(MILLI_SECONDS_TO_ADD)
                 .toEpochMilli());
     }
 

diff --git a/goonj/src/main/java/org/avni_integration_service/goonj/worker/avni/SubjectWorker.java b/goonj/src/main/java/org/avni_integration_service/goonj/worker/avni/SubjectWorker.java
@@ -22,7 +22,7 @@
 import java.util.HashMap;
 
 public abstract class SubjectWorker implements ErrorRecordWorker {
-    public static final int SECONDS_TO_ADD = 1;
+    public static final int MILLI_SECONDS_TO_ADD = 1;
     private static final int INT_CONSTANT_ONE = 1;
     private final AvniSubjectRepository avniSubjectRepository;
     private final AvniIgnoredConceptsRepository avniIgnoredConceptsRepository;
@@ -81,7 +81,7 @@ public void processSubjects() throws Exception {
      * @return EffectiveCutoffDateTime
      */
     private Date getEffectiveCutoffDateTime(IntegratingEntityStatus status) {
-        return new Date(status.getReadUptoDateTime().toInstant().plusSeconds(SECONDS_TO_ADD)
+        return new Date(status.getReadUptoDateTime().toInstant().plusMillis(MILLI_SECONDS_TO_ADD)
                 .toEpochMilli());
     }