Subversion Repositories bacoAlunos

package pt.estgp.estgweb.services.courseunits;

import jomm.dao.impl.AbstractDao;

import jomm.utils.PdfUtils;

import org.apache.commons.net.ftp.FTP;

import org.apache.commons.net.ftp.FTPClient;

import org.apache.fop.apps.FOPException;

import org.apache.log4j.Logger;

import org.dom4j.Document;

import pt.estgp.estgweb.Globals;

import pt.estgp.estgweb.domain.*;

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

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

import pt.estgp.estgweb.domain.views.CourseUnitEvaluationView;

import pt.estgp.estgweb.domain.views.CourseUnitView;

import pt.estgp.estgweb.filters.chains.ResourceAccessControlEnum;

import pt.estgp.estgweb.services.data.IRepositoryFile;

import pt.estgp.estgweb.services.data.RepositoryService;

import pt.estgp.estgweb.services.expceptions.ServiceException;

import pt.estgp.estgweb.utils.Dom4jUtil;

import pt.estgp.estgweb.web.FtpServer;

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

import javax.xml.transform.TransformerException;

import javax.xml.transform.dom.DOMSource;

import java.io.*;

import java.text.SimpleDateFormat;

import java.util.*;

/*

 * @author Goncalo Luiz gedl [AT] rnl [DOT] ist [DOT] utl [DOT] pt

 *

 *

 * Created at 17/Out/2003 , 23:45:24

 *

 */

/**

 * @author Jorge Machado

 *

 *

 * So pode editar a avaliação da unidade o docente da unidade

 * É gerado um PDF a cada gravação do Ficheiro

 *

 * Created at 17/Out/2003 , 23:45:24

 *

 */

public class SaveCourseUnitEvaluation implements IService

{

    private 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(SaveCourseUnitEvaluation.class);

    RepositoryService repositoryService = new RepositoryService();

    public CourseUnitEvaluationView save(CourseUnitEvaluationView cupv, 1.5.0/docs/api/java/lang/Long.html">Long coursUnitId, UserSession usession, CourseUnitImpl c) throws ServiceException, 1.5.0/docs/api/javax/xml/transform/TransformerException.html">TransformerException, 1.5.0/docs/api/java/io/IOException.html">IOException, FOPException {

        CourseUnitEvaluation evaluation = c.getCourseUnitEvaluation();

        if(evaluation == null)

        {

            evaluation = new CourseUnitEvaluationImpl();

            DaoFactory.getCourseUnitEvaluationDaoImpl().save(evaluation);

            c.setCourseUnitEvaluation(evaluation);

        }

//

        //O form tem de vir sempre completo com todos os campos

        //Caso isto mude de futuro teremos de usar um novo metodo para

        //comutar o estado e nao o save.

        //Apenas o open muda somente o estado

        /*if(usession.getUser() instanceof Teacher &&

                ((((Teacher)(usession.getUser())).isTeacherOfCourseUnit(c.getId(),true))

                        ||

                        (c.getResponsableTeacher()!=null && usession.getUser().getId() == c.getResponsableTeacher().getId())

        ))

        {

            //PROF OU RESPONSAVEL*/

        cupv.persistViewInObjectTeacher(evaluation);

        /*}

        else if(usession.getUser() instanceof Teacher

                && (((usession.getUser())).hasRole(c.getCourse().getValidationRole())

                ||

                ((usession.getUser()) == c.getCourse().getCoordinator()))

                )

        {

            //COMISSAO DE CURSO

            cupv.persistViewInObjectTeacher(evaluation);

        }*/

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

        1.5.0/docs/api/java/lang/String.html">String estado = "POR ENTREGAR";

        if(cupv.isFechar())

        {

            evaluation.setClosed(true);

            evaluation.setTeacherComplete(true);

            estado = "Aceite pela Comissão de Curso";

        }

        else if(cupv.isTeacherComplete())

        {

            estado = "Entregue à Comissão de Curso pelo docente";

            evaluation.setTeacherComplete(true);

        }

        else if(!cupv.isAutosave())

        {

            estado = "Alterado pelo docente";

            evaluation.setClosed(false);

            //TODO novo

            evaluation.setTeacherComplete(false);

        }

        if(!cupv.isAutosave())

        {

            createPdf(evaluation,c,usession,errors);

            if(usession != null && usession.getUser() != null && usession.getUser() instanceof Teacher)

                DirectedCoordinatedUnitsService.sendNotificationsCourseUnitEvaluationEditedInterestedPeople(c, estado, usession);

            else

            {

                logger.info("Nao vai informar docentes");

            }

        }

        //passou para aqui para não afetar a persistencia

        //estava em cima no create do new e depois o evaluation interno ficava a nulo

        // e no persist ja nao havia nada para persistir

        cupv.setCourseUnitEvaluation(evaluation);

        return cupv;

    }

    public CourseUnitEvaluationView open(1.5.0/docs/api/java/lang/Long.html">Long coursUnitId, UserSession usession,CourseUnitImpl c) throws ServiceException {

        CourseUnitEvaluation evaluation = c.getCourseUnitEvaluation();

        evaluation.setClosed(false);

        evaluation.setTeacherComplete(false);

        CourseUnitEvaluationView cupv = new CourseUnitEvaluationView(evaluation);

        if(usession != null && usession.getUser() != null && usession.getUser() instanceof Teacher)

            DirectedCoordinatedUnitsService.sendNotificationsCourseUnitEvaluationEditedInterestedPeople(c, "Aberto pela Comissão de Curso", usession);

        return cupv;

    }

    /**

     * Get the clearances from courseunit loaded by filter and put them in courseUnitView in service paramenter

     * returning the view fullfilled with clearances

     * @param cuv

     * @param courseUnitId

     * @param usession

     * @param c

     * @return

     * @throws ServiceException

     * @throws TransformerException

     * @throws IOException

     * @throws FOPException

     */

    public CourseUnitView initClearances(CourseUnitView cuv, 1.5.0/docs/api/java/lang/Long.html">Long courseUnitId, UserSession usession, CourseUnitImpl c) throws ServiceException, 1.5.0/docs/api/javax/xml/transform/TransformerException.html">TransformerException, 1.5.0/docs/api/java/io/IOException.html">IOException, FOPException {

        ((CourseUnitImpl)cuv.getCourseUnit()).setClearanceRuledSupport(c.getClearanceRuledSupport());

        return cuv;

    }

        //TODO TEACHER COMPLETE OPEN not in use coordinatores open and close every fields

    /*public CourseUnitEvaluationView setTeacherIncomplete(Long coursUnitId, UserSession usession) throws ServiceException {

        CourseUnit c = DaoFactory.getCourseUnitDaoImpl().get(coursUnitId);

        CourseUnitEvaluation evaluation = c.getCourseUnitEvaluation();

        //So responsaveis e profs desdemente que a avaliação nao esteja fechada

        //caso contrario so coordenadores

        boolean isTeacherOfCourseUnitAndEvaluationNotClosed =

                usession.getUser() instanceof Teacher

                &&

                (

                    ((Teacher)usession.getUser()).isTeacherOfCourseUnit(c.getId(),true)

                        ||

                    c.getResponsableTeacher()!=null && usession.getUser().getId() == c.getResponsableTeacher().getId()

                )

                && !evaluation.isClosed();

        boolean isCoordinatorOrCourseCommission =

                usession.getUser() instanceof Teacher

                        &&

                        (

                            usession.getUser().hasRole(c.getCourse().getValidationRole())

                                ||

                            ((usession.getUser()) == c.getCourse().getCoordinator())

                        );

        if(isTeacherOfCourseUnitAndEvaluationNotClosed || isCoordinatorOrCourseCommission)

        {

            evaluation.setTeacherComplete(false);

        }

        CourseUnitEvaluationView cupv = new CourseUnitEvaluationView(evaluation);

        return cupv;

    }*/

    public void createPdf(CourseUnitEvaluation cuv, CourseUnit cu, UserSession userSession,List<String> errors) throws 1.5.0/docs/api/java/io/IOException.html">IOException, 1.5.0/docs/api/javax/xml/transform/TransformerException.html">TransformerException, FOPException {

        1.5.0/docs/api/java/lang/String.html">String path = generatePdf(cuv, cu);

        RepositoryService repositoryService = new RepositoryService();

        User owner = userSession.getUser();

        if(cu.getEvaluationStreamId() == null)

        {

            1.5.0/docs/api/java/lang/String.html">String identifier = repositoryService.storeRepositoryFile(new 1.5.0/docs/api/java/io/FileInputStream.html">FileInputStream(path), "application/pdf", "pdf",((int) new 1.5.0/docs/api/java/io/File.html">File(path).length()), cu.getCode() + "-evaluation.pdf", "courseunit.evaluation.description" + cu.getName(), ResourceAccessControlEnum.courseunitEvaluationDomain, null, owner);

            cu.setEvaluationStreamId(identifier);

        }

        else

        {

            repositoryService.updateRepositoryFile(cu.getEvaluationStreamId(), new 1.5.0/docs/api/java/io/FileInputStream.html">FileInputStream(path),  "application/pdf", "pdf", ((int)new 1.5.0/docs/api/java/io/File.html">File(path).length()),cu.getCode() + "-evaluation.pdf", "evaluation.evaluation.description " + cu.getName(), ResourceAccessControlEnum.courseunitEvaluationDomain);

        }

        //Obrigar a ser falso

        //NOVO

        if(cuv.isClosed())

        {

            RepositoryFileImpl repoFile = repositoryService.loadView(cu.getEvaluationStreamId());

            sendPdfFtpIonline(cu,errors,userSession,new 1.5.0/docs/api/java/io/FileInputStream.html">FileInputStream(path),repoFile.getLastVersion().getSaveDate(),null);

        }

    }

    public 1.5.0/docs/api/java/lang/String.html">String generatePdf(CourseUnitEvaluation cuv, CourseUnit c) throws 1.5.0/docs/api/java/io/IOException.html">IOException, 1.5.0/docs/api/javax/xml/transform/TransformerException.html">TransformerException, FOPException {

        CourseUnitEvaluationImpl cuvImpl = (CourseUnitEvaluationImpl) DaoFactory.getCourseUnitEvaluationDaoImpl().narrow(cuv);

        5+0%2Fdocs%2Fapi+Document">Document  responseDoc = cuvImpl.getDom(c);

        responseDoc.setXMLEncoding("ISO-8859-1");

        1.5.0/docs/api/java/text/SimpleDateFormat.html">SimpleDateFormat sdf = new 1.5.0/docs/api/java/text/SimpleDateFormat.html">SimpleDateFormat("dd-MM-yyyy");

        responseDoc.getRootElement().addAttribute("data", sdf.format(new java.util.5+0%2Fdocs%2Fapi+Date">Date()));

        1.5.0/docs/api/java/lang/String.html">String path = Globals.TMP_DIR + 1.5.0/docs/api/java/io/File.html">File.separator + c.getCode() + "-" + c.getNormalizedName() + "-eval.pdf";

        1.5.0/docs/api/java/io/FileOutputStream.html">FileOutputStream out = new 1.5.0/docs/api/java/io/FileOutputStream.html">FileOutputStream(path);

        Map<String,Object> params = new HashMap<String,Object>();

        params.put("site", Globals.SITE_URL);

        org.w3c.dom.5+0%2Fdocs%2Fapi+Document">Document dd = Dom4jUtil.toW3c(responseDoc);

        PdfUtils.createPdfFromXml(new 1.5.0/docs/api/javax/xml/transform/dom/DOMSource.html">DOMSource(dd), "pt/estgp/estgweb/services/courseunits/courseunitevaluation.fo.xsl", out, params);

        out.flush();

        out.close();

        return path;

    }

   /* public boolean sendPdfFtpIonline(CourseUnit cu, List<String> errors, UserSession u, FTPClient client) throws IOException, TransformerException, FOPException

    {

        RepositoryService repositoryService = new RepositoryService();

        if(cu.getProgramStreamId() != null && cu.getProgramStreamId().length()> 0)

        {

            RepositoryFileImpl repoFile = repositoryService.loadView(cu.getProgramStreamId());

            String path = generatePdfFile(cu, errors, u);

            sendPdfFtpIonline(cu,errors,u,path,repoFile.getLastVersion().getSaveDate(),client);

            return true;

        }

        return false;

    }*/

    1.5.0/docs/api/java/text/SimpleDateFormat.html">SimpleDateFormat sdf = new 1.5.0/docs/api/java/text/SimpleDateFormat.html">SimpleDateFormat("yyyy_MM_dd.HH_mm_ss");

    private boolean sendPdfFtpIonline(CourseUnit cu, List<String> errors, UserSession u,5+0%2Fdocs%2Fapi+InputStream">InputStream input,5+0%2Fdocs%2Fapi+Date">Date versionDate,FTPClient client) throws 1.5.0/docs/api/java/io/IOException.html">IOException, 1.5.0/docs/api/javax/xml/transform/TransformerException.html">TransformerException, FOPException {

        if(Globals.TEST_ENVIRONEMENT)

        {

            1.5.0/docs/api/java/lang/String.html">String warn = "System in TEST Environement - will NOT send file to ionline test.control.var.DontSendIonlineFiles = true";

            logger.warn(warn);

            return false;

        }

        FtpServer server = null;

        if(client == null)

        {

            server = FtpServer.getNewServer(Globals.FTP_IONLINE_URL,Globals.FTP_IONLINE_USER,Globals.FTP_IONLINE_PASS);

            client = server.getClient();

            if(client == null)

            {

                logger.warn("###################");

                logger.warn("################### > CANT CONNECT FTP");

                return false;

            }

        }

        client.setFileType(FTP.BINARY_FILE_TYPE);

        1.5.0/docs/api/java/lang/String.html">String pastaFichaCurricular = Globals.FTP_IONLINE_START_PATH + cu.getPathIntranet() + "/" + Globals.INTRANET_DTP + "/" + Globals.INTRANET_DTP_FichaAvaliacao;

        if(!client.changeWorkingDirectory(pastaFichaCurricular))

        {

            logger.error("FTP CANT CHANGE TO PATH: " + pastaFichaCurricular);

            return false;

        }

        else

        {

            client.storeFile(cu.getCode() + "_" + cu.getNormalizedName() + "_v" + sdf.format(versionDate) + ".pdf",input);

            if(server != null)

            {

                client.quit();

                client.disconnect();

            }

            return true;

        }

        //

    }

    public void storeAllClosedEvaluationsInActivePeriod() throws 1.5.0/docs/api/java/io/IOException.html">IOException

    {

        CourseUnitDaoImpl dao = DaoFactory.getCourseUnitDaoImpl();

        List<Long> unitsIds = dao.loadClosedCourseUnitsEvaluations();

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

        for (1.5.0/docs/api/java/lang/Long.html">Long unitId: unitsIds) {

            CourseUnit next = DaoFactory.getCourseUnitDaoImpl().load(unitId);

            try {

                if(next.getEvaluationStreamId() == null)

                {

                    1.5.0/docs/api/java/lang/System.html">System.out.print("Generating PDF for evaluation report for: " + next.getCourse().getName() + " - " + next.getSemestre() + " - " + next.getNormalizedName());

                    createPdf(next.getCourseUnitEvaluation(),next,null,errors);

                }

                1.5.0/docs/api/java/lang/System.html">System.out.print("Sending evaluation report for: " + next.getCourse().getName() + " - " + next.getSemestre() + " - " + next.getNormalizedName());

                RepositoryFileImpl repoFile = repositoryService.loadView(next.getEvaluationStreamId());

                IRepositoryFile iRepoFile = repositoryService.loadByIdentifier(next.getEvaluationStreamId());

                if(sendPdfFtpIonline(next,errors,null,iRepoFile.getInput(),repoFile.getLastVersion().getSaveDate(),null))

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

                else

                    1.5.0/docs/api/java/lang/System.html">System.out.print(" ... FAIL probably no StreamID");

                1.5.0/docs/api/java/lang/System.html">System.out.print("\n");

                if(errors.size()>0)

                    for(1.5.0/docs/api/java/lang/String.html">String error:errors)

                        logger.warn(error);

            } catch (1.5.0/docs/api/java/io/IOException.html">IOException e) {

                logger.error(e,e);

            } catch (1.5.0/docs/api/javax/xml/transform/TransformerException.html">TransformerException e) {

                logger.error(e, e);

            } catch (FOPException e) {

                e.printStackTrace();

            }

            AbstractDao.getCurrentSession().evict(next);

        }

    }

    public static void main(1.5.0/docs/api/java/lang/String.html">String[] args) throws 1.5.0/docs/api/java/io/IOException.html">IOException {

        AbstractDao.getCurrentSession().beginTransaction();

        new SaveCourseUnitEvaluation().storeAllClosedEvaluationsInActivePeriod();

        AbstractDao.getCurrentSession().flush();

        AbstractDao.getCurrentSession().getTransaction().commit();

    }

}