|
|
@@ -1,274 +0,0 @@
|
|
|
-<?php
|
|
|
-
|
|
|
-namespace App\Module\GameItems\Logics;
|
|
|
-
|
|
|
-use App\Module\GameItems\Dtos\ItemChestOpenCostDto;
|
|
|
-use App\Module\GameItems\Enums\CHEST_COST_TYPE;
|
|
|
-use App\Module\GameItems\Models\ItemChestOpenCost;
|
|
|
-use App\Module\GameItems\Repositorys\ItemChestOpenCostRepository;
|
|
|
-use App\Module\User\Services\UserCurrencyService;
|
|
|
-use Illuminate\Support\Facades\Log;
|
|
|
-
|
|
|
-/**
|
|
|
- * 宝箱开启消耗逻辑类
|
|
|
- */
|
|
|
-class ChestOpenCostLogic
|
|
|
-{
|
|
|
- /**
|
|
|
- * @var ItemChestOpenCostRepository
|
|
|
- */
|
|
|
- protected $costRepository;
|
|
|
-
|
|
|
- /**
|
|
|
- * @var ItemLogic
|
|
|
- */
|
|
|
- protected $itemLogic;
|
|
|
-
|
|
|
- /**
|
|
|
- * 构造函数
|
|
|
- *
|
|
|
- * @param ItemChestOpenCostRepository $costRepository
|
|
|
- * @param ItemLogic $itemLogic
|
|
|
- */
|
|
|
- public function __construct(
|
|
|
- ItemChestOpenCostRepository $costRepository,
|
|
|
- ItemLogic $itemLogic
|
|
|
- ) {
|
|
|
- $this->costRepository = $costRepository;
|
|
|
- $this->itemLogic = $itemLogic;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 获取宝箱的所有激活消耗配置
|
|
|
- *
|
|
|
- * @param int $chestId 宝箱ID
|
|
|
- * @return ItemChestOpenCostDto[]
|
|
|
- */
|
|
|
- public function getActiveChestCosts(int $chestId): array
|
|
|
- {
|
|
|
- $costs = $this->costRepository->getActiveByChestId($chestId);
|
|
|
- $result = [];
|
|
|
-
|
|
|
- foreach ($costs as $cost) {
|
|
|
- $result[] = ItemChestOpenCostDto::fromModel($cost, true);
|
|
|
- }
|
|
|
-
|
|
|
- return $result;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 验证用户是否有足够的资源支付宝箱开启消耗
|
|
|
- *
|
|
|
- * @param int $userId 用户ID
|
|
|
- * @param int $chestId 宝箱ID
|
|
|
- * @param int $quantity 开启数量
|
|
|
- * @return array [bool $isValid, string $message, array $costs]
|
|
|
- */
|
|
|
- public function validateChestOpenCosts(int $userId, int $chestId, int $quantity = 1): array
|
|
|
- {
|
|
|
- $costs = $this->costRepository->getActiveByChestId($chestId);
|
|
|
-
|
|
|
- if ($costs->isEmpty()) {
|
|
|
- return [true, '无需额外消耗', []];
|
|
|
- }
|
|
|
-
|
|
|
- $costDetails = [];
|
|
|
-
|
|
|
- foreach ($costs as $cost) {
|
|
|
- $totalQuantity = $cost->cost_quantity * $quantity;
|
|
|
- $costDetails[] = [
|
|
|
- 'type' => $cost->cost_type,
|
|
|
- 'id' => $cost->cost_id,
|
|
|
- 'quantity' => $totalQuantity,
|
|
|
- 'model' => $cost
|
|
|
- ];
|
|
|
-
|
|
|
- // 验证用户是否有足够的资源
|
|
|
- switch ($cost->cost_type) {
|
|
|
- case CHEST_COST_TYPE::ITEM->value:
|
|
|
- // 验证物品数量
|
|
|
- $userItem = $this->itemLogic->getUserItem($userId, $cost->cost_id);
|
|
|
- if (!$userItem || $userItem->quantity < $totalQuantity) {
|
|
|
- return [
|
|
|
- false,
|
|
|
- "物品不足,需要 {$totalQuantity} 个 " . ($cost->costItem->name ?? "ID:{$cost->cost_id}"),
|
|
|
- $costDetails
|
|
|
- ];
|
|
|
- }
|
|
|
- break;
|
|
|
-
|
|
|
- case CHEST_COST_TYPE::CURRENCY->value:
|
|
|
- // 验证货币数量
|
|
|
- $userCurrency = UserCurrencyService::getUserCurrency($userId, $cost->cost_id);
|
|
|
- if ($userCurrency < $totalQuantity) {
|
|
|
- return [
|
|
|
- false,
|
|
|
- "货币不足,需要 {$totalQuantity} 个 ID:{$cost->cost_id}",
|
|
|
- $costDetails
|
|
|
- ];
|
|
|
- }
|
|
|
- break;
|
|
|
-
|
|
|
- case CHEST_COST_TYPE::OTHER_RESOURCE->value:
|
|
|
- // 验证其他资源,根据实际情况实现
|
|
|
- // 这里仅作为示例,实际实现可能需要调用其他模块的服务
|
|
|
- $hasEnoughResource = true; // 假设有足够资源
|
|
|
- if (!$hasEnoughResource) {
|
|
|
- return [
|
|
|
- false,
|
|
|
- "资源不足,需要 {$totalQuantity} 个 ID:{$cost->cost_id}",
|
|
|
- $costDetails
|
|
|
- ];
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return [true, '验证通过', $costDetails];
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 扣除宝箱开启所需的消耗资源
|
|
|
- *
|
|
|
- * @param int $userId 用户ID
|
|
|
- * @param array $costDetails 消耗详情数组
|
|
|
- * @param string $reason 消耗原因
|
|
|
- * @return bool 是否成功扣除
|
|
|
- */
|
|
|
- public function deductChestOpenCosts(int $userId, array $costDetails, string $reason = '开启宝箱'): bool
|
|
|
- {
|
|
|
- // 检查事务是否已开启
|
|
|
- \UCore\Db\Helper::check_tr();
|
|
|
-
|
|
|
- try {
|
|
|
-
|
|
|
- foreach ($costDetails as $detail) {
|
|
|
- switch ($detail['type']) {
|
|
|
- case CHEST_COST_TYPE::ITEM->value:
|
|
|
- // 扣除物品
|
|
|
- $result = $this->itemLogic->consumeUserItem(
|
|
|
- $userId,
|
|
|
- $detail['id'],
|
|
|
- $detail['quantity'],
|
|
|
- $reason
|
|
|
- );
|
|
|
-
|
|
|
- if (!$result) {
|
|
|
- throw new \Exception("扣除物品失败: ID {$detail['id']}");
|
|
|
- }
|
|
|
- break;
|
|
|
-
|
|
|
- case CHEST_COST_TYPE::CURRENCY->value:
|
|
|
- // 扣除货币
|
|
|
- $result = UserCurrencyService::deductCurrency(
|
|
|
- $userId,
|
|
|
- $detail['id'],
|
|
|
- $detail['quantity'],
|
|
|
- $reason
|
|
|
- );
|
|
|
-
|
|
|
- if (!$result) {
|
|
|
- throw new \Exception("扣除货币失败: ID {$detail['id']}");
|
|
|
- }
|
|
|
- break;
|
|
|
-
|
|
|
- case CHEST_COST_TYPE::OTHER_RESOURCE->value:
|
|
|
- // 扣除其他资源,根据实际情况实现
|
|
|
- // 这里仅作为示例,实际实现可能需要调用其他模块的服务
|
|
|
- $deductSuccess = true; // 假设扣除成功
|
|
|
-
|
|
|
- if (!$deductSuccess) {
|
|
|
- throw new \Exception("扣除资源失败: ID {$detail['id']}");
|
|
|
- }
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return true;
|
|
|
- } catch (\Exception $e) {
|
|
|
- Log::error('扣除宝箱开启消耗失败: ' . $e->getMessage(), [
|
|
|
- 'user_id' => $userId,
|
|
|
- 'cost_details' => $costDetails,
|
|
|
- 'exception' => $e
|
|
|
- ]);
|
|
|
- return false;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 创建宝箱开启消耗配置
|
|
|
- *
|
|
|
- * @param ItemChestOpenCostDto $dto
|
|
|
- * @return ItemChestOpenCost|null
|
|
|
- */
|
|
|
- public function createChestOpenCost(ItemChestOpenCostDto $dto): ?ItemChestOpenCost
|
|
|
- {
|
|
|
- try {
|
|
|
- return $this->costRepository->create([
|
|
|
- 'chest_id' => $dto->chestId,
|
|
|
- 'cost_type' => $dto->costType,
|
|
|
- 'cost_id' => $dto->costId,
|
|
|
- 'cost_quantity' => $dto->costQuantity,
|
|
|
- 'is_active' => $dto->isActive,
|
|
|
- ]);
|
|
|
- } catch (\Exception $e) {
|
|
|
- Log::error('创建宝箱开启消耗配置失败: ' . $e->getMessage(), [
|
|
|
- 'dto' => $dto->toArray(),
|
|
|
- 'exception' => $e
|
|
|
- ]);
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 更新宝箱开启消耗配置
|
|
|
- *
|
|
|
- * @param int $id
|
|
|
- * @param ItemChestOpenCostDto $dto
|
|
|
- * @return bool
|
|
|
- */
|
|
|
- public function updateChestOpenCost(int $id, ItemChestOpenCostDto $dto): bool
|
|
|
- {
|
|
|
- try {
|
|
|
- $cost = $this->costRepository->find($id);
|
|
|
-
|
|
|
- if (!$cost) {
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- return $this->costRepository->update($id, [
|
|
|
- 'chest_id' => $dto->chestId,
|
|
|
- 'cost_type' => $dto->costType,
|
|
|
- 'cost_id' => $dto->costId,
|
|
|
- 'cost_quantity' => $dto->costQuantity,
|
|
|
- 'is_active' => $dto->isActive,
|
|
|
- ]);
|
|
|
- } catch (\Exception $e) {
|
|
|
- Log::error('更新宝箱开启消耗配置失败: ' . $e->getMessage(), [
|
|
|
- 'id' => $id,
|
|
|
- 'dto' => $dto->toArray(),
|
|
|
- 'exception' => $e
|
|
|
- ]);
|
|
|
- return false;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 删除宝箱开启消耗配置
|
|
|
- *
|
|
|
- * @param int $id
|
|
|
- * @return bool
|
|
|
- */
|
|
|
- public function deleteChestOpenCost(int $id): bool
|
|
|
- {
|
|
|
- try {
|
|
|
- return $this->costRepository->delete($id);
|
|
|
- } catch (\Exception $e) {
|
|
|
- Log::error('删除宝箱开启消耗配置失败: ' . $e->getMessage(), [
|
|
|
- 'id' => $id,
|
|
|
- 'exception' => $e
|
|
|
- ]);
|
|
|
- return false;
|
|
|
- }
|
|
|
- }
|
|
|
-}
|