cron_job_sync_cmis_bridges.inc

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

class Cron_Job_Sync_CMIS_Bridges extends Cron_Job
{


    function __construct($assetid=0)
    {
        $this->_ser_attrs = TRUE;
        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()


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

    protected function _exec(&$msg)
    {
        $bridge_ids = $GLOBALS['SQ_SYSTEM']->am->getTypeAssetids('cmis_bridge', TRUE, TRUE);
        foreach ($bridge_ids as $bridge_id => $type) {
            if ($GLOBALS['SQ_SYSTEM']->am->assetInTrash($bridge_id, TRUE)) continue;
            
            $hh = $GLOBALS['SQ_SYSTEM']->getHipoHerder();
            $running_vars   = Array (
                                'bridge_id' => $bridge_id
                             );
            $errors = $hh->freestyleHipo('hipo_job_sync_cmis_bridge', $running_vars, SQ_PACKAGES_PATH.'/sharepoint/hipo_jobs/');
            if (!empty($errors)) trigger_error("CMIS Bridge (Id #:$bridge_id) HIPO errors:\n".print_r($errors, TRUE), E_USER_WARNING);
        }
            
        return SQ_CRON_JOB_COMPLETED;

    }//end _exec()


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

    }//end run()


}//end class

?>