DTS-50661: Renamed AiDataProcessorConstants to JobConstants.

shunaray · shunaray · commit 7b5cb981a110 · 2025-12-11T10:46:01.000+05:30
Change-log: Batch processing ai-recommendation for performance improvement.
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/aiusagestatisticscollector/processor/AccountItemProcessor.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/aiusagestatisticscollector/processor/AccountItemProcessor.java
@@ -21,7 +21,7 @@
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.dto.PagedAIUsagePerOrgLevel;
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.model.AIUsageStatistics;
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.service.AIUsageStatisticsService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 
 import jakarta.annotation.Nonnull;
 import lombok.AllArgsConstructor;
@@ -34,7 +34,7 @@ public class AccountItemProcessor implements ItemProcessor<PagedAIUsagePerOrgLev
 
     @Override
     public AIUsageStatistics process(@Nonnull PagedAIUsagePerOrgLevel item) {
-        log.debug("{} Fetching AI usage statistics for level name: {}", AiDataProcessorConstants.LOG_PREFIX_AI_USAGE_STATISTICS, item.levelName());
+        log.debug("{} Fetching AI usage statistics for level name: {}", JobConstants.LOG_PREFIX_AI_USAGE_STATISTICS, item.levelName());
         return aiUsageStatisticsService.fetchAIUsageStatistics(item.levelName());
     }
 }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/aiusagestatisticscollector/reader/AccountItemReader.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/aiusagestatisticscollector/reader/AccountItemReader.java
@@ -20,7 +20,7 @@
 
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.dto.PagedAIUsagePerOrgLevel;
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.service.AccountBatchService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -34,7 +34,7 @@ public class AccountItemReader implements ItemReader<PagedAIUsagePerOrgLevel> {
     @Override
     public PagedAIUsagePerOrgLevel read() {
         PagedAIUsagePerOrgLevel aiUsageStatistics = accountBatchService.getNextAccountPage();
-        log.info("{} Reader fetched level name: {}", AiDataProcessorConstants.LOG_PREFIX_AI_USAGE_STATISTICS, aiUsageStatistics.levelName());
+        log.info("{} Reader fetched level name: {}", JobConstants.LOG_PREFIX_AI_USAGE_STATISTICS, aiUsageStatistics.levelName());
         return aiUsageStatistics;
     }
 }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/aiusagestatisticscollector/writer/AccountItemWriter.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/aiusagestatisticscollector/writer/AccountItemWriter.java
@@ -23,7 +23,7 @@
 
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.model.AIUsageStatistics;
 import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.service.AIUsageStatisticsService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 
 import lombok.AllArgsConstructor;
 import lombok.NonNull;
@@ -36,7 +36,7 @@ public class AccountItemWriter implements ItemWriter<AIUsageStatistics> {
 
     @Override
     public void write(@NonNull Chunk<? extends AIUsageStatistics> chunk) {
-        log.info("{} Received chunk items for inserting into database with size: {}", AiDataProcessorConstants.LOG_PREFIX_AI_USAGE_STATISTICS, chunk.size());
+        log.info("{} Received chunk items for inserting into database with size: {}", JobConstants.LOG_PREFIX_AI_USAGE_STATISTICS, chunk.size());
         aiUsageStatisticsService.saveAll((List.copyOf(chunk.getItems())));
     }
 }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/constant/JobConstants.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/constant/JobConstants.java
@@ -22,7 +22,7 @@
  * Constants used across AI Data Processor jobs.
  */
 @UtilityClass
-public final class AiDataProcessorConstants {
+public final class JobConstants {
 
 	public static final String JOB_PRODUCTIVITY_CALCULATION = "productivity-calculation";
 	public static final String JOB_KPI_MATURITY_CALCULATION = "kpi-maturity-calculation";
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/kpimaturitycalculation/processor/ProjectItemProcessor.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/kpimaturitycalculation/processor/ProjectItemProcessor.java
@@ -19,7 +19,7 @@
 import org.springframework.batch.item.ItemProcessor;
 
 import com.publicissapient.kpidashboard.common.model.kpimaturity.organization.KpiMaturity;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.kpimaturitycalculation.service.KpiMaturityCalculationService;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -35,7 +35,7 @@ public class ProjectItemProcessor implements ItemProcessor<ProjectInputDTO, KpiM
 
     @Override
     public KpiMaturity process(@Nonnull ProjectInputDTO item) {
-        log.info("{} Starting kpi metrics calculation for project with nodeId: {}", AiDataProcessorConstants.LOG_PREFIX_KPI_MATURITY,item.nodeId());
+        log.info("{} Starting kpi metrics calculation for project with nodeId: {}", JobConstants.LOG_PREFIX_KPI_MATURITY,item.nodeId());
 
         return kpiMaturityCalculationService.calculateKpiMaturityForProject(item);
     }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/kpimaturitycalculation/reader/ProjectItemReader.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/kpimaturitycalculation/reader/ProjectItemReader.java
@@ -18,7 +18,7 @@
 
 import org.springframework.batch.item.ItemReader;
 
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.productivitycalculation.service.ProjectBatchService;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -35,7 +35,7 @@ public class ProjectItemReader implements ItemReader<ProjectInputDTO> {
     public ProjectInputDTO read() {
         ProjectInputDTO projectInputDTO = projectBatchService.getNextProjectInputData();
 
-        log.info("{} Received project input dto {}",AiDataProcessorConstants.LOG_PREFIX_KPI_MATURITY, projectInputDTO);
+        log.info("{} Received project input dto {}", JobConstants.LOG_PREFIX_KPI_MATURITY, projectInputDTO);
 
         return projectInputDTO;
     }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/kpimaturitycalculation/writer/ProjectItemWriter.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/kpimaturitycalculation/writer/ProjectItemWriter.java
@@ -19,7 +19,7 @@
 import java.util.List;
 
 import com.publicissapient.kpidashboard.common.service.ProcessorExecutionTraceLogService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import org.springframework.batch.item.Chunk;
 import org.springframework.batch.item.ItemWriter;
 import org.springframework.lang.NonNull;
@@ -40,7 +40,7 @@ public class ProjectItemWriter implements ItemWriter<KpiMaturity> {
 	@Override
 	public void write(@NonNull Chunk<? extends KpiMaturity> chunk) {
 		log.info("{} Received chunk items for inserting into database with size: {}",
-				AiDataProcessorConstants.LOG_PREFIX_KPI_MATURITY, chunk.size());
+				JobConstants.LOG_PREFIX_KPI_MATURITY, chunk.size());
 		kpiMaturityCalculationService.saveAll((List<KpiMaturity>) chunk.getItems());
 	}
 }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/productivitycalculation/processor/ProjectItemProcessor.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/productivitycalculation/processor/ProjectItemProcessor.java
@@ -19,7 +19,7 @@
 import org.springframework.batch.item.ItemProcessor;
 
 import com.publicissapient.kpidashboard.common.model.productivity.calculation.Productivity;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.productivitycalculation.service.ProductivityCalculationService;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -35,7 +35,7 @@ public class ProjectItemProcessor implements ItemProcessor<ProjectInputDTO, Prod
 
     @Override
     public Productivity process(@Nonnull ProjectInputDTO item) {
-        log.debug("{}Starting productivity calculation for project with nodeId: {}", AiDataProcessorConstants.LOG_PREFIX_PRODUCTIVITY, item.nodeId());
+        log.debug("{}Starting productivity calculation for project with nodeId: {}", JobConstants.LOG_PREFIX_PRODUCTIVITY, item.nodeId());
 
         return productivityCalculationService.calculateProductivityGainForProject(item);
     }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/productivitycalculation/reader/ProjectItemReader.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/productivitycalculation/reader/ProjectItemReader.java
@@ -18,7 +18,7 @@
 
 import org.springframework.batch.item.ItemReader;
 
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.productivitycalculation.service.ProjectBatchService;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -35,7 +35,7 @@ public class ProjectItemReader implements ItemReader<ProjectInputDTO> {
     public ProjectInputDTO read() {
         ProjectInputDTO projectInputDTO = projectBatchService.getNextProjectInputData();
 
-        log.info("[productivity-calculation job]Received project input dto {}", AiDataProcessorConstants.LOG_PREFIX_PRODUCTIVITY, projectInputDTO);
+        log.info("[productivity-calculation job]Received project input dto {}", JobConstants.LOG_PREFIX_PRODUCTIVITY, projectInputDTO);
 
         return projectInputDTO;
     }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/productivitycalculation/writer/ProjectItemWriter.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/productivitycalculation/writer/ProjectItemWriter.java
@@ -19,7 +19,7 @@
 import java.util.List;
 
 import com.publicissapient.kpidashboard.common.service.ProcessorExecutionTraceLogService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import org.springframework.batch.item.Chunk;
 import org.springframework.batch.item.ItemWriter;
 import org.springframework.lang.NonNull;
@@ -40,7 +40,7 @@ public class ProjectItemWriter implements ItemWriter<Productivity> {
 	@Override
 	public void write(@NonNull Chunk<? extends Productivity> chunk) {
         log.info("{} Received chunk items for inserting into database with size: {}",
-                AiDataProcessorConstants.LOG_PREFIX_PRODUCTIVITY, chunk.size());
+                JobConstants.LOG_PREFIX_PRODUCTIVITY, chunk.size());
         productivityCalculationService.saveAll((List<Productivity>) chunk.getItems());
 	}
 }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/listener/RecommendationCalculationJobExecutionListener.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/listener/RecommendationCalculationJobExecutionListener.java
@@ -32,7 +32,7 @@
 import com.publicissapient.kpidashboard.common.model.application.ErrorDetail;
 import com.publicissapient.kpidashboard.common.model.tracelog.JobExecutionTraceLog;
 import com.publicissapient.kpidashboard.common.service.JobExecutionTraceLogService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.recommendationcalculation.service.RecommendationProjectBatchService;
 
 import lombok.RequiredArgsConstructor;
@@ -51,7 +51,7 @@ public class RecommendationCalculationJobExecutionListener implements JobExecuti
 
 	@Override
 	public void afterJob(@NonNull JobExecution jobExecution) {
-		log.info("{} Job completed with status: {}", AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION,
+		log.info("{} Job completed with status: {}", JobConstants.LOG_PREFIX_RECOMMENDATION,
 				jobExecution.getStatus());
 		projectBatchService.initializeBatchProcessingParametersForTheNextProcess();
 		storeJobExecutionStatus(jobExecution);
@@ -80,7 +80,7 @@ private void storeJobExecutionStatus(JobExecution jobExecution) {
 			log.error(
 					"{} Could not store job execution ending status for job with name {} and execution id {}. Job "
 							+ "execution could not be found",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, jobName, executionId);
+					JobConstants.LOG_PREFIX_RECOMMENDATION, jobName, executionId);
 		}
 	}
 }
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/parser/BatchRecommendationResponseParser.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/parser/BatchRecommendationResponseParser.java
@@ -31,7 +31,7 @@
 import com.publicissapient.kpidashboard.common.model.recommendation.batch.ActionPlan;
 import com.publicissapient.kpidashboard.common.model.recommendation.batch.Recommendation;
 import com.publicissapient.kpidashboard.common.model.recommendation.batch.Severity;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -69,7 +69,7 @@ public Optional<Recommendation> parseRecommendation(@NonNull ChatGenerationRespo
 		String aiResponse = response.content();
 		if (aiResponse == null || aiResponse.trim().isEmpty()) {
 			log.error("{} AI Gateway returned null or empty response content",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION);
+					JobConstants.LOG_PREFIX_RECOMMENDATION);
 			return Optional.empty();
 		}
 
@@ -86,7 +86,7 @@ public Optional<Recommendation> parseRecommendation(@NonNull ChatGenerationRespo
 	private Optional<Recommendation> parseRecommendationContent(String aiResponse) {
 		if (StringUtils.isBlank(aiResponse)) {
 			log.error("{} AI response is empty, cannot parse recommendation",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION);
+					JobConstants.LOG_PREFIX_RECOMMENDATION);
 			return Optional.empty();
 		}
 
@@ -95,7 +95,7 @@ private Optional<Recommendation> parseRecommendationContent(String aiResponse) {
 
 			if (StringUtils.isBlank(jsonContent) || EMPTY_JSON_OBJECT.equals(jsonContent)) {
 				log.error("{} Extracted JSON content is empty or invalid from AI response",
-						AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION);
+						JobConstants.LOG_PREFIX_RECOMMENDATION);
 				return Optional.empty();
 			}
 			JsonNode rootNode = objectMapper.readTree(jsonContent);
@@ -112,7 +112,7 @@ private Optional<Recommendation> parseRecommendationContent(String aiResponse) {
 		} catch (Exception e) {
 			String preview = StringUtils.abbreviate(aiResponse, 100);
 			log.error("{} Error parsing AI response JSON: {} - Response preview: {}",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, e.getMessage(), preview, e);
+					JobConstants.LOG_PREFIX_RECOMMENDATION, e.getMessage(), preview, e);
 			return Optional.empty();
 		}
 	}
@@ -171,7 +171,7 @@ private Optional<Severity> parseSeverity(String severityStr) {
 			return Optional.of(Severity.valueOf(severityStr));
 		} catch (IllegalArgumentException e) {
 			log.warn("{} Invalid severity value from AI response: {}. Saving as null.",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, severityStr);
+					JobConstants.LOG_PREFIX_RECOMMENDATION, severityStr);
 			return Optional.empty();
 		}
 	}
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/processor/ProjectItemProcessor.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/processor/ProjectItemProcessor.java
@@ -21,7 +21,7 @@
 
 import com.publicissapient.kpidashboard.common.model.recommendation.batch.RecommendationsActionPlan;
 import com.publicissapient.kpidashboard.common.service.ProcessorExecutionTraceLogService;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.recommendationcalculation.service.RecommendationCalculationService;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -53,25 +53,25 @@ public class ProjectItemProcessor implements ItemProcessor<ProjectInputDTO, Reco
 	public RecommendationsActionPlan process(@Nonnull ProjectInputDTO projectInputDTO) throws Exception {
 		try {
 			log.debug("{} Starting recommendation calculation for project with nodeId: {}",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, projectInputDTO.nodeId());
+					JobConstants.LOG_PREFIX_RECOMMENDATION, projectInputDTO.nodeId());
 
 			RecommendationsActionPlan recommendation = recommendationCalculationService
 					.calculateRecommendationsForProject(projectInputDTO);
 
 			log.debug("{} Generated recommendation plan for project: {} with persona: {}",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, projectInputDTO.name(),
+					JobConstants.LOG_PREFIX_RECOMMENDATION, projectInputDTO.name(),
 					recommendation.getMetadata().getPersona());
 			return recommendation;
 		} catch (Exception e) {
 			log.error("{} Failed to process project: {} (nodeId: {})",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, projectInputDTO.name(),
+					JobConstants.LOG_PREFIX_RECOMMENDATION, projectInputDTO.name(),
 					projectInputDTO.nodeId(), e);
 
 			// Save detailed failure trace log with more context
 			String errorMessage = String.format("Processing failed for project %s: %s - %s. Root cause: %s",
 					projectInputDTO.name(), e.getClass().getSimpleName(), e.getMessage(),
 					ExceptionUtils.getRootCauseMessage(e));
-			processorExecutionTraceLogService.upsertTraceLog(AiDataProcessorConstants.JOB_RECOMMENDATION_CALCULATION,
+			processorExecutionTraceLogService.upsertTraceLog(JobConstants.JOB_RECOMMENDATION_CALCULATION,
 					projectInputDTO.nodeId(), false, errorMessage);
 
 			// Return null to skip this projectInputDTO
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/reader/ProjectItemReader.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/reader/ProjectItemReader.java
@@ -19,7 +19,7 @@
 
 import org.springframework.batch.item.ItemReader;
 
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.recommendationcalculation.service.RecommendationProjectBatchService;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -39,7 +39,7 @@ public class ProjectItemReader implements ItemReader<ProjectInputDTO> {
 	public ProjectInputDTO read() {
 		ProjectInputDTO projectInputDTO = projectBatchService.getNextProjectInputData();
 
-		log.info("{} Received project input dto {}", AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION,
+		log.info("{} Received project input dto {}", JobConstants.LOG_PREFIX_RECOMMENDATION,
 				projectInputDTO);
 
 		return projectInputDTO;
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/service/KpiDataExtractionService.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/service/KpiDataExtractionService.java
@@ -33,7 +33,7 @@
 import com.publicissapient.kpidashboard.common.model.application.DataCount;
 import com.publicissapient.kpidashboard.common.model.application.DataCountGroup;
 import com.publicissapient.kpidashboard.common.model.application.KpiDataPrompt;
-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;
+import com.publicissapient.kpidashboard.job.constant.JobConstants;
 import com.publicissapient.kpidashboard.job.recommendationcalculation.config.RecommendationCalculationConfig;
 import com.publicissapient.kpidashboard.job.shared.dto.ProjectInputDTO;
 
@@ -63,7 +63,7 @@ public class KpiDataExtractionService {
      */
 	public Map<String, Object> fetchKpiDataForProject(ProjectInputDTO projectInput) {
 		try {
-			log.debug("{} Fetching KPI data for project: {}", AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION,
+			log.debug("{} Fetching KPI data for project: {}", JobConstants.LOG_PREFIX_RECOMMENDATION,
 					projectInput.nodeId());
 
 			// Construct KPI requests
@@ -76,7 +76,7 @@ public Map<String, Object> fetchKpiDataForProject(ProjectInputDTO projectInput)
 			if (CollectionUtils.isEmpty(kpiElements)) {
 				log.error(
 						"{} No KPI elements received from KnowHOW API for project: {}. Failing recommendation calculation.",
-						AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, projectInput.nodeId());
+						JobConstants.LOG_PREFIX_RECOMMENDATION, projectInput.nodeId());
 				throw new IllegalStateException(
 						"No KPI data received from KnowHOW API for project: " + projectInput.nodeId());
 			}
@@ -91,18 +91,18 @@ public Map<String, Object> fetchKpiDataForProject(ProjectInputDTO projectInput)
 			if (!hasData) {
 				log.error(
 						"{} KPI data extraction resulted in empty values for all KPIs for project: {}. Failing recommendation calculation.",
-						AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, projectInput.nodeId());
+						JobConstants.LOG_PREFIX_RECOMMENDATION, projectInput.nodeId());
 				throw new IllegalStateException(
 						"No meaningful KPI data available for project: " + projectInput.nodeId());
 			}
 
 			log.debug("{} Successfully fetched {} KPIs for project: {}",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, kpiData.size(), projectInput.nodeId());
+					JobConstants.LOG_PREFIX_RECOMMENDATION, kpiData.size(), projectInput.nodeId());
 			return kpiData;
 
 		} catch (Exception e) {
 			log.error("{} Error fetching KPI data for project {}: {}",
-					AiDataProcessorConstants.LOG_PREFIX_RECOMMENDATION, projectInput.nodeId(), e.getMessage(), e);
+					JobConstants.LOG_PREFIX_RECOMMENDATION, projectInput.nodeId(), e.getMessage(), e);
 			throw e;
 		}
 	}
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/service/RecommendationCalculationService.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/service/RecommendationCalculationService.java
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/service/RecommendationProjectBatchService.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/service/RecommendationProjectBatchService.java
diff --git a/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/writer/ProjectItemWriter.java b/ai-data-processor/src/main/java/com/publicissapient/kpidashboard/job/recommendationcalculation/writer/ProjectItemWriter.java
diff --git a/ai-data-processor/src/test/java/com/publicissapient/kpidashboard/job/orchestrator/JobOrchestratorTest.java b/ai-data-processor/src/test/java/com/publicissapient/kpidashboard/job/orchestrator/JobOrchestratorTest.java

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@`
`23`	`23`
`24`	`24`	`import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.model.AIUsageStatistics;`
`25`	`25`	`import com.publicissapient.kpidashboard.job.aiusagestatisticscollector.service.AIUsageStatisticsService;`
`26`		`-import com.publicissapient.kpidashboard.job.constant.AiDataProcessorConstants;`
	`26`	`+import com.publicissapient.kpidashboard.job.constant.JobConstants;`
`27`	`27`
`28`	`28`	`import lombok.AllArgsConstructor;`
`29`	`29`	`import lombok.NonNull;`
`@@ -36,7 +36,7 @@ public class AccountItemWriter implements ItemWriter<AIUsageStatistics> {`
`36`	`36`
`37`	`37`	`@Override`
`38`	`38`	`public void write(@NonNull Chunk<? extends AIUsageStatistics> chunk) {`
`39`		`- log.info("{} Received chunk items for inserting into database with size: {}", AiDataProcessorConstants.LOG_PREFIX_AI_USAGE_STATISTICS, chunk.size());`
	`39`	`+ log.info("{} Received chunk items for inserting into database with size: {}", JobConstants.LOG_PREFIX_AI_USAGE_STATISTICS, chunk.size());`
`40`	`40`	`aiUsageStatisticsService.saveAll((List.copyOf(chunk.getItems())));`
`41`	`41`	`}`
`42`	`42`	`}`