root/events/phpframework/zend_framework/trunk/app/modules/index/services/Users.php @ 29496

<?php
/**
 * Logic code for users model
 *
 * PHP version 5.2
 *
 * LICENSE
 *
 * This source file is subject to the new BSD license.
 * It is also available through the world-wide-web at this URL:
 * http://framework.zend.com/license/new-bsd
 *
 * @category Phwittr
 * @package modules_index_services
 * @version $id$
 * @copyright 2008 Heavens hell
 * @author Heavens hell <heavenshell.jp@gmail.com>
 * @license New BSD License
 */

/**
 * Users
 *
 * @category Phwittr
 * @package modules_index_services
 * @version $id$
 * @copyright 2008 Heavens hell
 * @author Heavens hell <heavenshell.jp@gmail.com>
 * @license New BSD License
 */
class Index_Services_Users extends Phwittr_Service_Abstract
{
    /**
     * Data access object
     *
     * @var mixed
     * @access private
     */
    private $_dao = null;

    /**
     * Init
     *
     * @access public
     * @return void
     */
    public function init()
    {
        $this->_dao = $this->getDao('Users');
    }

    /**
     * Check user name available
     *
     * @param mixed $name user name
     * @access public
     * @return bool true:Available, false:Not available
     */
    public function isUserNameAvailable($name)
    {
        $row = $this->getUserInfoByName($name);
        if ($row === null) {
            return true;
        }

        return false;
    }

    /**
     * Check email available
     *
     * @param mixed $email Email address
     * @access public
     * @return bool true:Available, false:Not available
     */
    public function isEmailAvailable($email)
    {
        $row = $this->_dao->fetchRow($this->_dao->select()
                        ->where('email = ?', $email)
                        ->where('delete_flag = ?', 0));

        if ($row === null) {
            return true;
        }

        return false;
    }

    /**
     * Insert value to user table
     *
     * @param array $params Insert values
     * @access public
     * @return bool true:Success to insert, false:Fail to insert
     */
    public function register(array $params)
    {
        $data = array(
            'registration_flag' => 1,
            'updated_at'        => strftime('%Y-%m-%d %H:%M:%S', time())
        );

        $where = $this->_dbAdapter->quoteInto('id = ?', $params['id']);
        $this->_dbAdapter->beginTransaction();
        try {
            $id = $this->_dao->update($data, $where);
        } catch(Exception $e) {
            $this->_dbAdapter->rollBack();
            $this->_message = $e->getMessage();
            return false;
        }
        $this->_dbAdapter->commit();

        // Add to authenticate storage
        $data['id']           = $id;
        $data['user_name']    = $params['user_name'];
        $data['email']        = $params['email'];
        $data['private_flag'] = $params['private_flag'];
        $data['userLevel']    = 'owner';
        $class = new stdClass;
        foreach ($data as $key => $val) {
            if ($key === 'password') {
                continue;
            }
            $class->{$key} = $val;
        }

        $auth = Zend_Auth::getInstance();
        $auth->getStorage()->write($class);

        return true;
    }


    /**
     * Pre register
     *
     * @param array $params
     * @access public
     * @return void
     */
    public function preRegister(array $params)
    {
        $registerKey = sha1(uniqid(mt_rand(), true));
        $data = array(
            'user_name'         => $params['name'],
            'email'             => $params['email'],
            'password'          => $this->_createPassword($params['password']),
            'private_flag'      => 0,
            'registration_key'  => $registerKey,
            'registration_flag' => 0,
            'created_at'        => strftime('%Y-%m-%d %H:%M:%S', time()),
            'delete_flag'       => 0
        );

        $this->_dbAdapter->beginTransaction();
        try {
            $id = $this->_dao->insert($data);
        } catch(Exception $e) {
            $this->_dbAdapter->rollBack();
            $this->_message = $e->getMessage();
            return null;
        }
        $this->_dbAdapter->commit();

        return $registerKey;
    }

    /**
     * Get user data by registration key
     *
     * @param mixed $key
     * @access public
     * @return Zend_Db_Table_Rows
     */
    public function getUserInfoByRegisterKey($key)
    {
        $row = $this->_dao->fetchRow($this->_dao->select()
                        ->where('registration_key = ?', $key)
                        ->where('registration_flag =?', 0)
                        ->where('delete_flag = ?', 0));

        if (is_null($row)) {
            return null;
        }

        return $row;
    }

    /**
     * Update users table
     *
     * @param array $params Update params
     * @param mixed $id User id
     * @access public
     * @return bool true:Update success, false:Update fail
     */
    public function update(array $params, $id)
    {
        $update = strftime('%Y-%m-%d %H:%M:%S', time());
        $data = array(
            'user_name'    => $params['name'],
            'email'        => $params['email'],
            'private_flag' => $params['private_flag'],
            'updated_at'   => $update
        );

        $id = (is_numeric($id) ? (int)$id : $id);
        $where = $this->_dbAdapter->quoteInto('id = ?', $id);

        $this->_dbAdapter->beginTransaction();
        try {
            $this->_dao->update($data, $where);
        } catch(Exception $e) {
            $this->_dbAdapter->rollBack();
            $this->_message = $e->getMessage();
            return false;
        }

        $this->_dbAdapter->commit();

        // Update login user infomations
        $auth = Zend_Auth::getInstance()->getIdentity();
        $auth->user_name    = $params['name'];
        $auth->email        = $params['email'];
        $auth->private_flag = $params['private_flag'];
        $auth->updated_at   = $update;
        Zend_Auth::getInstance()->getStorage()->write($auth);

        return true;
    }

    /**
     * Update password
     *
     * @param string $password Password
     * @param mixed $id User id
     * @access public
     * @return bool true:update success, false:update fail
     */
    public function updatePassword($password, $id)
    {
        if ($password === null) {
            return false;
        }
        $update = strftime('%Y-%m-%d %H:%M:%S', time());
        $data = array(
            'password'   => $this->_createPassword($password),
            'updated_at' => $update
        );

        $id = (is_numeric($id) ? (int)$id : $id);
        $where = $this->_dbAdapter->quoteInto('id = ?', $id);

        $this->_dbAdapter->beginTransaction();
        try {
            $this->_dao->update($data, $where);
        } catch(Exception $e) {
            $this->_dbAdapter->rollBack();
            $this->_message = $e->getMessage();
            return false;
        }

        $this->_dbAdapter->commit();

        return true;
    }

    /**
     * Update image
     *
     * @param mixed $path
     * @param mixed $id
     * @access public
     * @return bool true:Success to update image, false:Fail to update image
     */
    public function updateImage($path, $id)
    {
        if ($path === null || $path === '') {
            return false;
        }

        $update = strftime('%Y-%m-%d %H:%M:%S', time());
        $data = array(
            'image'      => $path,
            'updated_at' => $update
        );

        $id    = (is_numeric($id) ? (int)$id : $id);
        $where = $this->_dbAdapter->quoteInto('id = ?', $id);

        $this->_dbAdapter->beginTransaction();
        try {
            $this->_dao->update($data, $where);
        } catch(Exception $e) {
            $this->_dbAdapter->rollBack();
            $this->_message = $e->getMessage();
            return false;
        }
        $this->_dbAdapter->commit();

        return true;
    }

    /**
     * Update image column null
     *
     * @param mixed $id
     * @access public
     * @return bool true:Success to delete image, false:Fail to update image
     */
    public function deleteImage($id)
    {
        if (!is_numeric($id)) {
            return false;
        }

        $update = strftime('%Y-%m-%d %H:%M:%S', time());
        $data = array(
            'image'      => null,
            'updated_at' => $update
        );
        $where = $this->_dbAdapter->quoteInto('id = ?', $id);

        $this->_dbAdapter->beginTransaction();
        try {
            $this->_dao->update($data, $where);
        } catch(Exception $e) {
            $this->_dbAdapter->rollBack();
            $this->_message = $e->getMessage();
            return false;
        }
        $this->_dbAdapter->commit();

        return true;
    }

    /**
     * Create password
     *
     * @param sitrin $plain Plain password string
     * @access private
     * @return string Encrypted password
     */
    private function _createPassword($plain)
    {
        $salt     = substr(sha1(uniqid(mt_rand(), true)), 0, 16);
        $password = sha1($salt . $plain) . ':' . $salt;

        return $password;
    }

    /**
     * Get password from database
     *
     * @param mixed $value User's name or urser's email address
     * @access public
     * @return string salt or null
     */
    public function getSalt($value)
    {
        if ($this->_isEmailAddress($value)) {
            $column = 'email = ?';
        } else {
            $column = 'user_name = ?';
        }

        $row = $this->_dao->fetchRow($this->_dao->select()
                        ->where($column, $value)
                        ->where('delete_flag = ?', 0));

        if ($row === null) {
            return null;
        }

        $passwords = explode(':', $row->password);
        if (!is_array($passwords)) {
            return null;
        }
        $salt = $passwords[1];

        return $salt;
    }

    /**
     * Is value email address?
     *
     * @param mixed $value User's email address
     * @access private
     * @return bool true:Email address, false:Not Email address
     */
    private function _isEmailAddress($value)
    {
        $validator = new Zend_Validate_EmailAddress();
        if ($validator->isValid($value) === false) {
            return false;
        }

        return true;
    }

    /**
     * Authenticate
     *
     * @param mixed $name User name or Email address
     * @param mixed $password Password
     * @access public
     * @return bool true:Success to login, false:Fail to login
     */
    public function authenticate($value, $password)
    {
        if ($this->_isEmailAddress($value)) {
            $column = 'email';
        } else {
            $column = 'user_name';
        }
        $authAdapter = new Zend_Auth_Adapter_DbTable($this->_dbAdapter, 'users' , $column, 'password');
        $authAdapter->setCredentialTreatment('? AND delete_flag = "0"')
                    ->setIdentity($value)
                    ->setCredential($password);

        $ret = $authAdapter->authenticate();
        if ($ret->isValid() === false) {
            return false;
        }

        $data = $authAdapter->getResultRowObject(null, 'password');
        $data->userLevel = 'owner';
        $auth = Zend_Auth::getInstance();
        $auth->getStorage()->write($data);

        return true;
    }

    /**
     * Get users table data by user name
     *
     * @param mixed $name User name
     * @access public
     * @return Zend_Db_Table_Rows or null
     */
    public function getUserInfoByName($name)
    {
        // Todo:Cache!!
        $row = $this->_dao->fetchRow($this->_dao->select()
                        ->where('user_name = ?', $name)
                        ->where('delete_flag = ?', 0));

        if (is_null($row)) {
            return null;
        }

        return $row;
    }

    /**
     * Get users table data by id
     *
     * @param mixed $id
     * @access public
     * @return Zend_Db_Table_Rows or null
     */
    public function getUserInfoById($id)
    {
        if (!is_numeric($id)) {
            return null;
        }
        $row = $this->_dao->fetchRow($this->_dao->select()
                        ->where('id = ?', $id)
                        ->where('delete_flag = ?', 0));

        if (is_null($row)) {
            return null;
        }

        return $row;
    }
}