cron_job_escalate_safe_trash.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_Escalate_Safe_Trash 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_escalate_safe_trash');

    }//end _getName()


    public function canClone()
    {
        return FALSE;

    }//end canClone()


    public function canDelete()
    {
        return FALSE;

    }//end canDelete()
    
    
    protected function _exec(&$msg)
    {
        $cron_mgr_assetid = $GLOBALS['SQ_SYSTEM']->am->getSystemAssetid('cron_manager');
        $links = $GLOBALS['SQ_SYSTEM']->am->getLinks($cron_mgr_assetid, SQ_LINK_TYPE_3, 'cron_job_attempt_safe_trash');

        foreach ($links as $link) {
            $job_assetid = $link['minorid'];
            $job_link = $GLOBALS['SQ_SYSTEM']->am->getLink($job_assetid, SQ_LINK_NOTICE, '', TRUE, 'updating');

            $job_info = $GLOBALS['SQ_SYSTEM']->am->getAssetInfo(Array($job_assetid));
            $job_info = $job_info[$job_assetid];

            $trash_user_info = $GLOBALS['SQ_SYSTEM']->am->getAssetInfo($job_info['created_userid']);
            $trash_user_info = $trash_user_info[$job_info['created_userid']];

            if (!empty($job_link)) {
                $trashing_assetid = $job_link['minorid'];
                $trash_errors = $GLOBALS['SQ_SYSTEM']->am->canSafeTrashAsset($trashing_assetid);

                // If there are safe trash errors
                if (!empty($trash_errors)) {
                    $trashing_asset = $GLOBALS['SQ_SYSTEM']->am->getAsset($trashing_assetid);
                    $from = '0';

                    $ms = $GLOBALS['SQ_SYSTEM']->getMessagingService();
                    $messages = Array();

                    if (!empty($trash_errors['status'])) {
                        // unsafe status
                        $type = 'cron.safetrash.notify.status';
                        $asset_admins = $GLOBALS['SQ_SYSTEM']->am->getPermission($trashing_assetid, SQ_PERMISSION_ADMIN, TRUE);

                        $replacements = Array(
                                            'assetid'       => $trashing_asset->id,
                                            'asset_name'    => $trashing_asset->name,
                                            'asset_status'  => get_status_description($trash_errors['status']),
                                            'trash_date'    => easy_datetime(iso8601_ts($job_info['created'])),
                                            'trashing_user' => $trash_user_info['name'],
                                        );

                        if (empty($asset_admins)) $asset_admins = Array(0);
                        $msg = $ms->newMessage($asset_admins, $type, $replacements);
                        $messages[] = $msg;
                    }

                    if (!empty($trash_errors['links'])) {
                        // unsafe links
                        $type = 'cron.safetrash.notify.links';

                        foreach ($trash_errors['links'] as $link) {
                            $asset_admins = $GLOBALS['SQ_SYSTEM']->am->getPermission($link['majorid'], SQ_PERMISSION_ADMIN, TRUE);
                            $linked_asset = $GLOBALS['SQ_SYSTEM']->am->getAsset($link['majorid']);

                            $replacements = Array(
                                                'assetid'           => $trashing_asset->id,
                                                'asset_name'        => $trashing_asset->name,
                                                'link_assetid'      => $linked_asset->id,
                                                'link_asset_name'   => $linked_asset->name,
                                                'trash_date'        => easy_datetime(iso8601_ts($job_info['created'])),
                                                'trashing_user'     => $trash_user_info['name'],
                                            );

                            if (empty($asset_admins)) $asset_admins = Array(0);
                            $msg = $ms->newMessage($asset_admins, $type, $replacements);
                            $messages[] = $msg;
                        }


                    }

                    if (!empty($trash_errors['children'])) {
                        // unsafe children
                        $type = 'cron.safetrash.notify.children';

                        foreach ($trash_errors['children'] as $link) {
                            $asset_admins = $GLOBALS['SQ_SYSTEM']->am->getPermission($link['minorid'], SQ_PERMISSION_ADMIN, TRUE);
                            $linked_asset = $GLOBALS['SQ_SYSTEM']->am->getAsset($link['minorid']);

                            $replacements = Array(
                                                'assetid'           => $trashing_asset->id,
                                                'asset_name'        => $trashing_asset->name,
                                                'link_assetid'      => $linked_asset->id,
                                                'link_asset_name'   => $linked_asset->name,
                                                'trash_date'        => easy_datetime(iso8601_ts($job_info['created'])),
                                                'trashing_user'     => $trash_user_info['name'],
                                            );

                            if (empty($asset_admins)) $asset_admins = Array(0);
                            $msg = $ms->newMessage($asset_admins, $type, $replacements);
                            $messages[] = $msg;
                        }
                    }

                    $ms->send($messages);

                }//end if trash errors
            }//end if job link not empty
        }//end foreach cron job link

        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



?>