#13772 - Add Epipulse export functionality for IPI disease

Author: roldy

sormas-api/src/main/java/de/symeda/sormas/api/epipulse/EpipulseDiseaseExportEntryDto.java

@@ -1211,7 +1211,9 @@ public String getPenicillinResistanceForCsv() {
 	public List<String> getClinicalPresentationForCsv(int maxCount) {
 		List<String> presentations = new ArrayList<>();
 		if (clinicalPresentation != null && !clinicalPresentation.isEmpty()) {
-			presentations.addAll(clinicalPresentation);
+			for (int i = 0; i < Math.min(maxCount, clinicalPresentation.size()); i++) {
+				presentations.add(clinicalPresentation.get(i));
+			}
 		}
 		// Pad with empty strings to match maxCount
 		while (presentations.size() < maxCount) {

sormas-backend/src/main/java/de/symeda/sormas/backend/epipulse/EpipulseCommonDtoMapper.java

@@ -76,9 +76,10 @@ public static int mapCommonFields(
 
 		// Index 2: Subject Code
 		String subjectCodeFromDb = (String) row[++index];
-		if (!StringUtils.isBlank(subjectCodeFromDb)) {
-			dto.setSubjectCode(EpipulseSubjectCode.valueOf(subjectCodeFromDb));
+		if (StringUtils.isBlank(subjectCodeFromDb)) {
+			throw new IllegalStateException("Subject code is missing for Epipulse export row");
 		}
+		dto.setSubjectCode(EpipulseSubjectCode.valueOf(subjectCodeFromDb));
 
 		// Index 3: National Record ID (case UUID)
 		dto.setNationalRecordId((String) row[++index]);

sormas-backend/src/main/java/de/symeda/sormas/backend/epipulse/EpipulseConfigurationLookupService.java

@@ -61,6 +61,13 @@ public class EpipulseConfigurationLookupService {
 	public EpipulseConfigurationContext lookupConfiguration(EpipulseExportDto exportDto, String serverCountryLocale, String serverCountryName)
 		throws IllegalArgumentException, IllegalStateException {
 
+		if (exportDto == null || exportDto.getSubjectCode() == null) {
+			throw new IllegalArgumentException("Subject code is required for Epipulse export");
+		}
+		if (StringUtils.isBlank(serverCountryLocale)) {
+			throw new IllegalArgumentException("Server country code/locale is required for Epipulse export");
+		}
+
 		String reportingCountry = lookupReportingCountry(serverCountryLocale);
 		String serverCountryNutsCode = lookupServerCountryNutsCode(serverCountryName);
 		String subjectCode = lookupSubjectCode(exportDto.getSubjectCode());
@@ -121,7 +128,7 @@ private String lookupServerCountryNutsCode(String countryName) {
 
 		@SuppressWarnings("unchecked")
 		String serverCountryNutsCode = (String) em.createNativeQuery(serverCountryQuery)
-			.setParameter("countryName", countryName.toLowerCase())
+			.setParameter("countryName", countryName.toLowerCase(java.util.Locale.ROOT))
 			.getResultStream()
 			.filter(java.util.Objects::nonNull)
 			.findFirst()

sormas-backend/src/main/java/de/symeda/sormas/backend/epipulse/strategy/IpiExportStrategy.java

@@ -271,16 +271,16 @@ private String buildPneuVaccinationDetailsCte() {
 		//@formatter:off
 		return "pneu_vaccination_details AS (" +
 			   "    SELECT c.id as case_id," +
-			   "           MAX(CASE WHEN pcv_row_num = 1 THEN v.vaccinationdate END) as date_pcv1," +
-			   "           MAX(CASE WHEN pcv_row_num = 1 THEN CAST(v.vaccinename AS text) END) as brand_pcv1," +
-			   "           MAX(CASE WHEN pcv_row_num = 2 THEN v.vaccinationdate END) as date_pcv2," +
-			   "           MAX(CASE WHEN pcv_row_num = 2 THEN CAST(v.vaccinename AS text) END) as brand_pcv2," +
-			   "           MAX(CASE WHEN pcv_row_num = 3 THEN v.vaccinationdate END) as date_pcv3," +
-			   "           MAX(CASE WHEN pcv_row_num = 3 THEN CAST(v.vaccinename AS text) END) as brand_pcv3," +
-			   "           MAX(CASE WHEN pcv_row_num = 4 THEN v.vaccinationdate END) as date_pcv4," +
-			   "           MAX(CASE WHEN pcv_row_num = 4 THEN CAST(v.vaccinename AS text) END) as brand_pcv4," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 1 THEN v.vaccinationdate END) as date_pcv1," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 1 THEN CAST(v.vaccinename AS text) END) as brand_pcv1," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 2 THEN v.vaccinationdate END) as date_pcv2," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 2 THEN CAST(v.vaccinename AS text) END) as brand_pcv2," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 3 THEN v.vaccinationdate END) as date_pcv3," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 3 THEN CAST(v.vaccinename AS text) END) as brand_pcv3," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 4 THEN v.vaccinationdate END) as date_pcv4," +
+			   "           MAX(CASE WHEN is_pcv AND pcv_row_num = 4 THEN CAST(v.vaccinename AS text) END) as brand_pcv4," +
 			   "           SUM(CASE WHEN is_pcv THEN 1 ELSE 0 END) as pcv_doses," +
-			   "           MAX(CASE WHEN ppv_row_num = 1 THEN v.vaccinationdate END) as date_ppv," +
+			   "           MAX(CASE WHEN is_ppv AND ppv_row_num = 1 THEN v.vaccinationdate END) as date_ppv," +
 			   "           SUM(CASE WHEN is_ppv THEN 1 ELSE 0 END) as ppv_doses " +
 			   "    FROM filtered_cases c " +
 			   "    LEFT JOIN vaccination v ON v.immunization_id IN (SELECT i.id FROM immunization i WHERE i.person_id = c.person_id AND i.disease = 'INVASIVE_PNEUMOCOCCAL_INFECTION') " +
@@ -293,12 +293,10 @@ private String buildPneuVaccinationDetailsCte() {
 			   "                 WHEN CAST(v.vaccinename AS text) LIKE '%PPV%' OR CAST(v.vaccinename AS text) LIKE '%POLYSACCHARIDE%' THEN true " +
 			   "                 ELSE false " +
 			   "               END as is_ppv," +
-			   "               ROW_NUMBER() OVER (PARTITION BY c.id, " +
-			   "                   CASE WHEN CAST(v.vaccinename AS text) LIKE '%PCV%' THEN 1 ELSE 0 END " +
-			   "                   ORDER BY v.vaccinationdate) as pcv_row_num," +
-			   "               ROW_NUMBER() OVER (PARTITION BY c.id, " +
-			   "                   CASE WHEN CAST(v.vaccinename AS text) LIKE '%PPV%' THEN 1 ELSE 0 END " +
-			   "                   ORDER BY v.vaccinationdate) as ppv_row_num " +
+               "               SUM(CASE WHEN CAST(v.vaccinename AS text) LIKE '%PCV%' OR CAST(v.vaccinename AS text) LIKE '%CONJUGATE%' THEN 1 ELSE 0 END) " +
+               "                   OVER (PARTITION BY c.id ORDER BY v.vaccinationdate) as pcv_row_num," +
+               "               SUM(CASE WHEN CAST(v.vaccinename AS text) LIKE '%PPV%' OR CAST(v.vaccinename AS text) LIKE '%POLYSACCHARIDE%' THEN 1 ELSE 0 END) " +
+               "                   OVER (PARTITION BY c.id ORDER BY v.vaccinationdate) as ppv_row_num " +
 			   "    ) vax_info ON true " +
 			   "    GROUP BY c.id) ";
 		//@formatter:on