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.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];

    }

    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");

        }

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

        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;

    }

    /**

     *

     * @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);

        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**/

        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<String> 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.getCodigoUnidade()))

            {

                /** 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;

        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.resetStats();

        cursoAfeto.setCourse(c);

        cursoAfeto.setAno(q.getYear());

        cursoAfeto.setCodigoCurso(c.getCode());

        cursoAfeto.setNome(c.getName());

        cursoAfeto.setQuestionario(q);

        cursoAfeto.setSemestre(q.getSemestre());

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

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

        int countUnits = 0;

        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.getCode());

            /** logging **/

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

            serviceLogInfo(msg);

            logger.info(msg);

            /** logging **/

            createUnidadeAfeta(cursoAfeto, cur,cu, logMessages);

            DaoFactory.getCourseUnitDaoImpl().evict(cu);

        }

        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.getCode());

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

        {

            msg = "Encontradas mais que uma unidade nos mesmos códigos: curso:" +cursoAfeto.getCodigoCurso() + ", unidade " + cu.getCode() + " 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();

            DaoFactory.getQuestionarioPedagogicoUnidadeCurricularAfetaDaoImpl().save(unidadeAfeta);

        }

        unidadeAfeta.resetStats();

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

        unidadeAfeta.setCourseUnit(cu);

        unidadeAfeta.setCodigoUnidade(cu.getCode());

        unidadeAfeta.setObs("");

        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();

            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);

            }

        }

    }

}