import 'dart:async';
import 'dart:convert';
import 'dart:io';

import 'package:appframe/config/constant.dart';
import 'package:appframe/config/locator.dart';
import 'package:appframe/config/routes.dart';
import 'package:appframe/data/models/message/h5_message.dart';
import 'package:appframe/services/dispatcher.dart';
import 'package:appframe/services/im_service.dart';
import 'package:appframe/services/local_server_service.dart';
import 'package:appframe/services/player_service.dart';
import 'package:appframe/services/recorder_service.dart';
import 'package:equatable/equatable.dart';
import 'package:flutter/cupertino.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:fluwx/fluwx.dart';
import 'package:path_provider/path_provider.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:webview_flutter/webview_flutter.dart';
import 'package:wechat_assets_picker/wechat_assets_picker.dart';
import 'package:wechat_camera_picker/wechat_camera_picker.dart';

class WebState extends Equatable {
  final int selectedIndex;
  final bool loaded;
  final String title;
  final int titleColor;
  final int bgColor;
  final String opIcon;
  final bool showBottomNavBar;

  final String? ip;
  final String? sessionCode;
  final String? userCode;
  final String? classCode;
  final int? userType;
  final String? stuId;

  /// getOrientationCmd
  final bool orientationCmdFlag;
  final String orientationCmdMessage;

  /// getWindowInfoCmd
  final bool windowInfoCmdFlag;
  final String windowInfoCmdMessage;

  /// chooseImageCmd
  final bool chooseImageCmdFlag;
  final String chooseImageCmdMessage;

  /// chooseVideoCmd
  final bool chooseVideoCmdFlag;
  final String chooseVideoCmdMessage;

  const WebState({
    this.selectedIndex = 0,
    this.loaded = false,
    this.title = '',
    this.titleColor = 0xFFFFFFFF,
    this.bgColor = 0xFF7691FA,
    this.opIcon = 'none',
    this.showBottomNavBar = false,
    this.ip,
    this.sessionCode,
    this.userCode,
    this.classCode,
    this.userType,
    this.stuId,
    this.orientationCmdFlag = false,
    this.orientationCmdMessage = '',
    this.windowInfoCmdFlag = false,
    this.windowInfoCmdMessage = '',
    this.chooseImageCmdFlag = false,
    this.chooseImageCmdMessage = '',
    this.chooseVideoCmdFlag = false,
    this.chooseVideoCmdMessage = '',
  });

  WebState copyWith({
    int? selectedIndex,
    bool? loaded,
    String? title,
    int? titleColor,
    int? bgColor,
    String? opIcon,
    bool? showNavBar,
    bool? showBottomNavBar,
    String? ip,
    String? sessionCode,
    String? userCode,
    String? classCode,
    int? userType,
    String? stuId,
    bool? orientationCmdFlag,
    String? orientationCmdMessage,
    bool? windowInfoCmdFlag,
    String? windowInfoCmdMessage,
    bool? chooseImageCmdFlag,
    String? chooseImageCmdMessage,
    bool? chooseVideoCmdFlag,
    String? chooseVideoCmdMessage,
  }) {
    return WebState(
      selectedIndex: selectedIndex ?? this.selectedIndex,
      loaded: loaded ?? this.loaded,
      title: title ?? this.title,
      titleColor: titleColor ?? this.titleColor,
      bgColor: bgColor ?? this.bgColor,
      opIcon: opIcon ?? this.opIcon,
      showBottomNavBar: showBottomNavBar ?? this.showBottomNavBar,
      ip: ip ?? this.ip,
      sessionCode: sessionCode ?? this.sessionCode,
      userCode: userCode ?? this.userCode,
      classCode: classCode ?? this.classCode,
      userType: userType ?? this.userType,
      stuId: stuId ?? this.stuId,
      orientationCmdFlag: orientationCmdFlag ?? this.orientationCmdFlag,
      orientationCmdMessage: orientationCmdMessage ?? this.orientationCmdMessage,
      windowInfoCmdFlag: windowInfoCmdFlag ?? this.windowInfoCmdFlag,
      windowInfoCmdMessage: windowInfoCmdMessage ?? this.windowInfoCmdMessage,
      chooseImageCmdFlag: chooseImageCmdFlag ?? this.chooseImageCmdFlag,
      chooseImageCmdMessage: chooseImageCmdMessage ?? this.chooseImageCmdMessage,
      chooseVideoCmdFlag: chooseVideoCmdFlag ?? this.chooseVideoCmdFlag,
      chooseVideoCmdMessage: chooseVideoCmdMessage ?? this.chooseVideoCmdMessage,
    );
  }

  @override
  List<Object?> get props => [
        selectedIndex,
        loaded,
        title,
        titleColor,
        bgColor,
        opIcon,
        showBottomNavBar,
        ip,
        sessionCode,
        userCode,
        classCode,
        userType,
        stuId,
        orientationCmdFlag,
        orientationCmdMessage,
        windowInfoCmdFlag,
        windowInfoCmdMessage,
        chooseImageCmdFlag,
        chooseImageCmdMessage,
        chooseVideoCmdFlag,
        chooseVideoCmdMessage,
      ];
}

class WebCubit extends Cubit<WebState> {
  late final MessageDispatcher _dispatcher;
  late final WebViewController _controller;
  late final Fluwx _fluwx;
  HttpServer? _server;
  PlayerService? _playerService;
  RecorderService? _recorderService;

  WebViewController get controller => _controller;

  WebCubit(super.initialState) {
    // 没有登录数据，跳转到登录页面
    if (state.sessionCode == null || state.sessionCode == '') {
      WidgetsBinding.instance.addPostFrameCallback((_) {
        router.go('/loginMain');
      });
    } else {
      _init();
    }
  }

  Future<void> _init() async {
    // 消息处理器
    _dispatcher = MessageDispatcher();

    // 启动本地服务器
    await _startLocalServer();

    // 创建WebView控制器
    await _createWebViewController();

    _loadHtml();

    // 登录IM
    _loginIM();

    _fluwx = getIt.get<Fluwx>();
    _playerService = getIt.get<PlayerService>();
    _playerService?.sendResponse = _sendResponse;
    _recorderService = getIt.get<RecorderService>();
  }

  Future<void> _startLocalServer() async {
    // 启动本地服务器
    _server = await getIt.get<LocalServerService>().startLocalServer();
  }

  Future<void> _createWebViewController() async {
    _controller = WebViewController();
    await _controller.setJavaScriptMode(JavaScriptMode.unrestricted);
    await _controller.setNavigationDelegate(
      NavigationDelegate(
        onUrlChange: (UrlChange url) {},
        onPageStarted: (String url) async {
          // 进行新页面加载时，关闭录音器和播放器，（如果有打开过）
          await _playerService?.close();
          await _recorderService?.close();
        },
        onPageFinished: (String url) async {
          print('onPageFinished--------------------------------->');
          print(url);

          /*if (url == '${Constant.localServerTestFileUrl}/login.html') {
            return;
          }*/

          _controller.runJavaScript(
            'document.querySelector("meta[name=viewport]").setAttribute("content", "width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=no")',
          );

          finishLoading();
        },
      ),
    );
    await _controller.addJavaScriptChannel("xeJsBridge", onMessageReceived: _onMessageReceived);
  }

  void _loadHtml() {
    // 构造函数中已拦截判断未登录的情况进行了处理，所以这里不再处理未登录的情况
    final String serverUrl = '${Constant.localServerUrl}/index.html'
        '#/h5/login/pages/applogin?'
        'sessionCode=${state.sessionCode}&'
        'userCode=${state.userCode}&'
        'classCode=${state.classCode}&'
        'userType=${state.userType}&'
        'stuId=${state.stuId}';
    _controller.loadRequest(Uri.parse(serverUrl));
  }

  Future<void> _loginIM() async {
    if (Constant.needIM) {
      var imService = getIt.get<ImService>();
      var loginResult = await imService.login(state.userCode!);
      if (loginResult) {
        print("缓存自动登录处，IM 登录成功");
        await imService.registerPush();
      } else {
        print("缓存自动登录处，IM 登录失败");
      }
    }
  }

  void _onMessageReceived(JavaScriptMessage message) async {
    try {
      _dispatcher.dispatch(message.message, (response) {
        _sendResponse(response);
      }, webCubit: this);
    } catch (e) {
      print('消息解析错误: $e');
    }
  }

  // 向H5发送响应
  void _sendResponse(Map<String, dynamic> response) {
    String jsonString = jsonEncode(response);
    String escapedJson = jsonString.replaceAll('"', '\\"');
    final String script = 'xeJsBridgeCallback("$escapedJson");';
    _controller.runJavaScript(script);
  }

  void finishLoading() {
    emit(state.copyWith(loaded: true));
  }

  //测试
  void goWechatAuth() {
    router.go('/wechatAuth');
  }

  void goLogin() {
    router.go('/loginMain');
  }

  void goIm() {
    router.go('/im');
  }

  //测试
  void goAuth() {
    // String serverUrl = 'http://${state.ip}:${_server.port}/index.html';
    String serverUrl = '${Constant.localServerUrl}/index.html';
    // String serverUrl = 'http://localdev.banxiaoer.net';
    _controller.loadRequest(Uri.parse(serverUrl));
  }

  void goMiniProgram() {
    _fluwx
      // ..addSubscriber(_responseListener)
      ..open(
        target: MiniProgram(
          username: 'gh_9a8d84445828',
          path: '/pages/index/index?classCode=needswitch',
          miniProgramType: WXMiniProgramType.preview,
        ),
      );

    // _fluwx.share(WeChatShareTextModel("source text", scene: WeChatScene.session));
  }

  // void _responseListener(response) {
  //   if (response is WeChatLaunchMiniProgramResponse) {
  //     print("小程序跳转 1 --------------------------------");
  //     print(response);
  //   }
  // }

  Future<String?> goScanCode() async {
    var result = await router.push('/scanCode');
    return result as String?;
  }

  Future<void> handleBack() async {
    // navigateBack指令
    var resp = {'unique': '', 'cmd': 'navigateBack', 'data': '', 'errMsg': ''};
    _sendResponse(resp);
  }

  Future<void> handleHome() async {
    // navigateHome指令
    var resp = {'unique': '', 'cmd': 'navigateHome', 'data': '', 'errMsg': ''};
    _sendResponse(resp);
  }

  Future<void> handleRefreshPage() async {
    // refreshPage指令
    var resp = {'unique': '', 'cmd': 'refreshPage', 'data': '', 'errMsg': ''};
    _sendResponse(resp);
  }

  bool setTitleBar(String title, String color, String bgColor, String icon) {
    int parsedTitleColor = _hexStringToInt(color);
    int parsedBgColor = _hexStringToInt(bgColor);

    emit(state.copyWith(title: title, titleColor: parsedTitleColor, bgColor: parsedBgColor, opIcon: icon));
    return true;
  }

  int _hexStringToInt(String hexString) {
    // 移除可能存在的 # 前缀
    if (hexString.startsWith('#')) {
      hexString = hexString.substring(1);
    }

    // 确保颜色值是8位（包含alpha通道）
    if (hexString.length == 6) {
      hexString = 'FF$hexString'; // 添加不透明的alpha值
    }

    // 解析十六进制字符串为整数
    return int.parse(hexString, radix: 16);
  }

  Future<void> refresh() async {
    // await clearRecording();
    // await clearAudio();
    _controller.reload();
  }

  Future<void> clearStorage() async {
    await getIt.get<SharedPreferences>().clear();
  }

  Future<void> logout() async {
    await clearStorage();
    // IM 登出
    await getIt.get<ImService>().logout();

    goLogin();
  }

  void updateSelectedIndex(int index) {
    emit(state.copyWith(selectedIndex: index));
  }

  void showBottomNavBar() {
    emit(state.copyWith(showBottomNavBar: true));
  }

  void hideBottomNavBar() {
    emit(state.copyWith(showBottomNavBar: false));
  }

  ///
  ///
  ///
  void setChooseImageCmdFlag(bool chooseImageCmdFlag, String chooseImageCmdMessage) {
    emit(state.copyWith(chooseImageCmdFlag: chooseImageCmdFlag, chooseImageCmdMessage: chooseImageCmdMessage));
  }

  void chooseImage(BuildContext context) async {
    final Map<String, dynamic> data = json.decode(state.chooseImageCmdMessage);
    H5Message h5Message = H5Message.fromJson(data);

    setChooseImageCmdFlag(false, '');

    final params = h5Message.params;
    if (params is! Map<String, dynamic>) {
      throw Exception('参数错误');
    }
    var sourceType = params['sourceType'] as String;
    if (sourceType != 'album' && sourceType != 'camera') {
      sourceType = 'album';
    }
    // 暂时忽略 sizeType 参数

    int count = 9;
    if (params.containsKey('count')) {
      count = params['count'] as int;
      if (count < 1 || count > 9) {
        count = 9;
      }
    }

    // 相册
    if (sourceType == 'album') {
      _chooseImageFromAlbum(context, count, h5Message.unique, h5Message.cmd);
    }
    // 拍照
    else {
      _chooseImageFromCamera(context, h5Message.unique, h5Message.cmd);
    }
  }

  void _chooseImageFromAlbum(BuildContext context, int count, String unique, String cmd) async {
    final List<AssetEntity>? result = await AssetPicker.pickAssets(
      context,
      pickerConfig: AssetPickerConfig(
        maxAssets: count,
        requestType: RequestType.image,
        gridThumbnailSize: const ThumbnailSize.square(80),
        previewThumbnailSize: const ThumbnailSize.square(150),
        dragToSelect: false,
      ),
    );

    if (result == null || result.isEmpty) {
      var resp = {'unique': unique, 'cmd': cmd, 'data': null, 'errMsg': 'cancel'};
      _sendResponse(resp);
      return;
    }

    // 获取临时目录
    final Directory tempDir = await getTemporaryDirectory();

    final List<Map<String, dynamic>> resultList = [];
    for (var asset in result) {
      resultList.add(await _handleSingleImage(asset, tempDir));
    }
    var resp = {
      'unique': unique,
      'cmd': cmd,
      'data': {'tempFiles': resultList},
      'errMsg': '',
    };
    _sendResponse(resp);
  }

  void _chooseImageFromCamera(BuildContext context, String unique, String cmd) async {
    AssetEntity? asset = await CameraPicker.pickFromCamera(context, pickerConfig: const CameraPickerConfig());

    if (asset == null) {
      var resp = {'unique': unique, 'cmd': cmd, 'data': null, 'errMsg': 'cancel'};
      _sendResponse(resp);
      return;
    }

    final Directory tempDir = await getTemporaryDirectory();
    final Map<String, dynamic> result = await _handleSingleImage(asset, tempDir);
    var resp = {
      'unique': unique,
      'cmd': cmd,
      'data': {
        'tempFiles': [result],
      },
      'errMsg': '',
    };
    _sendResponse(resp);
  }

  Future<Map<String, dynamic>> _handleSingleImage(AssetEntity asset, Directory tempDir) async {
    final file = await asset.file;

    // 生成缩略图
    final data = await asset.thumbnailData;
    final thumbnailFile = await File(
      '${tempDir.path}/${DateTime.now().millisecondsSinceEpoch}.png',
    ).writeAsBytes(data!);

    return {
      "tempFilePath": '${Constant.localServerTempFileUrl}${file!.path}',
      "size": file.lengthSync(),
      "width": asset.width,
      "height": asset.height,
      "thumbTempFilePath": '${Constant.localServerTempFileUrl}${thumbnailFile.path}',
      "fileType": file.path.split('/').last.split('.').last,
    };
  }

  void setChooseVideoCmdFlag(bool chooseVideoCmdFlag, String chooseVideoCmdMessage) {
    emit(state.copyWith(chooseVideoCmdFlag: chooseVideoCmdFlag, chooseVideoCmdMessage: chooseVideoCmdMessage));
  }

  void chooseVideo(BuildContext context) async {
    final Map<String, dynamic> data = json.decode(state.chooseVideoCmdMessage);
    H5Message h5Message = H5Message.fromJson(data);

    setChooseVideoCmdFlag(false, '');
    final params = h5Message.params;
    if (params is! Map<String, dynamic>) {
      throw Exception('参数错误');
    }
    var sourceType = params['sourceType'] as String;
    if (sourceType != 'album' && sourceType != 'camera') {
      sourceType = 'album';
    }
    // 暂时忽略 sizeType 参数

    int count = 1;
    if (params.containsKey('count')) {
      count = params['count'] as int;
      if (count < 1 || count > 9) {
        count = 9;
      }
    }

    int maxDuration = 60;
    if (params.containsKey('maxDuration')) {
      maxDuration = params['maxDuration'] as int;
      if (maxDuration < 1 || maxDuration > 600) {
        maxDuration = 60;
      }
    }

    // 相册选择
    if (sourceType == 'album') {
      _chooseVideoFromAlbum(context, count, h5Message.unique, h5Message.cmd);
    }
    // 拍摄
    else {
      _chooseVideoFromCamera(context, maxDuration, h5Message.unique, h5Message.cmd);
    }
  }

  void _chooseVideoFromAlbum(BuildContext context, int count, String unique, String cmd) async {
    final List<AssetEntity>? result = await AssetPicker.pickAssets(
      context,
      pickerConfig: AssetPickerConfig(
        maxAssets: count,
        requestType: RequestType.video,
        dragToSelect: false,
      ),
    );

    if (result == null || result.isEmpty) {
      var resp = {'unique': unique, 'cmd': cmd, 'data': null, 'errMsg': 'cancel'};
      _sendResponse(resp);
      return;
    }

    // 获取临时目录
    final Directory tempDir = await getTemporaryDirectory();

    final List<Map<String, dynamic>> resultList = [];
    for (var asset in result) {
      resultList.add(await _handleSingleVideo(asset, tempDir));
    }
    var resp = {
      'unique': unique,
      'cmd': cmd,
      'data': {'tempFiles': resultList},
      'errMsg': '',
    };
    _sendResponse(resp);
  }

  void _chooseVideoFromCamera(BuildContext context, int maxDuration, String unique, String cmd) async {
    AssetEntity? asset = await CameraPicker.pickFromCamera(
      context,
      pickerConfig: CameraPickerConfig(
        enableRecording: true,
        onlyEnableRecording: true,
        // enableTapRecording: true,
        maximumRecordingDuration: Duration(seconds: maxDuration),
      ),
    );

    if (asset == null) {
      var resp = {'unique': unique, 'cmd': cmd, 'data': null, 'errMsg': 'cancel'};
      _sendResponse(resp);
      return;
    }

    final Directory tempDir = await getTemporaryDirectory();
    final Map<String, dynamic> result = await _handleSingleVideo(asset, tempDir);
    var resp = {
      'unique': unique,
      'cmd': cmd,
      'data': {
        'tempFiles': [result],
      },
      'errMsg': '',
    };
    _sendResponse(resp);
  }

  Future<Map<String, dynamic>> _handleSingleVideo(AssetEntity asset, Directory tempDir) async {
    final file = await asset.file;

    // 获取缩略图
    final data = await asset.thumbnailData;
    final thumbnailFile = await File(
      '${tempDir.path}/${DateTime.now().millisecondsSinceEpoch}.png',
    ).writeAsBytes(data!);

    return {
      "tempFilePath": '${Constant.localServerTempFileUrl}${file!.path}',
      "size": file.lengthSync(),
      "width": asset.width,
      "height": asset.height,
      "thumbTempFilePath": '${Constant.localServerTempFileUrl}${thumbnailFile.path}',
      "fileType": file.path.split('/').last.split('.').last,
    };
  }

  void setOrientationCmdFlag(bool orientationCmdFlag, String orientationCmdMessage) {
    emit(state.copyWith(orientationCmdFlag: orientationCmdFlag, orientationCmdMessage: orientationCmdMessage));
  }

  void getOrientation(BuildContext context) async {
    final Map<String, dynamic> data = json.decode(state.orientationCmdMessage);
    H5Message h5Message = H5Message.fromJson(data);

    setOrientationCmdFlag(false, '');

    final orientation = MediaQuery.of(context).orientation;

    var resp = {
      'unique': h5Message.unique,
      'cmd': h5Message.cmd,
      'data': {'orientation': orientation == Orientation.portrait ? "portrait" : "landscape"},
      'errMsg': '',
    };
    _sendResponse(resp);
  }

  void setWindowInfoCmdFlag(bool windowInfoCmdFlag, String windowInfoCmdMessage) {
    emit(state.copyWith(windowInfoCmdFlag: windowInfoCmdFlag, windowInfoCmdMessage: windowInfoCmdMessage));
  }

  void getWindowInfo(BuildContext context) async {
    final Map<String, dynamic> data = json.decode(state.windowInfoCmdMessage);
    H5Message h5Message = H5Message.fromJson(data);

    setWindowInfoCmdFlag(false, '');

    final mediaQuery = MediaQuery.of(context);
    final viewPadding = mediaQuery.viewPadding;
    final size = mediaQuery.size;
    final safeArea = mediaQuery.padding;
    final devicePixelRatio = mediaQuery.devicePixelRatio;

    // 计算安全区域坐标
    final safeAreaLeft = safeArea.left;
    final safeAreaRight = size.width - safeArea.right;
    final safeAreaTop = safeArea.top;
    final safeAreaBottom = size.height - safeArea.bottom;
    final safeAreaWidth = size.width - safeArea.horizontal;
    final safeAreaHeight = size.height - safeArea.vertical;

    final windowInfo = {
      'pixelRatio': devicePixelRatio,
      'screenWidth': size.width * devicePixelRatio,
      'screenHeight': size.height * devicePixelRatio,
      'windowWidth': size.width,
      'windowHeight': size.height,
      'statusBarHeight': viewPadding.top,
      'screenTop': 0, // Flutter中通常不使用此值，设为0
      'safeArea': {
        'left': safeAreaLeft,
        'right': safeAreaRight,
        'top': safeAreaTop,
        'bottom': safeAreaBottom,
        'width': safeAreaWidth,
        'height': safeAreaHeight,
      },
    };

    var resp = {'unique': h5Message.unique, 'cmd': h5Message.cmd, 'data': windowInfo, 'errMsg': ''};
    _sendResponse(resp);
  }

  @override
  Future<void> close() async {
    _server?.close();
    // _fluwx.removeSubscriber(_responseListener);

    await _playerService?.close();
    await _recorderService?.close();

    return super.close();
  }
}