ActivityKit.fareworkSwiftUI.farework

/*! * @abstract 注册LiveActivity并上报PushToken * 在PushToken更新时，需同步调用该接口 * 在LiveActivity结束时，需同步调用该接口，PushToken为nil * * @param liveActivityId 标识某一个LiveActivity * @param pushToken 对应LiveActivity的PushToken * @param handler 结果回调 */ [MobPush registerLiveActivityWithID:@"mpLiveActivity"                                          pushToken:token                                         completion:^(NSError *error) {                    if (error) {                        NSLog(@"Register LiveActivity Failed: %@", error.localizedDescription);                    }                }];            }

static public func startActivity(pushTokenUpdate:@escaping (Bool, Data?)->Void) {        guard ActivityAuthorizationInfo().areActivitiesEnabled else {            //不可用            pushTokenUpdate(false, nil)            //监听可用状态//            for await enablment in ActivityAuthorizationInfo().activityEnablementUpdates {//                print("Activity AuthorizationInfo change to (enablment)")//            }            return        }
        endPreActivity()
        let state = HeartNoteLiveActivitsLiveAttributes.ContentState(prograssState: .Car)        let attri = HeartNoteLiveActivitsLiveAttributes(name: "MPLiveActivities")        do {            let current = try Activity.request(attributes: attri, contentState: state, pushType: .token)            Task {                for await tokenData in current.pushTokenUpdates {                    //监听token更新 注意线程                    pushTokenUpdate(true, tokenData)                }            }            Task {                for await state in current.contentStateUpdates {                    //监听state状态 开发者可自行编写回调监听                    print("1content state update: tip=(state.prograssState)")                }            }            Task {                //监听activity状态 开发者可自行编写回调监听                for await state in current.activityStateUpdates {                    print("activity state update: tip=(state) id:(current.id)")                }            }        } catch(let error) {            print("error=",error)            pushTokenUpdate(false, nil)        }    }

static public func updateActivityState(_ value: Int) {        Task {            guard let current = Activity<HeartNoteLiveActivitsLiveAttributes>.activities.first else {                return            }
            let state = HeartNoteLiveActivitsLiveAttributes.ContentState(prograssState: PrograssState(rawValue: value) ?? .Arrived)            let alertConfiguration = AlertConfiguration(title: "Delivery Update ", body: "Delivery Update State to (state.prograssState.rawValue)", sound: .default)            await current.update(using: state, alertConfiguration: alertConfiguration)        }    }

//建议关闭应用的时候要关闭 不然下次启动就脱离控制了    static public func endPreActivity() {        let activities = Activity<HeartNoteLiveActivitsLiveAttributes>.activities.filter { act in            return act.activityState == .active        }        guard activities.count > 0 else { return }        for item in activities {            Task {//                print("end activity (item.id)")                await item.end(dismissalPolicy:.immediate)            }        }    }