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: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;

  /// 录音
  // final bool recorderIsInit;
  //final int recordState;
  // final String recordPath;

  /// 播放
  // final bool playerIsInit;
  //final int playState;
  // final String playId;

  /// 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.recorderIsInit = false,
    // this.recordState = 0,
    // this.recordPath = '',
    // this.playerIsInit = false,
    // this.playState = 0,
    // this.playId = '',
    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? recorderIsInit,
    // int? recordState,
    // String? recordPath,
    // bool? playerIsInit,
    // int? playState,
    // String? playId,
    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,
      // recorderIsInit: recorderIsInit ?? this.recorderIsInit,
      // recordState: recordState ?? this.recordState,
      // recordPath: recordPath ?? this.recordPath,
      // playerIsInit: playerIsInit ?? this.playerIsInit,
      // playState: playState ?? this.playState,
      // playId: playId ?? this.playId,
      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,
        // recorderIsInit,
        // recordState,
        // recordPath,
        // playerIsInit,
        // playState,
        // playId,
        orientationCmdFlag,
        orientationCmdMessage,
        windowInfoCmdFlag,
        windowInfoCmdMessage,
        chooseImageCmdFlag,
        chooseImageCmdMessage,
        chooseVideoCmdFlag,
        chooseVideoCmdMessage,
      ];
}

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

  // FlutterSoundRecorder? _recorder;
  // StreamSubscription? _recorderSubscription;
  // FlutterSoundPlayer? _player;
  // StreamSubscription? _playerSubscription;
  // int? _playDuration;

  WebViewController get controller => _controller;

  // FlutterSoundRecorder? get recorder => _recorder;

  // FlutterSoundPlayer? get player => _player;

  WebCubit(super.initialState) {
    // 消息处理器
    _dispatcher = MessageDispatcher();

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

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

            // 页面加载完成时，清空录音和音频（如果有打开过）
            // await clearRecording();
            // await clearAudio();

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

    // 启动本地服务器，并加载HTML
    _startLocalServerAndLoadHtml();

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

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

    final String serverUrl;
    if (state.sessionCode == null || state.sessionCode == '') {
      // serverUrl = '${Constant.localServerUrl}/index.html';
      serverUrl = '${Constant.localServerTestFileUrl}/login.html';
      // serverUrl = '${Constant.localServerTestFileUrl}/test2.html';
    } else {
      // serverUrl =
      //     'http://${state.ip}:${_server.port}/index.html#/h5/login/pages/applogin?sessionCode=${state.sessionCode}&userCode=${state.userCode}&classCode=${state.classCode}&userType=${state.userType}&stuId=${state.stuId}';

      // IM 登录
      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 登录失败");
        }
      }

      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));
  }

  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, title: '班小二测试', opIcon: 'none'));
    emit(state.copyWith(loaded: true, title: '班小二测试'));
  }

  // 测试
  void resetLoading() {
    emit(state.copyWith(loaded: false, title: '界面加载中...'));
  }

  //测试
  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);
  }

  /// 录音初始化
  // Future<bool> _initRecorder(int maxDuration) async {
  //   // 请求麦克风权限
  //   var status = await Permission.microphone.request();
  //   if (status != PermissionStatus.granted) {
  //     throw RecordingPermissionException('no auth');
  //   }
  //
  //   // if (state.recordState != 0) {
  //   //   return false;
  //   // }
  //
  //   final directory = await getTemporaryDirectory();
  //   // String recordPath = '${directory.path}/${Uuid().v5(Namespace.url.value, 'www.banxiaoer.com')}_record.aac';
  //   // String recordPath = '${directory.path}/${Uuid().v4()}_record.aac';
  //   String recordPath = '${directory.path}/${Uuid().v4()}_record.mp4';
  //
  //   // 打开录音器
  //   try {
  //     final recorder = FlutterSoundRecorder();
  //     _recorder = (await recorder.openRecorder())!;
  //
  //     if (maxDuration > 0) {
  //       // 设置进度回调间隔
  //       await _recorder!.setSubscriptionDuration(Duration(seconds: 1));
  //       // 监听录制进度
  //       _recorder!.onProgress!.listen((event) {
  //         // event.duration 包含当前录制时长
  //         // event.decibels 包含当前音量级别
  //         print('录制进度: ${event.duration.inSeconds}秒, 音量: ${event.decibels}');
  //         /*if (event.duration.inSeconds >= maxDuration) {
  //           stopRecording();
  //         }*/
  //       });
  //     }
  //
  //     emit(state.copyWith(recorderIsInit: true, recordPath: recordPath));
  //     return true;
  //   } catch (e) {
  //     throw Exception('打开录音器失败！');
  //   }
  // }
  //
  // /// 开始录音
  // Future<bool> startRecording(int maxDuration) async {
  //   if (state.recorderIsInit) {
  //     return false;
  //   }
  //
  //   // if (state.recordState != 0) {
  //   //   return false;
  //   // }
  //
  //   if (_recorder != null && !_recorder!.isStopped) {
  //     return false;
  //   }
  //
  //   final initResult = await _initRecorder(maxDuration);
  //   if (!initResult) {
  //     return false;
  //   }
  //
  //   await _recorder!.startRecorder(toFile: state.recordPath, codec: Codec.aacMP4);
  //   // emit(state.copyWith(recordState: 1));
  //   return true;
  // }
  //
  // /// 暂停录音
  // Future<bool> pauseRecording() async {
  //   if (!state.recorderIsInit) {
  //     return false;
  //   }
  //
  //   // if (state.recordState != 1) {
  //   //   return false;
  //   // }
  //
  //   if (!_recorder!.isRecording) {
  //     return false;
  //   }
  //
  //   await _recorder!.pauseRecorder();
  //   // emit(state.copyWith(recordState: 2));
  //   return true;
  // }
  //
  // /// 恢复录音
  // Future<bool> resumeRecording() async {
  //   if (!state.recorderIsInit) {
  //     return false;
  //   }
  //
  //   // if (state.recordState != 2) {
  //   //   return false;
  //   // }
  //
  //   if (!_recorder!.isPaused) {
  //     return false;
  //   }
  //
  //   await _recorder!.resumeRecorder();
  //   // emit(state.copyWith(recordState: 1));
  //   return true;
  // }
  //
  // /// 停止录音
  // Future<Map<String, dynamic>> stopRecording() async {
  //   if (!state.recorderIsInit) {
  //     throw Exception("录音器未初始化");
  //   }
  //
  //   // if (state.recordState != 1 && state.recordState != 2) {
  //   //   throw Exception("录音器状态错误");
  //   // }
  //
  //   if (!_recorder!.isRecording && !_recorder!.isPaused) {
  //     throw Exception("录音器状态错误");
  //   }
  //
  //   var url = await _recorder!.stopRecorder();
  //   await _recorder!.closeRecorder();
  //   _recorder = null;
  //   // emit(state.copyWith(recorderIsInit: false, recordState: 0, recordPath: ''));
  //   emit(state.copyWith(recorderIsInit: false, recordPath: ''));
  //
  //   if (url == null || url.isEmpty) {
  //     throw Exception("录音失败");
  //   }
  //
  //   var tempDir = await getTemporaryDirectory();
  //   String fileName = path.basenameWithoutExtension(url);
  //   String mp3Path = '${tempDir.path}/$fileName.mp3';
  //
  //   // var convertResult = await compute(AudioUtil.convertAacToMp3, {'accPath': url, 'mp3Path': mp3Path});
  //   var convertResult = await AudioUtil.convertAacToMp3({'accPath': url, 'mp3Path': mp3Path});
  //   if (!convertResult) {
  //     throw Exception("录音转码失败");
  //   }
  //
  //   // 时长
  //   // var duration = await AudioUtil.getAudioDuration(mp3Path);
  //   var duration = await AudioUtil.getAudioDuration(url);
  //
  //   return {
  //     'tempFilePath': '${Constant.localServerTempFileUrl}$mp3Path',
  //     'duration': duration.inSeconds,
  //   };
  // }
  //
  // /// 清空录音
  // Future<bool> clearRecording() async {
  //   // await _recorder!.stopRecorder();
  //   try {
  //     await _recorder?.closeRecorder();
  //     _recorder = null;
  //   } catch (e) {
  //     print(e);
  //   }
  //   // emit(state.copyWith(recorderIsInit: false, recordState: 0, recordPath: ''));
  //   emit(state.copyWith(recorderIsInit: false, recordPath: ''));
  //   return true;
  // }

  /// 播放初始化
  // Future<bool> _initPlayer(String playId) async {
  //   // 打开播放器
  //   try {
  //     final player = FlutterSoundPlayer();
  //     _player = (await player.openPlayer())!;
  //     _player!.setSpeed(2); // 播放速度，默认1
  //
  //     // 播放进度回调
  //     _player!.setSubscriptionDuration(Duration(seconds: 1));
  //     _playerSubscription = _player!.onProgress!.listen((event) {
  //       print('播放回调--------- ${event.duration.inSeconds} ${event.position.inSeconds}');
  //
  //       _playDuration = event.duration.inSeconds;
  //       var playPosition = event.position.inSeconds;
  //
  //       var data = {'playId': state.playId, 'duration': _playDuration, 'currentTime': playPosition};
  //       var h5Cmd = {
  //         'unique': '',
  //         'cmd': 'audioProgress',
  //         'data': data,
  //         'errMsg': '',
  //       };
  //       _sendResponse(h5Cmd);
  //     });
  //
  //     emit(state.copyWith(playerIsInit: true, playId: playId));
  //     return true;
  //   } catch (e) {
  //     throw Exception('打开播放器失败！');
  //   }
  // }
  //
  // /// 播放音频
  // Future<bool> playAudio(String url, int seek, String playId) async {
  //   if (!state.playerIsInit) {
  //     final initResult = await _initPlayer(playId);
  //     if (!initResult) {
  //       return false;
  //     }
  //   }
  //
  //   await _player!.startPlayer(
  //     fromURI: url,
  //     whenFinished: () async {
  //       await _player!.stopPlayer();
  //       // emit(state.copyWith(playState: 0));
  //
  //       // 补发一下全部进度
  //       var h5Cmd = {
  //         'unique': '',
  //         'cmd': 'audioProgress',
  //         'data': {'playId': state.playId, 'duration': _playDuration, 'currentTime': _playDuration},
  //         'errMsg': '',
  //       };
  //       _sendResponse(h5Cmd);
  //
  //       // 播放结束后，发送消息给客户端
  //       h5Cmd = {
  //         'unique': '',
  //         'cmd': 'audioEnd',
  //         'data': {'playId': state.playId},
  //         'errMsg': '',
  //       };
  //       _sendResponse(h5Cmd);
  //     },
  //   );
  //   if (seek != 0) {
  //     await seekAudio(seek);
  //   }
  //   // emit(state.copyWith(playState: 1));
  //   return true;
  // }
  //
  // /// 暂停播放
  // Future<bool> pauseAudio() async {
  //   if (!state.playerIsInit) {
  //     throw Exception("播放器未初始化");
  //   }
  //
  //   // if (state.playState != 1) {
  //   //   throw Exception("播放器状态错误");
  //   // }
  //
  //   if (!_player!.isPlaying) {
  //     throw Exception("播放器状态错误");
  //   }
  //
  //   await _player!.pausePlayer();
  //   // emit(state.copyWith(playState: 2));
  //   return true;
  // }
  //
  // /// 恢复播放
  // Future<bool> resumeAudio() async {
  //   if (!state.playerIsInit) {
  //     throw Exception("播放器未初始化");
  //   }
  //
  //   // if (state.playState != 2) {
  //   //   throw Exception("播放器状态错误");
  //   // }
  //
  //   if (!_player!.isPaused) {
  //     throw Exception("播放器状态错误");
  //   }
  //
  //   await _player!.resumePlayer();
  //   // emit(state.copyWith(playState: 1));
  //   return true;
  // }
  //
  // /// 跳转播放
  // Future<bool> seekAudio(int seek) async {
  //   if (!state.playerIsInit) {
  //     throw Exception("播放器未初始化");
  //   }
  //
  //   await _player!.seekToPlayer(Duration(seconds: seek));
  //   // emit(state.copyWith(playState: 1));
  //   return true;
  // }
  //
  // /// 停止播放
  // Future<bool> stopAudio() async {
  //   if (!state.playerIsInit) {
  //     throw Exception("播放器未初始化");
  //   }
  //
  //   // if (state.playState != 1 && state.playState != 2) {
  //   //   throw Exception("播放器状态错误");
  //   // }
  //
  //   if (!_player!.isPlaying && !_player!.isPaused) {
  //     throw Exception("播放器状态错误");
  //   }
  //
  //   await _player!.stopPlayer();
  //   // emit(state.copyWith(playState: 0));
  //   return true;
  // }
  //
  // /// 清空播放
  // Future<bool> clearAudio() async {
  //   try {
  //     await _player?.closePlayer();
  //     _player = null;
  //     await _playerSubscription?.cancel();
  //     _playerSubscription = null;
  //     _playDuration = null;
  //   } catch (e) {
  //     print(e);
  //   }
  //   // emit(state.copyWith(playerIsInit: false, playState: 0, playId: ''));
  //   emit(state.copyWith(playerIsInit: false, playId: ''));
  //   return true;
  // }

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

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

    // try {
    //   await _recorder?.closeRecorder();
    //   _recorder = null;
    // } catch (e) {
    //   print(e);
    // }

    // try {
    //   await _player?.closePlayer();
    //   _player = null;
    //   await _playerSubscription?.cancel();
    //   _playerSubscription = null;
    //   _playDuration = null;
    // } catch (e) {
    //   print(e);
    // }

    return super.close();
  }
}