@@ -243,13 +247,15 @@
data: {
info: {},
status_list: [],
- ad_list: [],
- ad_item: {},
+ prizes_list: [],
+ prizes_item: {},
+ prizes_img: {value: '', src: ''},
},
mounted() {
var that = this;
that.info = ;
that.status_list = ;
+ that.prizes_list = ;
},
computed: {},
created: function () {
@@ -270,7 +276,7 @@
layer.msg("排序值不能为空！", {icon: 2});
return false;
}
- this.ad_list.sort(function (a, b) {
+ this.prizes_list.sort(function (a, b) {
return b.order_view - a.order_view;
});
$("#group_name_" + index).hide();
@@ -279,52 +285,46 @@
adModal: function (item) {
var that = this;
var _title = '新增广告';
- that.ad_item = {};
- var _img = '';
- var _img_url = '';
+ that.prizes_item = {};
if (item) {
- that.ad_item = item;
+ that.prizes_item = item;
_title = '编辑广告';
- _img = item.img;
- _img_url = item.img_url;
+ that.prizes_img = {value: item.img_value, src: item.img_src};
} else {
- that.ad_item = {"order_view": 50, "jump_type": 0};
+ that.prizes_item = {"order_view": 50};
+ that.prizes_img = {value: '', src: ''};
}
- $('#ad_img').val(_img);
- $("#ad_img_url").attr('src', _img_url);
layer.open({
type: 1,
- area: ['50%', '38%'], //宽高
+ area: ['50%'], //宽高
content: $('#ad-modal'),
title: _title,
shade: false,
btn: ['确定', '取消'],
yes: function (index) {
- _img = $('#ad_img').val();
- _img_url = $("#ad_img_url")[0].src;
if (!item) {
- that.ad_list.push({
- title: that.ad_item.title,
- img: _img,
- img_url: _img_url,
- link: that.ad_item.link,
- order_view: that.ad_item.order_view,
- jump_type: that.ad_item.jump_type
+ let timestamp = Date.parse(new Date());
+ let rand = parseInt(Math.random() * 1000);
+ let id = timestamp + rand;
+ that.prizes_list.push({
+ id: id,
+ title: that.prizes_item.title,
+ img_value: that.prizes_img.value,
+ img_src: that.prizes_img.src,
+ price: that.prizes_item.price,
+ order_view: that.prizes_item.order_view
});
- } else {
- item.img = _img;
- item.img_url = _img_url;
}
- that.ad_list.sort(function (a, b) {
+ that.prizes_list.sort(function (a, b) {
return b.order_view - a.order_view;
- })
+ });
layer.close(index);
}
});
},
removeAd: function (index) {
var vm = this;
- vm.ad_list.splice(index, 1);
+ vm.prizes_list.splice(index, 1);
},
editType: function (index) {
var vm = this;
@@ -348,15 +348,14 @@
},
saveEdit: function () {
var vm = this;
- vm.info.img = $('#cover_id').val();
vm.info.time = $('#time_id').val();
- vm.info.share_img = $('#share_img_id').val();
+ vm.info.prizes_list = vm.prizes_list;
$.ajax({
url: vm.info.edit_url,
type: 'post',
dataType: 'json',
data: {
- info: vm.info
+ info: vm.info,
},
beforeSend: function () {
layer.load(1, {
@@ -387,7 +386,7 @@
saveStatus: function () {
var vm = this;
$.ajax({
- url: '/app/licheb/sytactivity/edit_status',
+ url: '/app/licheb/sytlive/edit_status',
type: 'post',
dataType: 'json',
data: {
@@ -420,11 +419,6 @@
});
diff --git a/admin/views/app/licheb/syt/live_lists.php b/admin/views/app/licheb/syt/live_lists.php
index 80229b8e..2ec8596f 100644
--- a/admin/views/app/licheb/syt/live_lists.php
+++ b/admin/views/app/licheb/syt/live_lists.php
@@ -48,12 +48,12 @@
- 报名
- 门店
- 业绩报告
+
+
+
+
+
+
分享二维码
diff --git a/api/controllers/plan/Plan.php b/api/controllers/plan/Plan.php
index e6077cfe..d02bd049 100644
--- a/api/controllers/plan/Plan.php
+++ b/api/controllers/plan/Plan.php
@@ -34,9 +34,12 @@ class Plan extends CI_Controller
$plan[] = array('url' => base_url(array('plan', 'licheb', 'visit_sales_sms')), 'interval' => 1);//给销售发送待回访短信
$plan[] = array('url' => base_url(array('plan', 'licheb', 'customer_manager_sms')), 'interval' => 1);//给店长发送待分配短信
$plan[] = array('url' => base_url(array('plan', 'licheb', 'customer_manager_sms')), 'interval' => 1);//给店长发送待分配短信
- $plan[] = array('url' => base_url(array('plan', 'items', 'stock_log')), 'interval' => 5);//库存车辆日志
$plan[] = array('url' => base_url(array('plan', 'licheb', 'users_log')), 'interval' => 2);//顾问日志
+ $plan[] = array('url' => base_url(array('plan', 'items', 'stock_log')), 'interval' => 5);//库存车辆日志
+
+ $plan[] = array('url' => base_url(array('plan', 'polyv', 'view_log')), 'interval' => 5);//直播观看详情数据
+
$plan[] = array('url' => base_url(array('plan', 'biz', 'settle')), 'interval' => 1);
$plan[] = array('url' => base_url(array('plan', 'biz', 'merge')), 'interval' => 20); //合并结算
$plan[] = array('url' => base_url(array('plan', 'order', 'up_old_status')), 'interval' => 30); //更新旧订单状态
diff --git a/api/controllers/plan/Polyv.php b/api/controllers/plan/Polyv.php
new file mode 100644
index 00000000..7b4d1e59
--- /dev/null
+++ b/api/controllers/plan/Polyv.php
@@ -0,0 +1,107 @@
+log_file = 'polyv.log';
+ }
+
+ /**
+ * Notes:查询频道直播观看详情数据
+ * Created on: 2022/5/17 16:01
+ * Created by: dengbw
+ * https://liche-api-dev.xiaoyu.com/plan/polyv/view_log?sd=1
+ * https://api.liche.cn/plan/polyv/view_log
+ */
+ public function view_log()
+ {
+ $this->load->model('live/Live_polyv_viewlog_model', 'mdPolyvViewlog');
+ $this->load->library('PolyvApi');
+ $startTime = $endTime = time();
+ $redis = &load_cache('redis');
+ $redisKey = 'polyv_view_log_endtime';
+ $get_endTime = $redis->get($redisKey);
+ $params = $this->input->get();
+ if ($get_endTime && (date('Y-m-d', $get_endTime) != date('Y-m-d'))) {
+ $get_endTime = '';
+ }
+ if (!$get_endTime || $params['sd']) {
+ $startTime = strtotime(date('Y-m-d') . ' 00:00:00');
+ } else if ($get_endTime) {
+ $startTime = $get_endTime;
+ }
+ $params['startTime'] = $startTime * 1000;
+ $params['endTime'] = $endTime * 1000;
+ $params['param3'] = 'live';
+ $params['page'] = 1;
+ $results = $this->getViewLog($params);
+ if ($results['status'] == 'success') {
+ $redis->save($redisKey, $endTime, 24 * 3600);//保存最后时间
+ $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;
+ }
+ }
+ }
+ //if ($params['sd']) {
+ echo 'startTime=' . date('Y-m-d H:i:s', $startTime) . '&endTime=' . date('Y-m-d H:i:s', $endTime) . '
';
+ echo json_encode($results, JSON_UNESCAPED_UNICODE);
+ //}
+ }
+
+ /**
+ * Notes:新增/修改直播数据
+ * Created on: 2022/5/19 14:25
+ * Created by: dengbw
+ * @param $params
+ * @return bool|string
+ */
+ private function getViewLog($params)
+ {
+ $polyv = new PolyvApi();
+ $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)) {//新增数据
+ $addData = array_reverse($addData);
+ $this->mdPolyvViewlog->add_batch($addData);
+ }
+ }
+ return $results;
+ }
+}
\ No newline at end of file
diff --git a/common/libraries/PolyvApi.php b/common/libraries/PolyvApi.php
index a766e5cb..fc008e56 100644
--- a/common/libraries/PolyvApi.php
+++ b/common/libraries/PolyvApi.php
@@ -23,6 +23,34 @@ class PolyvApi
$this->timestamp = time() * 1000;
}
+ /**
+ * Notes:h5创建SDK参数
+ * Created on: 2022/5/12 15:21
+ * Created by: dengbw
+ * @return array
+ */
+ function getLiveSdk()
+ {
+ $params_sign = [
+ 'appId' => $this->app_id,
+ 'channelId' => $this->channel_id,
+ 'timestamp' => $this->timestamp,
+ ];
+ $sign = $this->getSign($params_sign);
+ return ['channelId' => $this->channel_id, 'sign' => $sign, 'timestamp' => $this->timestamp, 'appId' => $this->app_id];
+ }
+
+ /**
+ * Notes:获取参数
+ * Created on: 2022/5/16 17:38
+ * Created by: dengbw
+ * @return array
+ */
+ function getLiveParam()
+ {
+ return ['appId' => $this->app_id, 'app_secret' => $this->app_secret, 'user_id' => $this->user_id, 'channelId' => $this->channel_id];
+ }
+
/**
* Notes:分页查询频道直播观看详情数据
* https://help.polyv.net/index.html#/live/api/channel/viewdata/viewlog_page
diff --git a/common/models/app/licheb/Syt_live_biz_model.php b/common/models/app/licheb/Syt_live_biz_model.php
new file mode 100644
index 00000000..bdf2777d
--- /dev/null
+++ b/common/models/app/licheb/Syt_live_biz_model.php
@@ -0,0 +1,18 @@
+table_name, 'default');
+ }
+}
diff --git a/common/models/app/licheb/Syt_live_data_model.php b/common/models/app/licheb/Syt_live_data_model.php
new file mode 100644
index 00000000..5d2f7ae8
--- /dev/null
+++ b/common/models/app/licheb/Syt_live_data_model.php
@@ -0,0 +1,18 @@
+table_name, 'default');
+ }
+}
diff --git a/common/models/app/licheb/Syt_live_model.php b/common/models/app/licheb/Syt_live_model.php
index fc48bab8..acfd9067 100644
--- a/common/models/app/licheb/Syt_live_model.php
+++ b/common/models/app/licheb/Syt_live_model.php
@@ -15,4 +15,21 @@ class Syt_live_model extends HD_Model
{
parent::__construct($this->table_name, 'default');
}
+
+ /**
+ * Notes:直播状态
+ * Created on: 2022/5/19 11:23
+ * Created by: dengbw
+ * @param string $id
+ * @return array|mixed
+ */
+ public function lStatusAry($id = '')
+ {
+ $arr = [0 => '直播未开始', 1 => '直播已开始', 2 => '直播已结束'];
+ if (strlen($id)) {
+ return $arr[$id];
+ } else {
+ return $arr;
+ }
+ }
}
diff --git a/common/models/receiver/Receiver_customers_model.php b/common/models/receiver/Receiver_customers_model.php
index 881cf3b2..7848c8a9 100644
--- a/common/models/receiver/Receiver_customers_model.php
+++ b/common/models/receiver/Receiver_customers_model.php
@@ -84,7 +84,8 @@ class Receiver_customers_model extends HD_Model
$arr[3] = ['name' => '网络推广', 'list' => [30 => '抖音', 31 => '区域媒体', 32 => '懂车帝', 33 => '易车',
34 => '汽车之家', 35 => '网红', 36 => '厂商分配', 37 => '狸车分配']];
$arr[4] = ['name' => '外展外拓', 'list' => [40 => '巡展', 41 => '车展', 42 => '静展', 43 => '大客户']];
- $arr[5] = ['name' => '自媒体', 'list' => [50 => '小红书号', 51 => '咸鱼号', 52 => '抖音号', 53 => '狸车素材', 54 => '知乎号']];
+ $arr[5] = ['name' => '自媒体', 'list' => [50 => '小红书号', 51 => '咸鱼号', 52 => '抖音号', 53 => '狸车素材'
+ , 54 => '知乎号', 55 => '私域直播']];
if ($id) {
return $arr[$id];
} else {
diff --git a/home/controllers/h5/syt/Live.php b/home/controllers/h5/syt/Live.php
index bff8ee93..c98a9091 100644
--- a/home/controllers/h5/syt/Live.php
+++ b/home/controllers/h5/syt/Live.php
@@ -8,11 +8,16 @@ class Live extends Wxapp
private $session;
private $secret;
private $uid = 0;
+ private $of_id = 5;//自媒体
+ private $of2_id = 55;//私域直播
public function __construct()
{
parent::__construct(2);
$this->secret = "syt_live_2022505";
+ $this->load->model('app/licheb/syt_live_model', 'mdSytLive');
+ $this->load->model('app/licheb/syt_live_biz_model', 'mdSytLiveBiz');
+ $this->load->model('app/licheb/syt_live_data_model', 'mdSytLiveData');
$this->load->model('app/app_weixin_users_model', 'mdWeixinUsers');
$this->load->model('app/licheb/app_licheb_users_model', 'mdLichebUsers');
$ukey = get_cookie('ukey');
@@ -23,7 +28,7 @@ class Live extends Wxapp
//重置cookie
$reset = $this->input_param('reset');
if ($reset) {
- set_cookie("ukey", "", 86400 * 30);
+ set_cookie("ukey", "", 86400 * 1);
$this->session = array();
$this->uid = 0;
}
@@ -54,17 +59,17 @@ class Live extends Wxapp
}
$cf_uid = intval($params['cf_uid']);//来源狸车宝用户id
$biz_id = intval($params['biz_id']);//门店id
- echo json_encode($params, JSON_UNESCAPED_UNICODE);
-// $re = $this->mdSytActivity->get(array("id" => $id, "status" => 1));
-// if (!$re) {
-// throw new Hd_exception("活动不存在", 400);
-// }
+ //echo json_encode($params, JSON_UNESCAPED_UNICODE);
+ $re = $this->mdSytLive->get(array("id" => $id, "status" => 1));
+ if (!$re) {
+ throw new Hd_exception("直播不存在", 400);
+ }
$checkua = checkua();
$sign_package = [];
$url = http_host_com('home') . "/h5/syt/live?skey={$skey}";
if ($checkua == 'wxwork') {//企业微信
- $this->load->library('wx_qyapi_agent', ['app' => 'liche_1000024']);
- $this->load->library('wx_qyapi', ['app' => 'liche']);
+ $this->load->library('wx_qyapi_agent', ['app' => 'lichene_1000024']);
+ $this->load->library('wx_qyapi', ['app' => 'lichene']);
$this->set_auth_wxwork($url);
$sign_package = $this->wx_qyapi->getSignPackage();
} else if ($checkua == 'wx') {//微信
@@ -73,12 +78,26 @@ class Live extends Wxapp
$jssdk = new Jssdk('liche');
$sign_package = $jssdk->getSignPackage();
}
+ $live_user = ['userId' => 888888888, 'userName' => '私域直播', 'pic' => '//livestatic.videocc.net/assets/wimages/missing_face.png'];
if ($this->uid) {
- $re_wu = $this->mdWeixinUsers->get(['id' => $this->uid]);
- if ($re_wu) {//更新参数
- $jsondata = $re_wu['jsondata'] ? json_decode($re_wu['jsondata'], true) : '';
- $jsondata['live'] = $params;
- $this->mdWeixinUsers->update(['jsondata' => json_encode($jsondata, JSON_UNESCAPED_UNICODE)], ['id' => $this->uid]);
+ if ($checkua == 'wxwork') {
+ $re_wu = $this->mdLichebUsers->get(['id' => $this->uid]);
+ if ($re_wu) {
+ $re_wu['unionid'] && $live_user['userId'] = $re_wu['unionid'];
+ $live_user['userName'] = $re_wu['nickname'] ? $re_wu['nickname'] : $re_wu['uname'];
+ $re_wu['headimg'] && $live_user['pic'] = $re_wu['headimg'];
+ }
+ } else if ($checkua == 'wx') {
+ $re_wu = $this->mdWeixinUsers->get(['id' => $this->uid]);
+ if ($re_wu) {
+ $re_wu['unionid'] && $live_user['userId'] = $re_wu['unionid'];
+ $re_wu['nickname'] && $live_user['userName'] = $re_wu['nickname'];
+ $re_wu['headimg'] && $live_user['pic'] = $re_wu['headimg'];
+ ////更新参数
+// $jsondata = $re_wu['jsondata'] ? json_decode($re_wu['jsondata'], true) : '';
+// $jsondata['live'] = $params;
+// $this->mdWeixinUsers->update(['jsondata' => json_encode($jsondata, JSON_UNESCAPED_UNICODE)], ['id' => $this->uid]);
+ }
}
if ($this->session['biz_id']) {//门店人员
$biz_id = $this->session['biz_id'];
@@ -86,17 +105,86 @@ class Live extends Wxapp
}
}
$share_skey = "id=" . $id . "&cf_uid=" . $cf_uid . '&biz_id=' . $biz_id;
- echo '
share_skey:' . $share_skey;
+ //echo '
share_skey:' . $share_skey;
$share_url = http_host_com('home') . "/h5/syt/live?skey=" . $this->myencryption->base64url_encode($share_skey);
- echo '
share_url:' . $share_url;
- $title = '盲盒抽奖';
+ //echo '
share_url:' . $share_url;
+ $title = $re['title'];
+ $share_img = $share_desc = $rule_content = '';
+ if ($re['jsondata']) {
+ $jsondata = json_decode($re['jsondata'], true);
+ $jsondata['share_img'] && $share_img = build_qiniu_image_url($jsondata['share_img']);
+ $jsondata['share_desc'] && $share_desc = $jsondata['share_desc'];
+ $jsondata['rule'] && $rule_content = str_replace("\n", "
", $jsondata['rule']);
+ }
+ $winInfo = $prizeList = [];
+ $prizes = $re['prizes'] ? json_decode($re['prizes'], true) : [];
+ foreach ($prizes['list'] as $key => $value) {
+ $prizeList[$value['id']] = $value;
+ }
+ $res_data = $this->mdSytLiveData->select(['l_id' => $id, 'type' => 2], 'id DESC', 1, 15, 'jsondata');
+ foreach ($res_data as $key => $value) {
+ if ($value['jsondata']) {
+ $jsondata_l = json_decode($value['jsondata'], true);
+ $prize_name = $prizeList[$jsondata_l['prize_id']]['title'];
+ $mobile = mobile_asterisk($jsondata_l['mobile']);
+ $winInfo[] = ['title' => $mobile . '领取了盲盒，开出了' . $prize_name];
+ }
+ }
+ $info['id'] = $id;
+ $info['session_id'] = $re['session_id'];
+ $info['l_status'] = $re['l_status'];
+ $info['l_status_name'] = $this->mdSytLive->lStatusAry($re['l_status']);
+ $info['cf_uid'] = $cf_uid;
+ $info['biz_id'] = $biz_id;
+ $info['biz_uid'] = intval($this->session['biz_uid']);
+ $info['checkua'] = $checkua;
+ $info['winInfo'] = $winInfo;
+ $info['banner'] = $re['img'] ? build_qiniu_image_url($re['img']) : '';
+ $info['rule'] = ['title' => '活动规则', 'content' => $rule_content];
+ $info['isOpen'] = false;//是否已开奖
+ $info['lottery'] = false;//是否已中奖
+ $info['e_time'] = 15;//距离开奖时间
+ $info['serviceCode'] = 'http://www.xmfish.com/images/chanel/www/index2/b_mobile.jpg';
+ $info['msgMyPrize'] = ['title' => '', 'lottery' => ['title' => '', 'img' => '', 'name' => '', 'mobile' => '',
+ 'time' => ['title' => '', 'content' => ''], 'other' => ['title' => '注意事项', 'content' => '您还未登记信息！']]];
+ //检查是否试中奖
+ $re_data = $this->mdSytLiveData->get(['l_id' => $id, 'type' => 2, 'if_biz' => $this->session['biz_id'] ? 1 : 0
+ , 'uid' => $this->session['biz_uid'] ? $this->session['biz_uid'] : $this->uid]);
+ if ($re_data) {
+ $jsondata = $re_data['jsondata'] ? json_decode($re_data['jsondata'], true) : '';
+ $prize_id = intval($jsondata['prize_id']);
+ if ($prize_id) {
+ $prizes_item = $prizeList[$prize_id];
+ if ($prizes_item) {
+ $info['isOpen'] = true;//已开奖
+ $info['lottery'] = true;//已中奖
+ $info['e_time'] = 0;
+ $info['msgMyPrize'] = ['title' => '我的试驾礼', 'lottery' => ['title' => $prizes_item['title']
+ , 'img' => build_qiniu_image_url($prizes_item['img_value']), 'price' => $prizes_item['price']
+ , 'name' => $jsondata['name'], 'mobile' => $jsondata['mobile'],
+ 'time' => ['title' => '活动时间', 'content' => $prizes['note']],
+ 'other' => ['title' => '注意事项', 'content' => '']]];
+ }
+ }
+ }
+ //直播参数
+ $this->load->library('PolyvApi');
+ $polyv = new PolyvApi();
+ $liveSdk = $polyv->getLiveSdk();
+ $liveSdk['user'] = $live_user;
+ $info['liveSdk'] = $liveSdk;
+ //分享
$share = [
'title' => $title,
- "img" => 'http://bbs.xmfish.com/attachment/2022_05/097c021b16d9ed4c11e7cb6f97818350.jpg',
- "desc" => '五一说走就走的旅行！下了两天雨，终于要大晴天了',
+ "img" => $share_img,
+ "desc" => $share_desc,
"url" => $share_url
];
+ if ($re['l_status'] == 1) {//加进入直播统计
+ $this->addLiveData(['type' => 1, 'l_id' => $id, 'cf_uid' => $cf_uid, 'biz_id' => $biz_id]);
+ }
$data = [
+ "info" => $info,
'_title' => $title,
"sign_package" => $sign_package,
"share" => $share,
@@ -106,6 +194,428 @@ class Live extends Wxapp
return $data;
}
+ function get_statistics()
+ {
+ $params = $this->input->get();
+ $id = intval($params['id']);
+ if (!$id) {
+ throw new Hd_exception('参数错误', 400);
+ }
+ if (!$this->session['biz_id']) {
+ throw new Hd_exception('无权限查看', 400);
+ }
+ $re = $this->mdSytLive->get(array("id" => $id, "status" => 1));
+ if (!$re) {
+ throw new Hd_exception("直播不存在", 400);
+ }
+ $this->load->model('live/Live_polyv_viewlog_model', 'mdPolyvViewlog');
+ $this->load->model("biz/biz_model", 'mdBiz');
+ $where = ['l_id' => $id, 'biz_id' => $this->session['biz_id']];
+ $re_biz = $this->mdSytLiveBiz->get($where);
+ //$watchs_num = $this->mdSytLiveData->count(['l_id' => $id, 'biz_id' => $this->session['biz_id'], 'type' => 1]);
+ $watchs = $enrolls = $playDuration = $watchs_num = 0;
+ if ($re_biz) {
+ $watchs = $re_biz['watchs'];
+ $enrolls = $re_biz['enrolls'];
+ }
+ $dynamic = $watchsList = $enrollsList = [];
+ $res = $this->mdSytLiveData->select($where, 'id DESC', 1, 15, 'uid,if_biz,type,c_time');
+ if ($res) {
+ $users_wx = $users_cb = $map_wx = $map_cb = [];
+ foreach ($res as $key => $value) {
+ if ($value['if_biz']) {
+ $users_cb[] = $value['uid'];
+ } else {
+ $users_wx[] = $value['uid'];
+ }
+ }
+ if ($users_wx) {
+ $str_ids = implode(',', array_unique($users_wx));
+ $map_wx = $this->mdWeixinUsers->map('id', 'nickname,uname', ["id in({$str_ids})" => null]);
+ }
+ if ($users_cb) {
+ $str_ids = implode(',', array_unique($users_cb));
+ $map_cb = $this->mdLichebUsers->map('id', 'nickname,uname', ["id in({$str_ids})" => null]);
+ }
+ foreach ($res as $key => $value) {
+ $type_name = $value['type'] == 2 ? ' 领取了试驾盒' : ' 进入了直播间';
+ if ($value['if_biz']) {
+ $name = $map_cb[$value['uid']]['nickname'] ? $map_cb[$value['uid']]['nickname'] : $map_cb[$value['uid']]['uname'];
+ } else {
+ $name = $map_wx[$value['uid']]['nickname'] ? $map_wx[$value['uid']]['nickname'] : $map_wx[$value['uid']]['uname'];
+ }
+ !$name && $name = '无用户名';
+ $dynamic[] = ['title' => $name . $type_name, 'time' => friendly_date($value['c_time'], 'mohu')];
+ }
+ }
+ if ($re['session_id']) {
+ $this->load->library('PolyvApi');
+ $polyv = new PolyvApi();
+ $liveParam = $polyv->getLiveParam();
+ $where_live = ['param3' => 'live', 'channelId' => $liveParam['channelId'], 'sessionId' => $re['session_id'],
+ "param1 in (select distinct unionid from lc_syt_live_data where l_id={$id} AND biz_id={$this->session['biz_id']} AND type=1)" => null];
+ $re_sum = $this->mdPolyvViewlog->sum('playDuration', $where_live);
+ $playDuration = ceil($re_sum['playDuration'] / $watchs);
+ $watchs_num = $this->mdPolyvViewlog->count($where_live);
+ }
+ $res_watchs = $this->mdSytLiveBiz->select(['l_id' => $id], 'watchs DESC,id ASC', 1, 10, 'biz_id,watchs');
+ if ($res_watchs) {
+ $str_ids = implode(',', array_unique(array_column($res_watchs, 'biz_id')));
+ $map_biz = $this->mdBiz->map('id', 'biz_name', ["id in({$str_ids})" => null]);
+ foreach ($res_watchs as $key => $value) {
+ $watchsList[] = ['ranking' => ($key + 1), 'name' => $map_biz[$value['biz_id']], 'num' => $value['watchs'] . '人'];
+ }
+ }
+ $res_enrolls = $this->mdSytLiveBiz->select(['l_id' => $id], 'enrolls DESC,id ASC', 1, 10, 'biz_id,enrolls');
+ if ($res_enrolls) {
+ $str_ids = implode(',', array_unique(array_column($res_enrolls, 'biz_id')));
+ $map_biz = $this->mdBiz->map('id', 'biz_name', ["id in({$str_ids})" => null]);
+ foreach ($res_enrolls as $key => $value) {
+ $enrollsList[] = ['ranking' => ($key + 1), 'name' => $map_biz[$value['biz_id']], 'num' => $value['enrolls'] . '人'];
+ }
+ }
+ $survey = [['title' => '累计观看(次）', 'num' => $watchs_num, 'url' => ''], ['title' => '人均观看(秒）', 'num' => $playDuration, 'url' => '']
+ , ['title' => '观看用户', 'num' => $watchs, 'url' => '/h5/syt/live/statistics_view?id=' . $id], ['title' => '报名用户(人）', 'num' => $enrolls, 'url' => '']];
+ $info = ['tabid' => 1, 'tab' => [['id' => 1, 'title' => '活动数据'], ['id' => 2, 'title' => '活动排名']],
+ 'survey' => $survey, 'dynamic' => $dynamic, 'watchsList' => $watchsList, 'enrollsList' => $enrollsList];
+ $data = [
+ "info" => $info,
+ '_title' => '活动数据',
+ 'view' => 'h5/syt/live_statistics',
+ ];
+ return $data;
+ }
+
+ function get_statistics_view()
+ {
+ $params = $this->input->get();
+ $id = intval($params['id']);
+ if (!$id) {
+ throw new Hd_exception('参数错误', 400);
+ }
+ if (!$this->session['biz_id']) {
+ throw new Hd_exception('无权限查看', 400);
+ }
+ $re = $this->mdSytLive->get(array("id" => $id, "status" => 1));
+ if (!$re) {
+ throw new Hd_exception("直播不存在", 400);
+ }
+ $info = ['id' => $id, 'thead' => ['观看昵称', '观看次数', '停留时长'], 'isDataEnd' => false, 'isNoData' => false, 'list' => []];
+ $res = $this->statistics_view_list(['id' => $id, 'session_id' => $re['session_id']]);
+ $info['session_id'] = $re['session_id'];
+ $info['isNoData'] = $res['total'] == 0 ? true : false;
+ $info['isDataEnd'] = count($res['list']) == $res['total'] ? true : false;
+ $info['list'] = $res['list'];
+ $data = [
+ "info" => $info,
+ '_title' => '活动数据_观看用户',
+ 'view' => 'h5/syt/live_statistics_view',
+ ];
+ return $data;
+ }
+
+ function get_statistics_view_list()
+ {
+ $params = $this->input->get();
+ $data = $this->statistics_view_list($params);
+ $data['code'] = 200;
+ return $data;
+ }
+
+ function statistics_view_list($params = [])
+ {
+ $this->load->model('live/Live_polyv_viewlog_model', 'mdPolyvViewlog');
+ $page = $params['page'] ? intval($params['page']) : 1;
+ $size = $params['size'] ? intval($params['size']) : 10;
+ $where = ['l_id' => $params['id'], 'biz_id' => $this->session['biz_id']];
+ $total = $this->mdSytLiveData->count($where, 'unionid');
+ $list = [];
+ if ($total) {
+ $res = $this->mdSytLiveData->select($where, 'id DESC', $page, $size, 'distinct(unionid),uid,if_biz,unionid');
+ $users_wx = $users_cb = $map_wx = $map_cb = [];
+ foreach ($res as $key => $value) {
+ if ($value['if_biz']) {
+ $users_cb[] = $value['uid'];
+ } else {
+ $users_wx[] = $value['uid'];
+ }
+ }
+ if ($users_wx) {
+ $str_ids = implode(',', array_unique($users_wx));
+ $map_wx = $this->mdWeixinUsers->map('id', 'nickname,uname,headimg', ["id in({$str_ids})" => null]);
+ }
+ if ($users_cb) {
+ $str_ids = implode(',', array_unique($users_cb));
+ $map_cb = $this->mdLichebUsers->map('id', 'nickname,uname,headimg', ["id in({$str_ids})" => null]);
+ }
+ $this->load->library('PolyvApi');
+ $polyv = new PolyvApi();
+ $liveParam = $polyv->getLiveParam();
+ foreach ($res as $key => $value) {
+ if ($value['if_biz']) {
+ $name = $map_cb[$value['uid']]['nickname'] ? $map_cb[$value['uid']]['nickname'] : $map_cb[$value['uid']]['uname'];
+ $headimg = $map_cb[$value['uid']]['headimg'];
+ } else {
+ $name = $map_wx[$value['uid']]['nickname'] ? $map_wx[$value['uid']]['nickname'] : $map_wx[$value['uid']]['uname'];
+ $headimg = $map_wx[$value['uid']]['headimg'];
+ }
+ $where_live = ['param3' => 'live', 'channelId' => $liveParam['channelId'], 'sessionId' => $params['session_id']
+ , 'param1' => $value['unionid']];
+ $num = $this->mdPolyvViewlog->count($where_live);
+ $re_sum = $this->mdPolyvViewlog->sum('playDuration', $where_live);
+ $time = 0;
+ if ($re_sum['playDuration']) {
+ $format = $re_sum['playDuration'] >= 3600 ? 'H时i分s秒' : 'i分s秒';
+ $time = gmdate($format, $re_sum['playDuration']);
+ }
+ $tip = '';
+ $re = $this->mdSytLiveData->count(array_merge($where, ['type' => 2, 'unionid' => $value['unionid']]));
+ $re && $tip = '报名';
+ !$name && $name = '无用户名';
+ !$headimg && $headimg = '/img/h5/avatar.png';
+ $list[] = ['headimg' => $headimg, 'name' => $name, 'tip' => $tip, 'num' => $num, 'time' => $time];
+ }
+ }
+ return ['total' => $total, 'list' => $list];
+ }
+
+ /**
+ * Notes:修改直播状态
+ * Created on: 2022/5/19 11:57
+ * Created by: dengbw
+ * @return array
+ * @throws Hd_exception
+ */
+ function post_l_status()
+ {
+ $params = $this->input->post();
+ $id = intval($params['id']);
+ $l_status = intval($params['l_status']);
+ $session_id = $params['session_id'];
+ if (!$id || !$session_id) {
+ throw new Hd_exception('参数错误', 400);
+ }
+ $re = $this->mdSytLive->get(array("id" => $id, "status" => 1));
+ if (!$re) {
+ throw new Hd_exception("直播不存在", 400);
+ }
+ $upData = ['l_status' => $l_status];
+ if (!$re['session_id']) {
+ $upData['session_id'] = $session_id;
+ } else {
+ $session_id = $re['session_id'];
+ }
+ $this->mdSytLive->update($upData, ["id" => $re['id']]);
+ $data = [
+ "code" => 200,
+ "msg" => '状态更新成功',
+ 'l_status' => $l_status,
+ 'l_status_name' => $this->mdSytLive->lStatusAry($l_status),
+ 'session_id' => $session_id
+ ];
+ return $data;
+ }
+
+ /**
+ * Notes:抽盲盒
+ * Created on: 2022/5/11 17:35
+ * Created by: dengbw
+ */
+ function post_lottery()
+ {
+ $params = $this->input->post();
+ $id = intval($params['id']);
+ if (!$id) {
+ throw new Hd_exception('参数错误', 400);
+ }
+ $re = $this->mdSytLive->get(array("id" => $id, "status" => 1));
+ if (!$re) {
+ throw new Hd_exception("直播不存在", 400);
+ }
+ if ($re['l_status'] != 1) {
+ throw new Hd_exception($this->mdSytLive->lStatusAry($re['l_status']), 400);
+ }
+ $msgWin = ['title1' => '恭喜您', 'title2' => '获得试驾好礼啦'];
+ $msgMyPrize = [];
+ $prizes = $re['prizes'] ? json_decode($re['prizes'], true) : [];
+ if ($prizes && $prizes['list']) {
+ $msgWin['content'] = $prizes['note'];
+ $count = count($prizes['list']) - 1;
+ $num = rand(0, $count);
+ $prizes_item = $prizes['list'][$num];
+ if ($prizes_item) {
+ $msgWin['id'] = $prizes_item['id'];
+ $msgWin['name'] = $prizes_item['title'];
+ $msgWin['price'] = $prizes_item['price'];
+ $msgWin['img'] = $prizes_item['img_value'] ? build_qiniu_image_url($prizes_item['img_value']) : '';
+ $msgMyPrize = ['title' => '我的试驾礼', 'lottery' => ['title' => $msgWin['name']
+ , 'img' => $msgWin['img'], 'price' => $msgWin['price'], 'name' => '', 'mobile' => '',
+ 'time' => ['title' => '活动时间', 'content' => $prizes['note']],
+ 'other' => ['title' => '注意事项', 'content' => '您还未登记信息！']]];
+ }
+ } else {
+ throw new Hd_exception("暂无盲盒奖品", 400);
+ }
+ $data = [
+ "code" => 200,
+ "msg" => '抽奖成功',
+ 'msgWin' => $msgWin,
+ 'msgMyPrize' => $msgMyPrize,
+ ];
+ return $data;
+ }
+
+ /**
+ * Notes:登记信息
+ * Created on: 2022/5/16 10:32
+ * Created by: dengbw
+ * @throws Hd_exception
+ */
+ function post_enroll()
+ {
+ $params = $this->input->post();
+ $mobile = $params['mobile'];
+ $name = $params['name'];
+ if (!$name) {
+ throw new Hd_exception('请输入您的姓名', 400);
+ }
+ if (!mobile_valid($mobile)) {
+ throw new Hd_exception('请输入正确的手机号', 400);
+ }
+ $id = intval($params['id']);
+ $biz_id = intval($params['biz_id']);
+ $cf_uid = intval($params['cf_uid']);
+ $prize_id = intval($params['prize_id']);
+ $re = $this->mdSytLive->get(array("id" => $id, "status" => 1));
+ if (!$re) {
+ throw new Hd_exception("直播不存在", 400);
+ }
+ if ($re['l_status'] != 1) {
+ throw new Hd_exception($this->mdSytLive->lStatusAry($re['l_status']), 400);
+ }
+ $uid = $this->session['biz_uid'] ? $this->session['biz_uid'] : $this->uid;
+ $this->load->model("biz/biz_model", 'mdBiz');
+ $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
+ $re_data = $this->mdSytLiveData->get(['type' => 2, 'l_id' => $id, 'if_biz' => $this->session['biz_id'] ? 1 : 0, 'uid' => $uid]);
+ if ($re_data) {
+ throw new Hd_exception('您已经登记过了', 400);
+ }
+ if (!$biz_id) {//无门店加入线索池
+ $cf_id = 35;
+ $this->load->model('receiver/receiver_clues_model', 'mdClues');
+ $re_clue = $this->mdClues->get(['out_id' => $id, 'cf_id' => $cf_id, 'mobile' => $mobile]);
+ if ($re_clue) {
+ throw new Hd_exception('您已经登记过', 400);
+ }
+ $add_data = [
+ 'name' => $name,
+ 'mobile' => $mobile,
+ 'cf_id' => $cf_id,
+ 'out_id' => $id,
+ 'cf_platform' => 'h5',
+ 'en_time' => date('Y-m-d H:i:s'),
+ 'c_time' => time()
+ ];
+ $this->mdClues->db->trans_begin();
+ $enroll_id = $this->mdClues->add($add_data);
+ $jsondata = ['name' => $name, 'mobile' => $mobile, 'enroll_id' => $enroll_id, 'enroll_type' => 2, 'prize_id' => $prize_id];
+ $id_d = $this->addLiveData(['type' => 2, 'l_id' => $id, 'cf_uid' => $cf_uid, 'biz_id' => $biz_id, 'jsondata' => $jsondata]);
+ if ($enroll_id && $id_d) {
+ $this->mdClues->db->trans_commit();
+ throw new Hd_exception('登记成功', 200);
+ } else {
+ $this->mdClues->db->trans_rollback();
+ throw new Hd_exception('登记失败，请重试', 400);
+ }
+ }
+ $re_cus = $this->mdCustomers->get(['biz_id' => $biz_id, 'mobile' => $mobile, 'of_id' => $this->of_id
+ , 'of2_id' => $this->of2_id, 't_id' => $id]);
+ if ($re_cus) {
+ throw new Hd_exception('您已经登记过', 400);
+ }
+ $city_id = $county_id = 0;
+ $re_biz = $this->mdBiz->get(['id' => $biz_id, 'status' => 1]);
+ if ($re_biz) {
+ $city_id = $re_biz['city_id'];
+ $county_id = $re_biz['county_id'];
+ }
+ $add_data = [
+ 'name' => $name,
+ 'mobile' => $mobile,
+ 'biz_id' => $biz_id,
+ 'city_id' => $city_id,
+ 'county_id' => $county_id,
+ 'cf_title' => '自有资源',
+ 'of_id' => $this->of_id,
+ 'of2_id' => $this->of2_id,
+ 'admin_id' => $cf_uid,
+ 't_id' => $id,
+ 'p_time' => date('Y-m-d H:i:s'),
+ 'c_time' => time()
+ ];
+ $this->mdCustomers->db->trans_begin();
+ $enroll_id = $this->mdCustomers->add($add_data);
+ $jsondata = ['name' => $name, 'mobile' => $mobile, 'enroll_id' => $enroll_id, 'enroll_type' => 1, 'prize_id' => $prize_id];
+ $id_d = $this->addLiveData(['type' => 2, 'l_id' => $id, 'cf_uid' => $cf_uid, 'biz_id' => $biz_id, 'jsondata' => $jsondata]);
+ if ($enroll_id && $id_d) {
+ $this->mdCustomers->db->trans_commit();
+ throw new Hd_exception('登记成功', 200);
+ } else {
+ $this->mdCustomers->db->trans_rollback();
+ throw new Hd_exception('登记失败，请重试', 400);
+ }
+ }
+
+ /**
+ * Notes:直播数据
+ * Created on: 2022/5/16 10:31
+ * Created by: dengbw
+ * @param $params
+ * @return mixed
+ */
+ private function addLiveData($params)
+ {
+ $add_data = [
+ 'l_id' => $params['l_id'],
+ 'unionid' => $this->session['unionid'],
+ 'uid' => $this->session['biz_uid'] ? $this->session['biz_uid'] : $this->uid,
+ 'cf_uid' => $params['cf_uid'],
+ 'biz_id' => $params['biz_id'],
+ 'type' => $params['type'],
+ 'if_biz' => $this->session['biz_uid'] ? 1 : 0,
+ 'c_time' => time()
+ ];
+ $params['jsondata'] && $add_data['jsondata'] = json_encode($params['jsondata'], JSON_UNESCAPED_UNICODE);
+ $id = $this->mdSytLiveData->add($add_data);
+ if ($id && $params['biz_id']) {//更新门店数据
+ $re_biz = $this->mdSytLiveBiz->get(['l_id' => $params['l_id'], 'biz_id' => $params['biz_id']]);
+ if ($re_biz) {
+ if ($params['type'] == 2) {//试驾盲盒人
+ $this->mdSytLiveBiz->update(['enrolls = enrolls+1' => null], ['id' => $re_biz['id']]);
+ } else {//进直播间人
+ $re_count = $this->mdSytLiveData->count(['l_id' => $add_data['l_id'], 'biz_id' => $add_data['biz_id']
+ , 'uid' => $add_data['uid'], 'type' => $add_data['type'], 'if_biz' => $add_data['if_biz']]);
+ if ($re_count == 1) {//人只统计一次
+ $this->mdSytLiveBiz->update(['watchs = watchs+1' => null], ['id' => $re_biz['id']]);
+ }
+ }
+ } else {
+ $add_data = [
+ 'l_id' => $params['l_id'],
+ 'biz_id' => $params['biz_id'],
+ 'c_time' => time()
+ ];
+ if ($params['type'] == 2) {
+ $add_data['enrolls'] = 1;
+ } else {
+ $add_data['watchs'] = 1;
+ }
+ $this->mdSytLiveBiz->add($add_data);
+ }
+ }
+ return $id;
+ }
+
/**
* Notes:微信未登录授权登录
* Created on: 2020/10/28 21:07
@@ -129,7 +639,6 @@ class Live extends Wxapp
$ret = json_decode($res, true);
$openid = $ret['openid'];
$unionid = $ret['unionid'];
- $mobile = '';
if ($openid) {
$row_wechat = $this->mdWeixinUsers->get(array('openid' => $openid));
if (!$row_wechat) {//用户授权信息未记录到wechat
@@ -152,7 +661,6 @@ class Live extends Wxapp
} else {
!$unionid && $unionid = $row_wechat['unionid'];
$this->uid = $row_wechat['id'];
- $mobile = $row_wechat['mobile'];
}
}
if ($this->uid) {
@@ -164,9 +672,9 @@ class Live extends Wxapp
$biz_uid = $re_licheb_users['id'];
}
}
- $session = ['uid' => $this->uid, "unionid" => $unionid, "mobile" => $mobile, "biz_id" => $biz_id, "biz_uid" => $biz_uid];
+ $session = ['uid' => $this->uid, "unionid" => $unionid, "biz_id" => $biz_id, "biz_uid" => $biz_uid];
$ukey = liche_authcode(json_encode($session, JSON_UNESCAPED_UNICODE), 'ENCODE', $this->secret);
- set_cookie("ukey", $ukey, 86400 * 30);
+ set_cookie("ukey", $ukey, 86400 * 1);
$this->session = $session;
}
} elseif ($auth) {//信息授权获取用户微信昵称/头像
@@ -189,9 +697,9 @@ class Live extends Wxapp
*/
private function set_auth_wxwork($url = '')
{
-// if ($this->uid) {
-// return;
-// }
+ if ($this->uid) {
+ return;
+ }
$config = $this->wx_qyapi_agent->getConfig();
$code = $this->input->get('code');
if ($code) {//授权码获取微信信息
@@ -207,11 +715,10 @@ class Live extends Wxapp
if ($re_u) {
$this->uid = $biz_uid = $re_u['id'];
$biz_id = intval($re_u['biz_id']);
- $mobile = $re_u['mobile'];
- $unionid = '';
- $session = ['uid' => $this->uid, "unionid" => $unionid, "mobile" => $mobile, "biz_id" => $biz_id, "biz_uid" => $biz_uid];
+ $unionid = $re_u['unionid'] ? $re_u['unionid'] : '';
+ $session = ['uid' => $this->uid, "unionid" => $unionid, "biz_id" => $biz_id, "biz_uid" => $biz_uid];
$ukey = liche_authcode(json_encode($session, JSON_UNESCAPED_UNICODE), 'ENCODE', $this->secret);
- set_cookie("ukey", $ukey, 86400 * 30);
+ set_cookie("ukey", $ukey, 86400 * 1);
$this->session = $session;
}
}
diff --git a/home/views/h5/syt/live.php b/home/views/h5/syt/live.php
index 130fa10a..a3a9b161 100644
--- a/home/views/h5/syt/live.php
+++ b/home/views/h5/syt/live.php
@@ -1,13 +1,12 @@
-
<?= $_title ?>
-
+
@@ -16,10 +15,11 @@
-
+
+
-
+
-
- ![#]()
+ ![#]()
-
+
+
- {{rule.title}}
-
+ {{info.rule.title}}
+
-
-
-
-
+
+
+
知道了
+ @click="isShowMsgWin=!isShowMsgWin,isShowMsgReg=!isReg">知道了
@@ -154,26 +225,76 @@
-
+
暂时未中奖
-
-
-
-
-
-
- {{item.title}}
- {{item.time.title}}
-
- {{item.other.title}}
-
-
-
-
+
+
+
+ {{info.msgMyPrize.lottery.title}}
+ {{info.msgMyPrize.lottery.price}}
+ {{info.msgMyPrize.lottery.time.title}}
+
+
+ {{info.msgMyPrize.lottery.other.title}}
+
+
+
+ 登记信息
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ ![#]()
+ 添加客服
+
+
@@ -182,144 +303,61 @@
+
+
+
+
+
+
+
+
+ 
+
+ 展开收起
+
+
+ 展开更多
+
+
+
+
+ {{item.title}}
+ {{item.time}}
+
+
+ {{item.title}}
+ {{item.time}}
+
+
+ 暂时无数据
+
+
+
+
+
+
+
+ 
+
+ 展开收起
+
+
+ 展开更多
+
+
+
+
+
+ ![#]()
+ {{item.ranking}}
+ {{item.name}}
+
+ {{item.num}}
+
+
+
+ ![#]()
+ {{item.ranking}}
+ {{item.name}}
+
+ {{item.num}}
+
+
+ 暂时无数据
+
+
+
+
+
+ 
+
+ 展开收起
+
+
+ 展开更多
+
+
+
+
+
+ ![#]()
+ {{item.ranking}}
+ {{item.name}}
+
+ {{item.num}}
+
+
+
+ ![#]()
+ {{item.ranking}}
+ {{item.name}}
+
+ {{item.num}}
+
+
+ 暂时无数据
+
+
+
+
+
+
+
+
+
+ {{info.thead[0]}}
+ {{info.thead[1]}}
+ {{info.thead[2]}}
+
+
+
+
+ ![#]()
+ {{item.name}}
+ {{item.tip}}
+
+ {{item.num}}
+ {{item.time}}
+
+
+
+ 暂无数据
+ 请稍等...
+ 我们是有底线的
+
+
+
+
+
+ |
- 
- 
+