dengbw
340 lines
16 KiB
PHP
340 lines
16 KiB
PHP
<?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) : '';
|
|
!$params['param3'] && $params['param3'] = 'live';
|
|
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';
|
|
$watch_duration = $re_session['totalPlayDuration'] && $re_session['liveUV'] ? $re_session['totalPlayDuration'] / $re_session['liveUV'] : '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' => $watch_duration, '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'));
|
|
}
|
|
} |