SORMAS-Foundation#4008 - cases merge filter fix - add test

Author: barnabartha

sormas-backend/src/main/java/de/symeda/sormas/backend/caze/CaseFacadeEjb.java

@@ -1354,8 +1354,8 @@ public List<CaseIndexDto[]> getCasesForDuplicateMerging(CaseCriteria criteria, b
 		Predicate creationDateFilter = cb.or(
 			cb.lessThan(root.get(Case.CREATION_DATE), root2.get(Case.CREATION_DATE)),
 			cb.or(
-				cb.lessThan(root2.get(Case.CREATION_DATE), DateHelper.getEndOfDay(criteria.getCreationDateFrom())),
-				cb.greaterThan(root2.get(Case.CREATION_DATE), DateHelper.getStartOfDay(criteria.getCreationDateTo()))));
+				cb.lessThanOrEqualTo(root2.get(Case.CREATION_DATE), DateHelper.getStartOfDay(criteria.getCreationDateFrom())),
+				cb.greaterThanOrEqualTo(root2.get(Case.CREATION_DATE), DateHelper.getEndOfDay(criteria.getCreationDateTo()))));
 
 		Predicate filter = cb.and(caseService.createDefaultFilter(cb, root), caseService.createDefaultFilter(cb, root2));
 		if (userFilter != null) {

sormas-backend/src/test/java/de/symeda/sormas/backend/H2Function.java

@@ -11,10 +11,12 @@ public static float similarity(String a, String b) {
 		return a.equalsIgnoreCase(b) ? 1 : 0;
 	}
 
-	public static int date_part(String part, Date date) {
+	public static long date_part(String part, Date date) {
 		switch (part) {
 		case "year":
 			return DateHelper8.toLocalDate(date).getYear();
+		case "epoch":
+			return date.getTime() / 1000;
 		default:
 			throw new IllegalArgumentException(part);
 		}

sormas-backend/src/test/java/de/symeda/sormas/backend/caze/CaseFacadeEjbTest.java

@@ -27,6 +27,7 @@
 import static org.junit.Assert.assertThat;
 import static org.junit.Assert.assertTrue;
 
+import java.sql.Timestamp;
 import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -36,15 +37,17 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
-import de.symeda.sormas.api.VisitOrigin;
-import de.symeda.sormas.api.messaging.MessageType;
+import org.apache.commons.lang3.time.DateUtils;
+import org.hibernate.internal.SessionImpl;
+import org.hibernate.query.spi.QueryImplementor;
 import org.junit.Assert;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
 
 import de.symeda.sormas.api.Disease;
 import de.symeda.sormas.api.Language;
+import de.symeda.sormas.api.VisitOrigin;
 import de.symeda.sormas.api.caze.CaseClassification;
 import de.symeda.sormas.api.caze.CaseCriteria;
 import de.symeda.sormas.api.caze.CaseDataDto;
@@ -72,6 +75,7 @@
 import de.symeda.sormas.api.exposure.ExposureType;
 import de.symeda.sormas.api.facility.FacilityReferenceDto;
 import de.symeda.sormas.api.hospitalization.PreviousHospitalizationDto;
+import de.symeda.sormas.api.messaging.MessageType;
 import de.symeda.sormas.api.person.PersonDto;
 import de.symeda.sormas.api.person.PersonReferenceDto;
 import de.symeda.sormas.api.person.PresentCondition;
@@ -116,6 +120,52 @@ public class CaseFacadeEjbTest extends AbstractBeanTest {
 	@Rule
 	public final ExpectedException exception = ExpectedException.none();
 
+	@Test
+	public void testGetCasesForDuplicateMerging() {
+
+		final Date today = new Date();
+		final Date threeDaysAgo = DateUtils.addDays(today, -3);
+
+		RDCFEntities rdcf = creator.createRDCFEntities("Region", "District", "Community", "Facility");
+		UserDto user = creator
+			.createUser(rdcf.region.getUuid(), rdcf.district.getUuid(), rdcf.facility.getUuid(), "Surv", "Sup", UserRole.SURVEILLANCE_SUPERVISOR);
+		PersonDto cazePerson = creator.createPerson("Case", "Person");
+		CaseDataDto caze = creator.createCase(
+			user.toReference(),
+			cazePerson.toReference(),
+			Disease.EVD,
+			CaseClassification.PROBABLE,
+			InvestigationStatus.PENDING,
+			today,
+			rdcf);
+
+		SessionImpl em = (SessionImpl) getEntityManager();
+		QueryImplementor query = em.createQuery("select c from cases c where c.uuid=:uuid");
+		query.setParameter("uuid", caze.getUuid());
+		Case singleResult = (Case) query.getSingleResult();
+
+		singleResult.setCreationDate(new Timestamp(threeDaysAgo.getTime()));
+		singleResult.setReportDate(threeDaysAgo);
+		em.save(singleResult);
+
+		PersonDto cazePerson2 = creator.createPerson("Case", "Person");
+		CaseDataDto case2 = creator.createCase(
+			user.toReference(),
+			cazePerson2.toReference(),
+			Disease.EVD,
+			CaseClassification.PROBABLE,
+			InvestigationStatus.PENDING,
+			DateUtils.addMinutes(today, -3),
+			rdcf);
+
+		final List<CaseIndexDto[]> casesForDuplicateMergingToday =
+			getCaseFacade().getCasesForDuplicateMerging(new CaseCriteria().creationDateFrom(today).creationDateTo(today), true);
+		final List<CaseIndexDto[]> casesForDuplicateMergingThreeDaysAgo =
+			getCaseFacade().getCasesForDuplicateMerging(new CaseCriteria().creationDateFrom(threeDaysAgo).creationDateTo(threeDaysAgo), true);
+		Assert.assertEquals(1, casesForDuplicateMergingToday.size());
+		Assert.assertEquals(1, casesForDuplicateMergingThreeDaysAgo.size());
+	}
+
 	@Test
 	public void testDiseaseChangeUpdatesContacts() {