kknongchang_2506/app/Module/UrsPromotion/Services/UrsUserMappingService.php

<?php

namespace App\Module\UrsPromotion\Services;

use App\Module\UrsPromotion\Dtos\UrsUserMappingDto;
use App\Module\UrsPromotion\Models\UrsUserMapping;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

/**
 * URS用户映射服务
 *
 * 管理URS用户ID与农场用户ID的映射关系
 */
class UrsUserMappingService
{
    /**
     * 创建用户映射关系（用户进入农场时调用）
     *
     * @param int $ursUserId URS用户ID
     * @param int $farmUserId 农场用户ID
     * @return UrsUserMappingDto
     * @throws \Exception
     */
    public static function createMapping(int $ursUserId, int $farmUserId): UrsUserMappingDto
    {
        try {
            DB::beginTransaction();
            
            // 检查是否已存在映射
            $existingMapping = UrsUserMapping::where('urs_user_id', $ursUserId)->first();
            if ($existingMapping) {
                if ($existingMapping->user_id === $farmUserId) {
                    // 相同映射，直接返回
                    DB::rollBack();
                    return UrsUserMappingDto::fromModel($existingMapping);
                } else {
                    // 不同映射，抛出异常
                    throw new \Exception("URS用户ID {$ursUserId} 已映射到农场用户ID {$existingMapping->user_id}");
                }
            }
            
            // 检查农场用户ID是否已被映射
            $existingFarmMapping = UrsUserMapping::where('user_id', $farmUserId)->first();
            if ($existingFarmMapping) {
                throw new \Exception("农场用户ID {$farmUserId} 已映射到URS用户ID {$existingFarmMapping->urs_user_id}");
            }
            
            // 创建新映射
            $mapping = UrsUserMapping::create([
                'urs_user_id' => $ursUserId,
                'user_id' => $farmUserId,
                'mapping_time' => now(),
                'status' => UrsUserMapping::STATUS_VALID,
            ]);
            
            DB::commit();
            
            Log::info('URS用户映射创建成功', [
                'urs_user_id' => $ursUserId,
                'farm_user_id' => $farmUserId,
                'mapping_id' => $mapping->id
            ]);

            return UrsUserMappingDto::fromModel($mapping);
            
        } catch (\Exception $e) {
            DB::rollBack();
            Log::error('URS用户映射创建失败', [
                'urs_user_id' => $ursUserId,
                'farm_user_id' => $farmUserId,
                'error' => $e->getMessage()
            ]);
            throw $e;
        }
    }
    
    /**
     * 根据URS用户ID获取农场用户ID
     *
     * @param int $ursUserId URS用户ID
     * @return int|null 农场用户ID，如果未找到返回null
     */
    public static function getFarmUserId(int $ursUserId): ?int
    {
        return UrsUserMapping::getFarmUserIdByUrsUserId($ursUserId);
    }

    /**
     * 根据农场用户ID获取URS用户ID
     *
     * @param int $farmUserId 农场用户ID
     * @return int|null URS用户ID，如果未找到返回null
     */
    public static function getUrsUserId(int $farmUserId): ?int
    {
        return UrsUserMapping::getUrsUserIdByFarmUserId($farmUserId);
    }

    /**
     * 批量获取URS用户ID对应的农场用户ID
     *
     * @param array $ursUserIds URS用户ID数组
     * @return array 映射关系数组 [urs_user_id => farm_user_id]
     */
    public static function batchGetFarmUserIds(array $ursUserIds): array
    {
        return UrsUserMapping::getFarmUserIdsByUrsUserIds($ursUserIds);
    }

    /**
     * 批量获取农场用户ID对应的URS用户ID
     *
     * @param array $farmUserIds 农场用户ID数组
     * @return array 映射关系数组 [farm_user_id => urs_user_id]
     */
    public static function batchGetUrsUserIds(array $farmUserIds): array
    {
        return UrsUserMapping::getUrsUserIdsByFarmUserIds($farmUserIds);
    }

    /**
     * 检查URS用户是否已进入农场
     *
     * @param int $ursUserId URS用户ID
     * @return bool
     */
    public static function hasEnteredFarm(int $ursUserId): bool
    {
        return UrsUserMapping::hasEnteredFarm($ursUserId);
    }

    /**
     * 获取已进入农场的URS用户ID列表
     *
     * @param array $ursUserIds URS用户ID数组
     * @return array 已进入农场的URS用户ID数组
     */
    public static function getEnteredFarmUsers(array $ursUserIds): array
    {
        return UrsUserMapping::getEnteredFarmUrsUserIds($ursUserIds);
    }
    
    /**
     * 禁用用户映射关系
     *
     * @param int $ursUserId URS用户ID
     * @return bool
     */
    public static function disableMapping(int $ursUserId): bool
    {
        try {
            $mapping = UrsUserMapping::where('urs_user_id', $ursUserId)->first();
            if (!$mapping) {
                return false;
            }
            
            $mapping->status = UrsUserMapping::STATUS_INVALID;
            $mapping->save();
            
            Log::info('URS用户映射已禁用', [
                'urs_user_id' => $ursUserId,
                'mapping_id' => $mapping->id
            ]);
            
            return true;
            
        } catch (\Exception $e) {
            Log::error('URS用户映射禁用失败', [
                'urs_user_id' => $ursUserId,
                'error' => $e->getMessage()
            ]);
            return false;
        }
    }
    
    /**
     * 启用用户映射关系
     *
     * @param int $ursUserId URS用户ID
     * @return bool
     */
    public static function enableMapping(int $ursUserId): bool
    {
        try {
            $mapping = UrsUserMapping::where('urs_user_id', $ursUserId)->first();
            if (!$mapping) {
                return false;
            }
            
            $mapping->status = UrsUserMapping::STATUS_VALID;
            $mapping->save();
            
            Log::info('URS用户映射已启用', [
                'urs_user_id' => $ursUserId,
                'mapping_id' => $mapping->id
            ]);
            
            return true;
            
        } catch (\Exception $e) {
            Log::error('URS用户映射启用失败', [
                'urs_user_id' => $ursUserId,
                'error' => $e->getMessage()
            ]);
            return false;
        }
    }
    
    /**
     * 获取映射统计信息
     *
     * @return array
     */
    public static function getMappingStats(): array
    {
        return [
            'total_mappings' => UrsUserMapping::count(),
            'valid_mappings' => UrsUserMapping::where('status', UrsUserMapping::STATUS_VALID)->count(),
            'invalid_mappings' => UrsUserMapping::where('status', UrsUserMapping::STATUS_INVALID)->count(),
            'today_mappings' => UrsUserMapping::whereDate('created_at', today())->count(),
        ];
    }
    
    /**
     * 获取用户映射详情
     *
     * @param int $ursUserId URS用户ID
     * @return UrsUserMappingDto|null
     */
    public static function getMappingDetail(int $ursUserId): ?UrsUserMappingDto
    {
        $mapping = UrsUserMapping::where('urs_user_id', $ursUserId)->first();
        if (!$mapping) {
            return null;
        }

        return UrsUserMappingDto::fromModel($mapping);
    }
}