DataAccess/mysql/Reddot.php

Go to the documentation of this file.

<?php
// {{{ license

// +----------------------------------------------------------------------+
// | FastFrame Application Framework                                      |
// +----------------------------------------------------------------------+
// | Copyright (c) 2002-2006 The Codejanitor Group                        |
// +----------------------------------------------------------------------+
// | This source file is subject to the GNU Lesser Public License (LGPL), |
// | that is bundled with this package in the file LICENSE, and is        |
// | available at through the world-wide-web at                           |
// | http://www.fsf.org/copyleft/lesser.html                              |
// | If you did not receive a copy of the LGPL and are unable to          |
// | obtain it through the world-wide-web, you can get it by writing the  |
// | Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, |
// | MA 02111-1307, USA.                                                  |
// +----------------------------------------------------------------------+
// | Authors: Jason Rust <jrust@codejanitor.com>                          |
// | Authors: Greg Gilbert <ggilbert@codejanitor.com>                     |
// +----------------------------------------------------------------------+

// }}}
// {{{ requires

require_once FASTFRAME_ROOT . 'lib/FastFrame/DataAccess.php';
require_once dirname(__FILE__) . '/../../Model/Log.php';

// }}}
// {{{ constants

define('REDDOT_FILTER_BORROWER', 1);

// }}}
// {{{ class FF_DataAccess_Reddot_mysql 

// }}}
class FF_DataAccess_Reddot_mysql extends FF_DataAccess {
    // {{{ properties

    var $o_log;

    var $borrowersTable;

    var $filterName;

    // }}}
    // {{{ constructor

    function FF_DataAccess_Reddot_mysql()
    {
        FF_DataAccess::FF_DataAccess();
        $this->table = $this->o_registry->getConfigParam('data/reddots_table');
        $this->o_log =& new FF_Model_Log();
    }

    // }}}
    // {{{ update()

    function update($in_data)
    {
        unset($in_data['create_date']);
        unset($in_data['creator_id']);
        unset($in_data['borrower_id']);
        unset($in_data['cancelor_id']);
        unset($in_data['cancel_reason']);
        unset($in_data['cancel_date']);
        $o_result =& parent::update($in_data);
        if ($o_result->isSuccess()) {
            $tmp_result =& $this->o_log->newLogEntry('UPDATE', $in_data['id'], $this->table);
        }

        return $o_result;
    }

    // }}}
    // {{{ add()

    function add($in_data)
    {
        $in_data['create_date'] = $this->timestampToISODate($in_data['create_date']);
        unset($in_data['cancelor_id']);
        unset($in_data['cancel_reason']);
        unset($in_data['cancel_date']);
        $o_result =& parent::add($in_data);
        if ($o_result->isSuccess()) {
            $tmp_result =& $this->o_log->newLogEntry('INSERT', $in_data['id'], $this->table);
        }

        return $o_result;
    }

    // }}}
    // {{{ cancel()

    function cancel($in_data)
    {
        $o_result = new FF_Result();
        $s_where = 'id=' . $this->o_data->quoteSmart($in_data['id']);
        $a_data['cancel_reason'] = $in_data['cancel_reason'];
        $a_data['cancel_date'] = $this->timestampToISODate($in_data['cancel_date']);
        $a_data['cancelor_id'] = $in_data['cancelor_id'];
        $result = $this->o_data->autoExecute($this->table, $a_data, DB_AUTOQUERY_UPDATE, $s_where);
        if (DB::isError($result)) {
            $o_result->addMessage($result->getMessage());
            $o_result->setSuccess(false);
        }
        else {
            $tmp_result =& $this->o_log->newLogEntry('DELETE', $in_data['id'], $this->table);
        }

        return $o_result;
    }

    // }}}
    // {{{ getDataByPrimaryKey()

    function getDataByPrimaryKey($in_id, $in_fields = '*')
    {
        return parent::getDataByPrimaryKey($in_id, $this->_getSelectFields());
    }

    // }}}
    // {{{ getListData()

    function getListData($in_where, $in_orderByField, $in_orderByDir, $in_fields = '*')
    {
        if ($this->filterName == REDDOT_FILTER_BORROWER) {
            return parent::getListData($in_where, $in_orderByField, $in_orderByDir, $this->_getSelectFields());
        }
        else {
            $s_borrowerTable = $this->o_registry->getConfigParam('data/borrowers_table');
            $s_query = "SELECT " . $this->_getSelectFields() . ", COUNT(*) AS num_active,
                        CONCAT(first_name, ' ', last_name) AS borrower_name
                        FROM $this->table
                        LEFT JOIN $s_borrowerTable AS b ON borrower_id = b.id
                        WHERE $in_where 
                        GROUP BY borrower_id
                        ORDER BY $in_orderByField " . $this->_getOrderByDirection($in_orderByDir);
            return $this->o_data->query($s_query);
        }
    }

    // }}}
    // {{{ getListFilter()

    function getListFilter($in_searchString, $in_searchFields, $in_filter, $in_filterData)
    {
        $this->filterName = $in_filter;
        // Filter: the reddots for this borrower only
        if ($in_filter == REDDOT_FILTER_BORROWER) {
            $s_filter = sprintf('borrower_id = %s', $this->o_data->quoteSmart($in_filterData['borrowerId']));
        }
        // Filter: all borrowers with active reddots
        else {
            $s_create = $this->timestampToISODate(time() - 
                            $this->o_registry->getConfigParam('reddot/active_cutoff') * 86400);
            $s_filter = "cancel_date = 0 AND create_date > " . $this->o_data->quoteSmart($s_create);
        }

        $s_filter .= ' AND (' . parent::getListFilter($in_searchString, $in_searchFields, $in_filter, $in_filterData) . ')';
        $s_filter = preg_replace('/`borrower_name` LIKE \'%(.*?)%\'/', 
                'b.first_name LIKE \'\\1%\' OR b.last_name LIKE \'\\1%\'', $s_filter);

        return $s_filter;
    }

    // }}}
    // {{{ getNextId()

    function getNextId()
    {
        // change sequence name since we give it the full table name
        $this->o_data->setOption('seqname_format', '%s');
        return $this->o_data->nextId($this->o_registry->getConfigParam('data/sequence_table'));
    }

    // }}}
    // {{{ getProblemReddotsForBorrower()
    
    function getProblemReddotsForBorrower($in_borrowerId)
    {
        $s_query = "SELECT UNIX_TIMESTAMP(create_date) AS create_date, is_block
                    FROM $this->table 
                    WHERE borrower_id = ? AND cancel_date = 0 AND (is_block = 1 OR create_date > ?)
                    ORDER BY is_block DESC, create_date DESC";
        $s_create = $this->timestampToISODate(time() - 
                        $this->o_registry->getConfigParam('reddot/active_duration') * 86400);

        return $this->o_data->getAll($s_query, array($in_borrowerId, $s_create));
    }

    // }}}
    // {{{ getBlockingReddotCountForBorrower()
    
    function getBlockingReddotCountForBorrower($in_borrowerId)
    {
        $s_query = "SELECT COUNT(*) FROM $this->table 
                    WHERE borrower_id = ? AND cancel_date = 0 AND is_block = 1";

        return $this->o_data->getOne($s_query, array($in_borrowerId));
    }

    // }}}
    // {{{ getProblemReddotCountForBorrower()
    
    function getProblemReddotCountForBorrower($in_borrowerId)
    {
        $s_query = "SELECT COUNT(*) FROM $this->table 
                    WHERE borrower_id = ? AND cancel_date = 0 AND (is_block = 1 OR create_date > ?)";
        $s_create = $this->timestampToISODate(time() -
                        $this->o_registry->getConfigParam('reddot/active_duration') * 86400);

        return $this->o_data->getOne($s_query, array($in_borrowerId, $s_create));
    }

    // }}}
    // {{{ getReddotCountForBorrower()
    
    function getReddotCountForBorrower($in_borrowerId)
    {
        $s_query = "SELECT COUNT(*) FROM $this->table 
                    WHERE borrower_id = ? AND cancel_date = 0 and create_date > ?";
        $s_create = $this->timestampToISODate(time() -
                        $this->o_registry->getConfigParam('reddot/active_cutoff') * 86400);

        return $this->o_data->getOne($s_query, array($in_borrowerId, $s_create));
    }

    // }}}
    // {{{ _getSelectFields()

    function _getSelectFields()
    {
        return $this->table . '.id, description, borrower_id, creator_id, create_reason, UNIX_TIMESTAMP(create_date) AS create_date, cancelor_id, cancel_reason, UNIX_TIMESTAMP(cancel_date) AS cancel_date, is_block';
    }

    // }}}
}
?>

---