trigger_action_increment_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_Increment_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 increment hit count due to database error: '.$e->getMessage());
        }

        // if there is already a entry in the DB we will just increment the hit count
        if (!empty($asset_hit_count)) {
            if (isset($asset_hit_count[0]['hitcount'])) {
                $new_hit_count = (int) $asset_hit_count[0]['hitcount'];
                $new_hit_count++;
                // we update the entry in the DB
                try {
                    $bind_vars = Array(
                                  'assetid'     => (string) $state['assetid'],
                                  'hitcount'    => $new_hit_count,
                                 );
                    $result = MatrixDAL::executeQuery('data_package', 'updateHitCount', $bind_vars);
                } catch (Exception $e) {
                    $GLOBALS['SQ_SYSTEM']->doTransaction('ROLLBACK');
                    $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();
                    throw new Exception('Unable to increment hit count due to database error: '.$e->getMessage());
                }
            } else {
                // error
            }
        } else {
            // we insert a new entry in the DB
            try {
                $bind_vars = Array(
                              'assetid'     => (string) $state['assetid'],
                              'hitcount'    => 1,
                             );
                $result = MatrixDAL::executeQuery('data_package', 'insertHitCount', $bind_vars);
            } catch (Exception $e) {
                $GLOBALS['SQ_SYSTEM']->doTransaction('ROLLBACK');
                $GLOBALS['SQ_SYSTEM']->restoreDatabaseConnection();
                // Bug Fix  #3995 race condition in hit count
                // Fail silently if we cannot add a new entry to the database
                return TRUE;
            }
        }

        $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

?>