wonderful/live/lib/Handle.php

<?php
namespace Live\Lib;

use Dever;

class Handle
{
    public function method($config)
    {
        if ($config['type'] == 1) {
            $method = new Qiniu($config);
        }

        return $method;
    }

    # 启动
    public function start($id)
    {
        $info = Dever::db('live/stream')->one($id);
        $config = Dever::db('live/info')->one($info['live_id']);
        $method = $this->method($config);
        $stream = $method->start($info['key']);
    }

    # 禁播
    public function stop($id)
    {
        $info = Dever::db('live/stream')->one($id);
        $config = Dever::db('live/info')->one($info['live_id']);
        $method = $this->method($config);
        $stream = $method->stop($info['key']);
    }

    # 保存
    public function save($id, $log_id)
    {
        $info = Dever::db('live/stream')->one($id);
        $config = Dever::db('live/info')->one($info['live_id']);
        $method = $this->method($config);

        $info_update['where_id'] = $info['id'];
        $info_update['status'] = 3;

        Dever::db('live/stream')->update($info_update);

        Dever::db('live/stream_ios_log')->update(array('edate' => time(), 'where_id' => $log_id));

        return true;
    }

    # 建立ios直播日志
    public function saveIosLog($id, $log_id = false, $table = false)
    {
        $info = Dever::db('live/stream')->one($id);

        if (!$log_id) {
            $time = time();
            $data['sdate'] = $time;
            $data['stream_id'] = $id;
            $data['live_id'] = $info['live_id'];
            $data['active_id'] = $info['active_id'];
            $id = Dever::db('live/stream_ios_log')->insert($data);
        } else {

            $config = Dever::db('live/info')->one($info['live_id']);
            $log = Dever::db('live/stream_ios_log')->one($log_id);
            $method = $this->method($config);
            $log['sdate'] = intval($log['sdate']);
            $log['edate'] = intval($log['edate']);

            try {
                $data['url_m3u8'] = $config['host'] . $method->save($info['key'],$log['sdate'], $log['edate']);
                $data['url_mp4'] = $config['host'] . $method->save($info['key'], $log['sdate'], $log['edate'], 'mp4');
            } catch (\Exception $e) {
                $data['url_m3u8'] = $data['url_mp4'] = '';
            }

            if (!$data['url_m3u8']) {
                return;
            }
            $data['where_id'] = $log_id;
            Dever::db('live/stream_ios_log')->update($data);
            $id = $log_id;

            if ($table) {
                $this->createUrl($table, $method, $config, $info);
            }
        }
        
        return $id;
    }

    # 生成回放地址
    public function createUrl($table, $method, $config, $info)
    {
        $data = Dever::db($table)->state(array('stream_id' => $info['id']));
        if ($data) {
            foreach ($data as $k => $v) {
                $this->createUrlOne($v, $table, $method, $config, $info);
            }
        }
    }

    public function createUrlOne($data, $table, $method, $config, $info)
    {
        if (!$data['url_m3u8'] && $data['sdate'] > 0 && $data['edate'] > 0) {

            $data['sdate'] = intval($data['sdate']);
            $data['edate'] = intval($data['edate']);

            try {
                $url_m3u8 = $config['host'] . $method->save($info['key'],$data['sdate'], $data['edate']);
                $url_mp4 = $config['host'] . $method->save($info['key'], $data['sdate'], $data['edate'], 'mp4');
            } catch (\Exception $e) {
                $url_m3u8 = $url_mp4 = '';
            }

            if (!$url_m3u8) {
                return;
            }

            Dever::db($table)->update(array('where_id' => $data['id'], 'url_m3u8' => $url_m3u8, 'url_mp4' => $url_mp4));
        }
    }

    # 开始直播
    public function startLive($id)
    {
        $info = Dever::db('live/stream')->one($id);
        $config = Dever::db('live/info')->one($info['live_id']);
        $method = $this->method($config);

        $data['where_id'] = $info['id'];
        $data['status'] = 2;

        Dever::db('live/stream')->update($data);
    }

    # 初始化流
    public function init($id, $name = '')
    {
        $info = Dever::db('live/stream')->one($id);
        if ($info['url_rtmp']) {
            return;
        }
        if ($name) {
            $info['key'] = $name;
        }

        return $this->get($info, true);
    }

    # 获取流信息 定时跑
    public function get($info, $create = false)
    {
        if (!is_array($info)) {
            $info = Dever::db('live/stream')->one($info);
        }

        $config = Dever::db('live/info')->one($info['live_id']);
        
        $method = $this->method($config);

        if ($create) {
            $stream = $method->create($info['key']);
        } else {
            $stream = $method->getInfo($info['key']);
        }

        # 根据上次得到推流地址的时间计算下次应该得到的地址
        if (!$info['live_date']) {
            $info['live_date'] = 0;
        }
        $time = time();
        $num = $info['times'];
        if ($time - $info['live_date'] > $num) {
            $rtmp = $method->getRtmp($info['key'], $info['times'] * 3600);
        }

        if (!$info['url_rtmp']) {
            $url = $method->getPlay($info['key']);
        }

        $status = array();
        $history = array();

        try {
            $status = $method->getLiveStatus($info['key']);
        } catch (\Exception $e) {
            $status = array();
        }

        try {
            $history = $method->history($info['key']);
        } catch (\Exception $e) {
            $history = array();
        }

        $data['where_id'] = $info['id'];
        if (isset($rtmp) && $rtmp) {
            $data['live'] = $rtmp;
            $data['live_date'] = $time;
        }
        
        if (isset($url) && isset($url['rtmp']) && $url['rtmp']) {
            $data['url_rtmp'] = $url['rtmp'];
            $data['url_hls'] = $url['hls'];
            $data['url_hdl'] = $url['hdl'];
            $data['url_pic'] = $url['pic'];
        }

        $live = Dever::json_decode($info['info']);

        # 直播信息
        if ($stream) {
            $live['info'] = $stream;
        }
        
        # 直播状态
        if ($status) {
            $live['live'] = $status;
        }

        # 直播历史
        if ($history) {
            $live['history'] = $history;
            if (isset($history['items']) && $history['items']) {
                foreach ($history['items'] as $k => $v) {
                    $this->saveLog($info['id'], $v['start'], $v['end']);
                }
            }
        }

        if ($status) {
            $data['status'] = 2;
        } else {
            $data['status'] = 1;
        }

        $data['info'] = Dever::json_encode($live);

        Dever::db('live/stream')->update($data);

        return $data;
    }

    # 建立直播日志
    public function saveLog($id, $sdate, $edate)
    {
        $info = Dever::db('live/stream')->one($id);

        $data['sdate'] = $sdate;
        $data['edate'] = $edate;
        $data['stream_id'] = $id;
        $data['live_id'] = $info['live_id'];
        $data['active_id'] = $info['active_id'];
        $log = Dever::db('live/stream_log')->one($data);

        if (!$log) {
            $id = Dever::db('live/stream_log')->insert($data);
        }
        
        return $id;
    }
}