125 lines
4.5 KiB
PHP
125 lines
4.5 KiB
PHP
<?php
|
||
declare(strict_types=1);
|
||
|
||
namespace app\api\controller;
|
||
|
||
use support\Log;
|
||
use support\Request;
|
||
use support\Response;
|
||
use app\api\logic\GameLogic;
|
||
use app\api\logic\PlayStartLogic;
|
||
use app\api\util\ReturnCode;
|
||
use app\dice\model\play_record\DicePlayRecord;
|
||
use app\dice\model\player\DicePlayer;
|
||
use app\dice\model\reward_config\DiceRewardConfig;
|
||
use plugin\saiadmin\basic\OpenController;
|
||
use plugin\saiadmin\exception\ApiException;
|
||
|
||
/**
|
||
* 游戏相关接口（购买抽奖券等）
|
||
*/
|
||
class GameController extends OpenController
|
||
{
|
||
/**
|
||
* 购买抽奖券
|
||
* POST /api/game/buyLotteryTickets
|
||
* header: token（由 TokenMiddleware 注入 request->player_id）
|
||
* body: count = 1 | 5 | 10（1次/100coin, 5次/500coin, 10次/1000coin）
|
||
*/
|
||
public function buyLotteryTickets(Request $request): Response
|
||
{
|
||
$userId = (int) ($request->player_id ?? 0);
|
||
$count = (int) $request->post('count', 0);
|
||
if (!in_array($count, [1, 5, 10], true)) {
|
||
return $this->fail('购买抽奖券错误', ReturnCode::PARAMS_ERROR);
|
||
}
|
||
|
||
try {
|
||
$logic = new GameLogic();
|
||
$data = $logic->buyLotteryTickets($userId, $count);
|
||
return $this->success($data);
|
||
} catch (ApiException $e) {
|
||
$msg = $e->getMessage();
|
||
if ($msg === '平台币不足') {
|
||
$player = DicePlayer::find($userId);
|
||
$coin = $player ? (float) $player->coin : 0;
|
||
return $this->success(['coin' => $coin], $msg);
|
||
}
|
||
return $this->fail($msg, ReturnCode::BUSINESS_ERROR);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取彩金池（中奖配置表）
|
||
* GET /api/game/lotteryPool
|
||
* header: token
|
||
* 返回 DiceRewardConfig 列表（彩金池/中奖配置）
|
||
*/
|
||
public function lotteryPool(Request $request): Response
|
||
{
|
||
$list = DiceRewardConfig::order('id', 'asc')->select()->toArray();
|
||
return $this->success($list);
|
||
}
|
||
|
||
/**
|
||
* 开始游戏（抽奖一局）
|
||
* POST /api/game/playStart
|
||
* header: token（由 TokenMiddleware 注入 request->player_id）
|
||
* body: direction 必传，0=无 1=中奖
|
||
*/
|
||
public function playStart(Request $request): Response
|
||
{
|
||
$userId = (int) ($request->player_id ?? 0);
|
||
$direction = $request->post('direction');
|
||
if (empty($direction)) {
|
||
Log::error('传递的参数为direction = '.$direction);
|
||
return $this->fail('请传递 direction 参数', ReturnCode::PARAMS_ERROR);
|
||
}
|
||
$direction = (int) $direction;
|
||
if (!in_array($direction, [0, 1], true)) {
|
||
return $this->fail('direction 必须为 0 或 1', ReturnCode::PARAMS_ERROR);
|
||
}
|
||
|
||
$player = DicePlayer::find($userId);
|
||
if (!$player) {
|
||
return $this->fail('用户不存在', ReturnCode::NOT_FOUND);
|
||
}
|
||
$minEv = (float) DiceRewardConfig::min('real_ev');
|
||
$minCoin = abs($minEv + 100);
|
||
$coin = (float) $player->coin;
|
||
if ($coin < $minCoin) {
|
||
return $this->success([], '当前玩家余额小于DiceRewardConfigMin.real_ev+100无法继续游戏');
|
||
}
|
||
|
||
try {
|
||
$logic = new PlayStartLogic();
|
||
$data = $logic->run($userId, $direction);
|
||
return $this->success($data);
|
||
} catch (ApiException $e) {
|
||
return $this->fail($e->getMessage(), ReturnCode::BUSINESS_ERROR);
|
||
} catch (\Throwable $e) {
|
||
$timeoutRecord = null;
|
||
try {
|
||
$timeoutRecord = DicePlayRecord::create([
|
||
'player_id' => $userId,
|
||
'lottery_config_id' => 0,
|
||
'lottery_type' => 0,
|
||
'win_coin' => 0,
|
||
'direction' => $direction,
|
||
'reward_config_id' => 0,
|
||
'start_index' => 0,
|
||
'target_index' => 0,
|
||
'roll_array' => '[]',
|
||
'status' => PlayStartLogic::RECORD_STATUS_TIMEOUT,
|
||
]);
|
||
} catch (\Exception $e) {
|
||
$timeout_message = $e->getMessage();
|
||
Log::error("游玩记录写入超时: ". $e->getMessage());
|
||
}
|
||
|
||
$payload = $timeoutRecord ? ['record' => $timeoutRecord->toArray()] : [];
|
||
return $this->success($payload, '服务超时，'.$timeout_message ?? '没有原因');
|
||
}
|
||
}
|
||
}
|