Subversion Repositories bacoAlunos

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

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.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.util.ArrayList;

import java.util.HashSet;

import java.util.List;

import java.util.Set;

/**

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

    }

   //todo falta validar as clearances

    //todo falta meter a tarefa no Questionario

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

        }

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

    }

    @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

        serviceLogInfo("Starting running service ");

        logger.info("Starting running service");

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

                1.5.0/docs/api/java/lang/String.html">String msg = "Loading Course BACO ID: " + courseStrId;

                serviceLogInfo(msg);

                logger.info(msg);

                /** logging **/

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

                QuestionarioPedagogicoCursoAfeto cursoAfeto = DomainObjectFactory.createQuestionarioPedagogicoCursoAfeto();

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

                DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().save(cursoAfeto);

                /** logging **/

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

                serviceLogInfo(msg);

                logger.info(msg);

                /** logging **/

                int countUnits = 0;

                int totalUnits =  c.getCourseUnits().size();

                for(CourseUnit cu : c.getCourseUnits())

                {

                    countUnits++;

                    /** logging **/

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

                    serviceLogInfo(msg);

                    logger.info(msg);

                    /** logging **/

                    QuestionarioPedagogicoUnidadeCurricularAfetaImpl unidadeAfeta = DomainObjectFactory.createQuestionarioPedagogicoUnidadeCurricularAfeta();

                    unidadeAfeta.setCourseUnit(cu);

                    unidadeAfeta.setObs("");

                    unidadeAfeta.setCodigoUnidade(cu.getCode());

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

                    unidadeAfeta.setMarked(false);

                    if(cu.getTeachers() == null || cu.getTeachers().size() == 0)

                    {

                        unidadeAfeta.setProfs(0);

                        unidadeAfeta.setMarked(true); //WARNING

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

                    }

                    else

                        unidadeAfeta.setProfs(cu.getTeachers().size());

                    //todo falta as turmas verificacao de numero de profs

                    // testar se ja tem notas acrescentar

                    try{

                        unidadeAfeta.setTipologiasJson(((CourseUnitImpl)cu).getTipologiasClass().obtainMergeTipologiasSerialized());

                    }

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

                    {

                        unidadeAfeta.setMarked(true);

                        unidadeAfeta.setTipologiasJson(CourseUnitImpl.Tipologias.serializeMergedList(new ArrayList<CourseUnitImpl.Tipologia>()));

                        cursoAfeto.setMarcadas(cursoAfeto.getMarcadas()+1);

                        //todo colocar as observacoes auqi e na unidade marcada

                    }

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

                    DaoFactory.getQuestionarioPedagogicoCursoAfetoDaoImpl().save(cursoAfeto);

                }

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

                commitPartially();

            }

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

            }

        }

        setProgress(100);

        commitPartially();

        1.5.0/docs/api/java/lang/String.html">String msg = "Set courses state as " + QuestionarioImpl.SubStatePedagogico.COURSES_ASSIGNED.name();

        serviceLogInfo(msg);

        logger.info(msg);

        q.setSubStatePedagogicoClass(QuestionarioImpl.SubStatePedagogico.COURSES_ASSIGNED);

        commitPartially();

        return logMessages;

    }

}