130 lines
3.8 KiB
Dart
130 lines
3.8 KiB
Dart
import 'dart:async';
|
||
import 'package:flutter/foundation.dart';
|
||
import 'package:flutter_new_badger/flutter_new_badger.dart';
|
||
import 'package:qhd_prevention/common/route_service.dart';
|
||
import 'package:qhd_prevention/http/ApiService.dart';
|
||
import 'package:flutter/material.dart';
|
||
import 'package:qhd_prevention/http/modules/notif_api.dart';
|
||
|
||
|
||
/// 优化版 BadgeManager：每个接口超时保护、增量更新、notify 合并、原生角标 debounce
|
||
class BadgeManager extends ChangeNotifier {
|
||
BadgeManager._internal();
|
||
static final BadgeManager _instance = BadgeManager._internal();
|
||
factory BadgeManager() => _instance;
|
||
// 添加完整的工作数据存储
|
||
Map<String, dynamic> _workData = {};
|
||
Map<String, dynamic> get workData => _workData;
|
||
// 各模块未读
|
||
int _notifCount = 0;
|
||
|
||
|
||
// 读取接口值的公开 getter
|
||
int get count => _notifCount ;
|
||
int get notifCount => _notifCount;
|
||
|
||
|
||
|
||
// 通知合并控制（短时间内多次更新只触发一次 notify）
|
||
Timer? _notifyTimer;
|
||
Duration _notifyDelay = const Duration(milliseconds: 180);
|
||
void _scheduleNotify() {
|
||
// 如果已有计划，不需要再立即计划（合并）
|
||
_notifyTimer?.cancel();
|
||
_notifyTimer = Timer(_notifyDelay, () {
|
||
try {
|
||
notifyListeners();
|
||
} catch (e) {
|
||
debugPrint('BadgeManager.notifyListeners error: $e');
|
||
}
|
||
_notifyTimer = null;
|
||
});
|
||
}
|
||
|
||
// 原生角标同步 debounce（防止短时间内频繁调用）
|
||
Timer? _syncTimer;
|
||
Duration _syncDelay = const Duration(milliseconds: 250);
|
||
void _syncNativeDebounced() {
|
||
_syncTimer?.cancel();
|
||
_syncTimer = Timer(_syncDelay, () {
|
||
try {
|
||
final total = count;
|
||
if (total > 0) {
|
||
FlutterNewBadger.setBadge(total);
|
||
} else {
|
||
FlutterNewBadger.removeBadge();
|
||
}
|
||
} catch (e) {
|
||
debugPrint('BadgeManager._syncNativeDebounced error: $e');
|
||
}
|
||
_syncTimer = null;
|
||
});
|
||
}
|
||
|
||
// safe wrapper: 给单个 future 加超时与兜底返回
|
||
Future<T> _safe<T>(Future<T> future, T fallback, {Duration timeout = const Duration(seconds: 5)}) async {
|
||
try {
|
||
return await future.timeout(timeout);
|
||
} catch (e, st) {
|
||
// 报错不抛出到外层，记录并返回 fallback
|
||
debugPrint('BadgeManager._safe error: $e\n$st');
|
||
return fallback;
|
||
}
|
||
}
|
||
|
||
/// 初始化所有模块（并行发起，但每个接口独立 timeout & 提交结果）
|
||
Future<void> initAllModules() async {
|
||
// 不 await 整个 Future.wait，使调用方不会因为单个慢接口阻塞
|
||
try {
|
||
// 每个请求都通过 _safe 包裹，设置超时与兜底
|
||
final fNotif = _safe<Map<String, dynamic>>(
|
||
NotifApi.getNotifRedPoint().then((r) => r as Map<String, dynamic>),
|
||
<String, dynamic>{},
|
||
timeout: const Duration(seconds: 4),
|
||
);
|
||
|
||
|
||
fNotif.then((notifJson) {
|
||
try {
|
||
_notifCount = ((notifJson['data'] as int?) ?? 0);
|
||
} catch (e, st) {
|
||
debugPrint('BadgeManager.parse notifJson error: $e\n$st');
|
||
}
|
||
_scheduleNotify();
|
||
_syncNativeDebounced();
|
||
});
|
||
|
||
|
||
} catch (e, st) {
|
||
debugPrint('BadgeManager.initAllModules unexpected error: $e\n$st');
|
||
}
|
||
}
|
||
|
||
// 下面的 updateX 方法也做了超时保护并使用 _onModuleChanged 合并通知
|
||
|
||
void updateNotifCount() async {
|
||
try {
|
||
final notifJson = await _safe<Map<String, dynamic>>(
|
||
NotifApi.getNotifRedPoint().then((r) => r as Map<String, dynamic>),
|
||
<String, dynamic>{},
|
||
timeout: const Duration(seconds: 4),
|
||
);
|
||
_notifCount = (notifJson['data'] as int?) ?? 0;
|
||
_onModuleChanged();
|
||
} catch (e) {
|
||
debugPrint('updateNotifCount error: $e');
|
||
}
|
||
}
|
||
|
||
|
||
void clearAll() {
|
||
_syncNativeDebounced();
|
||
_scheduleNotify();
|
||
}
|
||
|
||
void _onModuleChanged() {
|
||
_syncNativeDebounced();
|
||
_scheduleNotify();
|
||
}
|
||
}
|