|
@@ -130,6 +130,9 @@ class LiveService extends BaseService
|
|
|
return false;
|
|
return false;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ // 验证是否有开播中断播的继续播
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
$data = [
|
|
$data = [
|
|
|
'type' => isset($params['type']) ? intval($params['type']) : 1,
|
|
'type' => isset($params['type']) ? intval($params['type']) : 1,
|
|
|
'user_id' => $userId,
|
|
'user_id' => $userId,
|
|
@@ -145,17 +148,25 @@ class LiveService extends BaseService
|
|
|
'view_allow' => isset($params['view_allow']) ? intval($params['view_allow']) : 1,
|
|
'view_allow' => isset($params['view_allow']) ? intval($params['view_allow']) : 1,
|
|
|
'push_url' => isset($params['push_url']) ? trim($params['push_url']) : '',
|
|
'push_url' => isset($params['push_url']) ? trim($params['push_url']) : '',
|
|
|
'play_url' => isset($params['play_url']) ? trim($params['play_url']) : '',
|
|
'play_url' => isset($params['play_url']) ? trim($params['play_url']) : '',
|
|
|
- 'create_time'=> time(),
|
|
|
|
|
'update_time'=> time(),
|
|
'update_time'=> time(),
|
|
|
'status' =>1,
|
|
'status' =>1,
|
|
|
'mark'=>1,
|
|
'mark'=>1,
|
|
|
];
|
|
];
|
|
|
|
|
|
|
|
- if(!$liveId = $this->model->insertGetId($data)){
|
|
|
|
|
- $this->error = 2042;
|
|
|
|
|
- return false;
|
|
|
|
|
|
|
+ if($liveId = $this->model->where(['user_id'=> $userId,'status'=>1,'mark'=>1])->value('id')){
|
|
|
|
|
+ if(!$this->model->where(['user_id'=> $userId,'status'=>1,'mark'=>1])->update($data)){
|
|
|
|
|
+ $this->error = 2042;
|
|
|
|
|
+ return false;
|
|
|
|
|
+ }
|
|
|
|
|
+ }else{
|
|
|
|
|
+ $data['create_time'] = time();
|
|
|
|
|
+ if(!$liveId = $this->model->insertGetId($data)){
|
|
|
|
|
+ $this->error = 2042;
|
|
|
|
|
+ return false;
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+
|
|
|
$data['id'] = $liveId;
|
|
$data['id'] = $liveId;
|
|
|
$data['member'] = MemberModel::where(['id'=> $userId])->select(['id','nickname','avatar','status'])->first();
|
|
$data['member'] = MemberModel::where(['id'=> $userId])->select(['id','nickname','avatar','status'])->first();
|
|
|
$data['member'] = $data['member']? $data['member'] : [];
|
|
$data['member'] = $data['member']? $data['member'] : [];
|