trigger_action_reset_hit_count.inc

<?php
require_once SQ_INCLUDE_PATH.'/general_occasional.inc';
require_once SQ_CORE_PACKAGE_PATH.'/system/triggers/trigger_action/trigger_action.inc';

class Trigger_Action_Reset_Hit_Count extends Trigger_Action
{


    public static function execute($settings, &$state)
    {
        if (empty($state['asset'])) {
            // grab the asset if assetid is given, but not the asset.
            if (empty($state['assetid'])) {
                return FALSE;
            } else {
                $state['asset'] = &$GLOBALS['SQ_SYSTEM']->am->getAsset($state['assetid']);
            }
        }
        if (is_null($state['asset'])) return FALSE;

        $GLOBALS['SQ_SYSTEM']->changeDatabaseConnection('db2');
        $GLOBALS['SQ_SYSTEM']->doTransaction('BEGIN');

        // we need to check if there is already an entry in the DB
        try {
            $bind_vars = Array('assetid' => (string) $state['assetid']);
            $asset_hit_count = MatrixDAL::executeAll('data_package', 'getHitCount', $bind_vars);
        } catch (Exception $e) {
            $GLOBALS['SQ_SYSTEM']->doTransaction('ROLLBACK');
            $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();
            throw new Exception('Unable to reset hit count due to database error: '.$e->getMessage());
        }

        // if there is already a entry in the DB we will remove it from the table
        if (!empty($asset_hit_count)) {
            try {
                $bind_vars = Array('assetid' => (string) $state['assetid']);
                $result = MatrixDAL::executeQuery('data_package', 'deleteHitCount', $bind_vars);
            } catch (Exception $e) {
                $GLOBALS['SQ_SYSTEM']->doTransaction('ROLLBACK');
                $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();
                throw new Exception('Unable to decrement hit count due to database error: '.$e->getMessage());
            }
        }

        $GLOBALS['SQ_SYSTEM']->doTransaction('COMMIT');
        $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();

    }//end execute()


    public static function getInterface($settings, $prefix, $write_access=FALSE)
    {
        // This trigger does not require any customisation from the details screen.
        return FALSE;

    }//end getInterface()


    public static function processInterface(&$settings, $request_data)
    {
        // This trigger does not use any settings, so we do not need to save.
        return FALSE;

    }//end processInterface()


    public static function getLocks($settings, &$state)
    {
        return Array($state['assetid'] => Array('lookups'));

    }//end getLocks()


}//end class

?>