mojiahui/webman-buildadmin
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.优化中奖事件统一使用bet.win订阅中奖消息

Browse Source
This commit is contained in:
zhenhui
2026-05-26 15:19:21 +08:00
parent 5cbb7ea485
commit d8d03662ed
2 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/common/service/GameBetSettleService.php
View File

@@ -180,7 +180,15 @@ final class GameBetSettleService
'update_time' => $now,
]);
GameHotDataCoordinator::afterUserCommitted($userId);
GameWebSocketPayloadHelper::publishUserStreak($userId, $next);
$periodNo = isset($aggregateByUser[$userId]['period_no']) ? (string) $aggregateByUser[$userId]['period_no'] : '';
GameWebSocketPayloadHelper::publishUserStreak($userId, $next, [
// 明确标记本期结算结果，客户端可直接判断“当前用户是否中奖”。
'is_win' => $hadWin,
'period_id' => $recordId,
'period_no' => $periodNo,
'result_number' => $resultNumber,
'settled_at' => $now,
]);
}
$jackpotHits = [];

11
app/common/service/GameWebSocketPayloadHelper.php
View File

@@ -66,12 +66,19 @@ final class GameWebSocketPayloadHelper
return array_merge($payload, self::userStreakData($userId, $currentStreak));
}
public static function publishUserStreak(int $userId, ?int $currentStreak = null): void
/**
* @param array<string, mixed> $extra
*/
public static function publishUserStreak(int $userId, ?int $currentStreak = null, array $extra = []): void
{
if ($userId <= 0) {
return;
}
GameWebSocketEventBus::publish(self::TOPIC_USER_STREAK, self::userStreakData($userId, $currentStreak));
$payload = self::userStreakData($userId, $currentStreak);
if ($extra !== []) {
$payload = array_merge($payload, $extra);
}
GameWebSocketEventBus::publish(self::TOPIC_USER_STREAK, $payload);
}
/**