YUSHENG/yusheng-php
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

pk对方房间内用户上下麦推送

Browse Source
This commit is contained in:
刘华清
2025-10-28 10:41:41 +08:00
parent 1eeeeb1c7c
commit 96f393ab4f
1 changed files with 49 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
application/api/model/RoomPit.php
View File

@@ -80,24 +80,36 @@ class RoomPit extends Model
$text['pit_number'] = $pit_number; $text['pit_number'] = $pit_number;
//聊天室推送系统消息 //聊天室推送系统消息
model('Chat')->sendMsg(1003,$room_id,$text); model('Chat')->sendMsg(1003,$room_id,$text);
if($pit_number == 9){
//推送消息给设置此用户开播提醒的人 //查看此房间是否处于pk中
$remind_users = db::name('vs_user_live_remind')->where('remind_user_id' , $user_id)->select('user_id'); $is_pk = db::name('vs_room_pk')->where(['room_id_a' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_b') ?? 0;
$remind_user = []; if(!$is_pk){
foreach ($remind_users as $k=>$v){ $is_pk = db::name('vs_room_pk')->where(['room_id_b' => $room_id])->where(['status' => ['in',[2,3,4]]])->value('room_id_a') ?? 0;
$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));
} }
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(); $reslut = db::name('vs_room_pit_apply')->where(['user_id' => $user_id, 'room_id' => $room_id, 'status' => 0])->delete();
if($reslut){ if($reslut){
$count = db::name('vs_room_pit_apply')->where(['room_id' => $room_id,'status' => 0])->count(); $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); model('Chat')->sendMsg(1022,$room_id,$text);
}else{ }else{
model('Chat')->sendMsg(1004,$room_id,$text); 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]; return ['code' => 1, 'msg' => '下麦成功', 'data' => null];
@@ -270,6 +292,16 @@ class RoomPit extends Model
$text['from_pit_number'] = $pit_infos['pit_number']; $text['from_pit_number'] = $pit_infos['pit_number'];
$text['to_pit_number'] = $pit_number; $text['to_pit_number'] = $pit_number;
model('Chat')->sendMsg(1039,$room_id,$text); 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]; return ['code' => 1, 'msg' => '上麦成功', 'data' => null];
}else{ }else{
$ompit = $this->OnPit($user_id,$room_id,$pit_number);//用户上了这个房间的几号麦位 $ompit = $this->OnPit($user_id,$room_id,$pit_number);//用户上了这个房间的几号麦位