rongcloud_im_plugin 4.0.3 rongcloud_im_plugin: ^4.0.3 copied to clipboard
RongCloud IM Flutter Plugin.
import 'package:flutter/material.dart';
import 'package:rongcloud_im_plugin/rongcloud_im_plugin.dart' as prefix;
import 'package:flutter_local_notifications/flutter_local_notifications.dart';
import 'other/home_page.dart';
import 'im/util/event_bus.dart';
import 'user_data.dart';
import 'router.dart';
import 'dart:developer' as developer;
void main() => runApp(MyApp());
class MyApp extends StatefulWidget {
@override
_MyAppState createState() => _MyAppState();
static BuildContext getContext() {
return _MyAppState.getContext();
}
}
class _MyAppState extends State<MyApp> with WidgetsBindingObserver {
String pageName = "example.main";
AppLifecycleState currentState = AppLifecycleState.resumed;
DateTime notificationQuietEndTime;
DateTime notificationQuietStartTime;
static BuildContext appContext;
static BuildContext getContext() {
return appContext;
}
@override
void initState() {
super.initState();
//1.初始化 im SDK
prefix.RongIMClient.init(RongAppKey);
// _initUserInfoCache();
WidgetsBinding.instance.addObserver(this);
EventBus.instance.addListener(EventKeys.UpdateNotificationQuietStatus,
(map) {
_getNotificationQuietHours();
});
prefix.RongIMClient.onMessageReceivedWrapper =
(prefix.Message msg, int left, bool hasPackage, bool offline) {
String hasP = hasPackage ? "true" : "false";
String off = offline ? "true" : "false";
if (msg.content != null) {
developer.log("object onMessageReceivedWrapper objName:" +
msg.content.getObjectName() +
" msgContent:" +
msg.content.encode() +
" left:" +
left.toString() +
" hasPackage:" +
hasP +
" offline:" +
off, name: pageName);
} else {
developer.log("object onMessageReceivedWrapper objName: ${msg.objectName} content is null left:${left.toString()} hasPackage:$hasP offline:$off", name: pageName);
}
if (currentState == AppLifecycleState.paused &&
!checkNoficationQuietStatus()) {
EventBus.instance.commit(EventKeys.ReceiveMessage,
{"message": msg, "left": left, "hasPackage": hasPackage});
prefix.RongIMClient.getConversationNotificationStatus(
msg.conversationType, msg.targetId, (int status, int code) {
if (status == 1) {
_postLocalNotification(msg, left);
}
});
} else {
//通知其他页面收到消息
EventBus.instance.commit(EventKeys.ReceiveMessage,
{"message": msg, "left": left, "hasPackage": hasPackage});
}
};
prefix.RongIMClient.onDataReceived = (Map map) {
developer.log("object onDataReceived " + map.toString(), name: pageName);
};
prefix.RongIMClient.onMessageReceiptRequest = (Map map) {
EventBus.instance.commit(EventKeys.ReceiveReceiptRequest, map);
developer.log("object onMessageReceiptRequest " + map.toString(), name: pageName);
};
prefix.RongIMClient.onMessageReceiptResponse = (Map map) {
EventBus.instance.commit(EventKeys.ReceiveReceiptResponse, map);
developer.log("object onMessageReceiptResponse " + map.toString(), name: pageName);
};
prefix.RongIMClient.onReceiveReadReceipt = (Map map) {
EventBus.instance.commit(EventKeys.ReceiveReadReceipt, map);
developer.log("object onReceiveReadReceipt " + map.toString(), name: pageName);
};
}
void _getNotificationQuietHours() {
prefix.RongIMClient.getNotificationQuietHours(
(int code, String startTime, int spansMin) {
if (startTime != null && startTime.length > 0 && spansMin > 0) {
DateTime now = DateTime.now();
String nowString = now.year.toString() +
"-" +
now.month.toString().padLeft(2, '0') +
"-" +
now.day.toString().padLeft(2, '0') +
" " +
startTime;
DateTime start = DateTime.parse(nowString);
notificationQuietStartTime = start;
notificationQuietEndTime = start.add(Duration(minutes: spansMin));
} else {
notificationQuietStartTime = null;
notificationQuietEndTime = null;
}
});
}
bool checkNoficationQuietStatus() {
bool isNotificationQuiet = false;
DateTime now = DateTime.now();
if (notificationQuietStartTime != null &&
notificationQuietEndTime != null &&
now.isAfter(notificationQuietStartTime) &&
now.isBefore(notificationQuietEndTime)) {
isNotificationQuiet = true;
}
return isNotificationQuiet;
}
void _postLocalNotification(prefix.Message msg, int left) async {
FlutterLocalNotificationsPlugin flutterLocalNotificationsPlugin =
new FlutterLocalNotificationsPlugin();
var initializationSettingsAndroid = new AndroidInitializationSettings(
"app_icon"); // app_icon 所在目录为 res/drawable/
var initializationSettingsIOS = new IOSInitializationSettings(
requestAlertPermission: true, requestSoundPermission: true);
var initializationSettings = new InitializationSettings(
initializationSettingsAndroid, initializationSettingsIOS);
flutterLocalNotificationsPlugin.initialize(initializationSettings,
onSelectNotification: null);
var androidPlatformChannelSpecifics = AndroidNotificationDetails(
'your channel id', 'your channel name', 'your channel description',
importance: Importance.Max, priority: Priority.High, ticker: '本地通知');
var platformChannelSpecifics =
NotificationDetails(androidPlatformChannelSpecifics, null);
String content = "测试本地通知";
await flutterLocalNotificationsPlugin.show(
0, 'RongCloud IM', content, platformChannelSpecifics,
payload: 'item x');
}
@override
Widget build(BuildContext context) {
appContext = context;
return MaterialApp(
onGenerateRoute: onGenerateRoute,
theme: ThemeData(primaryColor: Colors.blue),
home: HomePage(),
);
}
@override
void didChangeAppLifecycleState(AppLifecycleState state) {
developer.log("--" + state.toString(), name: pageName);
currentState = state;
switch (state) {
case AppLifecycleState.inactive: // 处于这种状态的应用程序应该假设它们可能在任何时候暂停。
break;
case AppLifecycleState.resumed: // 应用程序可见,前台
break;
case AppLifecycleState.paused: // 应用程序不可见,后台
break;
case AppLifecycleState.detached: // 申请将暂时暂停
break;
}
}
}