<?php
Yii::import('application.components.HiboxUpdateCache');
require_once realpath(Yii::app()->basePath . '/../../util/MQ/UserOnline/YMQUserOnlineGetData.class.php');
require_once realpath(Yii::app()->basePath . '/../../util/MQ/UserOnline/YMQUserOnlineSetData.class.php');
require_once realpath(Yii::app()->basePath . '/../../util/MQProcess/YUMMQProcess.class.php'); 
/**
 * 公共联系人类控制器
 */
class HiboxPublicContactController extends HiboxUpdateCache
{
    /**
     * @var string the default layout for the views. Defaults to '//layouts/column1', meaning
     * using two-column layout. See 'protected/views/layouts/column1.php'.
     */
    public $layout = '//layouts/column1';

    /**
     * @var CActiveRecord the currently loaded data model instance.
     */
    private $_model;
    
    /**
     * @return array action filters
     */
    public function filters()
    {
        return array(
            //'accessControl',
        );
    }
    
    /**
     * 显示公共联系人的Wave列表
     */
    public function actionIndex()
    {
        // 默认只显示两人聊天Wave
        $arg = Yii::app()->request->getQuery('q', 2);
        
        // 获取公共联系人的Wave列表
        $model = $this->_getWaveList($arg);
        
        $this->render('index', array('model' => $model));
    }
    
    /**
     * 创建公共联系人
     * 
     * 原通过后台管理方式动态生成, 已不再使用. (old)
     */
    public function actionCreate()
    {
        $model = new HiboxPublicContactForm;
        $this->performAjaxValidation($model);
        
        if (isset($_POST['HiboxPublicContactForm']))
        {
            $model->attributes = $_POST['HiboxPublicContactForm'];
            
            if ($model->validate())
            {
                // 解析配置文件
                $iniArray = $this->parseIniFileToArray();
                // 获取前端文件所在的目录地址
                $frontDirectory = $this->getCurrentFrontDirectory();
                // 源文件存放路径
                $sourceFile = $frontDirectory.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["path"].DIRECTORY_SEPARATOR.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["file"];
                // 获取目标缓存文件存放的目录
                $destDirectory = $this->getBackCacheDirectory();
                $destFile = $destDirectory.DIRECTORY_SEPARATOR.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["file"];
                
                // 如果目录不存在新建一个可写目录
                if (!file_exists($destDirectory))
                {
                    mkdir($destDirectory, 0777);
                }
                // 如果目标目录不可写, 改变文件模式
                if (!is_writable($destDirectory))
                {
                    chmod($destFile, 0777);
                }
                // 判断是否存在缓存文件, 没有新建
                if (!file_exists($sourceFile))
                {
                    $handle = @fopen($destFile, 'w');
                    $content = '<?php '.PHP_EOL. 'global $publicContactID;'.PHP_EOL.'$publicContactID = '.$model->contactID.';'.PHP_EOL.' ?>';
                    fwrite($handle, $content);
                    fclose($handle);
                    // 改变文件权限为: 可读可执行
                    chmod($destFile, 0755);
                    Yii::app()->user->setFlash('success', '已成功创建公共联系人！');
                }
                else
                {
                    Yii::app()->user->setFlash('error', '已创建过公共联系人！');
                    $this->refresh();
                    Yii::app()->end();
                }
                
                $model->onlineState = Yii::app()->request->getPost('onlineState', 1);
                // 加载需要的常量定义文件
                include $frontDirectory. $iniArray["HIBOX_PUBLIC_CONTACT_SET"]["path"].DIRECTORY_SEPARATOR.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["const"];
                // 设置公共联系人当前在线信息
                $this->_setUserOnlineInfo($model->contactID, $model->onlineState);
            }
        }
        
        $this->render('create', array('model' => $model));
    }
    
    /**
     * 修改公共联系人
     */
    public function actionUpdate()
    {
        $model = new HiboxPublicContactForm;
        $this->performAjaxValidation($model);
        
//        include realpath(Yii::app()->basePath.'/extensions/MQ/UserOnline/YMQUserOnlineGetData.class.php');
//        include realpath(Yii::app()->basePath.'/extensions/MQ/UserOnline/YMQUserOnlineSetData.class.php');
//        include realpath(Yii::app()->basePath.'/extensions/MQ/MQProcess/YUMMQProcess.class.php'); 
        
        // 解析配置文件
        $iniArray = $this->parseIniFileToArray();
        // 获取前端文件所在的目录地址
        $frontDirectory = $this->getCurrentFrontDirectory();
        // 源文件存放路径
        $sourceFile = $frontDirectory.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["path"].DIRECTORY_SEPARATOR.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["file"];
        // 获取目标缓存文件存放的目录
        $destDirectory = $this->getBackCacheDirectory();
        $destFile = $destDirectory.DIRECTORY_SEPARATOR.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["file"];
        
        // 检测是否创建过公共联系人
        if(!file_exists($destFile) && !file_exists($sourceFile))
        {
            throw new CHttpException(400, '您尚未创建公共联系人, 不能执行此操作！');
        }
        
        // 判断是否存在缓存文件
        if(!file_exists($destFile) && file_exists($sourceFile))
        {
            copy($sourceFile, $destFile);
        }
        
        // 加载公共联系人配置文件
        include $destFile;

        global $publicContactID;
        // 获取公共联系人的当前在线状态
        $onlineState = YMQUserOnlineGetData::getAll($publicContactID);

        if (!is_array($onlineState))
        {
            $onlineState = array('onlineState' => 0);
        }
        
        if (isset($_POST['HiboxPublicContactForm']))
        {
            $model->attributes = $_POST['HiboxPublicContactForm'];
            $newOnlineState = Yii::app()->request->getPost('onlineState', 1);
            
            // 用于检查是否有修改操作
            $isUpdate = null;
            // 修改公共联系人ID号
            if ($model->contactID != $publicContactID)
            {
                $isUpdate = true;
                $content = file_get_contents($destFile);
                $content = str_replace("$publicContactID", "$model->contactID", $content);
                file_put_contents($destFile, $content);
                unset($content);
            }
            // 修改公共联系人的当前在线状态
            if ($newOnlineState != $onlineState['onlineState'])
            {
                $isUpdate = true;
                $model->onlineState = $newOnlineState;
                $onlineState['onlineState'] = $newOnlineState;
                // 设置公共联系人的在线状态信息
                YMQUserOnlineSetData::set($publicContactID, json_encode($onlineState));
                // 设置公共联系人永久在线
                YMQUserOnlineSetData::setTimeout($publicContactID, 0);
                
//                // 发送即时消息到服务器
//                $data = array('state'  =>  $newOnlineState);    
//                $this->_changeStateToMQ($userID, $data);        
                $this->_setUserOnlineInfo($publicContactID, $newOnlineState);    
            }
            // 未进行修改操作
            if ($isUpdate === null)
            {
                Yii::app()->user->setFlash('error', '尚未进行任何修改！');
            }
            else 
            {
                Yii::app()->user->setFlash('success', '已成功修改公共联系人！');
            }
        }
        else
        {
            $model->contactID = $publicContactID;
            $model->onlineState = $onlineState['onlineState'];
        }
        
        $this->render('update', array('model' => $model));
    }
    
    /**
     * 更新缓存文件
     */
    public function actionUpdateCacheFile()
    {
        $this->updateCacheFile();
    }
    
    /**
     * 初始化消息
     */
    public function actionAjaxInitMessage()
    {
        if (Yii::app()->request->isPostRequest)
        {
            $waveID = Yii::app()->request->getPost('waveID', null);

            if (isset($waveID) && is_numeric($waveID))
            {
                $model = Wave::model()->with('messages')->find('', array(':waveID' => $waveID));
                
                $this->renderPartial('_initMessage', array('model' => $model));
            }
        }
    }
    
    /**
     * 发送消息
     */
    public function actionSendMessage()
    {
        if (Yii::app()->request->isPostRequest)
        {
            $userID = $this->_getPublicContactID();
            $waveID = Yii::app()->request->getPost('waveID', null);
            $message = Yii::app()->request->getPost('message', null);
            
            if (!isset($waveID, $message))
            {
                throw new CHttpException(400, '消息内容不能为空！');
            }
            
            // 目前只处理100K以下的信息内容, 100K以上的暂时不支持, 转为大文本格式
            if (mb_strlen($message, 'utf8') >= (10*1024))
            {
                $hugeContentID = $this->_addHugeContent($message);
                
                $message = '<span class = "hibox_msg"><span class = "hibox_bigContent">'.mb_substr(trim(strip_tags($message)), 0, 512, 'utf8');
                $message.= ' ... <a herf = "#" class = "opt_more_info"  onclick = "IYOHO_opt.WaveTalkContent.moreMsg(this,'.$hugeContentID.')">[点击查看全文]</a></span></span>';
            }
            // 消息内容进行字符串格式转义
            $message = htmlspecialchars(addslashes($message));
            
            $connection = Yii::app()->db;
            $transaction = $connection->beginTransaction();
            try 
            {
                $sqlStatement = "CALL p_im_userMsgs_i(:waveID, :userID, :message, 10)";
                $command = $connection->createCommand($sqlStatement);
                $command->bindValue(':waveID', $waveID);
                $command->bindValue(':userID', $userID);
                $command->bindValue(':message', "$message");
                $messageID = $command->queryScalar();
                // 返回上一页
                $this->redirect(Yii::app()->request->urlReferrer);
                $transaction->commit();
            }
            catch (Exception $e)
            {
                echo $e->getMessage();
                $transaction->rollback();
            }
        }
    }
    
    /**
     * Ajax 验证表单
     */
    protected function performAjaxValidation($model)
    {
        if (isset($_POST['ajax']) && $_POST['ajax'] === 'hibox-public-contact-form')
        {
            echo CActiveForm::validate($model);
            Yii::app()->end();
        }
    }
    
    /**
     * 获取公共联系人ID号
     */
    private function _getPublicContactID()
    {
        static $contactID = null;
        
        if (null === $contactID)
        {
            // 解析配置文件
            $iniArray = $this->parseIniFileToArray();
            // 获取前端文件所在的目录地址
            $frontDirectory = $this->getCurrentFrontDirectory();
            // 源文件存放路径
            $sourceFile = $frontDirectory.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["path"].DIRECTORY_SEPARATOR.$iniArray["HIBOX_PUBLIC_CONTACT_SET"]["file"];
    
            if (!file_exists($sourceFile))
            {
                throw new CHttpException(400, '您尚未设置公共联系人, 不能执行此操作!');
            }
            
            include $sourceFile;
            global $publicContactID;
            
            $contactID = $publicContactID;
            
            unset($iniArray);
        }
        
        return $contactID;
    }
    
    /**
     * 显示公共联系人的Wave列表
     */
    private function _getWaveList()
    {
        $model = array();
        $classID = func_get_arg(0);
        $classID = (int) $classID;
        $userID = $this->_getPublicContactID();

        if (is_numeric($userID) && is_int($classID))
        {    
            // 查询公共联系人的Wave列表
            $waveList = Wave::model()->with('send')->findAll('', array(':userID' => $userID, ':classID' => $classID));

            // 构建Wave列表格式
            foreach ($waveList as $wave)
            {
                $title = $wave->title.' ('.$wave->send->noReads. '条更新'.')';
                $content = '<div id = "message'. $wave->id. '">'. CHtml::link('点击查看', '', array('class' => 'btn', 'onclick' => 'initMessage('. $wave->id. ')')). '</div>';
                $model[$title] = $content;
            }
        }
        
        return $model;
    } 
    
    /**
     * 添加大文本消息
     */
    private function _addHugeContent($message)
    {
        if (is_string($message))
           {
               // 压缩后存储, 由于要加引号, 所以这里加上转义符号
               $message = addslashes(gzcompress($message));
               
               $connection = Yii::app()->db;
               $sqlStatement = "CALL p_im_userMsgs_big_i(:message);";
               $command = $connection->createCommand($sqlStatement);
               $command->bindValue(':message', "$message");
               // 向大文件表中添加内容数据库操作,返回ID
               $hugeContentID = $command->queryScalar();
               
               return $hugeContentID;
           }
    }
    
    /**
     * 发送在线状态到MQ中
     * 
     * @param int $userID
     * @param array $data
     */
    private function _changeStateToMQ($userID, $data)
    {
        // 构造待处理MQ中的创建wave数据实体
        $protocolData = array(
                                 'user' => 0,
                                 'type' => 0,
                                 'data' => array(),
                             );
        $protocolData['user'] = $userID;
        $protocolData['type'] = UM_CHANGESTATE;
        $protocolData['data'] = $data;
        $mMQProcess = new YUMMQProcess();
        // 处理MQ对象
        return $mMQProcess->deal($protocolData);
    }
    
    /**
     * 将登录信息发送到MQ函数
     * 
     * MQ中需要的登录数据协议格式
     * {
     *         user:userID
     *      type:数据协议键值
     *      data
     *      {
     *          state :onlineState
     *      }
     * }
     * 
     * @param int $userID
     * @param int $onlineState
     */
    private function _loginToMQ($userID, $onlineState)
    {
        $loginProtocol = array(
                                  'user' => $userID,
                                  'type' => UM_LOGIN,
                                  'data' => array('state' => $onlineState),
                              );
        $MQProcess = new YUMMQProcess();
        $MQProcess->deal($loginProtocol);
    }
    
    /**
     * 设置公共联系人登录状态信息
     * 
     * @param int $userID
     * @param int $onlineState
     */
    private function _setUserOnlineInfo($userID, $onlineState)
    {
//        include realpath(Yii::app()->basePath.'/extensions/MQ/UserOnline/YMQUserOnlineSetData.class.php');
//        include realpath(Yii::app()->basePath.'/extensions/MQ/MQProcess/YUMMQProcess.class.php');
        
        // 获取IP地址
        $ipObj = new IP();
        $ip = $ipObj->getip();
        // 生成随机码，随机码为8位
        $randomKey = substr(md5(uniqid(rand(),1)), 24, 8);
        // 计算key值
        $keyValue = $userID + time() + $ip;
        // 得到md5的key值
        $key = md5($keyValue.uniqid(rand(), 1));
        
        $userStateInfo = new stdClass();
        $userStateInfo->onlineState = $onlineState;
        //根据用户ID奇偶截取key的位置和长度
        if($userID % 2)
        {
            // 奇数,截取
            $userStateInfo->key = substr($key, 2, 22);
        }
        else
        {   // 偶数,截取
            $userStateInfo->key = substr($key, 4, 22);
        }
        // 随机码赋值
        $userStateInfo->randomKey = $randomKey;
        // 设置状态服务器
        YMQUserOnlineSetData::set($userID, json_encode($userStateInfo));
        // 发送到MQ
        $this->_loginToMQ($userID, $onlineState);      
    }
}
?>