You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
547 lines
28 KiB
547 lines
28 KiB
2 years ago
|
//
|
||
|
1 year ago
|
// DataBaseManagerFireBoltt.swift
|
||
|
2 years ago
|
// FunDoHealth
|
||
|
|
//
|
||
|
|
// Created by ecell on 2018/6/8.
|
||
|
|
// Copyright © 2020年 ecell. All rights reserved.
|
||
|
|
//
|
||
|
|
|
||
|
|
import Foundation
|
||
|
|
import FMDB
|
||
|
|
|
||
|
|
/// 通用路径
|
||
|
|
let ecellBasicPath = NSSearchPathForDirectoriesInDomains(FileManager.SearchPathDirectory.documentDirectory,FileManager.SearchPathDomainMask.userDomainMask,true).first!
|
||
|
|
|
||
|
|
// MARK:- 常量
|
||
|
|
fileprivate struct Metric {
|
||
|
|
/// 数据库名称
|
||
|
1 year ago
|
static let dataBasePath = ecellBasicPath + "/" + "FireBoltt.sqlite"
|
||
|
2 years ago
|
/// 数据表名
|
||
|
1 year ago
|
static let FB_table_step = "FB_table_step"
|
||
|
|
static let FB_table_sleep = "FB_table_sleep"
|
||
|
|
static let FB_table_heartRate = "FB_table_heartRate"
|
||
|
|
static let FB_table_sport = "FB_table_sport"
|
||
|
|
static let FB_table_temperature = "FB_table_temperature"
|
||
|
|
static let FB_table_bloodPressure = "FB_table_bloodPressure"
|
||
|
|
static let FB_table_bloodOxygen = "FB_table_bloodOxygen"
|
||
|
2 years ago
|
/// 数据类型获取对应的数据标名称
|
||
|
|
static func tableName(dataType: DataType) -> String {
|
||
|
|
switch dataType {
|
||
|
1 year ago
|
case .step: return FB_table_step
|
||
|
|
case .sleep: return FB_table_sleep
|
||
|
|
case .heartRate: return FB_table_heartRate
|
||
|
|
case .sport: return FB_table_sport
|
||
|
|
case .temperature: return FB_table_temperature
|
||
|
|
case .bloodPressure: return FB_table_bloodPressure
|
||
|
|
case .bloodOxygen: return FB_table_bloodOxygen
|
||
|
2 years ago
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 数据类型
|
||
|
|
public enum DataType: Int {
|
||
|
|
case step
|
||
|
|
case sleep
|
||
|
|
case heartRate
|
||
|
|
case sport
|
||
|
|
case temperature
|
||
|
|
case bloodPressure
|
||
|
|
case bloodOxygen
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 数据查询类型
|
||
|
|
enum DataQueryType: Int {
|
||
|
|
case day
|
||
|
|
case week
|
||
|
|
case month
|
||
|
|
case year
|
||
|
|
case all
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 数据查询闭包
|
||
|
|
typealias ResultClosure = ([BaseJsonModel]) -> ()
|
||
|
|
|
||
|
|
/// 数据表最近插入数据时间
|
||
|
|
typealias LastRecordClosure = (Int?) -> ()
|
||
|
|
|
||
|
|
// MARK:- 初始化
|
||
|
1 year ago
|
final class DataBaseManagerFireBoltt: NSObject {
|
||
|
2 years ago
|
/// 单例
|
||
|
1 year ago
|
static let shared = DataBaseManagerFireBoltt()
|
||
|
2 years ago
|
/// 需要在oc中调用此单例
|
||
|
1 year ago
|
@objc public class func ocShareInstance() -> DataBaseManagerFireBoltt {
|
||
|
2 years ago
|
return shared
|
||
|
|
}
|
||
|
|
|
||
|
|
private override init() {
|
||
|
|
super.init()
|
||
|
|
createDataTables()
|
||
|
|
}
|
||
|
|
/// 数据库
|
||
|
|
let dataBase = FMDatabaseQueue(path: Metric.dataBasePath)
|
||
|
|
|
||
|
|
/// 创建表
|
||
|
|
private func createDataTables() {
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
// 运动数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_sport) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, verison INTEGER NOT NULL, sportType INTEGER NOT NULL, dataDate TEXT NOT NULL, duration INTEGER NOT NULL, distance INTEGER NOT NULL, calorie FLOAT NOT NULL, stepNumber INTEGER NOT NULL, heartMax INTEGER NOT NULL, heartAvg INTEGER NOT NULL, heartMin INTEGER NOT NULL, stepFrequencyMax INTEGER NOT NULL, stepFrequencyAvg INTEGER NOT NULL, stepFrequencyMin INT NOT NULL, paceMax INTEGER NOT NULL, paceAvg INTEGER NOT NULL, paceMin INTEGER NOT NULL, startAltitude INTEGER NOT NULL, endAltitude INTEGER NOT NULL, gpsCount INTEGER NOT NULL, kmCount INTEGER NOT NULL, stepCount INTEGER NOT NULL, heartCount INTEGER NOT NULL, trainDetailCount INTEGER NOT NULL, gpsTimestamp INTEGER NOT NULL, gpsDeatail TEXT NULL, kmDetail TEXT NULL, stepTimestamp INTEGER NOT NULL, stepDetail TEXT NULL, hrsTimestamp INTEGER NOT NULL, hrsDetail TEXT NULL, swimmingDetail TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
// 计步数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_step) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, dataDate TEXT NOT NULL, stepNumber INTEGER NOT NULL, stepDistance INTEGER NOT NULL, stepCalorie FLOAT NOT NULL, stepDuration INTEGER NOT NULL, stepDetails TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
// 心率数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_heartRate) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, dataDate TEXT NOT NULL, heartMax INTEGER NOT NULL, heartMin INTEGER NOT NULL, heartAvg INTEGER NOT NULL, heartDetails TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
// 睡眠数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_sleep) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, dataDate TEXT NOT NULL, deepSleepDuration INTEGER NOT NULL, lightSleepDuration INTEGER NOT NULL, awakeDuration INTEGER NOT NULL, totalSleepDuration INTEGER NOT NULL, fallingSleepTimes TEXT NOT NULL, awakeTimes TEXT NOT NULL, awakeNumber INTEGER NOT NULL, sleepDetails TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
// 体温数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_temperature) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, dataDate TEXT NOT NULL, temperatureMax DOUBLE NOT NULL, temperatureMin DOUBLE NOT NULL, temperatureAvg DOUBLE NOT NULL, temperatureDetails TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
// 血压数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_bloodPressure) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, dataDate TEXT NOT NULL, sbpMax INTEGER NOT NULL, sbpMin INTEGER NOT NULL, sbpAvg INTEGER NOT NULL, dbpMax INTEGER NOT NULL, dbpMin INTEGER NOT NULL, dbpAvg INTEGER NOT NULL, details TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
// 血氧数据表
|
||
|
1 year ago
|
db.executeUpdate("CREATE TABLE IF NOT EXISTS \(Metric.FB_table_bloodOxygen) (id INTEGER PRIMARY KEY, macID TEXT NOT NULL, dataDate TEXT NOT NULL, bloodOxygenMax INTEGER NOT NULL, bloodOxygenMin INTEGER NOT NULL, bloodOxygenAvg INTEGER NOT NULL, details TEXT NULL);", withArgumentsIn: [])
|
||
|
2 years ago
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
// MARK:- 插入数据
|
||
|
1 year ago
|
extension DataBaseManagerFireBoltt {
|
||
|
2 years ago
|
/// 插入数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - models: 数据模型数组
|
||
|
|
/// - dataType: 数据类型
|
||
|
|
func insertModels(models: [BaseJsonModel], dataType: DataType) {
|
||
|
|
// 插入表名
|
||
|
|
let tableName = Metric.tableName(dataType: dataType)
|
||
|
|
switch dataType {
|
||
|
|
case .sport:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? SportModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = SportModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .sport)) {
|
||
|
2 years ago
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,verison,sportType,duration,distance,calorie,stepNumber,heartMax,heartAvg,heartMin,stepFrequencyMax,stepFrequencyAvg,stepFrequencyMin,paceMax,paceAvg,paceMin,startAltitude,endAltitude,gpsCount,kmCount,stepCount,heartCount,trainDetailCount,gpsTimestamp,gpsDeatail,kmDetail,stepTimestamp,stepDetail,hrsTimestamp,hrsDetail,swimmingDetail) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.verison, model.sportType, model.duration, model.distance, model.calorie, model.stepNumber, model.heartMax, model.heartAvg, model.heartMin, model.stepFrequencyMax, model.stepFrequencyAvg, model.stepFrequencyMin, model.paceMax, model.paceAvg, model.paceMin, model.startAltitude, model.endAltitude, model.gpsCount, model.kmCount, model.stepCount, model.heartCount, model.trainDetailCount, model.gpsTimestamp, model.gpsDeatail, model.kmDetail, model.stepTimestamp, model.stepDetail, model.hrsTimestamp, model.hrsDetail, model.swimmingDetail])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
case .sleep:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? SleepModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = SleepModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .sleep)) {
|
||
|
2 years ago
|
// 更新数据
|
||
|
|
let updateSQL = "UPDATE \(tableName) SET macID='\(model.macID)', deepSleepDuration='\(model.deepSleepDuration)', lightSleepDuration='\(model.lightSleepDuration)', awakeDuration='\(model.awakeDuration)', totalSleepDuration='\(model.totalSleepDuration)', fallingSleepTimes='\(model.fallingSleepTimes)', awakeTimes='\(model.awakeTimes)', awakeNumber='\(model.awakeNumber)', sleepDetails='\(model.sleepDetails)' WHERE dataDate='\(model.dataDate)'"
|
||
|
|
db.executeUpdate(updateSQL, withArgumentsIn: [])
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,deepSleepDuration,lightSleepDuration,awakeDuration,totalSleepDuration,fallingSleepTimes,awakeTimes,awakeNumber,sleepDetails) VALUES (?,?,?,?,?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.deepSleepDuration, model.lightSleepDuration, model.awakeDuration, model.totalSleepDuration, model.fallingSleepTimes, model.awakeTimes, model.awakeNumber, model.sleepDetails])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
case .step:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? StepModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = StepModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .step)) {
|
||
|
2 years ago
|
// 更新数据
|
||
|
|
let updateSQL = "UPDATE \(tableName) SET macID='\(model.macID)', stepNumber='\(model.stepNumber)', stepDistance='\(model.stepDistance)', stepCalorie='\(model.stepCalorie)', stepDuration='\(model.stepDuration)', stepDetails='\(model.stepDetails)' WHERE dataDate='\(model.dataDate)'"
|
||
|
|
db.executeUpdate(updateSQL, withArgumentsIn: [])
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,stepNumber,stepDistance,stepCalorie,stepDuration,stepDetails) VALUES (?,?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.stepNumber, model.stepDistance, model.stepCalorie, model.stepDuration, model.stepDetails])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
case .heartRate:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? HeartRateModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = HeartRateModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .heartRate)) {
|
||
|
2 years ago
|
// 更新数据
|
||
|
|
let updateSQL = "UPDATE \(tableName) SET macID='\(model.macID)', heartMax='\(model.heartMax)', heartMin='\(model.heartMin)', heartAvg='\(model.heartAvg)', heartDetails='\(model.heartDetails)' WHERE dataDate='\(model.dataDate)'"
|
||
|
|
db.executeUpdate(updateSQL, withArgumentsIn: [])
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,heartMax,heartMin,heartAvg,heartDetails) VALUES (?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.heartMax, model.heartMin, model.heartAvg, model.heartDetails])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
case .temperature:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? TemperatureModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = TemperatureModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .temperature)) {
|
||
|
2 years ago
|
// 更新数据
|
||
|
|
let updateSQL = "UPDATE \(tableName) SET macID='\(model.macID)', temperatureMax='\(model.temperatureMax)', temperatureMin='\(model.temperatureMin)', temperatureAvg='\(model.temperatureAvg)', temperatureDetails='\(model.temperatureDetails)' WHERE dataDate='\(model.dataDate)'"
|
||
|
|
db.executeUpdate(updateSQL, withArgumentsIn: [])
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,temperatureMax,temperatureMin,temperatureAvg,temperatureDetails) VALUES (?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.temperatureMax, model.temperatureMin, model.temperatureAvg, model.temperatureDetails])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
case .bloodPressure:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? BloodPressureModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = BloodPressureModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .bloodPressure)) {
|
||
|
2 years ago
|
// 更新数据
|
||
|
|
let updateSQL = "UPDATE \(tableName) SET macID='\(model.macID)', sbpMax='\(model.sbpMax)', sbpMin='\(model.sbpMin)', sbpAvg='\(model.sbpAvg)', dbpMax='\(model.dbpMax)', dbpMin='\(model.dbpMin)', dbpAvg='\(model.dbpAvg)', details='\(model.details)' WHERE dataDate='\(model.dataDate)'"
|
||
|
|
db.executeUpdate(updateSQL, withArgumentsIn: [])
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,sbpMax,sbpMin,sbpAvg,dbpMax,dbpMin,dbpAvg,details) VALUES (?,?,?,?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.sbpMax, model.sbpMin, model.sbpAvg, model.dbpMax, model.dbpMax, model.dbpAvg, model.details])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
case .bloodOxygen:
|
||
|
|
dataBase?.inTransaction({ (db, rollback) in
|
||
|
|
for model in models {
|
||
|
|
guard let model = model as? BloodOxygenModel else { continue }
|
||
|
|
// 是否存在旧数据
|
||
|
1 year ago
|
if let _ = BloodOxygenModel.deserialize(from: fbquerySingleData(db: db, dataDate: model.dataDate, dataType: .bloodOxygen)) {
|
||
|
2 years ago
|
// 更新数据
|
||
|
|
let updateSQL = "UPDATE \(tableName) SET macID='\(model.macID)', bloodOxygenMax='\(model.bloodOxygenMax)', bloodOxygenMin='\(model.bloodOxygenMin)', bloodOxygenAvg='\(model.bloodOxygenAvg)', details='\(model.details)' WHERE dataDate='\(model.dataDate)'"
|
||
|
|
db.executeUpdate(updateSQL, withArgumentsIn: [])
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
// 插入数据
|
||
|
|
let insertSQL = "INSERT INTO \(tableName) (macID,dataDate,bloodOxygenMax,bloodOxygenMin,bloodOxygenAvg,details) VALUES (?,?,?,?,?,?);"
|
||
|
|
db.executeUpdate(insertSQL, withArgumentsIn: [model.macID, model.dataDate, model.bloodOxygenMax, model.bloodOxygenMin, model.bloodOxygenAvg, model.details])
|
||
|
|
}
|
||
|
|
})
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
// MARK:- 数据查询
|
||
|
1 year ago
|
extension DataBaseManagerFireBoltt {
|
||
|
2 years ago
|
/// 查询睡眠数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataDate: 日期
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: 数组
|
||
|
1 year ago
|
func fbquerySleepModel(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_sleep
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE dataDate = '\(dataDate)'"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [SleepModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = SleepModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询心率数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataDate: 日期
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: 数组
|
||
|
1 year ago
|
func fbqueryHeartRateData(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_heartRate
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE dataDate = '\(dataDate)'"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [HeartRateModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = HeartRateModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询计步数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataDate: 日期
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: 数组
|
||
|
1 year ago
|
func fbqueryStepModel(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_step
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE dataDate = '\(dataDate)'"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [StepModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = StepModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询运动数据
|
||
|
|
///
|
||
|
|
/// - Parameters:
|
||
|
|
/// - date: 日期或时间戳
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: db,运动数组
|
||
|
1 year ago
|
func fbquerySportData(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_sport
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m-%d', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m-%d', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [SportModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = SportModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询体温数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataDate: 日期
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: 数组
|
||
|
1 year ago
|
func fbqueryTemperatureData(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_temperature
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE dataDate = '\(dataDate)'"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [TemperatureModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = TemperatureModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询血压数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataDate: 日期
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: 数组
|
||
|
1 year ago
|
func fbqueryBloodPressureData(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_bloodPressure
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE dataDate = '\(dataDate)'"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [BloodPressureModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = BloodPressureModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询血氧数据
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataDate: 日期
|
||
|
|
/// - queryType: 查询类型
|
||
|
|
/// - handle: 数组
|
||
|
1 year ago
|
func fbqueryBloodOxygenData(dataDate: String, queryType: DataQueryType, _ handle: @escaping ResultClosure) {
|
||
|
2 years ago
|
var querySQL = ""
|
||
|
1 year ago
|
let tableName = Metric.FB_table_bloodOxygen
|
||
|
2 years ago
|
switch queryType {
|
||
|
|
case .day:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE dataDate = '\(dataDate)'"
|
||
|
|
case .week:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%W', strftime('%s', '\(dataDate)'), 'unixepoch', 'weekday 6') = STRFTIME('%Y-%W', strftime('%s', dataDate), 'unixepoch', 'weekday 6') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
case .month:
|
||
|
|
querySQL = "SELECT *FROM \(tableName) WHERE strftime('%Y-%m', strftime('%s', '\(dataDate)'), 'unixepoch') = STRFTIME('%Y-%m', strftime('%s', dataDate), 'unixepoch') ORDER BY strftime('%s',dataDate) ASC"
|
||
|
|
default:
|
||
|
|
break
|
||
|
|
}
|
||
|
|
dataBase?.inDatabase { (db) in
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle([])
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
var models: [BloodOxygenModel] = []
|
||
|
|
while resultSet.next() {
|
||
|
|
if let model = BloodOxygenModel.deserialize(from: resultSet.resultDictionary as? [String: Any]) {
|
||
|
|
models.append(model)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(models)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 查询插入记录中最近的一条记录时间
|
||
|
|
/// - Parameters:
|
||
|
|
/// - dataType: 数据类型
|
||
|
1 year ago
|
func fbqueryLastRecordData(dataType: DataType, _ handle: @escaping LastRecordClosure) {
|
||
|
2 years ago
|
dataBase?.inDatabase { (db) in
|
||
|
|
let querySQL = "SELECT max(dataDate) as maxdate FROM \(Metric.tableName(dataType: dataType)) order by id DESC limit 1"
|
||
|
|
guard let resultSet = db.executeQuery(querySQL, withArgumentsIn: []) else {
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(nil)
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
// 获取最后一条数据的时间戳
|
||
|
|
var timestamp: Int?
|
||
|
|
if resultSet.next() {
|
||
|
|
if let maxDate = resultSet.string(forColumn: "maxdate") {
|
||
|
|
timestamp = DateClass.timeStrToTimestamp(maxDate, formatStr: dataType == .sport ? "yyyy-MM-dd HH:mm:ss" : "yyyy-MM-dd")
|
||
|
|
}
|
||
|
|
}
|
||
|
|
resultSet.close()
|
||
|
|
DispatchQueue.main.async {
|
||
|
|
handle(timestamp)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// 内部使用单个数查询
|
||
|
|
/// - Parameters:
|
||
|
|
/// - db: 数据库
|
||
|
|
/// - dataDate: 数据时间
|
||
|
|
/// - dataType: 数据类型
|
||
|
1 year ago
|
private func fbquerySingleData(db: FMDatabase, dataDate: String, dataType: DataType) -> [String: Any]? {
|
||
|
2 years ago
|
// 通用字段
|
||
|
|
let tableName = Metric.tableName(dataType: dataType)
|
||
|
|
let querySQL = "SELECT *FROM \(tableName) WHERE dataDate='\(dataDate)'"
|
||
|
|
let results = db.executeQuery(querySQL, withArgumentsIn: [])
|
||
|
|
guard let resultSet = results else {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
var result: [String : Any]?
|
||
|
|
while resultSet.next() {
|
||
|
|
result = resultSet.resultDictionary as? [String : Any]
|
||
|
|
}
|
||
|
|
return result
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
|