<?php
namespace soa\controllers\v1;

use Yii;
use soa\controllers\BaseController;
use backend\widgets\YHGImage\Common\Images as CommonImages;
use common\models\Room;
use common\models\Video;
use common\models\LiveComment;
use common\models\RoomNums;

class LivingController extends BaseController
{
    
    public function beforeAction($action) {
        
        return parent::beforeAction($action);
    }
    
    /**
     * 精选房间
     */
    public function actionBest()
    {
        $key = __CLASS__.__FUNCTION__.'app'.$this->app;
        if (!$ret = $this->cache->get($key)){
            
            $ret = Room::find()->with(['master'])->where(['and',['!=','best','0'],['app'=>$this->app]])->limit(2)->orderBy(['update_time'=>SORT_DESC])->all();

            foreach ($ret as $k=>$model){
                $row = [
                    'room_id'=>(int)$model->room_id,
                    'master_pic'=>CommonImages::getTemplateComplex($model->master->pic, 2),
                    'master_name'=>$model->master->name,
                    'master_meta'=>$model->master->meta,
                    'title'=>$model->title,
                    'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
                    'living'=>$model->living,
                    'starting_time'=>$model->starting_time,
                ];
                $ret[$k] = $row;
            }
        
            $dependency = new \yii\caching\DbDependency(['sql' => Yii::$app->db
                ->createCommand('SELECT MAX(update_time) FROM {{%room}} WHERE best!=0 AND app=:app')
                ->bindValue(':app', $this->app)
                ->getRawSql()]);
            $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
        }
        
        $this->renderJson(Yii::$app->params['success_code'],'',$ret);
    }
    
    /**
     * 直播中的所有视频
     */
    public function actionListing()
    {
        $key = __CLASS__.__FUNCTION__.'app'.$this->app;
        if (!$ret = $this->cache->get($key)){
            
            $ret = Room::find()->with(['master','roomNums'])->where(['and',['living'=>1],['status'=>1],['app'=>$this->app]])->joinWith('roomNums rn')->orderBy(['rn.online_num'=>SORT_DESC])->all();

            foreach ($ret as $k=>$model){
                $row = [
                    'room_id'=>(int)$model->room_id,
                    'master_pic'=>'',
                    'master_name'=>'',
                    'master_meta'=>'',
                    'title'=>$model->title,
                    'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
                    'audience_num'=>$model->roomNums ? (int)$model->roomNums->online_num : 0,//在线人数
                ];
                if ($model->master){
                    $row = array_merge($row,[
                        'master_pic'=>CommonImages::getTemplateComplex($model->master->pic, 2),
                        'master_name'=>$model->master->name,
                        'master_meta'=>$model->master->meta,
                    ]);
                }
                $ret[$k] = $row;
            }
            
            $dependency = new \yii\caching\DbDependency(['sql' => Yii::$app->db
                ->createCommand('SELECT MAX(update_time) FROM {{%room}} WHERE living=1 AND status=1 AND app=:app')
                ->bindValue(':app', $this->app)
                ->getRawSql()]);
            $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
        }else{
            Yii::$app->db->cache(function() use (&$ret){
                $_ret = json_decode($ret,true);
                $models = RoomNums::find()->indexBy('room_id')->all();
                foreach ($_ret as $k=>$row){
                    if (!empty($models[$row['room_id']]->online_num)){
                        $row['audience_num'] = (int)$models[$row['room_id']]->online_num;//在线人数
                    }
                    $_ret[$k] = $row;
                }
            }, 60);
        }
        
        
        $this->renderJson(Yii::$app->params['success_code'],'',$ret);
    }
    
    /**
     * 所有直播预告
     */
    public function actionStarting()
    {
        $key = __CLASS__.__FUNCTION__.'app'.$this->app;
        if (!$ret = $this->cache->get($key)){
            
            $ret = Room::find()->with(['master'])->where(['and',['living'=>0],['>','starting_time',time()],['app'=>$this->app]])->orderBy(['starting_time'=>SORT_ASC])->all();

            foreach ($ret as $k=>$model){
                $row = [
                    'room_id'=>(int)$model->room_id,
                    'master_pic'=>CommonImages::getTemplateComplex($model->master->pic, 2),
                    'master_name'=>$model->master->name,
                    'master_meta'=>$model->master->meta,
                    'title'=>$model->title,
                    'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
                    'starting_time'=>$model->starting_time,
                ];
                $ret[$k] = $row;
            }

            $dependency = new \yii\caching\DbDependency(['sql' => Yii::$app->db
                ->createCommand('SELECT MAX(update_time) FROM {{%room}} WHERE living=0 AND starting_time>0 AND app=:app')
                ->bindValue(':app', $this->app)
                ->getRawSql()]);
            $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
        }
        
        
        $this->renderJson(Yii::$app->params['success_code'],'',$ret);
    }
    
    /**
     * 所有精彩回放
     */
    public function actionReplaying()
    {
        $key = __CLASS__.__FUNCTION__.'app'.$this->app;
        if (!$ret = $this->cache->get($key)){
            
            $ret = Video::find()->with(['master'])->where(['and',['status' => 1],['not', ['url' => null]],['not', ['url' => '']],['app'=>$this->app]])->orderBy(['create_time'=>SORT_DESC])->all();

            foreach ($ret as $k=>$model){
                $row = [
                    'video_id'=>(int)$model->id,
                    'master_pic'=>CommonImages::getTemplateComplex($model->master->pic, 2),
                    'master_name'=>$model->master->name,
                    'master_meta'=>$model->master->meta,
                    'title'=>$model->title,
                    'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
                    'url'=>$model->url,
                    'live_title'=>$model->live_title,
                    'live_room_id'=>(int)$model->room_id,
                    'audience_num'=>(int)($model->audience_num+$model->replay_num),
                    'create_time'=>(int)$model->create_time,
                ];
                $ret[$k] = $row;
            }

            $dependency = new \yii\caching\DbDependency(['sql' => Yii::$app->db
                ->createCommand('SELECT MAX(update_time),count(*) FROM {{%video}} WHERE status=1 AND NOT (url IS NULL) AND NOT (url="") AND app=:app')
                ->bindValue(':app', $this->app)
                ->getRawSql()]);
            $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
        }else{
            Yii::$app->db->cache(function() use (&$ret){
                $_ret = json_decode($ret,true);
                $models = Video::find()->indexBy('id')->all();
                foreach ($_ret as $k=>$row){
                    if (!empty($models[$row['video_id']])){
                        $row['audience_num'] = (int)($models[$row['video_id']]->audience_num+$models[$row['video_id']]->replay_num);
                    }
                    $_ret[$k] = $row;
                }
            }, 60);
        }
        
        $this->renderJson(Yii::$app->params['success_code'],'',$ret);
    }
    
    /**
     * 直播详情
     */
    public function actionDetail()
    {
        if ($room_id = $this->requests('room_id'))
        {//直播视频详情
            
            //观看人数+1
            RoomNums::updateAllCounters(['audience_num' => 1],['room_id'=>$room_id]);
            
            $key = __CLASS__.__FUNCTION__.'room_id'.$room_id;
            if (!$ret = $this->cache->get($key)){
                if (!$model = Room::findOne(['room_id'=>$room_id])){
                    $this->renderJson(Yii::$app->params['failed_code'],'找不到该房间');
                }

                $ret = [
                    'master_pic'=>'',
                    'master_name'=>'',
                    'master_meta'=>'',
                    'title'=>$model->title,
                    'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
                    'watermark'=>$model->watermark,
                    'living'=>$model->living,
                    'like_num'=>0,
                    'audience_num'=>0,//在线人数
                    'live_start_time'=>0,
                    'rtmp_downstream_address'=>'',
                    'flv_downstream_address'=>'',
                    'hls_downstream_address'=>'',
                ];

                //直播时长（秒）
                if ($model->living == 2){
                    $ret['live_last_time'] = $model->videoLast ? $model->videoLast->live_end_time-$model->videoLast->live_start_time : 0;
                }

                if ($model->roomNums){
                    $ret = array_merge($ret,[
                        'like_num'=>(int)$model->roomNums->like_num,
                        'audience_num'=>(int)$model->roomNums->online_num,
                    ]);
                }

                if ($model->master){
                    $ret = array_merge($ret,[
                        'master_pic'=>CommonImages::getTemplateComplex($model->master->pic, 2),
                        'master_name'=>$model->master->name,
                        'master_meta'=>$model->master->meta,
                    ]);
                }

                if ($model->videoRecording){
                    $ret = array_merge($ret,[
                        'live_start_time'=>(int)$model->videoRecording->live_start_time,
                    ]);
                }

                if ($model->roomQchannel){
                    if (is_array($downstream_address = json_decode($model->roomQchannel->downstream_address)) && !empty($downstream_address[0])){
                        $ret = array_merge($ret,[
                            'rtmp_downstream_address'=>$downstream_address[0]->rtmp_downstream_address,
                            'flv_downstream_address'=>$downstream_address[0]->flv_downstream_address,
                            'hls_downstream_address'=>$downstream_address[0]->hls_downstream_address,
                        ]);
                    }
                }

                $ret['background_pic'] = 'http://img11.static.yhbimg.com/global/2016/08/17/18/01f17a9cd44149052482e4ee58e590cf1b.png';
                
                $dependency = new \yii\caching\DbDependency(['sql' => Yii::$app->db
                    ->createCommand('SELECT update_time FROM {{%room}} WHERE room_id=:room_id')
                    ->bindValue(':room_id', $room_id)
                    ->getRawSql()]);
                $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
            }else{
                Yii::$app->db->cache(function() use ($room_id,&$ret){
                    if (!$model = RoomNums::findOne(['room_id'=>$room_id])){
                        return;
                    }
                    $_ret = json_decode($ret,true);
                    $ret = array_merge($_ret,[
                        'like_num'=>(int)$model->like_num,
                        'audience_num'=>(int)$model->online_num,
                    ]);
                }, 60);
            }
            
            $this->renderJson(Yii::$app->params['success_code'],'',$ret);
        }elseif ($video_id = $this->requests('video_id'))
        {//重播视频详情
            
            //观看人数+1
            Video::updateAllCounters(['replay_num' => 1],['id'=>$video_id]);
            
            $key = __CLASS__.__FUNCTION__.'video_id'.$video_id;
            if (!$ret = $this->cache->get($key)){
                if (!$model = Video::findOne(['id'=>$video_id])){
                    $this->renderJson(Yii::$app->params['failed_code'],'找不到该回放');
                }

                $ret = [
                    'video_id'=>$model->id,
                    'master_pic'=>'',
                    'master_name'=>'',
                    'master_meta'=>'',
                    'title'=>$model->title,
                    'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
                    'watermark'=>'',
                    'url'=>$model->url,
                    'like_num'=>(int)$model->like_num,
                    'audience_num'=>(int)($model->audience_num+$model->replay_num),
                    'live_title'=>$model->live_title,
                    'live_start_time'=>(int)$model->live_start_time,
                    'live_end_time'=>(int)$model->live_end_time,

                ];

                if ($model->room){
                    $ret = array_merge($ret,[
                        'watermark'=>$model->room->watermark,
                    ]);
                }

                if ($model->master){
                    $ret = array_merge($ret,[
                        'master_pic'=>CommonImages::getTemplateComplex($model->master->pic, 2),
                        'master_name'=>$model->master->name,
                        'master_meta'=>$model->master->meta,
                    ]);
                }

                $ret['background_pic'] = 'http://img11.static.yhbimg.com/global/2016/08/17/18/01f17a9cd44149052482e4ee58e590cf1b.png';
                
                $dependency = new \yii\caching\DbDependency(['sql' => Yii::$app->db
                    ->createCommand('SELECT update_time FROM {{%video}} WHERE id=:video_id')
                    ->bindValue(':video_id', $video_id)
                    ->getRawSql()]);
                $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
            }else{
                Yii::$app->db->cache(function() use ($video_id,&$ret){
                    if (!$model = Video::findOne(['id'=>$video_id])){
                        return;
                    }
                    $_ret = json_decode($ret,true);
                    $ret = array_merge($_ret,[
                        'like_num'=>(int)$model->like_num,
                        'audience_num'=>(int)($model->audience_num + $model->replay_num),
                    ]);
                }, 60);
            }
            
            
            $this->renderJson(Yii::$app->params['success_code'],'',$ret);
        }else
        {
            $this->renderJson(Yii::$app->params['failed_code'],'缺少id');
        }
        
    }
    
    /**
     * 获取回放弹幕
     */
    public function actionGetreplaybarrage()
    {
        if (!$video_id = $this->requests('video_id'))
        {
            $this->renderJson(Yii::$app->params['failed_code'],'缺少id');
        }
        
        Yii::$app->db->cache(function() use ($video_id,&$model){
            $model = Video::findOne($video_id);
        }, Yii::$app->params['defaultCacheExpire']);
        if (empty($model)){
            $this->renderJson(Yii::$app->params['failed_code'],'找不到该回放');
        }
        
        $startTime = (int)$this->requests('startTime',0);
        $timeInterval = $this->requests('timeInterval',300);
        $endTime = $startTime + $timeInterval;
        $room_id = $model->room_id;
        
        $key = __CLASS__.__FUNCTION__."{$room_id}_{$startTime}_{$endTime}";
        if (!$ret = $this->cache->get($key)){
            
            $ret = LiveComment::findByRoomid($room_id)->where(['and',['room_id'=>$room_id],['>=','create_time',$startTime],['<=','create_time',$endTime]])->all();

            foreach ($ret as $k=>$row){
                $_row = [
                    'create_time'=>(int)$row->create_time - $model->live_start_time,
                    'avatar'=>$row->avatar,
                    'name'=>$row->name,
                    'msg'=>$row->comment,
                    'cmd'=>(int)$row->cmd,
                ];
                $ret[$k] = $_row;
            }

            $dependency = new \yii\caching\DbDependency(['sql' => 'SELECT COUNT(*) FROM '.LiveComment::tableName($room_id)." WHERE room_id={$room_id} AND create_time>={$startTime} AND create_time<={$endTime}"]);
            $this->cache->set($key, json_encode($ret), Yii::$app->params['defaultCacheExpire'], $dependency);
        }
        
        $this->renderJson(Yii::$app->params['success_code'],'',$ret);
    }
}