admin_polyv_217

admin/controllers/app/licheb/Main.php

@@ -19,6 +19,7 @@ class Main extends HD_Controller
         $this->load->model('app/material/Material_template_model', 'mdTemplate');
         $this->load->model('app/material/Material_biz_model', 'mdMaterialBiz');
         $this->load->model('topics/topics_model', 'mdTopics');
+        $this->load->model('live/Live_polyv_session_model', 'mdPolyvSession');
     }
 
     public function index()
@@ -80,6 +81,14 @@ class Main extends HD_Controller
                 array('name' => '查看详情', 'url' => '/app/licheb/sytactivity'),
             ),
         );
+        $value = $this->mdPolyvSession->count();
+        $list[] = array(
+            'title' => '保利威直播-场次报表',
+            'value' => $value,
+            'btns' => array(
+                array('name' => '查看详情', 'url' => '/live/polyv'),
+            ),
+        );
         $conditions[] = array('icon' => 'am-icon-user', 'list' => $list);
 
         /*小程序设置 end*/

admin/controllers/live/Polyv.php

@@ -0,0 +1,338 @@
+<?php
+defined('BASEPATH') OR exit('No direct script access allowed');
+
+/**
+ * Notes:保利威直播
+ * Created on: 2021/12/6 16:43
+ * Created by: dengbw
+ */
+class Polyv extends HD_Controller
+{
+    private $channelId = '2810581';
+
+    public function __construct()
+    {
+        parent::__construct();
+        $this->load->model('live/Live_polyv_session_model', 'mdPolyvSession');
+        $this->load->model('live/Live_polyv_viewlog_model', 'mdPolyvViewlog');
+    }
+
+    public function index()
+    {
+        return $this->lists();
+    }
+
+    public function lists()
+    {
+        $params = $this->input->get();
+        $params['page'] = $params['page'] ? intval($params['page']) : 1;
+        $params['size'] = $params['size'] ? intval($params['size']) : 20;
+        $lists = [];
+        $where = ['channelId' => $this->channelId];
+        if ($params['sessionId']) {
+            $where["sessionId"] = $params['sessionId'];
+        }
+        if ($params['time']) {
+            $time = explode(' ~ ', $params['time']);
+            $time[0] && $where["startTime>="] = strtotime($time[0] . ' 00:00:00') * 1000;
+            $time[1] && $where["endTime<="] = strtotime($time[1] . ' 23:59:59') * 1000;
+        }
+        $total = $this->mdPolyvSession->count($where);
+        if ($total) {
+            $res = $this->mdPolyvSession->select($where, "startTime desc", $params['page'], $params['size']);
+            foreach ($res as $key => $value) {
+                $setValue = $value;
+                $setValue['duration'] = $value['duration'] ? ceil($value['duration'] / 60) : '0';
+                $setValue['totalPlayDuration'] = $value['totalPlayDuration'] ? ceil($value['totalPlayDuration'] / 60) : '0';
+                $setValue['startTime'] = $value['startTime'] ? date('Y-m-d H:i:s', $value['startTime'] / 1000) : '';
+                $setValue['endTime'] = $value['endTime'] ? date('Y-m-d H:i:s', $value['endTime'] / 1000) : '';
+                $setValue['viewlog_time'] = $value['viewlog_time'] != '0000-00-00 00:00:00'
+                    ? date('Y-m-d H:i', strtotime($value['viewlog_time'])) : '未同步';
+                $setValue['session_time'] = date('Y-m-d H:i', strtotime($value['session_time']));
+                $lists[] = $setValue;
+            }
+        }
+        $this->data['pager'] = array('count' => ceil($total / $params['size']), 'curr' => $params['page'], 'totle' => $total);
+        $this->data['lists'] = $lists;
+        $this->data['params'] = $params;
+        $this->data['_title'] = "保利威频道({$this->channelId})_场次报表";
+        $this->show_view('live/polyv/lists', true);
+    }
+
+    public function lists_viewlog()
+    {
+        $params = $this->input->get();
+        if (!$params['sessionId']) {
+            return $this->show_json(SYS_CODE_FAIL, '场次ID不能为空！');
+        }
+        $menuAry = [];
+        $re_session = $this->mdPolyvSession->get(['channelId' => $this->channelId, 'sessionId' => $params['sessionId']]);
+        if (!$re_session) {
+            return $this->show_json(SYS_CODE_FAIL, '无此场次数据！');
+        }
+        $re_session['startTime'] = $re_session['startTime'] ? date('Y-m-d H:i:s', $re_session['startTime'] / 1000) : '';
+        if ($params['param3'] == 'live') {
+            $re_session['duration'] = $re_session['duration'] ? ceil($re_session['duration'] / 60) : '0';
+            $re_session['totalPlayDuration'] = $re_session['totalPlayDuration'] ? ceil($re_session['totalPlayDuration'] / 60) : '0';
+            $menuAry = [['title' => '直播时长(分钟)', 'value' => $re_session['duration'], 'tag' => '讲师该场直播直播时间']
+                , ['title' => '观看人数', 'value' => $re_session['liveUV'], 'tag' => '观看人数为观看用户总数，计算方式为观看记录根据用户id去重的条目数']
+                , ['title' => '观看次数', 'value' => $re_session['livePV'], 'tag' => '观看次数为观看记录条目数，用户刷新页面或者离开再进入直播，记为2条观看记录']
+                , ['title' => '观看时长', 'value' => $re_session['totalPlayDuration'], 'tag' => '观看时长是根据每条观看记录向上取整(不足1分钟按1分钟计算)，最后再相加后的结果。例如：单条观看记录时长为1分36秒，统计时会计算为2分钟。']
+                , ['title' => '人均观看时长', 'value' => $re_session['totalPlayDuration'] / $re_session['liveUV'], 'tag' => '人均观看时长=累计观看时长/观看人数，单位：分钟']
+            ];
+        } else if ($params['param3'] == 'vod') {
+            $re_sum = $this->mdPolyvViewlog->sum('stayDuration', ['param3' => 'vod', 'channelId' => $this->channelId, 'sessionId' => $params['sessionId']]);
+            $duration = $re_sum['stayDuration'] ? ceil($re_sum['stayDuration'] / 60) : '0';
+            $menuAry = [['title' => '回看时长(分钟)', 'value' => $duration, 'tag' => '观看时长是根据每条观看记录向上取整（不足1分钟按1分钟计算），最后再相加后的结果。例如：单条观看记录时长为1分36秒，统计时会计算为2分钟。']
+                , ['title' => '回看人数', 'value' => $re_session['playbackUV'], 'tag' => '回看人数为观看次数针对userid和时间去重，如果一个人连续2天都有观看，记为1次']
+                , ['title' => '回看次数', 'value' => $re_session['playbackPV'], 'tag' => '回看次数为该场次暂存列表和回放列表观看记录汇总']
+            ];
+        }
+        $results = $this->dataSelect($params);
+        $this->data['lists'] = $results['lists'];
+        $this->data['params'] = $results['params'];
+        $this->data['pager'] = $results['pager'];
+        $this->data['_title'] = $results['_title'];
+        $this->data['menuAry'] = $menuAry;
+        $this->data['info'] = $re_session;
+        $this->show_view('live/polyv/lists_viewlog', true);
+    }
+
+    private function dataSelect($params)
+    {
+        $params['page'] = $params['page'] ? intval($params['page']) : 1;
+        $params['size'] = $params['size'] ? intval($params['size']) : 20;
+        $params['param3'] = $params['param3'] ? $params['param3'] : 'live';
+        $params['merge'] = $params['merge'] ? $params['merge'] : '';
+        $lists = $menuAry = [];
+        $where = ['channelId' => $this->channelId, 'sessionId' => $params['sessionId'], 'param3' => $params['param3']];
+        if ($params['merge']) {
+            $total = $this->mdPolyvViewlog->count($where, 'param1');
+        } else {
+            $total = $this->mdPolyvViewlog->count($where);
+        }
+        if ($total) {
+            $fileds = '';
+            $params['size'] == 10000 && $fileds = 'param3,city,isMobile,referer,param4,param5,sessionId,';//导出
+            if ($params['merge']) {
+                $fileds .= 'param1,param2,createdTime,sum(playDuration) as playDuration,browser,ipAddress,province';
+                $res = $this->mdPolyvViewlog->select_groupby('param1', $where, "createdTime desc", $params['page'], $params['size'], $fileds);
+            } else {
+                $fileds .= 'param1,param2,createdTime,playDuration,browser,ipAddress,province';
+                $res = $this->mdPolyvViewlog->select($where, "createdTime desc", $params['page'], $params['size'], $fileds);
+            }
+            foreach ($res as $key => $value) {
+                $setValue = $value;
+                $setValue['createdTime'] = date('Y-m-d H:i:s', $value['createdTime'] / 1000);
+                $playDuration = '0';
+                if ($value['playDuration']) {
+                    $format = $value['playDuration'] >= 3600 || $params['size'] == 10000 ? 'H:i:s' : 'i:s';//大1小时
+                    $playDuration = gmdate($format, $value['playDuration']);
+                }
+                $setValue['playDuration'] = $playDuration;
+                $lists[] = $setValue;
+            }
+        }
+        $data['pager'] = array('count' => ceil($total / $params['size']), 'curr' => $params['page'], 'totle' => $total);
+        $data['lists'] = $lists;
+        $data['params'] = $params;
+        $data['_title'] = "观看日志统计";
+        return $data;
+    }
+
+    /**
+     * Notes:同步保利威分页查询频道直播观看详情数据
+     * Created on: 2022/2/14 14:38
+     * Created by: dengbw
+     * @return bool
+     */
+    public function api_viewlog()
+    {
+        $sessionIds = $this->input->post('sessionid');
+        $params['sessionIds'] = $sessionIds;
+        if (!$params['sessionIds']) {
+            return $this->show_json(SYS_CODE_FAIL, '场次ID不能为空！');
+        }
+        $re_session = $this->mdPolyvSession->get(['channelId' => $this->channelId, 'sessionId' => $params['sessionIds']]);
+        if (!$re_session) {
+            return $this->show_json(SYS_CODE_FAIL, '无此场次数据！');
+        }
+        if ($re_session['viewlog_time'] != '0000-00-00 00:00:00') {
+            $startTime = strtotime($re_session['viewlog_time']);
+        } else {
+            $startTime = $re_session['startTime'] / 1000;
+        }
+        $endTime = strtotime(date('Y-m-d H:i:s'));
+        //不同月份时开始取本月第1天
+        if (date('m', $startTime) != date('m', $endTime)) {
+            $startTime = strtotime(date('Y-m', time()) . '-01 00:00:00');
+        }
+        $params['startTime'] = $startTime * 1000;
+        $params['endTime'] = $endTime * 1000;
+        $params['page'] = 1;
+        $results = $this->getViewLog($params);
+//        $this->data['params'] = $params;
+//        $this->data['results'] = $results;
+        $message = $results['message'];
+        if ($results['status'] == 'success') {
+            $i = 10;
+            while (($i--) > 0) {
+                if ($results['status'] == 'success' && !$results['lastPage']
+                    && $results['pageNumber'] != $results['nextPageNumber']) {
+                    $params['page'] = $results['nextPageNumber'];
+                    $results = $this->getViewLog($params);
+                    continue;
+                } else {
+                    break;
+                }
+            }
+            //同步观看数据时间
+            $this->mdPolyvSession->update(['viewlog_time' => date('Y-m-d H:i:s', $endTime)], ['id' => $re_session['id']]);
+            return $this->show_json(SYS_CODE_SUCCESS, '操作成功');
+        } else {
+            return $this->show_json(SYS_CODE_FAIL, $message);
+        }
+    }
+
+    private function getViewLog($params)
+    {
+        $this->load->library('PolyvApi');
+        $polyv = new PolyvApi(['channel_id' => $this->channelId]);
+        $results = $polyv->getViewLog($params);
+        if ($results['status'] == 'success') {
+            $addData = [];
+            foreach ($results['data']['contents'] as $key => $value) {
+                $re = $this->mdPolyvViewlog->get(['playId' => $value['playId']]);
+                $data = [
+                    'channelId' => $value['channelId'], 'sessionId' => $value['sessionId'], 'playId' => $value['playId'],
+                    'userId' => $value['userId'], 'playDuration' => $value['playDuration'], 'stayDuration' => $value['stayDuration'],
+                    'flowSize' => $value['flowSize'], 'param1' => $value['param1'], 'param2' => $value['param2'],
+                    'param3' => $value['param3'], 'param4' => $value['param4'], 'param5' => $value['param5'], 'ptype' => $value['ptype'],
+                    'ipAddress' => $value['ipAddress'], 'country' => $value['country'], 'province' => $value['province'],
+                    'city' => $value['city'], 'isp' => $value['isp'], 'referer' => $value['referer'], 'userAgent' => $value['userAgent'],
+                    'operatingSystem' => $value['operatingSystem'], 'browser' => $value['browser'], 'isMobile' => $value['isMobile'],
+                    'currentDay' => $value['currentDay'], 'createdTime' => $value['createdTime'], 'lastModified' => $value['lastModified'],
+                ];
+                if ($re) {//同步更新数据
+                    $this->mdPolyvViewlog->update($data, ['id' => $re['id']]);
+                } else {//新增
+                    $data['c_time'] = time();
+                    $addData[] = $data;
+                }
+            }
+            if ($addData && count($addData)) {//新增数据
+                $this->mdPolyvViewlog->add_batch($addData);
+            }
+        }
+        return $results;
+    }
+
+    /**
+     * Notes:同步保利威频道多场次概览统计数据
+     * Created on: 2022/2/11 16:50
+     * Created by: dengbw
+     * @return bool
+     */
+    public function api_session()
+    {
+        $params = $this->input->post();
+        $where = [];
+        $params['sessionId'] && $where['sessionIds'] = $params['sessionId'];
+        if ($params['time']) {
+            $time = explode(' ~ ', $params['time']);
+            $time[0] && $where["startTime"] = strtotime($time[0] . ' 00:00:00') * 1000;
+            $time[1] && $where["endTime"] = strtotime($time[1] . ' 23:59:59') * 1000;
+        }
+        $this->load->library('PolyvApi');
+        $polyv = new PolyvApi(['channel_id' => $this->channelId]);
+        $results = $polyv->getSessionStats($where);
+        if ($results['status'] == 'success') {
+            foreach ($results['data']['list'] as $key => $value) {
+                $re = $this->mdPolyvSession->get(['channelId' => $this->channelId, 'sessionId' => $value['sessionId']]);
+                $data = [
+                    'channelId' => $value['channelId'], 'sessionId' => $value['sessionId'], 'name' => $value['name'],
+                    'startTime' => $value['startTime'], 'endTime' => $value['endTime'], 'duration' => $value['duration'],
+                    'liveUV' => $value['liveUV'], 'livePV' => $value['livePV'], 'playbackUV' => $value['playbackUV'],
+                    'playbackPV' => $value['playbackPV'], 'totalPlayDuration' => $value['totalPlayDuration'],
+                    'session_time' => date('Y-m-d H:i:s'),
+                ];
+                if ($re) {//同步更新数据
+                    $this->mdPolyvSession->update($data, ['id' => $re['id']]);
+                } else {//新增
+                    $data['c_time'] = time();
+                    $this->mdPolyvSession->add($data);
+                }
+            }
+            return $this->show_json(SYS_CODE_SUCCESS, '操作成功');
+        } else {
+            return $this->show_json(SYS_CODE_FAIL, $results['message']);
+        }
+    }
+
+    public function get()
+    {
+    }
+
+    public function add()
+    {
+    }
+
+    public function edit()
+    {
+    }
+
+    public function del()
+    {
+    }
+
+
+    public function batch()
+    {
+    }
+
+    public function export()
+    {
+        $params = $this->input->get();
+        $params['page'] = 1;
+        $params['size'] = 10000;
+        $data = $indexs = array();
+        $res = $this->dataSelect($params);
+        $fileName = $res['_title'];
+        foreach ($res['lists'] as $key => $value) {
+            $temp['playDuration'] = $value['playDuration'];
+            $temp['param1'] = $value['param1'];
+            $temp['param2'] = $value['param2'];
+            $temp['param3'] = $value['param3'] == 'live' ? '直播' : '回放';
+            $temp['createdTime'] = $value['createdTime'];
+            $temp['ipAddress'] = $value['ipAddress'];
+            $temp['province'] = $value['province'];
+            $temp['city'] = $value['city'];
+            $temp['browser'] = $value['browser'];
+            $temp['isMobile'] = $value['isMobile'] == 'Y' ? '是' : '否';
+            $temp['referer'] = $value['referer'];
+            $temp['param4'] = $value['param4'];
+            $temp['param5'] = $value['param5'];
+            $temp['sessionId'] = $value['sessionId'];
+            $data[] = $temp;
+        }
+        $indexs = [
+            'playDuration' => '观看时长',
+            'param1' => '用户ID',
+            'param2' => '昵称',
+            'param3' => '观看类型',
+            'createdTime' => '开始时间',
+            "ipAddress" => "观众IP",
+            "province" => "地区",
+            "city" => "城市",
+            "browser" => "浏览器类型",
+            "isMobile" => "是否移动端",
+            "referer" => "观看地址",
+            "param4" => "param4",
+            "param5" => "param5",
+            "sessionId" => "场次ID",
+        ];
+        array_unshift($data, $indexs);
+        $this->load->library('excel');
+        $this->excel->out_csv($data, $indexs, $fileName . "_" . date('YmdHis'));
+    }
+}

admin/views/live/polyv/lists.php

@@ -0,0 +1,170 @@
+<div class="coms-table-wrap mt10">
+    <form id="vue-app" class=" form-search coms-table-hd clearfix no-border" onsubmit="return false"
+          action="live/polyv">
+        <div class="am-form am-form-horizontal">
+            <div class="am-form-group fl">
+                <label class="am-para-label w50">时间：</label>
+                <div class="am-form-group fl">
+                    <div class="am-para-inline w300">
+                        <input id="id-time" name="time" type="text" value="<?= $params['time'] ?>"
+                               placeholder="开始时间 ~ 结束时间" autocomplete="off"/>
+                    </div>
+                    <div class="am-para-inline" style="padding-top: 5px;">
+                        <a class="mr10 id-day-btn" href="javascript:void (0);" data-date="today"
+                           data-source="id-time">今天</a>
+                        <a class="mr10 id-day-btn" href="javascript:void (0);" data-date="yesterday"
+                           data-source="id-time">昨日</a>
+                        <a class="mr10 id-day-btn" href="javascript:void (0);" data-date="7day"
+                           data-source="id-time">最近7天</a>
+                        <a class="mr10 id-day-btn" href="javascript:void (0);" data-date="30day"
+                           data-source="id-time">最近30天</a>
+                    </div>
+                </div>
+            </div>
+            <div class="am-form-group fl">
+                <label class="am-para-label w80">场次ID：</label>
+                <div class="am-para-inline w200">
+                    <input type="text" id="id-sessionId" name="sessionId" value="<?= $params['sessionId'] ?>"
+                           placeholder="请输入场次id搜索"/>
+                </div>
+            </div>
+            <div class="am-form-group fl ml20">
+                <div class="am-form-group fl ml10">
+                    <button type="submit" class="am-btn am-btn-success am-btn-sm w100">搜索</button>
+                </div>
+                <div class="am-form-group fl ml10">
+                    <button type="button" class="am-btn am-btn-success am-btn-sm" onclick="api_session();">同步搜索场次数据
+                    </button>
+                </div>
+            </div>
+        </div>
+    </form>
+    <div class="coms-table-bd">
+        <div class="fr">共有<?= $pager['totle'] ?>条数据</div>
+        <table class="am-table am-table-bordered">
+            <thead>
+            <tr>
+                <th width="8%"><span>场次ID</span></th>
+                <th width="15%"><span>名称</span></th>
+                <th width="12%"><span>开始时间</span><i class="fa fa-info-circle" title="该场次首次推流时间"></i></th>
+                <th width="12%"><span>结束时间</span></th>
+                <th width="8%"><span>直播时长</span><i class="fa fa-info-circle" title="讲师该场直播直播时间 单位：分钟"></i></th>
+                <th width="8%"><span>观看人数</span><i class="fa fa-info-circle"
+                                                   title="观看人数为观看用户总数，计算方式为观看记录根据用户id去重的条目数"></i></th>
+                <th width="8%"><span>观看次数</span><i class="fa fa-info-circle"
+                                                   title="观看次数为观看记录条目数，用户刷新页面或者离开再进入直播，记为2条观看记录"></i></th>
+                <th width="8%"><span>观看时长</span><i class="fa fa-info-circle"
+                                                   title="观看时长是根据每条观看记录向上取整(不足1分钟按1分钟计算)，最后再相加后的结果。例如：单条观看记录时长为1分36秒，统计时会计算为2分钟。"></i>
+                </th>
+                <th width="8%"><span>回看人数</span><i class="fa fa-info-circle"
+                                                   title="回看人数为观看次数针对userid和时间去重，如果一个人连续2天都有观看，记为1次"></i></th>
+                <th width="8%"><span>回看次数</span><i class="fa fa-info-circle" title="回看次数为该场次暂存列表和回放列表观看记录汇总"></i></th>
+            </tr>
+            </thead>
+            <tbody>
+            <?php if ($lists) {
+                foreach ($lists as $v) { ?>
+                    <tr>
+                        <td><?= $v['sessionId'] ?></td>
+                        <td><?= $v['name'] ?></td>
+                        <td><?= $v['startTime'] ?></td>
+                        <td><?= $v['endTime'] ?></td>
+                        <td><?= $v['duration'] ?></td>
+                        <td><?= $v['liveUV'] ?></td>
+                        <td><?= $v['livePV'] ?></td>
+                        <td><?= $v['totalPlayDuration'] ?></td>
+                        <td><?= $v['playbackUV'] ?></td>
+                        <td><?= $v['playbackPV'] ?></td>
+                    </tr>
+                    <tr>
+                        <td colspan="5" class="align-l">
+                            同步场次数据：<?= $v['session_time'] ?>&nbsp;&nbsp;&nbsp;&nbsp;
+                            同步观看数据：<?= $v['viewlog_time'] ?>
+                        </td>
+                        <td colspan="5" class="align-r">
+                            <a data-open="/live/polyv/lists_viewlog?sessionId=<?= $v['sessionId'] ?>"
+                               class="am-btn am-btn-primary am-btn-xs">查看详情</a>
+                            <a data-ajax="post" data-action="/live/polyv/api_viewlog"
+                               data-params-sessionid="<?= $v['sessionId'] ?>"
+                               class="am-btn am-btn-primary am-btn-xs">同步观看数据</a>
+                        </td>
+                    </tr>
+                <?php }
+            } ?>
+            </tbody>
+        </table>
+    </div>
+    <div class="coms-table-ft clearfix">
+        <div class="hander am-form">
+        </div>
+        <div class="coms-pagination fr mr20">
+            <?php page_view($pager) ?>
+        </div>
+    </div>
+</div>
+<script>
+    require(['laydate', 'autocomplete'], function (laydate) {
+        laydate.render({
+            elem: '#id-time', range: '~'
+        });
+        $('.id-day-btn').click(function () {
+            var type = $(this).data('date'), date = '', d_obj = new Date();
+            var source_id = $(this).data('source') || 'id-time';
+            switch (type) {
+                case 'today':
+                    date = d_obj.Format('yyyy-MM-dd');
+                    date = date + ' ~ ' + date;
+                    break;
+                case 'yesterday':
+                    date = (new Date(d_obj.getTime() - 86400000)).Format('yyyy-MM-dd');
+                    date = date + ' ~ ' + date;
+                    break;
+                case '7day':
+                    date = (new Date(d_obj.getTime() - 86400000 * 7)).Format('yyyy-MM-dd') + ' ~ ' + d_obj.Format('yyyy-MM-dd');
+                    break;
+                case '30day':
+                    date = (new Date(d_obj.getTime() - 86400000 * 29)).Format('yyyy-MM-dd') + ' ~ ' + d_obj.Format('yyyy-MM-dd');
+                    break;
+            }
+            $('#' + source_id).val(date);
+        });
+    });
+
+    function api_session() {
+        var id_time = $('#id-time').val();
+        var id_sessionId = $('#id-sessionId').val();
+        if (!id_time && !id_sessionId) {
+            layer.msg('同步数据(时间或场次ID)不能都为空');
+            return true;
+        }
+        $.ajax({
+            url: '/live/polyv/api_session',
+            type: 'post',
+            dataType: 'json',
+            data: {time: id_time, sessionId: id_sessionId},
+            beforeSend: function () {
+                layer.load(1, {
+                    shade: [0.1, '#fff'] //0.1透明度的白色背景
+                });
+            },
+            success: function (data) {
+                if (data['code']) {
+                    layer.msg(data.msg, {
+                        icon: 1,
+                        time: 2000
+                    }, function () {
+                        $.form.href("/live/polyv?time=" + id_time + "&sessionId=" + id_sessionId);
+                    });
+                } else {
+                    layer.msg(data.msg, {icon: 2});
+                }
+            },
+            complete: function () {
+                layer.closeAll('loading');
+            }
+        });
+        // $('#id-api').val(1);
+        // var $form = $('#vue-app');
+        // $form.submit();
+    }
+</script>

admin/views/live/polyv/lists_viewlog.php

@@ -0,0 +1,169 @@
+<table width="100%" style="margin-bottom: 12px;">
+    <tr>
+        <td class="align-l" style="font-size: 16px;font-weight: 600;"><?= $info['name'] ?></td>
+        <td class="align-r"><a data-ajax="post" data-action="/live/polyv/api_viewlog"
+                               data-params-sessionid="<?= $info['sessionId'] ?>"
+                               class="am-btn am-btn-primary am-btn-sm">同步观看数据</a></td>
+    </tr>
+    <tr>
+        <td colspan="2">直播开始时间 ： <?= $info['startTime'] ?> | 场次id：<?= $info['sessionId'] ?>（同步观看数据时间：<?= $info['viewlog_time'] ?>）</td>
+    </tr>
+</table>
+
+<div class="bs-example bs-example-tabs" data-example-id="togglable-tabs" style="font-size:15px;">
+    <div id="recom-stat"></div>
+    <ul class="nav nav-tabs" role="tablist">
+        <li role="presentation" class="<?= $params['param3'] == 'live' ? 'active' : '' ?>">
+            <a href="javascript:void (0);"
+               data-open="/live/polyv/lists_viewlog?sessionId=<?= $params['sessionId'] ?>&param3=live&merge=<?= $params['merge'] ?>">直播</a>
+        </li>
+        <li role="presentation" class="<?= $params['param3'] == 'vod' ? 'active' : '' ?>">
+            <a href="javascript:void (0);"
+               data-open="/live/polyv/lists_viewlog?sessionId=<?= $params['sessionId'] ?>&param3=vod&merge=<?= $params['merge'] ?>">回放</a>
+        </li>
+    </ul>
+</div>
+
+<div class="am-g" style="padding-top: 20px;">
+    <div class="col-sm-12">
+        <?php foreach ($menuAry as $key => $value) { ?>
+            <div class="col-sm-2">
+                <div class="my-panel">
+                    <div class="text-center">
+                        <?= $value['title'] ?> <i class="fa fa-info-circle" title="<?= $value['tag'] ?>"></i>
+                    </div>
+                    <div class="text-center" style="padding-top: 3px;">
+                        <span><?= $value['value'] ?></span>
+                    </div>
+                </div>
+            </div>
+        <? } ?>
+    </div>
+</div>
+
+<div class="coms-table-wrap mt10">
+    <div class="coms-table-bd">
+        <div class="mb10">
+            <table width="100%">
+                <tr>
+                    <td class="align-l"><input id="id-merge" type="checkbox"
+                                               onclick="merge();"<?= $params['merge'] ? 'checked' : '' ?>> 合并同一用户
+                    </td>
+                    <td class="align-r">观看数据常见问题
+                        <i class="fa fa-info-circle" title="
+                     如出现同一观众进入时间和观看时长有重复/冲突，或累计的观看时长超过了直播时长，一般会因为以下几种情况导致：
+                     1.使用旧版SDK观看：目前旧版SDK不支持判断是否多端登录
+                     2.观看端与观看端的打开时间间隔非常短：极端情况下，观众同时打开多个观看端，可能会导致多开成功
+                     3.使用APP观看：目前APP观看不支持判断是否多端登录
+                      除了以上三种场景，其余场景我们已限制了多端登录"></i>&nbsp;&nbsp;
+                        <button type="button" id="export" class="am-btn am-btn-primary am-btn-sm">导出列表</button>
+                    </td>
+                </tr>
+            </table>
+        </div>
+        <table class="am-table am-table-bordered">
+            <thead>
+            <tr>
+                <th width="15%"><span>UserId</span></th>
+                <th width="10%"><span>昵称</span></th>
+                <th width="12%"><span>观看开始时间</span></th>
+                <th width="10%"><span>时长</span></th>
+                <th width="10%"><span>观看终端</span></th>
+                <th width="10%"><span>IP</span></th>
+                <th width="10%"><span>地区</span></th>
+            </tr>
+            </thead>
+            <tbody>
+            <?php if ($lists) {
+                foreach ($lists as $v) { ?>
+                    <tr>
+                        <td><?= $v['param1'] ?></td>
+                        <td><?= $v['param2'] ?></td>
+                        <td><?= $v['createdTime'] ?></td>
+                        <td><?= $v['playDuration'] ?></td>
+                        <td><?= $v['browser'] ?></td>
+                        <td><?= $v['ipAddress'] ?></td>
+                        <td><?= $v['province'] ?></td>
+                    </tr>
+                <?php }
+            } ?>
+            </tbody>
+        </table>
+    </div>
+    <div class="coms-table-ft clearfix">
+        <div class="hander am-form">
+        </div>
+        <div class="coms-pagination fr mr20">
+            <?php page_view($pager) ?>
+        </div>
+    </div>
+</div>
+<script>
+    require(['laydate', 'autocomplete'], function (laydate) {
+        laydate.render({
+            elem: '#id-time', range: '~'
+        });
+        $('.id-day-btn').click(function () {
+            var type = $(this).data('date'), date = '', d_obj = new Date();
+            var source_id = $(this).data('source') || 'id-time';
+            switch (type) {
+                case 'today':
+                    date = d_obj.Format('yyyy-MM-dd');
+                    date = date + ' ~ ' + date;
+                    break;
+                case 'yesterday':
+                    date = (new Date(d_obj.getTime() - 86400000)).Format('yyyy-MM-dd');
+                    date = date + ' ~ ' + date;
+                    break;
+                case '7day':
+                    date = (new Date(d_obj.getTime() - 86400000 * 7)).Format('yyyy-MM-dd') + ' ~ ' + d_obj.Format('yyyy-MM-dd');
+                    break;
+                case '30day':
+                    date = (new Date(d_obj.getTime() - 86400000 * 30)).Format('yyyy-MM-dd') + ' ~ ' + d_obj.Format('yyyy-MM-dd');
+                    break;
+            }
+            $('#' + source_id).val(date);
+        });
+    });
+
+    function merge() {
+        var url = "/live/polyv/lists_viewlog?sessionId=<?= $params['sessionId'] ?>&param3=<?= $params['param3'] ?>&merge=<?= $params['merge'] ? '' : 1 ?>";
+        $.form.href(url);
+    }
+
+    function api_session() {
+        var id_time = $('#id-time').val();
+        var id_sessionId = $('#id-sessionId').val();
+        if (!id_time && !id_sessionId) {
+            layer.msg('同步数据(时间或场次ID)不能都为空');
+            return true;
+        }
+        $('#id-api').val(1);
+        var $form = $('#vue-app');
+        $form.submit();
+    }
+
+    $('#export').click(function () {
+        var count = <?=$pager['totle']?>;
+        if (count > 10000) {
+            layer.msg('单次导出数据不能超过10000');
+            return false;
+        }
+        var href = $.menu.parseUri(window.location.href);
+        var arr = href.split('?');
+        href = '/live/polyv/export?' + arr[1];
+        window.location.href = href;
+    });
+</script>
+<style>
+    .my-panel {
+        padding: 10px;
+        border: 1px solid #ddd;
+    }
+
+    .my-panel span {
+        font-size: 20px;
+        color: #2196f3;
+        font-weight: 700;
+    }
+</style>

common/libraries/PolyvApi.php

@@ -5,13 +5,13 @@
  * Created by: dengbw
  */
 
-class Polyv
+class PolyvApi
 {
     protected $url = "http://api.polyv.net/live";
-    protected $user_id = "549cf353c6";//2a3b848cd4
-    protected $app_id = "fr0myucldj";//g45uep0s6v
-    protected $app_secret = "4919b95df21e4afd80fe14ae8a722b1c";//447d5ce803d84f599794a3274177f796
-    protected $channel_id = "2005999";//2797712
+    protected $user_id = "2a3b848cd4";//549cf353c6
+    protected $app_id = "g45uep0s6v";//fr0myucldj
+    protected $app_secret = "447d5ce803d84f599794a3274177f796";//4919b95df21e4afd80fe14ae8a722b1c
+    protected $channel_id = "2810581";//2005999
     protected $timestamp;//时间戳
 
     public function __construct($param = [])
@@ -23,6 +23,35 @@ class Polyv
         $this->timestamp = time() * 1000;
     }
 
+    /**
+     * Notes:分页查询频道直播观看详情数据
+     * https://help.polyv.net/index.html#/live/api/channel/viewdata/viewlog_page
+     * Created on: 2022/2/11 16:52
+     * Created by: dengbw
+     * @param array $params
+     * @return bool|string
+     */
+    function getViewLog($params = [])
+    {
+        $params_sign = array(
+            'appId' => $this->app_id,//账号appid
+            'timestamp' => $this->timestamp,//当前13位毫秒级时间戳，3分钟内有效
+        );
+        $params['sessionIds'] && $params_sign['sessionIds'] = $params['sessionIds'];//场次ID, 多个场次使用,分隔
+        $params['page'] && $params_sign['page'] = $params['page'];//当前页码，默认为1
+        $params['pageSize'] && $params_sign['pageSize'] = $params['pageSize'];//每页显示的数据条数，默认每页显示1000条数据
+        $params['currentDay'] && $params_sign['currentDay'] = $params['currentDay'];//查询日期，格式：yyyy-MM-dd
+        $params['startTime'] && $params_sign['startTime'] = $params['startTime'];//查询开始时间，为13位毫秒级时间戳
+        $params['endTime'] && $params_sign['endTime'] = $params['endTime'];//查询结束时间，13位毫秒级时间戳
+        $params['param1'] && $params_sign['param1'] = $params['param1'];//观看用户ID，默认查询全部
+        $params['param2'] && $params_sign['param2'] = $params['param2'];//观看用户昵称，默认查询全部
+        $params['param3'] && $params_sign['param3'] = $params['param3'];//观看日志类型，默认查询全部vod：观看回放 live：直播
+        $sign = $this->getSign($params_sign);
+        $parts = http_build_query($params_sign);
+        $url = $this->url . "/v2/statistics/{$this->channel_id}/viewlog?{$parts}&sign={$sign}";
+        return $this->curlGet($url);
+    }
+
     /**
      * Notes:查询频道多场次概览统计数据
      * https://help.polyv.net/index.html#/live/api/channel/viewdata/get_session_stats
@@ -34,14 +63,14 @@ class Polyv
     function getSessionStats($params = [])
     {
         $params_sign = array(
-            'appId' => $this->app_id,
-            'timestamp' => $this->timestamp,
+            'appId' => $this->app_id,//账号appid
+            'timestamp' => $this->timestamp,//当前13位毫秒级时间戳，3分钟内有效
             'userId' => $this->user_id,
-            'channelId' => $params['channelId'] ? $params['channelId'] : $this->channel_id,
+            'channelId' => $params['channelId'] ? $params['channelId'] : $this->channel_id,//频道号
         );
-        $params['sessionIds'] && $params_sign['sessionIds'] = $params['sessionIds'];
-        $params['startTime'] && $params_sign['startTime'] = $params['startTime'];
-        $params['endTime'] && $params_sign['endTime'] = $params['endTime'];
+        $params['sessionIds'] && $params_sign['sessionIds'] = $params['sessionIds']; //场次ID，多个场次使用逗号分隔，如：fw82mayhuy,fvipafupmh，场次ID和直播开始结束时间必填一项，场次ID和直播开始结束时间同时存在时，使用场次ID进行查询
+        $params['startTime'] && $params_sign['startTime'] = $params['startTime'];//直播开始时间，13位毫秒级时间戳，开始时间和结束时间相隔不可以超过30天
+        $params['endTime'] && $params_sign['endTime'] = $params['endTime'];//直播结束时间，13位毫秒级时间戳，场次ID和直播开始结束时间必填一项
         $sign = $this->getSign($params_sign);
         $parts = http_build_query($params_sign);
         $url = $this->url . "/v3/channel/statistics/get-session-stats?{$parts}&sign={$sign}";
@@ -151,6 +180,8 @@ class Polyv
         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 360);
         $data = curl_exec($ch);
         curl_close($ch);
+        $data = trim($data, chr(239) . chr(187) . chr(191));
+        $data = json_decode($data, true);
         return $data;
     }
 
@@ -182,6 +213,8 @@ class Polyv
         curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
         $data = curl_exec($ch);
         curl_close($ch);
+        $data = trim($data, chr(239) . chr(187) . chr(191));
+        $data = json_decode($data, true);
         return $data;
     }
 }

common/models/live/Live_polyv_session_model.php

@@ -0,0 +1,17 @@
+<?php
+/**
+ * Notes:直播_保利威频道多场次统计
+ * Created on: 2022/02/10 14:52
+ * Created by: dengbw
+ */
+defined('BASEPATH') OR exit('No direct script access allowed');
+
+class Live_polyv_session_model extends HD_Model
+{
+    private $table_name = 'lc_live_polyv_session';
+
+    public function __construct()
+    {
+        parent::__construct($this->table_name, 'default');
+    }
+}

common/models/live/Live_polyv_viewlog_model.php

@@ -0,0 +1,17 @@
+<?php
+/**
+ * Notes:直播_保利威观看日志
+ * Created on: 2022/02/10 14:52
+ * Created by: dengbw
+ */
+defined('BASEPATH') OR exit('No direct script access allowed');
+
+class Live_polyv_viewlog_model extends HD_Model
+{
+    private $table_name = 'lc_live_polyv_viewlog';
+
+    public function __construct()
+    {
+        parent::__construct($this->table_name, 'default');
+    }
+}