Subversion Repositories bacoAlunos

package pt.estgp.estgweb.services.questionarios.pedagogico;

import com.owlike.genson.TransformationException;

import org.apache.log4j.Logger;

import org.json.JSONArray;

import org.json.JSONException;

import pt.estgp.estgweb.domain.*;

import pt.estgp.estgweb.domain.dao.DaoFactory;

import pt.estgp.estgweb.domain.dao.impl.CourseUnitDaoImpl;

import pt.estgp.estgweb.services.jobs.JobDeamon;

import pt.estgp.estgweb.services.jobs.ServiceJob;

import pt.estgp.estgweb.services.logresults.ILogMessages;

import pt.estgp.estgweb.services.logresults.LogMessageTypeEnum;

import pt.estgp.estgweb.services.logresults.impl.DefaultLogMessage;

import pt.estgp.estgweb.services.logresults.impl.DefaultLogMessages;

import pt.estgp.estgweb.services.questionarios.QuestionariosService;

import pt.estgp.estgweb.utils.ConfigProperties;

import pt.estgp.estgweb.web.exceptions.NotAuthorizedException;

import pt.utl.ist.berserk.logic.serviceManager.IService;

import java.io.IOException;

import java.util.*;

/**

 * Created by jorgemachado on 22/03/16.

 */

public class UpdateCoursesAndUnitsJobService extends ServiceJob implements IService

{

    public static final 1.5.0/docs/api/java/util/logging/Logger.html">Logger logger = 1.5.0/docs/api/java/util/logging/Logger.html">Logger.getLogger(UpdateCoursesAndUnitsJobService.class);

    //return similar questionarios in same year, semestre and history category

    public List<QuestionarioImpl> setAnoSemestre(1.5.0/docs/api/java/lang/String.html">String year, 1.5.0/docs/api/java/lang/String.html">String semestre, long questionarioId, UserSession userSession,QuestionarioImpl questionarioCleared) throws NotAuthorizedException

    {

        if(questionarioCleared.isClear((UserSessionImpl) userSession,QuestionarioImpl.QuestionarioClearancesOperation.QUESTIONARIO_SET_ANO_SEMESTRE.name()))

        {

            questionarioCleared.setYear(year);

            questionarioCleared.setSemestre(semestre);

            questionarioCleared.setSubStatePedagogicoClass(QuestionarioImpl.SubStatePedagogico.YEAR_SEMESTRE_ASSIGNED);

            List<QuestionarioImpl> similar = DaoFactory.getQuestionarioDaoImpl().findAnoSemestre(year, semestre, questionarioCleared.getQuestionarioHistoryDrive().getId());

            new QuestionariosService().loadInit(similar);

            return similar;

        }

        else

            throw new NotAuthorizedException("Não pode alterar o formulário porque o questionário está num estado avançado");

    }

    public 1.5.0/docs/api/java/lang/String.html">String[] deserializeCoursesList(QuestionarioImpl questionario)

    {

        JobServiceTaskImpl job = questionario.getCourseSelectionTaskId() > 0 ?

                (JobServiceTaskImpl) DaoFactory.getJobServiceTaskDaoImpl().load(questionario.getCourseSelectionTaskId()) :

                null;

        if(job == null)

            return new 1.5.0/docs/api/java/lang/String.html">String[0];

        1.5.0/docs/api/java/lang/String.html">String courses = job.getParameter(ServiceJob.JOB_questionario_courseList_KEY).getObject();

        return deserializeCoursesList(courses);

    }

    public List<Course> getCoursesList(1.5.0/docs/api/java/lang/String.html">String coursesListJson)

    {

        List<Course> courses = new ArrayList<Course>();

        1.5.0/docs/api/java/lang/String.html">String[] courseIds = deserializeCoursesList(coursesListJson);

        for(1.5.0/docs/api/java/lang/String.html">String courseId: courseIds)

        {

            try

            {

                Course c = DaoFactory.getCourseDaoImpl().load(new 1.5.0/docs/api/java/lang/Long.html">Long(courseId));

                courses.add(c);

            }

            catch(1.5.0/docs/api/java/lang/Throwable.html">Throwable e)

            {

                logger.info("Course not found in course list with id:" + courseId);

            }

        }

        return courses;

    }

    public 1.5.0/docs/api/java/lang/String.html">String[] deserializeCoursesList(1.5.0/docs/api/java/lang/String.html">String json)

    {

        try {

            JSONArray jsonArray = new JSONArray(json);

            1.5.0/docs/api/java/lang/String.html">String[] coursesList = new 1.5.0/docs/api/java/lang/String.html">String[jsonArray.length()];

            for(int i=0;i <jsonArray.length();i++)

            {

                coursesList[i] = ""+ jsonArray.get(i);

            }

            return coursesList;

        } catch (JSONException e) {

            logger.error(e,e);

        }

        return new 1.5.0/docs/api/java/lang/String.html">String[0];

    }

    /*************

     * CRIAR O JOB PARA O RUNNER

     * @param questionarioId

     * @param coursesList

     * @param session

     * @param questionarioCleared

     * @return

     * @throws NotAuthorizedException

     */

    public QuestionarioImpl runJobSelectCourses(long questionarioId,1.5.0/docs/api/java/lang/String.html">String[] coursesList,UserSession session,QuestionarioImpl questionarioCleared) throws NotAuthorizedException {

        if(!questionarioCleared.isClear((UserSessionImpl) session,QuestionarioImpl.QuestionarioClearancesOperation.QUESTIONARIO_SCHEDULLE_SELECT_COURSES.name()))

        {

            throw new NotAuthorizedException("Nao tem autorização para agendar atribuições de cursos");

        }

        /*******VERIFICACAO DE RESPOSTAS*********/

        long respostas = DaoFactory.getQuestionarioDaoImpl().getNumeroRespostas(questionarioId);

        if(respostas == 0)

        {

            (questionarioCleared).setSubStatePedagogicoClass(QuestionarioImpl.SubStatePedagogico.ASSIGNING_COURSES);

        }

        else

        {

            logger.warn("Vai falhar no serviço, deixar falhar para visar o user");

        }

        JSONArray jsonArray = new JSONArray();

        for(1.5.0/docs/api/java/lang/String.html">String sele: coursesList)

        {

            jsonArray.put(new 1.5.0/docs/api/java/lang/Long.html">Long(sele));

        }

        Set<JobServiceTaskParameter> paramsJob = new HashSet<JobServiceTaskParameter>();

        JobServiceTaskParameterImpl paramJobL = DomainObjectFactory.createJobServiceTaskParameterImpl();

        paramJobL.setName(ServiceJob.JOB_questionario_courseList_KEY);

        paramJobL.setDescription("lista de cursos a associar");

        paramJobL.setObject(jsonArray.toString());

        paramsJob.add(paramJobL);

        JobServiceTaskParameterImpl paramJob = DomainObjectFactory.createJobServiceTaskParameterImpl();

        paramJob.setName(ServiceJob.JOB_questionario_id_KEY);

        paramJob.setDescription("ID do questionário");

        paramJob.setObject("" + questionarioId);

        paramsJob.add(paramJob);

        JobServiceTask job = JobDeamon.createServiceJob(UpdateCoursesAndUnitsJobService.class, session.getUser(), paramsJob,

                "Service: Atribuição de Cursos e Unidades a um questionário Pedagógico");

        questionarioCleared.setCourseSelectionTaskId(job.getId());

        return questionarioCleared;

    }

    /**

     *

     * @param questionarioId

     * @param session

     * @param questionarioCleared

     * @throws NotAuthorizedException

     *

     */

    public ILogMessages revertAllAssignments(long questionarioId, UserSession session,QuestionarioImpl questionarioCleared) throws NotAuthorizedException {

        DefaultLogMessages logMessages = new DefaultLogMessages();

        if(!questionarioCleared.isClear((UserSessionImpl) session,QuestionarioImpl.QuestionarioClearancesOperation.QUESTIONARIO_REVERT_ALL_ASSIGNEMENTS.name()))

        {

            throw new NotAuthorizedException("Nao tem autorização para agendar atribuições de cursos");

        }

        long respostas = DaoFactory.getQuestionarioDaoImpl().getNumeroRespostas(questionarioId);

        if(respostas > 0)

        {

            logMessages.addMessage(new DefaultLogMessage("error.questionario.com.respostas.nao.pode.efetuar.op", LogMessageTypeEnum.WARNING,

                    "Operação não permitida, Existem Respostas"));

            logger.warn(logMessages.getLastMessage());

            serviceLogError(logMessages.getLastMessage());

            return logMessages;

        }

        for(QuestionarioPedagogicoCursoAfeto cu : DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().find(questionarioId))

        {

            int unidades = 0;

            if(cu.getUnidadesAfetas() != null)

            {

                unidades = cu.getUnidadesAfetas().size();

                for(QuestionarioPedagogicoUnidadeCurricularAfeta unidadeCurricularAfeta: cu.getUnidadesAfetas())

                {

                    1.5.0/docs/api/java/lang/String.html">String msg = "Reverting Unidade Curricular Afeta " + unidadeCurricularAfeta.getCodigoUnidade() + " - " + unidadeCurricularAfeta.getNome();

                    logger.info(msg);

                    logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.WARNING,msg));

                    if(unidadeCurricularAfeta.getTipologiasRequisitadas() != null && unidadeCurricularAfeta.getTipologiasRequisitadas().size() > 0)

                    {

                        msg = "A unidade " + unidadeCurricularAfeta.getCodigoUnidade() + " tem tipologias requisitadas que tem de ser removidas primeiro, iremos remover todas as tipologias e respostas candidatas associadas";

                        logger.warn(msg);

                        logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.WARNING,msg));

                        removeTipologiasERespostasCascade(unidadeCurricularAfeta);

                    }

                    unidadeCurricularAfeta.setCursoAfeto(null);

                    DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().delete(unidadeCurricularAfeta);

                }

            }

            1.5.0/docs/api/java/lang/String.html">String msg = "Removendo curso afeto:" + cu.getNome() + " e " + unidades + " uniades afetas";

            logger.info(msg);

            logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.INFO,msg));

            cu.setUnidadesAfetas(null);

            DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().delete(cu);

        }

        questionarioCleared.setSubStatePedagogicoClass(QuestionarioImpl.SubStatePedagogico.YEAR_SEMESTRE_ASSIGNED);

        return logMessages;

    }

    public static ILogMessages revertAllRespostasCandidatas(long questionarioId, ServiceJob serviceJob) throws NotAuthorizedException {

        DefaultLogMessages logMessages = new DefaultLogMessages();

        long respostas = DaoFactory.getQuestionarioDaoImpl().getNumeroRespostas(questionarioId);

        if(respostas > 0)

        {

            logMessages.addMessage(new DefaultLogMessage("error.questionario.com.respostas.nao.pode.efetuar.op", LogMessageTypeEnum.WARNING,

                    "Operação não permitida, Existem Respostas"));

            logger.warn(logMessages.getLastMessage());

            serviceJob.serviceLogError(logMessages.getLastMessage());

            throw new NotAuthorizedException(logMessages.getLastMessage());

        }

        1.5.0/docs/api/java/lang/String.html">String msg = "Revertendo respostas candidatas do questionario " + questionarioId;

        logger.info(msg);

        serviceJob.serviceLogInfo(msg);

        for(QuestionarioPedagogicoCursoAfeto cu : DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().find(questionarioId))

        {

            msg = "Revertendo respostas do curso " + cu.getCodigoCurso() + " , iremos remover todas as tipologias e respostas candidatas associadas";

            logger.info(msg);

            serviceJob.serviceLogInfo(msg);

            ((QuestionarioPedagogicoCursoAfetoImpl)cu).resetAnswerStats();

            int unidades = 0;

            if(cu.getUnidadesAfetas() != null)

            {

                unidades = cu.getUnidadesAfetas().size();

                for(QuestionarioPedagogicoUnidadeCurricularAfeta unidadeCurricularAfeta: cu.getUnidadesAfetas())

                {

                    ((QuestionarioPedagogicoUnidadeCurricularAfetaImpl)unidadeCurricularAfeta).resetAnswerStats();

                    logger.info("Reverting Respostas Unidade Curricular Afeta " + unidadeCurricularAfeta.getCodigoUnidade() + " - " + unidadeCurricularAfeta.getNome());

                    if(unidadeCurricularAfeta.getTipologiasRequisitadas() != null && unidadeCurricularAfeta.getTipologiasRequisitadas().size() > 0)

                    {

                        msg = "A unidade " + unidadeCurricularAfeta.getCodigoUnidade() + " tem tipologias requisitadas que tem de ser removidas primeiro, iremos remover todas as tipologias e respostas candidatas associadas";

                        logger.info(msg);

                        serviceJob.serviceLogWarn(msg);

                        logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.WARNING,msg));

                        removeTipologiasERespostasCascade(unidadeCurricularAfeta);

                    }

                }

            }

            logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.INFO,msg));

        }

        return logMessages;

    }

    /**

     *

     */

    protected static void removeTipologiasERespostasCascade(QuestionarioPedagogicoUnidadeCurricularAfeta unidadeAfeta)

    {

        for(QuestionarioPedagogicoTipologiaRequisitada tr: unidadeAfeta.getTipologiasRequisitadas())

        {

            logger.warn("deleting: " + tr);

            if(tr.getAlunosRequisitados() != null)

            {

                for(QuestionarioPedagogicoAlunoRequisitado ar: tr.getAlunosRequisitados())

                {

                    logger.warn("deleting: " + ar);

                    if(ar.getRespostaRequisitada() != null)

                    {

                        logger.warn("deleting: Resposta Requisitada " + ar.getRespostaRequisitada().getId());

                        if(ar.getRespostaRequisitada().getResposta() != null)

                        {

                            logger.warn("deleting resposta: " + ar.getRespostaRequisitada().getResposta());

                            DaoFactory.getQuestionarioRespostaDaoImpl().delete(ar.getRespostaRequisitada().getResposta());

                            ar.getRespostaRequisitada().setResposta(null);

                        }

                        DaoFactory.getQuestionarioRespostaRequisitadaDaoImplImpl().delete(ar.getRespostaRequisitada());

                        ar.setRespostaRequisitada(null);

                    }

                    DaoFactory.getQuestionarioPedagogicoAlunoRequisitadoDaoImpl().delete(ar);

                }

                tr.setAlunosRequisitados(null);

            }

            DaoFactory.getQuestionarioPedagogicoTipologiaRequisitadaDaoImpl().delete(tr);

        }

        unidadeAfeta.setTipologiasRequisitadas(null);

    }

    /**

     *

     * #############  JOB TASK ############

     * #############  JOB TASK ############

     * @return

     * @throws Throwable

     */

    @1.5.0/docs/api/java/lang/Override.html">Override

    protected ILogMessages runJobServiceTask() throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        DefaultLogMessages logMessages = new DefaultLogMessages();

        long questionarioId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(getParametersMap().get(ServiceJob.JOB_questionario_id_KEY).getObject());

        QuestionarioImpl q = (QuestionarioImpl) DaoFactory.getQuestionarioDaoImpl().load(questionarioId);

        /********VERIFICACAO DE RESPOSTAS***********/

        long respostas = DaoFactory.getQuestionarioDaoImpl().getNumeroRespostas(questionarioId);

        if(respostas > 0)

        {

            logMessages.addMessage(new DefaultLogMessage("error.questionario.com.respostas.nao.pode.efetuar.op", LogMessageTypeEnum.WARNING,

                    "Operação não permitida, Existem Respostas"));

            logger.warn(logMessages.getLastMessage());

            serviceLogError(logMessages.getLastMessage());

            throw new NotAuthorizedException("Nao tem autorização para agendar atribuições de cursos num questioário com respostas");

        }

        //aqui sacamos os cursos seleccionados que sao serializados em JSON no Questionario e sao necessários como parametro ao serviço

        1.5.0/docs/api/java/lang/String.html">String[] coursesList = deserializeCoursesList(q);

        //Colocamos já aqui o estado para nao se poder mudar o Ano e o Semestre

        /**logging**/

        1.5.0/docs/api/java/lang/String.html">String msg = "Starting running service for questionario: " + q.getId() + " - " + q.getiAnswersProcessorClass().getTitle();

        serviceLogInfo(msg);

        logger.info(msg);

        /**logging**/

        revertAllRespostasCandidatas(questionarioId,this);

        List<String> newCourseCodesList = new ArrayList<String>();

        int count = 0;

        int totalCourses = coursesList.length;

        for(1.5.0/docs/api/java/lang/String.html">String courseStrId: coursesList)

        {

            count++;

            try{

                1.5.0/docs/api/java/lang/Long.html">Long courseLong = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(courseStrId);

                /** logging **/

                msg = "Loading Course BACO ID: " + courseStrId;

                serviceLogInfo(msg);

                logger.info(msg);

                /** logging **/

                Course c = DaoFactory.getCourseDaoImpl().load(courseLong);

                newCourseCodesList.add(c.getCode());

                /** logging **/

                msg = "(" + count + " of " + totalCourses + ")-> Course loaded: " + c.getName() + "(" + c.getCode() + ")";

                serviceLogInfo(msg);

                logger.info(msg);

                /** logging **/

                createCursoAfeto(q, c, logMessages);

                /** COMMIT OPERATION **/

                setProgress((int)((((float)count)/((float)totalCourses))*100.0f));

                commitPartially();

                DaoFactory.getQuestionarioDaoImpl().update(q);

                /** COMMIT OPERATION **/

            }

            catch(1.5.0/docs/api/java/lang/Throwable.html">Throwable t)

            {

                logger.error(t,t);

                serviceLogError(t.toString(),t);

                logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.ERROR,t.toString()));

            }

        }

        removeUnselectedCourses(q, newCourseCodesList);

        /** COMMIT OPERATION **/

        setProgress(100);

        commitPartially();

        DaoFactory.getQuestionarioDaoImpl().update(q);

        /** COMMIT OPERATION **/

        msg = "Set courses state as " + QuestionarioImpl.SubStatePedagogico.COURSES_ASSIGNED.name();

        serviceLogInfo(msg);

        logger.info(msg);

        q.setSubStatePedagogicoClass(QuestionarioImpl.SubStatePedagogico.COURSES_ASSIGNED);

        commitPartially();

        return logMessages;

    }

    /**

     *

     * @param q

     * @param newCourseCodesList

     */

    private void removeUnselectedCourses(QuestionarioImpl q, List<String> newCourseCodesList) {

        /** logging **/

        1.5.0/docs/api/java/lang/String.html">String msg = "Removing unselected courses ";

        serviceLogInfo(msg);

        logger.info(msg);

        /** logging **/

        List<QuestionarioPedagogicoCursoAfeto> allCoursesInQuestionario =  DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().find(q.getId());

        for(QuestionarioPedagogicoCursoAfeto cursoAfeto: allCoursesInQuestionario)

        {

            if(!newCourseCodesList.contains(cursoAfeto.getCodigoCurso()))

            {

                removeCursoAfeto(cursoAfeto);

            }

        }

    }

    private void removeCursoAfeto(QuestionarioPedagogicoCursoAfeto cursoAfeto) {

        1.5.0/docs/api/java/lang/String.html">String msg; /** logging **/

        msg = "Deleting course: " + cursoAfeto.getCodigoCurso();

        serviceLogInfo(msg);

        logger.info(msg);

        /** logging **/

        for(QuestionarioPedagogicoUnidadeCurricularAfeta unidade: cursoAfeto.getUnidadesAfetas())

        {

            /** logging **/

            msg = "--->Deleting unit from course: " + unidade.getCodigoUnidade();

            serviceLogInfo(msg);

            logger.info(msg);

            /** logging **/

            DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().delete(unidade);

        }

        cursoAfeto.setUnidadesAfetas(null);

        DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().delete(cursoAfeto);

    }

    private void removeUnselectedUnits(QuestionarioPedagogicoCursoAfeto cursoAfetado, List<Long> newUnidadesCodesList) {

        /** logging **/

        1.5.0/docs/api/java/lang/String.html">String msg = "Removing unselected units from course: " + cursoAfetado.getCodigoCurso();

        serviceLogInfo(msg);

        logger.info(msg);

        /** logging **/

        Set<QuestionarioPedagogicoUnidadeCurricularAfeta> allUnidades =  cursoAfetado.getUnidadesAfetas();

        for(QuestionarioPedagogicoUnidadeCurricularAfeta unidadeAfeta: allUnidades)

        {

            if(!newUnidadesCodesList.contains(unidadeAfeta.getCourseUnit().getId()))

            {

                /** logging **/

                msg = "--->Deleting unidade: " + unidadeAfeta.getCodigoUnidade();

                serviceLogInfo(msg);

                logger.info(msg);

                /** logging **/

                DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().delete(unidadeAfeta);

            }

        }

    }

    /**

     *

     * @param q

     * @param c

     * @throws IOException

     * @throws TransformationException

     */

    private void createCursoAfeto(QuestionarioImpl q, Course c, DefaultLogMessages logMessages) throws 1.5.0/docs/api/java/io/IOException.html">IOException, TransformationException

    {

        1.5.0/docs/api/java/lang/String.html">String msg;

        QuestionarioPedagogicoCursoAfetoImpl cursoAfeto = null;

        //esta aqui um to_do mas foi revisto e nao aparenta haver problemas

        // As unidades do curso sao carregadas mais abaixo e são adicionadas,

        // Todas as não adicionadas são removidas seguidamente usando a lista de adicionadas.

        //  to_do antigo: fazer aqui um teste a ver se na lista de unidades found vem as unidades do curso afeto

        //reativar o set e testar isso

        //isto serve para o caso do curso ter sido afeto mais que uma vez, tem de se remover as afetacoes e deixar apenas uma

        List<QuestionarioPedagogicoCursoAfeto> cursosFound = DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().find(q.getId(),c.getCode());

        if(cursosFound != null && cursosFound.size() > 1)

        {

            msg = "Encontrados mais que um curso nos mesmos códigos:" + c.getCode() + " apagando um";

            serviceLogWarn(msg);

            logger.warn(msg);

            logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.WARNING,msg));

            cursoAfeto = (QuestionarioPedagogicoCursoAfetoImpl) cursosFound.get(0);

            cursosFound.remove(0);

            for(QuestionarioPedagogicoCursoAfeto ca: cursosFound)

                removeCursoAfeto(ca);

        }

        else if(cursosFound != null && cursosFound.size() == 1)

        {

            msg = "Curso " + c.getCode() + " encontrado, vai atualizar";

            serviceLogInfo(msg);

            logger.info(msg);

            cursoAfeto = (QuestionarioPedagogicoCursoAfetoImpl) cursosFound.get(0);

        }

        else

        {

            msg = "Criando novo curso para o código " + c.getCode();

            serviceLogInfo(msg);

            logger.info(msg);

            cursoAfeto = DomainObjectFactory.createQuestionarioPedagogicoCursoAfeto();

            DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().save(cursoAfeto);

            cursoAfeto.setUnidadesAfetas(new HashSet<QuestionarioPedagogicoUnidadeCurricularAfeta>());

        }

        cursoAfeto.resetStats();

        cursoAfeto.setCourse(c);

        cursoAfeto.setCodigoInstituicao(c.getInstitutionalCode());

        cursoAfeto.setNomeInstituicao(ConfigProperties.getProperty("institution.code."+c.getInstitutionalCode()));

        cursoAfeto.setAno(q.getYear());

        cursoAfeto.setCodigoCurso(c.getCode());

        cursoAfeto.setNome(c.getName());

        cursoAfeto.setQuestionario(q);

        cursoAfeto.setSemestre(q.getSemestre());

        List<Long> newUnitCodesList = new ArrayList<Long>();

        int countUnits = 0;

        //vai buscar todas as unidades da base de dados que fazem match as necessidades

        List<CourseUnitDaoImpl.CourseUnitResult> results = DaoFactory.getCourseUnitDaoImpl().loadCourseUnits(c.getId(), q.getSemestre(), q.getYear());

        int totalUnits =  results.size();

        for(CourseUnitDaoImpl.CourseUnitResult cur : results)

        {

            countUnits++;

            CourseUnit cu = DaoFactory.getCourseUnitDaoImpl().load(cur.id);

            newUnitCodesList.add(cu.getId());

            /** logging **/

            msg = "---->(" + countUnits + " of " + totalUnits  +") CourseUnit loaded: " + cu.getName() + "(" + cu.getCode() + ")";

            serviceLogInfo(msg);

            logger.info(msg);

            /** logging **/

            //este metodo procura a unidade primeiro e apenas a cria se ela ainda nao existir como afeta

            createUnidadeAfeta(cursoAfeto, cur,cu, logMessages);

            DaoFactory.getCourseUnitDaoImpl().evict(cu);

        }

        //o problema poderia dar-se se uma unidade desaparece da base de dados, nesse caso ela já era afeta e o sistema nao a iria remover

        //porque apesar de nao estar na nova lista de codigos, tb nao esta no curso afeto, mas o sistema

        //o que faz é carregar todas as afetas e remover todas as que nao estejam na lista de novas

        removeUnselectedUnits(cursoAfeto,newUnitCodesList);

    }

    /**

     *

     * @param cursoAfeto

     * @param cur

     * @throws IOException

     * @throws TransformationException

     */

    private void createUnidadeAfeta(QuestionarioPedagogicoCursoAfetoImpl cursoAfeto, CourseUnitDaoImpl.CourseUnitResult cur, CourseUnit cu, DefaultLogMessages logMessages) throws 1.5.0/docs/api/java/io/IOException.html">IOException, TransformationException {

        1.5.0/docs/api/java/lang/String.html">String msg;

        QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta = null;

        List<QuestionarioPedagogicoUnidadeCurricularAfeta> unidadesFound = DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().find(cursoAfeto.getQuestionario().getId(), cursoAfeto.getCodigoCurso(), cu.getId());

        if(unidadesFound != null && unidadesFound.size() > 1)

        {

            msg = "Encontradas mais que uma unidade nos mesmos códigos: curso:" +cursoAfeto.getCodigoCurso() + ", unidade " + cu.getCode() + " com id sistema(" + cu.getId() + ") apagando um";

            serviceLogWarn(msg);

            logger.warn(msg);

            logMessages.addMessage(new DefaultLogMessage("questionario.courses.selection", LogMessageTypeEnum.WARNING,msg));

            unidadeAfeta = (QuestionarioPedagogicoUnidadeCurricularAfetaImpl) unidadesFound.get(0);

            unidadesFound.remove(0);

            DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().delete(unidadesFound);

        }

        else if(unidadesFound != null && unidadesFound.size() == 1)

        {

            msg = "Unidade " +  cu.getCode() + " encontrada, vai atualizar";

            serviceLogInfo(msg);

            logger.info(msg);

            unidadeAfeta = (QuestionarioPedagogicoUnidadeCurricularAfetaImpl) unidadesFound.get(0);

        }

        else

        {

            msg = "Criando nova unidade para o código " + cu.getCode();

            serviceLogInfo(msg);

            logger.info(msg);

            unidadeAfeta = DomainObjectFactory.createQuestionarioPedagogicoUnidadeCurricularAfeta();

            unidadeAfeta.setUsar(true);

            unidadeAfeta.setUsarOlap(true);

            unidadeAfeta.setVista(false);

            DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().save(unidadeAfeta);

        }

        unidadeAfeta.resetStats();

        unidadeAfeta.setCursoAfeto(cursoAfeto);//so metemos de um dos lados

        unidadeAfeta.setCourseUnit(cu);

        unidadeAfeta.setCodigoUnidade(cu.getCode());

        unidadeAfeta.addObs("");

        unidadeAfeta.setNome(cu.getName());

        unidadeAfeta.setMarked(false);

        ArrayList<CourseUnitImpl.Tipologia> mergedTipologias = copiarTipologias(cu, unidadeAfeta);

        checkTurmaAndProfs(cu, unidadeAfeta, mergedTipologias);

        checkProfs(cur, unidadeAfeta);

        checkTurmas(cur, unidadeAfeta);

        checkStudents(cur, unidadeAfeta);

        if(unidadeAfeta.isMarked())

            cursoAfeto.incMarcadas();

    }

    /**

     *

     * @param cur

     * @param unidadeAfeta

     */

    private void checkTurmas(CourseUnitDaoImpl.CourseUnitResult cur, QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta) {

        if(cur.turmas == 0)

        {

            unidadeAfeta.setTurmas(0);

            unidadeAfeta.setMarked(true); //WARNING

            unidadeAfeta.addObs("Não tem turmas");

        }

        else

            unidadeAfeta.setTurmas(cur.turmas);

    }

    /**

     *

     * @param cur

     * @param unidadeAfeta

     */

    private void checkProfs(CourseUnitDaoImpl.CourseUnitResult cur, QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta) {

        if(cur.teachers == 0)

        {

            unidadeAfeta.setProfs(0);

            unidadeAfeta.setMarked(true); //WARNING

            unidadeAfeta.addObs("Não tem professores");

        }

        else

            unidadeAfeta.setProfs(cur.teachers);

    }

    /**

     *

     * @param cur

     * @param unidadeAfeta

     */

    private void checkStudents(CourseUnitDaoImpl.CourseUnitResult cur, QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta) {

        if(cur.students == 0)

        {

            unidadeAfeta.setStudents(0);

            unidadeAfeta.setMarked(true); //WARNING

            unidadeAfeta.addObs("Não tem estudantes");

        }

        else

            unidadeAfeta.setStudents(cur.students);

    }

    /**

     *

     * @param cu

     * @param unidadeAfeta

     * @return

     * @throws IOException

     * @throws TransformationException

     */

    private ArrayList<CourseUnitImpl.Tipologia> copiarTipologias(CourseUnit cu, QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta) throws 1.5.0/docs/api/java/io/IOException.html">IOException, TransformationException {

        try

        {

            CourseUnitImpl.Tipologias tipologias = ((CourseUnitImpl)cu).getTipologiasClass();

            //OBTEM-SE TODAS E DEPOIS QUANDO SE GERAREM AS RESPOSTAS VAO-SE OBTER ENTAO SIMPLES OU COMPLEXAS

            if(cu.getCode().equals("100595"))

                1.5.0/docs/api/java/lang/System.html">System.out.println();

            ArrayList<CourseUnitImpl.Tipologia> mergedTipologias = tipologias.obtainMergeTipologias();

            unidadeAfeta.setTipologias(mergedTipologias.size());

            unidadeAfeta.setTipologiasJson(CourseUnitImpl.Tipologias.serializeMergedList(mergedTipologias));

            unidadeAfeta.setAddedTipologias(tipologias.getTipologiasExtraAdicionadas().size());

            return mergedTipologias;

        }

        catch(1.5.0/docs/api/java/lang/Throwable.html">Throwable e)

        {

            ArrayList<CourseUnitImpl.Tipologia> tipologias = new ArrayList<CourseUnitImpl.Tipologia>();

            unidadeAfeta.setMarked(true);

            unidadeAfeta.addObs("Erro a descodificar tipologias");

            unidadeAfeta.setTipologiasJson(CourseUnitImpl.Tipologias.serializeMergedList(tipologias));

            return tipologias;

        }

    }

    /**

     *

     * @param cu

     * @param unidadeAfeta

     * @param mergedTipologias

     */

    private void checkTurmaAndProfs(CourseUnit cu, QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta, ArrayList<CourseUnitImpl.Tipologia> mergedTipologias) {

        if(cu.getTeachers() != null)

        {

            HashMap<String,Boolean> turmaWithProfs = new HashMap<String, Boolean>();

            HashMap<String,Boolean> profsWithTurma = new HashMap<String, Boolean>();

            for(CourseUnitImpl.Tipologia t: mergedTipologias)

            {

                turmaWithProfs.put(t.getCdTurma(),true);

                profsWithTurma.put(t.getCdDocente(),true);

            }

            for(Teacher t: cu.getTeachers())

            {

                if(profsWithTurma.get(""+t.getSigesCode())==null)

                {

                    unidadeAfeta.setProfsWithoutTurma(unidadeAfeta.getProfsWithoutTurma()+1);

                    unidadeAfeta.setMarked(true);

                }

                DaoFactory.getTeacherDaoImpl().evict(t);

            }

            for(CourseUnitTurma t: cu.getTurmas())

            {

                if(turmaWithProfs.get(t.getTurma())==null)

                {

                    unidadeAfeta.setTurmaWithoutProf(unidadeAfeta.getTurmaWithoutProf() + 1);

                    unidadeAfeta.setMarked(true);

                }

                DaoFactory.getCourseUnitTurmaDaoImpl().evict(t);

            }

        }

    }

    /**

     * SERVIÇO

     * @param questionarioId

     * @param cursosAfetos

     * @param session

     * @param questionarioCleared

     * @throws IOException

     * @throws TransformationException

     * @throws NotAuthorizedException

     */

    public void updateTipologiasPedagogico(long questionarioId, List<QuestionarioPedagogicoCursoAfeto> cursosAfetos, UserSession session,QuestionarioImpl questionarioCleared) throws 1.5.0/docs/api/java/io/IOException.html">IOException, TransformationException, NotAuthorizedException {

        if(!questionarioCleared.isClear((UserSessionImpl) session,QuestionarioImpl.QuestionarioClearancesOperation.QUESTIONARIO_CHANGE_TIPOLOGIES.name()))