web / yoho-live · Commits

Go to a project

Authored by wuxiao
Commit f013ac78f44f72504a07e6804d89e4e5250366ff 1 parent 1852a058

在线人数字段

Inline Side-by-side
Showing 2 changed files with 16 additions and 12 deletions
@@ -7,9 +7,9 @@ return [ @@ -7,9 +7,9 @@ return [
7 'config'=>[ 7 'config'=>[
8 //所属应用 8 //所属应用
9 'app'=>[ 9 'app'=>[
10 - 1=>'YOHOBUY',  
11 - 2=>'YOHOMARS',  
12 - 3=>'YOHOBOYS' 10 + 1=>'YOHOBuy',
  11 + 2=>'YOHOMars',
  12 + 3=>'YOHONow'
13 ], 13 ],
14 //是否精选 14 //是否精选
15 'best'=>[ 15 'best'=>[
@@ -69,7 +69,7 @@ class LivingController extends BaseController @@ -69,7 +69,7 @@ class LivingController extends BaseController
69 'master_meta'=>'', 69 'master_meta'=>'',
70 'title'=>$model->title, 70 'title'=>$model->title,
71 'pic'=>CommonImages::getTemplateComplex($model->pic, 2), 71 'pic'=>CommonImages::getTemplateComplex($model->pic, 2),
72 - 'audience_num'=>$model->roomNums ? (int)$model->roomNums->audience_num : 0, 72 + 'audience_num'=>$model->roomNums ? (int)$model->roomNums->online_num : 0,//在线人数
73 ]; 73 ];
74 if ($model->master){ 74 if ($model->master){
75 $row = array_merge($row,[ 75 $row = array_merge($row,[
@@ -91,8 +91,8 @@ class LivingController extends BaseController @@ -91,8 +91,8 @@ class LivingController extends BaseController
91 $_ret = json_decode($ret,true); 91 $_ret = json_decode($ret,true);
92 $models = RoomNums::find()->indexBy('room_id')->all(); 92 $models = RoomNums::find()->indexBy('room_id')->all();
93 foreach ($_ret as $k=>$row){ 93 foreach ($_ret as $k=>$row){
94 - if (!empty($models[$row['room_id']]->audience_num)){  
95 - $row['audience_num'] = $models[$row['room_id']]->audience_num; 94 + if (!empty($models[$row['room_id']]->online_num)){
  95 + $row['audience_num'] = $models[$row['room_id']]->online_num;//在线人数
96 } 96 }
97 $_ret[$k] = $row; 97 $_ret[$k] = $row;
98 } 98 }
@@ -158,7 +158,7 @@ class LivingController extends BaseController @@ -158,7 +158,7 @@ class LivingController extends BaseController
158 'url'=>$model->url, 158 'url'=>$model->url,
159 'live_title'=>$model->live_title, 159 'live_title'=>$model->live_title,
160 'live_room_id'=>(int)$model->room_id, 160 'live_room_id'=>(int)$model->room_id,
161 - 'audience_num'=>$model->roomNums ? (int)$model->roomNums->audience_num+$model->roomNums->replay_num : 0, 161 + 'audience_num'=>$model->roomNums ? intval($model->roomNums->audience_num+$model->roomNums->replay_num) : 0,
162 ]; 162 ];
163 $ret[$k] = $row; 163 $ret[$k] = $row;
164 } 164 }
@@ -173,8 +173,8 @@ class LivingController extends BaseController @@ -173,8 +173,8 @@ class LivingController extends BaseController
173 $_ret = json_decode($ret,true); 173 $_ret = json_decode($ret,true);
174 $models = RoomNums::find()->indexBy('room_id')->all(); 174 $models = RoomNums::find()->indexBy('room_id')->all();
175 foreach ($_ret as $k=>$row){ 175 foreach ($_ret as $k=>$row){
176 - if (!empty($models[$row['live_room_id']]->audience_num)){  
177 - $row['audience_num'] = $models[$row['live_room_id']]->audience_num; 176 + if (!empty($models[$row['live_room_id']])){
  177 + $row['audience_num'] = intval($models[$row['live_room_id']]->audience_num+$models[$row['live_room_id']]->replay_num);
178 } 178 }
179 $_ret[$k] = $row; 179 $_ret[$k] = $row;
180 } 180 }
@@ -191,6 +191,10 @@ class LivingController extends BaseController @@ -191,6 +191,10 @@ class LivingController extends BaseController
191 { 191 {
192 if ($room_id = $this->requests('room_id')) 192 if ($room_id = $this->requests('room_id'))
193 {//直播视频详情 193 {//直播视频详情
  194 +
  195 + //观看人数+1
  196 + RoomNums::updateAllCounters(['audience_num' => 1],['room_id'=>$room_id]);
  197 +
194 $key = __CLASS__.__FUNCTION__.'room_id'.$room_id; 198 $key = __CLASS__.__FUNCTION__.'room_id'.$room_id;
195 if (!$ret = $this->cache->get($key)){ 199 if (!$ret = $this->cache->get($key)){
196 if (!$model = Room::findOne(['room_id'=>$room_id,'app'=>$this->app])){ 200 if (!$model = Room::findOne(['room_id'=>$room_id,'app'=>$this->app])){
@@ -206,7 +210,7 @@ class LivingController extends BaseController @@ -206,7 +210,7 @@ class LivingController extends BaseController
206 'watermark'=>$model->watermark, 210 'watermark'=>$model->watermark,
207 'living'=>$model->living, 211 'living'=>$model->living,
208 'like_num'=>0, 212 'like_num'=>0,
209 - 'audience_num'=>0, 213 + 'audience_num'=>0,//在线人数
210 'live_start_time'=>0, 214 'live_start_time'=>0,
211 'rtmp_downstream_address'=>'', 215 'rtmp_downstream_address'=>'',
212 'flv_downstream_address'=>'', 216 'flv_downstream_address'=>'',
@@ -221,7 +225,7 @@ class LivingController extends BaseController @@ -221,7 +225,7 @@ class LivingController extends BaseController
221 if ($model->roomNums){ 225 if ($model->roomNums){
222 $ret = array_merge($ret,[ 226 $ret = array_merge($ret,[
223 'like_num'=>(int)$model->roomNums->like_num, 227 'like_num'=>(int)$model->roomNums->like_num,
224 - 'audience_num'=>(int)$model->roomNums->audience_num, 228 + 'audience_num'=>(int)$model->roomNums->online_num,
225 ]); 229 ]);
226 } 230 }
227 231
@@ -264,7 +268,7 @@ class LivingController extends BaseController @@ -264,7 +268,7 @@ class LivingController extends BaseController
264 $_ret = json_decode($ret,true); 268 $_ret = json_decode($ret,true);
265 $ret = array_merge($_ret,[ 269 $ret = array_merge($_ret,[
266 'like_num'=>(int)$model->like_num, 270 'like_num'=>(int)$model->like_num,
267 - 'audience_num'=>(int)$model->audience_num, 271 + 'audience_num'=>(int)$model->online_num,
268 ]); 272 ]);
269 }, 60); 273 }, 60);
270 } 274 }