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

1.ws优化订阅，修复中大奖没有推送

Browse Source
This commit is contained in:
zhenhui
2026-05-27 10:40:55 +08:00
parent 8f5ba977a4
commit a96aa0fb41
3 changed files with 241 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

118
app/common/service/GameLiveService.php
View File

@@ -33,6 +33,11 @@ final class GameLiveService
/** period.tick 边界帧去重（finished / void 每期只推一次），TTL 兼顾跨进程与跨期重启 */
private const TICK_BOUNDARY_DEDUP_KEY_PREFIX = 'dfw:v1:ws:tick:boundary:';
private const TICK_BOUNDARY_DEDUP_TTL_SECONDS = 300;
/** 开奖/派彩阶段公共推送去重（与 bet.win 分离；recover 补偿路径也会写） */
private const PERIOD_OPENED_NOTIFY_DEDUP_PREFIX = 'dfw:v1:ws:period_opened:';
private const PERIOD_PAYOUT_NOTIFY_DEDUP_PREFIX = 'dfw:v1:ws:period_payout:';
private const PERIOD_DRAW_NOTIFY_DEDUP_TTL = 86400;
private const KEY_PERIOD_SECONDS = 'period_seconds';
private const KEY_BET_SECONDS = 'bet_seconds';
private const KEY_PAYOUT_SECONDS = 'payout_seconds';
@@ -156,13 +161,23 @@ final class GameLiveService
return;
}
$periodNo = is_string($row['period_no'] ?? null) ? (string) $row['period_no'] : '';
$drawMode = filter_var($row['draw_mode'] ?? 0, FILTER_VALIDATE_INT);
GameBetSettleService::publishSettlementWinsAfterCommit(
$settleOut,
$recordId,
is_string($row['period_no'] ?? null) ? (string) $row['period_no'] : '',
$periodNo,
(int) $resultNumber
);
GameBetSettleService::ensurePeriodBetWinNotifications($recordId, (int) $resultNumber);
self::ensurePeriodDrawNotifications(
$recordId,
$periodNo,
(int) $resultNumber,
$drawMode === false ? 0 : $drawMode,
$payoutUntil > 0 ? $payoutUntil : $now + self::getPayoutGraceSeconds(),
$now
);
GameHotDataCoordinator::afterGameRecordCommitted($recordId);
self::publishSnapshot(null);
@@ -750,6 +765,16 @@ final class GameLiveService
$payoutUntil,
$now
): void {
// 开奖号已写入 DB：先推 period.opened / period.payout，再结算（避免 settle 异常导致永远收不到开奖推送）
self::ensurePeriodDrawNotifications($rid, $periodNo, $finalNumber, $drawMode, $payoutUntil, $now);
$settleOut = [
'jackpot_hits' => [],
'bet_wins' => [],
'user_streak_events' => [],
'wallet_events' => [],
'settled_order_count' => 0,
];
try {
$settleOut = GameBetSettleService::settleBetsForDraw($rid, $finalNumber);
} catch (Throwable $e) {
@@ -757,8 +782,6 @@ final class GameLiveService
'record_id' => $rid,
'error' => $e->getMessage(),
]);
return;
}
GameBetSettleService::publishSettlementWinsAfterCommit(
$settleOut,
@@ -766,13 +789,12 @@ final class GameLiveService
$periodNo,
$finalNumber
);
GameBetSettleService::ensurePeriodBetWinNotifications($rid, $finalNumber);
GameHotDataCoordinator::afterGameRecordCommitted($rid);
try {
GameRecordStatService::refreshForRecordId($rid);
} catch (Throwable) {
}
self::publishPublicPeriodOpened($periodNo, $finalNumber, $drawMode, $now);
self::publishPublicPeriodPayout($rid, $periodNo, $finalNumber, $payoutUntil, $now);
$jackpotHits = is_array($settleOut['jackpot_hits'] ?? null) ? $settleOut['jackpot_hits'] : [];
GameWebSocketEventBus::publish('admin.live.opened', [
'period_id' => $rid,
@@ -1550,6 +1572,92 @@ final class GameLiveService
]);
}
/**
* 开奖后推送 period.opened + period.payout（每期各至多一次；入队成功后才写 dedup）。
* recover / drawResult 补偿路径均会调用，避免仅 recover 结算时漏推 period.opened。
*/
public static function ensurePeriodDrawNotifications(
int $periodId,
string $periodNo,
int $resultNumber,
int $drawMode,
int $payoutUntil,
int $openTime
): void {
if ($periodId <= 0 || $periodNo === '' || $resultNumber < 1) {
return;
}
$openedKey = self::PERIOD_OPENED_NOTIFY_DEDUP_PREFIX . $periodId;
$payoutKey = self::PERIOD_PAYOUT_NOTIFY_DEDUP_PREFIX . $periodId;
if (!self::hasPeriodNotifyMarked($openedKey)) {
$ok = GameWebSocketEventBus::publish(self::EVT_PERIOD_OPENED, [
'period_no' => $periodNo,
'result_number' => $resultNumber,
'draw_mode' => $drawMode,
'open_time' => $openTime,
]);
if ($ok) {
self::markPeriodNotifyOnce($openedKey);
Log::channel('ws')->info('period.opened published', [
'period_id' => $periodId,
'period_no' => $periodNo,
'result_number' => $resultNumber,
]);
} else {
Log::channel('ws')->warning('period.opened publish failed', [
'period_id' => $periodId,
'period_no' => $periodNo,
]);
}
}
if (!self::hasPeriodNotifyMarked($payoutKey)) {
$grace = self::getPayoutGraceSeconds();
$remaining = max(0, $payoutUntil - $openTime);
$ok = GameWebSocketEventBus::publish(self::EVT_PERIOD_PAYOUT, [
'period_id' => $periodId,
'period_no' => $periodNo,
'result_number' => $resultNumber,
'payout_until' => $payoutUntil,
'payout_seconds' => $grace,
'payout_remaining_seconds' => $remaining,
'server_time' => $openTime,
]);
if ($ok) {
self::markPeriodNotifyOnce($payoutKey);
Log::channel('ws')->info('period.payout published', [
'period_id' => $periodId,
'period_no' => $periodNo,
]);
} else {
Log::channel('ws')->warning('period.payout publish failed', [
'period_id' => $periodId,
'period_no' => $periodNo,
]);
}
}
}
private static function hasPeriodNotifyMarked(string $key): bool
{
try {
$existing = Redis::get($key);
return $existing !== false && $existing !== null && $existing !== '';
} catch (Throwable) {
return false;
}
}
private static function markPeriodNotifyOnce(string $key): void
{
try {
Redis::setEx($key, self::PERIOD_DRAW_NOTIFY_DEDUP_TTL, '1');
} catch (Throwable) {
}
}
private static function publishPublicPeriodOpened(string $periodNo, int $resultNumber, int $drawMode, int $openTime): void
{
GameWebSocketEventBus::publish(self::EVT_PERIOD_OPENED, [