kknongchang_2506/app/Module/AppGame/Handler/Public/Login4uHandler.php

<?php

namespace App\Module\AppGame\Handler\Public;

use App\Module\AppGame\Events\LoginSuccessEvent;
use App\Module\AppGame\Handler\BaseHandler;
use App\Module\AppGame\SessionApp;
use App\Module\UrsPromotion\Services\UrsUserMappingService;
use App\Module\UrsPromotion\Services\UrsReferralService;
use App\Module\User\Services\UserService;
use Google\Protobuf\Internal\Message;
use Illuminate\Support\Facades\Event;
use Illuminate\Support\Facades\Log;
use ThirdParty\Urs\Services\UrsService;
use Uraus\Kku\Request\RequestPublicLogin4u;
use Uraus\Kku\Response\ResponsePublicLogin4u;
use Uraus\Kku\Response\LastLoginInfo;

/**
 * 处理URS login4u登录请求
 *
 * 使用URS的userKey进行登录，自动创建用户并同步推荐关系
 */
class Login4uHandler extends BaseHandler
{
    /**
     * 是否需要登录
     *
     * @var bool
     */
    protected bool $need_login = false;

    /**
     * 处理login4u登录请求
     *
     * @param RequestPublicLogin4u $data 登录请求数据
     * @return ResponsePublicLogin4u 登录响应
     */
    public function handle(Message $data): Message
    {
        $keylogin = '';
        try {
            Log::info('Login4u登录请求开始处理');

            // 1. 验证登录密钥
            $keylogin = $data->getKeylogin();
            Log::info('获取登录密钥', [
                'keylogin_length' => strlen($keylogin),
                'keylogin_empty' => empty($keylogin)
            ]);

            if (empty($keylogin)) {
                Log::error('登录密钥验证失败', ['error' => '登录密钥不能为空']);
                throw new \Exception('登录密钥不能为空');
            }

            // 2. 使用URS获取用户信息
            Log::info('开始获取URS用户信息');
            $ursUserInfo = $this->getUrsUserInfo($keylogin);
            $ursUserId = $ursUserInfo['userId'];

            Log::info('URS用户信息获取成功', [
                'urs_user_id' => $ursUserId,
                'user_info_keys' => array_keys($ursUserInfo)
            ]);

            // 3. 获取或创建农场用户ID（同时保存userKey）
            Log::info('开始获取农场用户ID', [
                'urs_user_id' => $ursUserId,
                'user_key_length' => strlen($keylogin)
            ]);
            $farmUserId = UrsUserMappingService::getFarmUserIdByUserKeyWithAutoCreate($keylogin, $ursUserId);
            if (!$farmUserId) {
                Log::error('获取农场用户ID失败', [
                    'urs_user_id' => $ursUserId,
                    'farm_user_id' => $farmUserId,
                    'user_key_length' => strlen($keylogin)
                ]);
                throw new \Exception('获取农场用户ID失败');
            }

            Log::info('农场用户ID获取成功', [
                'urs_user_id' => $ursUserId,
                'farm_user_id' => $farmUserId
            ]);

            // 4. 获取农场用户信息
            Log::info('开始获取农场用户信息', ['farm_user_id' => $farmUserId]);
            $userDto = UserService::info($farmUserId);
            if (!$userDto) {
                Log::error('农场用户不存在', [
                    'farm_user_id' => $farmUserId,
                    'user_dto' => $userDto
                ]);
                throw new \Exception('农场用户不存在');
            }

            Log::info('农场用户信息获取成功', [
                'farm_user_id' => $farmUserId,
                'user_name' => $userDto->name ?? 'unknown'
            ]);

            // 5. 同步上下级关系
            $this->syncReferralRelations($ursUserId,$farmUserId);

            // 6. 设置用户登录状态
            $user = \App\Module\User\Models\User::find($farmUserId);
            if (!$user) {
                throw new \Exception('用户模型获取失败');
            }

            SessionApp::setLogin($user);
            $sessionId = SessionApp::getSessionId();

            // 7. 触发登录成功事件
            Event::dispatch(new LoginSuccessEvent($user, $sessionId));

            // 8. 记录登录日志
            Log::info('URS login4u登录成功', [
                'urs_user_id' => $ursUserId,
                'farm_user_id' => $farmUserId,
                'username' => $user->username,
                'session_id' => $sessionId
            ]);

            // 9. 创建响应对象
            $response = new ResponsePublicLogin4u();
            $response->setToken($sessionId);





            return $response;

        } catch (\Exception $e) {
            Log::error('URS login4u登录失败', [
                'keylogin' => $keylogin ?? '',
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);

            throw new $e;
        }
        return $response;

    }

    /**
     * 获取URS用户信息
     *
     * @param string $keylogin 登录密钥
     * @return array URS用户信息
     * @throws \Exception
     */
    private function getUrsUserInfo(string $keylogin): array
    {
        Log::info('开始获取URS用户信息', [
            'keylogin_length' => strlen($keylogin),
            'keylogin_prefix' => substr($keylogin, 0, 10) . '...'
        ]);

        try {
            $result = UrsService::getUserInfo($keylogin);

            Log::info('URS服务调用完成', [
                'result_keys' => array_keys($result),
                'success' => $result['success'] ?? false,
                'message' => $result['message'] ?? '',
                'has_data' => isset($result['data']),
                'data_keys' => isset($result['data']) ? array_keys($result['data']) : []
            ]);

            if (!$result['success'] || empty($result['data']['userId'])) {
                Log::error('URS用户信息获取失败详情', [
                    'result' => $result,
                    'success' => $result['success'] ?? false,
                    'has_userId' => isset($result['data']['userId']),
                    'userId_value' => $result['data']['userId'] ?? null
                ]);
                throw new \Exception('URS用户信息获取失败: ' . ($result['message'] ?? '未知错误'));
            }

            Log::info('URS用户信息获取成功', [
                'userId' => $result['data']['userId'],
                'data_keys' => array_keys($result['data'])
            ]);

            return $result['data'];

        } catch (\Exception $e) {
            Log::error('获取URS用户信息异常', [
                'keylogin_length' => strlen($keylogin),
                'error_message' => $e->getMessage(),
                'error_file' => $e->getFile(),
                'error_line' => $e->getLine(),
                'trace' => $e->getTraceAsString()
            ]);
            throw new \Exception('URS用户验证失败: ' . $e->getMessage());
        }
    }

    /**
     * 同步上下级关系到UrsPromotion模块
     *
     * @param int $ursUserId URS用户ID
     * @return void
     */
    private function syncReferralRelations(int $ursUserId,$farmUserId): void
    {
        try {
            Log::info('开始同步URS推荐关系', ['urs_user_id' => $ursUserId]);

            // 获取用户的上级关系链
            $teamResult = UrsService::getUserTeam($ursUserId);

            Log::info('URS团队关系获取结果', [
                'urs_user_id' => $ursUserId,
                'success' => $teamResult['success'] ?? false,
                'has_data' => !empty($teamResult['data']),
                'team_data' => $teamResult['data'] ?? null
            ]);

            if (!$teamResult['success'] || empty($teamResult['data'])) {
                Log::info('URS用户无上级关系', ['urs_user_id' => $ursUserId]);
                return;
            }

            $teamData = $teamResult['data'];

            // 检查是否已存在推荐关系
            $existingReferral = \App\Module\UrsPromotion\Models\UrsUserReferral::where('urs_user_id', $ursUserId)->first();
            if ($existingReferral) {
                Log::info('URS用户推荐关系已存在', [
                    'urs_user_id' => $ursUserId,
                    'urs_referrer_id' => $existingReferral->urs_referrer_id
                ]);
                return;
            }

            // 获取直接推荐人（一级上级）
            // URS返回的数据格式是 {"team":{"1":10077,"2":10071,"3":10003}}
            $directReferrerId = $teamData['team']['1'] ?? null;

            Log::info('解析直接推荐人', [
                'urs_user_id' => $ursUserId,
                'team_data_structure' => array_keys($teamData),
                'team_levels' => isset($teamData['team']) ? array_keys($teamData['team']) : [],
                'direct_referrer_id' => $directReferrerId
            ]);

            if (!$directReferrerId) {
                Log::info('URS用户无直接推荐人', [
                    'urs_user_id' => $ursUserId,
                    'team_data' => $teamData
                ]);
                return;
            }

            // 创建推荐关系
            Log::info('开始创建推荐关系', [
                'urs_user_id' => $ursUserId,
                'urs_referrer_id' => $directReferrerId
            ]);

            $referralDto = UrsReferralService::createReferral($ursUserId, $directReferrerId);

            Log::info('URS推荐关系同步成功', [
                'urs_user_id' => $ursUserId,
                'urs_referrer_id' => $directReferrerId,
                'referral_id' => $referralDto->id
            ]);

        } catch (\Exception $e) {
            // 推荐关系同步失败不影响登录流程
            Log::warning('URS推荐关系同步失败', [
                'urs_user_id' => $ursUserId,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);
        }
    }
}