TipoDocumentoMysqlDAO.java

package trismegistoplanilla.mysqldao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.json.JSONArray;
import org.json.JSONObject;
import trismegistoplanilla.beans.TipoDocumentoBean;
import trismegistoplanilla.beans.TokenFichaBean;
import trismegistoplanilla.dao.TipoDocumentoDAO;
import trismegistoplanilla.utilities.ResponseHelper;
import trismegistoplanilla.utilities.Variables;

public class TipoDocumentoMysqlDAO implements TipoDocumentoDAO {

	@Override
	public JSONObject listarTipoDocumento() {
		System.out.println("TipoDocumentoMysqlDAO: listarTipoDocumento");
		JSONObject jsonObjListarTipoDocumento = null;
		JSONArray jsonArrListarTipoDocumento = new JSONArray();
		ResponseHelper response = new ResponseHelper();

		String sql
			= "SELECT "
			+ "	tipo_documento.codigo_tipo_documento AS codigoTipoDocumento, "
			+ "	tipo_documento.descripcion_larga AS descripcionLarga, "
			+ "	tipo_documento.descripcion_corta AS descripcionCorta, "
			+ "	tipo_documento.longitud, "
			+ "	tipo_documento.tipo_entrada AS tipoEntrada, "
			+ "	CASE "
			+ "WHEN tipo_documento.estado_registro = 1 THEN "
			+ "	'ACTIVO' "
			+ "WHEN tipo_documento.estado_registro = 0 THEN "
			+ "	'INACTIVO' "
			+ "ELSE "
			+ "	'ERROR' "
			+ "END AS nombreEstadoRegistro "
			+ "FROM "
			+ "	tipo_documento "
			+ "WHERE "
			+ "	tipo_documento.estado_registro = 1";

		Connection conexion = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		try {
			conexion = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
			ps = conexion.prepareStatement(sql);
			rs = ps.executeQuery();
			while (rs.next()) {
				TipoDocumentoBean tipoDocumento = new TipoDocumentoBean();
				tipoDocumento.setCodigoTipoDocumento(rs.getInt("codigoTipoDocumento"));
				tipoDocumento.setDescripcionLarga(rs.getString("descripcionLarga"));
				tipoDocumento.setDescripcionCorta(rs.getString("descripcionCorta"));
				tipoDocumento.setLongitud(rs.getString("longitud"));
				tipoDocumento.setTipoEntrada(rs.getString("tipoEntrada"));
				tipoDocumento.setTipoEntrada(rs.getString("tipoEntrada"));
				JSONObject jsonObjTipoDocumento = new JSONObject(tipoDocumento);
				jsonArrListarTipoDocumento.put(jsonObjTipoDocumento);
			}
			JSONObject jsonObjTipodocumento = new JSONObject();
			jsonObjTipodocumento.put("tipodocumentos", jsonArrListarTipoDocumento);
			response.setStatus(true);
			response.setMessage("Los tipos de documentos se han listado correctamente.");
			response.setData(jsonObjTipodocumento);
		} catch (SQLException e) {
			e.printStackTrace();
			response.setStatus(false);
			response.setMessage("Error: " + e.getMessage() + "   Error Code: [" + e.getErrorCode() + "]");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (ps != null) {
					ps.close();
				}
				if (conexion != null) {
					conexion.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		jsonObjListarTipoDocumento = new JSONObject(response);
		return jsonObjListarTipoDocumento;
	}

	@Override
	public JSONObject validarExistenciaTipoDocumento(TipoDocumentoBean tipoDocumento) {
		System.out.println("TipoDocumentoMysqlDAO: validarExistenciaTipoDocumento");
		JSONObject jsonObjValidarExistenciaTipoDocumento = null;
		ResponseHelper response = new ResponseHelper();
		int existeTipoDocumento = 0;

		String sql = ""
			+ "select "
			+ "count(1) existeTipoDocumento "
			+ "from tipo_documento "
			+ "where codigo_tipo_documento = ? and estado_registro = 1";

		Connection conexion = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		try {
			conexion = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
			ps = conexion.prepareStatement(sql);
			ps.setInt(1, tipoDocumento.getCodigoTipoDocumento());
			rs = ps.executeQuery();
			rs.next();
			existeTipoDocumento = rs.getInt("existeTipoDocumento");
			if (existeTipoDocumento > 0) {
				response.setStatus(true);
				response.setMessage("El tipo documento seleccionado existe.");
			} else if (existeTipoDocumento == 0) {
				response.setStatus(false);
				response.setMessage("El tipo documento seleccionado no existe.");
			}
		} catch (SQLException e) {
			e.printStackTrace();
			response.setStatus(false);
			response.setMessage("Error: " + e.getMessage() + "   Error Code: [" + e.getErrorCode() + "]");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (ps != null) {
					ps.close();
				}
				if (conexion != null) {
					conexion.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		jsonObjValidarExistenciaTipoDocumento = new JSONObject(response);
		return jsonObjValidarExistenciaTipoDocumento;
	}

	@Override
	public JSONObject obtenerLongitudTipoEntrdadaTipoDocumento(TipoDocumentoBean tipoDocumento) {
		System.out.println("TipoDocumentoMysqlDAO: obtenerLongitudTipoEntrdadaTipoDocumento");
		JSONObject jsonObjObtenerLongitudTipoEntrdadaTipoDocumento = null;
		JSONArray jsonArrObtenerLongitudTipoEntrdadaTipoDocumento = new JSONArray();
		ResponseHelper response = new ResponseHelper();

		String sql = ""
			+ "select "
			+ "longitud, "
			+ "tipo_entrada TipoEntrada "
			+ "from tipo_documento "
			+ "where codigo_tipo_documento = ? and estado_registro = 1";

		Connection conexion = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		try {
			conexion = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
			ps = conexion.prepareStatement(sql);
			ps.setInt(1, tipoDocumento.getCodigoTipoDocumento());
			rs = ps.executeQuery();
			while (rs.next()) {
				tipoDocumento.setLongitud(rs.getString("longitud"));
				tipoDocumento.setTipoEntrada(rs.getString("TipoEntrada"));
				JSONObject jsonObjTipoDocumento = new JSONObject(tipoDocumento);
				jsonArrObtenerLongitudTipoEntrdadaTipoDocumento.put(jsonObjTipoDocumento);
			}
			JSONObject jsonObjTipodocumento = new JSONObject();
			jsonObjTipodocumento.put("tipodocumentos", jsonArrObtenerLongitudTipoEntrdadaTipoDocumento);
			response.setStatus(true);
			response.setMessage("La longitud y tipo de entrada se han listado correctamente.");
			response.setData(jsonObjTipodocumento);
		} catch (SQLException e) {
			e.printStackTrace();
			response.setStatus(false);
			response.setMessage("Error: " + e.getMessage() + "   Error Code: [" + e.getErrorCode() + "]");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (ps != null) {
					ps.close();
				}
				if (conexion != null) {
					conexion.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		jsonObjObtenerLongitudTipoEntrdadaTipoDocumento = new JSONObject(response);
		return jsonObjObtenerLongitudTipoEntrdadaTipoDocumento;
	}

	@Override
	public JSONObject obtenerCodigoTipoDocumento(TokenFichaBean tf) {
		System.out.println("TipoDocumentoMysqlDAO: obtenerCodigoTipoDocumento");
		JSONObject jsonObjObtenerCodigoTipoDocumento = null;
		ResponseHelper response = new ResponseHelper();

		String sql = ""
			+ "select "
			+ "personal.codigo_tipo_documento codigoTipoDocumento "
			+ "from personal "
			+ "inner join ficha ON ficha.codigo_persona = personal.codper "
			+ "inner join token_ficha ON token_ficha.codigo_ficha = ficha.codigo_ficha "
			+ "where token_ficha.codigo_token_ficha = ? and token_ficha.token = ? and "
			+ "personal.retirado = 0 and "
			+ "ficha.estado_registro = 1 and "
			+ "token_ficha.estado_registro = 1";

		Connection conexion = null;
		PreparedStatement ps = null;
		ResultSet rs = null;
		try {
			conexion = MysqlDAOFactory.obtenerConexion(Variables.MYSQL_NUEVO_BD_NAME);
			ps = conexion.prepareStatement(sql);
			ps.setInt(1, tf.getCodigoTokenFicha());
			ps.setString(2, tf.getToken());
			rs = ps.executeQuery();
			rs.next();
			int codigoTipoDocumento = rs.getInt("codigoTipoDocumento");
			JSONObject objTipoDocumento = new JSONObject();
			objTipoDocumento.put("getResultedKey", codigoTipoDocumento);
			if (codigoTipoDocumento > 0) {
				response.setStatus(true);
				response.setMessage("Enhorabuena!, persona y tipo documento identificado");
				response.setData(objTipoDocumento);
			} else {
				response.setStatus(false);
				response.setMessage("Error: no se encontró la identificación de la persona ni el tipo de documento registrado");
			}
		} catch (SQLException e) {
			e.printStackTrace();
			response.setStatus(false);
			response.setMessage("Error: " + e.getMessage() + "   Error Code: [" + e.getErrorCode() + "]");
		} finally {
			try {
				if (rs != null) {
					rs.close();
				}
				if (ps != null) {
					ps.close();
				}
				if (conexion != null) {
					conexion.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		jsonObjObtenerCodigoTipoDocumento = new JSONObject(response);
		return jsonObjObtenerCodigoTipoDocumento;
	}

}