火灾报警改为使用web socket触发弹窗

lib/main.dart

@@ -1,6 +1,9 @@
 // Flutter imports:
+
 import 'package:aku_community_manager/provider/message_provider.dart';
 import 'package:aku_community_manager/tools/user_tool.dart';
+import 'package:aku_community_manager/utils/websocket/fier_dialog.dart';
+import 'package:aku_community_manager/utils/websocket/web_socket_util.dart';
 import 'package:flutter/cupertino.dart';
 import 'package:flutter/material.dart';
 
@@ -26,6 +29,13 @@ void main() async {
   JPush jpush = new JPush();
   const isProduct = const bool.fromEnvironment('ISPRODUCT');
   DevUtil.setDev(!isProduct);
+  WebSocketUtil().initWebSocket(
+      // heartDuration: Duration(seconds: 5),
+      onError: (e) {
+    LoggerData.addData(e);
+  }, onReceiveMes: (message) async {
+    await FireDialog.fireAlert(message);
+  });
   jpush.addEventHandler(
     // 接收通知回调方法。
     onReceiveNotification: (Map<String, dynamic>? message) async {

lib/provider/user_provider.dart

@@ -4,6 +4,7 @@ import 'dart:io';
 // Flutter imports:
 import 'package:aku_community_manager/models/user/user_info_model.dart';
 import 'package:aku_community_manager/provider/message_provider.dart';
+import 'package:aku_community_manager/utils/websocket/web_socket_util.dart';
 import 'package:flutter/material.dart';
 
 // Package imports:
@@ -20,7 +21,6 @@ import 'package:aku_community_manager/utils/network/base_file_model.dart';
 import 'package:aku_community_manager/utils/network/base_model.dart';
 import 'package:aku_community_manager/utils/network/net_util.dart';
 
-    
 //登录状态管理
 class UserProvider extends ChangeNotifier {
   bool _isLogin = false;
@@ -35,6 +35,8 @@ class UserProvider extends ChangeNotifier {
     await HiveStore.appBox!.put('login', true);
     _profileModel = await updateProfile();
     _infoModel = await updateUserInfo();
+    WebSocketUtil().setUser(infoModel!.id.toString());
+    WebSocketUtil().startWebSocket();
     // await setCurrentHouse((_userDetailModel?.estateNames?.isEmpty ?? true)
     //     ? ''
     //     : _userDetailModel?.estateNames?.first);
@@ -48,7 +50,8 @@ class UserProvider extends ChangeNotifier {
 
   ///更新用户profile
   Future<UserProfileModel?> updateProfile() async {
-    final messageProvider = Provider.of<MessageProvider>(Get.context!,listen: false);
+    final messageProvider =
+        Provider.of<MessageProvider>(Get.context!, listen: false);
     messageProvider.updateMessage();
     BaseModel? model = await NetUtil().get(API.user.profile);
     if (model.data == null)
@@ -72,6 +75,7 @@ class UserProvider extends ChangeNotifier {
   ///注销登录
   logout() async {
     await NetUtil().get(API.auth.logout, showMessage: true);
+    WebSocketUtil().closeWebSocket();
     NetUtil().logout();
     _isLogin = false;
     await HiveStore.appBox!.delete('token');
@@ -90,10 +94,6 @@ class UserProvider extends ChangeNotifier {
     notifyListeners();
   }
 
-
-
-  
-
   ///修改昵称
   setNickName(String name) {
     _infoModel!.nickName = name;

lib/ui/login/login_sms_page.dart

@@ -10,6 +10,7 @@ import 'package:bot_toast/bot_toast.dart';
 import 'package:dio/dio.dart';
 import 'package:get/get.dart' hide Response;
 import 'package:pin_input_text_field/pin_input_text_field.dart';
+import 'package:power_logger/power_logger.dart';
 import 'package:provider/provider.dart';
 
 // Project imports:
@@ -120,6 +121,7 @@ class _LoginSMSPageState extends State<LoginSMSPage> {
             onChanged: (text) async {
               if (text.length == 6) {
                 Function cancel = BotToast.showLoading();
+                try {
                   Response response = await NetUtil().dio!.post(
                     API.auth.login,
                     data: {'tel': widget.phone, 'code': text},
@@ -134,6 +136,10 @@ class _LoginSMSPageState extends State<LoginSMSPage> {
                     BotToast.showText(text: '登陆失败');
                     Get.off(LoginPage());
                   }
+                } catch (e) {
+                  LoggerData.addData(e);
+                  cancel();
+                }
               }
 
               // final userProvider =

lib/ui/splash/splash_page.dart

@@ -64,7 +64,7 @@ class _SplashPageState extends State<SplashPage> {
     Future.delayed(Duration(milliseconds: 2000), () async {
       await _initOp();
 
-      Get.off(HomePage());
+      Get.off(()=>HomePage());
     });
   }
 

lib/utils/jpush_message_parse.dart

@@ -1,14 +1,11 @@
 // Dart imports:
 import 'dart:convert';
 
+import 'package:aku_community_manager/utils/websocket/fier_dialog.dart';
+
 // Flutter imports:
-import 'package:flutter/cupertino.dart';
-import 'package:flutter/material.dart';
 
 // Package imports:
-import 'package:flutter_screenutil/flutter_screenutil.dart';
-import 'package:get/get.dart';
-import 'package:velocity_x/velocity_x.dart';
 
 class JpushMessageParse {
   final Map<String, dynamic> message;
@@ -28,36 +25,12 @@ class JpushMessageParse {
       type = _innerMap['type'] ?? '0';
       switch (type) {
         case '1':
-          await fireAlert(subTitle!);
+          await FireDialog.fireAlert(subTitle!);
           break;
         default:
       }
     }
   }
 
-  Future fireAlert(String subTitle) async {
+ 
-    await Get.dialog(
-      CupertinoAlertDialog(
-        title: Text('发现火灾！请立刻组织疏散人群！'),
-        content: Column(
-          children: [
-            Text(subTitle),
-            10.w.heightBox,
-            Icon(
-              CupertinoIcons.bell_fill,
-              color: Colors.red,
-              size: 48.w,
-            ),
-          ],
-        ),
-        actions: [
-          CupertinoDialogAction(
-            child: Text('确认'),
-            onPressed: () => Get.back(),
-          ),
-        ],
-      ),
-      barrierDismissible: false,
-    );
-  }
 }

lib/utils/websocket/fier_dialog.dart

@@ -0,0 +1,34 @@
+
+import 'package:flutter/cupertino.dart';
+import 'package:flutter/material.dart';
+import 'package:get/get.dart';
+import 'package:flutter_screenutil/flutter_screenutil.dart';
+import 'package:velocity_x/velocity_x.dart';
+
+class FireDialog {
+  static  Future fireAlert(String subTitle) async {
+    await Get.dialog(
+      CupertinoAlertDialog(
+        title: Text('发现火灾！请立刻组织疏散人群！'),
+        content: Column(
+          children: [
+            Text(subTitle),
+            10.w.heightBox,
+            Icon(
+              CupertinoIcons.bell_fill,
+              color: Colors.red,
+              size: 48.w,
+            ),
+          ],
+        ),
+        actions: [
+          CupertinoDialogAction(
+            child: Text('确认'),
+            onPressed: () => Get.back(),
+          ),
+        ],
+      ),
+      barrierDismissible: false,
+    );
+  }
+}

pubspec.lock

@@ -1044,7 +1044,7 @@ packages:
     source: hosted
     version: "3.0.1"
   web_socket_channel:
-    dependency: transitive
+    dependency: "direct main"
     description:
       name: web_socket_channel
       url: "https://pub.flutter-io.cn"

pubspec.yaml

@@ -28,6 +28,8 @@ dependencies:
   qr_code_scanner: ^0.4.0-nullsafety.0
   #toast
   bot_toast: ^4.0.1
+  #websocket
+  web_socket_channel: ^2.1.0
 
   extended_text: ^5.0.4