Se agrega insert de pruebas

parent bcb3bdcf
package amx.ccie.etl.dao;
import amx.ccie.dto.CatalogoDTO;
import amx.ccie.etl.util.Conexion;
import oracle.jdbc.OracleTypes;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
/**
*
* @author montielj
*/
public class CatalogosDAO extends Conexion {
// Método genérico para realizar consultas
private List<CatalogoDTO> ejecutarConsulta(String store, int id) {
List<CatalogoDTO> data = new ArrayList<>();
StringBuilder sql = new StringBuilder();
sql.append("{call ").append(getEsq_amx()).append(getPkg_pref()).append("CATALOGOS.").append(store).append("(?,?,?,?)}");
try (Connection conn = getConnection();
CallableStatement cs = conn.prepareCall(sql.toString())) {
cs.setString(1, "Prueba entrada Catalogo");
cs.setInt(2, id); // ID_IN
cs.registerOutParameter(3, OracleTypes.INTEGER); // ESTATUS_OUT
cs.registerOutParameter(4, OracleTypes.VARCHAR); // MSG_OUT
cs.execute();
int estatus = cs.getInt(3);
if (estatus != 1) { // Éxito
throw new SQLException(cs.getString(4));
}
} catch (SQLException e) {
e.printStackTrace(); // Manejo de errores
}
return data;
}
// Métodos específicos para cada tabla
public List<CatalogoDTO> crearCanalAtencion(int id) {
return ejecutarConsulta("crear_canal_atencion", id);
}
}
package amx.ccie.etl.scheduler;
import amx.ccie.etl.dao.BitacoraDAO;
import amx.ccie.etl.dao.CatalogosDAO;
import amx.ccie.etl.httpClient.TestApisEmpleado;
import amx.ccie.etl.httpClient.TestApisReporte;
import amx.ccie.etl.util.BitacoraDTO;
......@@ -25,12 +26,14 @@ public class CatalogoScheduler {
private final Logger log = LogManager.getLogger(this.getClass());
@Schedule(hour = "13", minute = "35", second = "0", persistent = false)
@Schedule(hour = "12", minute = "14", second = "0", persistent = false)
public void consultarCatalogoServicio() {
try {
List<BitacoraDTO> bitacora = new BitacoraDAO().getBitacora();
bitacora.stream().forEach(cat -> System.out.println("Hola mundo catalogo: " + cat.getDescripcion()));
bitacora.stream().forEach(cat -> log.info("Catalogo a ejecutar: {}", cat.getDescripcion()));
log.info("Se inserta en catalogo CCI_CAT_CANAL_ATENCION");
new CatalogosDAO().crearCanalAtencion(1);
log.info("Inserta en catalogo CCI_CAT_CANAL_ATENCION exitoso.");
log.info("Se ejecuta servicio de empleado.");
new TestApisEmpleado().getEmpleado();
log.info("Se ejecuta servicio de reporte.");
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment