reprocess

Author: alexmcdermid

api/src/main/java/ca/bc/gov/educ/studentdatacollection/api/controller/v1/SdcSchoolCollectionController.java

@@ -7,6 +7,7 @@
 import ca.bc.gov.educ.studentdatacollection.api.model.v1.SdcSchoolCollectionEntity;
 import ca.bc.gov.educ.studentdatacollection.api.service.v1.SdcSchoolCollectionSearchService;
 import ca.bc.gov.educ.studentdatacollection.api.service.v1.SdcSchoolCollectionService;
+import ca.bc.gov.educ.studentdatacollection.api.struct.ReprocessSdcSchoolCollection;
 import ca.bc.gov.educ.studentdatacollection.api.struct.v1.*;
 import ca.bc.gov.educ.studentdatacollection.api.util.JsonUtil;
 import ca.bc.gov.educ.studentdatacollection.api.util.RequestUtil;
@@ -97,6 +98,11 @@ public SdcSchoolCollection unsubmitSchoolCollection(UnsubmitSdcSchoolCollection
     return mapper.toStructure(sdcSchoolCollectionService.unsubmitSchoolCollection(unsubmitData));
   }
 
+  @Override
+  public SdcSchoolCollection reprocessSchoolCollection(ReprocessSdcSchoolCollection reprocessData) {
+    return mapper.toStructure(sdcSchoolCollectionService.reprocessSchoolCollection(reprocessData));
+  }
+
   @Override
   public SdcSchoolCollection reportZeroEnrollment(ReportZeroEnrollmentSdcSchoolCollection reportZeroEnrollmentData) {
     return mapper.toStructure(sdcSchoolCollectionService.reportZeroEnrollment(reportZeroEnrollmentData));

api/src/main/java/ca/bc/gov/educ/studentdatacollection/api/endpoint/v1/SdcSchoolCollectionEndpoint.java

@@ -1,6 +1,7 @@
 package ca.bc.gov.educ.studentdatacollection.api.endpoint.v1;
 
 import ca.bc.gov.educ.studentdatacollection.api.constants.v1.URL;
+import ca.bc.gov.educ.studentdatacollection.api.struct.ReprocessSdcSchoolCollection;
 import ca.bc.gov.educ.studentdatacollection.api.struct.v1.*;
 import io.swagger.v3.oas.annotations.media.Schema;
 import io.swagger.v3.oas.annotations.responses.ApiResponse;
@@ -81,6 +82,14 @@ List<SdcSchoolCollection> getAllSchoolCollections(@RequestParam(name = "schoolID
   @Schema(name = "SdcSchoolCollection", implementation = SdcSchoolCollection.class)
   SdcSchoolCollection unsubmitSchoolCollection(@RequestBody UnsubmitSdcSchoolCollection unsubmitData);
 
+  @PostMapping("/reprocess")
+  @PreAuthorize("hasAuthority('SCOPE_WRITE_SDC_DISTRICT_COLLECTION')")
+  @ApiResponses(value = {@ApiResponse(responseCode = "200", description = "OK"), @ApiResponse(responseCode = "400", description = "BAD REQUEST"), @ApiResponse(responseCode = "404", description = "NOT FOUND")})
+  @Transactional
+  @Tag(name = "Sdc School Collection", description = "Endpoints to reprocess school collection entity.")
+  @Schema(name = "SdcSchoolCollection", implementation = SdcSchoolCollection.class)
+  SdcSchoolCollection reprocessSchoolCollection(@RequestBody ReprocessSdcSchoolCollection reprocessData);
+
   @PostMapping("/reportZeroEnrollment")
   @PreAuthorize("hasAuthority('SCOPE_WRITE_SDC_SCHOOL_COLLECTION')")
   @ApiResponses(value = {@ApiResponse(responseCode = "200", description = "OK"), @ApiResponse(responseCode = "400", description = "BAD REQUEST"), @ApiResponse(responseCode = "404", description = "NOT FOUND")})

api/src/main/java/ca/bc/gov/educ/studentdatacollection/api/service/v1/SdcSchoolCollectionService.java

@@ -10,6 +10,7 @@
 import ca.bc.gov.educ.studentdatacollection.api.exception.errors.ApiError;
 import ca.bc.gov.educ.studentdatacollection.api.model.v1.*;
 import ca.bc.gov.educ.studentdatacollection.api.repository.v1.*;
+import ca.bc.gov.educ.studentdatacollection.api.struct.ReprocessSdcSchoolCollection;
 import ca.bc.gov.educ.studentdatacollection.api.struct.v1.ReportZeroEnrollmentSdcSchoolCollection;
 import ca.bc.gov.educ.studentdatacollection.api.struct.v1.SdcFileSummary;
 import ca.bc.gov.educ.studentdatacollection.api.struct.v1.UnsubmitSdcSchoolCollection;
@@ -237,6 +238,39 @@ public SdcSchoolCollectionEntity unsubmitSchoolCollection(UnsubmitSdcSchoolColle
     return sdcSchoolCollectionEntity;
   }
 
+  @Transactional(propagation = Propagation.REQUIRES_NEW)
+  public SdcSchoolCollectionEntity reprocessSchoolCollection(ReprocessSdcSchoolCollection reprocessData) {
+    Optional<SdcSchoolCollectionEntity> sdcSchoolCollectionOptional = sdcSchoolCollectionRepository.findById(reprocessData.getSdcSchoolCollectionID());
+    SdcSchoolCollectionEntity sdcSchoolCollectionEntity = sdcSchoolCollectionOptional.orElseThrow(() -> new EntityNotFoundException(SdcSchoolCollectionEntity.class, SDC_SCHOOL_COLLECTION_ID_KEY, reprocessData.getSdcSchoolCollectionID().toString()));
+
+    if(StringUtils.equals(sdcSchoolCollectionEntity.getSdcSchoolCollectionStatusCode(), SdcSchoolCollectionStatus.P_DUP_POST.getCode())
+      || StringUtils.equals(sdcSchoolCollectionEntity.getSdcSchoolCollectionStatusCode(), SdcSchoolCollectionStatus.P_DUP_VRFD.getCode())) {
+      ApiError error = ApiError.builder().timestamp(LocalDateTime.now()).message(INVALID_PAYLOAD_MSG).status(BAD_REQUEST).build();
+      var validationError = ValidationUtil.createFieldError(SDC_SCHOOL_COLLECTION_ID_KEY, reprocessData.getSdcSchoolCollectionID(), "Cannot reprocess SDC School Collection that is in or beyond provincial duplicates.");
+      List<FieldError> fieldErrorList = new ArrayList<>();
+      fieldErrorList.add(validationError);
+      error.addValidationErrors(fieldErrorList);
+      throw new InvalidPayloadException(error);
+    }
+
+    sdcSchoolCollectionEntity.getSDCSchoolStudentEntities().forEach(sdcSchoolCollectionStudentEntity -> {
+      if (!StringUtils.equals(sdcSchoolCollectionStudentEntity.getSdcSchoolCollectionStudentStatusCode(), SdcSchoolStudentStatus.DELETED.getCode())) {
+        TransformUtil.clearCalculatedFields(sdcSchoolCollectionStudentEntity, true);
+        sdcSchoolCollectionStudentEntity.setSdcSchoolCollectionStudentStatusCode(SdcSchoolStudentStatus.LOADED.getCode());
+        sdcSchoolCollectionStudentEntity.setUpdateDate(LocalDateTime.now());
+        sdcSchoolCollectionStudentEntity.setUpdateUser(reprocessData.getUpdateUser());
+      }
+    });
+
+    sdcSchoolCollectionStudentStorageService.saveAllSDCStudentsWithHistory(sdcSchoolCollectionEntity.getSDCSchoolStudentEntities().stream().toList());
+
+    sdcSchoolCollectionEntity.setUpdateDate(LocalDateTime.now());
+    sdcSchoolCollectionEntity.setUpdateUser(reprocessData.getUpdateUser());
+    saveSdcSchoolCollectionWithHistory(sdcSchoolCollectionEntity);
+
+    return sdcSchoolCollectionEntity;
+  }
+
   @Transactional(propagation = Propagation.REQUIRES_NEW)
   public SdcSchoolCollectionEntity reportZeroEnrollment(ReportZeroEnrollmentSdcSchoolCollection reportZeroEnrollmentData) {
     Optional<SdcSchoolCollectionEntity> sdcSchoolCollectionOptional = sdcSchoolCollectionRepository.findById(reportZeroEnrollmentData.getSdcSchoolCollectionID());

api/src/main/java/ca/bc/gov/educ/studentdatacollection/api/struct/ReprocessSdcSchoolCollection.java

@@ -0,0 +1,21 @@
+package ca.bc.gov.educ.studentdatacollection.api.struct;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import jakarta.validation.constraints.NotNull;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.UUID;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class ReprocessSdcSchoolCollection {
+    @NotNull
+    UUID sdcSchoolCollectionID;
+    String updateUser;
+}