|
|
@@ -0,0 +1,528 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace App\Module\GameItems\Logics;
|
|
|
+
|
|
|
+use App\Module\GameItems\Enums\FREEZE_ACTION_TYPE;
|
|
|
+use App\Module\GameItems\Enums\FREEZE_REASON_TYPE;
|
|
|
+use App\Module\GameItems\Models\Item;
|
|
|
+use App\Module\GameItems\Models\ItemFreezeLog;
|
|
|
+use App\Module\GameItems\Models\ItemUser;
|
|
|
+use Exception;
|
|
|
+use Illuminate\Support\Collection;
|
|
|
+use Illuminate\Support\Facades\Log;
|
|
|
+use UCore\Db\Helper;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 物品冻结逻辑类
|
|
|
+ *
|
|
|
+ * 处理物品冻结和解冻的核心业务逻辑,包括:
|
|
|
+ * - 统一属性物品的冻结/解冻(拆堆模式)
|
|
|
+ * - 单独属性物品的冻结/解冻
|
|
|
+ * - 冻结状态验证和数量查询
|
|
|
+ * - 批量冻结操作
|
|
|
+ */
|
|
|
+class ItemFreeze
|
|
|
+{
|
|
|
+ /**
|
|
|
+ * 冻结统一属性物品(拆堆模式)
|
|
|
+ *
|
|
|
+ * 实现逻辑:
|
|
|
+ * 1. 查找用户可用的物品堆叠(is_frozen=false)
|
|
|
+ * 2. 从可用堆叠中扣除冻结数量
|
|
|
+ * 3. 创建新的冻结堆叠记录(is_frozen=true)
|
|
|
+ * 4. 记录冻结日志
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param int $itemId 物品ID
|
|
|
+ * @param int $quantity 冻结数量
|
|
|
+ * @param FREEZE_REASON_TYPE $reason 冻结原因
|
|
|
+ * @param int|null $sourceId 来源ID
|
|
|
+ * @param string|null $sourceType 来源类型
|
|
|
+ * @param int|null $operatorId 操作员ID
|
|
|
+ * @return array 冻结结果
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ public static function freezeNormalItem(
|
|
|
+ int $userId,
|
|
|
+ int $itemId,
|
|
|
+ int $quantity,
|
|
|
+ FREEZE_REASON_TYPE $reason,
|
|
|
+ ?int $sourceId = null,
|
|
|
+ ?string $sourceType = null,
|
|
|
+ ?int $operatorId = null
|
|
|
+ ): array {
|
|
|
+ // 检查事务
|
|
|
+ Helper::check_tr();
|
|
|
+
|
|
|
+ // 验证冻结操作的合法性
|
|
|
+ if (!self::validateFreezeOperation($userId, $itemId, $quantity)) {
|
|
|
+ throw new Exception("用户 {$userId} 的物品 {$itemId} 可用数量不足,无法冻结 {$quantity} 个");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取用户可用的物品堆叠(按过期时间排序,优先冻结即将过期的)
|
|
|
+ $availableItems = ItemUser::where('user_id', $userId)
|
|
|
+ ->where('item_id', $itemId)
|
|
|
+ ->where('is_frozen', false)
|
|
|
+ ->whereNull('instance_id')
|
|
|
+ ->where('quantity', '>', 0)
|
|
|
+ ->orderBy('expire_at')
|
|
|
+ ->get();
|
|
|
+
|
|
|
+ $remainingQuantity = $quantity;
|
|
|
+ $frozenItems = [];
|
|
|
+
|
|
|
+ foreach ($availableItems as $userItem) {
|
|
|
+ if ($remainingQuantity <= 0) {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ $availableQuantity = $userItem->quantity;
|
|
|
+ $freezeQuantity = min($remainingQuantity, $availableQuantity);
|
|
|
+
|
|
|
+ // 创建冻结日志
|
|
|
+ $freezeLog = ItemFreezeLog::createLog(
|
|
|
+ $userId,
|
|
|
+ $itemId,
|
|
|
+ null,
|
|
|
+ $freezeQuantity,
|
|
|
+ FREEZE_ACTION_TYPE::FREEZE,
|
|
|
+ $reason->getName($reason->value),
|
|
|
+ $sourceId,
|
|
|
+ $sourceType,
|
|
|
+ $operatorId
|
|
|
+ );
|
|
|
+
|
|
|
+ if ($freezeQuantity == $availableQuantity) {
|
|
|
+ // 全部冻结,直接标记为冻结状态
|
|
|
+ $userItem->is_frozen = true;
|
|
|
+ $userItem->frozen_log_id = $freezeLog->id;
|
|
|
+ $userItem->save();
|
|
|
+
|
|
|
+ $frozenItems[] = [
|
|
|
+ 'user_item_id' => $userItem->id,
|
|
|
+ 'quantity' => $freezeQuantity,
|
|
|
+ 'freeze_log_id' => $freezeLog->id,
|
|
|
+ ];
|
|
|
+ } else {
|
|
|
+ // 部分冻结,需要拆堆
|
|
|
+ // 减少原堆叠数量
|
|
|
+ $userItem->quantity = $availableQuantity - $freezeQuantity;
|
|
|
+ $userItem->save();
|
|
|
+
|
|
|
+ // 创建新的冻结堆叠
|
|
|
+ $frozenItem = new ItemUser([
|
|
|
+ 'user_id' => $userId,
|
|
|
+ 'item_id' => $itemId,
|
|
|
+ 'instance_id' => null,
|
|
|
+ 'quantity' => $freezeQuantity,
|
|
|
+ 'expire_at' => $userItem->expire_at,
|
|
|
+ 'is_frozen' => true,
|
|
|
+ 'frozen_log_id' => $freezeLog->id,
|
|
|
+ ]);
|
|
|
+ $frozenItem->save();
|
|
|
+
|
|
|
+ $frozenItems[] = [
|
|
|
+ 'user_item_id' => $frozenItem->id,
|
|
|
+ 'quantity' => $freezeQuantity,
|
|
|
+ 'freeze_log_id' => $freezeLog->id,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ $remainingQuantity -= $freezeQuantity;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($remainingQuantity > 0) {
|
|
|
+ throw new Exception("冻结操作失败,剩余未冻结数量:{$remainingQuantity}");
|
|
|
+ }
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'success' => true,
|
|
|
+ 'user_id' => $userId,
|
|
|
+ 'item_id' => $itemId,
|
|
|
+ 'frozen_quantity' => $quantity,
|
|
|
+ 'frozen_items' => $frozenItems,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 冻结单独属性物品
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param int $itemId 物品ID
|
|
|
+ * @param int $instanceId 物品实例ID
|
|
|
+ * @param FREEZE_REASON_TYPE $reason 冻结原因
|
|
|
+ * @param int|null $sourceId 来源ID
|
|
|
+ * @param string|null $sourceType 来源类型
|
|
|
+ * @param int|null $operatorId 操作员ID
|
|
|
+ * @return array 冻结结果
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ public static function freezeUniqueItem(
|
|
|
+ int $userId,
|
|
|
+ int $itemId,
|
|
|
+ int $instanceId,
|
|
|
+ FREEZE_REASON_TYPE $reason,
|
|
|
+ ?int $sourceId = null,
|
|
|
+ ?string $sourceType = null,
|
|
|
+ ?int $operatorId = null
|
|
|
+ ): array {
|
|
|
+ // 检查事务
|
|
|
+ Helper::check_tr();
|
|
|
+
|
|
|
+ // 查找用户的单独属性物品
|
|
|
+ $userItem = ItemUser::where('user_id', $userId)
|
|
|
+ ->where('item_id', $itemId)
|
|
|
+ ->where('instance_id', $instanceId)
|
|
|
+ ->where('is_frozen', false)
|
|
|
+ ->first();
|
|
|
+
|
|
|
+ if (!$userItem) {
|
|
|
+ throw new Exception("用户 {$userId} 没有可冻结的物品实例 {$instanceId}");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 创建冻结日志
|
|
|
+ $freezeLog = ItemFreezeLog::createLog(
|
|
|
+ $userId,
|
|
|
+ $itemId,
|
|
|
+ $instanceId,
|
|
|
+ 1, // 单独属性物品数量始终为1
|
|
|
+ FREEZE_ACTION_TYPE::FREEZE,
|
|
|
+ $reason->getName($reason->value),
|
|
|
+ $sourceId,
|
|
|
+ $sourceType,
|
|
|
+ $operatorId
|
|
|
+ );
|
|
|
+
|
|
|
+ // 标记为冻结状态
|
|
|
+ $userItem->is_frozen = true;
|
|
|
+ $userItem->frozen_log_id = $freezeLog->id;
|
|
|
+ $userItem->save();
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'success' => true,
|
|
|
+ 'user_id' => $userId,
|
|
|
+ 'item_id' => $itemId,
|
|
|
+ 'instance_id' => $instanceId,
|
|
|
+ 'user_item_id' => $userItem->id,
|
|
|
+ 'freeze_log_id' => $freezeLog->id,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 解冻物品(通过冻结日志ID)
|
|
|
+ *
|
|
|
+ * @param int $freezeLogId 冻结日志ID
|
|
|
+ * @return array 解冻结果
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ public static function unfreezeByLogId(int $freezeLogId): array
|
|
|
+ {
|
|
|
+ // 检查事务
|
|
|
+ Helper::check_tr();
|
|
|
+
|
|
|
+ // 查找冻结日志
|
|
|
+ $freezeLog = ItemFreezeLog::find($freezeLogId);
|
|
|
+ if (!$freezeLog) {
|
|
|
+ throw new Exception("冻结日志 {$freezeLogId} 不存在");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!$freezeLog->isFreeze()) {
|
|
|
+ throw new Exception("日志 {$freezeLogId} 不是冻结操作记录");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查找对应的冻结物品
|
|
|
+ $frozenItem = ItemUser::where('frozen_log_id', $freezeLogId)
|
|
|
+ ->where('is_frozen', true)
|
|
|
+ ->first();
|
|
|
+
|
|
|
+ if (!$frozenItem) {
|
|
|
+ throw new Exception("未找到冻结日志 {$freezeLogId} 对应的冻结物品");
|
|
|
+ }
|
|
|
+
|
|
|
+ // 创建解冻日志
|
|
|
+ $unfreezeLog = ItemFreezeLog::createLog(
|
|
|
+ $frozenItem->user_id,
|
|
|
+ $frozenItem->item_id,
|
|
|
+ $frozenItem->instance_id,
|
|
|
+ $frozenItem->quantity,
|
|
|
+ FREEZE_ACTION_TYPE::UNFREEZE,
|
|
|
+ "解冻操作,原冻结日志ID: {$freezeLogId}",
|
|
|
+ $freezeLog->source_id,
|
|
|
+ $freezeLog->source_type,
|
|
|
+ $freezeLog->operator_id
|
|
|
+ );
|
|
|
+
|
|
|
+ // 解冻物品(保持独立,不合并堆叠)
|
|
|
+ $frozenItem->is_frozen = false;
|
|
|
+ $frozenItem->frozen_log_id = null;
|
|
|
+ $frozenItem->save();
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'success' => true,
|
|
|
+ 'user_id' => $frozenItem->user_id,
|
|
|
+ 'item_id' => $frozenItem->item_id,
|
|
|
+ 'instance_id' => $frozenItem->instance_id,
|
|
|
+ 'unfrozen_quantity' => $frozenItem->quantity,
|
|
|
+ 'user_item_id' => $frozenItem->id,
|
|
|
+ 'unfreeze_log_id' => $unfreezeLog->id,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 检查用户可用物品数量(排除冻结堆叠)
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param int $itemId 物品ID
|
|
|
+ * @param int|null $instanceId 实例ID
|
|
|
+ * @return int 可用数量
|
|
|
+ */
|
|
|
+ public static function getAvailableQuantity(
|
|
|
+ int $userId,
|
|
|
+ int $itemId,
|
|
|
+ ?int $instanceId = null
|
|
|
+ ): int {
|
|
|
+ return ItemUser::getAvailableQuantity($userId, $itemId, $instanceId);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 验证用户是否有足够的可用物品
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param int $itemId 物品ID
|
|
|
+ * @param int $requiredQuantity 需要的数量
|
|
|
+ * @param int|null $instanceId 实例ID
|
|
|
+ * @return bool 是否有足够的可用物品
|
|
|
+ */
|
|
|
+ public static function checkAvailableQuantity(
|
|
|
+ int $userId,
|
|
|
+ int $itemId,
|
|
|
+ int $requiredQuantity,
|
|
|
+ ?int $instanceId = null
|
|
|
+ ): bool {
|
|
|
+ $availableQuantity = self::getAvailableQuantity($userId, $itemId, $instanceId);
|
|
|
+ return $availableQuantity >= $requiredQuantity;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 验证冻结操作的合法性
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param int $itemId 物品ID
|
|
|
+ * @param int $quantity 冻结数量
|
|
|
+ * @param int|null $instanceId 实例ID
|
|
|
+ * @return bool 是否可以冻结
|
|
|
+ */
|
|
|
+ public static function validateFreezeOperation(
|
|
|
+ int $userId,
|
|
|
+ int $itemId,
|
|
|
+ int $quantity,
|
|
|
+ ?int $instanceId = null
|
|
|
+ ): bool {
|
|
|
+ // 检查物品是否存在
|
|
|
+ $item = Item::find($itemId);
|
|
|
+ if (!$item) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 检查数量是否合法
|
|
|
+ if ($quantity <= 0) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 检查可用数量是否足够
|
|
|
+ return self::checkAvailableQuantity($userId, $itemId, $quantity, $instanceId);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 批量冻结物品
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param array $items 物品列表 [['item_id' => 1, 'quantity' => 10], ...]
|
|
|
+ * @param FREEZE_REASON_TYPE $reason 冻结原因
|
|
|
+ * @param int|null $sourceId 来源ID
|
|
|
+ * @param string|null $sourceType 来源类型
|
|
|
+ * @param int|null $operatorId 操作员ID
|
|
|
+ * @return array 冻结结果
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
+ public static function batchFreezeItems(
|
|
|
+ int $userId,
|
|
|
+ array $items,
|
|
|
+ FREEZE_REASON_TYPE $reason,
|
|
|
+ ?int $sourceId = null,
|
|
|
+ ?string $sourceType = null,
|
|
|
+ ?int $operatorId = null
|
|
|
+ ): array {
|
|
|
+ // 检查事务
|
|
|
+ Helper::check_tr();
|
|
|
+
|
|
|
+ $results = [];
|
|
|
+ $errors = [];
|
|
|
+
|
|
|
+ foreach ($items as $itemData) {
|
|
|
+ $itemId = $itemData['item_id'];
|
|
|
+ $quantity = $itemData['quantity'] ?? 1;
|
|
|
+ $instanceId = $itemData['instance_id'] ?? null;
|
|
|
+
|
|
|
+ try {
|
|
|
+ if ($instanceId) {
|
|
|
+ // 单独属性物品
|
|
|
+ $result = self::freezeUniqueItem(
|
|
|
+ $userId,
|
|
|
+ $itemId,
|
|
|
+ $instanceId,
|
|
|
+ $reason,
|
|
|
+ $sourceId,
|
|
|
+ $sourceType,
|
|
|
+ $operatorId
|
|
|
+ );
|
|
|
+ } else {
|
|
|
+ // 统一属性物品
|
|
|
+ $result = self::freezeNormalItem(
|
|
|
+ $userId,
|
|
|
+ $itemId,
|
|
|
+ $quantity,
|
|
|
+ $reason,
|
|
|
+ $sourceId,
|
|
|
+ $sourceType,
|
|
|
+ $operatorId
|
|
|
+ );
|
|
|
+ }
|
|
|
+ $results[] = $result;
|
|
|
+ } catch (Exception $e) {
|
|
|
+ $errors[] = [
|
|
|
+ 'item_id' => $itemId,
|
|
|
+ 'instance_id' => $instanceId,
|
|
|
+ 'quantity' => $quantity,
|
|
|
+ 'error' => $e->getMessage(),
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($errors)) {
|
|
|
+ throw new Exception("批量冻结操作部分失败:" . json_encode($errors, JSON_UNESCAPED_UNICODE));
|
|
|
+ }
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'success' => true,
|
|
|
+ 'user_id' => $userId,
|
|
|
+ 'frozen_items_count' => count($results),
|
|
|
+ 'results' => $results,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 检查冻结物品是否过期并处理
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @return int 处理的过期冻结物品数量
|
|
|
+ */
|
|
|
+ public static function handleExpiredFrozenItems(int $userId): int
|
|
|
+ {
|
|
|
+ // 查找过期的冻结物品
|
|
|
+ $expiredFrozenItems = ItemUser::where('user_id', $userId)
|
|
|
+ ->where('is_frozen', true)
|
|
|
+ ->where('expire_at', '<', now())
|
|
|
+ ->whereNotNull('expire_at')
|
|
|
+ ->get();
|
|
|
+
|
|
|
+ $processedCount = 0;
|
|
|
+
|
|
|
+ foreach ($expiredFrozenItems as $frozenItem) {
|
|
|
+ try {
|
|
|
+ // 先解冻再处理过期
|
|
|
+ if ($frozenItem->frozen_log_id) {
|
|
|
+ self::unfreezeByLogId($frozenItem->frozen_log_id);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 处理过期逻辑(这里可以根据业务需求决定是删除还是其他处理)
|
|
|
+ // 暂时设置数量为0,不删除记录
|
|
|
+ $frozenItem->quantity = 0;
|
|
|
+ $frozenItem->save();
|
|
|
+
|
|
|
+ $processedCount++;
|
|
|
+ } catch (Exception $e) {
|
|
|
+ // 记录错误日志,但不中断处理
|
|
|
+ Log::error("处理过期冻结物品失败", [
|
|
|
+ 'user_id' => $userId,
|
|
|
+ 'item_user_id' => $frozenItem->id,
|
|
|
+ 'error' => $e->getMessage(),
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return $processedCount;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取用户的冻结物品列表
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @param array $filters 过滤条件
|
|
|
+ * @return Collection 冻结物品集合
|
|
|
+ */
|
|
|
+ public static function getFrozenItems(int $userId, array $filters = []): Collection
|
|
|
+ {
|
|
|
+ $query = ItemUser::where('user_id', $userId)
|
|
|
+ ->where('is_frozen', true)
|
|
|
+ ->with(['item', 'instance', 'freezeLog']);
|
|
|
+
|
|
|
+ // 应用过滤条件
|
|
|
+ if (isset($filters['item_id'])) {
|
|
|
+ $query->where('item_id', $filters['item_id']);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($filters['source_type'])) {
|
|
|
+ $query->whereHas('freezeLog', function ($q) use ($filters) {
|
|
|
+ $q->where('source_type', $filters['source_type']);
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($filters['reason'])) {
|
|
|
+ $query->whereHas('freezeLog', function ($q) use ($filters) {
|
|
|
+ $q->where('reason', 'like', '%' . $filters['reason'] . '%');
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+ return $query->get();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取冻结统计信息
|
|
|
+ *
|
|
|
+ * @param int $userId 用户ID
|
|
|
+ * @return array 统计信息
|
|
|
+ */
|
|
|
+ public static function getFreezeStatistics(int $userId): array
|
|
|
+ {
|
|
|
+ $frozenItems = ItemUser::where('user_id', $userId)
|
|
|
+ ->where('is_frozen', true)
|
|
|
+ ->with(['item', 'freezeLog'])
|
|
|
+ ->get();
|
|
|
+
|
|
|
+ $statistics = [
|
|
|
+ 'total_frozen_items' => $frozenItems->count(),
|
|
|
+ 'total_frozen_quantity' => $frozenItems->sum('quantity'),
|
|
|
+ 'frozen_by_reason' => [],
|
|
|
+ 'frozen_by_source_type' => [],
|
|
|
+ ];
|
|
|
+
|
|
|
+ // 按原因分组统计
|
|
|
+ $frozenItems->groupBy('freezeLog.reason')->each(function ($items, $reason) use (&$statistics) {
|
|
|
+ $statistics['frozen_by_reason'][$reason] = [
|
|
|
+ 'count' => $items->count(),
|
|
|
+ 'quantity' => $items->sum('quantity'),
|
|
|
+ ];
|
|
|
+ });
|
|
|
+
|
|
|
+ // 按来源类型分组统计
|
|
|
+ $frozenItems->groupBy('freezeLog.source_type')->each(function ($items, $sourceType) use (&$statistics) {
|
|
|
+ $statistics['frozen_by_source_type'][$sourceType] = [
|
|
|
+ 'count' => $items->count(),
|
|
|
+ 'quantity' => $items->sum('quantity'),
|
|
|
+ ];
|
|
|
+ });
|
|
|
+
|
|
|
+ return $statistics;
|
|
|
+ }
|
|
|
+}
|