Merge branch 'GERM-MAYO-2023' into 'master'

Germ mayo 2023

See merge request !2

pom.xml

@@ -43,6 +43,7 @@
         <dependency>
             <groupId>org.springframework.batch</groupId>
             <artifactId>spring-batch-core</artifactId>
+            <version>4.2.4.RELEASE</version>
         </dependency>
 
         <dependency>
@@ -77,7 +78,7 @@
         <dependency>
             <groupId>com.itextpdf</groupId>
             <artifactId>itextpdf</artifactId>
-            <version>5.5.13.3</version>
+            <version>5.1.0</version>
         </dependency>
 
 
@@ -86,7 +87,31 @@
         <dependency>
             <groupId>org.postgresql</groupId>
             <artifactId>postgresql</artifactId>
-            <version>9.4-1200-jdbc41</version>
+            <version>42.5.4</version>
+        </dependency>
+
+
+        <dependency>
+        <groupId>org.postgresql</groupId>
+        <artifactId>postgresql</artifactId>
+        <scope>runtime</scope>
+    </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jdbc</artifactId>
+        </dependency>
+
+
+        <dependency>
+            <groupId>com.microsoft.sqlserver</groupId>
+            <artifactId>mssql-jdbc</artifactId>
+            <scope>runtime</scope>
         </dependency>
 
 

src/main/java/ec/edu/epn/consumosriautorizacion/ConsumoSriAutorizacionApplication.java

 package ec.edu.epn.consumosriautorizacion;
 
+import ec.edu.epn.consumosriautorizacion.config.SchPublicConfig;
 import org.springframework.batch.core.Job;
 import org.springframework.batch.core.JobExecution;
 import org.springframework.batch.core.JobExecutionException;
@@ -10,12 +11,14 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+import org.springframework.context.annotation.Import;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 
 @SpringBootApplication
 @EnableAsync
+@Import(SchPublicConfig.class)
 public class ConsumoSriAutorizacionApplication extends SpringBootServletInitializer {
 
     @Override

src/main/java/ec/edu/epn/consumosriautorizacion/Tasks/Task_Ftp.java

@@ -5,11 +5,14 @@ import org.springframework.batch.core.StepContribution;
 import org.springframework.batch.core.scope.context.ChunkContext;
 import org.springframework.batch.core.step.tasklet.Tasklet;
 import org.springframework.batch.repeat.RepeatStatus;
+import org.springframework.stereotype.Component;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.ArrayList;
 import java.util.List;
 
+
+@Component
 public class Task_Ftp implements Tasklet {
 
 
@@ -27,7 +30,7 @@ public class Task_Ftp implements Tasklet {
         List<String> fileNames = new ArrayList<>();
         for (MultipartFile file : files) {
             String fileName = file.getOriginalFilename();
-            ftpService.uploadFileToFTP(file.getInputStream(), pathFtp, fileName);
+          //  ftpService.uploadFileToFTP(file.getInputStream(), pathFtp, fileName);
             fileNames.add(fileName);
         }
         ftpService.disconnectFTP();

src/main/java/ec/edu/epn/consumosriautorizacion/Tasks/Task_SendEmail.java

@@ -28,7 +28,7 @@ public class Task_SendEmail implements Tasklet {
         String subject = "Correo electrónico masivo de prueba";
         String text = "Este es un correo electrónico masivo de prueba enviado desde Spring Boot.";
 
-        emailService.sendEmail(to, subject, text);
+        //emailService.sendEmail(to, subject, text);
         System.out.println("Estado del trabajo: ");
 
 

src/main/java/ec/edu/epn/consumosriautorizacion/Tasks/Task_autorizacion.java

+package ec.edu.epn.consumosriautorizacion.Tasks;
+
+import ec.edu.epn.consumosriautorizacion.controller.ConsultasFacturacionController;
+import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.FacturacionOfflineDTO;
+import ec.edu.epn.consumosriautorizacion.service.EmailService;
+import ec.gob.sri.comprobantes.ws.RecepcionComprobantesOffline;
+import ec.gob.sri.comprobantes.ws.RecepcionComprobantesOfflineService;
+import ec.gob.sri.comprobantes.ws.RespuestaSolicitud;
+import ec.gob.sri.comprobantes.ws.aut.AutorizacionComprobantesOffline;
+import ec.gob.sri.comprobantes.ws.aut.AutorizacionComprobantesOfflineService;
+import ec.gob.sri.comprobantes.ws.aut.RespuestaComprobante;
+import org.springframework.batch.core.StepContribution;
+import org.springframework.batch.core.scope.context.ChunkContext;
+import org.springframework.batch.core.step.tasklet.Tasklet;
+import org.springframework.batch.repeat.RepeatStatus;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.xml.namespace.QName;
+import java.net.URL;
+import java.sql.Timestamp;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+import static java.nio.charset.StandardCharsets.ISO_8859_1;
+import static java.nio.charset.StandardCharsets.UTF_8;
+
+
+@Component
+public class Task_autorizacion implements Tasklet {
+
+
+
+
+
+    private static String  ambiente= "PRODUCCION";
+
+
+   /* @Autowired
+    ConsultasFacturacionController consultas;*/
+
+
+    @Override
+    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
+
+        ConsultasFacturacionController consultas= new ConsultasFacturacionController();
+
+          List<FacturaDTO> listFactContingencia= new ArrayList<FacturaDTO>();
+
+          /**OBTENER LA FECHA ACTUAL**/
+        Date date = new Date();
+        DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        listFactContingencia= consultas.consumoFactContingencia(dateFormat.format(date));
+        /**RECORREMOS LA LISTA DE FACTURAS PARA SU AUTORIZACION*/
+        if(listFactContingencia!=null){
+            for(FacturaDTO dto: listFactContingencia){
+
+                /**ENVIO PARA RECEPCION DE FACTURAS**/
+                FacturacionOfflineDTO offlineRecepcionDTO = new FacturacionOfflineDTO();
+                offlineRecepcionDTO= this.recepcion(dto.getXml());
+
+                if(offlineRecepcionDTO.getEstado().equals("RECIBIDA")){
+
+                    this.envioCorreoRecepcion(dto);
+
+                    dto.setEstadoFactura(offlineRecepcionDTO.getEstado());
+
+                    try {
+                        consultas.actualizarEstadoSRIFact(dto);
+                    }catch(Exception e){
+                        return RepeatStatus.FINISHED;
+                    }
+
+                    /**ENVIO PARA AUTORIZACIÓN DE FACTURA**/
+                    FacturacionOfflineDTO offlineAutorizacionDTO = new FacturacionOfflineDTO();
+
+                    offlineAutorizacionDTO= this.autorizacion(dto.getNumautoriza());
+
+                    if(offlineAutorizacionDTO!=null){
+
+                        if(offlineAutorizacionDTO.getEstado().equals("AUTORIZADO")){
+                            dto.setFechaautoriza(offlineAutorizacionDTO.getFechaAutorizacion().toString());
+                            dto.setEstadoFactura(offlineAutorizacionDTO.getEstado());
+
+
+                            try {
+                                consultas.actualizarSRIFact(dto);
+                            }catch(Exception e){
+                                return RepeatStatus.FINISHED;
+                            }
+
+                        }else{
+                            offlineAutorizacionDTO.setNumeroAutoFac(dto.getIdFactura());
+                            consultas.ingresoErrorSRIFact(offlineAutorizacionDTO);
+                        }
+
+                    }
+                }else{
+
+                    offlineRecepcionDTO.setNumeroAutoFac(dto.getIdFactura());
+                    consultas.ingresoErrorSRIFact(offlineRecepcionDTO);
+
+                }
+
+            }
+        }
+        return  RepeatStatus.FINISHED;
+
+    }
+
+
+
+
+    public FacturacionOfflineDTO recepcion(String xml){
+
+        String val = "";
+        FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+
+        try {
+            RespuestaSolicitud respuesta = new RespuestaSolicitud();
+
+            byte[] bytes = xml.getBytes();
+
+            String wsdl = "https://cel.sri.gob.ec/comprobantes-electronicos-ws/RecepcionComprobantesOffline?wsdl";
+            URL url = new URL(wsdl);
+
+            QName qname = new QName("http://ec.gob.sri.ws.recepcion", "RecepcionComprobantesOfflineService");
+
+            RecepcionComprobantesOfflineService service = new RecepcionComprobantesOfflineService(url, qname);
+            RecepcionComprobantesOffline port = service.getRecepcionComprobantesOfflinePort();  //getRecepcionComprobantesOfflinePort();
+
+            respuesta = port.validarComprobante(bytes);
+
+            /*PARA EL CASO DONDE EL ESTADO SEA NULL**/
+            if (respuesta.getEstado() == null) {
+                if (respuesta.getComprobantes() != null) {
+
+                    try {
+                        offlineDTO.setMensaje(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getMensaje());
+                    } catch (Exception e) {
+                        offlineDTO.setMensaje("NINGUN MENSAJE ENCONTRADO");
+                    }
+
+                    try {
+                        offlineDTO.setInfoAdicional(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
+                    } catch (Exception e) {
+                        offlineDTO.setInfoAdicional("NO DEFINIDO");
+                    }
+
+                    try {
+                        offlineDTO.setIdentificador(Integer.valueOf(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
+                    } catch (Exception e) {
+                        offlineDTO.setIdentificador(0);
+                    }
+
+                    try {
+                        offlineDTO.setTipo(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getTipo());
+                    } catch (Exception e) {
+                        offlineDTO.setTipo("ERROR");
+                    }
+
+                    try {
+                        offlineDTO.setClaveAcceso(respuesta.getComprobantes().getComprobante().get(0).getClaveAcceso());
+                    } catch (Exception e) {
+                        offlineDTO.setClaveAcceso("NO DEFINIDO");
+                    }
+
+                    offlineDTO.setEstado("DEVUELTA - SN");
+
+                }
+            }else{
+                if (respuesta.getEstado().equals("DEVUELTA")) {
+                    try {
+                        offlineDTO.setMensaje(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getMensaje());
+                    } catch (Exception e) {
+                        offlineDTO.setMensaje("NINGUN MENSAJE ENCOTRADO");
+                    }
+
+                    try {
+                        offlineDTO.setInfoAdicional(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
+                    } catch (Exception e) {
+                        offlineDTO.setInfoAdicional("NO DEFINIDO");
+                    }
+
+                    try {
+                        offlineDTO.setIdentificador(Integer.valueOf(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
+                    } catch (Exception e) {
+                        offlineDTO.setIdentificador(0);
+                    }
+
+                    try {
+                        offlineDTO.setTipo(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getTipo());
+                    } catch (Exception e) {
+                        offlineDTO.setTipo("ERROR");
+                    }
+
+                    try {
+                        offlineDTO.setClaveAcceso(respuesta.getComprobantes().getComprobante().get(0).getClaveAcceso());
+                    } catch (Exception e) {
+                        offlineDTO.setClaveAcceso("NO DEFINIDO");
+                    }
+
+                    offlineDTO.setEstado("DEVUELTA");
+                }
+
+                if (respuesta.getEstado().equals("RECIBIDA")) {
+                    offlineDTO.setEstado("RECIBIDA");
+                }
+
+            }
+
+
+
+            System.out.println("ESTADO FACTURA  " + respuesta.getEstado());
+
+            return offlineDTO;
+
+        } catch (Exception e) {
+
+            return offlineDTO;
+        }
+    }
+
+
+    public FacturacionOfflineDTO autorizacion(String numAutorizacion){
+
+        FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+        try {
+
+            String wsdl = "https://cel.sri.gob.ec/comprobantes-electronicos-ws/AutorizacionComprobantesOffline?wsdl";
+            URL url = new URL(wsdl);
+            QName qname = new QName("http://ec.gob.sri.ws.autorizacion", "AutorizacionComprobantesOfflineService");
+            AutorizacionComprobantesOfflineService services = new AutorizacionComprobantesOfflineService(new URL(wsdl), qname);
+            AutorizacionComprobantesOffline port = services.getAutorizacionComprobantesOfflinePort();
+
+
+            RespuestaComprobante respuesta = port.autorizacionComprobante(numAutorizacion);
+
+            if(respuesta.getAutorizaciones()!=null){
+
+                if(respuesta.getAutorizaciones().getAutorizacion().get(0).getEstado().equals("AUTORIZADO")){
+                    offlineDTO.setAmbiente("PRODUCCION");
+                    offlineDTO.setEstado("AUTORIZADO");
+
+                    try {
+                        respuesta.getAutorizaciones().getAutorizacion().get(0).getFechaAutorizacion().toGregorianCalendar().setTimeZone(TimeZone.getTimeZone("ECT"));
+                        offlineDTO.setFechaAutorizacion(Timestamp.valueOf(respuesta.getAutorizaciones().getAutorizacion().get(0).getFechaAutorizacion().toGregorianCalendar().getTimeZone().toString()));
+                    } catch (Exception e) {
+
+                        Calendar cal = Calendar.getInstance();
+                        Date fechaHoy= cal.getTime();
+                        String DATE_FORMAT = "yyyy-MM-dd hh:mm:ss";
+                        TimeZone timeZone = TimeZone.getTimeZone("ECT");
+                        SimpleDateFormat formatterWithTimeZone = new SimpleDateFormat(DATE_FORMAT);
+                        formatterWithTimeZone.setTimeZone(timeZone);
+                        String sDate = formatterWithTimeZone.format(fechaHoy);
+                        SimpleDateFormat formatter = new SimpleDateFormat(DATE_FORMAT);
+                        Date dateWithTimeZone = formatter.parse(sDate);
+
+
+
+
+                        offlineDTO.setFechaAutorizacion(new Timestamp(dateWithTimeZone.getTime()));
+                    }
+
+                }
+
+                if(!respuesta.getAutorizaciones().getAutorizacion().get(0).getEstado().equals("AUTORIZADO")){
+
+                    offlineDTO.setAmbiente("PRODUCCION");
+                    offlineDTO.setEstado("NO AUTORIZADO -ND");
+                    try {
+                        offlineDTO.setMensaje(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getMensaje());
+                    } catch (Exception e) {
+                        offlineDTO.setMensaje("NO DEFIIDO");
+                    }
+
+
+                    try {
+                        offlineDTO.setIdentificador(Integer.valueOf(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
+                    } catch (Exception e) {
+                        offlineDTO.setIdentificador(0);
+                    }
+
+
+                    try {
+                        offlineDTO.setTipo(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getTipo());
+                    } catch (Exception e) {
+                        offlineDTO.setTipo("NO DEFINIDO");
+                    }
+
+                    try {
+                        offlineDTO.setInfoAdicional(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
+                    } catch (Exception e) {
+                        offlineDTO.setInfoAdicional("NINGNUNO");
+                    }
+                }
+            }
+
+            if(respuesta.getNumeroComprobantes().equals("0")){
+                offlineDTO.setAmbiente("PRODUCCION");
+                offlineDTO.setEstado("NO AUTORIZADO SIN ENVIO RECEPCION");
+                offlineDTO.setMensaje("NO DEFIIDO");
+                offlineDTO.setTipo("NO DEFINIDO");
+                offlineDTO.setInfoAdicional("NINGNUNO");
+            }
+
+            return offlineDTO;
+
+        }catch (Exception e){
+            return null;
+        }
+    }
+
+
+
+    public void envioCorreoRecepcion(FacturaDTO factura){
+
+        java.util.List<String> para = new ArrayList<String>();
+
+        if (factura.getXml() != null) {
+            String mail = factura.getEmailCl();
+            if (mail == null || mail.equals("")) {
+                mail = "german.romero@epn.edu.ec";
+            }
+            para.add(mail);
+            String hoyFecha = "";
+            DateFormat fecha = new SimpleDateFormat("yyyy/MM/dd");
+            Date hoy = new Date();
+
+            hoyFecha = fecha.format(hoy);
+
+           // String de = "<facturacion.electronica@epn.edu.ec>";
+            String subject = "EPN FACTURA ELECTRÓNICA";
+            // Cuerpo mensaje
+
+            String cabecera = "<HTML><BODY>  <p align='center' style='margin-right:50px;'> <img src='https://cem.epn.edu.ec/imagenes/logos_institucionales/big_jpg/EPN_logo_big.jpg' width= '300' height='150' style='margin-right:50px;' /> <br/> <br/>";
+            String cuerpo = "<p align='center' style='margin-right:50px;'>" + "<b>Estimado(a): </b> <br/>"
+                    + factura.getNombreCli() + "<br/>"
+                    + "<b>Una nueva Factura Electrónica está disponible para usted  </b><br/>"
+                    + "<b>REFERENCIAS </b> <br/>" + "<b>Factura Número: </b>  " + factura.getIdFactura() + " <br/>"
+                    + "<b>Total Factura: </b>" + String.valueOf(factura.getTotalF()) + " USD <br/>"
+                    + "<b>Fecha Factura: </b>" + hoyFecha + " <br/>" + "<b>Ambiente: </b>" + ambiente + " <br/>"
+                    + "<b>Estado: </b>" + factura.getEstadoSri() + " <br/>" + "<b>Clave de Acceso: </b>"
+                    + factura.getClaveacceso() + " <br/>";
+
+            String pie = "<br/> <br/> <img src='cid:cidpie' style='margin-right:50px;'/></BODY></HTML>";
+
+            byte[] ptext = this.remplazarCaracteresHTML(cuerpo).getBytes(ISO_8859_1);
+            String cuerpoF = new String(ptext, UTF_8);
+
+            String text = cabecera + cuerpoF + pie;
+
+            EmailService emailService= new EmailService();
+            emailService.sendEmail(para, subject, text, "", factura.getIdFactura());
+        }
+
+    }
+
+
+
+    public String remplazarCaracteresHTML(String valor) {
+        try {
+            String A = "&#193;";
+            String E = "&#201;";
+            String I = "&#205;";
+            String O = "&#211;";
+            String U = "&#218;";
+            String a = "&#225;";
+            String e = "&#233;";
+            String i = "&#237;";
+            String o = "&#243;";
+            String u = "&#250;";
+            String Ñ = "&#209;";
+            String ñ = "&#241;";
+
+            valor = valor.replace("á", a).replace("é", e).replace("í", i).replace("ó", o).replace("ú", u)
+                    .replace("Á", A).replace("É", E);
+            valor = valor.replace("Í", I).replace("Ó", O).replace("Ú", U).replace("Ñ", Ñ).replace("ñ", ñ);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return valor;
+    }
+
+
+
+
+}

src/main/java/ec/edu/epn/consumosriautorizacion/Tasks/Task_cargaDocumentacion.java

+package ec.edu.epn.consumosriautorizacion.Tasks;
+
+import ec.edu.epn.consumosriautorizacion.controller.ConsultasFacturacionController;
+import ec.edu.epn.consumosriautorizacion.controller.GeneracionFactOfflinePDF;
+import ec.edu.epn.consumosriautorizacion.controller.GeneracionFactOfflineXML;
+import ec.edu.epn.consumosriautorizacion.dto.DetallefacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.PagosDTO;
+import ec.edu.epn.consumosriautorizacion.dto.UserFactDTO;
+import ec.edu.epn.consumosriautorizacion.service.EmailService;
+import ec.edu.epn.consumosriautorizacion.service.FTPService;
+import ec.edu.epn.consumosriautorizacion.service.FileServiceImp;
+import org.apache.commons.net.util.Base64;
+import org.springframework.batch.core.StepContribution;
+import org.springframework.batch.core.scope.context.ChunkContext;
+import org.springframework.batch.core.step.tasklet.Tasklet;
+import org.springframework.batch.repeat.RepeatStatus;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.crypto.Cipher;
+import javax.crypto.spec.SecretKeySpec;
+import java.io.BufferedInputStream;
+import java.io.FileInputStream;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+import static java.nio.charset.StandardCharsets.ISO_8859_1;
+import static java.nio.charset.StandardCharsets.UTF_8;
+
+@Component
+public class Task_cargaDocumentacion implements Tasklet {
+
+   /* @Autowired
+    ConsultasFacturacionController consultas;
+
+
+    @Autowired
+    FTPService ftpService;*/
+
+
+
+    private static String NUMEROS = "0123456789";
+    private static String MAYUSCULAS = "ABCDEFGHIJKLMNOPQRSTUVWXYZ";
+    private static String MINUSCULAS = "abcdefghijklmnopqrstuvwxyz";
+    private static String ESPECIALES = "ñÑ";
+
+    private static String ambiente= "PRODUCCION";
+
+
+    @Override
+    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
+
+
+        ConsultasFacturacionController consultas= new ConsultasFacturacionController();
+        FTPService ftpService= new FileServiceImp();
+
+        List<FacturaDTO> listFact= new ArrayList<FacturaDTO>();
+        /**OBTENER LA FECHA ACTUAL**/
+        Date date = new Date();
+        DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        listFact= consultas.consumoFactPDF(dateFormat.format(date));
+        /**RECORREMOS LA LISTA DE FACTURAS PARA SU AUTORIZACION*/
+        if(listFact!=null) {
+            for (FacturaDTO dto : listFact) {
+
+                List<DetallefacturaDTO> listDetalle= new ArrayList<DetallefacturaDTO>();
+                List<PagosDTO> listPagos= new ArrayList<PagosDTO>();
+                listDetalle= consultas.consumoDetalleFact(dto.getIdFactura());
+                listPagos= consultas.consumoPagos(dto.getIdFactura());
+                GeneracionFactOfflinePDF pdf= new GeneracionFactOfflinePDF();
+
+                String attchment= pdf.generarPDFFacturaOffline(dto, listDetalle, listPagos);
+
+                BufferedInputStream buffIn = null;
+                buffIn = new BufferedInputStream(new FileInputStream(attchment));
+
+                /**CARGAR FTP FACTURACION*/
+
+                ftpService.uploadFileToFTP(buffIn,
+                        dto.getRucCli().trim() + "_Facturas",
+                        dto.getIdFactura().trim() + "-" + dto.getRucCli().trim() + ".pdf");
+
+                /**CARGAR XML FACTURA**/
+                GeneracionFactOfflineXML xmlDOc= new GeneracionFactOfflineXML();
+                String attchemnXml= xmlDOc.generacionXml(dto);
+
+
+                BufferedInputStream buffInXml = null;
+                buffInXml = new BufferedInputStream(new FileInputStream(attchemnXml));
+
+                ftpService.uploadFileToFTP(buffInXml,
+                        dto.getRucCli().trim() + "_Facturas",
+                        dto.getIdFactura().trim() + "-" + dto.getRucCli().trim() + ".xml");
+
+
+                dto.setPath(dto.getRucCli().trim() + "_Facturas/" +  dto.getRucCli().trim() + ".pdf");
+                dto.setPathxml(dto.getRucCli().trim() + "_Facturas/" +  dto.getRucCli().trim() + ".xml");
+
+                consultas.actualizarPathPdf(dto);
+                this.enviarCorreo(dto, attchment);
+
+
+
+
+            }
+        }
+
+        return  RepeatStatus.FINISHED;
+    }
+
+
+
+
+    public void enviarCorreo(FacturaDTO factura, String attachment) {
+
+        UserFactDTO userF = this.usuarioFact(factura.getRucCli().trim());
+
+
+        java.util.List<String> para = new ArrayList<String>();
+
+        if (factura.getXml() != null) {
+            String mail = factura.getEmailCl();
+            if(mail==null || mail.equals("")){
+                mail= "german.romero@epn.edu.ec";
+            }
+            para.add(mail);
+            String hoyFecha = "";
+            DateFormat fecha = new SimpleDateFormat("yyyy/MM/dd");
+            Date hoy = new Date();
+
+            hoyFecha = fecha.format(hoy);
+
+            String de = "<facturacion.electronica@epn.edu.ec>";
+            String subject = "EPN FACTURA ELECTRÓNICA";
+            // Cuerpo mensaje
+
+            String cabecera = "<HTML><BODY>  <p align='center' style='margin-right:50px;'> <img src='https://cem.epn.edu.ec/imagenes/logos_institucionales/big_jpg/EPN_logo_big.jpg' width= '300' height='150' style='margin-right:50px;' /> <br/> <br/>";
+            String cuerpo = "<p align='center' style='margin-right:50px;'>" + "<b>Estimado(a): </b> <br/>"
+                    + factura.getNombreCli() + "<br/>"
+                    + "<b>Una nueva Factura Electrónica está disponible para usted </b><br/>"
+                    + "<b>REFERENCIAS </b> <br/>" + "<b>Factura Número: </b>  " + factura.getIdFactura() + " <br/>"
+                    + "<b>Total Factura: </b>" + String.valueOf(factura.getTotalF()) + " USD <br/>"
+                    + "<b>Fecha Factura: </b>" + hoyFecha + " <br/>" + "<b>Ambiente: </b>" + ambiente + " <br/>"
+                    + "<b>Clave de Acceso: </b>" + factura.getClaveacceso() + " <br/>"
+                    + "<b>Estado: </b>" + factura.getEstadoSri() + " <br/>"
+                    + " <br/>" + "<b>Fecha Aut: </b>" + factura.getFechaautoriza()
+                    + " <br/>" + "<b>Usted puede revisar este comprobante en: <br/> </b>" + "http://www.epn.edu.ec/sistema-integrado-de-informacion/facturacion-electronica/" + " <br/>"
+                    + "<b>Usuario: </b>" + userF.getUsuario() + " <br/>" + "<b>Contraseña: </b>"
+                    + this.remplazarCaracteresHTML(this.Desencriptar(userF.getClave())) + " <br/>"
+                    + "<b>Si tiene alguna inquietud no dude en contactarnos:  </b>" + " <br/>"
+                    + "<b>     asistencia.tecnica@epn.edu.ec</b>" + " <br/>"
+                    + "<b>DIRECCION DE GESTION DE LA INFORMACION Y PROCESOS</b>";
+
+            String pie = "<br/> <br/> <img src='cid:cidpie' style='margin-right:50px;'/></BODY></HTML>";
+
+
+
+            byte[] ptext = this.remplazarCaracteresHTML(cuerpo).getBytes(ISO_8859_1);
+            String cuerpoF = new String(ptext, UTF_8);
+
+            String text = cabecera + cuerpoF + pie;
+
+            EmailService emailService= new EmailService();
+            emailService.sendEmail(para, subject, text, attachment, factura.getIdFactura());
+        }
+    }
+
+
+
+    public String generaClaves(String key, int length) {
+        String pswd = "";
+        length = 5;
+        for (int i = 0; i < length; i++) {
+            pswd += (key.charAt((int) (Math.random() * key.length())));
+            System.out.println("PSW 1: " + pswd.toString());
+
+        }
+        return pswd;
+    }
+
+
+    public String encriptar(String input) {
+        byte[] crypted = null;
+        String key = "1357908642135790";
+
+        try {
+            SecretKeySpec skey = new SecretKeySpec(key.getBytes(), "AES");
+            Cipher cipher = Cipher.getInstance("AES/ECB/PKCS5Padding");
+            cipher.init(Cipher.ENCRYPT_MODE, skey);
+            byte[] plainTextBytes = input.getBytes("utf-8");
+            crypted = cipher.doFinal(plainTextBytes);
+
+        } catch (Exception e) {
+            System.out.println(e.toString());
+        }
+        return new String(Base64.encodeBase64(crypted));
+    }
+
+
+
+    public UserFactDTO usuarioFact(String ciRucCli) {
+
+        ConsultasFacturacionController consultas= new ConsultasFacturacionController();
+        UserFactDTO usuario= new UserFactDTO();
+                usuario = consultas.consumoUserFact(ciRucCli.trim());
+        try {
+            if (usuario != null) {
+                if (usuario.getClave().trim().equals("")){
+                    usuario.setClave(this.encriptar(this.generaClaves(NUMEROS + MAYUSCULAS + MINUSCULAS + ESPECIALES, 12)));
+                    consultas.actualizarUserFact(usuario);
+                }
+                return usuario;
+
+            } else {
+                usuario = new UserFactDTO();
+                usuario.setUsuario(ciRucCli.trim());
+                usuario.setClave(this.encriptar(this.generaClaves(NUMEROS + MAYUSCULAS + MINUSCULAS + ESPECIALES, 12)));
+                consultas.ingresarUserFact(usuario);
+                return usuario;
+            }
+        } catch (Exception e1) {
+            // TODO Auto-generated catch block
+            e1.printStackTrace();
+            return null;
+        }
+
+    }
+
+    public static String Desencriptar(String input) {
+        byte[] output = null;
+
+
+        String key = "1357908642135790";
+        String base64EncryptedString = "";
+        try {
+            SecretKeySpec skey = new SecretKeySpec(key.getBytes(), "AES");
+            Cipher cipher = Cipher.getInstance("AES/ECB/PKCS5Padding");
+            cipher.init(Cipher.DECRYPT_MODE, skey);
+            byte[] plainTextBytes = input.getBytes("utf-8");
+            output = cipher.doFinal(Base64.decodeBase64(plainTextBytes));
+            base64EncryptedString = new String(output, "UTF-8");
+        } catch (Exception e) {
+            System.out.println(e.toString());
+        }
+        return new String(base64EncryptedString);
+    }
+
+
+    public String remplazarCaracteresHTML(String valor){
+        try {
+            String A= "&#193;";
+            String E= "&#201;";
+            String I= "&#205;";
+            String O= "&#211;";
+            String U= "&#218;";
+            String a= "&#225;";
+            String e= "&#233;";
+            String i= "&#237;";
+            String o= "&#243;";
+            String u= "&#250;";
+            String Ñ= "&#209;";
+            String ñ= "&#241;";
+
+            valor= valor.replace("á", a).replace("é", e).replace("í", i).replace("ó", o).replace("ú", u).replace("Á", A).replace("É", E);
+            valor= valor.replace("Í", I).replace("Ó", O).replace("Ú", U).replace("Ñ", Ñ).replace("ñ", ñ);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return valor;
+    }
+
+
+}

src/main/java/ec/edu/epn/consumosriautorizacion/config/BatchTareasConfig.java

 package ec.edu.epn.consumosriautorizacion.config;
 
-import ec.edu.epn.consumosriautorizacion.Tasks.Tarea3;
-import ec.edu.epn.consumosriautorizacion.Tasks.Task_Ftp;
-import ec.edu.epn.consumosriautorizacion.Tasks.Task_SendEmail;
+import ec.edu.epn.consumosriautorizacion.Tasks.*;
 import org.springframework.batch.core.Job;
 import org.springframework.batch.core.Step;
 import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
@@ -29,27 +27,27 @@ public class BatchTareasConfig {
     @Bean
     public Step step1() {
 
-        return stepBuilderFactory.get("paso1").tasklet(new Task_Ftp()).build();
+        return stepBuilderFactory.get("paso1").tasklet(new Task_autorizacion()).build();
     }
 
     @Bean
     public Step step2() {
 
-        return stepBuilderFactory.get("paso2").tasklet(new Task_SendEmail()).build();
+        return stepBuilderFactory.get("paso2").tasklet(new Task_cargaDocumentacion()).build();
     }
 
-    @Bean
+   /* @Bean
     public Step step3() {
 
         return stepBuilderFactory.get("paso3").tasklet(new Tarea3()).build();
-    }
+    }*/
 
     @Bean
     Job autorizacionLotesJob() {
 
         return jobBuilderFactory.get("autorizacionLotesJob")
-                .start(step3())
-                //.next(step2())
+                .start(step1())
+                .next(step2())
                 //.next(step3())
                 .build();
 

src/main/java/ec/edu/epn/consumosriautorizacion/config/SchPublicConfig.java

+package ec.edu.epn.consumosriautorizacion.config;
+
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.core.env.Environment;
+
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DriverManagerDataSource;
+
+
+import javax.sql.DataSource;
+
+
+@Configuration
+public class SchPublicConfig {
+
+
+/*
+
+    @Value("${spring.datasource.url}")
+    private String url;
+
+
+    @Value("${spring.datasource.username}")
+    private String username;
+
+
+    @Value("${spring.datasource.password}")
+    private String password;
+
+
+    @Value("${spring.datasource.driver-class-name}")
+    private String drivers;
+
+
+    public  JdbcTemplate jdbcTemplate;
+
+
+    @Primary
+    @Bean(name = "pubDataSource")
+    public DataSource adminDatasource() {
+        DriverManagerDataSource dataSource = new DriverManagerDataSource();
+       /* dataSource.setUrl(env.getProperty("spring.datasource.url"));
+        dataSource.setUsername(env.getProperty("spring.datasource.username"));
+        dataSource.setPassword(env.getProperty("spring.datasource.password"));
+        dataSource.setDriverClassName(env.getProperty("spring.datasource.driver-class-name"));*/
+
+     /*   dataSource.setUrl(url);
+        dataSource.setUsername(username);
+        dataSource.setPassword(password);
+        dataSource.setDriverClassName(drivers);
+
+
+        return dataSource;
+    }
+
+
+    @Autowired
+    public SchPublicConfig(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }
+
+
+   /* @Bean
+    public JdbcTemplate jdbcTemplate() {
+        return new JdbcTemplate(adminDatasource());
+    }*/
+
+
+
+
+
+
+}

src/main/java/ec/edu/epn/consumosriautorizacion/controller/ConsultasFacturacionController.java

@@ -3,152 +3,167 @@ package ec.edu.epn.consumosriautorizacion.controller;
 
 
 
+import ec.edu.epn.consumosriautorizacion.config.SchPublicConfig;
 import ec.edu.epn.consumosriautorizacion.dto.*;
-import ec.edu.epn.consumosriautorizacion.service.conexionPostgres;
 
+import ec.edu.epn.consumosriautorizacion.service.conexionPostgres;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import org.springframework.context.annotation.Primary;
+import org.springframework.core.env.Environment;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DriverManagerDataSource;
+import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
+
+import javax.sql.DataSource;
 import java.io.Serializable;
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.Statement;
+import java.sql.*;
 import java.util.ArrayList;
+import java.util.Calendar;
 import java.util.List;
 
+
+
+
+@Configuration
 public class ConsultasFacturacionController implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
 
-   public void consumoFactura(String numAutorizacion){
 
-       FacturaDTO facturaDTO= new FacturaDTO();
-       PreparedStatement ps = null;
-       try {
 
-           Statement stmt = coneccionSQL().createStatement();
-           String sql = "SELECT id_factura as id, " +
-                   "fechafac_f as fechaFac, " +
-                   "subtotal_f as subtotal, descuento_f as descuento, " +
-                   "iva_f as iva, total_f as total, " +
-                   "id_estado_factura as estado," +
-                   "id_punto_facturacion as puntofact," +
-                   "id_caja as caja, tipo_f as tipo," +
-                   "porcentajeiva as porcentajeiva," +
-                   "nombre_e as nombree, direccion_e as direccione," +
-                   "telefono_e as telefonoe, carrera_e as carrerae," +
-                   "cedula_e as cedulae," +
-                   "nropagos, " +
-                   "email_cl as emailcli," +
-                   "estadomail, " +
-                   "claveacceso," +
-                   "numautoriza, " +
-                   "ambiente, emision," +
-                   "estado_sri as estadosri, xml " +
-                   "FROM \"Facturacion\".factura;" +
-                   "WHERE trim(numautoriza)= ?";
-
-
-           ps= coneccionSQL().prepareStatement(sql);
-           ps.setString(1, numAutorizacion);
-
-           ResultSet rs = ps.executeQuery(sql);
-
-           while (rs.next()) {
-              facturaDTO.setIdFactura(rs.getString(1));
-              facturaDTO.setFechafacF(rs.getTimestamp(2));
-              facturaDTO.setSubtotalF(rs.getDouble(3));
-              facturaDTO.setDescuentoF(rs.getDouble(4));
-              facturaDTO.setIvaF(rs.getDouble(5));
-              facturaDTO.setTotalF(rs.getDouble(6));
-              facturaDTO.setEstadoFactura(rs.getString(7));
-              facturaDTO.setPuntoFacturacion(rs.getString(8));
-              facturaDTO.setIdCaja(rs.getInt(9));
-              facturaDTO.setTipoF(rs.getString(10));
-              facturaDTO.setPorcentajeiva(rs.getBigDecimal(11));
-              facturaDTO.setNombreE(rs.getString(12));
-              facturaDTO.setNombreCli(rs.getString(12));
-              facturaDTO.setDireccionE(rs.getString(13));
-              facturaDTO.setDireccionCli(rs.getString(13));
-              facturaDTO.setTelefonoE(rs.getString(14));
-              facturaDTO.setTelefonoCli(rs.getString(14));
-              facturaDTO.setCarreraE(rs.getString(15));
-              facturaDTO.setCedulaE(rs.getString(16));
-              facturaDTO.setCedulaCli(rs.getString(16));
-              facturaDTO.setRucCli(rs.getString(16));
-              facturaDTO.setIdEstudiante(rs.getString(16));
-              facturaDTO.setNropagos(rs.getInt(17));
-              facturaDTO.setEmailCl(rs.getString(18)==null?"":rs.getString(18));
-              facturaDTO.setEstadomail(rs.getString(19));
-              facturaDTO.setClaveacceso(rs.getString(20));
-              facturaDTO.setNumautoriza(rs.getString(21));
-              facturaDTO.setAmbiente(rs.getString(22));
-              facturaDTO.setEmision(rs.getString(23));
-              facturaDTO.setEstadoSri(rs.getString(24));
-              facturaDTO.setXml(rs.getString(25));
+      /*  @Autowired
+        SchPublicConfig config;*/
 
 
-           }
-           conexionPostgres conexionSQL = new conexionPostgres();
-           conexionSQL.closeConnection();
 
+    @Value("${spring.datasource.url}")
+    private String url;
+
+
+    @Value("${spring.datasource.username}")
+    private String username;
+
+
+    @Value("${spring.datasource.password}")
+    private String password;
+
+
+    @Value("${spring.datasource.driver-class-name}")
+    private String drivers;
+
+
+    public  JdbcTemplate jdbcTemplate;
+
+
+   // @Primary
+    @Bean//(name = "pubDataSource")
+    public DataSource adminDatasource() {
+        DriverManagerDataSource dataSource = new DriverManagerDataSource();
+       /* dataSource.setUrl(env.getProperty("spring.datasource.url"));
+        dataSource.setUsername(env.getProperty("spring.datasource.username"));
+        dataSource.setPassword(env.getProperty("spring.datasource.password"));
+        dataSource.setDriverClassName(env.getProperty("spring.datasource.driver-class-name"));*/
+
+        dataSource.setUrl(url);
+        dataSource.setUsername(username);
+        dataSource.setPassword(password);
+        dataSource.setDriverClassName(drivers);
+
+
+        return dataSource;
+    }
+
+    @Bean
+    public JdbcTemplate jdbcTemplate() {
+        return new JdbcTemplate(adminDatasource());
+    }
+
+   /* @Autowired
+    public ConsultasFacturacionController(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }*/
+
+
+    public List<FacturaDTO> consumoFactContingencia(String fecha){
+        List<FacturaDTO> listFact = new ArrayList<FacturaDTO>();
+
+        try {
+
+            listFact= jdbcTemplate().query("SELECT * FROM \"Facturacion\".factura WHERE fechafac_f like ? AND estado_sri LIKE '%CONTINGENCIA%'", BeanPropertyRowMapper.newInstance(FacturaDTO.class), "%" + fecha + "%");
+
+
+            return listFact;
+
+        }catch (Exception e){
+            return null;
+        }
+    }
+
+
+    public List<FacturaDTO> consumoFactPDF(String fecha){
+        List<FacturaDTO> listFact = new ArrayList<FacturaDTO>();
+
+        try {
+
+            listFact= jdbcTemplate().query("SELECT * FROM \"Facturacion\".factura WHERE path IS NULL AND estado_sri = 'AUTORIZADO' AND fechafac_f like ? ", BeanPropertyRowMapper.newInstance(FacturaDTO.class), "%" + fecha + "%");
+
+
+            return listFact;
+
+        }catch (Exception e){
+            return null;
+        }
+    }
+
+
+    public FacturaDTO consumoFactura(String idFactura){
+
+       FacturaDTO facturaDTO= new FacturaDTO();
+       try {
+          facturaDTO= jdbcTemplate().queryForObject("SELECT * FROM \"Facturacion\".factura WHERE trim(id_factura)=? ", BeanPropertyRowMapper.newInstance(FacturaDTO.class), idFactura);
 
+           return facturaDTO;
        }catch (Exception e){
-            facturaDTO= null;
+           return null;
        }
    }
 
 
-   public void consumoDetalleFact(String idFactura){
+   public List<DetallefacturaDTO> consumoDetalleFact(String idFactura){
        List<DetallefacturaDTO> listDetalleFAct= new ArrayList<DetallefacturaDTO>();
-       PreparedStatement ps = null;
+       List<DetallefacturaDTO> listDetalleFActTotal= new ArrayList<DetallefacturaDTO>();
+
        try {
+           listDetalleFAct= jdbcTemplate().query("SELECT * FROM \"Facturacion\".detallefactura WHERE trim(id_factura)=? ", BeanPropertyRowMapper.newInstance(DetallefacturaDTO.class), idFactura);
+
+           for(DetallefacturaDTO dto: listDetalleFAct){
+               if(dto.getIdConcepto()!=null){
+                   dto.setConceptoDTO(this.consumoConcepto(dto.getIdConcepto()));
+               }
+
+               if(dto.getIdServicio()!=null){
+                   dto.setServicioDTO(this.consumoServicio(dto.getIdServicio()));
+               }
 
 
-           String sql ="SELECT id_servicio," +
-                   "id_factura," +
-                   "id_detallefactura," +
-                   "costo_df," +
-                   "unidades_df," +
-                   "costot_df," +
-                   "id_metodo," +
-                   "id_concepto," +
-                   "porcentajeiva," +
-                   "valor_iva,n" +
-                   "subtotal," +
-                   "nombreser" +
-                   "FROM \"Facturacion\".detallefactura WHERE id_factura= ?";
-
-
-           ps= coneccionSQL().prepareStatement(sql);
-           ps.setString(1, idFactura);
-
-           ResultSet rs = ps.executeQuery(sql);
-
-           while (rs.next()) {
-               DetallefacturaDTO detalleDTO= new DetallefacturaDTO();
-               detalleDTO.setIdServicio(rs.getString(1)== null?"":rs.getString(1));
-               detalleDTO.setIdFactura(rs.getString(2));
-               detalleDTO.setIdDetallefactura(rs.getString(3));
-               detalleDTO.setCostoDf(rs.getDouble(4));
-               detalleDTO.setUnidadesDf(rs.getInt(5));
-               detalleDTO.setCostotDf(rs.getDouble(6));
-               detalleDTO.setIdMetodo(rs.getString(7)== null?"":rs.getString(7));
-               detalleDTO.setConcepto(rs.getString(8));
-               detalleDTO.setPorcentajeiva(rs.getBigDecimal(9));
-               detalleDTO.setValorIva(rs.getDouble(10));
-               detalleDTO.setSubtotal(rs.getDouble(11));
-               detalleDTO.setNombreser(rs.getString(12)== null?"":rs.getString(12));
-
-               detalleDTO.setConceptoDTO(this.consumoConcepto(detalleDTO.getConcepto()));
-
-                listDetalleFAct.add(detalleDTO);
+               listDetalleFActTotal.add(dto);
+
            }
 
-           conexionPostgres conexionSQL = new conexionPostgres();
-           conexionSQL.closeConnection();
+
+           return listDetalleFActTotal;
 
        }catch (Exception e){
-           listDetalleFAct= null;
+           return null;
        }
 
 
@@ -157,81 +172,40 @@ public class ConsultasFacturacionController implements Serializable {
 
 
 
-   public void consumoPagos(String idFactura){
+   public List<PagosDTO> consumoPagos(String idFactura){
 
        List<PagosDTO> listPagosDTO= new ArrayList<PagosDTO>();
-       PreparedStatement ps = null;
+       List<PagosDTO> listPagosDTOTotal= new ArrayList<PagosDTO>();
        try {
-
-           String sql ="SELECT id_pagos," +
-                   "id_factura," +
-                   "numero_documento_pa," +
-                   "monto_pa," +
-                   "saldo_pa," +
-                   "id_bancos," +
-                   "id_forma_pago," +
-                   "id_tc," +
-                   "comision_tc" +
-                   "  FROM \"Facturacion\".pagos WHERE id_factura=?";
+           listPagosDTO= jdbcTemplate().query("SELECT * FROM \"Facturacion\".pagos WHERE trim(id_factura)=? ", BeanPropertyRowMapper.newInstance(PagosDTO.class), idFactura);
 
 
-           ps= coneccionSQL().prepareStatement(sql);
-           ps.setString(1, idFactura);
+           for(PagosDTO dto: listPagosDTO){
 
-           ResultSet rs = ps.executeQuery(sql);
+               if(dto.getIdFormaPago()!=null){
 
-           while (rs.next()) {
-               PagosDTO pagosDTO= new PagosDTO();
+                   dto.setFormaPagoDTO(this.consumoFormaPago(dto.getIdFormaPago()));
 
-               pagosDTO.setIdPagos(rs.getString(1));
-               pagosDTO.setIdFactura(rs.getString(2));
-               pagosDTO.setNumeroDocumentoPa(rs.getString(3)==null?"":rs.getString(3));
-               pagosDTO.setMontoPa(rs.getBigDecimal(4));
-               pagosDTO.setSaldoPa(rs.getBigDecimal(5));
-               pagosDTO.setIdBancos(rs.getInt(6));
-               pagosDTO.setIdFormaPago(rs.getString(7));
-               pagosDTO.setIdTc(rs.getString(8));
-               pagosDTO.setComisionTc(rs.getDouble(9));
+               }
 
-               pagosDTO.setFormaPagoDTO(this.consumoFormaPago(pagosDTO.getIdFormaPago()));
-
-               listPagosDTO.add(pagosDTO);
+               listPagosDTOTotal.add(dto);
            }
 
+           return listPagosDTOTotal;
+
 
        }catch (Exception e){
-           listPagosDTO= null;
+           return null;
        }
    }
 
 
    public FormaPagoDTO consumoFormaPago(String idFormaPago){
         FormaPagoDTO formaPagoDTO= new FormaPagoDTO();
-       PreparedStatement ps = null;
 
        try {
 
-           String sql= "SELECT id_forma_pago," +
-                   "nombre_fp," +
-                   "descr_fp," +
-                   "codigo_sri," +
-                   "activo," +
-                   "codigo_sae" +
-                   "FROM \"Facturacion\".forma_pago WHERE id_forma_pago=?;";
-
-           ps= coneccionSQL().prepareStatement(sql);
-           ps.setString(1, idFormaPago);
-
-           ResultSet rs = ps.executeQuery(sql);
-
-           while (rs.next()) {
-                formaPagoDTO.setIdFormaPago(rs.getString(1));
-                formaPagoDTO.setNombreFp(rs.getString(2));
-                formaPagoDTO.setDescrFp(rs.getString(3));
-                formaPagoDTO.setCodigoSri(rs.getString(4));
-                formaPagoDTO.setActivo(rs.getString(5));
-                formaPagoDTO.setCodigoSae(rs.getString(6));
-           }
+           formaPagoDTO= jdbcTemplate().queryForObject("SELECT * FROM \"Facturacion\".forma_pago WHERE trim(id_forma_pago)=? ", BeanPropertyRowMapper.newInstance(FormaPagoDTO.class), idFormaPago);
 
            return formaPagoDTO;
 
@@ -243,23 +217,9 @@ public class ConsultasFacturacionController implements Serializable {
 
    public ConceptoDTO consumoConcepto(String idConcepto){
        ConceptoDTO conceptoDTO = new ConceptoDTO();
-       PreparedStatement ps = null;
-       try {
-
-           String sql= "SELECT id_concepto, nombre_concp" +
-                   "  FROM \"Facturacion\".concepto WHERE id_concepto= ?;";
-
-
-           ps= coneccionSQL().prepareStatement(sql);
-           ps.setString(1, idConcepto);
-
-           ResultSet rs = ps.executeQuery(sql);
-
-           while (rs.next()) {
-               conceptoDTO.setIdConcepto(rs.getString(1));
-               conceptoDTO.setNombreConcp(rs.getString(2));
-           }
 
+       try {
+           conceptoDTO= jdbcTemplate().queryForObject("SELECT * FROM \"Facturacion\".concepto WHERE trim(id_concepto)=? ", BeanPropertyRowMapper.newInstance(ConceptoDTO.class), idConcepto);
 
            return conceptoDTO;
 
@@ -272,29 +232,12 @@ public class ConsultasFacturacionController implements Serializable {
    public ServicioDTO consumoServicio(String idServicio){
 
        ServicioDTO servicioDTO= new ServicioDTO();
-       PreparedStatement ps = null;
+
        try {
-           String sql= "SELECT id_servicio, id_laboratorio," +
-                   "id_tiposerv, nombre_s," +
-                   "descr_s, aux_id_servicio," +
-                   "precio_s" +
-                   "  FROM \"Laboratorios\".servicio WHERE id_servicio= ?;";
-
-           ps= coneccionSQL().prepareStatement(sql);
-           ps.setString(1, idServicio);
-
-           ResultSet rs = ps.executeQuery(sql);
-
-           while (rs.next()) {
-               servicioDTO.setIdServicio(rs.getString(1));
-               servicioDTO.setLaboratorio(rs.getString(2));
-               servicioDTO.setTiposervicio(rs.getString(3));
-               servicioDTO.setNombreS(rs.getString(4));
-               servicioDTO.setDescrS(rs.getString(5));
-               servicioDTO.setAuxIdServicio(rs.getInt(6));
-               servicioDTO.setPrecioS(rs.getFloat(7));
 
-           }
+           servicioDTO= jdbcTemplate().queryForObject("SELECT * FROM \"Laboratorios\".servicio WHERE trim(id_servicio)=? ", BeanPropertyRowMapper.newInstance(ServicioDTO.class), idServicio);
+
+
 
            return servicioDTO;
        }catch (Exception e){
@@ -304,16 +247,118 @@ public class ConsultasFacturacionController implements Serializable {
 
 
 
-    private Connection coneccionSQL() {
+   public void actualizarEstadoSRIFact(FacturaDTO facturaDTO){
+        try {
+
+            String sql= "UPDATE \"Facturacion\".factura SET estado_sri = ? WHERE id_factura= ?;";
+            jdbcTemplate().update(sql, facturaDTO.getEstadoFactura(), facturaDTO.getIdFactura());
+
+        }catch (Exception e){
+            e.getMessage();
+        }
+   }
+
+
+    public void actualizarSRIFact(FacturaDTO facturaDTO){
+        try {
+
+            String sql= "UPDATE \"Facturacion\".factura SET estado_sri = ?, fechaautoriza= ? WHERE id_factura= ?;";
+            jdbcTemplate().update(sql,  facturaDTO.getEstadoFactura(), facturaDTO.getFechaautoriza(), facturaDTO.getIdFactura());
+            System.out.println("FACTURA  ACTUALIZADA CORRECTAMENTE");
+
+        }catch (Exception e){
+            e.getMessage();
+        }
+    }
+
+
+    public void actualizarPathPdf(FacturaDTO facturaDTO){
         try {
-            conexionPostgres conexionSQL = new conexionPostgres();
-            Connection con = conexionSQL.getConnection();
-            return con;
-        } catch (Exception e) {
+
+            String sql= "UPDATE \"Facturacion\".factura SET path = ?, pathxml= ? WHERE id_factura= ?;";
+            jdbcTemplate().update(sql,  facturaDTO.getPath(), facturaDTO.getPathxml(), facturaDTO.getIdFactura());
+            System.out.println("FACTURA  ACTUALIZADA CORRECTAMENTE");
+
+        }catch (Exception e){
+            e.getMessage();
+        }
+    }
+
+
+
+
+    public void ingresoErrorSRIFact(FacturacionOfflineDTO offlineDTO){
+        try {
+
+
+            long now = System.currentTimeMillis();
+            Timestamp sqlTimestamp = new Timestamp(now);
+
+            String sql= "INSERT INTO \"Facturacion\".recepcion_comprobantes_sri(" +
+                        "id_documento, tipo_documento, servicio, fecha_recepcion," +
+                        "estado, tipo, identificador, mensaje, info_adicional)" +
+                            "VALUES (?, ?, ?, ?, ?," +
+                                "?, ?, ?, ?, ?);";
+
+
+            jdbcTemplate().update(sql, offlineDTO.getNumeroAutoFac(), "FACTURA", "VALIDACIÓN", sqlTimestamp,
+                    offlineDTO.getEstado(), offlineDTO.getTipo(), offlineDTO.getIdentificador(), offlineDTO.getMensaje(),
+                    offlineDTO.getInfoAdicional());
+
+            System.out.println("RECEPCION INGRESADA CORRECTAMENTE");
+
+
+        }catch (Exception e){
+            e.getMessage();
+        }
+    }
+
+
+
+    public UserFactDTO consumoUserFact(String rucCli){
+        UserFactDTO userFactDTO= new UserFactDTO();
+
+        try {
+
+            userFactDTO= jdbcTemplate().queryForObject("SELECT * FROM \"Facturacion\".userfact WHERE trim(usuario)=? ", BeanPropertyRowMapper.newInstance(UserFactDTO.class), rucCli);
+
+            return userFactDTO;
+
+        }catch (Exception e){
             return null;
         }
+    }
+
 
+    public void actualizarUserFact(UserFactDTO userFactDTO){
+        try {
+
+            String sql= "UPDATE \"Facturacion\".userfact SET clave = ?;";
+            jdbcTemplate().update(sql,  userFactDTO.getClave());
+            System.out.println("USER FACT  ACTUALIZADA CORRECTAMENTE");
+
+        }catch (Exception e){
+            e.getMessage();
+        }
+    }
+
+
+
+    public void ingresarUserFact(UserFactDTO userFactDTO){
+        try {
+
+            String sql= "INSERT INTO \"Facturacion\".userfact(usuario, clave) VALUES (?, ?);;";
+            jdbcTemplate().update(sql, userFactDTO.getUsuario() ,userFactDTO.getClave());
+            System.out.println("USER FACT  INGRESADA CORRECTAMENTE");
+
+        }catch (Exception e){
+            e.getMessage();
+        }
     }
 
 
+
+
+
+
 }

src/main/java/ec/edu/epn/consumosriautorizacion/controller/GeneracionFactOfflinePDF.java

@@ -35,14 +35,20 @@ import ec.edu.epn.consumosriautorizacion.dto.DetallefacturaDTO;
 import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
 import ec.edu.epn.consumosriautorizacion.dto.PagosDTO;
 import ec.edu.epn.consumosriautorizacion.dto.ServicioDTO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 
 
 public class GeneracionFactOfflinePDF {
-	
+
+
+    //@Value("${es.edu.epn.direccion}")
+   // String locate;
 
 
     public String generarPDFFacturaOffline(FacturaDTO factura,
-                                           List<DetallefacturaDTO> detalle, Double total, Collection<PagosDTO> pagos
+                                           List<DetallefacturaDTO> detalle,  List<PagosDTO> pagos
                                            ) {
 
         String url = "";
@@ -53,7 +59,7 @@ public class GeneracionFactOfflinePDF {
             DateFormat fecha = new SimpleDateFormat("dd/MM/yyyy");
             DateFormat fechaMs = new SimpleDateFormat("dd/MM/yyyy hh:mm:ss");
             hoyFecha = fecha.format(hoy);
-            String locate = "/FacturaUtils/";
+            String locate = "/datos/FacturaUtils/";
             //String locate = "C:/facturacion_electronica/facturaUtils/";
             
             System.out.println("-->" + locate);
@@ -114,12 +120,12 @@ public class GeneracionFactOfflinePDF {
             						"R.U.C.:		1760005620001"  + "\n\n"
             						+ "FACTURA" + "\n\n"            								
             						+ "No. " + factura.getIdFactura() + "\n\n"
-            						+ "N�MERO DE AUTORIZACI�N" + "\n\n"
+            						+ "NÚMERO DE AUTORIZACIÓN" + "\n\n"
             						+ factura.getNumautoriza() + "\n\n"
             						+ "FECHA Y HORA DE 		" + factura.getFechaautoriza() + "\n"
-            						+ "AUTORIZACI�N:" + "\n\n"
+            						+ "AUTORIZACIÓN:" + "\n\n"
             						+ "AMBIENTE:		" + factura.getAmbiente()  + "\n\n"
-            						+ "EMISI�N:		" + factura.getEmision() + "\n\n"
+            						+ "EMISIÓN:		" + factura.getEmision() + "\n\n"
             						+ "	CLAVE DE ACCESO" + "\n\n"));
             
             
@@ -144,8 +150,8 @@ public class GeneracionFactOfflinePDF {
             datoscabecera.setWidthPercentage(100);
             datoscabecera.addCell(createLabelCell3(
             						"Raz�n Social/ Nombres y Apellidos:\t\t\t\t\t\t\t\t\t  " + factura.getNombreCli() + "\n" 
-            						+  "\t\t\t\tidentificaci�n:"  + factura.getRucCli()  + "\n\n"            						
-            						+ "Fecha Emisi�n:	" + hoyFecha));            
+            						+  "\t\t\t\tidentificación:"  + factura.getRucCli()  + "\n\n"
+            						+ "Fecha Emisión:	" + hoyFecha));
 
             document.add(datoscabecera);
 
@@ -192,11 +198,8 @@ public class GeneracionFactOfflinePDF {
                                 + "\n\n"));
                     }
                 } else {
-                    ConsultasFacturacionController consultas= new ConsultasFacturacionController();
-                	ServicioDTO servicio =  consultas.consumoServicio(det.getIdServicio());
-
-					if(servicio==null){
-						if(det.getConcepto()!=null){
+					if(det.getServicioDTO()==null){
+						if(det.getIdConcepto()!=null){
 							 datosfactura.addCell(createLabelCell4(det.getConceptoDTO().getIdConcepto()));
 			                 datosfactura.addCell(createLabelCell4(det.getConceptoDTO().getIdConcepto()));
 			                 datosfactura.addCell(createLabelCell4(det.getUnidadesDf().toString()));
@@ -206,7 +209,7 @@ public class GeneracionFactOfflinePDF {
 						datosfactura.addCell(createLabelCell4(det.getIdServicio()));
 	                    datosfactura.addCell(createLabelCell4(det.getIdServicio()));
 	                    datosfactura.addCell(createLabelCell4(det.getUnidadesDf().toString()));
-	                    datosfactura.addCell(createLabelCell4(servicio.getNombreS()));
+	                    datosfactura.addCell(createLabelCell4(det.getServicioDTO().getNombreS()));
 					}
 
                 }
@@ -242,9 +245,9 @@ public class GeneracionFactOfflinePDF {
             com.itextpdf.text.Font fuente1 = FontFactory.getFont(
                     FontFactory.TIMES_ROMAN, 9);
 
-            String text = "			Informaci�n Adicional " + "\n\n"
-                    + "Direcci�n:		" + factura.getDireccionCli() + "\n\n"
-                    + "Tel�fono:		" + factura.getTelefonoCli() + "\n\n" 
+            String text = "			Información Adicional " + "\n\n"
+                    + "Dirección:		" + factura.getDireccionCli() + "\n\n"
+                    + "Teléfono:		" + factura.getTelefonoCli() + "\n\n"
                     + "Email:		" + factura.getEmailCl() + "\n\n"
             		+ "Forma de Pago:		" + pagosF;
             celdaInfAdicional = new PdfPCell(new Phrase(text, fuente1));

src/main/java/ec/edu/epn/consumosriautorizacion/controller/GeneracionFactOfflineXML.java

@@ -3,6 +3,7 @@ package ec.edu.epn.consumosriautorizacion.controller;
 
 
 import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
+import org.springframework.beans.factory.annotation.Value;
 
 import java.io.BufferedWriter;
 import java.io.File;
@@ -12,13 +13,17 @@ import java.io.IOException;
 public class GeneracionFactOfflineXML {
 
 
+
+
     public String generacionXml(FacturaDTO factura) throws IOException {
 
-        String pathXml= "";
+       // String pathXml= "";
 
         BufferedWriter writer = null;
+        String pathXml="";
 
-        pathXml = "/FacturaUtils/" +  factura.getRucCli().trim() + "-" + factura.getIdFactura().trim() + ".xml";
+        //pathXml = "C:/facturacion_electronica/facturaUtils/" +  factura.getRucCli().trim() + "-" + factura.getIdFactura().trim() + ".xml";
+        pathXml = "/datos/FacturaUtils/" +  factura.getRucCli().trim() + "-" + factura.getIdFactura().trim() + ".xml";
         File file = new File(pathXml);
 
         try {

src/main/java/ec/edu/epn/consumosriautorizacion/controller/JobController.java

@@ -23,6 +23,7 @@ public class JobController {
 
     @PostMapping("/inciarCron")
     public String iniciar(@RequestBody RequestJob taskDefinition) {
+
         taskDefinitionBean.setTaskDefinition(taskDefinition);
         return taskSchedulingService.scheduleATask(taskDefinitionBean, taskDefinition.getCronExpression());
     }

src/main/java/ec/edu/epn/consumosriautorizacion/controller/ProcesoOfflineDocumento.java

+package ec.edu.epn.consumosriautorizacion.controller;
+
+import static java.nio.charset.StandardCharsets.ISO_8859_1;
+import static java.nio.charset.StandardCharsets.UTF_8;
+
+import java.io.BufferedWriter;
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.ObjectOutputStream;
+import java.net.URL;
+import java.sql.Timestamp;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+
+import javax.mail.MessagingException;
+import javax.naming.InitialContext;
+import javax.xml.namespace.QName;
+
+import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.FacturacionOfflineDTO;
+import ec.edu.epn.consumosriautorizacion.service.EmailService;
+import ec.gob.sri.comprobantes.ws.RecepcionComprobantesOffline;
+import ec.gob.sri.comprobantes.ws.RecepcionComprobantesOfflineService;
+import ec.gob.sri.comprobantes.ws.RespuestaSolicitud;
+import ec.gob.sri.comprobantes.ws.aut.AutorizacionComprobantesOffline;
+import ec.gob.sri.comprobantes.ws.aut.AutorizacionComprobantesOfflineService;
+import ec.gob.sri.comprobantes.ws.aut.RespuestaComprobante;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.PathVariable;
+
+@Component
+public class ProcesoOfflineDocumento{
+
+
+	public ProcesoOfflineDocumento() {
+
+	}
+
+	@Autowired
+	ConsultasFacturacionController consultas;
+
+
+	private static String pathPdf, pathXml, ambiente = "PRODUCCION";
+
+
+
+	public void autorizacionesFacturas(){
+		try {
+
+			List<FacturaDTO> listFactura = new ArrayList<FacturaDTO>();
+			//ConsultasFacturacionController consultas= new ConsultasFacturacionController();
+			String fechaConsulta;
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+			fechaConsulta=sdf.format(new Date());
+
+			listFactura= consultas.consumoFactContingencia(fechaConsulta);
+
+			if(listFactura!=null){
+
+				for(FacturaDTO dto: listFactura){
+
+					/**ENVIO PARA RECEPCION DE FACTURAS**/
+					FacturacionOfflineDTO offlineRecepcionDTO = new FacturacionOfflineDTO();
+					offlineRecepcionDTO= this.recepcion(dto.getXml());
+
+					if(offlineRecepcionDTO.getEstado().equals("RECIBIDA")){
+
+						dto.setEstadoFactura(offlineRecepcionDTO.getEstado());
+
+						try {
+							consultas.actualizarEstadoSRIFact(dto);
+						}catch(Exception e){
+							return;
+						}
+
+
+
+						/**ENVIO PARA AUTORIZACIÓN DE FACTURA**/
+						FacturacionOfflineDTO offlineAutorizacionDTO = new FacturacionOfflineDTO();
+
+						offlineAutorizacionDTO= this.autorizacion(dto.getNumautoriza());
+
+						if(offlineRecepcionDTO!=null){
+
+							if(offlineRecepcionDTO.getEstado().equals("AUTORIZADO")){
+								dto.setFechaautoriza(offlineAutorizacionDTO.getFechaAutorizacion().toString());
+								dto.setEstadoFactura(offlineAutorizacionDTO.getEstado());
+
+
+								try {
+									consultas.actualizarSRIFact(dto);
+								}catch(Exception e){
+									return;
+								}
+
+							}else{
+
+								offlineAutorizacionDTO.setNumeroAutoFac(dto.getIdFactura());
+								consultas.ingresoErrorSRIFact(offlineAutorizacionDTO);
+
+							}
+
+						}
+
+
+					}else{
+
+						offlineRecepcionDTO.setNumeroAutoFac(dto.getIdFactura());
+						consultas.ingresoErrorSRIFact(offlineRecepcionDTO);
+
+					}
+
+				}
+
+
+
+
+			}
+
+
+
+		}catch (Exception e){
+			e.getMessage();
+		}
+	}
+
+
+	public FacturacionOfflineDTO recepcion(String xml){
+
+		String val = "";
+		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+
+		try {
+			RespuestaSolicitud respuesta = new RespuestaSolicitud();
+
+			byte[] bytes = val.getBytes();
+
+			String wsdl = "https://cel.sri.gob.ec/comprobantes-electronicos-ws/RecepcionComprobantesOffline?wsdl";
+			URL url = new URL(wsdl);
+
+			QName qname = new QName("http://ec.gob.sri.ws.recepcion", "RecepcionComprobantesOfflineService");
+
+			RecepcionComprobantesOfflineService service = new RecepcionComprobantesOfflineService(url, qname);
+			RecepcionComprobantesOffline port = service.getRecepcionComprobantesOfflinePort();  //getRecepcionComprobantesOfflinePort();
+
+			respuesta = port.validarComprobante(bytes);
+
+			/*PARA EL CASO DONDE EL ESTADO SEA NULL**/
+			if (respuesta.getEstado() == null) {
+				if (respuesta.getComprobantes() != null) {
+
+					try {
+						offlineDTO.setMensaje(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getMensaje());
+					} catch (Exception e) {
+						offlineDTO.setMensaje("NINGUN MENSAJE ENCONTRADO");
+					}
+
+					try {
+						offlineDTO.setInfoAdicional(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
+					} catch (Exception e) {
+						offlineDTO.setInfoAdicional("NO DEFINIDO");
+					}
+
+					try {
+						offlineDTO.setIdentificador(Integer.valueOf(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
+					} catch (Exception e) {
+						offlineDTO.setIdentificador(0);
+					}
+
+					try {
+						offlineDTO.setTipo(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getTipo());
+					} catch (Exception e) {
+						offlineDTO.setTipo("ERROR");
+					}
+
+					try {
+						offlineDTO.setClaveAcceso(respuesta.getComprobantes().getComprobante().get(0).getClaveAcceso());
+					} catch (Exception e) {
+						offlineDTO.setClaveAcceso("NO DEFINIDO");
+					}
+
+					offlineDTO.setEstado("DEVUELTA - SN");
+
+				}
+			}
+
+			if (respuesta.getEstado().equals("DEVUELTA")) {
+				try {
+					offlineDTO.setMensaje(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getMensaje());
+				} catch (Exception e) {
+					offlineDTO.setMensaje("NINGUN MENSAJE ENCOTRADO");
+				}
+
+				try {
+					offlineDTO.setInfoAdicional(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
+				} catch (Exception e) {
+					offlineDTO.setInfoAdicional("NO DEFINIDO");
+				}
+
+				try {
+					offlineDTO.setIdentificador(Integer.valueOf(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
+				} catch (Exception e) {
+					offlineDTO.setIdentificador(0);
+				}
+
+				try {
+					offlineDTO.setTipo(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getTipo());
+				} catch (Exception e) {
+					offlineDTO.setTipo("ERROR");
+				}
+
+				try {
+					offlineDTO.setClaveAcceso(respuesta.getComprobantes().getComprobante().get(0).getClaveAcceso());
+				} catch (Exception e) {
+					offlineDTO.setClaveAcceso("NO DEFINIDO");
+				}
+
+				offlineDTO.setEstado("DEVUELTA");
+			}
+
+			if (respuesta.getEstado().equals("RECIBIDA")) {
+				offlineDTO.setEstado("RECIBIDA");
+			}
+
+			System.out.println("ESTADO FACTURA  " + respuesta.getEstado());
+
+			return offlineDTO;
+
+		} catch (Exception e) {
+
+			return null;
+		}
+	}
+
+
+	public FacturacionOfflineDTO autorizacion(String numAutorizacion){
+
+		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+		try {
+
+			String wsdl = "https://cel.sri.gob.ec/comprobantes-electronicos-ws/AutorizacionComprobantesOffline?wsdl";
+			URL url = new URL(wsdl);
+			QName qname = new QName("http://ec.gob.sri.ws.autorizacion", "AutorizacionComprobantesOfflineService");
+			AutorizacionComprobantesOfflineService services = new AutorizacionComprobantesOfflineService(new URL(wsdl), qname);
+			AutorizacionComprobantesOffline port = services.getAutorizacionComprobantesOfflinePort();
+
+
+			RespuestaComprobante respuesta = port.autorizacionComprobante(numAutorizacion);
+
+			if(respuesta.getAutorizaciones()!=null){
+
+				if(respuesta.getAutorizaciones().getAutorizacion().get(0).getEstado().equals("AUTORIZADO")){
+					offlineDTO.setAmbiente("PRODUCCION");
+					offlineDTO.setEstado("AUTORIZADO");
+
+					try {
+						respuesta.getAutorizaciones().getAutorizacion().get(0).getFechaAutorizacion().toGregorianCalendar().setTimeZone(TimeZone.getTimeZone("ECT"));
+						offlineDTO.setFechaAutorizacion(Timestamp.valueOf(respuesta.getAutorizaciones().getAutorizacion().get(0).getFechaAutorizacion().toGregorianCalendar().getTimeZone().toString()));
+					} catch (Exception e) {
+
+						Calendar cal = Calendar.getInstance();
+						Date fechaHoy= cal.getTime();
+						String DATE_FORMAT = "yyyy-MM-dd hh:mm:ss";
+						TimeZone timeZone = TimeZone.getTimeZone("ECT");
+						SimpleDateFormat formatterWithTimeZone = new SimpleDateFormat(DATE_FORMAT);
+						formatterWithTimeZone.setTimeZone(timeZone);
+						String sDate = formatterWithTimeZone.format(fechaHoy);
+						SimpleDateFormat formatter = new SimpleDateFormat(DATE_FORMAT);
+						Date dateWithTimeZone = formatter.parse(sDate);
+
+
+
+
+						offlineDTO.setFechaAutorizacion(new Timestamp(dateWithTimeZone.getTime()));
+					}
+
+				}
+
+				if(!respuesta.getAutorizaciones().getAutorizacion().get(0).getEstado().equals("AUTORIZADO")){
+
+					offlineDTO.setAmbiente("PRODUCCION");
+					offlineDTO.setEstado("NO AUTORIZADO -ND");
+					try {
+						offlineDTO.setMensaje(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getMensaje());
+					} catch (Exception e) {
+						offlineDTO.setMensaje("NO DEFIIDO");
+					}
+
+
+					try {
+						offlineDTO.setIdentificador(Integer.valueOf(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
+					} catch (Exception e) {
+						offlineDTO.setIdentificador(0);
+					}
+
+
+					try {
+						offlineDTO.setTipo(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getTipo());
+					} catch (Exception e) {
+						offlineDTO.setTipo("NO DEFINIDO");
+					}
+
+					try {
+						offlineDTO.setInfoAdicional(respuesta.getAutorizaciones().getAutorizacion().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
+					} catch (Exception e) {
+						offlineDTO.setInfoAdicional("NINGNUNO");
+					}
+				}
+			}
+
+			if(respuesta.getNumeroComprobantes().equals("0")){
+				offlineDTO.setAmbiente("PRODUCCION");
+				offlineDTO.setEstado("NO AUTORIZADO SIN ENVIO RECEPCION");
+				offlineDTO.setMensaje("NO DEFIIDO");
+				offlineDTO.setTipo("NO DEFINIDO");
+				offlineDTO.setInfoAdicional("NINGNUNO");
+			}
+
+			return offlineDTO;
+
+		}catch (Exception e){
+			return null;
+		}
+	}
+
+
+
+
+
+
+	public void envioCorreoRecepcion(FacturaDTO factura){
+
+		java.util.List<String> para = new ArrayList<String>();
+
+		if (factura.getXml() != null) {
+			String mail = factura.getEmailCl();
+			if (mail == null || mail.equals("")) {
+				mail = "german.romero@epn.edu.ec";
+			}
+			para.add(mail);
+			String hoyFecha = "";
+			DateFormat fecha = new SimpleDateFormat("yyyy/MM/dd");
+			Date hoy = new Date();
+
+			hoyFecha = fecha.format(hoy);
+
+			String de = "<facturacion.electronica@epn.edu.ec>";
+			String subject = "EPN FACTURA ELECTRÓNICA";
+			// Cuerpo mensaje
+
+			String cabecera = "<HTML><BODY>  <p align='center' style='margin-right:50px;'> <img src='cid:cidcabecera' style='margin-right:50px;' /> <br/> <br/>";
+			String cuerpo = "<p align='center' style='margin-right:50px;'>" + "<b>Estimado(a): </b> <br/>"
+					+ factura.getNombreCli() + "<br/>"
+					+ "<b>Una nueva Factura Electrónica está disponible para usted  </b><br/>"
+					+ "<b>REFERENCIAS </b> <br/>" + "<b>Factura Número: </b>  " + factura.getIdFactura() + " <br/>"
+					+ "<b>Total Factura: </b>" + String.valueOf(factura.getTotalF()) + " USD <br/>"
+					+ "<b>Fecha Factura: </b>" + hoyFecha + " <br/>" + "<b>Ambiente: </b>" + ambiente + " <br/>"
+					+ "<b>Estado: </b>" + factura.getEstadoSri() + " <br/>" + "<b>Clave de Acceso: </b>"
+					+ factura.getClaveacceso() + " <br/>";
+
+			String pie = "<br/> <br/> <img src='cid:cidpie' style='margin-right:50px;'/></BODY></HTML>";
+
+			byte[] ptext = this.remplazarCaracteresHTML(cuerpo).getBytes(ISO_8859_1);
+			String cuerpoF = new String(ptext, UTF_8);
+
+			String text = cabecera + cuerpoF + pie;
+
+			java.util.List<String> adjuntos = new ArrayList<String>();
+
+
+			EmailService emailService= new EmailService();
+
+		//	emailService.sendEmail(para, subject, text);
+		}
+
+	}
+
+
+	public String remplazarCaracteresHTML(String valor) {
+		try {
+			String A = "&#193;";
+			String E = "&#201;";
+			String I = "&#205;";
+			String O = "&#211;";
+			String U = "&#218;";
+			String a = "&#225;";
+			String e = "&#233;";
+			String i = "&#237;";
+			String o = "&#243;";
+			String u = "&#250;";
+			String Ñ = "&#209;";
+			String ñ = "&#241;";
+
+			valor = valor.replace("á", a).replace("é", e).replace("í", i).replace("ó", o).replace("ú", u)
+					.replace("Á", A).replace("É", E);
+			valor = valor.replace("Í", I).replace("Ó", O).replace("Ú", U).replace("Ñ", Ñ).replace("ñ", ñ);
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+		return valor;
+	}
+
+
+
+
+
+
+
+}

src/main/java/ec/edu/epn/consumosriautorizacion/controller/SriAutorizacionController.java

 package ec.edu.epn.consumosriautorizacion.controller;
 
 
+import ec.edu.epn.consumosriautorizacion.Tasks.Task_autorizacion;
+import ec.edu.epn.consumosriautorizacion.Tasks.Task_cargaDocumentacion;
+import ec.edu.epn.consumosriautorizacion.dto.DetallefacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
 import ec.edu.epn.consumosriautorizacion.dto.FacturacionOfflineDTO;
+import ec.edu.epn.consumosriautorizacion.dto.PagosDTO;
+import ec.edu.epn.consumosriautorizacion.exceptions.FTPErrors;
+import ec.edu.epn.consumosriautorizacion.service.EmailService;
+import ec.edu.epn.consumosriautorizacion.service.FTPService;
 import ec.gob.sri.comprobantes.ws.RecepcionComprobantesOffline;
 import ec.gob.sri.comprobantes.ws.RecepcionComprobantesOfflineService;
 import ec.gob.sri.comprobantes.ws.aut.AutorizacionComprobantesOffline;
 import ec.gob.sri.comprobantes.ws.aut.AutorizacionComprobantesOfflineService;
 import ec.gob.sri.comprobantes.ws.aut.RespuestaComprobante;
 import ec.gob.sri.comprobantes.ws.RespuestaSolicitud;
+
+import java.io.BufferedInputStream;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.InputStream;
 import java.net.URL;
 import javax.xml.namespace.QName;
+
+import org.springframework.batch.repeat.RepeatStatus;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RestController;
 import java.sql.Timestamp;
+import java.text.DateFormat;
 import java.text.SimpleDateFormat;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.TimeZone;
+import java.util.*;
+
+import static java.nio.charset.StandardCharsets.ISO_8859_1;
+import static java.nio.charset.StandardCharsets.UTF_8;
 
 @RestController
 public class SriAutorizacionController {
 
 
+	@Autowired
+	ConsultasFacturacionController consultas;
 
 
-	@GetMapping("/pruebas")
-	public String pruebas(){
-		return "PRUEBA EXITOSA";
-	}
-
-	@GetMapping("/recepcion/{xml}")
-	public FacturacionOfflineDTO recepcion(@PathVariable String xml){
-
-		String val = "";
-		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
-
-		try {
-			RespuestaSolicitud respuesta = new RespuestaSolicitud();
-
-			byte[] bytes = val.getBytes();
-
-			String wsdl = "https://cel.sri.gob.ec/comprobantes-electronicos-ws/RecepcionComprobantesOffline?wsdl";
-			URL url = new URL(wsdl);
-
-			QName qname = new QName("http://ec.gob.sri.ws.recepcion", "RecepcionComprobantesOfflineService");
-
-			RecepcionComprobantesOfflineService service = new RecepcionComprobantesOfflineService(url, qname);
-			RecepcionComprobantesOffline port = service.getRecepcionComprobantesOfflinePort();  //getRecepcionComprobantesOfflinePort();
-
-			respuesta = port.validarComprobante(bytes);
-
-			/*PARA EL CASO DONDE EL ESTADO SEA NULL**/
-			if (respuesta.getEstado() == null) {
-				if (respuesta.getComprobantes() != null) {
-
-					try {
-						offlineDTO.setMensaje(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getMensaje());
-					} catch (Exception e) {
-						offlineDTO.setMensaje("NINGUN MENSAJE ENCOTRADO");
-					}
-
-					try {
-						offlineDTO.setInfoAdicional(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
-					} catch (Exception e) {
-						offlineDTO.setInfoAdicional("NO DEFINIDO");
-					}
-
-					try {
-						offlineDTO.setIdentificador(Integer.valueOf(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
-					} catch (Exception e) {
-						offlineDTO.setIdentificador(0);
-					}
-
-					try {
-						offlineDTO.setTipo(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getTipo());
-					} catch (Exception e) {
-						offlineDTO.setTipo("ERROR");
-					}
-
-					try {
-						offlineDTO.setClaveAcceso(respuesta.getComprobantes().getComprobante().get(0).getClaveAcceso());
-					} catch (Exception e) {
-						offlineDTO.setClaveAcceso("NO DEFINIDO");
-					}
-
-					offlineDTO.setEstado("DEVUELTA - SN");
-
-				}
-			}
-
-			if (respuesta.getEstado().equals("DEVUELTA")) {
-				try {
-					offlineDTO.setMensaje(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getMensaje());
-				} catch (Exception e) {
-					offlineDTO.setMensaje("NINGUN MENSAJE ENCOTRADO");
-				}
-
-				try {
-					offlineDTO.setInfoAdicional(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getInformacionAdicional());
-				} catch (Exception e) {
-					offlineDTO.setInfoAdicional("NO DEFINIDO");
-				}
-
-				try {
-					offlineDTO.setIdentificador(Integer.valueOf(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getIdentificador()));
-				} catch (Exception e) {
-					offlineDTO.setIdentificador(0);
-				}
+	@Autowired
+	FTPService ftpService;
 
-				try {
-					offlineDTO.setTipo(respuesta.getComprobantes().getComprobante().get(0).getMensajes().getMensaje().get(0).getTipo());
-				} catch (Exception e) {
-					offlineDTO.setTipo("ERROR");
-				}
-
-				try {
-					offlineDTO.setClaveAcceso(respuesta.getComprobantes().getComprobante().get(0).getClaveAcceso());
-				} catch (Exception e) {
-					offlineDTO.setClaveAcceso("NO DEFINIDO");
-				}
-
-				offlineDTO.setEstado("DEVUELTA");
-			}
+	@GetMapping("/pruebas")
+	public String pruebas() throws FTPErrors, FileNotFoundException {
 
-			if (respuesta.getEstado().equals("RECIBIDA")) {
-				offlineDTO.setEstado("RECIBIDA");
-			}
 
-			System.out.println("ESTADO FACTURA  " + respuesta.getEstado());
 
-			return offlineDTO;
+		return "PRUEBA EXITOSA";
+	}
 
-		} catch (Exception e) {
 
-			return new FacturacionOfflineDTO();
-		}
-	}
 
 
 
 	@GetMapping("/autorizacion/{numAutorizacion}")
-	public FacturacionOfflineDTO autorizacion(@PathVariable String numAutorizacion){
+	public FacturacionOfflineDTO autorizaciona(@PathVariable String numAutorizacion){
 		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
 
 		try {
@@ -234,4 +154,241 @@ public class SriAutorizacionController {
 		}
 	}
 
+	@GetMapping("/envioCorreo/{correo}")
+	public FacturacionOfflineDTO envioCorreo(@PathVariable String correo) {
+		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+
+		try {
+
+			java.util.List<String> para = new ArrayList<String>();
+
+
+
+			para.add(correo);
+			String hoyFecha = "";
+			DateFormat fecha = new SimpleDateFormat("yyyy/MM/dd");
+			Date hoy = new Date();
+
+			hoyFecha = fecha.format(hoy);
+
+			String de = "<facturacion.electronica@epn.edu.ec>";
+			String subject = "EPN FACTURA ELECTRÓNICA";
+			// Cuerpo mensaje
+
+			String cabecera = "<HTML><BODY>  <p align='center' style='margin-right:50px;'> <img src='https://cem.epn.edu.ec/imagenes/logos_institucionales/big_jpg/EPN_logo_big.jpg' width= '300' height='150' style='margin-right:50px;' /> <br/> <br/>";
+			String cuerpo = "<p align='center' style='margin-right:50px;'>" + "<b>Estimado(a): </b> <br/>"
+					+ "GERMAN ROMERO" + "<br/>"
+					+ "<b>Una nueva Factura Electrónica está disponible para usted  </b><br/>"
+					+ "<b>REFERENCIAS </b> <br/>" + "<b>Factura Número: </b>  001-001-000001 <br/>"
+					+ "<b>Total Factura: </b> 50 USD <br/>"
+					+ "<b>Fecha Factura: </b>" + hoyFecha + " <br/>" + "<b>Ambiente: </b> PRODUCCION <br/>"
+					+ "<b>Estado: </b> PRUEBAS <br/>" + "<b>Clave de Acceso: </b>"
+					+  " <br/>";
+
+			String pie = "<br/> <br/> <img src='cid:cidpie' style='margin-right:50px;'/></BODY></HTML>";
+
+
+
+			EmailService emailService= new EmailService();
+
+			byte[] ptext =  emailService.remplazarCaracteresHTML(cuerpo).getBytes(ISO_8859_1);
+			String cuerpoF = new String(ptext, UTF_8);
+
+			String text = cabecera + cuerpoF + pie;
+
+			java.util.List<String> adjuntos = new ArrayList<String>();
+
+
+		//	ConsultasFacturacionController consulta= new ConsultasFacturacionController();
+			FacturaDTO facturaDTO= new FacturaDTO();
+			List<DetallefacturaDTO> listDetalle= new ArrayList<DetallefacturaDTO>();
+			List<PagosDTO> listPagos= new ArrayList<PagosDTO>();
+			facturaDTO= consultas.consumoFactura("001-003-0077105");
+			listDetalle= consultas.consumoDetalleFact(facturaDTO.getIdFactura());
+			listPagos= consultas.consumoPagos(facturaDTO.getIdFactura());
+			GeneracionFactOfflinePDF pdf= new GeneracionFactOfflinePDF();
+
+			String attchment= pdf.generarPDFFacturaOffline(facturaDTO, listDetalle, listPagos);
+
+
+
+
+			//emailService.sendEmail(para, subject, text, attchment);
+
+			offlineDTO.setMensaje("CORREO ENVIADO CORRECTAMENTE");
+			return offlineDTO;
+
+		}catch (Exception e){
+
+			FacturacionOfflineDTO offlineDTOerror = new FacturacionOfflineDTO();
+
+			offlineDTOerror.setMensaje(e.getMessage());
+			return offlineDTOerror;
+
+		}
+	}
+
+
+	@GetMapping("/autorizar/{fecha}")
+	public FacturacionOfflineDTO autorizar(@PathVariable String fecha) {
+		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+		List<FacturaDTO> listFactContingencia= new ArrayList<FacturaDTO>();
+		FacturacionOfflineDTO offlineDTOerror = new FacturacionOfflineDTO();
+		try {
+
+		/**OBTENER LA FECHA ACTUAL**/
+		Date date = new Date();
+		DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+		//listFactContingencia= consultas.consumoFactContingencia(dateFormat.format(date));
+			listFactContingencia= consultas.consumoFactContingencia(fecha);
+		/**RECORREMOS LA LISTA DE FACTURAS PARA SU AUTORIZACION*/
+		if(listFactContingencia!=null){
+			offlineDTO.setMensaje("AUTORIZACIONES CORRECTAMENTE REALIZADAS " + listFactContingencia.size());
+			for(FacturaDTO dto: listFactContingencia){
+
+				Task_autorizacion tarea= new Task_autorizacion();
+
+				/**ENVIO PARA RECEPCION DE FACTURAS**/
+				FacturacionOfflineDTO offlineRecepcionDTO = new FacturacionOfflineDTO();
+				offlineRecepcionDTO= tarea.recepcion(dto.getXml());
+
+				if(offlineRecepcionDTO.getEstado().equals("RECIBIDA")){
+
+					tarea.envioCorreoRecepcion(dto);
+
+					dto.setEstadoFactura(offlineRecepcionDTO.getEstado());
+
+					try {
+						consultas.actualizarEstadoSRIFact(dto);
+					}catch(Exception e){
+
+						offlineDTOerror.setMensaje(e.getMessage());
+						return offlineDTOerror;
+					}
+
+					/**ENVIO PARA AUTORIZACIÓN DE FACTURA**/
+					FacturacionOfflineDTO offlineAutorizacionDTO = new FacturacionOfflineDTO();
+
+					offlineAutorizacionDTO= tarea.autorizacion(dto.getNumautoriza());
+
+					if(offlineAutorizacionDTO!=null){
+
+						if(offlineAutorizacionDTO.getEstado().equals("AUTORIZADO")){
+							dto.setFechaautoriza(offlineAutorizacionDTO.getFechaAutorizacion().toString());
+							dto.setEstadoFactura(offlineAutorizacionDTO.getEstado());
+
+
+							try {
+								consultas.actualizarSRIFact(dto);
+							}catch(Exception e){
+								offlineDTOerror.setMensaje(e.getMessage());
+								return offlineDTOerror;
+							}
+
+						}else{
+							offlineAutorizacionDTO.setNumeroAutoFac(dto.getIdFactura());
+							consultas.ingresoErrorSRIFact(offlineAutorizacionDTO);
+						}
+
+					}
+				}else{
+
+					offlineRecepcionDTO.setNumeroAutoFac(dto.getIdFactura());
+					consultas.ingresoErrorSRIFact(offlineRecepcionDTO);
+
+				}
+
+			}
+		}else{
+			offlineDTO.setMensaje("AUTORIZACIONES CORRECTAMENTE REALIZADAS 0");
+		}
+
+			return offlineDTO;
+
+
+		} catch (Exception e) {
+
+			offlineDTOerror.setMensaje(e.getMessage());
+			return offlineDTOerror;
+
+		}
+
+	}
+
+
+
+
+	@GetMapping("/generardoc/{fecha}")
+	public FacturacionOfflineDTO generaddoc(@PathVariable String fecha) {
+		FacturacionOfflineDTO offlineDTO = new FacturacionOfflineDTO();
+		List<FacturaDTO> listFact= new ArrayList<FacturaDTO>();
+		FacturacionOfflineDTO offlineDTOerror = new FacturacionOfflineDTO();
+
+		try {
+			/**OBTENER LA FECHA ACTUAL**/
+			Date date = new Date();
+			DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+			//listFact= consultas.consumoFactContingencia(dateFormat.format(date));
+			listFact= consultas.consumoFactPDF(fecha);
+			/**RECORREMOS LA LISTA DE FACTURAS PARA SU AUTORIZACION*/
+			if(listFact!=null) {
+				for (FacturaDTO dto : listFact) {
+
+					Task_cargaDocumentacion tarea= new Task_cargaDocumentacion();
+
+					List<DetallefacturaDTO> listDetalle= new ArrayList<DetallefacturaDTO>();
+					List<PagosDTO> listPagos= new ArrayList<PagosDTO>();
+					listDetalle= consultas.consumoDetalleFact(dto.getIdFactura());
+					listPagos= consultas.consumoPagos(dto.getIdFactura());
+					GeneracionFactOfflinePDF pdf= new GeneracionFactOfflinePDF();
+
+					String attchment= pdf.generarPDFFacturaOffline(dto, listDetalle, listPagos);
+
+					BufferedInputStream buffIn = null;
+					buffIn = new BufferedInputStream(new FileInputStream(attchment));
+
+					/**CARGAR FTP FACTURACION*/
+
+					ftpService.uploadFileToFTP(buffIn,
+							dto.getRucCli().trim() + "_Facturas",
+							dto.getIdFactura().trim() + "-" + dto.getRucCli().trim() + ".pdf");
+
+					/**CARGAR XML FACTURA**/
+					GeneracionFactOfflineXML xmlDOc= new GeneracionFactOfflineXML();
+					String attchemnXml= xmlDOc.generacionXml(dto);
+
+
+					BufferedInputStream buffInXml = null;
+					buffInXml = new BufferedInputStream(new FileInputStream(attchemnXml));
+
+					ftpService.uploadFileToFTP(buffInXml,
+							dto.getRucCli().trim() + "_Facturas",
+							dto.getIdFactura().trim() + "-" + dto.getRucCli().trim() + ".xml");
+
+
+					dto.setPath(dto.getRucCli().trim() + "_Facturas/" +  dto.getIdFactura().trim() + "-" + dto.getRucCli().trim() + ".pdf");
+					dto.setPathxml(dto.getRucCli().trim() + "_Facturas/" + dto.getIdFactura().trim() + "-" + dto.getRucCli().trim() + ".xml");
+
+					consultas.actualizarPathPdf(dto);
+					tarea.enviarCorreo(dto, attchment);
+
+
+
+
+				}
+			}
+
+
+
+			offlineDTO.setMensaje("DOCUMENTOS GENERADOS CORRECTAMENTE");
+			return offlineDTO;
+
+		}catch (Exception e){
+			offlineDTOerror.setMensaje(e.getMessage());
+			return offlineDTOerror;
+		}
+	}
+
+
+
 }

src/main/java/ec/edu/epn/consumosriautorizacion/dto/DetallefacturaDTO.java

@@ -18,13 +18,15 @@ public class DetallefacturaDTO {
     private String mesArriendo;
     private String nombreser;
     private BigDecimal porcentajeiva;
-    private double subtotal = 0;
+    private double subtotal;
     private Integer unidadesDf;
     private double valorIva;
-    private String concepto;
+    private String idConcepto;
 
     private ConceptoDTO conceptoDTO;
 
+    private ServicioDTO servicioDTO;
+
 
     public String getIdDetallefactura() {
         return idDetallefactura;
@@ -138,12 +140,12 @@ public class DetallefacturaDTO {
         this.valorIva = valorIva;
     }
 
-    public String getConcepto() {
-        return concepto;
+    public String getIdConcepto() {
+        return idConcepto;
     }
 
-    public void setConcepto(String concepto) {
-        this.concepto = concepto;
+    public void setIdConcepto(String idConcepto) {
+        this.idConcepto = idConcepto;
     }
 
     public ConceptoDTO getConceptoDTO() {
@@ -153,4 +155,12 @@ public class DetallefacturaDTO {
     public void setConceptoDTO(ConceptoDTO conceptoDTO) {
         this.conceptoDTO = conceptoDTO;
     }
+
+    public ServicioDTO getServicioDTO() {
+        return servicioDTO;
+    }
+
+    public void setServicioDTO(ServicioDTO servicioDTO) {
+        this.servicioDTO = servicioDTO;
+    }
 }

src/main/java/ec/edu/epn/consumosriautorizacion/dto/UserFactDTO.java

+package ec.edu.epn.consumosriautorizacion.dto;
+
+public class UserFactDTO {
+
+    private String usuario;
+
+
+    private String clave;
+
+    public String getUsuario() {
+        return usuario;
+    }
+
+    public void setUsuario(String usuario) {
+        this.usuario = usuario;
+    }
+
+    public String getClave() {
+        return clave;
+    }
+
+    public void setClave(String clave) {
+        this.clave = clave;
+    }
+}

src/main/java/ec/edu/epn/consumosriautorizacion/service/EmailService.java

 package ec.edu.epn.consumosriautorizacion.service;
 
+import ec.edu.epn.consumosriautorizacion.dto.DetallefacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.FacturaDTO;
+import ec.edu.epn.consumosriautorizacion.dto.PagosDTO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.*;
 import org.springframework.mail.SimpleMailMessage;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.mail.javamail.JavaMailSenderImpl;
+import org.springframework.mail.javamail.MimeMessageHelper;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
 
+import javax.activation.DataSource;
+import javax.mail.MessagingException;
+import javax.mail.internet.MimeMessage;
+import javax.mail.util.ByteArrayDataSource;
+import java.io.*;
 import java.util.List;
 import java.util.Properties;
 
@@ -15,34 +26,87 @@ import java.util.Properties;
 public class EmailService {
     @Autowired
     private JavaMailSender javaMailSender;
-    @Value("${spring.mail.host}")
-    private String host;
 
-    @Value("${spring.mail.port}")
-    private int port;
 
-    @Value("${spring.mail.username}")
-    private String username;
 
-    @Value("${spring.mail.password}")
-    private String password;
 
     @Async
-    public void sendEmail(List<String> to, String subject, String text) {
-        JavaMailSenderImpl javaMailSender = new JavaMailSenderImpl();
-        javaMailSender.setHost(host);
-        javaMailSender.setPort(port);
-        javaMailSender.setUsername(username);
-        javaMailSender.setPassword(password);
-        Properties props = javaMailSender.getJavaMailProperties();
-        props.put("mail.transport.protocol", "smtp");
-        props.put("mail.smtp.auth", "true");
-        props.put("mail.smtp.starttls.enable", "true");
-        props.put("mail.debug", "true");
-        SimpleMailMessage message = new SimpleMailMessage();
-        message.setTo(to.toArray(new String[to.size()]));
-        message.setSubject(subject);
-        message.setText(text);
-        javaMailSender.send(message);
+    public void sendEmail(List<String> to, String subject, String text, String attachment, String idFactura) {
+        try {
+            JavaMailSenderImpl javaMailSender = new JavaMailSenderImpl();
+            javaMailSender.setHost("smtp.office365.com");
+            javaMailSender.setPort(587);
+            javaMailSender.setUsername("facturacion.electronica@epn.edu.ec");
+            javaMailSender.setPassword("Epndgip2023*$");
+            Properties props = javaMailSender.getJavaMailProperties();
+            props.put("mail.transport.protocol", "smtp");
+            props.put("mail.smtp.auth", "true");
+            props.put("mail.smtp.starttls.enable", "true");
+            props.put("mail.debug", "true");
+
+
+
+            MimeMessage mimeMessage = javaMailSender.createMimeMessage();
+            MimeMessageHelper messageHelper = new MimeMessageHelper(mimeMessage, true, "utf-8");
+            mimeMessage.setContent(text.toString(), "text/html;charset=utf-8");
+            messageHelper.setTo(to.toArray(new String[to.size()]));
+            messageHelper.setFrom("facturacion.electronica@epn.edu.ec");
+            messageHelper.setSubject(subject);
+
+
+            //// AGREGAR FACTURA PARA ENVIO
+
+            if(!attachment.equals("")){
+                System.out.println("ARCHIVOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOOO" + attachment);
+
+                File initialFile = new File(attachment);
+                InputStream targetStream = new FileInputStream(initialFile);
+                DataSource content = new ByteArrayDataSource(targetStream, "application/octet-stream");
+                messageHelper.addAttachment("pruebas.pdf",
+                        content);
+                javaMailSender.send(mimeMessage);
+                System.out.printf("SEND MAILIN PE..");
+            }
+            
+
+
+
+
+
+            javaMailSender.send(mimeMessage);
+
+        }catch(Exception e){
+            e.getMessage();
+        }
+
+    }
+
+
+
+
+
+    public String remplazarCaracteresHTML(String valor) {
+        try {
+            String A = "&#193;";
+            String E = "&#201;";
+            String I = "&#205;";
+            String O = "&#211;";
+            String U = "&#218;";
+            String a = "&#225;";
+            String e = "&#233;";
+            String i = "&#237;";
+            String o = "&#243;";
+            String u = "&#250;";
+            String Ñ = "&#209;";
+            String ñ = "&#241;";
+
+            valor = valor.replace("á", a).replace("é", e).replace("í", i).replace("ó", o).replace("ú", u)
+                    .replace("Á", A).replace("É", E);
+            valor = valor.replace("Í", I).replace("Ó", O).replace("Ú", U).replace("Ñ", Ñ).replace("ñ", ñ);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return valor;
     }
 }

src/main/java/ec/edu/epn/consumosriautorizacion/service/FTPService.java

@@ -4,6 +4,7 @@ package ec.edu.epn.consumosriautorizacion.service;
 import ec.edu.epn.consumosriautorizacion.exceptions.FTPErrors;
 import org.springframework.stereotype.Service;
 
+import java.io.BufferedInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 
@@ -11,7 +12,7 @@ import java.io.InputStream;
 public interface FTPService {
     void connectToFTP() throws FTPErrors, FTPErrors;
 
-    void uploadFileToFTP(InputStream input, String ftpHostDir, String serverFilename) throws FTPErrors;
+    void uploadFileToFTP(BufferedInputStream input, String ftpHostDir, String serverFilename) throws FTPErrors;
 
     void downloadFileFromFTP(String ftpRelativePath, String copytoPath) throws FTPErrors;
 

src/main/java/ec/edu/epn/consumosriautorizacion/service/FileServiceImp.java

@@ -67,6 +67,7 @@ public class FileServiceImp implements FTPService {
         }
         try {
             ftpconnection.login(ftpUserName, ftpuserPassword);
+
         } catch (IOException e) {
             ErrorMessage errorMessage = new ErrorMessage(-3, "El usuario=" + ftpUserName + ", y el pass=**** no fueron válidos para la autenticación.");
             logger.error(errorMessage.toString());
@@ -80,6 +81,8 @@ public class FileServiceImp implements FTPService {
             throw new FTPErrors(errorMessage);
         }
         ftpconnection.enterLocalPassiveMode();
+
+        System.out.println("CONEXION EXITOSA");
     }
 
     public  String stripAccents(String s)
@@ -107,10 +110,17 @@ public class FileServiceImp implements FTPService {
     // @Async("threadPoolTaskExecutor")
     @Async
     @Override
-    public void uploadFileToFTP(InputStream input, String ftpHostDir, String serverFilename) throws FTPErrors {
+    public void uploadFileToFTP(BufferedInputStream input, String ftpHostDir, String serverFilename) throws FTPErrors {
         try {
            serverFilename = new String(serverFilename.getBytes("utf-8"));
-            this.ftpconnection.storeFile(ftpHostDir + serverFilename, input);
+
+           int creacion= this.ftpconnection.mkd(ftpHostDir);
+
+           this.ftpconnection.changeWorkingDirectory("\\" + ftpHostDir);
+           this.ftpconnection.setFileType(FTP.BINARY_FILE_TYPE);
+            this.ftpconnection.storeFile(serverFilename, input);
+            this.ftpconnection.logout();
+            this.ftpconnection.disconnect();
 
         } catch (Exception e) {
             ErrorMessage errorMessage = new ErrorMessage(-5, "No se pudo subir el archivo al servidor.");

src/main/java/ec/edu/epn/consumosriautorizacion/service/TaskSchedulingService.java

@@ -7,10 +7,7 @@ import org.springframework.scheduling.TaskScheduler;
 import org.springframework.scheduling.support.CronTrigger;
 import org.springframework.stereotype.Service;
 
-import java.util.HashMap;
-import java.util.Map;
-import java.util.TimeZone;
-import java.util.UUID;
+import java.util.*;
 import java.util.concurrent.ScheduledFuture;
 
 @Service
@@ -25,7 +22,8 @@ public class TaskSchedulingService {
         UUID uuid = UUID.randomUUID();
         String jobId = uuid.toString();
         System.out.println("Cron con job id: " + jobId + " y cron : " + cronExpression);
-        ScheduledFuture<?> scheduledTask = taskScheduler.schedule(tasklet, new CronTrigger(cronExpression, TimeZone.getTimeZone(TimeZone.getDefault().getID())));
+        //ScheduledFuture<?> scheduledTask = taskScheduler.schedule(tasklet, new CronTrigger(cronExpression, TimeZone.getTimeZone(TimeZone.getDefault().getID())));
+        ScheduledFuture<?> scheduledTask = taskScheduler.schedule(tasklet, new CronTrigger("0 0/5 8,9,10,11,12,13,14,15,16,17,18 * * ?"));
         jobsMap.put(jobId, scheduledTask);
         return "CRON-JOB:{id: " + jobId + ", cron : " + cronExpression + "}";
     }

src/main/resources/application.properties

@@ -12,8 +12,8 @@ spring.mail.properties.mail.smtp.from=smtp.office365.com
 ##### SMTP #####
 spring.mail.host=smtp.office365.com
 spring.mail.port=587
-spring.mail.username=desarrollo.dgip@epn.edu.ec
-spring.mail.password=Generico2022**
+spring.mail.username=facturacion.electronica@epn.edu.ec
+spring.mail.password=Epndgip2023*$
 
 ##### CONEXION FTP #####
 #Multipart file config
@@ -24,13 +24,31 @@ spring.servlet.multipart.file-size-threshold=2KB
 spring.servlet.multipart.max-file-size=800MB
 # Max Request Size
 spring.servlet.multipart.max-request-size=800MB
-ftp.server=localhost
+ftp.server=172.31.5.24
 ftp.port=21
-ftp.userName=epnFtp
-ftp.userPassword=epn-test
+ftp.userName=facturaciona
+ftp.userPassword=12345678
 spring.messages.encoding=UTF-8
 server.tomcat.uri-encoding=UTF-8
 
+
+
+####CONEXION A BDDCORPEPN
+spring.datasource.url=jdbc:postgresql://172.31.5.10:5432/bddcorpepn
+spring.datasource.username=seguridad
+spring.datasource.password=seguridad
+
+##### SOPORTE DRIVERS POSTGRES #####
+spring.datasource.driver-class-name=org.postgresql.Driver
+spring.jpa.database-platform=org.hibernate.dialect.PostgreSQL93Dialect
+spring.batch.jdbc.initialize-schema=always
+
+
+####### CARGA ARCHIVOS FACTURACION
+#es.edu.epn.direccion=/FacturaUtils/
+
+
+
 #### PARA LOS SCHEDULE #####
 # -------    0 * * * * * se traduce en:
 # El método se ejecutará cuando los segundos sean igual a 0