DataAccess/mysql/TicketWatchlist.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>                          |
// +----------------------------------------------------------------------+

// }}}
// {{{ requires

require_once FASTFRAME_ROOT . 'lib/FastFrame/DataAccess.php';

// }}}
// {{{ class FF_DataAccess_TicketWatchlist_mysql 

// }}}
class FF_DataAccess_TicketWatchlist_mysql extends FF_DataAccess {
    // {{{ constructor

    function FF_DataAccess_TicketWatchlist_mysql()
    {
        FF_DataAccess::FF_DataAccess();
        $this->table = $this->o_registry->getConfigParam('data/ticket_watchlist_table');
    }

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

    function remove($in_ticketId, $in_userId)
    {
        $o_result = new FF_Result();
        $s_stmt = $this->o_data->prepare("DELETE FROM $this->table WHERE ticket_id = ? AND user_id = ? LIMIT 1");
        if (DB::isError($result = $this->o_data->execute($s_stmt, array($in_ticketId, $in_userId)))) {
            $o_result->addMessage($result->getMessage());
            $o_result->setSuccess(false);
        }
        
        return $o_result;
    }

    // }}}
    // {{{ getWatchlistByTicketId()

    function getWatchlistByTicketId($in_ticketId)
    {
        $s_profileTable = $this->o_registry->getConfigParam('data/table', 'profile', 'profile');
        $s_query = "SELECT tw.user_id, CONCAT(p.firstname, ' ', p.lastname) AS fullname
                    FROM $this->table AS tw
                    LEFT JOIN $s_profileTable AS p ON tw.user_id = p.id
                    WHERE tw.ticket_id = ? ORDER BY fullname";

        if (is_null($in_ticketId) || 
            DB::isError($result = $this->o_data->getAssoc($s_query, false, $in_ticketId))) {
            return array();
        }
        else {
            return $result;
        }
    }

    // }}}
    // {{{ getWatchlistEmailsByTicketId()

    function getWatchlistEmailsByTicketId($in_ticketId)
    {
        $s_profileTable = $this->o_registry->getConfigParam('data/table', 'profile', 'profile');
        $s_query = "SELECT p.email FROM $this->table AS tw
                    LEFT JOIN $s_profileTable AS p ON tw.user_id = p.id
                    WHERE tw.ticket_id = ?";

        if (DB::isError($result = $this->o_data->getCol($s_query, 0, $in_ticketId))) {
            return array();
        }
        else {
            return $result;
        }
    }

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

    // }}}
}
?>

---