TRAX course replication

Author: arcshiftsolutions

api/src/main/java/ca/bc/gov/educ/api/pen/replication/choreographer/ChoreographEventHandler.java

@@ -92,6 +92,12 @@ public void handleEvent(@NonNull final Event event) {
                 final EventService<GraduationStudentRecord> gradStudentCitzService = (EventService<GraduationStudentRecord>) this.eventServiceMap.get(UPDATE_GRAD_STUDENT_CITIZENSHIP.toString());
                 gradStudentCitzService.processEvent(gradStudentRecordForCitz, event);
                 break;
+              case "UPDATE_SCHOOL_OF_RECORD":
+                log.info("Processing UPDATE_SCHOOL_OF_RECORD event record :: {} ", event);
+                val schoolOfRecordUpdate = JsonUtil.getJsonObjectFromString(StudentSchoolOfRecordUpdate.class, event.getEventPayload());
+                final EventService<StudentSchoolOfRecordUpdate> schoolOfRecordUpdateEventService = (EventService<StudentSchoolOfRecordUpdate>) this.eventServiceMap.get(UPDATE_SCHOOL_OF_RECORD.toString());
+                schoolOfRecordUpdateEventService.processEvent(schoolOfRecordUpdate, event);
+                break;
               case "ADD_POSSIBLE_MATCH":
                 final List<PossibleMatch> possibleMatchList = JsonUtil.objectMapper.readValue(event.getEventPayload(), new TypeReference<>() {
                 });

api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/SchoolOfRecordUpdateService.java

@@ -0,0 +1,69 @@
+package ca.bc.gov.educ.api.pen.replication.service;
+
+import ca.bc.gov.educ.api.pen.replication.model.Event;
+import ca.bc.gov.educ.api.pen.replication.repository.EventRepository;
+import ca.bc.gov.educ.api.pen.replication.rest.RestUtils;
+import ca.bc.gov.educ.api.pen.replication.struct.GraduationStudentRecord;
+import ca.bc.gov.educ.api.pen.replication.struct.StudentSchoolOfRecordUpdate;
+import jakarta.persistence.EntityManager;
+import jakarta.persistence.EntityManagerFactory;
+import lombok.extern.slf4j.Slf4j;
+import lombok.val;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import static ca.bc.gov.educ.api.pen.replication.constants.EventType.UPDATE_GRAD_STUDENT_CITIZENSHIP;
+import static ca.bc.gov.educ.api.pen.replication.constants.EventType.UPDATE_SCHOOL_OF_RECORD;
+
+@Service
+@Slf4j
+public class SchoolOfRecordUpdateService extends BaseService<StudentSchoolOfRecordUpdate> {
+
+  private final TraxStudentService traxStudentService;
+  /**
+   * The Rest utils.
+   */
+  private final RestUtils restUtils;
+
+  public SchoolOfRecordUpdateService(final EntityManagerFactory emf, final EventRepository eventRepository, TraxStudentService traxStudentService, final RestUtils restUtils) {
+    super(eventRepository, emf);
+    this.traxStudentService = traxStudentService;
+    this.restUtils = restUtils;
+  }
+
+  /**
+   * Process event.
+   *
+   * @param event the event
+   */
+  @Override
+  public void processEvent(final StudentSchoolOfRecordUpdate schoolOfRecordUpdate, final Event event) {
+    var studentPEN = restUtils.getStudentPen(schoolOfRecordUpdate.getStudentID());
+    val existingTraxStudentRecord = this.traxStudentService.findTraxStudentByPen(StringUtils.rightPad(studentPEN, 10));
+    if (existingTraxStudentRecord.isPresent()) {
+      val existingTraxStudent = existingTraxStudentRecord.get();
+      var school = restUtils.getSchoolBySchoolID(schoolOfRecordUpdate.getSchoolOfRecordID());
+      existingTraxStudent.setMincode(school.get().getMincode());
+      
+      log.info("Processing choreography update event with ID {} :: payload is: {}", event.getEventId(), existingTraxStudent);
+      this.traxStudentService.saveTraxStudent(existingTraxStudent);
+    }
+    this.updateEvent(event);
+  }
+
+
+  /**
+   * Gets event type.
+   *
+   * @return the event type
+   */
+  @Override
+  public String getEventType() {
+    return UPDATE_SCHOOL_OF_RECORD.toString();
+  }
+
+  @Override
+  protected void buildAndExecutePreparedStatements(final EntityManager em, final StudentSchoolOfRecordUpdate schoolOfRecordUpdate) {
+    // Not required this child class use repository pattern of spring.
+  }
+}

api/src/main/java/ca/bc/gov/educ/api/pen/replication/struct/StudentSchoolOfRecordUpdate.java

@@ -0,0 +1,27 @@
+package ca.bc.gov.educ.api.pen.replication.struct;
+
+import ca.bc.gov.educ.api.gradstudent.model.dto.BaseModel;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.ToString;
+import lombok.experimental.SuperBuilder;
+
+import java.io.Serializable;
+
+@Data
+@SuperBuilder
+@NoArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@JsonIgnoreProperties(ignoreUnknown = true)
+@ToString(callSuper = true)
+public class StudentSchoolOfRecordUpdate extends BaseRequest implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String studentID;
+
+    private String schoolOfRecordID;
+
+}