jiankangtv/application/api/controller/Tvindex.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use Redis;
class Tvindex extends Api
{
    protected $noNeedLogin = ['indexdata','video_list','videoinfo','zhuanti','tudingc','search','history'];
    protected $noNeedRight = '*';

    //首页
    public function indexdata(){

        //左上角 logo,名称,4个按钮

        $data['index_logo']           = localpath_to_netpath(config('site.index_logo'));
        $data['index_appname']        = config('site.index_appname');

        $data['index_tuiding_switch'] = config('site.index_tuiding_switch');
        $data['index_search_switch']  = config('site.index_search_switch');
        $data['index_history_switch'] = config('site.index_history_switch');
        $data['index_dinggou_switch'] = config('site.index_dinggou_switch');

        //右上角 三行

        $data['index_right_1'] = config('site.index_right_1');
        $data['index_right_2'] = config('site.index_right_2');
        $data['index_right_3'] = config('site.index_right_3');

        //固定五个
        $data['index_top_video_image'] = localpath_to_netpath(config('site.index_top_video_image'));
        $data['index_top_video']       = localpath_to_netpath(config('site.index_top_video'));

        $page_wenzhen = Db::name('page_wenzhen')->field('id,name,image,url')->where('status',1)->order('weigh asc')->select();
        $data['page_wenzhen'] = list_domain_image($page_wenzhen,['image']);

        //大分类+剧集
        $video_type = Db::name('video_type')->field('id,name,showtype')->where('status',1)->where('type','neq',3)->order('weigh asc, id desc')->select();
        $video = Db::name('video')->field('id, video_type_id, title, image, is_pay')->where(['status' => 1, 'inject_status' => 2])->order('weigh asc, id desc')->select();
        $video = list_domain_image($video, ['image']);

        //分布:1=左一右四,2=两行八个,3=一行四个,4=一行三个
        $more = [
            'id' => 0,
            'video_type_id' => 0,
            'title' => '查看更多',
            'image' => 'https://jiankang-1304634122.cos.ap-nanjing.myqcloud.com/uploads/20240529/37bd30cf2b80186b51f3bbfedb10a7d5.png',
            'is_pay'=> 0,
        ];
        foreach($video_type as $key => $type){
            $type['child'] = [];

            $more['video_type_id'] = $type['id'];

            //循环放入child
            $child = [];
            foreach($video as $k => $v){
                if($type['id'] == $v['video_type_id']){
                    $child[] = $v;
                }
            }
            //查看更多
            if($type['showtype'] == 1){
                if(count($child) > 5){
                    $child = array_chunk($child,4)[0];
                    $child[] = $more;
                }
            }
            if($type['showtype'] == 2){
                if(count($child) > 8){
                    $child = array_chunk($child,7)[0];
                    $child[] = $more;
                }
            }
            if($type['showtype'] == 3){
                if(count($child) > 4){
                    $child = array_chunk($child,3)[0];
                    $child[] = $more;
                }
            }
            if($type['showtype'] == 4){
                if(count($child) > 3){
                    $child = array_chunk($child,2)[0];
                    $child[] = $more;
                }
            }

            $type['child'] = $child;
            $video_type[$key] = $type;
        }
        $data['video_type'] = $video_type;


        //精彩专题
        $data['buttom_name'] = '精彩专题';
        $buttom_list = Db::name('video_type')->field('id,name,image')->where('status',1)->where('type',3)->order('weigh asc,id desc')->limit(3)->select();
        $data['buttom_list'] = list_domain_image($buttom_list,['image']);

        $this->success('首页',$data);
    }

    //更多页
    //视频列表
    public function video_list() {
        $type_id = input('type_id', 0, 'intval'); //分类id
        if (!$type_id) {
            $this->error('您的网络开小差了~');
        }

        $video_type = Db::name('video_type')->where('id',$type_id)->value('name');

        $list = Db::name('video')->field('id, title, image, is_pay')->where(['video_type_id' => $type_id, 'status' => 1, 'inject_status' => 2])
            ->order('weigh asc, id desc')->select();
        $list = list_domain_image($list, ['image']);

        $result = [
            'typename'  => $video_type,
            'videolist' => $list,
        ];
        $this->success('视频更多', $result);
    }

    //视频详情
    public function videoinfo() {

        $id = input('id', 0, 'intval'); //视频id
        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->field('id,video_type_id, title, image, desc, is_pay, status, inject_status, seriesid, programid, movieid')
            ->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }
        if ($info['status'] != 1) {
            $this->error('视频丢失');
        }
        if ($info['inject_status'] != 2) {
            $this->error('视频丢失');
        }

        $info['image'] = one_domain_image($info['image']);
        $info['is_collection'] = Db::name('video_collection')->where(['user_id' => $this->auth->id, 'video_id' => $id])->count('id');
        $info['is_good']       = Db::name('video_good')->where(['user_id' => $this->auth->id, 'video_id' => $id])->count('id');

        //剧集列表
        $juji = [];
        $video_list = Db::name('video')->field('id, title, image, is_pay')->where(['video_type_id' => $info['video_type_id'], 'status' => 1, 'inject_status' => 2])
            ->order('weigh asc, id desc')->select();
        if(!empty($video_list)){
            $video_list = list_domain_image($video_list, ['image']);

            $video_list = array_chunk($video_list,10);
            foreach($video_list as $page => $ten){
                $juji[] = [
                    'name'=> ($page*10 + 1) .'-'. ($page*10 + 10),
                    'list'=>$ten,
                ];
            }
        }

        //猜你喜欢
        $guess_list = Db::name('video')->field('id, title, image, is_pay')->where(['status' => 1, 'inject_status' => 2])
            ->orderRaw('rand()')->limit(4)->select();
        $guess_list = list_domain_image($guess_list, ['image']);

        //记录浏览历史,给浏览历史列表用的,即时的
        if($this->auth->isLogin()){
            $view_map = [
                'user_id'  => $this->auth->id,
                'video_id' => $id,
            ];
            $check_view = Db::name('video_view')->where($view_map)->find();
            if($check_view){
                Db::name('video_view')->where($view_map)->update(['updatetime'=>time()]);
            }else{
                $view_map['createtime'] = time();
                $view_map['updatetime'] = time();
                Db::name('video_view')->insertGetId($view_map);
            }
        }

        //记录pv,uv
        $this->video_pvuv($id);

        //
        $result = [
            'video_info' => $info,
            'juji_list'  => $juji,
            'guess_list' => $guess_list,
        ];

        $this->success('详情', $result);
    }
    public function videoinfo_simple() {

        $id = input('id', 0, 'intval'); //视频id
        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->field('id,video_type_id, title, image, desc, is_pay, status, inject_status, seriesid, programid, movieid')
            ->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }
        if ($info['status'] != 1) {
            $this->error('视频丢失');
        }
        if ($info['inject_status'] != 2) {
            $this->error('视频丢失');
        }

        $info['image'] = one_domain_image($info['image']);
        $info['is_collection'] = Db::name('video_collection')->where(['user_id' => $this->auth->id, 'video_id' => $id])->count('id');
        $info['is_good']       = Db::name('video_good')->where(['user_id' => $this->auth->id, 'video_id' => $id])->count('id');

        //记录浏览历史,给浏览历史列表用的,即时的
        if($this->auth->isLogin()){
            $view_map = [
                'user_id'  => $this->auth->id,
                'video_id' => $id,
            ];
            $check_view = Db::name('video_view')->where($view_map)->find();
            if($check_view){
                Db::name('video_view')->where($view_map)->update(['updatetime'=>time()]);
            }else{
                $view_map['createtime'] = time();
                $view_map['updatetime'] = time();
                Db::name('video_view')->insertGetId($view_map);
            }
        }

        //记录pv,uv
        $this->video_pvuv($id);

        //
        $result = [
            'video_info' => $info,
        ];

        $this->success('详情', $result);
    }

    //专题页
    public function zhuanti(){
        $type_id = input('type_id', 0, 'intval'); //分类id
        if (!$type_id) {
            $this->error('您的网络开小差了~');
        }

        $list = Db::name('video')->field('id, title, image, is_pay, status, inject_status, seriesid, programid, movieid')->where(['video_type_id' => $type_id, 'status' => 1, 'inject_status' => 2])->order('weigh asc, id desc')->limit(5)->select();

        $list = list_domain_image($list, ['image']);
        $this->success('视频', $list);
    }

    //退订服务
    public function tudingc()
    {
        $data = config('site.text_tuiding');
        $this->success('', $data);
    }

    //搜索页
    public function search(){
        $keyword = input('keyword','');

        //热门推荐4个
        if(empty($keyword)){
            $list = Db::name('video')->field('id, title, image, is_pay')->where(['status' => 1, 'inject_status' => 2])
                ->orderRaw('rand()')->limit(12)->select();
            $list = list_domain_image($list, ['image']);
        }else{
            $list = Db::name('video')->field('id, title, image, is_pay')->where(['status' => 1, 'inject_status' => 2])->where('search_title','LIKE','%'.$keyword.'%')->order('is_pay asc,weigh asc,id desc')->select();
            $list = list_domain_image($list, ['image']);
        }

        $this->success('视频', $list);
    }

    //浏览历史
    public function history(){
        if($this->auth->isLogin()){
            $video_view = Db::name('video_view')->where('user_id',$this->auth->id)->order('updatetime desc')->group('video_id')->column('video_id,updatetime');

            if(!empty($video_view)){

                $video_ids = implode(',',array_keys($video_view));

                $list = Db::name('video')->field('id, title, image, is_pay')->where(['status' => 1, 'inject_status' => 2])->where('id','IN',$video_ids)->orderRaw('field(id,'.$video_ids.')')->page($this->page,$this->pagenum)->select();
                $list = list_domain_image($list, ['image']);
                foreach($list as $key => $val){
                    $list[$key]['history_time'] = $video_view[$val['id']];
                }

            }else{
                $list = [];
            }

        }else{
            $list = [];
        }

        $this->success('视频', $list);
    }

    //视频收藏/取消收藏
    public function video_collection() {

        $id = input('id', 0, 'intval');
        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }
        $info['image'] = one_domain_image($info['image']);
        //查询是否收藏
        $count = Db::name('video_collection')->where(['user_id' => $this->auth->id, 'video_id' => $id])->count('id');
        //开启事务
        if ($count) {
            $result = Db::name('video_collection')->where(['user_id' => $this->auth->id, 'video_id' => $id])->delete();
            Db::name('video')->where('id',$id)->setDec('collect_number',1); //收藏数减少
        } else {
            $result = Db::name('video_collection')->insertGetId(['user_id' => $this->auth->id, 'video_id' => $id, 'createtime' => time()]);
            Db::name('video')->where('id',$id)->setInc('collect_number',1); //收藏数增加
        }
        if (!$result) {
            Db::rollback();
            $this->error('操作失败');
        }

        $url = 'http://meta-history.unso.gitv.tv/OTT/jscmcc/addThirdPartyCollectionRecord';
        $content = [
            'cpPrvdName' => '健康e家',
            'cpPrvCode' => '41000144',
            'cpPrvType' => '1006',
            'content' => $info['title'],
            'ChnCode' => '1000020',
            'contentId' => (string)$info['movieid'],
            'extraContentID' => '',
            'isEffective' => $info['status'],
            'isPaid' => $info['is_pay'],
            'collectionFlag' => $count ? 0 : 1,
            'account' => $this->encrypt($this->auth->mobile, '!@#$%^&*FJGFJT78'),
            'cpPermission' => 'GITV',
            'intent' => [
                'action' => 'com.huxiu.heh.tv.ui.splash.SplashActivity',
                'package' => 'com.huxiu.heh.tv',
                'component' => [
                    'pkg' => 'com.huxiu.heh.tv',
                    'cls' => 'com.huxiu.heh.tv.ui.splash.SplashActivity'
                ],
                'extras' => [
                    /*'cmd' => '',
                    'from' => '',
                    'media_id' => ''*/
                    'type_id' => $info['video_type_id'],
                    'id' => $info['id']
                ]
            ],
            'imageURL' => $info['image']
        ];

        $content = json_encode($content, 320);

        $rt = httpRequest($url, 'POST', $content);
        file_put_contents('shoucang.txt',$id.'_'.$rt.PHP_EOL, FILE_APPEND);
        if (!$rt) {
            Db::rollback();
            $this->error('操作失败');
        }
        $rt = json_decode($rt, true);
        if (empty($rs) || $rt['code'] != 0) {
            Db::rollback();
            $this->error('操作失败');
        }

        //大数据上报
        $data = [
            'favid' => (string)(config('data_cp_id') . date('Ymd') . getMillisecond() . mt_rand(10000000, 99999999)),
            'UserID' => $this->auth->mobile,
            'time' => date('Y-m-d H:i:s'),
            'type' => $count ? 0 : 1,
            'cpid' => config('data_cp_id'),
            'albumid' => $id,
            'albumname' => $info['title']
        ];

        $data = join(json_decode('"\u0001"', true), $data);
        $filename = date('Ymd').'_'.config('data_cp_id').'_userfavdata_1.dat';
        $check_filename = date('Ymd').'_'.config('data_cp_id').'_userfavdata_1.chk';

        error_log(print_r($data, 1) . PHP_EOL, 3, './dashuju/' . $filename);
        error_log('', 3, './dashuju/' . $check_filename);
        $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_userfavdata.finish';
        error_log('', 3, './dashuju/' . $finish_filename);

        Db::commit();
        $this->success('操作成功');
    }

    //点赞视频、取消点赞
    public function video_good() {

        $id = input('id', 0, 'intval');
        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }
        //查询是否收藏
        $check = Db::name('video_good')->where(['user_id' => $this->auth->id, 'video_id' => $id])->find();
        //开启事务
        if ($check) {
            $result = Db::name('video_good')->where(['user_id' => $this->auth->id, 'video_id' => $id])->delete();
            Db::name('video')->where('id',$id)->setDec('good_number',1); //点赞数减少
        } else {
            $result = Db::name('video_good')->insertGetId(['user_id' => $this->auth->id, 'video_id' => $id, 'createtime' => time()]);
            Db::name('video')->where('id',$id)->setInc('good_number',1); //点赞数增加
        }

        $this->success('操作成功');
    }

    //用户观看行为(支付)
    public function payuserplay() {
        $id = input('id', 0, 'intval'); //视频id
        $sn = input('sn', '', 'trim'); //SN号
        $start_time = input('start_time', '', 'trim'); //yyyymmddhhmmss (24小时制),节目开始播放时间
        $end_time = input('end_time', '', 'trim'); //yyyymmddhhmmss (24小时制)，节目结束播放时间，如果播放未结束，但是此时需要同步数据，填当前时间
        $csource = input('csource', 0, ''); //1：从搜索结果访问2：从用户收藏/书签访问3：从EPG访问4：从推荐页面访问5、其他

        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }

        //播放日志
        $play_data = [
            'user_id' => $this->auth->id,
            'video_id' => $id,
            'sn' => $sn,
            'start_time' => $start_time,
            'end_time' => $end_time,
            'csource' => $csource,
            'createtime' => time(),
            'updatetime' => time(),
        ];
        Db::name('video_play_payuserplay')->insertGetId($play_data);

        $content = [
            'UserID' => $this->auth->mobile,
            'city' => '14',
            'start_time' => $start_time,
            'end_time' => $end_time,
            'service_type' => 1,
            'albumid' => $id,
            'albumname' => $info['title'],
            'csource' => $csource,
            'SN' => $sn,
            'ip' => request()->ip(),
            'fee_type' => $info['is_pay'] == 1 ? 1 : '',
            'flow' => '',
            'product' => '',
            'product_name' => '',
            'info_source' => '02'
        ];

        $content = join('|', $content);

        $filename = date('YmdH').'_'.config('cp_id').'_userviewdata_1.dat';
        $check_filename = date('YmdH').'_'.config('cp_id').'_userviewdata_1.chk';

        error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
        error_log('', 3, './dashuju/' . $check_filename);

        $this->success('');
    }

    //视频播放记录
    public function playrecord() {
        $id = input('id', 0, 'intval');
        $total_time = input('total_time', 0, 'intval'); //总时长
        $start_time = input('start_time', 0, 'intval'); //开始看时间:相对时间
        $end_time = input('end_time', 0, 'intval'); //结束看时间:相对时间
        $log_type = input('log_type', 'watching', 'trim'); //begin:开始播放；watching:正在播放；end:结束播放

        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }
        if ($info['inject_status'] != 2) {
            $this->error('视频丢失');
        }

        //播放日志
        $play_data = [
            'user_id' => $this->auth->id,
            'video_id' => $id,
            'total_time' => $total_time,
            'start_time' => $start_time,
            'end_time' => $end_time,
            'log_type' => $log_type,
            'createtime' => time(),
            'updatetime' => time(),
        ];
        Db::name('video_play_playrecord')->insertGetId($play_data);

        $info['image'] = one_domain_image($info['image']);

        $url = 'http://meta-history.unso.gitv.tv/OTT/jscmcc/addThirdPartyHistoryRecord';
        $content = [
            'cpPrvdName' => '健康e家',
            'cpPrvCode' => '41000144',
            'cpPrvType' => '1006',
            'contentName' => $info['title'],
            'ChnName' => '健康',
            'ChnCode' => '1000020',
            'contentId' => (string)$info['movieid'],
            'extraContentID' => '',
            'isEffective' => $info['status'],
            'isPaid' => $info['is_pay'],
            'contentTotalTime' => $total_time,
            'startWatchTime' => $start_time,
            'endWatchTime' => $end_time,
            'playTime' => $end_time - $start_time,
            'logType' => $log_type,
            'account' => $this->encrypt($this->auth->mobile, '!@#$%^&*FJGFJT78'),
            'cpPermission' => 'GITV',
            'intent' => [
                'action' => 'com.huxiu.heh.tv.ui.splash.SplashActivity',
                'package' => 'com.huxiu.heh.tv',
                'component' => [
                    'pkg' => 'com.huxiu.heh.tv',
                    'cls' => 'com.huxiu.heh.tv.ui.splash.SplashActivity'
                ],
                'extras' => [
                    /*'cmd' => '',
                    'from' => '',
                    'media_id' => ''*/
                    'type_id' => $info['video_type_id'],
                    'id' => $info['id']
                ]
            ],
            'imageURL' => $info['image']
        ];

        $content = json_encode($content, 320);

        $rt = httpRequest($url, 'POST', $content);
        file_put_contents('bofang.txt',$id.'_'.$rt.PHP_EOL, FILE_APPEND);
        if (!$rt) {
            $this->error('同步失败');
        }
        $rt = json_decode($rt, true);
        if ($rt['code'] != 0) {
            $this->error('同步失败');
        }

        $this->success('同步成功');
    }

    //用户观看行为(大数据)
    public function userplay() {
        $id = input('id', 0, 'intval'); //视频id
        $sn = input('sn', '', 'trim'); //SN号
        $start_time = input('start_time', '', 'trim'); //YYYY-MM-DD HH:MM:SS(24小时制)节目开始播放时间
        $end_time = input('end_time', '', 'trim'); //YYYY-MM-DD HH:MM:SS(24小时制)节目结束播放时间
        $csource = input('csource', 0, ''); //1：从搜索结果访问2：从用户收藏/书签访问3：从EPG访问4：从推荐页面访问5：从猜你喜欢个性化推荐页面访问(带上推荐接口的trace_id)99：其他
        $trace_id = input('trace_id', '', 'trim');
        $istry = input('istry', 0, 'intval'); //0非试看 1试看
        $start_posi = input('start_posi', 0, 'intval'); //播放起始点相对于影片起始点的时长，单位秒，例如从影片第 600 秒开始观看

        if (!$id) {
            $this->error('您的网络开小差了');
        }

        $info = Db::name('video')->where(['id' => $id])->find();
        if (!$info) {
            $this->error('数据不存在');
        }

        //播放日志
        $play_data = [
            'user_id' => $this->auth->id,
            'video_id' => $id,
            'sn' => $sn,
            'start_time' => $start_time,
            'end_time' => $end_time,
            'csource' => $csource,
            'trace_id' => $trace_id,
            'istry' => $istry,
            'start_posi' => $start_posi,
            'createtime' => time(),
            'updatetime' => time(),
        ];
        Db::name('video_play_userplay')->insertGetId($play_data);

        $content = [
            'playid' => (string)(config('data_cp_id') . date('Ymd') . getMillisecond() . mt_rand(10000000, 99999999)),
            'UserID' => $this->auth->mobile,
            'SN' => $sn,
            'start_time' => $start_time,
            'end_time' => $end_time,
            'service_type' => 1,
            'cpid' => config('data_cp_id'),
            'albumid' => $id,
            'albumname' => $info['title'],
            'videoid' => $id,
            'videoname' => $info['title'],
            'csource' => $csource,
            'trace_id' => $trace_id,
            'fee_type' => $info['is_pay'] == 1 ? 1 : 4,
            'istry' => $istry,
            'iscon' => 0,
            'start_posi' => $start_posi
        ];

        $content = join(json_decode('"\u0001"', true), $content);

        $filename = date('Ymd').'_'.config('data_cp_id').'_userplaydata_1.dat';
        $check_filename = date('Ymd').'_'.config('data_cp_id').'_userplaydata_1.chk';

        error_log(print_r($content, 1) . PHP_EOL, 3, './dashuju/' . $filename);
        error_log('', 3, './dashuju/' . $check_filename);
        $finish_filename = date('Ymd') . '_' . config('data_cp_id') . '_userplaydata.finish';
        error_log('', 3, './dashuju/' . $finish_filename);

        $this->success('');
    }

    //获取特殊机型
    public function special_models() {
        $special_models = config('site.special_models');
        $special_models = explode(',', $special_models);

        $this->success('获取特殊机型', $special_models);
    }

    //前端报错记录
    public function app_error() {
        $this->success('');
    }

    /** * * @param string $string 需要加密的字符串 * @param string $key 密钥 * @return string */
    private function encrypt($string, $key) {
//        $key = substr(openssl_digest(openssl_digest($key, 'sha1', true), 'sha1', true), 0, 16);
        $data = openssl_encrypt($string, 'AES-128-ECB', $key, OPENSSL_RAW_DATA);
        $data = bin2hex($data);
        return $data;
    }

    /** * @param string $string 需要解密的字符串 * @param string $key 密钥 * @return string */
    private function decrypt($string, $key) {
//        $key = substr(openssl_digest(openssl_digest($key, 'sha1', true), 'sha1', true), 0, 16);
        $decrypted = openssl_decrypt(hex2bin($string), 'AES-128-ECB', $key, OPENSSL_RAW_DATA);
        return $decrypted;
    }

    //共有方法，
    private function video_pvuv($video_id = 0){
        if(empty($video_id)) {return true;}

        //开启redis
        $redis = new Redis();
        $config = config('redis');
        $redis->connect($config['redis_host'], $config['redis_port']);
        if ($config['redis_pwd']) {
            $redis->auth($config['redis_pwd']);
        }
        if($config['redis_selectdb'] > 0){
            $redis->select($config['redis_selectdb']);
        }

        //今天
        $today = date('Y-m-d');

        //今日pv+1
        $today_pv_key = $today.'_video_pv_'.$video_id;
        $redis->incr($today_pv_key,1);

        //今日uv+1
        if($this->auth->isLogin() && $this->auth->id){
            $today_uv_key = $today.'_video_uv_'.$video_id;
            $uid = $this->auth->id;
            $redis->sAdd($today_uv_key,$uid);
        }

        //今日视频id列表
        $today_video_key = $today.'_video_list';
        $redis->sAdd($today_video_key,$video_id);
    }
    /*public function test(){
        $this->video_pvuv(input('video_id',0));
    }*/
}