275 lines
9.9 KiB
Swift
275 lines
9.9 KiB
Swift
//
|
||
// dimensionhubApp.swift
|
||
// dimensionhub
|
||
//
|
||
// Created by 安礼成 on 2025/2/18.
|
||
//
|
||
|
||
import SwiftUI
|
||
import SwiftData
|
||
import Observation
|
||
import BackgroundTasks
|
||
|
||
@main
|
||
struct dimensionhubApp: App {
|
||
@UIApplicationDelegateAdaptor(AppDelegate.self) var appDelegate
|
||
@StateObject var appNav = AppNavigation.shared
|
||
|
||
private var userId: String
|
||
|
||
var sharedModelContainer: ModelContainer = {
|
||
let schema = Schema([
|
||
Item.self,
|
||
SearchHistory.self
|
||
])
|
||
let modelConfiguration = ModelConfiguration(
|
||
schema: schema,
|
||
isStoredInMemoryOnly: true,
|
||
allowsSave: true
|
||
)
|
||
|
||
do {
|
||
return try ModelContainer(for: schema, configurations: [modelConfiguration])
|
||
} catch {
|
||
fatalError("Could not create ModelContainer: \(error)")
|
||
}
|
||
}()
|
||
|
||
init() {
|
||
self.userId = KeychainHelper.getPersistentUserId()
|
||
|
||
// 尽可能早设置代理对象
|
||
UNUserNotificationCenter.current().delegate = appDelegate
|
||
print("user_id is: \(self.userId)")
|
||
}
|
||
|
||
var body: some Scene {
|
||
WindowGroup {
|
||
NavigationStack(path: $appNav.path) {
|
||
IndexView()
|
||
.navigationDestination(for: AppNavigation.Destination.self) { dest in
|
||
switch dest {
|
||
case .detail(id: let id, channelName: let channelName):
|
||
DetailView(id: id, channelName: channelName)
|
||
case .followList(num: let num):
|
||
FollowListView(num: num)
|
||
case .search:
|
||
SearchView()
|
||
}
|
||
}
|
||
}
|
||
.navigationViewStyle(.stack)
|
||
.tint(.black)
|
||
.environment(\.userId, self.userId)
|
||
.environmentObject(appNav)
|
||
.preferredColorScheme(.light)
|
||
}
|
||
.modelContainer(sharedModelContainer)
|
||
}
|
||
|
||
}
|
||
|
||
class AppDelegate: UIResponder, UIApplicationDelegate, UNUserNotificationCenterDelegate {
|
||
|
||
let taskId = "com.jihe.dimensionhub.refresh"
|
||
|
||
func application(_ application: UIApplication, didFinishLaunchingWithOptions launchOptions: [UIApplication.LaunchOptionsKey : Any]? = nil) -> Bool {
|
||
|
||
BGTaskScheduler.shared.register(forTaskWithIdentifier: taskId, using: nil) { task in
|
||
self.handleAppRefresh(task: task)
|
||
}
|
||
|
||
Task.detached {
|
||
await self.registerForPushNotifications()
|
||
|
||
// 更新未读消息数
|
||
let unreadDramaIds = await self.getSystemUnreadDramaIds()
|
||
let userId = KeychainHelper.getPersistentUserId()
|
||
let response = await API.resetUserUnreadNum(userId: userId, dramaIds: unreadDramaIds, as: String.self)
|
||
switch response {
|
||
case .result(let result):
|
||
NSLog("reset user unread num result is: \(result)")
|
||
case .error(let errorCode, let message):
|
||
NSLog("reset user unread error_code: \(errorCode), message: \(message)")
|
||
}
|
||
|
||
Task {@MainActor in
|
||
do {
|
||
try await UNUserNotificationCenter.current().setBadgeCount(unreadDramaIds.count)
|
||
NSLog("UNUserNotificationCenter setBadgeCount num: \(unreadDramaIds.count)")
|
||
} catch let err {
|
||
NSLog("UNUserNotificationCenter setBadgeCount get error: \(err)")
|
||
}
|
||
}
|
||
}
|
||
return true
|
||
}
|
||
|
||
private func handleAppRefresh(task: BGTask) {
|
||
self.scheduleAppRefresh()
|
||
|
||
task.expirationHandler = {
|
||
// 清理未完成的操作
|
||
task.setTaskCompleted(success: false)
|
||
}
|
||
|
||
Task {@MainActor in
|
||
if let unreadNum = await self.fetchUserUnreadCount(), unreadNum > 0 {
|
||
do {
|
||
try await UNUserNotificationCenter.current().setBadgeCount(unreadNum)
|
||
task.setTaskCompleted(success: true)
|
||
NSLog("Refresh setBadgeCount num: \(unreadNum)")
|
||
} catch let err {
|
||
NSLog("Refresh setBadgeCount get error: \(err)")
|
||
task.setTaskCompleted(success: false)
|
||
}
|
||
} else {
|
||
task.setTaskCompleted(success: false)
|
||
}
|
||
}
|
||
}
|
||
|
||
private func scheduleAppRefresh() {
|
||
let request = BGAppRefreshTaskRequest(identifier: taskId)
|
||
|
||
// 设置下次执行时间（建议 1-4 小时）
|
||
request.earliestBeginDate = Date(timeIntervalSinceNow: 900)
|
||
do {
|
||
try BGTaskScheduler.shared.submit(request)
|
||
} catch {
|
||
NSLog("无法安排后台任务: \(error.localizedDescription)")
|
||
}
|
||
}
|
||
|
||
private func registerForPushNotifications() {
|
||
// 请求通知权限
|
||
UNUserNotificationCenter.current().requestAuthorization(options: [.alert, .sound, .badge]) {granted, error in
|
||
NSLog("通知权限 granted: \(granted)")
|
||
guard granted else {
|
||
return
|
||
}
|
||
|
||
// 获取通知设置
|
||
UNUserNotificationCenter.current().getNotificationSettings { settings in
|
||
NSLog("通知设置: \(settings)")
|
||
guard settings.authorizationStatus == .authorized else {
|
||
return
|
||
}
|
||
|
||
NSLog("通知设置: authorized!!!!")
|
||
DispatchQueue.main.async {
|
||
// 注册远程通知
|
||
UIApplication.shared.registerForRemoteNotifications()
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
// 从服务器获取初始未读数
|
||
private func fetchUserUnreadCount() async -> Int? {
|
||
let userId = KeychainHelper.getPersistentUserId()
|
||
let response = await API.getUserUnreadNum(userId: userId, as: Int.self)
|
||
switch response {
|
||
case .result(let unreadNum):
|
||
return unreadNum
|
||
case .error(let errorCode, let error):
|
||
NSLog("fetchUserUnreadCount get error: \(error), code: \(errorCode)")
|
||
return nil
|
||
}
|
||
}
|
||
|
||
// 通系统通知列表获取未读取的消息总数
|
||
private func getSystemUnreadDramaIds() async -> [Int] {
|
||
let notifications = await UNUserNotificationCenter.current().deliveredNotifications()
|
||
let unreadDramaIds = notifications.flatMap { n -> [Int] in
|
||
let userInfo = n.request.content.userInfo
|
||
guard let customData = userInfo["custom_data"] as? [String: AnyObject],
|
||
let params = customData["params"] as? [String : AnyObject],
|
||
let dramaId = params["drama_id"] as? Int else {
|
||
return []
|
||
}
|
||
return [dramaId]
|
||
}
|
||
return unreadDramaIds
|
||
}
|
||
|
||
// 成功注册远程通知，获取到 deviceToken
|
||
func application(_ application: UIApplication, didRegisterForRemoteNotificationsWithDeviceToken deviceToken: Data) {
|
||
let tokenParts = deviceToken.map { data in String(format: "%02.2hhx", data) }
|
||
let token = tokenParts.joined()
|
||
|
||
NSLog("Device Token: \(token)")
|
||
// 将 deviceToken 发送给你的服务器
|
||
Task {
|
||
let userId = KeychainHelper.getPersistentUserId()
|
||
|
||
let sendResult = await API.sendDeviceTokenToServer(userId: userId, token: token, as: String.self)
|
||
switch sendResult {
|
||
case .result(let reply):
|
||
NSLog("send token to server get reply: \(reply)")
|
||
case .error(let errorCode, let message):
|
||
NSLog("send token to server error_code: \(errorCode), message: \(message)")
|
||
}
|
||
}
|
||
}
|
||
|
||
// 注册远程通知失败
|
||
func application(_ application: UIApplication, didFailToRegisterForRemoteNotificationsWithError error: Error) {
|
||
NSLog("注册远程通知失败: \(error)")
|
||
}
|
||
|
||
// 收到远程通知（App 在前台）
|
||
func application(_ application: UIApplication, didReceiveRemoteNotification userInfo: [AnyHashable: Any], fetchCompletionHandler completionHandler: @escaping (UIBackgroundFetchResult) -> Void) {
|
||
completionHandler(.newData)
|
||
}
|
||
|
||
// MARK: UNUserNotificationCenterDelegate
|
||
|
||
// App 在前台时收到通知
|
||
func userNotificationCenter(_ center: UNUserNotificationCenter,
|
||
willPresent notification: UNNotification,
|
||
withCompletionHandler completionHandler: @escaping (UNNotificationPresentationOptions) -> Void) {
|
||
// 设置如何显示通知
|
||
completionHandler([.banner, .sound])
|
||
}
|
||
|
||
// 用户点击通知
|
||
func userNotificationCenter(_ center: UNUserNotificationCenter,
|
||
didReceive response: UNNotificationResponse,
|
||
withCompletionHandler completionHandler: @escaping () -> Void) {
|
||
|
||
let userInfo = response.notification.request.content.userInfo
|
||
handleRemoteNotification(userInfo: userInfo)
|
||
// 根据通知内容跳转到特定页面
|
||
if let deepLink = userInfo["deepLink"] as? String {
|
||
handleDeepLink(deepLink)
|
||
}
|
||
|
||
completionHandler()
|
||
}
|
||
|
||
// MARK: 消息处理
|
||
private func handleRemoteNotification(userInfo: [AnyHashable: Any]) {
|
||
AppNavigation.shared.handleNotification(userInfo)
|
||
}
|
||
|
||
private func handleDeepLink(_ link: String) {
|
||
// 实现深度链接处理逻辑
|
||
NSLog("处理深度链接: \(link)")
|
||
}
|
||
|
||
}
|
||
|
||
// userId通过环境变量传递
|
||
|
||
struct UserId: EnvironmentKey {
|
||
static let defaultValue: String = KeychainHelper.getPersistentUserId()
|
||
}
|
||
|
||
extension EnvironmentValues {
|
||
var userId: String {
|
||
get { self[UserId.self] }
|
||
set { self[UserId.self] = newValue }
|
||
}
|
||
}
|