fix: sample processing preventing export

pom.xml

@@ -14,7 +14,7 @@
 
 	<groupId>fr.insee.pearljam</groupId>
 	<artifactId>pearljam-batch</artifactId>
-	<version>3.9.0</version>
+	<version>3.9.1</version>
 	<packaging>jar</packaging>
 	<name>pearljam-batch</name>
 	<description>PearlJam Batch</description>

src/main/java/fr/insee/pearljam/batch/service/PilotageLauncherService.java

@@ -1,9 +1,7 @@
 package fr.insee.pearljam.batch.service;
 
 import fr.insee.pearljam.batch.Constants;
-import fr.insee.pearljam.batch.campaign.Campaign;
-import fr.insee.pearljam.batch.campaign.CommunicationTemplateType;
-import fr.insee.pearljam.batch.campaign.SurveyUnitType;
+import fr.insee.pearljam.batch.campaign.*;
 import fr.insee.pearljam.batch.config.ApplicationConfig;
 import fr.insee.pearljam.batch.dao.CampaignDao;
 import fr.insee.pearljam.batch.dao.CommunicationTemplateDaoImpl;
@@ -36,6 +34,9 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.sql.SQLException;
+import java.time.Instant;
+import java.time.LocalDate;
+import java.time.ZoneOffset;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -64,6 +65,9 @@
 	private static final Logger logger = LogManager.getLogger(PilotageLauncherService.class);
 	private static final String CAMPAIGN_PATH_IN = "/campaign/campaign.xml";
 
+	@Value("${application.feature.sampleprocessing.allowwhenidentificationstarted}")
+	private boolean allowWhenIdentificationStarted;
+
 	/**
 	 * Global function that structure the batch execution depends on batchOption
 	 *
@@ -343,9 +347,21 @@
 
 		List<InterrogationDataCollectionDto> interrogations = new ArrayList<>();
 		Map<String, SurveyUnitType> oldSuMap = new HashMap<>();
 		for(Questionnaire questionnaire : questionnaires) {
 			String interrogationId = questionnaire.getIdInterrogation();
 			if (steps.contains(Constants.PILOTAGE)) {
+
+				try
+				{
+					isIntegrationFeasible(campaignId, interrogationId);
+				}
+				catch (BatchException e)
+				{
+					logger.log(Level.WARN, e.getMessage());
+					returnCode = BatchErrorCode.KO_FONCTIONAL_ERROR;
+					continue;
+				}
+
 				boolean pilotageValidate = campaignService.validateInput(mapPilotageSu.get(interrogationId), campaignId);
 				if(!pilotageValidate) {
 					logger.log(Level.WARN, "Interrogation {} is invalid", interrogationId);
@@ -399,6 +415,38 @@
 		return returnCode;
 	}
 
+	private void isIntegrationFeasible(String campaignId, String interrogationId) throws BatchException {
+		if(allowWhenIdentificationStarted)
+		{
+			return;
+		}
+
+		Campaign campaign = campaignDao.findById(campaignId);
+		OrganizationalUnitsType organizationalUnitType = campaign.getOrganizationalUnits();
+
+
+		boolean afterIdentificationStarted = false;
+		if(organizationalUnitType != null)
+		{
+			LocalDate localDate = LocalDate.now();
+			afterIdentificationStarted = organizationalUnitType.getOrganizationalUnit().stream().anyMatch(
+					ou ->
+					{
+						long epochMilliSeconds = Long.parseLong(ou.getIdentificationPhaseStartDate());
+						LocalDate date = Instant.ofEpochMilli(epochMilliSeconds)
+								.atZone(ZoneOffset.UTC)
+								.toLocalDate();
+
+						return localDate.isAfter(date);
+					});
+		}
+
+		if(afterIdentificationStarted)
+		{
+			throw new BatchException(String.format("Can not integrate sample processing, idendification start date for %s already in the past", interrogationId));
+		}
+	}
+
 
 	private void moveFilesInOutFolders(BatchErrorCode returnCode) throws IOException, ValidateException {
 		if(new File(appConfig.folderIn() + CAMPAIGN_PATH_IN).exists()) {

src/main/resources/application.yml

@@ -78,4 +78,9 @@ api:
 
 logging:
   level:
-    fr.insee.lunatic.utils.XslTransformation: WARN
+    fr.insee.lunatic.utils.XslTransformation: WARN
+
+application:
+   feature:
+      sampleprocessing:
+        allowwhenidentificationstarted: true

src/test/resources/application-test.yml

@@ -76,4 +76,9 @@ api:
   datacollection:
     url: http://localhost:9999
     bulk:
-      size: 500
+      size: 500
+
+application:
+  feature:
+    sampleprocessing:
+      allowwhenidentificationstarted: true