Files
chatroom/app/Jobs/OpenLotteryIssueJob.php
lkddi 27371fe321 新增:双色球彩票系统后端基础(阶段一)
📦 数据库
  - lottery_issues(期次表)
  - lottery_tickets(购票记录表)
  - lottery_pool_logs(奖池流水表,透明展示)

🔩 核心组件
  - LotteryIssue / LotteryTicket / LotteryPoolLog 完整 Model
  - LotteryService:购票/机选/开奖/奖池派发/滚存/超级期预热/公屏广播
  - LotteryController:current/buy/quickPick/history/my 五个接口
  - DrawLotteryJob(每日定时开奖)/ OpenLotteryIssueJob(初始化首期)

💰 货币日志
  - CurrencySource 新增 LOTTERY_BUY / LOTTERY_WIN
  - 所有金币变动均通过 UserCurrencyService::change() 记录流水

🗓️ 调度器
  - 每分钟检查停售/开奖时机
  - 每日 18:00 超级期预热广播

🔧 配置
  - GameConfigSeeder 追加 lottery 默认配置(默认关闭)
  - /games/enabled 接口追加 lottery 开关状态
  - 新增 /lottery/* 路由组(auth 保护)
2026-03-04 15:38:02 +08:00

70 lines
1.8 KiB
PHP

<?php
/**
* 文件功能:双色球开新期队列任务
*
* 在系统初始化时或管理员手动触发时使用,
* 创建第一期并设置好截止/开奖时间。
* 正常情况下,开奖后由 LotteryService::openNextIssue() 自动创建下一期。
*
* @author ChatRoom Laravel
*
* @version 1.0.0
*/
namespace App\Jobs;
use App\Models\GameConfig;
use App\Models\LotteryIssue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
class OpenLotteryIssueJob implements ShouldQueue
{
use Queueable;
/**
* 最大重试次数。
*/
public int $tries = 1;
/**
* 执行开新期逻辑(仅在无当前期时创建)。
*/
public function handle(): void
{
if (! GameConfig::isEnabled('lottery')) {
return;
}
// 已有进行中的期次则跳过
if (LotteryIssue::currentIssue()) {
return;
}
$config = GameConfig::forGame('lottery')?->params ?? [];
$drawHour = (int) ($config['draw_hour'] ?? 20);
$drawMinute = (int) ($config['draw_minute'] ?? 0);
$stopMinutes = (int) ($config['stop_sell_minutes'] ?? 2);
// 今天的开奖时间;若当前时间已过今日开奖时间,则用明天
$drawAt = now()->setTime($drawHour, $drawMinute, 0);
if ($drawAt->isPast()) {
$drawAt->addDay();
}
$closeAt = $drawAt->copy()->subMinutes($stopMinutes);
LotteryIssue::create([
'issue_no' => LotteryIssue::nextIssueNo(),
'status' => 'open',
'pool_amount' => 0,
'carry_amount' => 0,
'is_super_issue' => false,
'no_winner_streak' => 0,
'sell_closes_at' => $closeAt,
'draw_at' => $drawAt,
]);
}
}