NN2024010801/app/Http/Controllers/Api/v1/LiveController.php

<?php

namespace App\Http\Controllers\Api\v1;
use App\Http\Controllers\Api\webApp;
use App\Http\Validator\LiveValidator;
use App\Services\LiveService;
use App\Services\RedisService;

/**
 * 在线直播
 * @package App\Http\Controllers\Api\v1
 */
class LiveController extends webApp
{

    /**
     * 列表
     * @return array
     */
    public function index()
    {
       try {
        $params = request()->post();
        $pageSize = request()->post('pageSize', 0);
        $params['is_recommend'] = 1;
        $datas = LiveService::make()->getDataList($params, $pageSize,'', $this->userId);
        return message(1010, true, $datas);
       } catch (\Exception $exception){
           RedisService::set("caches:request:error_live_index", ['error'=>$exception->getMessage(),'trace'=>$exception->getTrace()], 7200);
           return message(1018, false, ['error'=>env('APP_DEBUG')? $exception->getMessage() : '']);
       }
    }

    /**
     * 播放与浏览
     * @return array
     */
    public function updatePlay()
    {
        $id = request()->post('id',0);
        if(!$result = LiveService::make()->updatePlay($this->userId, $id)){
            return message(LiveService::make()->getError(), false);
        }else{
            return message(LiveService::make()->getError(), true, $result);
        }
    }

    /**
     * 获取流地址
     * @return array
     */
    public function getUrl()
    {
        $urls = LiveService::make()->getLiveUrl($this->userId);
        return message(1010, true, $urls);
    }

    /**
     * 直播详情
     * @param LiveValidator $validator
     * @return array
     */
    public function getInfo(LiveValidator $validator)
    {
        $params = request()->all();
        $params = $validator->check($params, 'info');
        if (!is_array($params)) {
            return message($params, false);
        }

        if(!$info = LiveService::make()->getInfo($params['id'], $this->userId)){
            return message(LiveService::make()->getError(),false);
        }else{
            return message(1010,true, $info);
        }
    }

    /**
     * 状态
     * @return array|mixed
     */
    public function status()
    {
        if(!$result = LiveService::make()->status()){
            return message(LiveService::make()->getError(), false);
        }else{
            return message(LiveService::make()->getError(), true, $result);
        }
    }

    /**
     * 创建直播间（开启直播）
     * @return array
     */
    public function create(LiveValidator $validator)
    {

        $params = request()->all();
        $params = $validator->check($params, 'create');
        if (!is_array($params)) {
            return message($params, false);
        }

        if(!$result = LiveService::make()->create($this->userId, $params)){
            return message(LiveService::make()->getError(),false);
        }else{
            return message(LiveService::make()->getError(),true, $result);
        }
    }
}