diff --git a/application/api/model/RoomPit.php b/application/api/model/RoomPit.php index 38d0866..8d92a77 100644 --- a/application/api/model/RoomPit.php +++ b/application/api/model/RoomPit.php @@ -80,24 +80,36 @@ class RoomPit extends Model $text['pit_number'] = $pit_number; //聊天室推送系统消息 model('Chat')->sendMsg(1003,$room_id,$text); - if($pit_number == 9){ - //推送消息给设置此用户开播提醒的人 - $remind_users = db::name('vs_user_live_remind')->where('remind_user_id' , $user_id)->select('user_id'); - $remind_user = []; - foreach ($remind_users as $k=>$v){ - $remind_user[$k] = 'u'.$v['user_id']; - if($k >= 499){ //批量发单聊消息 最大数500个 - //结束整个循环 - break; - } - } - $content = [ - 'type' => 1, - 'roomID' => $room_id, - 'content' => '您关注的用户' . $FromUserInfo['nickname'] . '正在直播,快去围观吧!', - ]; - model('Tencent')->batchsendmsg($remind_user,json_encode($content)); + + //查看此房间是否处于pk中 + $is_pk = db::name('vs_room_pk')->where(['room_id_a' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_b') ?? 0; + if(!$is_pk){ + $is_pk = db::name('vs_room_pk')->where(['room_id_b' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_a') ?? 0; } + if($is_pk > 0){ + //如果此房间是pk中,则推送给pk中房间的成员 + $text['is_pk'] = 1; + model('Chat')->sendMsg(1003,$room_id,$text); + } + +// if($pit_number == 9){ +// //推送消息给设置此用户开播提醒的人 +// $remind_users = db::name('vs_user_live_remind')->where('remind_user_id' , $user_id)->select('user_id'); +// $remind_user = []; +// foreach ($remind_users as $k=>$v){ +// $remind_user[$k] = 'u'.$v['user_id']; +// if($k >= 499){ //批量发单聊消息 最大数500个 +// //结束整个循环 +// break; +// } +// } +// $content = [ +// 'type' => 1, +// 'roomID' => $room_id, +// 'content' => '您关注的用户' . $FromUserInfo['nickname'] . '正在直播,快去围观吧!', +// ]; +// model('Tencent')->batchsendmsg($remind_user,json_encode($content)); +// } $reslut = db::name('vs_room_pit_apply')->where(['user_id' => $user_id, 'room_id' => $room_id, 'status' => 0])->delete(); if($reslut){ $count = db::name('vs_room_pit_apply')->where(['room_id' => $room_id,'status' => 0])->count(); @@ -171,6 +183,16 @@ class RoomPit extends Model model('Chat')->sendMsg(1022,$room_id,$text); }else{ model('Chat')->sendMsg(1004,$room_id,$text); + //查看此房间是否处于pk中 + $is_pk = db::name('vs_room_pk')->where(['room_id_a' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_b') ?? 0; + if(!$is_pk){ + $is_pk = db::name('vs_room_pk')->where(['room_id_b' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_a') ?? 0; + } + if($is_pk > 0){ + //如果此房间是pk中,则推送给pk中房间的成员 + $text['is_pk'] = 1; + model('Chat')->sendMsg(1004,$room_id,$text); + } } return ['code' => 1, 'msg' => '下麦成功', 'data' => null]; @@ -270,6 +292,16 @@ class RoomPit extends Model $text['from_pit_number'] = $pit_infos['pit_number']; $text['to_pit_number'] = $pit_number; model('Chat')->sendMsg(1039,$room_id,$text); + //查看此房间是否处于pk中 + $is_pk = db::name('vs_room_pk')->where(['room_id_a' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_b') ?? 0; + if(!$is_pk){ + $is_pk = db::name('vs_room_pk')->where(['room_id_b' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_a') ?? 0; + } + if($is_pk > 0){ + //如果此房间是pk中,则推送给pk中房间的成员 + $text['is_pk'] = 1; + model('Chat')->sendMsg(1039,$room_id,$text); + } return ['code' => 1, 'msg' => '上麦成功', 'data' => null]; }else{ $ompit = $this->OnPit($user_id,$room_id,$pit_number);//用户上了这个房间的几号麦位