kknongchang_2506/app/Module/Game/Logics/LandTemp.php

<?php

namespace App\Module\Game\Logics;

use App\Module\Farm\Events\LandCreatedEvent;
use App\Module\Farm\Events\LandStatusChangedEvent;
use App\Module\Farm\Events\LandUpgradedEvent;
use App\Module\Farm\Services\LandService;
use App\Module\Game\Dtos\LandChangeTempDto;
use App\Module\Game\Dtos\LandStatusTempDto;
use Illuminate\Support\Facades\Log;
use UCore\Helper\Cache;

/**
 * 土地临时数据逻辑类
 *
 * 负责处理土地相关事件的临时数据存储逻辑，包括：
 * 1. 将土地创建数据临时存储
 * 2. 将土地升级数据临时存储
 * 3. 将土地状态变更数据临时存储
 * 4. 按照用户进行存储
 * 5. 同一土地多次变更进行数据覆盖
 */
class LandTemp
{
    /**
     * 临时数据键前缀 - 土地变更
     */
    const TEMP_KEY_CHANGED_PREFIX = 'game:land:changed:';

    /**
     * 临时数据键前缀 - 土地状态变更
     */
    const TEMP_KEY_STATUS_PREFIX = 'game:land:status:';

    /**
     * 临时数据过期时间（秒）
     */
    const TEMP_TTL = 3600; // 1小时

    /**
     * 处理土地创建事件
     *
     * @param LandCreatedEvent $event 土地创建事件
     * @return void
     */
    public static function handleLandCreated(LandCreatedEvent $event): void
    {
        try {
            // 获取土地信息
            $land = LandService::getLandById($event->landId);
            if (!$land) {
                Log::error('处理土地创建事件失败：土地不存在', [
                    'user_id' => $event->userId,
                    'land_id' => $event->landId,
                ]);
                return;
            }

            // 构建临时数据键，按用户ID进行存储
            $tempKey = self::TEMP_KEY_CHANGED_PREFIX . $event->userId;

            // 获取当前用户的土地变更临时数据
            $userLandsTemp = Cache::get($tempKey, []);

            // 构建土地变更数据
            $landData = [
                'land_id' => $event->landId,
                'position' => $land->position,
                'old_type' => 0, // 新创建的土地，旧类型为0
                'new_type' => $land->land_type,
                'updated_at' => time(),
            ];

            // 使用土地ID作为键，实现同一土地多次变更的数据覆盖
            $userLandsTemp[$event->landId] = $landData;

            // 将更新后的数据存回临时存储
            Cache::put($tempKey, $userLandsTemp, self::TEMP_TTL);

            Log::info('土地创建数据已临时存储', [
                'user_id' => $event->userId,
                'land_id' => $event->landId,
                'position' => $land->position,
                'land_type' => $land->land_type,
            ]);
        } catch (\Exception $e) {
            Log::error('土地创建数据临时存储失败', [
                'error' => $e->getMessage(),
                'user_id' => $event->userId,
                'land_id' => $event->landId,
            ]);
        }
    }

    /**
     * 处理土地升级事件
     *
     * @param LandUpgradedEvent $event 土地升级事件
     * @return void
     */
    public static function handleLandUpgraded(LandUpgradedEvent $event): void
    {
        try {
            // 获取土地信息
            $land = LandService::getLandById($event->landId);
            if (!$land) {
                Log::error('处理土地升级事件失败：土地不存在', [
                    'user_id' => $event->userId,
                    'land_id' => $event->landId,
                ]);
                return;
            }

            // 构建临时数据键，按用户ID进行存储
            $tempKey = self::TEMP_KEY_CHANGED_PREFIX . $event->userId;

            // 获取当前用户的土地变更临时数据
            $userLandsTemp = Cache::get($tempKey, []);

            // 构建土地变更数据
            $landData = [
                'land_id' => $event->landId,
                'position' => $land->position,
                'old_type' => $event->oldType,
                'new_type' => $event->newType,
                'updated_at' => time(),
            ];

            // 使用土地ID作为键，实现同一土地多次变更的数据覆盖
            $userLandsTemp[$event->landId] = $landData;

            // 将更新后的数据存回临时存储
            Cache::put($tempKey, $userLandsTemp, self::TEMP_TTL);

            Log::info('土地升级数据已临时存储', [
                'user_id' => $event->userId,
                'land_id' => $event->landId,
                'old_type' => $event->oldType,
                'new_type' => $event->newType,
            ]);
        } catch (\Exception $e) {
            Log::error('土地升级数据临时存储失败', [
                'error' => $e->getMessage(),
                'user_id' => $event->userId,
                'land_id' => $event->landId,
            ]);
        }
    }

    /**
     * 处理土地状态变更事件
     *
     * @param LandStatusChangedEvent $event 土地状态变更事件
     * @return void
     */
    public static function handleLandStatusChanged(LandStatusChangedEvent $event): void
    {
        try {
            // 获取土地信息
            $land = LandService::getLandById($event->landId);
            if (!$land) {
                Log::error('处理土地状态变更事件失败：土地不存在', [
                    'user_id' => $event->userId,
                    'land_id' => $event->landId,
                ]);
                return;
            }

            // 构建临时数据键，按用户ID进行存储
            $tempKey = self::TEMP_KEY_STATUS_PREFIX . $event->userId;

            // 获取当前用户的土地状态变更临时数据
            $userLandsStatusTemp = Cache::get($tempKey, []);

            // 获取土地上的作物ID（如果有）
            $cropId = null;
            if ($land->crop) {
                $cropId = $land->crop->id;
            }

            // 构建土地状态变更数据
            $statusData = [
                'land_id' => $event->landId,
                'position' => $land->position,
                'land_type' => $land->land_type,
                'old_status' => $event->oldStatus,
                'new_status' => $event->newStatus,
                'crop_id' => $cropId,
                'updated_at' => time(),
            ];

            // 使用土地ID作为键，实现同一土地多次变更的数据覆盖
            $userLandsStatusTemp[$event->landId] = $statusData;

            // 将更新后的数据存回临时存储
            Cache::put($tempKey, $userLandsStatusTemp, self::TEMP_TTL);

            Log::info('土地状态变更数据已临时存储', [
                'user_id' => $event->userId,
                'land_id' => $event->landId,
                'old_status' => $event->oldStatus,
                'new_status' => $event->newStatus,
            ]);
        } catch (\Exception $e) {
            Log::error('土地状态变更数据临时存储失败', [
                'error' => $e->getMessage(),
                'user_id' => $event->userId,
                'land_id' => $event->landId,
            ]);
        }
    }

    /**
     * 获取用户的土地变更临时数据
     *
     * @param int $userId 用户ID
     * @return array 用户的土地变更数据
     */
    public static function getUserLandChanges(int $userId): array
    {
        $tempKey = self::TEMP_KEY_CHANGED_PREFIX . $userId;
        $cachedData = Cache::get($tempKey, []);

        return LandChangeTempDto::fromCache($cachedData);
    }

    /**
     * 获取用户特定土地的变更临时数据
     *
     * @param int $userId 用户ID
     * @param int $landId 土地ID
     * @return LandChangeTempDto|null 土地变更数据，不存在时返回null
     */
    public static function getUserLandChange(int $userId, int $landId): ?LandChangeTempDto
    {
        $userLandChanges = self::getUserLandChanges($userId);
        return $userLandChanges[$landId] ?? null;
    }

    /**
     * 获取用户的土地状态变更临时数据
     *
     * @param int $userId 用户ID
     * @return array 用户的土地状态变更数据
     */
    public static function getUserLandStatusChanges(int $userId): array
    {
        $tempKey = self::TEMP_KEY_STATUS_PREFIX . $userId;
        $cachedData = Cache::get($tempKey, []);

        return LandStatusTempDto::fromCache($cachedData);
    }

    /**
     * 获取用户特定土地的状态变更临时数据
     *
     * @param int $userId 用户ID
     * @param int $landId 土地ID
     * @return LandStatusTempDto|null 土地状态变更数据，不存在时返回null
     */
    public static function getUserLandStatusChange(int $userId, int $landId): ?LandStatusTempDto
    {
        $userLandStatusChanges = self::getUserLandStatusChanges($userId);
        return $userLandStatusChanges[$landId] ?? null;
    }

    /**
     * 清除用户的土地变更临时数据
     *
     * @param int $userId 用户ID
     * @return void
     */
    public static function clearUserLandChanges(int $userId): void
    {
        $tempKey = self::TEMP_KEY_CHANGED_PREFIX . $userId;
        Cache::put($tempKey, [], 0);
    }

    /**
     * 清除用户的土地状态变更临时数据
     *
     * @param int $userId 用户ID
     * @return void
     */
    public static function clearUserLandStatusChanges(int $userId): void
    {
        $tempKey = self::TEMP_KEY_STATUS_PREFIX . $userId;
        Cache::put($tempKey, [], 0);
    }

    /**
     * 清除用户的所有土地临时数据
     *
     * @param int $userId 用户ID
     * @return void
     */
    public static function clearUserAllLandTemp(int $userId): void
    {
        self::clearUserLandChanges($userId);
        self::clearUserLandStatusChanges($userId);
    }
}