增加接入方法

lib/clx_flutter_message.dart

 import 'package:clx_flutter_message/util/string_util.dart';
 import 'package:clx_flutter_message/util/toast_util.dart';
 import 'package:flutter/material.dart';
-
 import 'clx_flutter_message_platform_interface.dart';
+import 'common/constant.dart';
 import 'core/model/message_config.dart';
 import 'core/model/message_data.dart';
+import 'core/notice/notice_manager.dart';
 import 'core/notification/notification_manager.dart';
 import 'core/socket/socket_io.dart';
 
@@ -16,7 +17,7 @@ class ClxFlutterMessage {
 
 MessageConfig messageConfig = MessageConfig();
 
-abstract class BaseMessageConfig with NotificationManager {
+abstract class BaseMessageConfig with NotificationManager, NoticeManager {
   //处理消息页面跳转
   void onJumpToMessagePage(String page, dynamic arguments);
 
@@ -39,7 +40,7 @@ abstract class BaseMessageConfig with NotificationManager {
   Future<bool> setMessageShowed(MessageData? message);
 
   //连接websocket 获取及时消息
-  Future<void> connectWebSocket() async {
+  Future<void> connectWebSocket(BuildContext context) async {
     String userNo = messageConfig.userKey;
     String url = messageConfig.webSocketUrl;
     String connectId = '${DateTime.now().microsecondsSinceEpoch}-$userNo';
@@ -59,11 +60,37 @@ abstract class BaseMessageConfig with NotificationManager {
 
     Socket.getInstance().onReceivedMessage = (message) {
       // 处理消息
+      _handleMessage(message, context);
     };
 
     await Socket.getInstance().connect(url, params, headers);
   }
 
+  // 处理socket消息
+  void _handleMessage(dynamic data, context) {
+    var mBizType = data?['bizType'];
+    if (mBizType == bizType) {
+      var body = MessageData.fromJson(data?['body']);
+      if (body.showType == '1') {
+        /// 首页公告
+        insertNotice(body);
+      } else if (body.showType == '2') {
+        /// 全局通知
+        insertNotification(body);
+        showNotification(context);
+      }
+    } else {
+      debugPrint('未知消息类型');
+      debugPrint(data.toString());
+    }
+  }
+
+  close() async {
+    clear();
+    clearNoticeDialog();
+    return await Socket.getInstance().close();
+  }
+
   // 处理消息跳转对应页面
   void gotoDealMessage(MessageData? message) {
     if (message?.canHand != true) {
@@ -97,7 +124,7 @@ abstract class BaseMessageConfig with NotificationManager {
   }
 
   //刷新消息、获取未处理消息，重新连接websocket
-  void refreshMessage(BuildContext context) {
+  Future<void> refreshMessage(BuildContext context) async {
     // 校验消息相关配置字段
     if (StringUtil.isEmpty(messageConfig.userKey)) {
       ToastUtils.showCenter("userNo不能为空");
@@ -124,9 +151,15 @@ abstract class BaseMessageConfig with NotificationManager {
       ToastUtils.showCenter("webSocketUrl不能为空");
       return;
     }
+    connectWebSocket(context);
+
+    List<MessageData> nList = await getUnReadMessage();
+    List<MessageData> aList = await getUnReadNotice();
+
+    // 处理消息
+    setNotification(nList);
+    // 处理公告
+    setNotice(aList);
 
-    getUnReadMessage();
-    getUnReadNotice();
-    connectWebSocket();
   }
 }

lib/common/constant.dart

@@ -4,8 +4,6 @@ const btnBgColor = Color(0xFF73BC8B);
 const Color overlayColor = Color(0x33FFFFFF);
 const Color appMain = Color(0xFF73BC8B);
 
-const String companyNo = "待定";
 
-const String inAppAccessKey = "待定";
+const String bizType = "in_app";
 
-const String socketAddress = "待定";

lib/common/message_config_interface.dart

-
-
-/// 消息组件配置
-abstract class MessageConfig {
-  /// 消息组件配置
-  const MessageConfig();
-
-
-  /// 消息跳转页面配置方法
-  void onJumpToMessagePage(String page, dynamic arguments);
-
-
-
-}
\ No newline at end of file

lib/core/message_deal.dart

-
-
-mixin MessageDeal {
-  
-
-  
-  
-}

lib/core/notice/notice_dialog_widget.dart

@@ -202,7 +202,7 @@ class NoticeDialogWidgetController extends GetxController {
   /// 插入公告
   void insertNotice(MessageData data) {
     _insertNode(data);
-    update();
+    _initData();
   }
 
   /// 处理公告
@@ -224,13 +224,13 @@ class NoticeDialogWidgetController extends GetxController {
 
     /// 隐藏当前的
     showDialog = false;
-    update();
+    _initData();
 
     /// 显示下一个
     if (headNode != null) {
       Future.delayed(const Duration(milliseconds: 300)).then((value) {
         showDialog = true;
-        update();
+        _initData();
       });
     }
   }
@@ -240,13 +240,13 @@ class NoticeDialogWidgetController extends GetxController {
       _insertNode(MessageData.fromJson(element));
     }
 
-    update();
+    _initData();
   }
 
   void clear() {
     headNode = null;
     showDialog = false;
-    update();
+    _initData();
   }
 
   void ignore() {
@@ -261,19 +261,9 @@ class NoticeDialogWidgetController extends GetxController {
     next();
   }
 
-  // @override
-  // void onInit() {
-  //   super.onInit();
-  // }
-
   @override
   void onReady() {
     super.onReady();
     _initData();
   }
-
-  // @override
-  // void onClose() {
-  //   super.onClose();
-  // }
 }

lib/core/notice/notice_manager.dart

+import 'package:clx_flutter_message/core/notice/notice_dialog_widget.dart';
+import 'package:clx_flutter_message/util/extension.dart';
+
+import '../model/message_data.dart';
+
+mixin NoticeManager {
+  final NoticeDialogWidgetController? _controller =
+      findOtherLogic<NoticeDialogWidgetController>();
+
+  void insertNotice(MessageData data) {
+    _controller?.insertNotice(data);
+  }
+
+  void clearNoticeDialog() {
+    _controller?.clear();
+  }
+
+  void setNotice(List<dynamic> data) {
+    _controller?.setNotice(data);
+  }
+}

lib/core/notification/note/controller.dart

-import 'package:get/get.dart';
-
-class NoteController extends GetxController {
-  NoteController();
-
-  _initData() {
-    update(["note"]);
-  }
-
-  void onTap() {}
-
-  // @override
-  // void onInit() {
-  //   super.onInit();
-  // }
-
-  @override
-  void onReady() {
-    super.onReady();
-    _initData();
-  }
-
-  // @override
-  // void onClose() {
-  //   super.onClose();
-  // }
-}

lib/core/notification/note/index.dart

-library note;
-
-export './controller.dart';
-export './view.dart';

lib/core/notification/note/view.dart

-import 'package:flutter/material.dart';
-import 'package:get/get.dart';
-
-import 'index.dart';
-
-class NotePage extends GetView<NoteController> {
-  const NotePage({super.key});
-
-  // 主视图
-  Widget _buildView() {
-    return const Center(
-      child: Text("NotePage"),
-    );
-  }
-
-  @override
-  Widget build(BuildContext context) {
-    return GetBuilder<NoteController>(
-      init: NoteController(),
-      id: "note",
-      builder: (_) {
-        return Scaffold(
-          appBar: AppBar(title: const Text("note")),
-          body: SafeArea(
-            child: _buildView(),
-          ),
-        );
-      },
-    );
-  }
-}

lib/core/notification/notification_layout/notification_layout_widget.dart

@@ -174,10 +174,6 @@ class NotificationLayoutController extends GetxController {
     update();
   }
 
-  // @override
-  // void onInit() {
-  //   super.onInit();
-  // }
 
   @override
   void onReady() {
@@ -185,8 +181,4 @@ class NotificationLayoutController extends GetxController {
     _initData();
   }
 
-  // @override
-  // void onClose() {
-  //   super.onClose();
-  // }
 }

lib/util/extension.dart

+
+import 'package:get/get.dart';
+
+S? findOtherLogic<S>({String? tag}) {
+  if (Get.isRegistered<S>(tag: tag)) {
+    return Get.find<S>(tag: tag);
+  }
+  return null;
+}