392 lines
15 KiB
PHP
392 lines
15 KiB
PHP
<?php
|
||
|
||
/**
|
||
* 文件功能：AI小班长自动参与百家乐下注
|
||
*
|
||
* 在每局百家乐开启时延迟调度执行：
|
||
* 1. 检查是否存在连输休息惩罚（1小时）
|
||
* 2. 检查可用金币，确保留存底金
|
||
* 3. 调用 AI 接口预测路单走势决定下注方向（AI 不可用时回退本地决策）
|
||
* 4. 提交下注
|
||
*
|
||
* @author ChatRoom Laravel
|
||
*
|
||
* @version 1.0.0
|
||
*/
|
||
|
||
namespace App\Jobs;
|
||
|
||
use App\Enums\CurrencySource;
|
||
use App\Events\MessageSent;
|
||
use App\Models\BaccaratBet;
|
||
use App\Models\BaccaratRound;
|
||
use App\Models\GameConfig;
|
||
use App\Models\Sysparam;
|
||
use App\Models\User;
|
||
use App\Services\BaccaratPredictionService;
|
||
use App\Services\ChatStateService;
|
||
use App\Services\UserCurrencyService;
|
||
use Illuminate\Bus\Queueable;
|
||
use Illuminate\Contracts\Queue\ShouldQueue;
|
||
use Illuminate\Foundation\Bus\Dispatchable;
|
||
use Illuminate\Queue\InteractsWithQueue;
|
||
use Illuminate\Queue\SerializesModels;
|
||
use Illuminate\Support\Facades\DB;
|
||
use Illuminate\Support\Facades\Log;
|
||
use Illuminate\Support\Facades\Redis;
|
||
|
||
class AiBaccaratBetJob implements ShouldQueue
|
||
{
|
||
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||
|
||
public function __construct(
|
||
public readonly BaccaratRound $round,
|
||
) {}
|
||
|
||
public function handle(UserCurrencyService $currency): void
|
||
{
|
||
// 1. 检查总开关与游戏开关
|
||
if (Sysparam::getValue('chatbot_enabled', '0') !== '1' || ! GameConfig::isEnabled('baccarat')) {
|
||
return;
|
||
}
|
||
|
||
$user = User::where('username', 'AI小班长')->first();
|
||
if (! $user) {
|
||
return;
|
||
}
|
||
|
||
$chatState = app(ChatStateService::class);
|
||
|
||
// 2. 资金管理：自动存款与领取补偿
|
||
$this->manageFinances($user, $chatState);
|
||
|
||
$round = $this->round->fresh();
|
||
if (! $round || ! $round->isBettingOpen()) {
|
||
return;
|
||
}
|
||
|
||
// 3. 检查连输惩罚超时
|
||
if (Redis::exists('ai_baccarat_timeout')) {
|
||
return; // 还在禁赛期
|
||
}
|
||
|
||
// 4. 检查余额与限额
|
||
$config = GameConfig::forGame('baccarat')?->params ?? [];
|
||
$minBet = (int) ($config['min_bet'] ?? 100);
|
||
$maxBet = (int) ($config['max_bet'] ?? 50000);
|
||
|
||
// 至少保留 100万 金币底仓（确保有充足资金参与多轮下注）
|
||
$reserve = 1000000;
|
||
$availableGold = ($user->jjb ?? 0) - $reserve;
|
||
if ($availableGold < $minBet) {
|
||
return; // 资金不足以支撑最小下注
|
||
}
|
||
|
||
// 5. 获取近期路单和 AI 历史下注
|
||
$recentResults = BaccaratRound::query()
|
||
->where('status', 'settled')
|
||
->orderByDesc('id')
|
||
->limit(20)
|
||
->pluck('result')
|
||
->toArray();
|
||
|
||
$historicalBets = BaccaratBet::query()
|
||
->join('baccarat_rounds', 'baccarat_bets.round_id', '=', 'baccarat_rounds.id')
|
||
->where('baccarat_bets.user_id', $user->id)
|
||
->where('baccarat_rounds.status', 'settled')
|
||
->orderByDesc('baccarat_rounds.id')
|
||
->limit(10)
|
||
->select('baccarat_bets.*')
|
||
->get()
|
||
->map(function ($bet) {
|
||
return [
|
||
'round_id' => $bet->round_id,
|
||
'bet_type' => $bet->bet_type,
|
||
'amount' => $bet->amount,
|
||
'profit' => $bet->profit ?? 0,
|
||
];
|
||
})
|
||
->toArray();
|
||
|
||
// 5. 调用 AI 接口出具统筹策略
|
||
$predictionService = app(BaccaratPredictionService::class);
|
||
$context = [
|
||
'recent_results' => $recentResults,
|
||
'available_gold' => $availableGold,
|
||
'historical_bets' => $historicalBets,
|
||
];
|
||
|
||
$aiPrediction = $predictionService->predict($context);
|
||
$decisionSource = 'ai';
|
||
|
||
$betType = 'pass';
|
||
$amount = 0;
|
||
$reason = '';
|
||
|
||
if ($aiPrediction) {
|
||
$betType = $aiPrediction['action'];
|
||
$percent = $aiPrediction['percentage'];
|
||
$reason = $aiPrediction['reason'];
|
||
|
||
// 限定单局最高下注不超过可用金额的 5% 以防止 AI "乱梭哈" 破产
|
||
$percent = min(5, max(0, $percent));
|
||
|
||
if ($betType !== 'pass') {
|
||
$amount = (int) round($availableGold * ($percent / 100.0));
|
||
$amount = max($minBet, min($amount, $maxBet));
|
||
if ($amount > $user->jjb) {
|
||
$amount = $user->jjb;
|
||
}
|
||
}
|
||
} else {
|
||
// AI 不可用时回退本地路单决策（保底逻辑）
|
||
$decisionSource = 'local';
|
||
$bigCount = count(array_filter($recentResults, fn (string $r) => $r === 'big'));
|
||
$smallCount = count(array_filter($recentResults, fn (string $r) => $r === 'small'));
|
||
|
||
$strategy = rand(1, 100);
|
||
if ($strategy <= 10) {
|
||
$betType = 'triple'; // 10% 概率博豹子
|
||
} elseif ($bigCount > $smallCount) {
|
||
$betType = rand(1, 100) <= 70 ? 'big' : 'small';
|
||
} elseif ($smallCount > $bigCount) {
|
||
$betType = rand(1, 100) <= 70 ? 'small' : 'big';
|
||
} else {
|
||
$betType = rand(0, 10) === 0 ? 'pass' : (rand(0, 1) ? 'big' : 'small');
|
||
}
|
||
|
||
if ($betType !== 'pass') {
|
||
$percent = rand(2, 5) / 100.0;
|
||
$amount = (int) round($availableGold * $percent);
|
||
$amount = max($minBet, min($amount, $maxBet));
|
||
}
|
||
}
|
||
|
||
// 记录 AI 小班长本次决策日志
|
||
$labelMap = ['big' => '大', 'small' => '小', 'triple' => '豹子', 'pass' => '观望'];
|
||
Log::channel('daily')->info('AI小班长百家乐决策', [
|
||
'round_id' => $round->id,
|
||
'decision_source' => $decisionSource === 'ai' ? 'AI接口策略' : '本地路单兜底',
|
||
'action' => $labelMap[$betType] ?? $betType,
|
||
'bet_amount' => $amount,
|
||
'reason' => $reason,
|
||
'roadmap_20' => implode('→', array_map(fn (string $r) => $labelMap[$r] ?? $r, array_reverse($recentResults))),
|
||
]);
|
||
|
||
if ($betType === 'pass') {
|
||
// 观望时仅广播，不执行真正的金币扣除下注逻辑
|
||
$this->broadcastPassMessage($user, $round->room_id ?? 1, $reason);
|
||
|
||
return;
|
||
}
|
||
|
||
// 二次校验，防止大模型接口调用太慢导致下注时该局已关闭
|
||
$round->refresh();
|
||
if (! $round->isBettingOpen()) {
|
||
Log::channel('daily')->warning("AI小班长百家乐下注拦截：由于AI接口思考耗时，这局#{$round->id}投注已截止。");
|
||
|
||
return;
|
||
}
|
||
|
||
// 6. 执行下注 (同 BaccaratController::bet 逻辑)
|
||
DB::transaction(function () use ($user, $round, $betType, $amount, $currency) {
|
||
// 幂等：同一局只能下一注
|
||
$existing = BaccaratBet::query()
|
||
->where('round_id', $round->id)
|
||
->where('user_id', $user->id)
|
||
->lockForUpdate()
|
||
->exists();
|
||
|
||
if ($existing) {
|
||
return;
|
||
}
|
||
|
||
// 扣除金币
|
||
$currency->change(
|
||
$user,
|
||
'gold',
|
||
-$amount,
|
||
CurrencySource::BACCARAT_BET,
|
||
"AI小班长百家乐 #{$round->id} 押 ".match ($betType) {
|
||
'big' => '大', 'small' => '小', default => '豹子'
|
||
},
|
||
);
|
||
|
||
// 写入下注记录
|
||
BaccaratBet::create([
|
||
'round_id' => $round->id,
|
||
'user_id' => $user->id,
|
||
'bet_type' => $betType,
|
||
'amount' => $amount,
|
||
'status' => 'pending',
|
||
]);
|
||
|
||
// 更新局次汇总统计
|
||
$field = 'total_bet_'.$betType;
|
||
$countField = 'bet_count_'.$betType;
|
||
$round->increment($field, $amount);
|
||
$round->increment($countField);
|
||
$round->increment('bet_count');
|
||
|
||
// 广播各选项的最新押注人数（让前台看到 AI 下注的人数增长）
|
||
event(new \App\Events\BaccaratPoolUpdated($round));
|
||
});
|
||
|
||
// 下注成功后，在聊天室发送一条普通聊天消息告知大家
|
||
$this->broadcastBetMessage($user, $round->room_id ?? 1, $betType, $amount, $decisionSource);
|
||
}
|
||
|
||
/**
|
||
* 广播 AI小班长的观望文案到聊天室
|
||
*
|
||
* @param User $user AI小班长用户
|
||
* @param int $roomId 聊天室 ID
|
||
* @param string $reason 观望理由
|
||
*/
|
||
private function broadcastPassMessage(User $user, int $roomId, string $reason): void
|
||
{
|
||
if (empty($reason)) {
|
||
$reason = '风大雨大，保本最大，这把我决定观望一下！';
|
||
}
|
||
|
||
$chatState = app(ChatStateService::class);
|
||
$content = "🌟 🎲 【百家乐】 <b>{$user->username}</b> 本局选择挂机观望：✨ <br/><span style='color:#666;'>[🤖 策略分析] {$reason}</span>";
|
||
|
||
$msg = [
|
||
'id' => $chatState->nextMessageId($roomId),
|
||
'room_id' => $roomId,
|
||
'from_user' => '系统传音',
|
||
'to_user' => '大家',
|
||
'content' => $content,
|
||
'is_secret' => false,
|
||
'font_color' => '#d97706',
|
||
'action' => '',
|
||
'sent_at' => now()->toDateTimeString(),
|
||
];
|
||
|
||
$chatState->pushMessage($roomId, $msg);
|
||
broadcast(new MessageSent($roomId, $msg));
|
||
SaveMessageJob::dispatch($msg);
|
||
}
|
||
|
||
/**
|
||
* 广播 AI小班长本次下注情况到聊天室
|
||
*
|
||
* 以普通聊天消息形式发送，发送对象为大家。
|
||
*
|
||
* @param User $user AI小班长用户对象
|
||
* @param int $roomId 目标房间 ID
|
||
* @param string $betType 下注方向：big|small|triple
|
||
* @param int $amount 下注金额
|
||
* @param string $decisionSource 决策来源：ai | local
|
||
*/
|
||
private function broadcastBetMessage(
|
||
User $user,
|
||
int $roomId,
|
||
string $betType,
|
||
int $amount,
|
||
string $decisionSource,
|
||
): void {
|
||
$chatState = app(ChatStateService::class);
|
||
$labelMap = ['big' => '大', 'small' => '小', 'triple' => '豹子'];
|
||
$label = $labelMap[$betType] ?? $betType;
|
||
|
||
$sourceText = $decisionSource === 'ai' ? '🤖 经过深度算法预测，本局我看好：' : '📊 观察了下最近的路单，这把我觉得是：';
|
||
$content = "🌟 🎲 【百家乐】 <b>{$user->username}</b> 已下注：<span style='color:#1d4ed8;font-weight:bold;'>{$label}</span> (".number_format($amount)." 金币)<br/><span style='color:#666;'>{$sourceText} {$label}！</span>";
|
||
|
||
$msg = [
|
||
'id' => $chatState->nextMessageId($roomId),
|
||
'room_id' => $roomId,
|
||
'from_user' => '系统传音',
|
||
'to_user' => '大家',
|
||
'content' => $content,
|
||
'is_secret' => false,
|
||
'font_color' => '#8b5cf6',
|
||
'action' => '动态播报',
|
||
'sent_at' => now()->toDateTimeString(),
|
||
];
|
||
$chatState->pushMessage($roomId, $msg);
|
||
broadcast(new MessageSent($roomId, $msg));
|
||
SaveMessageJob::dispatch($msg);
|
||
}
|
||
|
||
/**
|
||
* AI 资金管理逻辑：自动存款、领取买单补偿
|
||
*/
|
||
private function manageFinances(User $user, ChatStateService $chatState): void
|
||
{
|
||
// 1. 检查是否有“买单”活动补偿可领取 (jjb 较低时优先领取)
|
||
if ($user->jjb < 20000) {
|
||
$lossCoverService = app(\App\Services\BaccaratLossCoverService::class);
|
||
$pendingEvents = \App\Models\BaccaratLossCoverEvent::where('status', 'claimable')->get();
|
||
foreach ($pendingEvents as $event) {
|
||
$record = \App\Models\BaccaratLossCoverRecord::where('event_id', $event->id)
|
||
->where('user_id', $user->id)
|
||
->where('claim_status', 'pending')
|
||
->first();
|
||
|
||
if ($record && $record->compensation_amount > 0) {
|
||
$lossCoverService->claim($event, $user);
|
||
Log::info("AI小班长自动领取活动补偿: Event #{$event->id}, Amount: {$record->compensation_amount}");
|
||
}
|
||
}
|
||
}
|
||
|
||
// 2. 自动存款逻辑：长期目标 1000万 / 3000万
|
||
$bankTarget1 = 10000000;
|
||
$bankTarget2 = 30000000;
|
||
$currentBank = (int) $user->bank_jjb;
|
||
|
||
// 如果手上金币超过 10万，且存款未达 3000万，则进行存款
|
||
if ($user->jjb > 100000 && $currentBank < $bankTarget2) {
|
||
$depositAmount = $user->jjb - 50000; // 留 5万在手上作为本金
|
||
|
||
// 如果存款快到目标了，按需存入
|
||
if ($currentBank < $bankTarget1 && ($currentBank + $depositAmount) > $bankTarget1) {
|
||
$depositAmount = $bankTarget1 - $currentBank;
|
||
}
|
||
|
||
DB::transaction(function () use ($user, $depositAmount, $currentBank, $bankTarget1, $bankTarget2, $chatState) {
|
||
$user->decrement('jjb', $depositAmount);
|
||
$user->increment('bank_jjb', $depositAmount);
|
||
$newBank = $user->bank_jjb;
|
||
|
||
\App\Models\BankLog::create([
|
||
'user_id' => $user->id,
|
||
'type' => 'deposit',
|
||
'amount' => $depositAmount,
|
||
'balance_after' => $newBank,
|
||
]);
|
||
|
||
// 达成阶段性目标时大声宣布
|
||
$milestone = 0;
|
||
if ($currentBank < $bankTarget1 && $newBank >= $bankTarget1) {
|
||
$milestone = 1000; // 1000万
|
||
} elseif ($currentBank < $bankTarget2 && $newBank >= $bankTarget2) {
|
||
$milestone = 3000; // 3000万
|
||
}
|
||
|
||
if ($milestone > 0) {
|
||
$content = "🏆 🎉 <b>【全站公告】</b> 恭喜 <b>AI小班长</b> 达成理财新高度！<br/>他在银行的存款已成功突破 <span style='color:#e11d48;font-weight:bold;'>{$milestone}万</span> 金币！💰✨";
|
||
$msg = [
|
||
'id' => $chatState->nextMessageId(1),
|
||
'room_id' => 1,
|
||
'from_user' => '系统传音',
|
||
'to_user' => '大家',
|
||
'content' => $content,
|
||
'is_secret' => false,
|
||
'font_color' => '#f59e0b',
|
||
'action' => '大声宣告',
|
||
'sent_at' => now()->toDateTimeString(),
|
||
];
|
||
$chatState->pushMessage(1, $msg);
|
||
broadcast(new MessageSent(1, $msg));
|
||
SaveMessageJob::dispatch($msg);
|
||
}
|
||
});
|
||
|
||
Log::info("AI小班长自动存款: Amount: {$depositAmount}, New Bank Balance: {$user->bank_jjb}");
|
||
}
|
||
}
|
||
}
|