mirror of
https://github.com/HChaZZY/PiliPlus.git
synced 2025-12-06 09:13:48 +08:00
289 lines
8.8 KiB
Dart
289 lines
8.8 KiB
Dart
import 'dart:convert';
|
|
|
|
import 'package:PiliPlus/http/video.dart';
|
|
import 'package:PiliPlus/models/live/danmu_info.dart';
|
|
import 'package:PiliPlus/models/live/quality.dart';
|
|
import 'package:PiliPlus/pages/mine/controller.dart';
|
|
import 'package:PiliPlus/pages/video/detail/widgets/send_danmaku_panel.dart';
|
|
import 'package:PiliPlus/services/service_locator.dart';
|
|
import 'package:PiliPlus/tcp/live.dart';
|
|
import 'package:PiliPlus/utils/danmaku.dart';
|
|
import 'package:PiliPlus/utils/storage.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:flutter_smart_dialog/flutter_smart_dialog.dart';
|
|
import 'package:get/get.dart';
|
|
import 'package:PiliPlus/http/constants.dart';
|
|
import 'package:PiliPlus/http/live.dart';
|
|
import 'package:PiliPlus/models/live/room_info.dart';
|
|
import 'package:PiliPlus/plugin/pl_player/index.dart';
|
|
import 'package:get/get_navigation/src/dialog/dialog_route.dart';
|
|
import '../../models/live/room_info_h5.dart';
|
|
import '../../utils/video_utils.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<RoomInfoH5Model> roomInfoH5 = RoomInfoH5Model().obs;
|
|
|
|
RxList<dynamic> messages = [].obs;
|
|
RxBool disableAutoScroll = false.obs;
|
|
double? brightness;
|
|
DanmakuController? controller;
|
|
bool showDanmaku = true;
|
|
|
|
int? currentQn;
|
|
late List<Map> acceptQnList = <Map>[];
|
|
RxString currentQnDesc = ''.obs;
|
|
|
|
String? savedDanmaku;
|
|
|
|
late final isLogin = Accounts.main.isLogin;
|
|
|
|
@override
|
|
void onInit() {
|
|
super.onInit();
|
|
roomId = int.parse(Get.parameters['roomid']!);
|
|
if (Accounts.main.isLogin && !MineController.anonymity.value) {
|
|
VideoHttp.roomEntryAction(roomId: roomId);
|
|
}
|
|
}
|
|
|
|
playerInit(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
|
|
},
|
|
),
|
|
// 硬解
|
|
enableHA: true,
|
|
autoplay: true,
|
|
direction: isPortrait.value ? 'vertical' : 'horizontal',
|
|
);
|
|
}
|
|
|
|
final RxBool isPortrait = false.obs;
|
|
|
|
Future 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']) {
|
|
isPortrait.value = res['data'].isPortrait ?? false;
|
|
List<CodecItem> codec =
|
|
res['data'].playurlInfo.playurl.stream.first.format.first.codec;
|
|
CodecItem item = codec.first;
|
|
// 以服务端返回的码率为准
|
|
currentQn = item.currentQn!;
|
|
List acceptQn = item.acceptQn!;
|
|
acceptQnList = 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;
|
|
}
|
|
}
|
|
|
|
void setVolume(value) {
|
|
if (value == 0) {
|
|
// 设置音量
|
|
volumeOff.value = false;
|
|
} else {
|
|
// 取消音量
|
|
volume = value;
|
|
volumeOff.value = true;
|
|
}
|
|
}
|
|
|
|
Future queryLiveInfoH5() async {
|
|
var res = await LiveHttp.liveRoomInfoH5(roomId: roomId);
|
|
if (res['status']) {
|
|
roomInfoH5.value = res['data'];
|
|
videoPlayerServiceHandler.onVideoDetailChange(
|
|
roomInfoH5.value,
|
|
roomId,
|
|
heroTag,
|
|
);
|
|
}
|
|
return res;
|
|
}
|
|
|
|
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']) {
|
|
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((v) {
|
|
if (v['status']) {
|
|
LiveDanmakuInfo info = v['data'];
|
|
// logger.d("info => $info");
|
|
List<String> servers = [];
|
|
for (final host in info.data.hostList) {
|
|
servers.add('wss://${host.host}:${host.wssPort}/sub');
|
|
}
|
|
msgStream = LiveMessageStream(
|
|
streamToken: info.data.token,
|
|
roomId: roomId,
|
|
uid: Accounts.main.mid,
|
|
servers: servers,
|
|
);
|
|
msgStream?.addEventListener((obj) {
|
|
if (obj['cmd'] == 'DANMU_MSG') {
|
|
// logger.i(' 原始弹幕消息 ======> ${jsonEncode(obj)}');
|
|
messages.add({
|
|
'name': obj['info'][0][15]['user']['base']['name'],
|
|
'uid': obj['info'][0][15]['user']['uid'],
|
|
'text': obj['info'][1],
|
|
'emots': jsonDecode(obj['info'][0][15]['extra'])['emots'],
|
|
'uemote': obj['info'][0][13],
|
|
});
|
|
Map json = jsonDecode(obj['info'][0][15]['extra']);
|
|
if (showDanmaku) {
|
|
controller?.addDanmaku(
|
|
DanmakuContentItem(
|
|
json['content'],
|
|
color: DmUtils.decimalToColor(json['color']),
|
|
type: DmUtils.getPosition(json['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);
|
|
scrollController.dispose();
|
|
super.onClose();
|
|
}
|
|
|
|
// 修改画质
|
|
void changeQn(int qn) async {
|
|
if (currentQn == qn) {
|
|
return;
|
|
}
|
|
currentQn = qn;
|
|
currentQnDesc.value = LiveQuality.values
|
|
.firstWhere((element) => element.code == currentQn)
|
|
.description;
|
|
await queryLiveInfo();
|
|
}
|
|
|
|
void onSendDanmaku() {
|
|
if (!isLogin) {
|
|
SmartDialog.showToast('未登录');
|
|
return;
|
|
}
|
|
Navigator.of(Get.context!).push(
|
|
GetDialogRoute(
|
|
pageBuilder: (buildContext, animation, secondaryAnimation) {
|
|
return SendDanmakuPanel(
|
|
roomId: roomId,
|
|
initialValue: savedDanmaku,
|
|
onSave: (danmaku) => savedDanmaku = danmaku,
|
|
callback: (danmakuModel) {
|
|
savedDanmaku = null;
|
|
plPlayerController.danmakuController?.addDanmaku(danmakuModel);
|
|
},
|
|
darkVideoPage: false,
|
|
);
|
|
},
|
|
transitionDuration: const Duration(milliseconds: 500),
|
|
transitionBuilder: (context, animation, secondaryAnimation, child) {
|
|
const begin = Offset(0.0, 1.0);
|
|
const end = Offset.zero;
|
|
const curve = Curves.linear;
|
|
|
|
var tween =
|
|
Tween(begin: begin, end: end).chain(CurveTween(curve: curve));
|
|
|
|
return SlideTransition(
|
|
position: animation.drive(tween),
|
|
child: child,
|
|
);
|
|
},
|
|
),
|
|
);
|
|
}
|
|
}
|