Subversion Repositories bacoAlunos

package pt.estgp.estgweb.services.sigesimports.oracle.dao;

import pt.estgp.estgweb.services.sigesimports.oracle.domain.Aluno;

import pt.estgp.estgweb.services.sigesimports.oracle.domain.AlunoHistorico;

import pt.estgp.estgweb.services.sigesimports.oracle.domain.Disciplina;

import pt.estgp.estgweb.services.sigesimports.oracle.domain.Nacionalidade;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.HashMap;

/**

 * Created by jorgemachado on 07/01/16.

 */

public class AlunoDao extends AbstractDao<Aluno> {

    private static AlunoDao instance = null;

    private AlunoDao() {

    }

    public static AlunoDao getInstance() {

        if (instance == null)

            instance = new AlunoDao();

        return instance;

    }

    protected 1.5.0/docs/api/java/lang/String.html">String getTable() {

        return "CSE.T_ALUNOS";

    }

    protected 1.5.0/docs/api/java/lang/String.html">String getIdColumn() {

        return "CD_ALUNO";

    }

    public HashMap<Integer,Nacionalidade> loadNacionalidades(1.5.0/docs/api/java/sql/Connection.html">Connection conn) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        HashMap<Integer,Nacionalidade> nacionalidades = new HashMap<Integer, Nacionalidade>();

        boolean connWasNull = conn == null;

        if (conn == null) {

            conn = getCurrentConnection();

        }

        1.5.0/docs/api/java/sql/PreparedStatement.html">PreparedStatement catCMD = conn.prepareStatement("SELECT * FROM SIGES.T_TBNACIONA");

        1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReader = catCMD.executeQuery();

        while (aReader.next())

        {

            1.5.0/docs/api/java/lang/Integer.html">Integer nacionalidadeCodigo = getDecimal("CD_NACIONA", aReader);

            1.5.0/docs/api/java/lang/String.html">String nacionalidade = getString("DS_NACIONA",aReader);

            1.5.0/docs/api/java/lang/String.html">String pais = getString("DS_PAIS",aReader);

            Nacionalidade nacionalidadeRec = new Nacionalidade();

            nacionalidadeRec.setCodigoNacionalidade(nacionalidadeCodigo);

            nacionalidadeRec.setNacionalidade(nacionalidade);

            nacionalidadeRec.setPais(pais);

            nacionalidades.put(nacionalidadeCodigo,nacionalidadeRec);

        }

        //close the reader

        aReader.close();

        catCMD.close();

        if (connWasNull)

            conn.close();

        return nacionalidades;

    }

    public Aluno load(1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReader) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        Aluno a = new Aluno();

        a.codigo = getDecimal("CD_ALUNO", aReader);

        //a.nome = getString("NM_ALUNO",aReader);

        a.nome = getString("NM_COMPLETO", aReader);

        a.codigoNacionalidade = getDecimal("CD_NACIONA",aReader);

        //d.nomeFuncionario = getString("NM_COMPLETO", aReader); //ok T_INDIVIDUO  FALTA VER O "NOME"

        //d.nomeFuncionarioInt = getString("NM_FUNC_INT", aReader);

        //d.nomeFuncionario = getString("NM_ABREVIADO", aReader); //ok T_INDIVIDUO

        //d.nomeAcademico = getString("NM_ACADEMICO", aReader);   //ok T_INDIVIDUO

        //a.sexo = getString("CD_SEXO", aReader);

        a.sexo = getString("SEXO", aReader);

        //a.data_nascimento = getDateTime("DT_NASCIME", aReader);

        //a.morada = getString("DS_MORADA", aReader);

        //a.codigoPostal = getInteger("CD_POSTAL", aReader);

        //a.subCodigoPostal = getInteger("CD_SUBPOS", aReader);

        //a.email = getString("DS_EMAIL", aReader);

        //a.numeroBi = getString("NR_BI", aReader);

        a.telemovel = getString("NR_TELEMOVEL", aReader);

        a.data_nascimento = getDateTime("DT_NASCIMENTO", aReader);

        a.morada = getString("DS_MORADA", aReader);

        a.codigoPostal = getDecimal("CD_POSTAL", aReader);

        a.subCodigoPostal = getDecimal("CD_SUBPOS", aReader);

        a.email = getString("EMAIL", aReader);

        a.numeroBi = getString("IDENTIFICACAO", aReader);

        //a.usernameNetpa = getString("USERNAME_NETPA", aReader);

        a.usernameNetpa = getString("USER_NETPA", aReader); //T_ALUNO

        return a;

    }

    public ArrayList<Integer> loadCodigosAlunos(1.5.0/docs/api/java/lang/Integer.html">Integer codigoInstituicao, 1.5.0/docs/api/java/lang/String.html">String ano) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        return loadCodigosAlunos(codigoInstituicao, ano,null);

    }

    /*Valid with diagrams*/

    public ArrayList<Integer> loadCodigosAlunos(1.5.0/docs/api/java/lang/Integer.html">Integer codigoInstituicao, 1.5.0/docs/api/java/lang/String.html">String ano, 1.5.0/docs/api/java/sql/Connection.html">Connection conn) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        ArrayList<Integer> codigos = new ArrayList<Integer>();

        boolean connWasNull = conn == null;

        if (conn == null) {

            conn = getCurrentConnection();

        }

        1.5.0/docs/api/java/sql/PreparedStatement.html">PreparedStatement catCMD = conn.prepareStatement("SELECT DISTINCT " +

                " CSE.T_ALUNOS.CD_ALUNO AS CD_ALUNO " +

                "FROM CSE.T_ALUNOS " +

                "INNER JOIN (CSE.T_INSCRI INNER JOIN CSE.T_TBDISCIP ON CSE.T_INSCRI.CD_DISCIP = CSE.T_TBDISCIP.CD_DISCIP) ON CSE.T_ALUNOS.CD_ALUNO = CSE.T_INSCRI.CD_ALUNO " +

                "WHERE (((CSE.T_TBDISCIP.CD_INSTITUIC)=" + codigoInstituicao + ") AND ((CSE.T_INSCRI.CD_LECTIVO)='" + ano + "') " +

                /*AND ((CSE.T_ALUNOS.CD_SITUA_PAR)=1)*/

                " AND ((CSE.T_INSCRI.CD_STATUS)<>5))");

        1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReader = catCMD.executeQuery();

        while (aReader.next()) {

            codigos.add(getDecimal("CD_ALUNO", aReader));

        }

        //close the reader

        aReader.close();

        catCMD.close();

        if (connWasNull)

            conn.close();

        return codigos;

    }

    public Aluno loadInscrito(1.5.0/docs/api/java/lang/Integer.html">Integer codigo, 1.5.0/docs/api/java/lang/Integer.html">Integer codigoInstituicao, 1.5.0/docs/api/java/lang/String.html">String ano) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        return loadInscrito(codigo, codigoInstituicao, ano,null);

    }

    public Aluno loadInscrito(1.5.0/docs/api/java/lang/Integer.html">Integer codigo, 1.5.0/docs/api/java/lang/Integer.html">Integer codigoInstituicao, 1.5.0/docs/api/java/lang/String.html">String ano,1.5.0/docs/api/java/sql/Connection.html">Connection conn) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        boolean connWasNull = conn == null;

        if (conn == null) {

            conn = getCurrentConnection();

        }

        1.5.0/docs/api/java/sql/PreparedStatement.html">PreparedStatement catCMD = conn.prepareStatement("SELECT * FROM " + getTable() + " " +

                "INNER JOIN SIGES.T_INDIVIDUO on SIGES.T_INDIVIDUO.ID_INDIVIDUO = CSE.T_ALUNOS.ID_INDIVIDUO " +

                "where /*CD_SITUA_PAR = 1 AND*/ " + getIdColumn() + "=" + codigo);

        1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReader = catCMD.executeQuery();

        if (aReader.next()) {

            Aluno a = load(aReader);

            a.disciplinasInscrito = loadDiscilpinasInscrito(codigo, codigoInstituicao, ano);

            a.historicos = getHistorico(codigo);

            obtainTiposAlunoRepresentados(codigo, ano, conn, a);

            aReader.close();

            return a;

        }

        aReader.close();

        catCMD.close();

        if (connWasNull)

            conn.close();

        //close the reader

        return null;

    }

    private void obtainTiposAlunoRepresentados(1.5.0/docs/api/java/lang/Integer.html">Integer codigo, 1.5.0/docs/api/java/lang/String.html">String ano, 1.5.0/docs/api/java/sql/Connection.html">Connection conn, Aluno a) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        1.5.0/docs/api/java/sql/PreparedStatement.html">PreparedStatement tiposAluno = conn.prepareStatement(

                "SELECT DISTINCT CSE.T_TIPALUNO.CD_TIP_ALU AS CD_TIP_ALU, CSE.T_TBTIPALU.DS_TIP_ALU AS DS_TIP_ALU " +

                "       FROM CSE.T_TIPALUNO " +

                "       LEFT OUTER JOIN CSE.T_TBTIPALU ON CSE.T_TIPALUNO.CD_TIP_ALU = CSE.T_TBTIPALU.CD_TIP_ALU " +

                "       where     CSE.T_TIPALUNO.CD_ALUNO = " + codigo + "  " +

                "             AND CSE.T_TIPALUNO.CD_LECTIVO = '" + ano + "'");

        1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReaderTiposAluno = tiposAluno.executeQuery();

        a.setTiposAlunosRepresentados(new ArrayList<Aluno.TipoAluno>());

        while(aReaderTiposAluno.next())

        {

            1.5.0/docs/api/java/lang/Integer.html">Integer cdTipAluno = getDecimal("CD_TIP_ALU",aReaderTiposAluno);

            if(cdTipAluno != null && cdTipAluno > 0)

            {

                Aluno.TipoAluno tipoAluno = new Aluno.TipoAluno();

                tipoAluno.setCodigoTipoAluno(""+cdTipAluno);

                tipoAluno.setDescTipoAluno(getString("DS_TIP_ALU", aReaderTiposAluno));

                a.getTiposAlunosRepresentados().add(tipoAluno);

            }

        }

        aReaderTiposAluno.close();

        tiposAluno.close();

    }

    /*Mudar a lista para uma lista de Códigos com pelo menos CD_LECTIVO, CD_DISCIP, CD_CURSO, CD_TURMA*/

                /*Do lado do Baco as Disciplinas são criadas uma por (CD_LECTIVO, CODIGO, CURSO, SEMESTRE) ficam anexadas todas as turmas encontradas*/

                /* O Serviço de Leituras de Sumarios pede apenas os detalhe_aula com codigos de turma igual ao pedido e CD_LECTIVO = actual */

    public ArrayList<Disciplina> loadDiscilpinasInscrito(1.5.0/docs/api/java/lang/Integer.html">Integer codigo, 1.5.0/docs/api/java/lang/Integer.html">Integer codigoInstituicao, 1.5.0/docs/api/java/lang/String.html">String ano) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        ArrayList<Disciplina> disciplinas = new ArrayList<Disciplina>();

        1.5.0/docs/api/java/sql/Connection.html">Connection conn = getCurrentConnection();

        1.5.0/docs/api/java/sql/PreparedStatement.html">PreparedStatement catCMD = conn.prepareStatement("SELECT " +

                "                CSE.T_INSCRI.CD_TIPDIS AS CD_TIPDIS, " +

                "                CSE.T_INSCRI.CD_DISCIP AS CD_DISCIP,  " +

                "                CSE.T_INSCRI.CD_DURACAO AS CD_DURACAO, " +

                "                CSE.T_INSCRI.CD_CURSO AS CD_CURSO, " +

                "                CSE.T_INSCRI.CD_TURMA_T AS CD_TURMA, " +

                "                CSE.T_INSCRI.CD_TURMA_P, " +

                "                CSE.T_INSCRI.CD_TURMA_L, " +

                "                CSE.T_INSCRI.CD_TURMA_TP, " +

                "                CSE.T_INSCRI.CD_TURMA_S, " +

                "                CSE.T_INSCRI.CD_TURMA_C, " +

                "                CSE.T_INSCRI.CD_TURMA_O, " +

                "                CSE.T_INSCRI.CD_TURMA_E "  +

                "                FROM CSE.T_INSCRI INNER JOIN CSE.T_TBDISCIP ON CSE.T_INSCRI.CD_DISCIP = CSE.T_TBDISCIP.CD_DISCIP " +

                //"                INNER JOIN CSE.T_CURSOS ON CSE.T_CURSOS.CD_CURSO = CSE.T_INSCRI.CD_CURSO " +

                "                WHERE CSE.T_INSCRI.CD_ALUNO = " + codigo + " " +

                "                AND" +

                "                    CSE.T_TBDISCIP.CD_INSTITUIC= " + codigoInstituicao + " AND " +

                "                    CSE.T_INSCRI.CD_LECTIVO='" + ano + "' AND " +

                "                    CSE.T_INSCRI.CD_STATUS<>5 AND " +

                "                (CSE.T_INSCRI.CD_TIPDIS = 2 OR CSE.T_INSCRI.CD_TIPDIS = 1 OR CSE.T_INSCRI.CD_TIPDIS = 6) "

        );

        //CD_TIPDISC = 1 Inscricoes normais

        //CD_TIPDISC = 2 Nao conta para media

        //CD_TIPDISC = 3 Qualitativa

        //CD_TIPDISC = 4 Equivalencia

        //CD_TIPDISC = 5 Equivalencia sem nota

        //CD_TIPDISC = 6 Extra Curricular

        //CD_TIPDISC = 7 Suplemento Diploma

        //CD_TIPDISC = 8 Integracao ou refazimento do plano de estudos

        1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReader = catCMD.executeQuery();

        while (aReader.next()) {

            Disciplina d = new Disciplina();

            d.codigo = getDecimal("CD_DISCIP", aReader);

            d.codigoCurso = getDecimal("CD_CURSO", aReader);

            d.codigoInstituicao = codigoInstituicao;

            d.cdLectivo = ano;

            d.cdTipoDisciplina = getDecimal("CD_TIPDIS", aReader);

            d.cdDuracao = getString("CD_DURACAO", aReader);

            d.cdTurma = getString("CD_TURMA", aReader);

            if(getString("CD_TURMA_P", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_P", aReader);

                d.outraTurmaCode = "P";

            }

            else if(getString("CD_TURMA_L", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_L", aReader);

                d.outraTurmaCode = "L";

            }

            else if(getString("CD_TURMA_TP", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_TP", aReader);

                d.outraTurmaCode = "TP";

            }

            else if(getString("CD_TURMA_S", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_S", aReader);

                d.outraTurmaCode = "S";

            }

            else if(getString("CD_TURMA_C", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_C", aReader);

                d.outraTurmaCode = "C";

            }

            else if(getString("CD_TURMA_O", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_O", aReader);

                d.outraTurmaCode = "O";

            }

            else if(getString("CD_TURMA_E", aReader) != null)

            {

                d.outraTurma = getString("CD_TURMA_E", aReader);

                d.outraTurmaCode = "E";

            }

            disciplinas.add(d);

        }

        //close the reader

        aReader.close();

        return disciplinas;

    }

    /*Mudar a lista para uma lista de Códigos com pelo menos CD_LECTIVO, CD_DISCIP, CD_CURSO, CD_TURMA*/

        /*Do lado do Baco as Disciplinas são criadas uma por (CD_LECTIVO, CODIGO, CURSO, SEMESTRE) ficam anexadas todas as turmas encontradas*/

        /* O Serviço de Leituras de Sumarios pede apenas os detalhe_aula com codigos de turma igual ao pedido e CD_LECTIVO = actual */

    public ArrayList<AlunoHistorico> getHistorico(1.5.0/docs/api/java/lang/Integer.html">Integer codigo) throws 1.5.0/docs/api/java/sql/SQLException.html">SQLException {

        ArrayList<AlunoHistorico> historicos = new ArrayList<AlunoHistorico>();

        1.5.0/docs/api/java/sql/Connection.html">Connection conn = getCurrentConnection();

        1.5.0/docs/api/java/sql/PreparedStatement.html">PreparedStatement catCMD = conn.prepareStatement("SELECT CSE.T_HISTALUN.CD_LECTIVO AS CD_LECTIVO, CSE.T_HISTALUN.CD_CURSO AS CD_CURSO, CSE.T_HISTALUN.DT_MATRIC AS DT_MATRIC, CSE.T_HISTALUN.PROTEGIDO AS PROTEGIDO, CSE.T_HISTALUN.CD_PROPINA AS CD_PROPINA  FROM CSE.T_HISTALUN WHERE CSE.T_HISTALUN.CD_ALUNO = " + codigo + "");

        1.5.0/docs/api/java/sql/ResultSet.html">ResultSet aReader = catCMD.executeQuery();

        while (aReader.next()) {

            AlunoHistorico a = new AlunoHistorico();

            a.codigo = codigo;

            a.codigoCurso = getDecimal("CD_CURSO", aReader);

            a.codigoLectivo = getString("CD_LECTIVO", aReader);

            a.dataMatricula = getDateTime("DT_MATRIC", aReader);

            a.propinaEmDia = getString("CD_PROPINA", aReader);

            a.historicoProtegido = getString("PROTEGIDO", aReader);

            historicos.add(a);

        }

        //close the reader

        aReader.close();

        return historicos;

    }

}