<?php

defined('MBQ_IN_IT') or exit;

MbqMain::$oClk->includeClass('MbqBaseRdEtPm');

/**
 * private message read class

 */
Class MbqRdEtPm extends MbqBaseRdEtPm {
    
    public function __construct() {
    }
    
    public function makeProperty(&$oMbqEtPm, $pName, $mbqOpt = array()) {
        switch ($pName) {
            default:
            MbqError::alert('', __METHOD__ . ',line:' . __LINE__ . '.' . MBQ_ERR_INFO_UNKNOWN_PNAME . ':' . $pName . '.');
            break;
        }
    }
    /**
     * init one private message by condition
     *
     * @return  Mixed
     */
    public function initOMbqEtPm($var, $mbqOpt = array('case'=> 'onPmMessage')) {
        if ($mbqOpt['case'] == 'byMsgId') {
            $message = $this->getObjsMbqEtMessage($var['msgId']);
            $message->boxid = isset($var['boxId']) ?$var['boxId']  : 0;
            return $this->initOMbqEtPm($message);
        }
        else if ($mbqOpt['case'] == 'onPmMessage') {
            //$oMbqEtPm = MbqMain::$oClk->newObj('MbqEtPm');
            //$oMbqEtPm->msgId->setOriValue($var->id);
            //$oMbqEtPm->msgTitle->setOriValue($this->getTitleMessage($var->message));
            //$oMbqEtPm->msgContent->setOriValue($var->message);
            //$oMbqEtPm->sentDate->setOriValue($var->datum);
            //$message = PHP_EOL . PHP_EOL . '____________' . PHP_EOL . $this->processToDisplay($var->message, false);
            //$oMbqEtPm->msgContent->setTmlDisplayValue($message);
            $v = $var;
            $oMbqEtPm = MbqMain::$oClk->newObj('MbqEtPm');
            $oMbqEtPm->boxId->setOriValue($v->boxid);
            $oMbqEtPm->msgId->setOriValue($v->id);
            $oMbqEtPm->msgTitle->setOriValue($this->getTitleMessage($v->message));
            $oMbqEtPm->sentDate->setOriValue($v->datum);
            $oMbqEtPm->isRead->setOriValue($v->toread);
            $oMbqEtPm->isReply->setOriValue($v->toread);
            $oMbqEtPm->isForward->setOriValue($v->replyid);
            $oMbqEtPm->msgFromId->setOriValue($v->fromid);
            $oMbqEtPm->msgFrom->setOriValue($this->getUsername($v->fromid));
            $oMbqEtPm->isOnline->setOriValue(uddeIMisOnline($v->fromid));
            $avatars = KunenaFactory::getAvatarIntegration();
            if($v->boxid==1)
            {
                $oMbqEtPm->iconUrl->setOriValue($avatars->getURL(JFactory::getUser($v->fromid)));
            }
            else 
            {
                $oMbqEtPm->iconUrl->setOriValue($avatars->getURL(JFactory::getUser($v->toid)));
            }
            $oMbqEtUser = MbqMain::$oClk->newObj('MbqEtUser');
            $oMbqEtUser->userId->setOriValue((string)$v->toid);
            $oMbqEtUser->userName->setOriValue($this->getUsername($v->toid));
            $oMbqEtUser->loginName->setOriValue($this->getUsername($v->toid));
            array_push($oMbqEtPm->objsRecipientMbqEtUser,$oMbqEtUser);
            $oMbqEtPm->shortContent->setOriValue($this->processToDisplay(MbqMain::$oMbqCm->getShortContent($v->message),false));
            $oMbqEtPm->msgContent->setOriValue($v->message);
            $oMbqEtPm->msgContent->setTmlDisplayValue($this->processToDisplay($v->message, false));
            return $oMbqEtPm;
        }else if($mbqOpt['case'] =='message'){
            $oMbqEtPm = MbqMain::$oClk->newObj('MbqEtPm');
            $oMbqEtPm->msgContent->setOriValue($this->processToDisplay($var->message));
            return $oMbqEtPm;
        }else if ($mbqOpt['case'] == 'byPostId'){
            $message = $this->getObjsMbqEtQuotePm($var);
            return $this->initOMbqEtPm($message);
        }
        
        //MbqError::alert('', __METHOD__ . ',line:' . __LINE__ . '.' . MBQ_ERR_INFO_NEED_ACHIEVE_IN_INHERITED_CLASSE);
    }
    
    
    
    public function getObjsMbqEtPm($var,  $mbqOpt = array('case'=> 'byBox')){
        if($mbqOpt['case'] == 'byBox')
        {
            $oMbqEtPmBox = $var;
            $oMbqDataPage = $mbqOpt['oMbqDataPage'];
            $limit = (!$oMbqDataPage->lastNum)?  $oMbqDataPage->numPerPage : $oMbqDataPage->lastNum;
            $oCurJUser = MbqMain::$oMbqAppEnv->oCurJUser;
            if($oMbqEtPmBox->boxId->oriValue == 1) 
            {
                $box = uddeIMselectInbox($oCurJUser->id, $oMbqDataPage->startNum, $limit, MbqMain::$oMbqAppEnv->pm->config);
            }
            else if($oMbqEtPmBox->boxId->oriValue == 2) 
            {
                $box = uddeIMselectOutbox($oCurJUser->id, $oMbqDataPage->startNum, $limit, MbqMain::$oMbqAppEnv->pm->config);
            }
            else if($oMbqEtPmBox->boxId->oriValue == 3) 
            {
                $box = uddeIMselectArchive($oCurJUser->id, $oMbqDataPage->startNum, $limit, MbqMain::$oMbqAppEnv->pm->config);
            }
            else 
            {
                return false;
            }
            foreach ($box as $pm){
               $pm->boxid = $oMbqEtPmBox->boxId->oriValue;
               $oMbqEtPm = $this->initOMbqEtPm($pm);
               $boxs[] = $oMbqEtPm;
            }
            $oMbqDataPage->datas = $boxs;
            return $oMbqDataPage;
        }
    }
    /**
     * init one private message box by condition
     *
     * @return  Mixed
     */
    public function initOMbqEtPmBox($var,  $mbqOpt = array('case'=> 'onPmBox')) {
        if(!$var) return false;
        if($mbqOpt['case'] =='onPmBox' ){
            $boxs = array();
            foreach ($var as $v){
                if(!$v->toid || !$v->fromid) continue;
                $oMbqEtPm = MbqMain::$oClk->newObj('MbqEtPm');
                $oMbqEtPm->boxId->setOriValue($v->box_id);
                $oMbqEtPm->msgId->setOriValue($v->id);
                $oMbqEtPm->msgTitle->setOriValue($this->getTitleMessage($v->message));
                $oMbqEtPm->sentDate->setOriValue($v->datum);
                $oMbqEtPm->isRead->setOriValue($v->toread);
                $oMbqEtPm->isReply->setOriValue($v->toread);
                $oMbqEtPm->isForward->setOriValue($v->replyid);
                $oMbqEtPm->msgFromId->setOriValue($v->fromid);
                $oMbqEtPm->msgFrom->setOriValue($this->getUsername($v->fromid));
                $oMbqEtPm->isOnline->setOriValue($v->is_online);
                $oMbqEtPm->iconUrl->setOriValue($v->icon_url);
                $oMbqEtUser = MbqMain::$oClk->newObj('MbqEtUser');
                $oMbqEtUser->userId->setOriValue((string)$v->toid);
                $oMbqEtUser->userName->setOriValue($this->getUsername($v->toid));
                array_push($oMbqEtPm->objsRecipientMbqEtUser,$oMbqEtUser);
                $oMbqEtPm->shortContent->setOriValue($this->processToDisplay(MbqMain::$oMbqCm->getShortContent($v->message),false));
                $boxs[] = $this->returnApiDataPm($oMbqEtPm, false);
            }
            return $boxs;
        }else if($mbqOpt['case'] =='byBoxId'){
            $boxes = $this->getObjsMbqEtPmBox($var, $mbqOpt);
            foreach($boxes as $box)
            {
                if($box->boxId->oriValue == $var)
                {
                    return $box;
                }
            }
            return null;
        }else if($mbqOpt['case'] == 'byMsgId'){
            $msg = $this->getObjsMbqEtQuotePm($var['msgId'],$var['boxId'] );
            return $this->initOMbqEtPmBox($msg, array('case'=>'onPmMsg' ));
        }else if($mbqOpt['case'] == 'onPmMsg'){
            $avatars = KunenaFactory::getAvatarIntegration();
            $oMbqEtPm = MbqMain::$oClk->newObj('MbqEtPm');
            $oMbqEtPm->msgFromId->setOriValue($var->fromid);
            $oMbqEtPm->msgId->setOriValue($var->id);
            $oMbqEtPm->msgTitle->setOriValue($this->getTitleMessage($var->message));
            $oMbqEtPm->msgFrom->setOriValue($this->getUsername($var->fromid));
            $oMbqEtPm->iconUrl->setOriValue($avatars->getURL(JFactory::getUser($var->fromid)));
            $oMbqEtPm->sentDate->setOriValue($var->datum);
            $oMbqEtPm->msgContent->setTmlDisplayValue($this->processToDisplay($var->message));
            $oMbqEtPm->msgContent->setTmlDisplayValueNoHtml($var->message);
            $oMbqEtPm->isOnline->setOriValue(uddeIMisOnline($var->fromid));
            $oMbqEtPm->isRead->setOriValue($var->toread);
            $oMbqEtPm->isReply->setOriValue($var->toread);
            $oMbqEtPm->isForward->setOriValue($var->replyid);
            $oMbqEtUser = MbqMain::$oClk->newObj('MbqEtUser');
            $oMbqEtUser->userId->setOriValue((string)$v->toid);
            $oMbqEtUser->userName ->setOriValue($this->getUsername($v->toid));
            array_push($oMbqEtPm->objsRecipientMbqEtUser,$oMbqEtUser);
            return $oMbqEtPm;
        }
    }
    /**
     * get private message box objs
     *
     * @return  Mixed
     */
    public function getObjsMbqEtPmBox() {
        $oCurJUser = MbqMain::$oMbqAppEnv->oCurJUser;
        $type = array('inbox'=>'Inbox','sent'=>'Outbox','archive'=>'Archive');
        $i = 0;
        foreach ($type as $k=>$v){
            $oMbqEtPmBox = MbqMain::$oClk->newObj('MbqEtPmBox');
            $oMbqEtPmBox->boxId->setOriValue($i+1);
            $oMbqEtPmBox->boxName->setOriValue($v);
            $oMbqEtPmBox->boxType->setOriValue(strtoupper($k));
            if($k=='inbox'){
                $oMbqEtPmBox->msgCount->setOriValue(uddeIMgetInboxCount($oCurJUser->id));
                $oMbqEtPmBox->unreadCount->setOriValue(uddeIMgetInboxCount($oCurJUser->id, 0, true));
            }else if($k=='sent'){
                $oMbqEtPmBox->msgCount->setOriValue(uddeIMgetOutboxCount($oCurJUser->id));
                $oMbqEtPmBox->unreadCount->setOriValue(uddeIMgetOutboxCount($oCurJUser->id, 0 , true));
            }else{
                $oMbqEtPmBox->msgCount->setOriValue(uddeIMgetInboxArchiveCount($oCurJUser->id));
                $oMbqEtPmBox->unreadCount->setOriValue(0);
            }
            $boxs[] = $oMbqEtPmBox;
            $i++;
        }
        return $boxs;
    }
    
    public function getTitleMessage($message){
        $content = explode(PHP_EOL, $message);
        return MbqMain::$oMbqCm->getShortContent($content[0], 30);
    }
            
    function processToDisplay($post, $returnHtml = true){
        $post = MbqMain::$oMbqCm->unreplaceCodes($post, 'quote|email|ebay|map');
        /* change the &quot; in quote bbcode to " maked by kunena! */
        $post = preg_replace('/\[quote=&quot;(.*?)&quot;.*?\]/i', '[quote="$1"]', $post);
        $pathtouser  = uddeIMgetPath('user');
        require_once($pathtouser.'/bbparser.php');
        $config = MbqMain::$oMbqAppEnv->pm->config;
    	if($returnHtml){
            //$post = preg_replace('/<img .*?src="(.*?)" .*?\/>/i', '[img]$1[/img]', $post);
            //replace image insser from mobile
            $post = preg_replace("/<img[^>]+src\s*=\s*[\"']\/?([^\"']+)[\"'][^>]*\>/i", '[img]$1[/img]', $post);
            $post = str_ireplace("[b]", '<b>', $post);
            $post = str_ireplace("[/b]", '</b>', $post);
            $post = str_ireplace("[i]", '<i>', $post);
            $post = str_ireplace("[/i]", '</i>', $post);
            $post = str_ireplace("[u]", '<u>', $post);
            $post = str_ireplace("[/u]", '</u>', $post);
            $post = str_replace("\r", '', $post);
            //$post = str_replace("\n", '<br />', $post);
            $post = str_ireplace('[hr]', '<br />____________________________________<br />', $post);
            $post = str_ireplace('<hr />', '<br />____________________________________<br />', $post);
            $post = str_ireplace('<li>', "\t\t<li>", $post);
            $post = str_ireplace('</li>', "</li><br />", $post);
            $post = str_ireplace('</tr>', '</tr><br />', $post);
            $post = str_ireplace('</td>', "</td>\t\t", $post);
            $post = str_ireplace('</div>', '</div><br />', $post);
            // if system message or bbcodes allowed, call parser
            if ($config->allowbb) $post = uddeIMbbcode_replace($post, $config);
            //if ($config->allowsmile) $post = uddeIMsmile_replace($post, $config);
            //$post = preg_replace("/<img[^>]+src\s*=\s*[\"']\/?([^\"']+)[\"'][^>]*\>/i", '[img]$1[/img]', $post);
    	} else {
            $post = uddeIMbbcode_strip($post);
    	    $post = preg_replace('/<br \/>/i', "\n", $post);
            $post = str_ireplace('[hr]', "\n____________________________________\n", $post);
            $post = str_ireplace('<hr />', "\n____________________________________\n", $post);
            //$post = strip_tags($post);
            $post = html_entity_decode($post, ENT_QUOTES, 'UTF-8');
            $post = strip_tags($post, '<br><i><b><u><font>');
    	}
        $post = str_replace(PHP_EOL, '<br/>' , $post);
    	$post = trim($post);
    	return $post;
      
        
        
    }
    
    /**
     * init one private message box by condition
     *
     * @return  Mixed
     */
    public function initOMbqEtPmBoxInfo() {
        $boxInfo = $this->getObjsMbqEtPmBox();
        $boxs = array();
        foreach ($boxInfo as $box){
            $box = (object) $box;
            $oMbqEtQuotePmBox = MbqMain::$oClk->newObj('MbqEtPmBox');
            $oMbqEtQuotePmBox->boxId->setOriValue($box->box_id);
            $oMbqEtQuotePmBox->boxName->setOriValue($box->box_name);
            $oMbqEtQuotePmBox->msgCount->setOriValue($box->msg_count);
            $oMbqEtQuotePmBox->unreadCount->setOriValue($box->unread_count);
            $oMbqEtQuotePmBox->boxType->setOriValue($box->box_type);
            $boxs[] = $oMbqEtQuotePmBox;
        }
        return $boxs;
    }
    
    public function getUsername($var){
        return JFactory::getUser($var)->username;
    }
    
    public function getTotalMessage(){
        $boxInfo = $this->getObjsMbqEtPmBox();
        return $boxInfo[0]['msg_count'] + $boxInfo[1]['msg_count'];
    }
    
    public function getTotalMessageInbox($oMbqEtPmBox, $type=''){
      
        if($type=='unread') return $oMbqEtPmBox->unreadCount->oriValue;
        return  $oMbqEtPmBox->msgCount->oriValue;
    }
    
    public function getObjsMbqEtMessage($msgId){
        if(!$msgId) return false;
        $database = uddeIMgetDatabase();
        return $database->setQuery('SELECT * FROM #__uddeim WHERE id='.$msgId)->loadObject();
    }

    public function getObjsMbqEtBoxId($msgId){
        $message = $this->getObjsMbqEtMessage($msgId);
        $oCurJUser = MbqMain::$oMbqAppEnv->oCurJUser;
        if($oCurJUser->id == $message->toid) return 1;
        if($oCurJUser->id == $message->fromid) return 2;
        return 3;
    }

    public function getObjsMbqEtQuotePm($msgId, $boxId = 0){
        $oCurJUser = MbqMain::$oMbqAppEnv->oCurJUser;
        if(!$boxId) $boxId = $this->getObjsMbqEtBoxId ($msgId);
        if($boxId==1) $message =  uddeIMselectInboxMessage($oCurJUser->id, $msgId, MbqMain::$oMbqAppEnv->pm->config, 0);
        elseif($boxId==2) $message =  uddeIMselectOutboxMessage($oCurJUser->id, $msgId, MbqMain::$oMbqAppEnv->pm->config, 0);
        elseif($boxId==3) $message =  uddeIMselectArchiveMessage($oCurJUser->id, $msgId, MbqMain::$oMbqAppEnv->pm->config);
        else return false;
        $oMbqWrEtPm = MbqMain::$oClk->newObj('MbqWrEtPm'); //write class
        $oMbqWrEtPm->markMbqEtPmRead($oCurJUser->id, $msgId);
        return $message[0];
    }
    public function getPmRoomCount()
    {
        return 1000;
    }
  
    public function getQuotePm($oMbqEtPm)
    {
        return $oMbqEtPm->msgContent->oriValue;
    }
}