This changes the initialization for the data health for new participants so that also occurrencies of already started but still ongoing observations are created

Author: Rupert Westenthaler

studymanager-services/src/main/java/io/redlink/more/studymanager/scheduling/UpsertOccurredObservationsCron.java

@@ -62,16 +62,17 @@ private void upsertOccurredObservations(Study study) {
             }
             ctx.putStudy(study);
             List<Participant> participants = participantService.listParticipants(study.getStudyId());
-            Instant lastOccurredObservation = occurredObservationService.getLatestStartTime(study.getStudyId());
             //NOTE: use now + 1min for current because:
             //  1. we truncatedTo(ChronoUnit.MINUTES) all Instants and
             //  2. we check with start.isBefore(current)
             // doing so will include all Observations that start in the current minute
             Instant current = Instant.now().plus(1, ChronoUnit.MINUTES).truncatedTo(ChronoUnit.MINUTES);
-            LOGGER.debug("Upsert Occurred Observations for Study(id: {}) and timeperiode(start:{}, end:{})", study.getStudyId(), lastOccurredObservation, current);
+            LOGGER.debug("Upsert Occurred Observations for Study(id: {}) ", study.getStudyId());
             participants.stream()
                 .filter(participant -> participant.getStatus() == Participant.Status.ACTIVE)
                 .forEach(participant -> {
+                    Instant lastOccurredObservation = occurredObservationService.getLatestStartTime(study.getStudyId(), participant.getParticipantId());
+                    LOGGER.debug("Upsert Occurred Observations for Study(id: {}) Participant(id: {}) and timeperiode(start:{}, end:{})", study.getStudyId(), participant.getParticipantId(), lastOccurredObservation, current);
                     ctx.putParticipant(participant);
                     //NOTE: from, to are currently not supported
                     var timeline = calendarService.getTimeline(study, participant, null, null, null, null, null);

studymanager-services/src/main/java/io/redlink/more/studymanager/service/OccurredObservationService.java

@@ -40,10 +40,11 @@ public OccurredObservation update(OccurredObservation occurredObservation) {
     /**
      * The latest start time of any {@link OccurredObservation} for the parst studyId
      * @param studyId the study id
+     * @param participantId the participantId
      * @return the latest start time or <code>null</code> if no {@link OccurredObservation} is present for the study
      */
-    public Instant getLatestStartTime(long studyId) {
-        return repository.getLatestStartTime(studyId, null, null, null, null);
+    public Instant getLatestStartTime(long studyId, int participantId) {
+        return repository.getLatestStartTime(studyId, participantId, null, null, null);
     }
 
     /**