Subversion Repositories bacoAlunos

package pt.estgp.estgweb.services.jobs;

import jomm.dao.impl.AbstractDao;

import org.apache.log4j.FileAppender;

import org.apache.log4j.Level;

import org.apache.log4j.Logger;

import org.apache.log4j.PatternLayout;

import pt.estgp.estgweb.utils.Globals;

import pt.estgp.estgweb.domain.JobServiceTask;

import pt.estgp.estgweb.domain.JobServiceTaskImpl;

import pt.estgp.estgweb.domain.JobServiceTaskParameter;

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

import java.io.IOException;

import java.util.*;

/**

 * Created by jorgemachado on 02/11/15.

 *

 * Todos os serviços podem correr em BackGround através da chamada ao JobRunner

 * desde que implementem esta interface

 */

public abstract class ServiceJob implements JobHandler

{

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_importYear_KEY = "JOB_importYear_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_semestre_KEY = "JOB_semestre_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_sendIonline_KEY = "JOB_sendIonline_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_sendEmail_KEY = "JOB_sendEmail_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_cloneOnlyNews_KEY = "JOB_cloneOnlyNews_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_generateAllPdfs_KEY = "JOB_generateAllPdfs_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_validate_KEY = "JOB_validade_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_institution_KEY = "JOB_institution_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_questionario_courseList_KEY = "JOB_questionario_courseList_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_questionario_id_KEY = "JOB_questionario_id_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_questionario_report_id_KEY = "JOB_questionario_report_id_KEY";

    public static final 1.5.0/docs/api/java/lang/String.html">String JOB_questionario_sigesCode_KEY = "JOB_questionario_sigesCode_KEY";

    /*Log for service run*/

    protected final 1.5.0/docs/api/java/util/logging/Logger.html">Logger serviceLog = 1.5.0/docs/api/java/util/logging/Logger.html">Logger.getLogger("JobServiceTaskLog");

    /*Class regular log*/

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

    private Map<String,JobServiceTaskParameter> parameters = new HashMap<String, JobServiceTaskParameter>();

    protected pt.estgp.estgweb.domain.JobServiceTaskImpl jobServiceTask = null; //to be used in subService in order to update log and check stopRequest

    public ServiceJob()

    {

    }

    public Collection<JobServiceTaskParameter> getParameters() { return parameters.values(); }

    public Map<String,JobServiceTaskParameter> getParametersMap() { return parameters;}

    public JobServiceTask getJobServiceTask() { return jobServiceTask; }

    public void setParameters(Set<JobServiceTaskParameter> parameters)

    {

        this.parameters.clear();

        for(JobServiceTaskParameter param: parameters)

        {

            this.parameters.put(param.getName(),param);

        }

    }

    /**

     * Inicialisation

     * @param jobServiceTask

     */

    public void setJobServiceTask(JobServiceTaskImpl jobServiceTask) {

        this.jobServiceTask = jobServiceTask;

        jobServiceTask.setProgress(0);

        //Service Log initialization

        logger.info("Defining service log " + jobServiceTask.getLogFilePath());

        serviceLog.removeAllAppenders();

        serviceLog.setLevel(org.apache.log4j.1.5.0/docs/api/java/util/logging/Level.html">Level.INFO);

        1.5.0/docs/api/java/lang/String.html">String logPath = Globals.JOB_SERVICES_LOG_DIR + java.io.1.5.0/docs/api/java/io/File.html">File.separator + jobServiceTask.getLogFilePath();

        java.io.1.5.0/docs/api/java/io/File.html">File dirs = new java.io.1.5.0/docs/api/java/io/File.html">File(logPath).getParentFile();

        if(!dirs.exists())

            dirs.mkdirs();

        try {

            serviceLog.addAppender(new FileAppender(new PatternLayout("%d (%F:%L) %-5r %-5p [%t] %c{2} - %m%n"), logPath));

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

            logger.info("Error defining service log", ex);

        }

        serviceLog.setAdditivity(false);

        serviceLog.info("STARTING INFO serviceLog FOR SERVICE " + jobServiceTask.getLogFilePath() + " LOG at " + jobServiceTask.getLogFilePath());

    }

    /**

     * Run the job

     * This method is called from JobDaemon is synchronous

     */

    public void runJob()

    {

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

        if(jobServiceTask == null)

            throw new 1.5.0/docs/api/java/lang/RuntimeException.html">RuntimeException("This Service as not been initialized to run as JobService");

        msg = "STARTING SERVICE";

        serviceLog.info(msg);

        logger.info(msg);

        msg = "CLASS: " + jobServiceTask.getTargetService();

        serviceLog.info(msg);

        logger.info(msg);

        if(jobServiceTask.getCreatedBy() != null)

        {

            msg = "CREATED BY: " + jobServiceTask.getCreatedBy().getUsername() + " - " + jobServiceTask.getCreatedBy().getName();

            serviceLog.info(msg);

            logger.info(msg);

        }

        else

        {

            msg ="CREATED BY: unknown";

            serviceLog.info(msg);

            logger.info(msg);

        }

        for(JobServiceTaskParameter parameter: parameters.values())

        {

            msg = "PARAMETER: " + parameter.getName() + " : " + parameter.getObject().toString();

            serviceLog.info(msg);

            logger.info(msg);

        }

        logger.info("Starting job service " + getClass().getName() + " more info in serviceLog " + jobServiceTask.getLogFilePath());

        jobServiceTask.setProgress(0);

        jobServiceTask.setThreadId(new 1.5.0/docs/api/java/lang/Integer.html">Integer("" + 1.5.0/docs/api/java/lang/Thread.html">Thread.currentThread().getId()));

        jobServiceTask.setStatusEnum(JobServiceTaskImpl.JobStatus.STARTED);

        jobServiceTask.setServiceStartDate(new 5+0%2Fdocs%2Fapi+Date">Date());

        jobServiceTask.setServiceLastUpdateDate(new 5+0%2Fdocs%2Fapi+Date">Date());

        commitPartially();

        try {

            //call the implementation of service this will update serviceLog and progress

            ILogMessages messages = runJobServiceTask();

            if(messages.hasErrors())

                jobServiceTask.setStatusEnum(JobServiceTaskImpl.JobStatus.FINISHED_ERRORS);

            else if(messages.hasWarnings())

                jobServiceTask.setStatusEnum(JobServiceTaskImpl.JobStatus.FINISHED_WARNINGS);

            else

                jobServiceTask.setStatusEnum(JobServiceTaskImpl.JobStatus.FINISHED);

            jobServiceTask.setServiceLastUpdateDate(new 5+0%2Fdocs%2Fapi+Date">Date());

            jobServiceTask.setServiceFinishDate(new 5+0%2Fdocs%2Fapi+Date">Date());

            serviceLog.info("FINISHING SERVICE");

            logger.info("Finishing job service " + getClass().getName() + " more info in serviceLog " + jobServiceTask.getLogFilePath());

        } catch (1.5.0/docs/api/java/lang/Throwable.html">Throwable throwable) {

            jobServiceTask.setStatusEnum(JobServiceTaskImpl.JobStatus.FAILED);

            jobServiceTask.setServiceLastUpdateDate(new 5+0%2Fdocs%2Fapi+Date">Date());

            jobServiceTask.setServiceFinishDate(new 5+0%2Fdocs%2Fapi+Date">Date());

            serviceLog.info("ERROR IN SERVICE", throwable);

            logger.info("Error in job service " + getClass().getName() + " more info in serviceLog " + jobServiceTask.getLogFilePath());

       }

    }

    public void setProgress(int progress){

        1.5.0/docs/api/java/lang/System.html">System.out.println(progress+"% PROGRESS##############");

        if(jobServiceTask != null) jobServiceTask.setProgress(progress);

    }

    public void serviceLogInfo(1.5.0/docs/api/java/lang/String.html">String str){ if(jobServiceTask != null) serviceLog.info(str);}

    public void serviceLogWarn(1.5.0/docs/api/java/lang/String.html">String str){ if(jobServiceTask != null) serviceLog.warn(str);}

    public void serviceLogError(1.5.0/docs/api/java/lang/String.html">String str){ if(jobServiceTask != null) serviceLog.error(str);}

    public void serviceLogFatal(1.5.0/docs/api/java/lang/String.html">String str){ if(jobServiceTask != null) serviceLog.fatal(str);}

    public void serviceLogInfo(1.5.0/docs/api/java/lang/String.html">String str, 1.5.0/docs/api/java/lang/Throwable.html">Throwable e){ if(jobServiceTask != null) serviceLog.info(str,e);}

    public void serviceLogWarn(1.5.0/docs/api/java/lang/String.html">String str, 1.5.0/docs/api/java/lang/Throwable.html">Throwable e){ if(jobServiceTask != null) serviceLog.warn(str,e);}

    public void serviceLogError(1.5.0/docs/api/java/lang/String.html">String str, 1.5.0/docs/api/java/lang/Throwable.html">Throwable e){ if(jobServiceTask != null) serviceLog.error(str,e);}

    public void serviceLogFatal(1.5.0/docs/api/java/lang/String.html">String str, 1.5.0/docs/api/java/lang/Throwable.html">Throwable e){ if(jobServiceTask != null) serviceLog.fatal(str,e);}

    //Implemented in SubService to run the Job

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

    /**

     * Should be override on services wich can run only once at a time

     * Should return false is schedulle over time is permited

     * If not only RunNowService will schedulle

     * @return

     */

    public boolean runOnlyOnDemand()

    {

        return false;

    }

    protected void commitPartially() {

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

        AbstractDao.getCurrentSession().beginTransaction();

        printMem(false);

        AbstractDao.getCurrentSession().clear();

        printMem(false);

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

        printMem(true);

        if(jobServiceTask != null)

            AbstractDao.getCurrentSession().update(jobServiceTask);

    }

    private void printMem(boolean printService)

    {

        int mb = 1024*1024;

        //Getting the runtime reference from system

        1.5.0/docs/api/java/lang/Runtime.html">Runtime runtime = 1.5.0/docs/api/java/lang/Runtime.html">Runtime.getRuntime();

        //serviceLogInfo("##### Heap utilization statistics [MB] #####");

        logger.debug("##### Heap utilization statistics [MB] #####");

        //Print used memory

        logger.info("Used Memory:" + (runtime.totalMemory() - runtime.freeMemory()) / mb);

        if(printService)

            serviceLogInfo("#####Heap Used Memory:" + (runtime.totalMemory() - runtime.freeMemory()) / mb + "[MB]");

        //Print free memory

        //serviceLogInfo("Free Memory:" + runtime.freeMemory() / mb);

        logger.debug("Free Memory:" + runtime.freeMemory() / mb);

        //Print total available memory

        //serviceLogInfo("Total Memory:" + runtime.totalMemory() / mb);

        logger.debug("Total Memory:" + runtime.totalMemory() / mb);

        //Print Maximum available memory

        //serviceLogInfo("Max Memory:" + runtime.maxMemory() / mb);

        logger.debug("Max Memory:" + runtime.maxMemory() / mb);

    }

    public void serviceLogInfoWithLoggerSource(1.5.0/docs/api/java/lang/String.html">String message)

    {

        serviceLogInfo(message);

        logger.log(this.getClass().getCanonicalName(), 1.5.0/docs/api/java/util/logging/Level.html">Level.INFO, message, null);

    }

}