#include <ctime>
#include "kv_store.h"
#include "custom_utils.h"
+#include "custom_runtime.h"
#include <fstream>
#include <sstream>
#include <string>
#include <cstdint>
#include "heartrate/include/HeartModel.h"
#include "bloodoxygen/include/BloodOxygenModel.h"
+
namespace OHOS
{
extern "C"
{
+ void uapi_dev_runtime_set_bloodoxygen_storage_status(uint8_t status);
+ void uapi_dev_runtime_set_heartrate_storage_status(uint8_t status);
+
void save_heart_data()
{
printf("save_heart_data\r\n");
cJSON_Delete(heart_root);
return data;
}
+
// 保存血氧数据
- bool HealthService::UpdateHealthData(const BloodOxygenData &data)
- {
- // 判断文件夹是否存在
- if (!CreateHealthFolder())
- {
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "CreateHealthFolder file");
- return false;
- }
+ bool HealthService::UpdateHealthData(const BloodOxygenData &data)
+ {
+ // 配置血氧存储状态
+ uapi_dev_runtime_set_bloodoxygen_storage_status(1);
- // 判断文件是否存在 不存在即创建 并打开以输出模式
- std::ofstream outFile(BLOOD_JSON_PATH, std::ios::trunc);
- if (!outFile.is_open())
- {
- // 文件创建失败
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to create or open JSON file for writing");
- return false;
- }
+ // 判断文件夹是否存在
+ if (!CreateHealthFolder())
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "CreateHealthFolder file");
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return false;
+ }
- // 创建一个 JSON 对象
- cJSON *oxygen_root = cJSON_CreateObject();
- if (oxygen_root == NULL)
- {
- outFile.close();
- return false;
- }
+ // 判断文件是否存在，不存在即创建并打开以输出模式
+ std::ofstream outFile(BLOOD_JSON_PATH, std::ios::trunc);
+ if (!outFile.is_open())
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to create or open JSON file for writing");
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return false;
+ }
- cJSON_AddItemToObject(oxygen_root, "value", cJSON_CreateNumber(data.SPO2));
- cJSON_AddItemToObject(oxygen_root, "timestamp", cJSON_CreateNumber(data.timestamp));
+ // 创建一个 JSON 对象
+ cJSON *oxygen_root = cJSON_CreateObject();
+ if (oxygen_root == NULL)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to create JSON object");
+ outFile.close();
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return false;
+ }
- char *jsonData = cJSON_Print(oxygen_root);
- if (jsonData == NULL)
- {
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to generate JSON data");
- cJSON_free(oxygen_root);
- outFile.close();
- return false;
- }
+ cJSON_AddItemToObject(oxygen_root, "value", cJSON_CreateNumber(data.SPO2));
+ cJSON_AddItemToObject(oxygen_root, "timestamp", cJSON_CreateNumber(data.timestamp));
- // 写入 JSON 数据到文件
- outFile << jsonData;
+ char *jsonData = cJSON_Print(oxygen_root);
+ if (jsonData == NULL)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to generate JSON data");
+ cJSON_Delete(oxygen_root); // 释放内存
+ outFile.close();
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return false;
+ }
- cJSON_free(oxygen_root);
- free(jsonData);
- outFile.close();
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "UpdateHealthData SPO2 JSON is ok");
+ // 写入 JSON 数据到文件
+ outFile << jsonData;
- /* 存储bin文件[协议使用] */
- std::string binFilePath = GetBinFilePath(HEALTH_TYPE_OXYGEN);
- FILE *fp = fopen(binFilePath.c_str(), "ab+");
- if (fp == NULL)
- {
- return false;
- }
+ // 释放资源
+ cJSON_Delete(oxygen_root);
+ free(jsonData);
+ outFile.close();
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "UpdateHealthData SPO2 JSON is ok");
+
+ /* 存储bin文件[协议使用] */
+ std::string binFilePath = GetBinFilePath(HEALTH_TYPE_OXYGEN);
+ FILE *fp = fopen(binFilePath.c_str(), "ab+");
+ if (fp == NULL)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to open binary file for writing");
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return false;
+ }
- fwrite(&data.timestamp, 4, 1, fp);
- fwrite(&data.SPO2, 1, 1, fp);
+ // 写入数据
+ if (fwrite(&data.timestamp, sizeof(data.timestamp), 1, fp) != 1 ||
+ fwrite(&data.SPO2, sizeof(data.SPO2), 1, fp) != 1)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to write data to binary file");
+ fclose(fp);
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return false;
+ }
- fclose(fp);
+ fclose(fp);
- return true;
+
+ uapi_dev_runtime_set_bloodoxygen_storage_status(0); // 恢复状态
+ return true;
}
- // 存储心率
- bool HealthService::UpdateHealthData(const HeartRateData &data)
- {
- // 判断文件夹是否存在
- if (!CreateHealthFolder())
- {
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "CreateHealthFolder file");
- return false;
- }
+ //存储心率
+ bool HealthService::UpdateHealthData(const HeartRateData &data)
+ {
+ // 配置心率存储状态
+ uapi_dev_runtime_set_heartrate_storage_status(1);
- // 判断文件是否存在 不存在即创建 并打开以输出模式
- std::ofstream outFile(HEART_JSON_PATH, std::ios::trunc);
- if (!outFile.is_open())
- {
- // 文件创建失败
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to create or open JSON file for writing");
- return false;
- }
+ // 判断文件夹是否存在
+ if (!CreateHealthFolder())
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "CreateHealthFolder file");
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
- // 创建一个 JSON 对象
- cJSON *heart_root = cJSON_CreateObject();
- if (heart_root == NULL)
- {
- outFile.close();
- return false;
- }
+ // 判断文件是否存在，不存在即创建并打开以输出模式
+ std::ofstream outFile(HEART_JSON_PATH, std::ios::trunc);
+ if (!outFile.is_open())
+ {
+ // 文件创建失败
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to create or open JSON file for writing");
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
+
+ // 创建一个 JSON 对象
+ cJSON *heart_root = cJSON_CreateObject();
+ if (heart_root == NULL)
+ {
+ outFile.close();
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
- cJSON_AddItemToObject(heart_root, "value", cJSON_CreateNumber(data.Heart));
- cJSON_AddItemToObject(heart_root, "timestamp", cJSON_CreateNumber(data.timestamp));
+ cJSON_AddItemToObject(heart_root, "value", cJSON_CreateNumber(data.Heart));
+ cJSON_AddItemToObject(heart_root, "timestamp", cJSON_CreateNumber(data.timestamp));
- char *jsonData = cJSON_Print(heart_root);
- if (jsonData == NULL)
- {
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to generate JSON data");
- cJSON_free(heart_root);
- outFile.close();
- return false;
- }
+ char *jsonData = cJSON_Print(heart_root);
+ if (jsonData == NULL)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to generate JSON data");
+ cJSON_Delete(heart_root); // 使用 cJSON_Delete 释放内存
+ outFile.close();
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
- // 写入 JSON 数据到文件
- outFile << jsonData;
+ // 写入 JSON 数据到文件
+ outFile << jsonData;
- cJSON_free(heart_root);
- free(jsonData);
- outFile.close();
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "UpdateHealthData Heart JSON is ok");
+ // 释放资源
+ cJSON_Delete(heart_root);
+ free(jsonData);
+ outFile.close();
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "UpdateHealthData Heart JSON is ok");
- // 写入文件到当天历史数据
+ // 写入文件到当天历史数据
UpdateHourlyHeartRate(data.timestamp, data.Heart);
- WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "UpdateHourlyHeartRate is ok");
- /* 存储bin文件[协议使用] */
- std::string binFilePath = GetBinFilePath(HEALTH_TYPE_HEART);
- FILE *fp = fopen(binFilePath.c_str(), "ab+");
- if (fp == NULL)
- {
- return false;
- }
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "UpdateHourlyHeartRate is ok");
- fwrite(&data.timestamp, 4, 1, fp);
- fwrite(&data.Heart, 1, 1, fp);
+ if (!SaveDailyHeartRate()) // 进行心率历史数据文件存储
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "SaveDailyHeartRate failed");
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
- fclose(fp);
+ /* 存储 bin 文件 [协议使用] */
+ std::string binFilePath = GetBinFilePath(HEALTH_TYPE_HEART);
+ FILE *fp = fopen(binFilePath.c_str(), "ab+");
+ if (fp == NULL)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to open binary file for writing");
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
- return true;
+ // 写入数据
+ if (fwrite(&data.timestamp, sizeof(data.timestamp), 1, fp) != 1 ||
+ fwrite(&data.Heart, sizeof(data.Heart), 1, fp) != 1)
+ {
+ WEARABLE_LOGE(WEARABLE_LOG_MODULE_APP, "Failed to write data to binary file");
+ fclose(fp);
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return false;
+ }
+
+ fclose(fp);
+
+ uapi_dev_runtime_set_heartrate_storage_status(0); // 恢复状态
+ return true;
}
// 清空健康数据
bool HealthService::CleanHealthData()
#include "custom_runtime.h"
#include "chip_system_time.h"
+#include <stdint.h>
uint8_t repair_download_status;//升级下载状态
uint8_t hrs_passivity_status;//获取被动心率检测状态
uint8_t mmc_status; //是否为指南针页面
+ //读写锁
+ uint8_t rwlock_status;//手表状态（存储）
+ uint8_t lock_flag_training;//训练
+ uint8_t lock_flag_heartrate;//心率
+ uint8_t lock_flag_blood;//血氧
+
} runtime_status_t;
return g_runtime.enter_safemode;
}
+//读写锁状态
+void uapi_dev_runtime_set_rwlock_status(uint8_t status)
+{
+ // 不能有set
+ // g_runtime.rwlock_status = status;
+}
+uint8_t uapi_dev_runtime_get_rwlock_status(void)
+{
+ //读写状态取决与所有的模块存储状态
+ g_runtime.rwlock_status = 0;
+ if(g_runtime.lock_flag_training)
+ {
+ //运动存储
+ g_runtime.rwlock_status = 1;
+ }
+ if(g_runtime.lock_flag_heartrate)
+ {
+ //心率存储
+ g_runtime.rwlock_status = 1;
+ }
+ if(g_runtime.lock_flag_blood)
+ {
+ //血氧存储
+ g_runtime.rwlock_status = 1;
+ }
+ return g_runtime.rwlock_status;
+}
+//设置运动存储
+void uapi_dev_runtime_set_train_storage_status(uint8_t status)
+{
+ g_runtime.lock_flag_training = status;
+}
+uint8_t uapi_dev_runtime_get_train_storage_status(void)
+{
+ return g_runtime.lock_flag_training;
+}
+//设置心率存储
+void uapi_dev_runtime_set_heartrate_storage_status(uint8_t status)
+{
+ g_runtime.lock_flag_heartrate = status;
+}
+uint8_t uapi_dev_runtime_get_heartrate_storage_status(void)
+{
+ return g_runtime.lock_flag_heartrate;
+}
+//设置血氧存储
+void uapi_dev_runtime_set_bloodoxygen_storage_status(uint8_t status)
+{
+ g_runtime.lock_flag_blood = status;
+}
+uint8_t uapi_dev_runtime_get_bloodoxygen_storage_status(void)
+{
+ return g_runtime.lock_flag_blood;
+}
+//后续还需要补充。。。
+
// 设置被动心率检测状态
void uapi_dev_runtime_set_hrs_passivity(uint8_t status)
{
projects / mirrors / FD230.git / commitdiff