DataAccess/mysql/Demo.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('DEMOS_FILTER_BORROWER_DEMO', 1);

// }}}
// {{{ class FF_DataAccess_Demo_mysql 

// }}}
class FF_DataAccess_Demo_mysql extends FF_DataAccess {
    // {{{ properties

    var $o_log;

    var $demoItemsTable;

    var $borrowerDemosTable;

    var $itemsTable;

    var $groupsTable;

    var $filterName;

    // }}}
    // {{{ constructor

    function FF_DataAccess_Demo_mysql()
    {
        FF_DataAccess::FF_DataAccess();
        $this->table = $this->o_registry->getConfigParam('data/demos_table');
        $this->demoItemsTable = $this->o_registry->getConfigParam('data/demo_items_table');
        $this->groupsTable = $this->o_registry->getConfigParam('data/groups_table');
        $this->itemsTable = $this->o_registry->getConfigParam('data/items_table');
        $this->borrowerDemosTable = $this->o_registry->getConfigParam('data/borrower_demos_table');
        $this->o_log =& new FF_Model_Log();
    }

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

    function update($in_data)
    {
        $a_items = $in_data['items'];
        unset($in_data['items']);
        unset($in_data['create_date']);
        unset($in_data['itemsToRemove']);
        unset($in_data['borrowersToAdd']);
        $o_result =& parent::update($in_data);
        if ($o_result->isSuccess()) {
            $tmp_result =& $this->o_log->newLogEntry('UPDATE', $in_data['id'], $this->table);
            $this->addNewItems($in_data['id'], $a_items, $o_result);
        }

        return $o_result;
    }

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

    function add($in_data)
    {
        $a_items = $in_data['items'];
        unset($in_data['items']);
        unset($in_data['create_date']);
        unset($in_data['itemsToRemove']);
        unset($in_data['borrowersToAdd']);
        $in_data['deleted'] = false;
        $o_result =& parent::add($in_data);
        if ($o_result->isSuccess()) {
            $tmp_result =& $this->o_log->newLogEntry('INSERT', $in_data['id'], $this->table);
            $this->addNewItems($in_data['id'], $a_items, $o_result);
        }

        return $o_result;
    }

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

    function getListData($in_where, $in_orderByField, $in_orderByDir, $in_fields = '*')
    {
        if ($this->filterName == DEMOS_FILTER_BORROWER_DEMO) {
            $s_query = "SELECT t2.id, name, description, UNIX_TIMESTAMP(t1.create_date) AS create_date
                        FROM $this->borrowerDemosTable AS t1 
                        INNER JOIN $this->table as t2 ON t1.demo_id = t2.id
                        WHERE $in_where GROUP BY t2.id ORDER BY $in_orderByField " . 
                        $this->_getOrderByDirection($in_orderByDir);
            return $this->o_data->query($s_query);
        }
        else {
            return parent::getListData($in_where, $in_orderByField, $in_orderByDir);
        }
    }

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

    function getListFilter($in_searchString, $in_searchFields, $in_filter, $in_filterData)
    {
        $this->filterName = $in_filter;
        if ($this->filterName == DEMOS_FILTER_BORROWER_DEMO) {
            $s_filter = sprintf('borrower_id = %s AND t1.deleted != 1',
                    $this->o_data->quoteSmart($in_filterData['borrowerId']));
        } 
        else {
            $s_filter = 'deleted != 1 AND ';
            $s_filter .= '(' . parent::getListFilter($in_searchString, $in_searchFields, $in_filter, $in_filterData) . ')';
        }

        return $s_filter;
    }

    // }}}
    // {{{ remove()

    function remove($in_demoId)
    {
        $a_data['deleted'] = true;
        $a_data['id'] = $in_demoId;
        return parent::update($a_data);
    }

    // }}}
    // {{{ 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'));
    }

    // }}}
    //{{{ getDemosByBorrowerId()

    function getDemosByBorrowerId($in_borrowerId)
    {
        $s_query = "SELECT demo_id FROM $this->borrowerDemosTable WHERE borrower_id = %s AND deleted = 0";
        return $this->o_data->getCol($s_query,0, $in_borrowerId);
    }
    
    // }}}
    // {{{ getDemoItems()

    function getDemoItems($in_id)
    {
        $s_query = "SELECT item_id, barcode,
                    IF(i.name IS NULL, g.name, i.name) AS name, 
                    IF(i.name IS NULL, g.is_kit, 0) AS is_kit, 
                    ISNULL(i.name) AS is_group 
                    FROM $this->demoItemsTable AS d
                    LEFT JOIN $this->itemsTable AS i ON d.item_id=i.id
                    LEFT JOIN $this->groupsTable AS g ON d.item_id=g.id
                    WHERE demo_id=?"; 
        return $this->o_data->getAll($s_query, array($in_id));
    }

    // }}}
    // {{{ addNewItems()

    function addNewItems($in_demoId, $in_items, &$in_resultObj)
    {
        $s_query = "SELECT item_id FROM $this->demoItemsTable WHERE demo_id=?"; 
        $a_existingItems = $this->o_data->getCol($s_query, 0, $in_demoId);
        $s_stmt = $this->o_data->autoPrepare($this->demoItemsTable, array('demo_id', 'item_id'));
        foreach ($in_items as $a_data) {
            if (!is_null($a_data['itemId']) &&
                !in_array($a_data['itemId'], $a_existingItems)) {
                if (PEAR::isError($o_result = $this->o_data->execute($s_stmt, array($in_demoId, $a_data['itemId'])))) {
                    $in_resultObj->addMessage(sprintf(_('Error adding item with id: %s'), $a_data['itemId']));
                    $in_resultObj->setSuccess(false);
                }
                else {
                    // Add the item to the list of existing items
                    $a_existingItems[] = $a_data['itemId'];
                }
            }
        }
    }

    // }}}
    // {{{ removeItem()

    function removeItem($in_demoId, $in_itemId, &$in_resultObj)
    {
        $s_stmt = $this->o_data->prepare("DELETE FROM $this->demoItemsTable WHERE demo_id=? AND item_id=?"); 
        if (PEAR::isError($tmp_result = $this->o_data->execute($s_stmt, array($in_demoId, $in_itemId)))) {
            $in_resultObj->addMessage($tmp_result->getMessage());
            $in_resultObj->setSuccess(false);
        }
    }

    // }}}
    // {{{ addDemoToBorrower()

    function &addDemoToBorrower($in_demoId, $in_borrowerId)
    {
        $o_result = new FF_Result();
        $a_data['borrower_id'] = $in_borrowerId;
        $a_data['demo_id'] = $in_demoId;
        $a_data['create_date'] = $this->timestampToISODate(time());
        $a_data['deleted'] = false;
        $result = $this->o_data->autoExecute($this->borrowerDemosTable, $a_data);
        if (DB::isError($result)) {
            $o_result->addMessage($result->getMessage());
            $o_result->setSuccess(false);
        }

        return $o_result;
    }

    // }}}
    // {{{ removeDemoFromBorrower()

    function removeDemoFromBorrower($in_demoId, $in_borrowerId)
    {
        $o_result = new FF_Result();
        $s_stmt = $this->o_data->prepare("UPDATE $this->borrowerDemosTable SET deleted = 1 WHERE demo_id = ? AND borrower_id = ?");
        if (DB::isError($result = $this->o_data->execute($s_stmt, array($in_demoId, $in_borrowerId)))) {
            $o_result->addMessage($result->getMessage());
            $o_result->setSuccess(false);
        }

        return $o_result;
    }

    // }}}
    // {{{ getMissingDemos()

    function getMissingDemos($in_items, $in_borrowerId)
    {
        $s_itemGroupWhere = '';
        $a_items = array();
        foreach ($in_items as $s_key => $a_item) {
            $s_itemGroupWhere .= sprintf(' OR di.item_id = %s', $a_item['item_id']);
            if (!$a_item['is_group']) {
                $a_items[] = $a_item['item_id'];
            }

            // Key it for fast searching later on
            unset($in_items[$s_key]);
            $in_items[$a_item['item_id']] = $a_item;
        }

        if (count($a_items) > 0) {
            $o_groupsDataAccess =& FF_DataAccess::factory('Group');
            $a_groups = $o_groupsDataAccess->getGroupsForItems($a_items);
            foreach ($a_groups as $s_groupId => $s_itemId) {
                $s_itemGroupWhere .= sprintf(' OR di.item_id = %s', $s_groupId);
                // Copy over the info about the item that found this group
                $in_items[$s_groupId] = $in_items[$s_itemId];
            }
        }

        $s_query = "SELECT DISTINCT(d.id), d.name, di.item_id
                    FROM $this->table AS d
                    INNER JOIN $this->demoItemsTable AS di ON d.id = di.demo_id
                    LEFT JOIN $this->borrowerDemosTable AS b ON b.demo_id = d.id  AND b.deleted = 0 AND b.borrower_id = ?
                    WHERE (b.borrower_id IS NULL) AND d.deleted=0 AND ( 0 $s_itemGroupWhere)";
        $a_demos = $this->o_data->getAll($s_query, array($in_borrowerId));
        // Add additional information about the item
        foreach ($a_demos as $s_key => $a_demo) {
            if (isset($in_items[$a_demo['item_id']])) {
                $a_demos[$s_key]['is_group'] = $in_items[$a_demo['item_id']]['is_group'];
                $a_demos[$s_key]['item_name'] = $in_items[$a_demo['item_id']]['name'];
            }
        }

        return $a_demos;
    }

    // }}}
}
?>

---