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
    {
        try {
            // 1. 验证登录密钥
            $keylogin = $data->getKeylogin();
            if (empty($keylogin)) {
                throw new \Exception('登录密钥不能为空');
            }

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

            // 3. 获取或创建农场用户ID
            $farmUserId = UrsUserMappingService::getFarmUserId($ursUserId);
            if (!$farmUserId) {
                throw new \Exception('获取农场用户ID失败');
            }

            // 4. 获取农场用户信息
            $userDto = UserService::info($farmUserId);
            if (!$userDto) {
                throw new \Exception('农场用户不存在');
            }

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

            // 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);
            $response->setIsProhibit(false); // 根据用户状态设置

            // 设置最后登录信息（可选）
            $lastLoginInfo = new LastLoginInfo();
            $lastLoginInfo->setLastLoginTimes(time());
            $response->setLastLoginInfo($lastLoginInfo);

            return $response;

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

            // 返回失败响应
            $response = new ResponsePublicLogin4u();
            $response->setToken('');
            $response->setIsProhibit(true);
            
            return $response;
        }
    }

    /**
     * 获取URS用户信息
     *
     * @param string $keylogin 登录密钥
     * @return array URS用户信息
     * @throws \Exception
     */
    private function getUrsUserInfo(string $keylogin): array
    {
        try {
            $result = UrsService::getUserInfo($keylogin);
            
            if (!$result['success'] || empty($result['data']['userId'])) {
                throw new \Exception('URS用户信息获取失败: ' . ($result['message'] ?? '未知错误'));
            }

            return $result['data'];

        } catch (\Exception $e) {
            Log::error('获取URS用户信息失败', [
                'keylogin' => $keylogin,
                'error' => $e->getMessage()
            ]);
            throw new \Exception('URS用户验证失败: ' . $e->getMessage());
        }
    }

    /**
     * 同步上下级关系到UrsPromotion模块
     *
     * @param int $ursUserId URS用户ID
     * @return void
     */
    private function syncReferralRelations(int $ursUserId): void
    {
        try {
            // 获取用户的上级关系链
            $teamResult = UrsService::getUserTeam($ursUserId);
            
            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;
            }

            // 获取直接推荐人（一级上级）
            $directReferrerId = $teamData['level1'] ?? null;
            if (!$directReferrerId) {
                Log::info('URS用户无直接推荐人', ['urs_user_id' => $ursUserId]);
                return;
            }

            // 创建推荐关系
            $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()
            ]);
        }
    }
}