import 'dart:async';
import 'dart:convert';
import 'package:crypto/crypto.dart';
import 'package:flutter_timezone/flutter_timezone.dart';
import 'package:doublefeel_flutter/app/modules/login/views/email_login_new_password_view.dart';
import 'package:doublefeel_flutter/app/modules/login/views/email_login_view.dart';
import 'package:doublefeel_flutter/core/config/app_environment_config.dart';
import 'package:doublefeel_flutter/core/constants/app_const.dart';
import 'package:doublefeel_flutter/core/logging/app_logger.dart';
import 'package:doublefeel_flutter/core/services/app_config_service.dart';
import 'package:doublefeel_flutter/core/services/thinking_data_service.dart';
import 'package:doublefeel_flutter/data/models/local/user_preferences.dart';
import 'package:doublefeel_flutter/l10n/gen/app_localizations.dart';
import 'package:doublefeel_flutter/l10n/l10n_extensions.dart';
import 'package:doublefeel_flutter/pigeon/platform_api.g.dart';
import 'package:doublefeel_flutter/pigeon/wechat_api.g.dart';
import 'package:flutter/services.dart';
import 'package:flutter/widgets.dart';
import 'package:get/get.dart';
import 'package:doublefeel_flutter/core/util/app_toast.dart';
import 'package:doublefeel_flutter/core/network/api/user_api.dart';
import 'package:doublefeel_flutter/core/network/api/vip_api.dart';
import 'package:doublefeel_flutter/core/services/user_state_service.dart';
import 'package:doublefeel_flutter/data/local/local_storage.dart';
import 'package:doublefeel_flutter/data/local/user_account_storage.dart';
import 'package:doublefeel_flutter/data/local/user_preferences_storage.dart';
import 'package:doublefeel_flutter/data/models/user/user_models.dart';
import 'package:doublefeel_flutter/data/models/vip/vip_info.dart';
import 'package:doublefeel_flutter/core/result/app_result.dart';
import 'package:doublefeel_flutter/app/routes/app_pages.dart';
import 'package:doublefeel_flutter/core/services/loading_service.dart';

class LoginController extends GetxController {
  final UserApi _userApi = Get.find<UserApi>();
  final VipApi _vipApi = Get.find<VipApi>();
  final UserPreferencesStorage _userPrefs = Get.find<UserPreferencesStorage>();
  final UserAccountStorage _userAccount = Get.find<UserAccountStorage>();
  final UserStateService _userStateService = Get.find<UserStateService>();
  final environmentConfig = Get.find<AppEnvironmentConfig>();

  final phoneController = TextEditingController();
  final emailController = TextEditingController();
  final passwordController = TextEditingController();
  final resetPasswordCodeController = TextEditingController();
  final codeController = TextEditingController();
  final codeFocusNode = FocusNode();

  final phoneInput = ''.obs;
  final codeInput = ''.obs;

  final emailInput = ''.obs;
  final passwordInput = ''.obs;

  final isSendingCode = false.obs;
  final countdownSeconds = 0.obs;
  Timer? _countdownTimer;

  final isLoggingIn = false.obs;
  final hasSentCode = false.obs;

  final termsChecked = false.obs;
  final isPasswordObscured = true.obs;

  /// 是否已经点击过「Continue」（用于控制提示文字是否变红）
  final hasTriedEmailLogin = false.obs;
  final hasTriedEmailPwd = false.obs;
  final resetPasswordCode = ''.obs;

  void togglePasswordVisibility() {
    isPasswordObscured.value = !isPasswordObscured.value;
  }

  static final _emailRegex = RegExp(
    r'^[a-zA-Z0-9._%+\-]+@[a-zA-Z0-9.\-]+\.[a-zA-Z]{2,}$',
  );

  static final _passwordRegex = RegExp(
    r'^(?=.*[0-9])(?=.*[A-Z]).{6,}$',
  );

  bool get isEmailValid =>
      _emailRegex.hasMatch(emailInput.value.trim()) &&
      emailInput.value.isNotEmpty;
  bool get isPasswordValid =>
      _passwordRegex.hasMatch(passwordInput.value) &&
      passwordInput.value.isNotEmpty;
  final resetPasswordError = false.obs;

  /// 邮箱格式正确且密码符合要求时，按钮可点击
  bool get canEmailLogin => isEmailValid && isPasswordValid;

  AppleSignInModel? appleSignInModel;
  GoogleSignInModel? googleSignInModel;

  bool _isToggling = false;

  void toggleTermsChecked() {
    // 互斥锁：函数执行期间忽略所有重入调用（手势积压、快速连点）
    if (_isToggling) return;
    _isToggling = true;

    final newValue = !termsChecked.value;
    termsChecked.value = newValue;

    // ① 写盘不 await，避免阻塞（SharedPrefs 写失败影响极小）
    unawaited(Get.find<LocalStorage>().setTermsAgreed(newValue).catchError(
          (e) => AppLogger.e('setTermsAgreed error: $e'),
        ));

    if (newValue && !_userStateService.sdksInitialized) {
      // ② SDK 初始化完全异步，不阻塞任何点击
      unawaited(_initSdksAndTrack());
    }

    // 释放锁：推迟到下一帧，确保当前帧内积压的所有手势事件都已被忽略
    WidgetsBinding.instance.addPostFrameCallback((_) {
      _isToggling = false;
    });
  }

  Future<void> _initSdksAndTrack() async {
    try {
      await _userStateService.initializeSdks();
      if (needTrackWelcomepage) {
        ta.track('enter_doublefeel_welcome_page');
        needTrackWelcomepage = false;
      }
      unawaited(AppConfigService.to.fetch());
    } catch (e) {
      AppLogger.e('initializeSdks error: $e');
    }
  }

  void onPhoneLoginPressed() {
    if (!termsChecked.value &&
        environmentConfig.region.value == AppRegion.china) {
      AppToast.show(AppLocalizations.of(Get.context!)!.loginAgreeToTermsToast);
      return;
    }
    ta.track('enter_doublefeel_telephone_login_page');
    Get.toNamed(AppRoutes.phoneLogin);
  }

  void onEmailLoginPressed() {
    ta.track('enter_doublefeel_email_login_page');
    Get.to(() => const EmailLoginView());
  }

  void onAppleLoginPressed() async {
    if (!termsChecked.value &&
        environmentConfig.region.value == AppRegion.china) {
      AppToast.show(AppLocalizations.of(Get.context!)!.loginAgreeToTermsToast);
      return;
    }
    try {
      final result = await LoadingService.instance.run(() async {
        return await PlatformHostApi().requestAppleSignIn();
      }, type: LoadingType.circular);
      // result 为 null 或 identityToken 为空，说明用户取消或苹果授权失败
      if (result == null ||
          result.identityToken?.isNotEmpty != true ||
          result.userId.isNotEmpty != true) {
        appleSignInModel = null;
        return;
      }
      appleSignInModel = result;
      await _loginWithApple(result);
    } catch (e) {
      appleSignInModel = null;
      AppToast.show(e.toString());
    }
  }

  void onGoogleLoginPressed() async {
    try {
      final result = await LoadingService.instance.run(() async {
        return await PlatformHostApi().requestGoogleSignIn();
      }, type: LoadingType.circular);
      // result 为 null 或 identityToken 为空，说明用户取消或苹果授权失败
      if (result == null ||
          result.idToken.isNotEmpty != true ||
          result.clientID?.isNotEmpty != true) {
        googleSignInModel = null;
        return;
      }
      googleSignInModel = result;
      await _loginWithGoogle(result);
    } catch (e) {
      googleSignInModel = null;
      AppToast.show(e.toString());
    }
  }

  void onWechatLoginPressed() async {
    if (!termsChecked.value &&
        environmentConfig.region.value == AppRegion.china) {
      AppToast.show(AppLocalizations.of(Get.context!)!.loginAgreeToTermsToast);
      return;
    }
    try {
      final code = await LoadingService.instance.run(
        () => WeChatHostApi().requestAuthorizationCode(),
        type: LoadingType.circular,
      );
      if (code.isEmpty) return;
      await _loginWithWechat(code);
    } on PlatformException catch (e) {
      AppToast.show(e.message?.isNotEmpty == true ? e.message! : '微信登录失败');
    } catch (e) {
      AppToast.show(e.toString());
    }
  }

  void onDebugPressed() {
    Get.toNamed(AppRoutes.debugEnvironment);
  }

  Future<void> selectServiceRegion(AppRegion region) async {
    if (environmentConfig.region.value == region) return;
    await environmentConfig.setRegion(region);
    if (environmentConfig.region.value == AppRegion.china) {
      if (termsChecked.value) toggleTermsChecked();
    } else {
      if (!termsChecked.value) toggleTermsChecked();
    }
    ta.setSuperProperties({
      'app_region': environmentConfig.region.value == AppRegion.china
          ? 'mainland'
          : 'overseas'
    });
  }

  void openUserTerms() {
    String url = environmentConfig.region.value == AppRegion.china
        ? AppConst.userTerms
        : AppConst.userTermsGlobal;
    Get.toNamed(
      AppRoutes.webview,
      parameters: {'url': url},
    );
  }

  void openPrivacyPolicy() {
    String url = environmentConfig.region.value == AppRegion.china
        ? AppConst.privacyPolicy
        : AppConst.privacyPolicyGlobal;
    Get.toNamed(
      AppRoutes.webview,
      parameters: {'url': url},
    );
  }

  @override
  void onInit() {
    super.onInit();
    termsChecked.value = Get.find<LocalStorage>().termsAgreed;

    phoneController.addListener(() {
      phoneInput.value = phoneController.text;
    });
    codeController.addListener(() {
      codeInput.value = codeController.text;
    });

    emailController.addListener(() {
      emailInput.value = emailController.text;
      hasTriedEmailLogin.value = false;
    });
    passwordController.addListener(() {
      hasTriedEmailPwd.value = false;
      passwordInput.value = passwordController.text;
    });
    resetPasswordCodeController.addListener(() {
      resetPasswordCode.value = resetPasswordCodeController.text.trim();
    });
  }

  bool get canResetPassword =>
      resetPasswordCode.value.isNotEmpty && isPasswordValid;

  @override
  void onClose() {
    _countdownTimer?.cancel();
    phoneController.dispose();
    codeController.dispose();
    passwordController.dispose();
    resetPasswordCodeController.dispose();
    codeFocusNode.dispose();
    super.onClose();
  }

  @override
  void onReady() {
    super.onReady();
    if (_userStateService.sdksInitialized) {
      ta.track('enter_doublefeel_welcome_page');
      needTrackWelcomepage = false;
    } else {
      needTrackWelcomepage = true;
    }
  }

  bool needTrackWelcomepage = false;

  String get cleanPhone => phoneInput.value.replaceAll(' ', '');

  bool get canRequestCode =>
      cleanPhone.length == 11 &&
      !isSendingCode.value &&
      countdownSeconds.value == 0;

  bool get canLogin =>
      cleanPhone.length == 11 &&
      codeInput.value.isNotEmpty &&
      !isLoggingIn.value;

  Future<void> requestVerifyCode() async {
    if (!canRequestCode) return;

    if (cleanPhone.length < 11) {
      AppToast.show(AppLocalizations.of(Get.context!)!.phoneLoginInvalidPhone);
      return;
    }

    isSendingCode.value = true;
    final request = VerifyCodeRequest.login(cleanPhone);
    final result = await _userApi.requestVerifyCode(request);

    isSendingCode.value = false;
    if (result is AppSuccess<void>) {
      AppToast.show(
          AppLocalizations.of(Get.context!)!.phoneLoginCodeSentSuccess);
      _startCountdown();
      codeFocusNode.requestFocus();
    }
  }

  void _startCountdown() {
    hasSentCode.value = true;
    _countdownTimer?.cancel();
    countdownSeconds.value = 60;
    _countdownTimer = Timer.periodic(const Duration(seconds: 1), (timer) {
      if (countdownSeconds.value > 1) {
        countdownSeconds.value--;
      } else {
        countdownSeconds.value = 0;
        timer.cancel();
      }
    });
  }

  Future<void> login() async {
    if (!canLogin) return;

    if (cleanPhone.length < 11) {
      AppToast.show(AppLocalizations.of(Get.context!)!.phoneLoginInvalidPhone);
      return;
    }
    if (codeInput.value.isEmpty) {
      AppToast.show(AppLocalizations.of(Get.context!)!.phoneLoginInvalidCode);
      return;
    }

    isLoggingIn.value = true;
    try {
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.login(
          telephone: cleanPhone,
          verifyCode: codeInput.value,
        );

        if (loginRes is AppSuccess<LoginResponse>) {
          await _handleLoginSuccess(loginRes.data);
          await Get.find<LocalStorage>().setLastLoginMethod('phone');
          await environmentConfig.updateHideChooseRegion(true);
        }
      });
    } finally {
      isLoggingIn.value = false;
    }
  }

  /// 邮箱登录 Continue 按钮点击
  Future<void> emailLogin() async {
    hasTriedEmailLogin.value = true;
    hasTriedEmailPwd.value = true;

    if (!isEmailValid) {
      // AppToast.show(l10n.invalidEmailFormat);
      return;
    }

    if (!isPasswordValid) {
      // AppToast.show(l10n.invalidPasswordFormat);
      return;
    }

    isLoggingIn.value = true;
    try {
      final md5Password =
          md5.convert(utf8.encode(passwordInput.value)).toString();
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.loginWithEmail(
          email: emailInput.value.trim(),
          password: md5Password,
        );
        if (loginRes is AppSuccess<LoginResponse>) {
          await _handleLoginSuccess(loginRes.data, emailPassword: md5Password);
          await Get.find<LocalStorage>().setLastLoginMethod('email');
        }
      });
    } finally {
      isLoggingIn.value = false;
    }
    var success = true;
    if (success) {
      TextInput.finishAutofillContext();
    }
  }

  Future<void> sendRestEmail() async {
    if (!isEmailValid) {
      AppToast.show(l10n.invalidEmailFormat);
      return;
    }

    try {
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.forgetPasswordSendEmail(
          email: emailInput.value.trim(),
        );
        if (loginRes is AppSuccess<LoginResponse>) {
          Get.to(() => EmailLoginNewPasswordView());
        } else {}
      });
    } catch (e) {}
  }

  Future<void> resetPassword() async {
    if (!isEmailValid) {
      // AppToast.show(l10n.invalidEmailFormat);
      return;
    }

    if (resetPasswordCode.value.isEmpty) {
      AppToast.show(l10n.invalidCode);
      return;
    }
    if (!isPasswordValid) {
      // AppToast.show(l10n.invalidPasswordFormat);
      return;
    }

    try {
      final md5Password =
          md5.convert(utf8.encode(passwordInput.value)).toString();
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.forgetPasswordSetNewPassword(
          email: emailInput.value.trim(),
          verificationCode: resetPasswordCode.value,
          newPassword: md5Password,
        );
        if (loginRes is AppSuccess<LoginResponse>) {
          AppToast.show(l10n.paswordHasBeenChanged);
          Get.back();
          Get.back();
        } else {}
      });
    } catch (e) {}
  }

  Future<void> _loginWithApple(AppleSignInModel appleModel) async {
    isLoggingIn.value = true;
    try {
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.loginWithApple(appleModel);

        if (loginRes is AppSuccess<LoginResponse>) {
          await _handleLoginSuccess(loginRes.data, appleModel: appleModel);
          await Get.find<LocalStorage>().setLastLoginMethod('apple');
          await environmentConfig.updateHideChooseRegion(true);
        }
      });
    } finally {
      isLoggingIn.value = false;
    }
  }

  Future<void> _loginWithWechat(String code) async {
    isLoggingIn.value = true;
    try {
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.loginWithWechat(code);
        if (loginRes is AppSuccess<LoginResponse>) {
          await _handleLoginSuccess(loginRes.data, wechatCode: code);
          await Get.find<LocalStorage>().setLastLoginMethod('wechat');
          await environmentConfig.updateHideChooseRegion(true);
        }
      });
    } finally {
      isLoggingIn.value = false;
    }
  }

  Future<void> _loginWithGoogle(GoogleSignInModel googleModel) async {
    isLoggingIn.value = true;
    try {
      await LoadingService.instance.run(() async {
        final loginRes = await _userApi.loginWithGoogle(googleModel);

        if (loginRes is AppSuccess<LoginResponse>) {
          await _handleLoginSuccess(loginRes.data, googleModel: googleModel);
          await Get.find<LocalStorage>().setLastLoginMethod('google');
          await environmentConfig.updateHideChooseRegion(true);
        }
      });
    } finally {
      isLoggingIn.value = false;
    }
  }

  /// 登录/注册成功后的公共处理逻辑（手机号登录与苹果登录共用）
  Future<void> _handleLoginSuccess(LoginResponse loginData,
      {AppleSignInModel? appleModel,
      GoogleSignInModel? googleModel,
      String? emailPassword,
      String? wechatCode}) async {
    bool isApple = appleModel != null;
    bool isGoogle = googleModel != null;
    bool isEmail = emailPassword != null;
    bool isWechat = wechatCode != null;
    final isRegister = loginData.isNewUser == true;
    String accessToken = loginData.accessToken;

    if (isRegister) {
      Map<String, dynamic>? registerData;
      if (isApple) {
        registerData = {
          'login_type': 'apple',
          'apple_user_id': appleModel.userId,
          'identity_token': appleModel.identityToken,
        };
      } else if (isGoogle) {
        registerData = {
          'login_type': 'google',
          'identity_token': googleModel.idToken,
          'expected_client_id': googleModel.clientID,
        };
      } else if (isEmail) {
        registerData = {
          'login_type': 'email',
          'email': emailInput.value.trim(),
          'password': emailPassword,
        };
      } else if (isWechat) {
        registerData = {
          'login_type': 'wechat',
          'wechat_code': wechatCode,
        };
      } else {
        registerData = {
          'login_type': 'verification_code',
          'telephone': cleanPhone,
          'verification_code': codeInput.value,
        };
      }
      if (environmentConfig.region.value == AppRegion.global) {
        try {
          final timezoneInfo = await FlutterTimezone.getLocalTimezone();
          registerData['tz_iana'] = timezoneInfo.identifier;
        } catch (e) {
          // AppLogger.w('Failed to get IANA timezone: $e');
          // registerData['tz_iana'] = DateTime.now().timeZoneName;
        }
      }

      final regRes = await _userApi.register(registerData);
      if (regRes is AppSuccess<RegisterResponse>) {
        accessToken = regRes.data.accessToken;
      } else {
        isLoggingIn.value = false;
        return;
      }
    }

    // Fetch user info and VIP info
    final userInfoResFuture = _userApi.getUserInfo(accessToken: accessToken);
    final vipInfoResFuture = isRegister
        ? Future.value(null)
        : _vipApi.getVipInfo(accessToken: accessToken);

    final results = await Future.wait([userInfoResFuture, vipInfoResFuture]);
    final userInfoRes = results[0];
    final vipInfoRes = results[1];

    if (userInfoRes is AppSuccess<UserInfoResponse>) {
      final me = userInfoRes.data;
      UserInfoResponse? partner;

      // if ((me.pairId ?? 0) > 0) {
      //   final partnerRes =
      //       await _userApi.getPartnerUserInfo(accessToken: accessToken);
      //   if (partnerRes is AppSuccess<BoundUserInfoResponse>) {
      //     partner = partnerRes.data.partnerUserInfo;
      //   }
      // }

      VipInfo? vip;
      if (vipInfoRes is AppSuccess<VipInfo>) {
        vip = vipInfoRes.data;
      }

      await _userPrefs.updateFromLogin(
        accessToken: accessToken,
        me: me,
        partner: partner,
        vip: vip,
      );

      try {
        if (Get.isRegistered<AppEnvironmentConfig>()) {
          var env = Get.find<AppEnvironmentConfig>();
          await PlatformHostApi().updateLoginInfo(
              jsonEncode(UserPreferences(
                accessToken: accessToken,
                meUserInfo: me,
                partnerUserInfo: partner,
                vipInfo: vip != null
                    ? UserPreferencesVipInfo.fromVipInfo(vip)
                    : null,
              )),
              env.serverBaseUrl);
        }
      } on Exception catch (e) {
        AppLogger.e(e);
      }

      await _userStateService.onLogin();
      if (isRegister) {
        ta.track('success_regist');
      }

      // 用户登录成功即代表同意了协议，持久化到本地供冷启动时 SDK 初始化判断使用
      await Get.find<LocalStorage>().setTermsAgreed(true);

      // 根据引导完成状态决定跳转目标
      final userId = me.id ?? 0;
      if (_userAccount.hasCompletedOnboarding(userId) ||
          me.isPassNoviceGuide == 1) {
        // 该账号已完成引导，直接进主页
        Get.offAllNamed(AppRoutes.home);
      } else {
        // 新用户或未完成引导，进入引导页（支持断点续做）
        final resumeStage = _userAccount.onboardingResumeStage(userId);
        Get.offAllNamed(
          AppRoutes.userOnboarding,
          arguments: resumeStage != null ? {'resumeStage': resumeStage} : null,
        );
      }
    } else {
      // userInfoRes 失败，外层 finally 会重置 isLoggingIn
    }
  }
}