AMM-1139 | Scheduler for fetching L3 to L5 grievance details

src/main/java/com/iemr/common/config/quartz/QuartzConfig.java

@@ -97,7 +97,8 @@ public SchedulerFactoryBean quartzScheduler() {
 		Trigger[] triggers = { processMQTriggerForUnblock().getObject(), processMQTriggerForSMS().getObject(),
 				processMQTriggerForEmail().getObject(), processMQTriggerForRegistration().getObject(),
 				processMQTriggerForEverwellDataSync().getObject(), processMQTriggerForCtiDataSync().getObject(),
-				processMQTriggerForAvniRegistration().getObject(), processMQTriggerForNHMDashboardData().getObject() };
+				processMQTriggerForAvniRegistration().getObject(),
+				processMQTriggerForNHMDashboardData().getObject(), processMQTriggerForGrievanceDataSync().getObject() };
 
 		quartzScheduler.setTriggers(triggers);
 
@@ -169,7 +170,7 @@ public CronTriggerFactoryBean processMQTriggerForEmail() {
 		Boolean startJob = ConfigProperties.getBoolean("start-email-scheduler");
 		CronTriggerFactoryBean cronTriggerFactoryBean = new CronTriggerFactoryBean();
 		String scheduleConfig = quartzJobDefaultSchedule;
-		if (startJob) {
+		if (Boolean.TRUE.equals(startJob)) {
 			scheduleConfig = ConfigProperties.getPropertyByName("cron-scheduler-email");
 		}
 		cronTriggerFactoryBean.setJobDetail(processMQJobForEmail().getObject());
@@ -226,6 +227,33 @@ public CronTriggerFactoryBean processMQTriggerForEverwellDataSync() {
 		return cronTriggerFactoryBean;
 	}
 
+	//-----------------Grievance Data Sync Scheduler----------------------------------------------
+
+	@Bean
+	public JobDetailFactoryBean processMQJobForGrievanceDataSync() {
+		JobDetailFactoryBean jobDetailFactory;
+		jobDetailFactory = new JobDetailFactoryBean();
+		jobDetailFactory.setJobClass(ScheduleForGrievanceDataSync.class);
+		jobDetailFactory.setGroup(quartzJobGroup);
+		return jobDetailFactory;
+	}
+
+	@Bean
+	public CronTriggerFactoryBean processMQTriggerForGrievanceDataSync() {
+		Boolean startJob = ConfigProperties.getBoolean("start-grievancedatasync-scheduler");
+		CronTriggerFactoryBean cronTriggerFactoryBean = new CronTriggerFactoryBean();
+		String scheduleConfig = quartzJobDefaultSchedule;
+		if (startJob) {
+			scheduleConfig = ConfigProperties.getPropertyByName("cron-scheduler-grievancedatasync");
+		}
+		cronTriggerFactoryBean.setJobDetail(processMQJobForGrievanceDataSync().getObject());
+		cronTriggerFactoryBean.setCronExpression(scheduleConfig);
+		cronTriggerFactoryBean.setGroup(quartzJobGroup);
+		return cronTriggerFactoryBean;
+	}
+
+
+
 	// --------------------------------------------------------------------------------------------------------------
 	@Bean
 	public JobDetailFactoryBean processMQJobForCtiDataSync() {

src/main/java/com/iemr/common/config/quartz/ScheduleForGrievanceDataSync.java

@@ -0,0 +1,38 @@
+package com.iemr.common.config.quartz;
+
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.iemr.common.service.grievance.GrievanceDataSync;
+
+@Service
+@Transactional
+public class ScheduleForGrievanceDataSync implements Job {
+
+	private final Logger logger = LoggerFactory.getLogger(this.getClass().getName());
+
+
+	private final GrievanceDataSync grievanceDataSync;
+
+	@Autowired
+	public ScheduleForGrievanceDataSync(GrievanceDataSync grievanceDataSync) {
+		this.grievanceDataSync = grievanceDataSync;
+	}
+
+	@Override
+	public void execute(JobExecutionContext arg0) throws JobExecutionException
+	{
+		logger.info("Started job for grievance data sync {}", arg0.getClass().getName());
+		grievanceDataSync.dataSyncToGrievance();
+		logger.info("Completed job for grievance data sync {}" , arg0.getClass().getName());
+	}
+
+
+
+}