盲盒转盘礼物推送

This commit is contained in:
2025-10-24 22:11:59 +08:00
parent a2533669bc
commit eb75b0d097

View File

@@ -91,7 +91,7 @@ class BlindBoxTurntableGift extends Model
$FromUserInfo['chat_bubble'] = model('Decorate')->user_decorate_detail($blind_box_turntable['user_id'],9);//聊天气泡 $FromUserInfo['chat_bubble'] = model('Decorate')->user_decorate_detail($blind_box_turntable['user_id'],9);//聊天气泡
$user_nickname = $FromUserInfo['nickname']; $user_nickname = $FromUserInfo['nickname'];
$userGiftMap = []; $userGiftMap = [];
$giftCount = []; $ToUserInfo = [];
foreach ($blind_box_turntable_log as $key => $value) { foreach ($blind_box_turntable_log as $key => $value) {
$ToUserInfo = Db::name('user')->where(['id' => $value['gift_user_id']])->field('id as user_id,nickname,avatar,sex')->find(); $ToUserInfo = Db::name('user')->where(['id' => $value['gift_user_id']])->field('id as user_id,nickname,avatar,sex')->find();
$draw_gift = Db::name('vs_gift')->where(['gid'=>$value['gift_id']])->find(); $draw_gift = Db::name('vs_gift')->where(['gid'=>$value['gift_id']])->find();
@@ -117,19 +117,12 @@ class BlindBoxTurntableGift extends Model
]; ];
} }
$userGiftMap[$userId]['gifts'][] = [ $userGiftMap[$userId]['gifts'][] = [
'gift_id' => $draw_gift['gid'],
'gift_name' => $draw_gift['gift_name'], 'gift_name' => $draw_gift['gift_name'],
'count' => $value['count'], 'count' => $value['count'],
'play_image' => $draw_gift['play_image'] 'play_image' => $draw_gift['play_image'],
'base_image' => $draw_gift['base_image']
]; ];
// 统计相同礼物的数量
if (isset($giftCount[$value['gift_id']])) {
$giftCount[$value['gift_id']]['count']++;
} else {
$giftCount[$value['gift_id']] = [
'gift_info' => $draw_gift,
'count' => 1
];
}
} }
// 为每个用户单独推送消息 // 为每个用户单独推送消息
@@ -140,8 +133,15 @@ class BlindBoxTurntableGift extends Model
// 构建用户专属文本消息,接收者名字只出现一次 // 构建用户专属文本消息,接收者名字只出现一次
$userTextMessage = $user_nickname . ' 送给 ' . $userInfo['nickname']; $userTextMessage = $user_nickname . ' 送给 ' . $userInfo['nickname'];
// 添加该用户收到的所有礼物 // 添加该用户收到的所有礼物
$giftCount = [];
foreach ($gifts as $gift) { foreach ($gifts as $gift) {
$userTextMessage .= ' 盲盒转盘礼物 ' . $gift['gift_name'].' x ' .$gift['count']; $userTextMessage .= ' 盲盒转盘礼物 ' . $gift['gift_name'].' x ' .$gift['count'];
// 统计相同礼物的数量
$giftCount[] = [
'gift_info' => $gift,
'count' => $gift['count']
];
} }
$userInfo['icon'][0] = model('UserData')->user_wealth_icon($userInfo['user_id']); $userInfo['icon'][0] = model('UserData')->user_wealth_icon($userInfo['user_id']);
@@ -157,16 +157,15 @@ class BlindBoxTurntableGift extends Model
// 聊天室推送系统消息给每个用户 // 聊天室推送系统消息给每个用户
model('Chat')->sendMsg(1038,$room_id,$userText); model('Chat')->sendMsg(1038,$room_id,$userText);
}
// 循环推送每个礼物的特效消息 foreach ($giftCount as $giftData) {
foreach ($giftCount as $giftId => $giftData) {
$gift_inf = $giftData['gift_info']; $gift_inf = $giftData['gift_info'];
$count = $giftData['count']; $count = $giftData['count'];
// 推送礼物特效消息 // 推送礼物特效消息
$effectData = [ $effectData = [
'FromUserInfo' => $FromUserInfo, 'FromUserInfo' => $FromUserInfo,
'ToUserInfo' => $ToUserInfo, 'ToUserInfo' => $userInfo,
'GiftInfo' => $gift_inf, 'GiftInfo' => $gift_inf,
'gift_num' => $count, 'gift_num' => $count,
'text' => null 'text' => null
@@ -175,6 +174,9 @@ class BlindBoxTurntableGift extends Model
// 聊天室推送礼物特效消息 // 聊天室推送礼物特效消息
model('Chat')->sendMsg(1005,$room_id,$effectData); model('Chat')->sendMsg(1005,$room_id,$effectData);
} }
}
// 循环推送每个礼物的特效消息
$roomtype = Db::name('vs_room')->where(['id' => $room_id])->value('type_id'); $roomtype = Db::name('vs_room')->where(['id' => $room_id])->value('type_id');
if($roomtype == 6){ if($roomtype == 6){
@@ -198,7 +200,7 @@ class BlindBoxTurntableGift extends Model
db::name('vs_blind_box_turntable_log')->where('id', $send_id)->update(['is_sued' => 1, 'updatetime' => time()]); db::name('vs_blind_box_turntable_log')->where('id', $send_id)->update(['is_sued' => 1, 'updatetime' => time()]);
return ['code' => 1, 'msg' => '成功', 'data' => null]; return ['code' => 1, 'msg' => '成功', 'data' => null];
} catch (\Exception $e) { } catch (\Exception $e) {
return ['code' => 0, 'msg' => "网络请求错误,请重试!", 'data' => null]; return ['code' => 0, 'msg' => "网络请求错误,请重试!".$e->getMessage(), 'data' => null];
} }
} }