<?php
|
|
class xjhlive_model extends model{
|
/**
|
* @desc 发布/修改直播宣讲会
|
* @param array $data: post-宣讲会相关字段 id-修改宣讲会Id
|
* @return $return
|
*/
|
function addXjh($data = array())
|
{
|
|
$post = $data['post']; // 宣讲会数据相关字段
|
$id = $data['id']; // 更新宣讲会ID
|
|
if($post){
|
|
$picurlArr = array();
|
// 处理封面图片
|
if(is_array($post['pic'])){
|
|
$picArr = $post['pic'];
|
|
include_once('upload.model.php');
|
$UploadM = new upload_model($this->db, $this->def);
|
|
foreach($picArr as $pk=>$pv){
|
|
if (!empty($pv)){
|
|
$upArr = array(
|
'dir' => 'xjh',
|
'base' => $pv
|
);
|
|
$result = $UploadM -> newUpload($upArr);
|
|
if (!empty($result['msg'])){
|
|
$return['msg'] = $result['msg'];
|
$return['errcode'] = '8';
|
|
return $return;
|
}else if(!empty($result['picurl'])){
|
$picurlArr[] = $result['picurl'];
|
}
|
}
|
}
|
}
|
unset($post['pic']);
|
|
if ($post['state'] == 1){
|
|
$post['statetime'] = time();
|
|
}elseif ($post['state'] == 3){
|
|
$post['statetime'] = '';
|
}
|
|
if (!empty($id)) {
|
|
$xjh = $this -> select_once('xjhlive', array('id'=>$id));
|
|
if ($xjh['stime'] < time()){
|
|
$return['msg'] = '宣讲会直播已到开始时间，不支持修改';
|
|
}else if ($xjh['livestatus'] == 3){
|
|
$return['msg'] = '宣讲会直播已开始，不支持修改';
|
|
}else if ($xjh['livestatus'] == 2){
|
|
$return['msg'] = '宣讲会直播已结束，不支持修改';
|
|
}else if ($xjh['caster'] == 2){
|
|
$return['msg'] = '导播台已开启，不支持修改';
|
}
|
if (!empty($return['msg'])){
|
|
$return['errcode'] = 8;
|
|
return $return;
|
}
|
|
$this->update_once('xjhlive', $post, array('id' => $id));
|
$nid = $id;
|
$msg = '更新';
|
} else {
|
|
$nid = $this->insert_into('xjhlive', $post);
|
$msg = '发布';
|
}
|
if ($nid) {
|
|
if(!empty($picurlArr)){
|
//插入封面多图
|
foreach($picurlArr as $xpk=>$xpv){
|
|
$picdata = array(
|
'xid' => $nid,
|
'picurl'=> $xpv,
|
'ctime' => time()
|
);
|
|
$this->insert_into('xjhlive_pic', $picdata);
|
}
|
|
}
|
// 同步处理获取直播播放地址
|
$result = $this->xjhSync($nid);
|
|
if (empty($result['msg'])){
|
|
$return = array(
|
'id' => $nid,
|
'errcode' => 9,
|
'msg' => $msg.'直播宣讲会成功'
|
);
|
}else{
|
|
$return = $result;
|
|
if (empty($id)) {
|
// 平台发布失败，清除本地记录
|
$this->delete_all('xjhlive', array('id'=>$nid));
|
$this->delete_all('xjhlive_pic', array('xid'=>$nid), '');
|
}
|
}
|
}
|
|
}else{
|
|
$return = array(
|
'errcode' => 8,
|
'msg' => '数据错误'
|
);
|
}
|
|
return $return;
|
}
|
/**
|
* 后台添加参会企业
|
*/
|
public function addXjhCom($data = array()){
|
|
if (!empty($data['comid'])){
|
|
$comid = explode(',', $data['comid']);
|
$rows = $this->select_all('xjhlive_com',array('xid'=>$data['xid']));
|
|
if (!empty($rows)){
|
|
foreach ($rows as $v){
|
|
$xc[] = $v['uid'];
|
}
|
|
foreach ($comid as $v){
|
if (!in_array($v, $xc)){
|
|
$new[] = $v;
|
}
|
}
|
}else{
|
|
$new = $comid;
|
}
|
|
if (!empty($new)){
|
|
$time = time();
|
$valueData = array();
|
|
foreach ($new as $k => $v){
|
|
$valueData[$k]['uid'] = $v;
|
$valueData[$k]['xid'] = $data['xid'];
|
$valueData[$k]['ctime'] = $time;
|
}
|
$this->DB_insert_multi('xjhlive_com', $valueData);
|
|
$return['errcode'] = 9;
|
$return['msg'] = '添加成功';
|
|
}else{
|
|
$return['errcode'] = 8;
|
$return['msg'] = '重复添加';
|
}
|
}else{
|
|
$return['errcode'] = 8;
|
$return['msg'] = '请选择要添加的企业';
|
}
|
return $return;
|
}
|
function upXjh($where=array(),$data=array()){
|
|
if(!empty($where) && !empty($data)){
|
|
$xid = $this->update_once('xjhlive',$data,$where);
|
|
return $xid;
|
}
|
}
|
|
/**
|
* 获取宣讲会列表
|
* @param $whereData 查询条件
|
* @param string[] $data 自定义处理数组
|
* @return array|bool|false|string|void
|
*/
|
function getList($whereData,$data=array('utype'=>'')){
|
|
if(!empty($whereData)){
|
|
$select = $data['field'] ? $data['field'] : '*';
|
|
$List = $this -> select_all('xjhlive',$whereData,$select);
|
|
if(!empty($List)){
|
|
foreach($List as $k=>$v){
|
|
$xjhids[] = $v['id'];
|
}
|
$time = time();
|
|
$pwhere = array(
|
'xid' => array('in',pylode(',',$xjhids)),
|
'orderby' => 'id,ASC'
|
);
|
$xjhpic = $this->select_all("xjhlive_pic",$pwhere);
|
$picarr = array();
|
if(!empty($xjhpic)){
|
|
foreach($xjhpic as $pk=>$pv){
|
$picarr[$pv["xid"]][] = $pv["picurl"];
|
}
|
}
|
|
foreach($List as $k=>$v){
|
if (!empty($v['stime'])){
|
$List[$k]['stime_n'] = date('Y-m-d H:i',$v['stime']);
|
}
|
if (!empty($v['ctime'])){
|
$List[$k]['ctime_n'] = date('Y-m-d H:i',$v['ctime']);
|
}
|
if (!empty($v['statetime'])){
|
$List[$k]['statetime_n']= date('Y-m-d H:i',$v['statetime']);
|
}
|
$List[$k]['picarr'] = array();
|
|
if(!empty($picarr[$v['id']])){
|
|
foreach($picarr[$v['id']] as $pk=>$pv){
|
|
$picarr[$v['id']][$pk] = checkpic($pv);
|
|
}
|
|
$List[$k]['picarr'] = $picarr[$v['id']];
|
$List[$k]['pic'] = $picarr[$v['id']][0] ? $picarr[$v['id']][0] : '';
|
}
|
|
if(isset($v['status']) && $v['status']==0){
|
$List[$k]['status_n'] = '未审核';
|
}else if($v['status']==1){
|
$List[$k]['status_n'] = '已审核';
|
}else if($v['status']==2){
|
$List[$k]['status_n'] = '未通过';
|
}
|
|
if($v['livestatus']==1){
|
|
if (!empty($v['playtime'])){
|
|
$List[$k]['livestatus_n'] = '未开始';
|
|
}else{
|
$List[$k]['livestatus_n'] = '未开始';
|
}
|
$List[$k]['livestatus'] = 1;
|
}else if($v['livestatus']==2){
|
|
$List[$k]['livestatus_n'] = '已结束';
|
$List[$k]['livestatus'] = 2;
|
}else if($v['livestatus']==3){
|
$List[$k]['livestatus_n'] = '直播中';
|
$List[$k]['livestatus'] = 3;
|
}
|
}
|
if ($data['utype'] == 'admin'){
|
|
$List = $this->adminList($List);
|
}
|
|
if ($data['shortlen'] > 0){
|
foreach($List as $k=>$v){
|
if(mb_strlen($v['name'])>$data['shortlen']){
|
|
$List[$k]['name'] = mb_substr($v['name'],0,$data['shortlen'],'utf-8')."...";
|
$List[$k]['name_t'] = $v['name'];
|
}
|
}
|
}
|
|
if ($data['num']){
|
|
$subList = $this->select_all('xjhlive_yy',array('xid'=>array('in',pylode(',',$xjhids)),'groupby'=>'xid'),'`xid`,count(*) AS `num`');
|
|
if(!empty($subList)){
|
foreach($List as $key=>$val) {
|
|
$subnum = 0;
|
|
foreach($subList as $v) {
|
|
if($val['id']==$v['xid']){
|
$subnum = $v['num'];
|
}
|
}
|
$List[$key]['subnum'] = $subnum;
|
}
|
}
|
}
|
}
|
return $List;
|
}
|
}
|
private function adminList($List){
|
|
$uids = array();
|
foreach ($List as $v){
|
|
$xids[] = $v['id'];
|
$uids[] = $v['uid'];
|
}
|
$com = $this->select_all('company',array('uid'=>array('in',pylode(',', array_unique($uids)))),'`uid`,`name`');
|
|
$all = $this->select_all('xjhlive_com',array('xid'=>array('in', pylode(',', $xids)),'groupby'=>'xid'),'xid,count(*) as num');
|
|
foreach($List as $k=>$v){
|
|
foreach ($com as $val){
|
|
if ($v['uid'] == $val['uid']){
|
|
$List[$k]['comname'] = $val['name'];
|
}
|
}
|
|
if(!empty($all)){
|
foreach($all as $val){
|
if($v['id'] == $val['xid']){
|
$List[$k]['comnum'] = $val['num']; // 参会企业
|
}
|
}
|
}
|
}
|
return $List;
|
}
|
|
/**
|
* 获取宣讲会详情
|
* @param $whereData 查询条件
|
* @param int[] $data liveRecord 获取点播数据 livestatus 获取直播状态
|
* @return array|bool|false|string|void
|
*/
|
function getInfo($whereData, $data = array('liveRecord'=>0,'livestatus'=>0)){
|
|
if(!empty($whereData)){
|
|
$xjh = $this -> select_once('xjhlive', $whereData);
|
|
if($xjh['livestatus']==1 && ($xjh['stime']+3600*$xjh['playtime'])<time()){
|
// 直播宣讲会，超过预设时间后，将状态改为已结束，导播台开启的也要关掉
|
if ($xjh['caster'] == 2){
|
|
$sqlArr['caster'] = 1;
|
}
|
$sqlArr['livestatus'] = 2;
|
$this->update_once('xjhlive',$sqlArr,$whereData);
|
}
|
|
$field = empty($data['field']) ? '*' : $data['field'];
|
|
$Info = $this->select_once('xjhlive', $whereData, $field);
|
|
if(!empty($Info)){
|
|
$xjhpics = $this -> select_all('xjhlive_pic',array('xid'=>$Info['id']));
|
$picarr = array();
|
if(!empty($xjhpics)){
|
foreach($xjhpics as $pk=>$pv){
|
$picarr[$pk]['id'] = $pv['id'];
|
$picarr[$pk]['url'] = checkpic($pv['picurl']);
|
}
|
}
|
$Info['picarr'] = $picarr;
|
if (!empty($Info['stime'])){
|
$Info['stime_n'] = date('Y-m-d H:i',$Info['stime']);
|
}
|
if (!empty($Info['ctime'])){
|
$Info['ctime_n'] = date('Y-m-d H:i',$Info['ctime']);
|
}
|
|
$time = time();
|
|
// 正在直播改为手动触发，但正在直播需在直播时间内，不然依然算未开始
|
if ($Info['livestatus']==3 && !empty($Info['playtime'])){
|
|
if ($Info['stime'] > $time || ($Info['stime'] + (3600 * $Info['playtime'])) < $time){
|
|
$Info['livestatus'] = 1;
|
}
|
}
|
|
if (isset($Info['caster']) && $Info['caster'] == 2 && $Info['stime'] <= $time){
|
// 开启了导播台，并且到直播开始时间
|
$Info['iscaster'] = 1;
|
}else{
|
$Info['iscaster'] = 0;
|
}
|
if (!empty($Info['playtime'])){
|
$Info['endtime'] = $Info['stime'] + (3600 * $Info['playtime']);
|
}
|
if (!empty($Info['statetime'])){
|
$Info['statetime_n'] = date('Y-m-d H:i',$Info['statetime']);
|
}
|
// 直播公告
|
$Info['content'] = $this->config['sy_xjh_notice'];
|
//获取所有参会企业信息
|
if(isset($data['getcom'])){
|
$xjhcoms = $this -> select_all('xjhlive_com',array('xid'=>$Info['id']));
|
|
if(!empty($xjhcoms)){
|
$cuid = array();
|
foreach($xjhcoms as $k=>$v){
|
$cuid[] = $v['uid'];
|
}
|
|
require_once ('company.model.php');
|
$comM = new company_model($this->db, $this->def);
|
$comlist = $comM->getList(
|
array(
|
'uid' => array('in',pylode(',',$cuid)),
|
'r_status' => 1,
|
'name' => array('<>','')
|
),
|
array('field'=>'`uid`,`content`,`name`','logo'=>'1')
|
);
|
|
if (!empty($comlist['list'])){
|
|
foreach ($comlist['list'] as $ck=>$cv){
|
$content = strip_tags($cv['content']);
|
if(mb_strlen($content)>100){
|
$comlist['list'][$ck]['content'] = mb_substr($content, 0, 100, 'UTF8').'...';
|
}else{
|
$comlist['list'][$ck]['content'] = $content;
|
}
|
}
|
}
|
}
|
$Info['comlist'] = !empty($comlist['list']) ? $comlist['list'] : array();
|
}
|
|
if (!empty($Info['playurl'])){
|
|
$Info['hls'] = $Info['playurl'] . '.m3u8';
|
$Info['flv'] = $Info['playurl'] . '.flv';
|
unset($Info['playurl']);
|
}
|
if (isset($data['livestatus']) && $data['livestatus'] == 1){
|
|
if ($Info['livestatus'] == 2){
|
|
$Info['errmsg'] = '宣讲会直播已结束';
|
}
|
}
|
}
|
}
|
|
return $Info;
|
}
|
|
/**
|
* @desc 删除宣讲会
|
* @param int|array $delId
|
* @param array $data: admin, zdid, uid,userdel
|
*/
|
public function delXjh($delId = null, $data = array())
|
{
|
if (empty($delId)) {
|
|
$return = array(
|
'errcode' => 8,
|
'msg' => '请选择要删除的数据！'
|
);
|
} else {
|
|
if (is_array($delId)) {
|
|
$delId = pylode(',', $delId);
|
|
$return['layertype'] = 1;
|
} else {
|
|
$return['layertype'] = 0;
|
}
|
|
$delWhere = array('id' => array('in', $delId));
|
|
$result = $this->delete_all('xjhlive', $delWhere, '');
|
|
if ($result) {
|
|
$this->delete_all('xjhlive_black', array('xid' => array('in', $delId)), '');
|
|
$this->delete_all('xjhlive_material', array('xid' => array('in', $delId)), '');
|
|
$this->delete_all('xjhlive_yy', array('xid' => array('in', $delId)), '');
|
|
$this->delete_all('xjhlive_yymsg', array('xid' => array('in', $delId)), '');
|
|
$this->delete_all('xjhlive_com', array('xid' => array('in', $delId)), '');
|
|
$this->delete_all('xjhlive_chat', array('xid' => array('in', $delId)), '');
|
|
$this->delete_all('xjhlive_pic', array('xid' => array('in', $delId)), '');
|
|
$postjson = array('xid'=>$delId);
|
$this->dxRequest('m=xjh&c=delsync', $postjson);
|
}
|
|
$return['errcode'] = $result ? 9 : 8;
|
|
$msg = '宣讲会';
|
|
$return['msg'] = $result ? $msg.'删除成功！' : $msg.'删除失败！';
|
}
|
return $return;
|
}
|
/**
|
* @desc 删除宣讲会封面
|
* @param int|array $delId
|
* @param array $data: admin, zdid, uid,userdel
|
*/
|
public function delXjhPic($delId = null, $data = array())
|
{
|
if (empty($delId)) {
|
|
$return = array(
|
'errcode' => 8,
|
'msg' => '请选择要删除的数据！'
|
);
|
} else {
|
|
if (is_array($delId)) {
|
|
$delId = pylode(',', $delId);
|
|
$return['layertype'] = 1;
|
} else {
|
|
$return['layertype'] = 0;
|
}
|
|
if ($data['utype'] == 'admin') {
|
|
$delWhere = array('id' => array('in', $delId));
|
} else {
|
|
$delWhere['id'] = array('in', $delId);
|
|
$delWhere['uid'] = $data['uid'];
|
}
|
|
$result = $this->delete_all('xjhlive_pic', $delWhere, '');
|
|
|
$return['errcode'] = $result ? 9 : 8;
|
|
$msg = '宣讲会封面';
|
|
$return['msg'] = $result ? $msg.'删除成功！' : $msg.'删除失败！';
|
}
|
return $return;
|
}
|
/**
|
* 删除参会企业
|
*/
|
public function delXjhCom($delId = null, $xid = ''){
|
|
if (empty($delId) || $xid == '') {
|
|
$return = array('errcode' => 8, 'msg' => '请选择要删除的数据！');
|
} else {
|
|
if (is_array($delId)) {
|
|
$delId = pylode(',', $delId);
|
|
$return['layertype'] = 1;
|
} else {
|
|
$return['layertype'] = 0;
|
}
|
|
$list = $this->select_all('xjhlive_com',array('id'=>array('in',$delId)));
|
|
if(!empty($list)){
|
|
foreach ($list as $v){
|
|
$uid[] = $v['uid'];
|
}
|
}
|
|
$return['id'] = $this -> delete_all('xjhlive_com', array('id' => array('in', $delId)), '');
|
|
$return['errcode'] = $return['id'] ? 9 : 8;
|
|
$msg = '宣讲会参会企业（ID：'.$delId.'）';
|
|
$return['msg'] = $return['id'] ? $msg.'删除成功！' : '删除失败！';
|
}
|
return $return;
|
}
|
/**
|
* 查询参会企业
|
*/
|
function getXjhComList($whereData=array(),$data=array()){
|
|
$field = !empty($data['field']) ? $data['field'] : '*';
|
|
$List = $this->select_all('xjhlive_com',$whereData,$field);
|
|
if(!empty($List)){
|
|
$uid = $zid = $xid = array();
|
|
foreach($List as $v){
|
if($v['uid'] && !in_array($v['uid'] , $uid)){
|
$uid[] = $v['uid'];
|
}
|
if($v['xid'] && !in_array($v['xid'],$xid)){
|
$xid[] = $v['xid'];
|
}
|
}
|
|
if ($data['utype'] == 'admin'){
|
|
$company = $this -> select_all('company', array('uid'=>array('in',pylode(',',$uid))),'`uid`,`name`,`logo`,`logo_status`,`r_status`');
|
|
$jfield = '`id`,`uid`,`name`';
|
|
$listA = $this -> select_all('company_job',array('uid'=>array('in',pylode(',',$uid)),'state' => 1, 'status' => 0,'r_status' => 1),$jfield);
|
}
|
|
$xjh = $this -> select_all('xjhlive',array('id'=>array('in',pylode(',',$xid))),'`id`,`name`');
|
|
|
foreach($List as $k => $v){
|
|
if ($data['utype'] == 'admin'){
|
foreach($company as $val){
|
|
if($v['uid'] == $val['uid']){
|
|
$List[$k]['comname'] = $val['name'];
|
}
|
}
|
$jobname = array();
|
|
foreach($listA as $val){
|
|
if ($v['uid'] == $val['uid']) {
|
if (count($jobname) < 10){
|
$jobname[] = $val['name'];
|
$List[$k]['jobname'] = @implode('、',$jobname);
|
}
|
}
|
}
|
}
|
foreach($xjh as $val){
|
if($v['xid'] == $val['id']){
|
$List[$k]['xjhname'] = $val['name'];
|
}
|
}
|
}
|
}
|
|
return $List;
|
}
|
/**
|
* @desc 查询宣讲会预定列表
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
function getyyList($where=array(),$data=array()){
|
|
if(!empty($where)){
|
|
$List = $this->select_all('xjhlive_yy',$where);
|
|
if(!empty($List)){
|
|
$uid = $xid = array();
|
|
foreach($List as $k=>$v){
|
|
if($v['uid'] && !in_array($v['uid'] , $uid)){
|
$uid[] = $v['uid'];
|
}
|
if($v['xid'] && !in_array($v['xid'],$xid)){
|
$xid[] = $v['xid'];
|
}
|
}
|
$user = $this->select_all('resume', array('uid'=>array('in',pylode(',',$uid))),'`uid`,`name`');
|
$xjhList = $this->getList(array('id'=>array('in',pylode(',',$xid))));
|
|
foreach($List as $key=>$val){
|
|
$List[$key]['ctime_n'] = date('Y-m-d H:i', $val['ctime']);
|
|
foreach ($user as $cv){
|
if ($val['uid'] == $cv['uid']){
|
|
$List[$key]['name'] = $cv['name'];
|
}
|
}
|
foreach($xjhList as $k=>$v){
|
|
if($val['xid'] == $v['id']){
|
|
$List[$key]['xjhname'] = $v['name'];
|
|
$List[$key]['stime_n'] = $v['stime_n'];
|
|
$List[$key]['livestatus_n'] = $v['livestatus_n'];
|
$List[$key]['livestatus'] = $v['livestatus'];
|
$List[$key]['wapxjh_url'] = Url('wap',array('c'=>'xjhlive','a'=>'show','id'=>$v['id']));
|
}
|
}
|
}
|
}
|
|
return $List;
|
}
|
}
|
/**
|
* 删除宣讲会预约记录
|
* @param int|array $delId
|
* @param array $data
|
*/
|
public function delyy($delId, $data = array()){
|
|
if (empty($delId)) {
|
|
$return = array('errcode' => 8, 'msg' => '请选择要取消的数据！');
|
} else {
|
|
if (is_array($delId)) {
|
|
$delId = pylode(',', $delId);
|
|
$return['layertype'] = 1;
|
} else {
|
|
$return['layertype'] = 0;
|
}
|
|
if ($data['utype'] == 'admin'){
|
|
$delWhere = array('id' => array('in', $delId));
|
|
}else{
|
|
$delWhere = array('id' => array('in', $delId), 'uid' => $data['uid']);
|
}
|
|
$yylist = $this->select_all('xjhlive_yy', $delWhere);
|
|
$yids = array();
|
|
foreach($yylist as $k=>$v){
|
$yids[] = $v['id'];
|
}
|
|
$return['id'] = $this->delete_all('xjhlive_yy', $delWhere, '');
|
|
if ($return['id']) {
|
|
$this -> delete_all('xjhlive_yymsg', array('yid' => array('in', pylode(',', $yids))), '');
|
}
|
|
$return['errcode'] = $return['id'] ? 9 : 8;
|
|
$msg = '宣讲会预约记录';
|
|
$return['msg'] = $return['id'] ? $msg.'取消成功！' : $msg.'取消失败！';
|
}
|
return $return;
|
}
|
/**
|
* 添加宣讲会严禁词
|
*/
|
function addXjhkeyword($name=array(),$data=array()){
|
|
if(!empty($name)){
|
|
$nwarr = $this->select_all('xjhlive_keyword', array('name' => array('in', "'".implode("','", $name)."'")));
|
|
if(empty($nwarr)){
|
|
foreach($name as $k=>$v){
|
|
if (!empty($v)){
|
|
$nid= $this->insert_into('xjhlive_keyword',array('name'=>$v));
|
}
|
}
|
|
if($nid){
|
|
$this->addKeywordFile();
|
|
$return['msg'] = '添加成功';
|
|
$return['errcode'] = 9;
|
|
}else{
|
|
$return['msg'] = '数据错误';
|
|
$return['errcode'] = 8;
|
}
|
}else{
|
|
$return['msg'] = '该严禁词已添加';
|
$return['code'] = 7;
|
$return['errcode'] = 8;
|
}
|
|
}else{
|
$return['msg'] = '严禁词不能为空';
|
|
$return['errcode'] = 8;
|
}
|
return $return;
|
}
|
private function addKeywordFile($data=array()){
|
|
$zdid = $data['zdid'] ? $data['zdid'] : 0;
|
|
$nwarr = $this->select_all('xjhlive_keyword');
|
|
$name = array();
|
foreach($nwarr as $k=>$v){
|
$name[] = $v['name'];
|
}
|
if(!empty($name)){
|
|
$nstr = implode("\r\n", $name);
|
}else{
|
|
$nstr = '';
|
}
|
|
$path = DATA_PATH.'sensitive/xjhword.txt';
|
|
$fp = @fopen($path,w);
|
@fwrite($fp,"$nstr");
|
@fclose($fp);
|
}
|
public function delXjhkeyword($delId = null, $data = array()){
|
|
if (empty($delId)) {
|
|
$return = array('errcode' => 8, 'msg' => '请选择要删除的数据！');
|
} else {
|
|
if (is_array($delId)) {
|
|
$delId = pylode(',', $delId);
|
|
$return['layertype'] = 1;
|
} else {
|
|
$return['layertype'] = 0;
|
}
|
|
$delWhere = array('id' => array('in',$delId));
|
|
$return['id'] = $this -> delete_all('xjhlive_keyword', $delWhere, '');
|
|
$this->addKeywordFile();
|
|
$return['errcode'] = $return['id'] ? 9 : 8;
|
|
$msg = '严禁词';
|
|
$return['msg'] = $return['id'] ? $msg.'删除成功！' : '删除失败！';
|
}
|
return $return;
|
}
|
/**
|
* 严禁词列表
|
*/
|
public function getXjhkeywordList($whereData , $data = array('field'=>null, 'utype'=> null)) {
|
|
$select = $data['field'] ? $data['field'] : '*';
|
|
$List = $this -> select_all('xjhlive_keyword',$whereData,$select);
|
|
return $List;
|
}
|
/**
|
* 添加宣讲会开播通知待发送记录
|
*/
|
function addyyMsg($xjhid = '', $uid = '',$nid){
|
|
if($xjhid != ''){
|
|
$xjh = $this -> select_once('xjhlive', array('id'=>$xjhid),'`id`,`name`,`stime`');
|
|
if(!empty($xjh)){
|
$stime = $xjh['stime']-30*60>time()?$xjh['stime']-30*60:time();
|
|
$msgData = array(
|
'xid' => $xjh['id'],
|
'stime' => $stime,
|
'yid' => $nid,
|
'xjhname' => $xjh['name'],
|
'xjhtime' => $xjh['stime']
|
);
|
|
$member = $this->select_once('member',array('uid'=>$uid),'`uid`,`wxid`');
|
|
if (!empty($member)){
|
// 有这些参数，可用来发送通知
|
$msgData['uid'] = $member['uid'];
|
|
if (empty($member['wxid'])){
|
|
$return['wxshow'] = 1;
|
}
|
}
|
|
$return['id'] = $this -> insert_into('xjhlive_yymsg', $msgData);
|
|
return $return;
|
}
|
}
|
}
|
/**
|
* 直播宣讲会预约发送微信提醒
|
* 后台计划任务文件名：xjhlive_yy.php; url执行方法：index.php?m=ajax&c=sendXjhliveYy
|
*/
|
function sendYymsg(){
|
|
$time = time();
|
|
$begined = $this->select_once('xjhlive_yymsg', array('status'=>1,'xjhtime'=>array('<',$time)));
|
|
if (!empty($begined)){
|
|
$this->delete_all('xjhlive_yymsg', array('status'=>1,'xjhtime'=>array('<',$time)), '');
|
}
|
|
$list = $this -> select_all('xjhlive_yymsg', array('status'=>0,'stime'=>array('<',time())));
|
|
if(!empty($list)){
|
|
$ids = array();
|
foreach($list as $val){
|
|
$uids[] = $val['uid'];
|
}
|
$uids = array_unique($uids);
|
|
$members = $this->select_all('member', array('uid'=>array('in', pylode(',', $uids))), '`uid`,`wxid`');
|
|
require_once 'weixin.model.php';
|
|
$weixinM = new weixin_model($this->db, $this->def);
|
|
$sendData = array();
|
|
foreach($list as $key=>$val){
|
|
foreach ($members as $v){
|
|
if ($val['uid'] == $v['uid']){
|
|
$sendData['id'] = $val['id'];
|
$sendData['uid'] = $val['uid'];
|
$sendData['usertype']= 1;
|
$sendData['wxid'] = $v['wxid'];
|
$sendData['name'] = $val['xjhname'];
|
$sendData['stime'] = $val['xjhtime'];
|
$sendData['url'] = Url('wap', array('c'=>'xjhlive', 'a' => 'show', 'id' => $val['xid']));
|
|
$weixinM->sendWxXjhLiveYy($sendData);
|
|
$ids[] = $val['id'];
|
}
|
}
|
}
|
if (!empty($ids)){
|
|
$this->update_once('xjhlive_yymsg',array('status'=>1),array('id'=>array('in',pylode(',', $ids))));
|
}
|
}
|
}
|
/**
|
* 添加预约记录
|
* @param array $data
|
* @return boolean|unknown
|
*/
|
function addyy($data=array()){
|
|
if(!empty($data)){
|
$nid = $this->insert_into('xjhlive_yy', $data);
|
}
|
|
return $nid;
|
|
}
|
/**
|
* 获取预约信息
|
*/
|
function getyyInfo($whereData=array(),$data=array()){
|
|
if(!empty($whereData)){
|
|
$field = empty($data['field']) ? '*' : $data['field'];
|
|
$Info = $this -> select_once('xjhlive_yy', $whereData, $field);
|
|
if(!empty($Info)){
|
|
$xjh = $this->getInfo(array('id'=>$Info['xid']));
|
|
$Info['status_n'] = $xjh['status_n'];
|
|
$Info['name'] = $xjh['name'];
|
|
$Info['stime_n'] = $xjh['stime_n'];
|
}
|
}
|
|
return $Info;
|
|
}
|
/**
|
* 添加宣讲会导播台素材
|
*/
|
function addMaterial($data){
|
|
if (!empty($data)){
|
|
$this->insert_into('xjhlive_material', $data);
|
}
|
}
|
/**
|
* 查询宣讲会导播台素材
|
*/
|
function getMaterial($where){
|
|
$row = $this->select_once('xjhlive_material', $where);
|
|
if (!empty($row['url'])){
|
|
$token = $this->base64Encode(array('ak'=>$this->config['sy_xjhlive_appkey'],'t'=>time()));
|
|
if (stripos($row['url'], '.mp4')!==false || stripos($row['url'], '.MP4') !== false){
|
$row['url'] .= '?vframe/jpg/offset/0/w/140/h/90&token=' .$token;
|
}else{
|
$row['url'] .= '?token='.$token;
|
}
|
}
|
return $row;
|
}
|
/**
|
* 查询宣讲会导播台素材列表
|
*/
|
function getMaterials($where){
|
|
$rows = $this->select_all('xjhlive_material', $where);
|
|
if (!empty($rows)){
|
|
$token = $this->base64Encode(array('ak'=>$this->config['sy_xjhlive_appkey'],'t'=>time()));
|
|
foreach ($rows as $k=>$v){
|
|
$rows[$k]['video'] = 0;
|
if (stripos($v['url'], '.mp4')!==false || stripos($v['url'], '.MP4')!==false){
|
$rows[$k]['video'] = 1;
|
$rows[$k]['url'] = $v['url']. '?vframe/jpg/offset/0/w/140/h/90&token=' .$token;
|
}else{
|
$rows[$k]['url'] = $v['url']. '?token=' .$token;
|
}
|
}
|
}
|
return $rows;
|
}
|
/**
|
* 宣讲会导播台素材修改
|
*/
|
function upMaterial($where=array(),$data=array()){
|
|
if(!empty($where)){
|
|
$xid = $this->update_once('xjhlive_material',$data,$where);
|
|
return $xid;
|
}
|
}
|
/**
|
* @desc 删除宣讲会导播台素材
|
*/
|
public function delMaterial($delId = null, $data = array())
|
{
|
if (empty($delId)) {
|
|
$return = array(
|
'errcode' => 8,
|
'msg' => '请选择要删除的数据！'
|
);
|
} else {
|
|
if (is_array($delId)) {
|
|
$delId = pylode(',', $delId);
|
|
$return['layertype'] = 1;
|
} else {
|
|
$return['layertype'] = 0;
|
}
|
|
$result = $this->delete_all('xjhlive_material', array('id' => array('in', $delId)), '');
|
|
$return['errcode'] = $result ? 9 : 8;
|
|
$msg = '导播素材';
|
|
$return['msg'] = $result ? $msg.'删除成功！' : $msg.'删除失败！';
|
}
|
return $return;
|
}
|
/**
|
* 设置导播台暖场视频
|
*/
|
function setCasterVideo($where,$data){
|
|
$msg = '暖场视频';
|
|
if ($data['state'] == 1){
|
// 设置
|
$startvideo = 1;
|
|
}else{
|
// 取消设置
|
$startvideo = 0;
|
$msg .= '取消';
|
}
|
|
$this->update_once('xjhlive_material', array('startvideo'=>$startvideo), $where);
|
|
$row = $this->select_once('xjhlive_material',$where, '`id`,xid,`syncid`');
|
|
$postjson['mid'] = $row['syncid'];
|
$postjson['xid'] = $row['xid'];
|
$postjson['startvideo'] = $startvideo;
|
|
$url = 'm=xjh&c=setVideo';
|
|
$this->dxRequest($url, $postjson);
|
|
$return['msg'] = $msg . '设置成功';
|
$return['errcode'] = 9;
|
|
return $return;
|
}
|
/**
|
* 创建导播台
|
*/
|
function createCaster($data = array()){
|
|
$xid = $data['xid'];
|
$xjh = $this->select_once('xjhlive', array('id'=>$xid), '`id`,`stime`,`playtime`,`status`,`livestatus`');
|
|
if ($xjh['status'] == 0){
|
|
$return = array('errcode'=>8,'msg'=>'宣讲会审核中');
|
|
}elseif ($xjh['status'] == 2){
|
|
$return = array('errcode'=>8,'msg'=>'宣讲会未通过审核');
|
|
}elseif ($xjh['stime'] - 600 >= time()){
|
|
$return = array('errcode'=>8,'msg'=>'宣讲会开始前10分钟内才可创建导播台');
|
|
}elseif ($xjh['livestatus'] == 2){
|
|
$return = array('errcode'=>8,'msg'=>'宣讲会已结束');
|
|
}elseif ($xjh['livestatus'] == 3){
|
|
$return = array('errcode'=>8,'msg'=>'宣讲会正在直播中，无法创建导播台');
|
|
}else{
|
|
$material = $this->select_once('xjhlive_material',array('xid'=>$xjh['id']));
|
|
if (!empty($material)){
|
|
// 创建导播台
|
$postjson['xid'] = $xjh['id'];
|
|
$url = 'm=xjh&c=createCaster';
|
|
$return = $this->dxRequest($url, $postjson);
|
|
if (!empty($return['playurl'])){
|
|
$this->update_once('xjhlive',array('playurl'=>$return['playurl'],'caster'=>1),array('id'=>$xjh['id']));
|
|
$return = array('errcode'=>9,'msg'=>'导播台创建成功');
|
}else{
|
$return = array('errcode'=>8,'msg'=>$return['msg']);
|
}
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'请先添加导播素材');
|
}
|
}
|
return $return;
|
}
|
/**
|
* 开启导播台
|
*/
|
function openCaster($data = array()){
|
|
$xid = $data['xid'];
|
$xjh = $this->select_once('xjhlive', array('id'=>$xid), '`id`');
|
|
$postjson['xid'] = $xjh['id'];
|
|
$url = 'm=xjh&c=openCaster';
|
|
$return = $this->dxRequest($url, $postjson);
|
|
if ($return['errcode'] == 9){
|
|
$this->update_once('xjhlive',array('caster'=>2), array('id'=>$xjh['id']));
|
|
$return = array('errcode'=>9,'msg'=>$return['msg']);
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>$return['msg']);
|
}
|
|
return $return;
|
}
|
/**
|
* 导播台切换监视器画面，并切换布局
|
*/
|
function upMonitor($data = array()){
|
|
$xid = $data['xid'];
|
$xjh = $this->select_once('xjhlive', array('id'=>$xid), '`id`');
|
|
$postjson['xid'] = $xjh['id'];
|
$postjson['mid'] = $data['mid'];
|
$postjson['layout'] = $data['layout'];
|
|
$url = 'm=xjh&c=upMonitor';
|
|
$return = $this->dxRequest($url, $postjson);
|
|
if ($return['errcode'] == 9){
|
|
$return = array('errcode'=>9,'msg'=>'切换成功');
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>$return['msg']);
|
}
|
|
return $return;
|
}
|
/**
|
* 导播台切换监视器画面，并切换布局
|
*/
|
function liveCaster($data = array()){
|
|
$xid = $data['xid'];
|
$xjh = $this->select_once('xjhlive', array('id'=>$xid), '`id`');
|
|
$postjson['xid'] = $xjh['id'];
|
|
$url = 'm=xjh&c=liveCaster';
|
|
$return = $this->dxRequest($url, $postjson);
|
|
if ($return['errcode'] == 9){
|
|
$return = array('errcode'=>9,'msg'=>'切换成功');
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>$return['msg']);
|
}
|
|
return $return;
|
}
|
/**
|
* 上传素材文件
|
*/
|
function uploadMaterial($file, $data = array()){
|
|
$xjh = $this->select_once('xjhlive', array('id'=>$data['xid']), '`livestatus`');
|
|
if($xjh['livestatus'] ==2){
|
|
$return = array('errcode'=>8,'msg'=>'直播宣讲会已结束');
|
|
}else{
|
|
if ($file['tmp_name']){
|
|
$douxu = $this->dxRequest('m=xjh&c=getUpToken');
|
|
if ($douxu['errcode'] == 9){
|
|
require_once APP_PATH.'api/qiniu/oss.php';
|
|
$oss = new qiniuOss();
|
$res = $oss->uploadFile($douxu['token'], $file);
|
|
if (!empty($res['url'])){
|
|
$postjson['xid'] = $data['xid'];
|
$postjson['url'] = $res['url'];
|
|
$return = $this->dxRequest('m=xjh&c=addMaterial', $postjson);
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'文件上传失败');
|
}
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'上传凭证获取失败');
|
}
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'请上传文件');
|
}
|
}
|
return $return;
|
}
|
/**
|
* 通过接口查询是否可以创建宣讲会
|
*/
|
function xjhCanAdd(){
|
|
$url = 'm=xjh&c=canAdd';
|
|
$douxu = $this->dxRequest($url);
|
|
return $douxu;
|
}
|
/**
|
* 通过接口同步宣讲会，获取直播播放地址
|
*/
|
function xjhSync($id){
|
|
$xjh = $this->select_once('xjhlive',array('id'=>$id),'`id`,`name`,`ctime`,`stime`,`playtime`,`playback`,`state`,`statetime`');
|
|
$postjson['xjh'] = json_encode($xjh);
|
|
$url = 'm=xjh&c=sync';
|
|
$douxu = $this->dxRequest($url, $postjson);
|
|
if (!empty($douxu['playurl'])){
|
|
$this->update_once('xjhlive', array('playurl'=>$douxu['playurl'],'syncid'=>$douxu['id']), array('id'=>$xjh['id']));
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'操作失败：'.$douxu['msg']);
|
}
|
return $return;
|
}
|
/**
|
* 通过接口获取宣讲会直播地址
|
*/
|
function getLiveQrcode($where){
|
|
$xjh = $this->select_once('xjhlive', $where, '`id`,`name`,`ctime`,`stime`,`playtime`,`playback`,`livestatus`');
|
|
if($xjh['livestatus'] == 2 || ($xjh['stime']+3600*$xjh['playtime']) < time()){
|
|
$return = array('errcode'=>8,'msg'=>'直播宣讲会已结束');
|
}else{
|
|
$postjson['xjh'] = json_encode($xjh);
|
|
$url = 'm=xjh&c=getLiveQrcode';
|
|
$douxu = $this->dxRequest($url, $postjson);
|
|
if (!empty($douxu['pushurl'])){
|
|
$return = array('errcode'=>9,'msg'=>'直播宣讲会直播地址获取成功','url'=>$douxu['pushurl']);
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'直播宣讲会直播地址获取失败'.$douxu['msg']);
|
}
|
}
|
return $return;
|
}
|
/**
|
* 同步关闭直播
|
*/
|
function liveEnd($where){
|
|
$xjh = $this->select_once('xjhlive', $where, '`id`,`stime`,`livestatus`,`caster`');
|
|
if($xjh['livestatus'] == 1 && $xjh['stime'] >= time()){
|
|
$return = array('errcode'=>8,'msg'=>'直播宣讲会未开始');
|
|
}elseif($xjh['livestatus'] ==2){
|
|
$return = array('errcode'=>8,'msg'=>'直播宣讲会已结束');
|
|
}else{
|
|
$url = 'm=xjh&c=liveEnd';
|
|
$douxu = $this->dxRequest($url, array('xid'=>$xjh['id']));
|
|
if ($douxu['errcode'] == 9){
|
|
$sql = array(
|
'livestatus' => 2
|
);
|
|
if (!empty($douxu['fname'])){
|
|
$sql['recordurl'] = $douxu['fname'];
|
}
|
if ($xjh['caster'] == 2){
|
|
$sql['caster'] = 1;
|
}
|
$this->update_once('xjhlive', $sql, array('id'=>$xjh['id']));
|
|
$return = array('errcode'=>9,'msg'=>'直播关闭成功');
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'直播关闭失败'.$douxu['msg']);
|
}
|
}
|
return $return;
|
}
|
/**
|
* 获取宣讲会直播推流地址
|
*/
|
function getPushUrl($where){
|
|
$xjh = $this->select_once('xjhlive', $where, '`id`,`stime`,`livestatus`,`caster`,`playtime`');
|
|
if ($xjh['stime'] - 1800 >= time()){
|
$return = array('errcode'=>8,'msg'=>'宣讲会开始前30分钟内才可获取');
|
}elseif($xjh['livestatus'] == 2){
|
$return = array('errcode'=>8,'msg'=>'直播宣讲会已结束');
|
}elseif ($xjh['caster'] != 0){
|
$return = array('errcode'=>8,'msg'=>'已创建导播台，不支持获取推流地址');
|
}else{
|
$url = 'm=xjh&c=getPushUrl';
|
|
$douxu = $this->dxRequest($url, array('xid'=>$xjh['id']));
|
|
if ($douxu['errcode'] == 9){
|
|
$return = array('errcode'=>9,'msg'=>'推流地址有效期'.$xjh['playtime'].'小时','live'=>$douxu['live']);
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'获取失败，'.$douxu['msg']);
|
}
|
}
|
return $return;
|
}
|
/**
|
* 请求综合平台
|
*/
|
private function dxRequest($url, $postjson = array()){
|
|
if (!empty($this->config['sy_xjhlive_appkey']) && !empty($this->config['sy_xjhlive_appsecret'])){
|
|
$postjson['appKey'] = $this->config['sy_xjhlive_appkey'];
|
$postjson['appSecret'] = $this->config['sy_xjhlive_appsecret'];
|
|
$url = 'https://trtc.phpyun.com/zphnetv/index.php?'. $url;
|
|
$result = CurlPost($url,$postjson);
|
$reponse = json_decode($result, true);
|
$return = $reponse['data'];
|
|
}else{
|
|
$return = array('errcode'=>8,'msg'=>'请配置宣讲会云导播秘钥');
|
}
|
return $return;
|
}
|
/**
|
* base64加密
|
* @param string $data 需要编码的数组
|
* @return string
|
*/
|
private static function base64Encode($data)
|
{
|
return str_replace('=', '', strtr(base64_encode(json_encode($data, JSON_UNESCAPED_UNICODE)), '+/', '-_'));
|
}
|
}
|
?>
|
