From b6d179ca88bf4ab479109ef1ab0b6c70bbf65add Mon Sep 17 00:00:00 2001
From: fabio <fabio@d1611594-4594-4d17-8e1d-87c2c4800839>
Date: Fri, 12 Nov 2021 15:17:00 +0000
Subject: [PATCH] fixes bug#23499 dev: Valdevir qua:

git-svn-id: http://desenvolvimento.rjconsultores.com.br/repositorio/sco/AdmVenta/Web/trunk/ventaboletos@109594 d1611594-4594-4d17-8e1d-87c2c4800839
---
 .../controladores/job/IntegracaoSapJob.java   | 35 ++++++++++++++
 .../ventaboletos/web/utilerias/MyAppInit.java | 46 +++++++++++++++++++
 2 files changed, 81 insertions(+)
 create mode 100644 src/java/com/rjconsultores/ventaboletos/web/gui/controladores/job/IntegracaoSapJob.java

diff --git a/src/java/com/rjconsultores/ventaboletos/web/gui/controladores/job/IntegracaoSapJob.java b/src/java/com/rjconsultores/ventaboletos/web/gui/controladores/job/IntegracaoSapJob.java
new file mode 100644
index 000000000..15c33d28f
--- /dev/null
+++ b/src/java/com/rjconsultores/ventaboletos/web/gui/controladores/job/IntegracaoSapJob.java
@@ -0,0 +1,35 @@
+package com.rjconsultores.ventaboletos.web.gui.controladores.job;
+
+import org.apache.log4j.Logger;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.context.ApplicationContext;
+
+import com.rjconsultores.ventaboletos.service.SapService;
+import com.rjconsultores.ventaboletos.web.utilerias.spring.AppContext;
+
+public class IntegracaoSapJob implements Job {
+
+    private static Logger log = Logger.getLogger(IntegracaoSapJob.class);    
+    private SapService sapService;
+
+    public SapService getSapService() {
+        return sapService;
+    }
+
+    @Override
+    public void execute(JobExecutionContext jec) throws JobExecutionException {
+        log.info("Inicio do job de integração de boletos com o SAP.");
+
+        ApplicationContext appContext = AppContext.getApplicationContext();
+        SapService iss = (SapService) appContext.getBean("sapService");
+        try {
+			iss.integracaoSapAutomatica();
+		} catch (Exception e) {
+			log.error(e);
+		}
+
+        log.info("Fim do job de integração de boletos com o SAP.");
+    }
+}
diff --git a/src/java/com/rjconsultores/ventaboletos/web/utilerias/MyAppInit.java b/src/java/com/rjconsultores/ventaboletos/web/utilerias/MyAppInit.java
index 25b391bc0..cb9b610c3 100644
--- a/src/java/com/rjconsultores/ventaboletos/web/utilerias/MyAppInit.java
+++ b/src/java/com/rjconsultores/ventaboletos/web/utilerias/MyAppInit.java
@@ -33,6 +33,7 @@ import com.rjconsultores.ventaboletos.utilerias.ApplicationProperties;
 import com.rjconsultores.ventaboletos.web.gui.controladores.job.GeneracionConferenciaMovimentoJob;
 import com.rjconsultores.ventaboletos.web.gui.controladores.job.GeneracionCorridaJob;
 import com.rjconsultores.ventaboletos.web.gui.controladores.job.GeneracionRetencaoDiariaComissaoJob;
+import com.rjconsultores.ventaboletos.web.gui.controladores.job.IntegracaoSapJob;
 import com.rjconsultores.ventaboletos.web.gui.controladores.job.MonitoramentoCCFCRZJob;
 import com.rjconsultores.ventaboletos.web.utilerias.spring.AppContext;
 
@@ -45,6 +46,7 @@ public class MyAppInit implements org.zkoss.zk.ui.util.WebAppInit {
 	private static final String HORA_GENERACION_CORRIDA = "HORA_GENERACION_CORRIDA";
 	private static final String HORA_EXEC_CONFERENCIA_MOVIMENTO = "HORA_EXEC_CONFERENCIA_MOVIMENTO";
 	private static final String HORA_EXEC_MONITORAMENTO_REDUCAOZ = "HORA_EXEC_MONITORAMENTO_REDUCAOZ";
+	private static final String HORA_INTEGRACAO_SAP = "HORA_INTEGRACAO_SAP";
 	private static Logger log = Logger.getLogger(MyAppInit.class);
 	SchedulerFactory schedFact = new StdSchedulerFactory();
 	Scheduler sched;
@@ -91,6 +93,8 @@ public class MyAppInit implements org.zkoss.zk.ui.util.WebAppInit {
 			
 			//Retencao diara comissao
 			jobGeneracionRetencaoDiariaComissao();
+			
+			jobIntegracaoSap();
 		}
 		
 		executeFlyway();
@@ -285,6 +289,48 @@ public class MyAppInit implements org.zkoss.zk.ui.util.WebAppInit {
 		}
 	}
 	
+	private void jobIntegracaoSap() {
+		try {
+			sched = schedFact.getScheduler();
+
+			JobDetail jobDetail = new JobDetail("IntegracaoSap", null, IntegracaoSapJob.class);
+
+			Integer[] hora = horaExecucion(HORA_INTEGRACAO_SAP);
+
+			if (hora == null) {
+				log.info("constante HORA_INTEGRACAO_SAP não habilitada.");
+
+				return;
+			}
+
+			log.info("Horario de integraçao com sap : " + hora[0] + ":" + hora[1]);
+
+			Trigger trigger = TriggerUtils.makeDailyTrigger("integracaoSapTrigger", hora[0], hora[1]);
+
+			// TESTE TRIGGER
+//			 Trigger trigger = TriggerUtils.makeImmediateTrigger("integracaoSapTrigger", 1, 1000);
+
+			trigger.setName("integracaoSapTrigger");
+
+			JobDetail job = sched.getJobDetail(jobDetail.getName(), jobDetail.getGroup());
+
+			log.info("Job=" + jobDetail.getName() + "." + jobDetail.getGroup());
+
+			if (job != null) {
+				log.info("Job ya existia");
+				boolean deleted = sched.deleteJob(job.getName(), Scheduler.DEFAULT_GROUP);
+				log.info("Deleted=" + deleted);
+			}
+
+			sched.scheduleJob(jobDetail, trigger);
+
+			sched.start();
+
+		} catch (SchedulerException ex) {
+			log.error(ex);
+		}
+	}
+	
 	/**
 	 * Cria job do Quartz para Conferência de Movimento Automática do dia anterior.
 	 */