Swift HealthKit HKStatisticsCollectionQuery statisticsUpdateHandler 并不总是被调用

Swift HealthKit HKStatisticsCollectionQuery statisticsUpdateHandler not always called

我有一个测试项目,我在其中获取用户在一周内每天的跌倒总数。 initialResultsHandler 每次都能完美运行,但是 statisticsUpdateHandler 并不总是触发。如果您启动应用程序,然后转到健康应用程序并手动插入跌倒,切换回测试应用程序,您应该会看到今天更新的总数。实际上,这适用于大约前 3-6 次。之后 statisticsUpdateHandler 不再被调用。

同样奇怪的是,如果您删除数据然后返回到测试应用程序,或者添加早于现在的时间的数据,则会调用 statisticsUpdateHandler。这使我认为它与 statisticsUpdateHandler 结束日期有关。

Apple 文档非常清楚,但我担心他们可能会漏掉一些东西。

如果这个属性设置为nil,统计查询会在计算完初始结果后自动停止。如果此 属性 不为零,则查询的行为类似于观察者查询。它继续 运行,监控 HealthKit 存储。如果任何新的、匹配的样本被保存到存储中——或者如果任何现有的匹配样本从存储中被删除——查询将在后台队列上执行更新处理程序。

是否有任何原因可能无法调用 statisticsUpdateHandler?我在下面包含了一个测试项目。

struct Falls: Identifiable{
    let id = UUID()
    let date: Date
    let value: Int
    
    var formattedDate: String{
        let formatter = DateFormatter()
        formatter.setLocalizedDateFormatFromTemplate("MM/dd/yyyy")
        return formatter.string(from: date)
    }
}
struct ContentView: View {
    @StateObject var manager = HealthKitManager()
    
    var body: some View {
        NavigationView{
            List{
                Text("Updates: \(manager.updates)")
                ForEach(manager.falls){ falls in
                    HStack{
                        Text(falls.value.description)
                        Text(falls.formattedDate)
                    }
                }
            }
            .overlay(
                ProgressView()
                    .scaleEffect(1.5)
                    .opacity(manager.isLoading ? 1 : 0)
            )
            .navigationTitle("Falls")
        }
    }
}

struct ContentView_Previews: PreviewProvider {
    static var previews: some View {
        ContentView()
    }
}
class HealthKitManager: ObservableObject{
    let healthStore = HKHealthStore()
    let fallType   = HKQuantityType.quantityType(forIdentifier: .numberOfTimesFallen)!
    @Published var isLoading = false
    @Published var falls = [Falls]()
    @Published var updates = 0

    init() {
        let healthKitTypesToRead: Set<HKSampleType> = [fallType]

        healthStore.requestAuthorization(toShare: nil, read: healthKitTypesToRead) { (success, error) in
            if let error = error{
                print("Error: \(error)")
            } else if success{
                self.startQuery()
            }
        }
    }
    
    func startQuery(){
        let now = Date()
        let cal = Calendar.current
        let sevenDaysAgo = cal.date(byAdding: .day, value: -7, to: now)!
        let startDate = cal.startOfDay(for: sevenDaysAgo)
        let predicate = HKQuery.predicateForSamples(withStart: startDate, end: now, options: [.strictStartDate, .strictEndDate])
        
        var interval = DateComponents()
        interval.day = 1
        
        // start from midnight
        let anchorDate = cal.startOfDay(for: now)
       
        let query = HKStatisticsCollectionQuery(
            quantityType: fallType,
            quantitySamplePredicate: predicate,
            options: .cumulativeSum,
            anchorDate: anchorDate,
            intervalComponents: interval
        )
        
        query.initialResultsHandler = { query, collection, error in
            guard let collection = collection else {
                print("No collection")
                DispatchQueue.main.async{
                    self.isLoading = false
                }
                return
            }
            
            collection.enumerateStatistics(from: startDate, to: Date()){ (result, stop) in
                guard let sumQuantity = result.sumQuantity() else {
                    return
                }
                
                let totalFallsForADay = Int(sumQuantity.doubleValue(for: .count()))
                let falls = Falls(date: result.startDate, value: totalFallsForADay)
                print(falls.value, falls.formattedDate)
                
                DispatchQueue.main.async{
                    self.falls.insert(falls, at: 0)
                }
            }
            
            print("initialResultsHandler done")
            DispatchQueue.main.async{
                self.isLoading = false
            }
        }
        
        
        query.statisticsUpdateHandler = { query, statistics, collection, error in
            print("In statisticsUpdateHandler...")
            guard let collection = collection else {
                print("No collection")
                DispatchQueue.main.async{
                    self.isLoading = false
                }
                return
            }
            
            DispatchQueue.main.async{
                self.isLoading = true
                self.updates += 1
                self.falls.removeAll(keepingCapacity: true)
            }
            
            collection.enumerateStatistics(from: startDate, to: Date()){ (result, stop) in
                guard let sumQuantity = result.sumQuantity() else {
                    return
                }
                
                let totalFallsForADay = Int(sumQuantity.doubleValue(for: .count()))
                let falls = Falls(date: result.startDate, value: totalFallsForADay)
                print(falls.value, falls.formattedDate)
                print("\n\n")

                DispatchQueue.main.async{
                    self.falls.insert(falls, at: 0)
                }
            }
            
            print("statisticsUpdateHandler done")
            DispatchQueue.main.async{
                self.isLoading = false
            }
        }
        
        
        isLoading = true
        healthStore.execute(query)
    }
}

我太专注于 statisticsUpdateHandler 以及开始和结束时间而没有注意查询本身。事实证明谓词是问题所在。通过给它一个结束日期,它永远不会在初始谓词结束日期之外寻找样本。

将谓词更改为此解决了问题:

let predicate = HKQuery.predicateForSamples(withStart: startDate, end: nil, options: [.strictStartDate])