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

        // if there is already a entry in the DB we will just decrement the hit count
        if (!empty($asset_hit_count)) {
            if (isset($asset_hit_count[0]['hitcount'])) {
                if ((int) $asset_hit_count[0]['hitcount'] == 1) {
                    $deleterow = TRUE;
                } else {
                    $deleterow = FALSE;
                    $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 decrement hit count due to database error: '.$e->getMessage());
                    }
                }
            } else {
                // error
            }
        }

        if (isset($deleterow) && $deleterow) {
            // if the hit count is equal to 1, delete the row
            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

?>