yunjing_master/app/appapi/controller/LivebackController.php

<?php
/**
 * 直播回放
 */
namespace app\appapi\controller;

use cmf\controller\HomeBaseController;
use think\facade\Db;
use think\db\Query;

class livebackController extends HomebaseController {
	
	/* 
		回调数据格式
		{
				"channel_id": "2121_15919131751",
				"end_time": 1473125627,
				"event_type": 100,
				"file_format": "flv",
				"file_id": "9192487266581821586",
				"file_size": 9749353,
				"sign": "fef79a097458ed80b5f5574cbc13e1fd",
				"start_time": 1473135647,
				"stream_id": "2121_15919131751",
				"t": 1473126233,
				"video_id": "200025724_ac92b781a22c4a3e937c9e61c2624af7",
				"video_url": "http://200025724.vod.myqcloud.com/200025724_ac92b781a22c4a3e937c9e61c2624af7.f0.flv"
		}
	*/
	public function index(){
		$request = file_get_contents("php://input");
		//file_put_contents('./im.txt',date('y-m-d H:i:s').' 提交参数信息 callback request:'.$request."\r\n",FILE_APPEND);
		$result = array( 'code' => 0 );    
		$data = json_decode($request, true);

		if(!$data){
			$this->callbacklog("request para json format error");
			$result['code']=4001;
			echo json_encode($result);	
			return;
		}
		
		if(/*array_key_exists("t",$data)
				&& array_key_exists("sign",$data)
				&&*/ array_key_exists("event_type",$data) 
				&& array_key_exists("stream_id",$data))
		{
			// $check_t = $data['t'];
			// $check_sign = $data['sign'];
			$event_type = $data['event_type'];
			$stream_id = $data['stream_id'];
		}else {
			$this->callbacklog("request para error");
			$result['code']=4002;
			echo json_encode($result);	
			return;
		}
		/* $md5_sign = $this-> GetCallBackSign($check_t);
		if( !($check_sign == $md5_sign) ){
			$this->callbacklog("check_sign error:" . $check_sign . ":" . $md5_sign);
			$result['code']=4003;
			echo json_encode($result);	
			return;
		}      */   
		
		if($event_type == 100){
			/* 回放回调 */
			if(array_key_exists("video_id",$data) && 
					array_key_exists("video_url",$data) &&
					array_key_exists("start_time",$data) &&
					array_key_exists("end_time",$data) ){
						
				$video_id = $data['video_id'];
				$video_url = $data['video_url'];
				$start_time = $data['start_time'];
				$end_time = $data['end_time'];
			}else{
				$this->callbacklog("request para error:回放信息参数缺少" );
				$result['code']=4002;
				echo json_encode($result);	
				return;
			}
		}     
		
		$ret=0;
		if($event_type == 0){        	
			/* 状态回调 断流 */
			//$ret=$this->stopRoom('',$stream_id);
			
			$this->upOfftime(1,'',$stream_id);

		}elseif ($event_type == 1){
			//推流
			//$ret = $this->dao_live->callBackLiveStatus($stream_id,1);
			
			$this->upOfftime(0,'',$stream_id);

		}elseif ($event_type == 100){
			//腾讯云点播回调
			//$duration = $end_time - $start_time;
			//if ( $duration > 60 ){ 
				
				$data=array(
					"video_url"=>$video_url,
					// "duration"=>$duration,
					// "file_id"=>$video_id,
				);								
				Db::name("user_liverecord")->where("stream='{$stream_id}'")->update($data);

			//}else {
			//	$ret = 0;
			//	$this->callbacklog("tape duration too short:" . strval($duration) ."|" . $stream_id . "|" . $video_id);
			//}
			
		}

		$result['code']=$ret; 
		echo json_encode($result);

	}
	
	public function GetCallBackSign($txTime){
		$config=getConfigPri();
		$md5_val = md5($config['live_push_key'] . strval($txTime));
		return $md5_val;
	}
	
	public function callbacklog($msg){
		//file_put_contents('./callbacklog.txt',date('Y-m-d H:i:s').' 提交参数信息 :'.$msg."\r\n",FILE_APPEND);
	}
	
	public function upOfftime($isoff=1,$uid='',$stream=''){
        $where['islive']=1;
		if($uid){
            $where['uid']=$uid;
		}else{
            $where['stream']=$stream;
		}
        $data=[
            'isoff'=>$isoff,
            'offtime'=>0,
        ];
        if($isoff==1){
            $data['offtime']=time();
        }
        
        $info=Db::name('user_live')->where($where)->update($data);
        
        return 0;
    }
	
	public function stopRoom($uid='',$stream=''){

		$where['islive']=1;
		if($uid){
			$where['uid']=$uid;
			//file_put_contents('./im.txt',date('y-m-d H:i:s').' 提交参数信息 im:'."\r\n",FILE_APPEND);
		}else{
			$where['stream']=$stream;
			//file_put_contents('./im.txt',date('y-m-d H:i:s').' 提交参数信息 callback:'."\r\n",FILE_APPEND);
		}

		$live=Db::name("user_live")->field("uid,showid,starttime,title,province,city,stream,thumb")->where($where)->find();
		//file_put_contents('./im.txt',date('y-m-d H:i:s').' 提交参数信息 sql:'.$where."\r\n",FILE_APPEND);
		//file_put_contents('./im.txt',date('y-m-d H:i:s').' 提交参数信息 live:'.json_encode($live)."\r\n",FILE_APPEND);
		if($live){
			Db::name('user_live')->where(['stream'=>$live['stream']])->delete();
			//  votes
			
			$uid=$live['uid'];
            $stream=$live['stream'];
			$nowtime=time();
			$live['endtime']=$nowtime;
			$live['time']=date("Y-m-d",$live['showid']);
			$nums=zSize('user_'.$stream);
			$live['nums']=0;
			if($nums){
				$live['nums']=$nums;
			}
			
			$live['votes']=0;

			$where2['uid']=['neq',$uid];
            $where2['touid']=$uid;
            $where2['showid']=$live['showid'];

			$votes=Db::name('user_coinrecord')
				->where($where2)
				->sum('totalcoin');
			if($votes){
				$live['votes']=$votes;
			}

			$result=Db::name('user_liverecord')->insert($live);

			hDel("livelist",$uid);
			delcache('user_'.$stream);

			// 解除本场禁言
            $list2=Db::name("user_live_shut")
                ->field('uid')
                ->where("liveuid={$uid} and showid!=0")
                ->select();

            Db::name("user_live_shut")->where("liveuid={$uid} and showid!=0")->delete();

            foreach($list2 as $k=>$v){
                hDel($uid . 'shutup',$v['uid']);
            }
		}		
		return 0;
	}

	/* 定时处理关播-允许短时间 断流续推 */
    public function uplive(){
        $notime=time();
        
        $offtime=$notime - 30;
        
        $where=[];
        $where[]=['islive','=','1'];
        $where[]=['isvideo','=','0'];
        $where[]=['isoff','=','1'];
        $where[]=['offtime','<',$offtime];
        $list=Db::name("user_live")->where($where)->select();
        $list->each(function($v,$k){
            $this->stopRoom('',$v['stream']);
        });
        
        echo 'OK';
    }

}