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

import 'package:PiliPlus/http/constants.dart';
import 'package:PiliPlus/http/live.dart';
import 'package:PiliPlus/http/video.dart';
import 'package:PiliPlus/models/common/video/live_quality.dart';
import 'package:PiliPlus/models_new/live/live_dm_info/data.dart';
import 'package:PiliPlus/models_new/live/live_room_info_h5/data.dart';
import 'package:PiliPlus/models_new/live/live_room_play_info/codec.dart';
import 'package:PiliPlus/models_new/live/live_room_play_info/data.dart';
import 'package:PiliPlus/pages/mine/controller.dart';
import 'package:PiliPlus/plugin/pl_player/controller.dart';
import 'package:PiliPlus/plugin/pl_player/models/data_source.dart';
import 'package:PiliPlus/services/service_locator.dart';
import 'package:PiliPlus/tcp/live.dart';
import 'package:PiliPlus/utils/danmaku_utils.dart';
import 'package:PiliPlus/utils/extension.dart';
import 'package:PiliPlus/utils/storage.dart';
import 'package:PiliPlus/utils/video_utils.dart';
import 'package:canvas_danmaku/canvas_danmaku.dart';
import 'package:connectivity_plus/connectivity_plus.dart';
import 'package:flutter/material.dart';
import 'package:flutter/rendering.dart';
import 'package:get/get.dart';

class LiveRoomController extends GetxController {
  LiveRoomController(this.heroTag);
  final String heroTag;
  late int roomId;
  dynamic liveItem;
  double volume = 0.0;
  // 静音状态
  RxBool volumeOff = false.obs;
  PlPlayerController plPlayerController =
      PlPlayerController.getInstance(videoType: 'live');
  Rx<RoomInfoH5Data?> roomInfoH5 = Rx<RoomInfoH5Data?>(null);

  RxList<dynamic> messages = [].obs;
  RxBool disableAutoScroll = false.obs;
  double? brightness;
  DanmakuController? controller;
  bool showDanmaku = true;

  int? currentQn;
  late List<({int code, String desc})> acceptQnList = [];
  RxString currentQnDesc = ''.obs;

  String? savedDanmaku;

  late final isLogin = Accounts.main.isLogin;

  @override
  void onInit() {
    super.onInit();
    roomId = int.parse(Get.parameters['roomid']!);
    queryLiveInfoH5();
    if (Accounts.main.isLogin && !MineController.anonymity.value) {
      VideoHttp.roomEntryAction(roomId: roomId);
    }
  }

  Future<void> playerInit(String source) async {
    await plPlayerController.setDataSource(
      DataSource(
        videoSource: source,
        audioSource: null,
        type: DataSourceType.network,
        httpHeaders: {
          'user-agent':
              'Mozilla/5.0 (Macintosh; Intel Mac OS X 13_3_1) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.4 Safari/605.1.15',
          'referer': HttpString.baseUrl
        },
      ),
      autoplay: true,
      direction: isPortrait.value ? 'vertical' : 'horizontal',
    );
  }

  final RxBool isPortrait = false.obs;

  Future<void> queryLiveInfo() async {
    if (currentQn == null) {
      await Connectivity().checkConnectivity().then((res) {
        currentQn = res.contains(ConnectivityResult.wifi)
            ? GStorage.liveQuality
            : GStorage.liveQualityCellular;
      });
    }
    var res = await LiveHttp.liveRoomInfo(roomId: roomId, qn: currentQn);
    if (res['status']) {
      RoomPlayInfoData data = res['data'];
      if (data.liveStatus != 1) {
        _dialog(title: '当前直播间未开播');
        return;
      }
      if (data.roomId != null) {
        roomId = data.roomId!;
      }
      isPortrait.value = data.isPortrait ?? false;
      List<CodecItem> codec =
          data.playurlInfo!.playurl!.stream!.first.format!.first.codec!;
      CodecItem item = codec.first;
      // 以服务端返回的码率为准
      currentQn = item.currentQn!;
      acceptQnList = item.acceptQn!.map((e) {
        return (
          code: e,
          desc: LiveQuality.values
              .firstWhere((element) => element.code == e)
              .description,
        );
      }).toList();
      currentQnDesc.value = LiveQuality.values
          .firstWhere((element) => element.code == currentQn)
          .description;
      String videoUrl = VideoUtils.getCdnUrl(item);
      await playerInit(videoUrl);
      return res;
    }
  }

  Future<void> queryLiveInfoH5() async {
    var res = await LiveHttp.liveRoomInfoH5(roomId: roomId);
    if (res['status']) {
      roomInfoH5.value = res['data'];
      videoPlayerServiceHandler.onVideoDetailChange(
        roomInfoH5.value,
        roomId,
        heroTag,
      );
    } else {
      if (res['msg'] != null) {
        _dialog(title: res['msg']);
      }
    }
  }

  void _dialog({
    required String title,
  }) {
    Get.dialog(
      AlertDialog(
        title: Text(title),
        actions: [
          TextButton(
            onPressed: Get.back,
            child: Text(
              '关闭',
              style: TextStyle(color: Get.theme.colorScheme.outline),
            ),
          ),
          TextButton(
            onPressed: () => Get
              ..back()
              ..back(),
            child: const Text('退出'),
          ),
        ],
      ),
    );
  }

  LiveMessageStream? msgStream;
  final ScrollController scrollController = ScrollController();

  void scrollToBottom() {
    if (disableAutoScroll.value) return;
    if (scrollController.hasClients) {
      scrollController.animateTo(
        scrollController.position.maxScrollExtent,
        duration: const Duration(milliseconds: 500),
        curve: Curves.linearToEaseOut,
      );
    }
  }

  void liveMsg() {
    if (messages.isEmpty) {
      LiveHttp.liveRoomDanmaPrefetch(roomId: roomId).then((v) {
        if (v['status']) {
          if ((v['data'] as List?)?.isNotEmpty == true) {
            messages.addAll((v['data'] as List)
                .map((obj) => {
                      'name': obj['user']['base']['name'],
                      'uid': obj['user']['uid'],
                      'text': obj['text'],
                      'emots': obj['emots'],
                      'uemote': obj['emoticon']['emoticon_unique'] != ""
                          ? obj['emoticon']
                          : null,
                    })
                .toList());
            WidgetsBinding.instance.addPostFrameCallback(
              (_) => scrollToBottom(),
            );
          }
        }
      });
    }
    LiveHttp.liveRoomGetDanmakuToken(roomId: roomId).then((res) {
      if (res['status']) {
        LiveDmInfoData info = res['data'];
        // logger.d("info => $info");
        if (info.hostList!.isNullOrEmpty) {
          return;
        }
        msgStream = LiveMessageStream(
          streamToken: info.token!,
          roomId: roomId,
          uid: Accounts.main.mid,
          servers: info.hostList!
              .map((host) => 'wss://${host.host}:${host.wssPort}/sub')
              .toList(),
        );
        msgStream?.addEventListener((obj) {
          if (obj['cmd'] == 'DANMU_MSG') {
            // logger.i(' 原始弹幕消息 ======> ${jsonEncode(obj)}');
            final info = obj['info'];
            final first = info[0];
            final content = first[15];
            final extra = jsonDecode(content['extra']);
            final user = content['user'];
            messages.add({
              'name': user['base']['name'],
              'uid': user['uid'],
              'text': info[1],
              'emots': extra['emots'],
              'uemote': first[13],
            });
            if (showDanmaku) {
              controller?.addDanmaku(
                DanmakuContentItem(
                  extra['content'],
                  color: DmUtils.decimalToColor(extra['color']),
                  type: DmUtils.getPosition(extra['mode']),
                ),
              );
              WidgetsBinding.instance
                  .addPostFrameCallback((_) => scrollToBottom());
            }
          }
        });
        msgStream?.init();
        scrollController.addListener(listener);
      }
    });
  }

  void listener() {
    if (scrollController.position.userScrollDirection ==
        ScrollDirection.forward) {
      disableAutoScroll.value = true;
    } else if (scrollController.position.userScrollDirection ==
        ScrollDirection.reverse) {
      final pos = scrollController.position;
      if (pos.maxScrollExtent - pos.pixels <= 100) {
        disableAutoScroll.value = false;
      }
    }
  }

  @override
  void onClose() {
    scrollController
      ..removeListener(listener)
      ..dispose();
    super.onClose();
  }

  // 修改画质
  FutureOr<void> changeQn(int qn) {
    if (currentQn == qn) {
      return null;
    }
    currentQn = qn;
    currentQnDesc.value = LiveQuality.values
        .firstWhere((element) => element.code == currentQn)
        .description;
    return queryLiveInfo();
  }
}