feat: 直播弹幕2

lib/pages/danmaku/controller.dart

@@ -2,8 +2,9 @@ import 'package:pilipala/http/danmaku.dart';
 import 'package:pilipala/models/danmaku/dm.pb.dart';
 
 class PlDanmakuController {
-  PlDanmakuController(this.cid);
+  PlDanmakuController(this.cid, this.type);
   final int cid;
+  final String type;
   Map<int, List<DanmakuElem>> dmSegMap = {};
   // 已请求的段落标记
   List<bool> requestedSeg = [];

lib/pages/danmaku/view.dart

@@ -12,11 +12,15 @@ import 'package:pilipala/utils/storage.dart';
 class PlDanmaku extends StatefulWidget {
   final int cid;
   final PlPlayerController playerController;
+  final String type;
+  final Function(DanmakuController)? createdController;
 
   const PlDanmaku({
     super.key,
     required this.cid,
     required this.playerController,
+    this.type = 'video',
+    this.createdController,
   });
 
   @override
@@ -43,9 +47,9 @@ class _PlDanmakuState extends State<PlDanmaku> {
     super.initState();
     enableShowDanmaku =
         setting.get(SettingBoxKey.enableShowDanmaku, defaultValue: false);
-    _plDanmakuController = PlDanmakuController(widget.cid);
-    if (mounted) {
-      playerController = widget.playerController;
+    _plDanmakuController = PlDanmakuController(widget.cid, widget.type);
+    playerController = widget.playerController;
+    if (mounted && widget.type == 'video') {
       if (enableShowDanmaku || playerController.isOpenDanmu.value) {
         _plDanmakuController.initiate(
             playerController.duration.value.inMilliseconds,
@@ -55,13 +59,15 @@ class _PlDanmakuState extends State<PlDanmaku> {
         ..addStatusLister(playerListener)
         ..addPositionListener(videoPositionListen);
     }
-    playerController.isOpenDanmu.listen((p0) {
-      if (p0 && !_plDanmakuController.initiated) {
-        _plDanmakuController.initiate(
-            playerController.duration.value.inMilliseconds,
-            playerController.position.value.inMilliseconds);
-      }
-    });
+    if (widget.type == 'video') {
+      playerController.isOpenDanmu.listen((p0) {
+        if (p0 && !_plDanmakuController.initiated) {
+          _plDanmakuController.initiate(
+              playerController.duration.value.inMilliseconds,
+              playerController.position.value.inMilliseconds);
+        }
+      });
+    }
     blockTypes = playerController.blockTypes;
     showArea = playerController.showArea;
     opacityVal = playerController.opacityVal;
@@ -128,6 +134,7 @@ class _PlDanmakuState extends State<PlDanmaku> {
           child: DanmakuView(
             createdController: (DanmakuController e) async {
               playerController.danmakuController = _controller = e;
+              widget.createdController?.call(e);
             },
             option: DanmakuOption(
               fontSize: 15 * fontSizeVal,
@@ -136,8 +143,7 @@ class _PlDanmakuState extends State<PlDanmaku> {
               hideTop: blockTypes.contains(5),
               hideScroll: blockTypes.contains(2),
               hideBottom: blockTypes.contains(4),
-              duration:
-                  danmakuDurationVal / playerController.playbackSpeed,
+              duration: danmakuDurationVal / playerController.playbackSpeed,
               strokeWidth: strokeWidth,
               // initDuration /
               //     (danmakuSpeedVal * widget.playerController.playbackSpeed),

lib/pages/live_room/controller.dart

@@ -1,7 +1,9 @@
 import 'dart:convert';
+import 'dart:ui';
 import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
 import 'package:get/get.dart';
 import 'package:hive/hive.dart';
+import 'package:ns_danmaku/ns_danmaku.dart';
 import 'package:pilipala/http/constants.dart';
 import 'package:pilipala/http/init.dart';
 import 'package:pilipala/http/live.dart';
@@ -37,6 +39,7 @@ class LiveRoomController extends GetxController {
   String token = '';
   // 弹幕消息列表
   RxList<LiveMessageModel> messageList = <LiveMessageModel>[].obs;
+  DanmakuController? danmakuController;
 
   @override
   void onInit() {
@@ -172,9 +175,28 @@ class LiveRoomController extends GetxController {
         final List<LiveMessageModel>? liveMsg =
             LiveUtils.decodeMessage(message);
         if (liveMsg != null) {
-          messageList.addAll(liveMsg
-              .where((msg) => msg.type == LiveMessageType.chat)
-              .toList());
+          // 过滤出聊天消息
+          var chatMessages =
+              liveMsg.where((msg) => msg.type == LiveMessageType.chat).toList();
+
+          // 添加到 messageList
+          messageList.addAll(chatMessages);
+
+          // 将 chatMessages 转换为 danmakuItems 列表
+          List<DanmakuItem> danmakuItems = chatMessages.map<DanmakuItem>((e) {
+            return DanmakuItem(
+              e.message ?? '',
+              color: Color.fromARGB(
+                255,
+                e.color.r,
+                e.color.g,
+                e.color.b,
+              ),
+            );
+          }).toList();
+
+          // 添加到 danmakuController
+          danmakuController?.addItems(danmakuItems);
         }
       },
       onErrorCb: (e) {

lib/pages/live_room/view.dart

@@ -7,6 +7,7 @@ import 'package:flutter/rendering.dart';
 import 'package:get/get.dart';
 import 'package:pilipala/common/widgets/network_img_layer.dart';
 import 'package:pilipala/models/live/message.dart';
+import 'package:pilipala/pages/danmaku/index.dart';
 import 'package:pilipala/plugin/pl_player/index.dart';
 
 import 'controller.dart';
@@ -22,7 +23,7 @@ class LiveRoomPage extends StatefulWidget {
 class _LiveRoomPageState extends State<LiveRoomPage>
     with TickerProviderStateMixin {
   final LiveRoomController _liveRoomController = Get.put(LiveRoomController());
-  PlPlayerController? plPlayerController;
+  late PlPlayerController plPlayerController;
   late Future? _futureBuilder;
   late Future? _futureBuilderFuture;
 
@@ -32,6 +33,7 @@ class _LiveRoomPageState extends State<LiveRoomPage>
   final ScrollController _scrollController = ScrollController();
   late AnimationController fabAnimationCtr;
   bool _shouldAutoScroll = true;
+  final int roomId = int.parse(Get.parameters['roomid']!);
 
   @override
   void initState() {
@@ -110,8 +112,9 @@ class _LiveRoomPageState extends State<LiveRoomPage>
       future: _futureBuilderFuture,
       builder: (BuildContext context, AsyncSnapshot snapshot) {
         if (snapshot.hasData && snapshot.data['status']) {
+          plPlayerController = _liveRoomController.plPlayerController;
           return PLVideoPlayer(
-            controller: plPlayerController!,
+            controller: plPlayerController,
             bottomControl: BottomControl(
               controller: plPlayerController,
               liveRoomCtr: _liveRoomController,
@@ -122,6 +125,14 @@ class _LiveRoomPageState extends State<LiveRoomPage>
                 });
               },
             ),
+            danmuWidget: PlDanmaku(
+              cid: roomId,
+              playerController: plPlayerController,
+              type: 'live',
+              createdController: (e) {
+                _liveRoomController.danmakuController = e;
+              },
+            ),
           );
         } else {
           return const SizedBox();