cron_job_generate_log_reports.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/system/cron/cron_job/cron_job.inc';
require_once SQ_INCLUDE_PATH.'/workflow_manager.inc';
require_once SQ_FUDGE_PATH.'/general/datetime.inc';

class Cron_Job_Generate_Log_Reports extends Cron_Job
{


    function __construct($assetid=0)
    {
        parent::__construct($assetid);

    }//end constructor


    public function create(Array &$link)
    {
        require_once SQ_CORE_PACKAGE_PATH.'/system/system_asset_fns.inc';
        if (!system_asset_fns_create_pre_check($this)) {
            return FALSE;
        }
        $GLOBALS['SQ_SYSTEM']->changeDatabaseConnection('db2');
        $GLOBALS['SQ_SYSTEM']->doTransaction('BEGIN');

        if ($linkid = parent::create($link)) {
            if (!system_asset_fns_create_cleanup($this)) {
                $linkid = FALSE;
            }
        }

        if ($linkid) {
            $GLOBALS['SQ_SYSTEM']->doTransaction('COMMIT');
        } else {
            $GLOBALS['SQ_SYSTEM']->doTransaction('ROLLBACK');
        }

        $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();
        return $linkid;

    }//end create()


    protected function _getName($short_name=FALSE)
    {
        return translate('cron_job_generate_log_reports');

    }//end _getName()


    public function canClone()
    {
        return FALSE;

    }//end canClone()


    public function canDelete()
    {
        return FALSE;

    }//end canDelete()
    
    
    protected function _exec(&$msg)
    {
        // set the UMASK to u=rw,g=rw,o=r (0002), so that the system can write to the the logfiles the cronjob creates
        if (substr(PHP_OS, 0, 3) != 'WIN') $old_mask = umask(0113);

        $lm = $GLOBALS['SQ_SYSTEM']->getLogManager();

        $rotated_logs = $lm->rotateLogs();

        // nothing was rotated, so don't generate any reports and end prematurely
        if (empty($rotated_logs)) return SQ_CRON_JOB_COMPLETED;

        // get all the log_reports in the system before looping through, if they exist
        $status = $this->generateReports($rotated_logs);

        if (isset($old_mask)) umask($old_mask);

        return SQ_CRON_JOB_COMPLETED;

    }//end _exec()


    public function generateReports(Array $target_logs)
    {
        if (empty($target_logs)) return FALSE;

        if (!$GLOBALS['SQ_SYSTEM']->am->installed('log_report')) {
            return FALSE;
        }

        $log_reports  = $GLOBALS['SQ_SYSTEM']->am->getTypeAssetids('log_report', FALSE, TRUE);

        // a list of all the logs in the system
        $lm = $GLOBALS['SQ_SYSTEM']->getLogManager();
        $logs = $lm->getLogs();
        foreach ($target_logs as $logname) {
            if (isset($logs[$logname])) {
                $this->generateReportFromLog($logname, $log_reports);
            }
        }

        return TRUE;

    }//end generateReports()


    public function generateReportFromLog($logname, Array &$log_reports)
    {
        if (empty($log_reports)) return FALSE;

        // start up a hipo for each report
        $hh = $GLOBALS['SQ_SYSTEM']->getHipoHerder();

        foreach ($log_reports as $reportid => $info) {
            $report_type = $info['type_code'];
            $report = $GLOBALS['SQ_SYSTEM']->am->getAsset($reportid, $report_type);
            if ($report->logname == $logname) {
                $vars   = Array(
                            'assetid'           => $reportid,
                            'report'            => $report,
                          );
                $status = $hh->freestyleHIPO('hipo_job_generate_report', $vars);
            }
        }

        return TRUE;

    }//end generateReportFromLog()


    public function run()
    {
        $res = parent::run();
        if ($res & SQ_CRON_JOB_REMOVE) {
            $res = $res & -SQ_CRON_JOB_REMOVE;
        }
        return $res;

    }//end run()


}//end class



?>