cron_job_update_trim_record.inc

<?php
require_once SQ_CORE_PACKAGE_PATH.'/system/cron/cron_job/cron_job.inc';
require_once SQ_FUDGE_PATH.'/db_extras/db_extras.inc';

class Cron_Job_Update_Trim_Record extends Cron_Job
{


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

    }//end constructor


    function create(&$link)
    {
        require_once SQ_CORE_PACKAGE_PATH.'/system/system_asset_fns.inc';

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


    function _getName($short_name=FALSE)
    {
        return $GLOBALS['SQ_SYSTEM']->am->getTypeInfo($this->type(), 'name');

    }//end _getName()


    function canClone()
    {
        return FALSE;

    }//end canClone()


    function morph($new_type_code)
    {
        trigger_localised_error('CRON0024', E_USER_WARNING, $GLOBALS['SQ_SYSTEM']->am->getTypeInfo($this->type(), 'name'));
        return FALSE;

    }//end morph()


    function canDelete()
    {
        return FALSE;

    }//end canDelete()

    
    function _exec(&$msg)
    {
        $old_mask = umask(0002);

        require_once SQ_PACKAGES_PATH.'/trim/lib/trim_common.inc';

        $sql        = 'SELECT assetid FROM sq_ast WHERE type_code like \'trim_saved_search\'';
        $query      = MatrixDAL::preparePdoQuery($sql);
        $assetids   = MatrixDAL::executePdoGroupedAssoc($query);
        if (!empty($assetids)) {
            foreach ($assetids as $assetid  => $info) {
                $trash_link = $GLOBALS['SQ_SYSTEM']->am->getParents($assetid, 'trash_folder', TRUE);
                if (empty($trash_link)) {
                    $ss = $GLOBALS['SQ_SYSTEM']->am->getAsset($assetid);
                    if(!empty($ss)) {
                        $connection = $ss->getConnection();
                        $test_connection    = TRIM_Common::test_trim_connection($connection);
                        if ($test_connection) {
                            $ss->updateCachedResult();
                        }//end if
                    }
                }//end if
            }//end if
        }//end if

        umask($old_mask);

        return SQ_CRON_JOB_COMPLETED;

    }//end _exec()


}//end class
?>