Endpoints Qr

build.gradle

@@ -16,6 +16,8 @@ repositories {
 }
 
 dependencies {
+    implementation files('libs/ojdbc11.jar')
+    runtimeOnly("com.oracle.database.jdbc:ojdbc11")
     implementation("io.micronaut.sql:micronaut-jdbc")
     
     annotationProcessor("io.micronaut:micronaut-http-validation")
@@ -26,7 +28,6 @@ dependencies {
     implementation("jakarta.validation:jakarta.validation-api")
     compileOnly("io.micronaut:micronaut-http-client")
     runtimeOnly("ch.qos.logback:logback-classic")
-    runtimeOnly("com.oracle.database.jdbc:ojdbc11")
     //runtimeOnly("com.oracle.database.jdbc:ojdbc8:19.3.0.0")
     implementation("io.micronaut.data:micronaut-data-jdbc")
     testImplementation("io.micronaut:micronaut-http-client")

src/main/java/jumapacelaya/gob/mx/qr/controlador/QrControlador.java

@@ -0,0 +1,83 @@
+package jumapacelaya.gob.mx.qr.controlador;
+
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+import io.micronaut.http.HttpResponse;
+import io.micronaut.http.annotation.Body;
+import io.micronaut.http.annotation.Controller;
+import io.micronaut.http.annotation.Get;
+import io.micronaut.http.annotation.PathVariable;
+import io.micronaut.http.annotation.Post;
+import jakarta.inject.Inject;
+import jumapacelaya.gob.mx.qr.dto.OtInapamDTO;
+import jumapacelaya.gob.mx.qr.dto.accionPredioDTO;
+import jumapacelaya.gob.mx.qr.dto.pagoQrDTO;
+import jumapacelaya.gob.mx.qr.dto.predioQrDTO;
+import jumapacelaya.gob.mx.qr.dto.turnoDTO;
+import jumapacelaya.gob.mx.qr.servicio.QrServicio;
+import io.micronaut.http.MediaType;
+
+@Controller("/qr")
+public class QrControlador {
+
+    @Inject
+    QrServicio servicio;
+
+    @Get("/consupredio/{nomcte}/{calle}/{numext}")
+    public HttpResponse<List<predioQrDTO>> consupredio(String nomcte, String calle, String numext) {
+        List<predioQrDTO> resultados = servicio.buscarPredios(nomcte, calle, numext);
+        return HttpResponse.ok(resultados);
+    }
+
+    @Post("/consupredio/acc")
+    public HttpResponse<accionPredioDTO> consuPredioAccion(@Body accionPredioDTO dto) {
+        String inapam = servicio.buscarINAPAMPorPredio(dto.getPredioid());
+        dto.setInapam(inapam);
+        return HttpResponse.ok(dto);
+    }
+
+    @Get("/consupredio/{predioid}")
+    public HttpResponse<Map<String, Object>> obtenerPredioPorId(@PathVariable Long predioid) {
+        Map<String, Object> respuesta = new HashMap<>();
+        respuesta.put("predioid", predioid);
+        return HttpResponse.ok(respuesta);
+    }
+
+    @Post("/consupredio/otinapam")
+    public HttpResponse<?> generarOtInapam(@Body OtInapamDTO dto) {
+        try {
+            String mensaje = servicio.generarOtInapam(
+                dto.getPredioid(),
+                dto.getDireccion(),
+                dto.getObservacion()
+            );
+
+            return HttpResponse.ok(new LinkedHashMap<>() {{
+                put("mensaje", mensaje);
+                put("predioid", dto.getPredioid());
+                put("nomcte", dto.getNomcte());
+                put("direccion", dto.getDireccion());
+                put("obs", dto.getObservacion());
+            }});
+        } catch (Exception e) {
+            return HttpResponse.serverError(new LinkedHashMap<>() {{
+                put("error", e.getMessage());
+            }});
+        }
+    }
+
+    @Get(uri = "/pagoqr/{predioid}/{pagoid}", produces = MediaType.APPLICATION_JSON)
+    public Optional<pagoQrDTO> obtenerPagoQr(@PathVariable Long predioid, @PathVariable String pagoid) {
+        return servicio.obtenerPagoQr(predioid, pagoid);
+    }
+
+    @Get("/turnos/{puntoid}")
+    public HttpResponse<List<turnoDTO>> obtenerTurnos(@PathVariable int puntoid) {
+        List<turnoDTO> turnos = servicio.obtenerTurnosPorPunto(puntoid);
+        return HttpResponse.ok(turnos);
+    }
+}

src/main/java/jumapacelaya/gob/mx/qr/dto/OtInapamDTO.java

@@ -0,0 +1,29 @@
+package jumapacelaya.gob.mx.qr.dto;
+
+public class OtInapamDTO {
+    private Long predioid;
+    private String nomcte;
+    private String direccion;
+    private String observacion;
+
+    // Getters y setters
+    public Long getPredioid() { return predioid; }
+    public void setPredioid(Long predioid) {
+        this.predioid = predioid;
+    }
+
+    public String getNomcte() { return nomcte; }
+    public void setNomcte(String nomcte) {
+        this.nomcte = nomcte;
+    }
+
+    public String getDireccion() { return direccion; }
+    public void setDireccion(String direccion) {
+        this.direccion = direccion;
+    }
+
+    public String getObservacion() { return observacion; }
+    public void setObservacion(String observacion) {
+        this.observacion = observacion;
+    }
+}

src/main/java/jumapacelaya/gob/mx/qr/dto/accionPredioDTO.java

@@ -0,0 +1,42 @@
+package jumapacelaya.gob.mx.qr.dto;
+
+public class accionPredioDTO {
+    private Integer predioid;
+    private String nomcte;
+    private String direccion;
+    private String tarifa;
+    private String edopredio;
+    private String inapam;
+
+    // Getters y Setters
+    public Integer getPredioid() { return predioid; }
+    public void setPredioid(Integer predioid) {
+        this.predioid = predioid;
+    }
+
+    public String getNomcte() { return nomcte; }
+    public void setNomcte(String nomcte) {
+        this.nomcte = nomcte;
+    }
+
+    public String getDireccion() { return direccion; }
+    public void setDireccion(String direccion) {
+        this.direccion = direccion;
+    }
+
+    public String getTarifa() { return tarifa; }
+    public void setTarifa(String tarifa) {
+        this.tarifa = tarifa;
+    }
+
+    public String getEdopredio() { return edopredio; }
+    public void setEdopredio(String edopredio) {
+        this.edopredio = edopredio;
+    }
+
+    public String getInapam() { return inapam; }
+    public void setInapam(String inapam) {
+        this.inapam = inapam;
+    }
+
+}

src/main/java/jumapacelaya/gob/mx/qr/dto/pagoQrDTO.java

@@ -0,0 +1,29 @@
+package jumapacelaya.gob.mx.qr.dto;
+
+public class pagoQrDTO {
+    private Long predioid;
+    private String nomcliente;
+    private String direccion;
+    private String pagoid;
+
+    // Getters y Setters
+    public Long getPredioid() { return predioid; }
+    public void setPredioid(Long predioid) {
+        this.predioid = predioid;
+    }
+
+    public String getNomcliente() { return nomcliente; }
+    public void setNomcliente(String nomcliente) {
+        this.nomcliente = nomcliente;
+    }
+
+    public String getDireccion() { return direccion; }
+    public void setDireccion(String direccion) {
+        this.direccion = direccion;
+    }
+
+    public String getPagoid() { return pagoid; }
+    public void setPagoid(String pagoid) {
+        this.pagoid = pagoid;
+    }
+}

src/main/java/jumapacelaya/gob/mx/qr/dto/predioQrDTO.java

@@ -0,0 +1,82 @@
+package jumapacelaya.gob.mx.qr.dto;
+
+public class predioQrDTO {
+
+    private Integer predioid;
+    private String direccion;
+    private Integer direcid;
+    private String colonia;
+    private String calle;
+    private Integer clienteid;
+    private String nombre;
+    private Integer propietarioid;
+    private String ctalocaliza;
+    private String contrato;
+    private String ctaant;
+    private String zonafactid;
+    private String tarifa;
+    private String usoid;
+    private String actividadid;
+    private String edopredioid;
+    private String metsumid;
+    private String serialmed;
+    private String instalmed;
+
+    // Getters y setters
+    public Integer getPredioid() { return predioid; }
+    public void setPredioid(Integer predioid) { this.predioid = predioid; }
+
+    public String getDireccion() { return direccion; }
+    public void setDireccion(String direccion) { this.direccion = direccion; }
+
+    public Integer getDirecid() { return direcid; }
+    public void setDirecid(Integer direcid) { this.direcid = direcid; }
+
+    public String getColonia() { return colonia; }
+    public void setColonia(String colonia) { this.colonia = colonia; }
+
+    public String getCalle() { return calle; }
+    public void setCalle(String calle) { this.calle = calle; }
+
+    public Integer getClienteid() { return clienteid; }
+    public void setClienteid(Integer clienteid) { this.clienteid = clienteid; }
+
+    public String getNombre() { return nombre; }
+    public void setNombre(String nombre) { this.nombre = nombre; }
+
+    public Integer getPropietarioid() { return propietarioid; }
+    public void setPropietarioid(Integer propietarioid) { this.propietarioid = propietarioid; }
+
+    public String getCtalocaliza() { return ctalocaliza; }
+    public void setCtalocaliza(String ctalocaliza) { this.ctalocaliza = ctalocaliza; }
+
+    public String getContrato() { return contrato; }
+    public void setContrato(String contrato) { this.contrato = contrato; }
+
+    public String getCtaant() { return ctaant; }
+    public void setCtaant(String ctaant) { this.ctaant = ctaant; }
+
+    public String getZonafactid() { return zonafactid; }
+    public void setZonafactid(String zonafactid) { this.zonafactid = zonafactid; }
+
+    public String getTarifa() { return tarifa; }
+    public void setTarifa(String tarifa) { this.tarifa = tarifa; }
+
+    public String getUsoid() { return usoid; }
+    public void setUsoid(String usoid) { this.usoid = usoid; }
+
+    public String getActividadid() { return actividadid; }
+    public void setActividadid(String actividadid) { this.actividadid = actividadid; }
+
+    public String getEdopredioid() { return edopredioid; }
+    public void setEdopredioid(String edopredioid) { this.edopredioid = edopredioid; }
+
+    public String getMetsumid() { return metsumid; }
+    public void setMetsumid(String metsumid) { this.metsumid = metsumid; }
+
+    public String getSerialmed() { return serialmed; }
+    public void setSerialmed(String serialmed) { this.serialmed = serialmed; }
+
+    public String getInstalmed() { return instalmed; }
+    public void setInstalmed(String instalmed) { this.instalmed = instalmed; }
+}

src/main/java/jumapacelaya/gob/mx/qr/dto/turnoDTO.java

@@ -0,0 +1,12 @@
+package jumapacelaya.gob.mx.qr.dto;
+
+public class turnoDTO {
+    private String servicio;
+    private String estado;
+
+    public String getServicio() { return servicio; }
+    public void setServicio(String servicio) { this.servicio = servicio; }
+
+    public String getEstado() { return estado; }
+    public void setEstado(String estado) { this.estado = estado; }
+}

src/main/java/jumapacelaya/gob/mx/qr/repositorio/QrRepositorio.java

@@ -0,0 +1,5 @@
+package jumapacelaya.gob.mx.qr.repositorio;
+
+public class QrRepositorio {
+
+}

src/main/java/jumapacelaya/gob/mx/qr/servicio/QrServicio.java

@@ -0,0 +1,238 @@
+package jumapacelaya.gob.mx.qr.servicio;
+
+import jakarta.inject.Singleton;
+import jumapacelaya.gob.mx.qr.dto.pagoQrDTO;
+import jumapacelaya.gob.mx.qr.dto.predioQrDTO;
+import jumapacelaya.gob.mx.qr.dto.turnoDTO;
+import oracle.jdbc.OraclePreparedStatement;
+
+import javax.sql.DataSource;
+
+import io.micronaut.data.connection.annotation.Connectable;
+import io.micronaut.transaction.annotation.Transactional;
+
+import java.sql.*;
+import java.util.*;
+
+@Singleton
+public class QrServicio {
+
+    private final DataSource dataSource;
+
+    public QrServicio(DataSource dataSource) {
+        this.dataSource = dataSource;
+    }
+
+    @Transactional
+    public List<predioQrDTO> buscarPredios(String nomcte, String calle, String numext) {
+        List<predioQrDTO> predios = new ArrayList<>();
+
+        String pNomCliente = nomcte.equalsIgnoreCase("X") ? null : nomcte.toUpperCase();
+        String pNomCalle = calle.equalsIgnoreCase("X") ? null : calle.toUpperCase();
+        String pNumExt = numext.equalsIgnoreCase("X") ? null : numext.toUpperCase();
+
+        StringBuilder query = new StringBuilder();
+        query.append("SELECT DISTINCT predioid, fn_get_direccion(d.direcid) AS direccion, p.direcid, ")
+             .append("co.nombre AS colonia, ca.nombre AS calle, c.clienteid, c.nombre, propietarioid, ")
+             .append("ctalocaliza, contrato, ctaant, zonafactid, fn_get_tarifa(p.predioid) AS tarifa, ")
+             .append("usoid, actividadid, edopredioid, metsumid, serialmed, instalmed ")
+             .append("FROM predios p ")
+             .append("INNER JOIN clientes c ON p.clienteid = c.clienteid ")
+             .append("INNER JOIN direcciones d ON p.direcid = d.direcid ")
+             .append("INNER JOIN colonias co USING (coloniaid) ")
+             .append("INNER JOIN calles ca USING (coloniaid, calleid) ")
+             .append("WHERE ROWNUM <= 10 ");
+
+        if (pNomCliente != null) query.append("AND regexp_like(c.nombre, ?) ");
+        if (pNomCalle != null) query.append("AND regexp_like(ca.nombre, ?) ");
+        if (pNumExt != null) query.append("AND regexp_like(d.numext, ?) ");
+        query.append("ORDER BY predioid");
+
+        try (Connection conn = dataSource.getConnection();
+             PreparedStatement ps = conn.prepareStatement(query.toString())) {
+
+            int paramIndex = 1;
+            if (pNomCliente != null) ps.setString(paramIndex++, pNomCliente);
+            if (pNomCalle != null) ps.setString(paramIndex++, pNomCalle);
+            if (pNumExt != null) ps.setString(paramIndex++, pNumExt);
+
+            try (ResultSet rs = ps.executeQuery()) {
+                while (rs.next()) {
+                    predioQrDTO dto = new predioQrDTO();
+                    dto.setPredioid(rs.getInt("predioid"));
+                    dto.setDireccion(rs.getString("direccion"));
+                    dto.setDirecid(rs.getInt("direcid"));
+                    dto.setColonia(rs.getString("colonia"));
+                    dto.setCalle(rs.getString("calle"));
+                    dto.setClienteid(rs.getInt("clienteid"));
+                    dto.setNombre(rs.getString("nombre"));
+                    dto.setPropietarioid(rs.getInt("propietarioid"));
+                    dto.setCtalocaliza(rs.getString("ctalocaliza"));
+                    dto.setContrato(rs.getString("contrato"));
+                    dto.setCtaant(rs.getString("ctaant"));
+                    dto.setZonafactid(rs.getString("zonafactid"));
+                    dto.setTarifa(rs.getString("tarifa"));
+                    dto.setUsoid(rs.getString("usoid"));
+                    dto.setActividadid(rs.getString("actividadid"));
+                    dto.setEdopredioid(rs.getString("edopredioid"));
+                    dto.setMetsumid(rs.getString("metsumid"));
+                    dto.setSerialmed(rs.getString("serialmed"));
+                    dto.setInstalmed(rs.getString("instalmed"));
+
+                    predios.add(dto);
+                }
+            }
+
+        } catch (SQLException e) {
+            throw new RuntimeException("Error al consultar predios: " + e.getMessage(), e);
+        }
+
+        return predios;
+    }
+
+    @Transactional
+    public String buscarINAPAMPorPredio(int predioid) {
+        String query = "select inapam from padronpad where predioid = ?";
+        try (Connection conn = dataSource.getConnection();
+             PreparedStatement ps = conn.prepareStatement(query)) {
+
+            ps.setInt(1, predioid);
+
+            try (ResultSet rs = ps.executeQuery()) {
+                if (rs.next()) {
+                    return rs.getString("inapam");
+                }
+            }
+        } catch (Exception e) {
+            throw new RuntimeException("Error al consultar INAPAM: " + e.getMessage(), e);
+        }
+
+        return null;
+    }
+
+    @Transactional
+    public String generarOtInapam(Long predioid, String direccion, String descripcion) {
+        String usuario = "WISJUMAPA";
+        String motivoId = "312";
+
+        String query = """
+            BEGIN
+                operacion.pk_orden.SP_ORDENTRABAJOENC (
+                    null, sysdate, null, null, null, null,
+                    :usuario, null, null, null,
+                    :descripcion, null, null, null, null, null, null,
+                    1, sysdate, :predioid, null,
+                    :motivoid, :direccion, null, 1,
+                    :usuario, null, null, null, null, null, null, null, null, null, null, 1
+                );
+            END;
+        """;
+
+        try (Connection conn = dataSource.getConnection();
+            OraclePreparedStatement stmt = (OraclePreparedStatement) conn.prepareStatement(query)) {
+
+            stmt.setStringAtName("descripcion", descripcion);
+            stmt.setStringAtName("usuario", usuario);
+            stmt.setLongAtName("predioid", predioid);
+            stmt.setStringAtName("motivoid", motivoId);
+            stmt.setStringAtName("direccion", direccion);
+
+            stmt.execute();
+
+            return "Se generó la inspección de INAPAM al predio " + predioid + " ubicado en la dirección: " + direccion;
+
+        } catch (SQLException e) {
+            throw new RuntimeException("Error al generar la inspección INAPAM: " + e.getMessage(), e);
+        }
+    }
+
+    public Optional<pagoQrDTO> obtenerPagoQr(Long predioid, String pagoid) {
+        String query = "SELECT c.nombre AS nomcliente, fn_get_direccion(p.direcid) AS direccionmostrar " +
+                       "FROM predios p " +
+                       "LEFT JOIN clientes c USING (clienteid) " +
+                       "WHERE p.predioid = ?";
+
+        try (Connection conn = dataSource.getConnection();
+             PreparedStatement ps = conn.prepareStatement(query)) {
+
+            ps.setLong(1, predioid);
+
+            try (ResultSet rs = ps.executeQuery()) {
+                if (rs.next()) {
+                    pagoQrDTO dto = new pagoQrDTO();
+                    dto.setPredioid(predioid);
+                    dto.setPagoid(pagoid);
+                    dto.setNomcliente(rs.getString("nomcliente"));
+                    dto.setDireccion(rs.getString("direccionmostrar"));
+                    return Optional.of(dto);
+                }
+            }
+
+        } catch (SQLException e) {
+            throw new RuntimeException("Error al obtener datos del predio: " + e.getMessage(), e);
+        }
+
+        return Optional.empty();
+    }
+
+    @Connectable
+    public List<turnoDTO> obtenerTurnosPorPunto(int puntoId) {
+        List<turnoDTO> turnos = new ArrayList<>();
+
+        String query = """
+            SELECT b.descripcion servicio, 'Pendientes: ' || TO_CHAR(COUNT(*)) pendientes
+            FROM turnomatico.tmturno a
+            INNER JOIN turnomatico.tmservicios b USING (tmservicioid)
+            WHERE a.fechaemision >= TRUNC(SYSDATE)
+            AND puntoid = ?
+            AND entidadid = 1
+            AND a.tmturnoid NOT IN (
+                SELECT tmturnoid
+                FROM turnomatico.tmturnoventanilla
+                WHERE fechainicio >= TRUNC(SYSDATE)
+                    AND puntoid = ?
+                    AND entidadid = 1
+            )
+            GROUP BY b.descripcion
+
+            UNION
+
+            SELECT r.descripcion, 'Atendiendo: ' || s.letra || '-' || SUBSTR('000' || noturno, -3, 3)
+            FROM turnomatico.tmturno a
+            INNER JOIN turnomatico.tmservicios s USING (tmservicioid)
+            INNER JOIN (
+                SELECT MAX(tmturnoid) mturno, c.descripcion
+                FROM turnomatico.tmturnoventanilla a
+                INNER JOIN turnomatico.tmturno b USING (tmturnoid)
+                INNER JOIN turnomatico.tmservicios c USING (tmservicioid)
+                WHERE fechainicio >= TRUNC(SYSDATE)
+                AND a.puntoid = ?
+                AND a.entidadid = 1
+                GROUP BY c.descripcion
+            ) r ON r.mturno = a.tmturnoid
+            ORDER BY 1, 2 DESC
+            """;
+
+        try (Connection connection = dataSource.getConnection();
+            PreparedStatement ps = connection.prepareStatement(query)) {
+
+            ps.setInt(1, puntoId);
+            ps.setInt(2, puntoId);
+            ps.setInt(3, puntoId);
+
+            try (ResultSet rs = ps.executeQuery()) {
+                while (rs.next()) {
+                    turnoDTO dto = new turnoDTO();
+                    dto.setServicio(rs.getString(1));
+                    dto.setEstado(rs.getString(2));
+                    turnos.add(dto);
+                }
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException("Error al obtener los turnos: " + e.getMessage(), e);
+        }
+
+        return turnos;
+    }
+
+}

src/main/java/jumapacelaya/gob/mx/vv/controlador/VvControlador.java

@@ -1,6 +1,5 @@
 package jumapacelaya.gob.mx.vv.controlador;
 
-import java.util.Collections;
 import java.util.List;
 import java.util.Map;