【2024 DigiKey创意大赛】- 基于毫米波雷达的生命体征检测及健康监护系统-监护模块

zygalaxy · 发表于2024-10-31 20:29

【2024 DigiKey创意大赛】- 基于毫米波雷达的生命体征检测及健康监护系统-监护模块 [复制链接]

<i class="pstatus"> 本帖最后由 zygalaxy 于 2024-10-31 19:52 编辑 </i>

## 【2024 DigiKey创意大赛】- 基于毫米波雷达的生命体征检测及健康监护系统 - 健康监护模块开发

## 一、模块概述

本健康监护模块旨在为用户提供实时的心率、呼吸频率和睡眠质量监测功能，通过先进的毫米波雷达技术和传感器，准确获取用户的生命体征数据，并在异常情况下自动报警，通知家人或医疗服务机构。同时，该模块还能生成详细的睡眠质量报告，帮助用户改善睡眠。

<ignore_js_op>

<div class="tip tip_4 aimg_tip" id="aimg_856809_menu" style="position: absolute; display: none" disautofocus="true">
<div class="xs0">
<p><strong>监护详细模块结构图.drawio.png</strong> <em class="xg1">(25.73 KB, 下载次数: 0)</em></p>
<p>
<a href="javascript:;" class="loginf" >下载附件</a>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_856809" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=856809&handlekey=savephoto_856809">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

## 二、功能需求

1. **心率监测**
 - 利用 MR60BHA1 毫米波雷达实时监测用户的心率。
 - 将心率数据通过 ESP32 模块传输至 LCD 触摸屏显示器和用户手机 APP，以便用户实时查看。
2. **呼吸频率监测**
 - 采用毫米波雷达技术精准监测用户的呼吸频率。
 - 当检测到呼吸频率异常时，自动报警并通知家人或医疗服务机构。
3. **睡眠质量监测**
 - 通过传感器监测用户的睡眠状态。
 - 生成详细的睡眠质量报告，包括入睡时间、睡眠时长、深度睡眠时间等信息。
 - 为用户提供改善睡眠的建议。

<ignore_js_op>

<div class="tip tip_4 aimg_tip" id="aimg_856810_menu" style="position: absolute; display: none" disautofocus="true">
<div class="xs0">
<p><strong>监护模块.drawio.png</strong> <em class="xg1">(49.42 KB, 下载次数: 0)</em></p>
<p>
<a href="javascript:;" class="loginf" >下载附件</a>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_856810" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=856810&handlekey=savephoto_856810">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

## 三、硬件需求

1. **MR60BHA1 毫米波非接触式心率传感器模块**：用于心率监测。
2. **毫米波雷达**：用于呼吸频率监测和睡眠质量监测。
3. **ESP32 评估板**：负责数据传输和处理。
4. **LCD 触摸屏显示器**：显示心率、呼吸频率和睡眠质量数据。

<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857284" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857284&handlekey=savephoto_857284">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857283" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857283&handlekey=savephoto_857283">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

## 四、软件设计

1. **数据采集**
 - 利用传感器模块和毫米波雷达采集用户的心率、呼吸频率和睡眠状态数据。
 - 确保数据采集的准确性和稳定性。

2. **数据处理**
 - 对采集到的数据进行处理和分析，提取有用的信息。
 - 计算心率、呼吸频率的平均值、最大值和最小值等统计信息。
 - 分析睡眠状态数据，生成睡眠质量报告。
3. **数据传输**
 - 通过 ESP32 模块将处理后的数据传输至 LCD 触摸屏显示器和用户手机 APP。
 - 确保数据传输的实时性和可靠性。
4. **报警系统**
 - 当检测到心率、呼吸频率异常或睡眠质量较差时，自动触发报警。
 - 报警方式可以是声音、震动或推送通知等。

## 五、用户界面设计

1. **LCD 触摸屏显示器界面**
 - 显示用户的心率、呼吸频率和睡眠质量数据。
 - 提供简洁明了的图表和数字显示，方便用户查看。
 
 
<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857283" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857283&handlekey=savephoto_857283">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

2. **手机 APP 界面**
 - 实时显示用户的健康数据，包括心率、呼吸频率和睡眠质量报告。
 - 提供历史数据查询功能，用户可以查看过去一段时间的健康数据。
 - 推送报警通知，当检测到异常情况时及时提醒用户。
 
 
<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857295" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857295&handlekey=savephoto_857295">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857293" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857293&handlekey=savephoto_857293">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

<ignore_js_op>

<div class="tip tip_4 aimg_tip" id="aimg_857292_menu" style="position: absolute; display: none" disautofocus="true">
<div class="xs0">
<p><strong>WechatIMG50.jpg</strong> <em class="xg1">(176.1 KB, 下载次数: 0)</em></p>
<p>
<a href="javascript:;" class="loginf" >下载附件</a>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857292" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857292&handlekey=savephoto_857292">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857291" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857291&handlekey=savephoto_857291">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

<ignore_js_op>

<a href="javascript:;" onclick="showWindow(this.id, this.getAttribute('url'), 'get', 0);" id="savephoto_857290" url="home.php?mod=spacecp&ac=album&op=saveforumphoto&aid=857290&handlekey=savephoto_857290">保存到相册</a>

</p>

</div>
<div class="tip_horn"></div>
</div>

</ignore_js_op>

## 六、部分代码

硬件代码：
```c
#include <Arduino.h>
#include <WiFi.h>
#include <PubSubClient.h>
#include <60ghzbreathheart.h>

// WiFi network credentials
const char *ssid = "zygalaxy";
const char *password = "12345678";

// MQTT broker settings
const char *mqtt_server = "104.168.82.148";
const int mqtt_port = 1883;
const char *clientId = "heart_breath_1";
const char *mqtt_user = "zygalaxy";
const char *mqtt_password = "YOUR_MQTT_PASSWORD";

//定义心率呼吸信息topic
const char *heart_rate_topic = "t/heart_rate";

const char *breath_topic = "t/breath_rate";

//定义睡眠topic

// 进出床状态
//0：未检测到；1：上床；2：下床
const char *bed_topic = "t/bed";

// 睡眠状态
const char *sleep_awake_topic = "t/sleep_awake";
const char *sleep_light_topic = "t/sleep_light";
const char *sleep_deep_topic = "t/sleep_deep";
const char *sleep_none_topic = "t/sleep_none";

// 睡眠时间
const char *awake_time_topic = "t/awake_time";
const char *light_time_topic = "t/light_time";
const char *deep_time_topic = "t/deep_time";

// 睡眠评分
const char *sleep_score_topic = "t/sleep_score";

// 综合睡眠状态
const char *sleep_statue_existence_topic = "t/sleep_statue/existence";
const char *sleep_statue_state_topic = "t/sleep_statue/state";
const char *sleep_statue_breath_rate_topic = "t/sleep_statue/breath_rate";
const char *sleep_statue_heart_rate_topic = "t/sleep_statue/heart_rate";
const char *sleep_statue_turn_num_topic = "t/sleep_statue/turn_num";
const char *sleep_statue_substantial_move_ratio_topic = "t/sleep_statue/substantial_move_ratio";
const char *sleep_statue_small_move_ratio_topic = "t/sleep_statue/small_move_ratio";
const char *sleep_statue_apnea_num_topic = "t/sleep_statue/apnea_num";

// 睡眠质量信息
const char *sleep_quality_score_topic = "t/sleep_quality/score";
const char *sleep_quality_time_total_topic = "t/sleep_quality/time_total";
const char *sleep_quality_awake_time_radio_topic = "t/sleep_quality/awake_time_radio";
const char *sleep_quality_light_time_radio_topic = "t/sleep_quality/light_time_radio";
const char *sleep_quality_deep_time_radio_topic = "t/sleep_quality/deep_time_radio";
const char *sleep_quality_outbed_time_topic = "t/sleep_quality/outbed_time";
const char *sleep_quality_outbed_num_topic = "t/sleep_quality/outbed_num";
const char *sleep_quality_breath_rate_topic = "t/sleep_quality/breath_rate";
const char *sleep_quality_heart_rate_topic = "t/sleep_quality/heart_rate";
const char *sleep_quality_apnea_num_topic = "t/sleep_quality/apnea_num";

// 异常睡眠情况
const char *sleep_less4h_topic = "t/sleep_less4h";
const char *sleep_over12h_topic = "t/sleep_over12h";
const char *longtime_noone_topic = "t/longtime_noone";
const char *error_none_topic = "t/error_none";

WiFiClient wifiClient;
PubSubClient client(wifiClient);

BreathHeart_60GHz radar = BreathHeart_60GHz(&Serial1);

void callback(char *topic, byte *payload, unsigned int length) {
  Serial.print("Message arrived on topic: ");
  Serial.println(topic);
  Serial.print("Message:");
  for (int i = 0; i < length; i++) {
  Serial.print((char) payload<i>);
  }
  Serial.println();
}

void reconnect() {
  while (!client.connected()) {
  Serial.print("Attempting MQTT connection...");
  if (client.connect(clientId, mqtt_user, mqtt_password)) {
    Serial.println(" connected");
  } else {
    Serial.print(" failed, rc=");
    Serial.print(client.state());
    Serial.println(" try again in 5 seconds");
    delay(5000);
  }
  }
}

void setup() {
  Serial.begin(115200);
  Serial1.begin(115200);
  while (!Serial);
  Serial.println("Ready");
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
  delay(500);
  Serial.print(".");
  }
  Serial.println("\nConnected to the WiFi network");

client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);
}
int a=0;
void loop() {
  if (!client.connected()) {
  reconnect();
  }
  client.loop();

radar.BreathHeart_Breath_Sleep_Decode_Heart();

if (radar.sensor_report != 0x00) {
  switch (radar.sensor_report) {
    case HEARTRATEVAL:
      Serial.print("Sensor monitored the current heart rate value is: ");
      Serial.println(radar.heart_rate, DEC);
      client.publish(heart_rate_topic, String(radar.heart_rate).c_str());
      Serial.println("----------------------------");
      break;
    case HEARTRATEWAVE:
      // Heart rate wave data can be published as well if needed.
      Serial.print("The heart rate waveform(Sine wave) -- point 1: ");
      Serial.print(radar.heart_point_1);
      Serial.print(", point 2 : ");
      Serial.print(radar.heart_point_2);
      Serial.print(", point 3 : ");
      Serial.print(radar.heart_point_3);
      Serial.print(", point 4 : ");
      Serial.print(radar.heart_point_4);
      Serial.print(", point 5 : ");
      Serial.println(radar.heart_point_5);
      Serial.println("----------------------------");
      break;
    case BREATHNOR:
      Serial.println("Sensor detects current breath rate is normal.");
      client.publish(breath_topic, "Normal");
      Serial.println("----------------------------");
      break;
    case BREATHRAPID:
      Serial.println("Sensor detects current breath rate is too fast.");
      //client.publish(breath_topic, "Rapid");
      Serial.println("----------------------------");
      break;
    case BREATHSLOW:
      Serial.println("Sensor detects current breath rate is too slow.");
      //client.publish(breath_topic, "Slow");
      Serial.println("----------------------------");
      break;
    case BREATHNONE:
      Serial.println("There is no breathing information yet, please wait...");
      break;
    case BREATHVAL:
      Serial.print("Sensor monitored the current breath rate value is: ");
      Serial.println(radar.breath_rate);
      client.publish(breath_topic, String(radar.breath_rate).c_str());
      Serial.println("----------------------------");
      break;
    case BREATHWAVE:
      // Breath wave data can be published as well if needed.
      Serial.print("The breath rate waveform(Sine wave) -- point 1: ");
      Serial.print(radar.breath_point_1);
      Serial.print(", point 2 : ");
      Serial.print(radar.breath_point_2);
      Serial.print(", point 3 : ");
      Serial.print(radar.breath_point_3);
      Serial.print(", point 4 : ");
      Serial.print(radar.breath_point_4);
      Serial.print(", point 5 : ");
      Serial.println(radar.breath_point_5);
      Serial.println("----------------------------");
      break;
      //睡眠信息
    case OUTBED:
      Serial.println("Sensor detects someone currently leaving the bed.");
      Serial.println("----------------------------");

break;
    case INBED:
      Serial.println("Sensor detects that someone is currently in bed.");
      Serial.println("----------------------------");
      break;
    case NOINOUT:
      Serial.println("No subject is detected leaving or going to bed.");
      Serial.println("----------------------------");
      break;
    case SLEEPAWAKE:
      Serial.println("Sensor detects that the monitoring people is awake.");
      Serial.println("----------------------------");
      break;
    case SLEEPLIGHT:
      Serial.println("Sensor detects that the monitoring people is in light sleeping.");
      Serial.println("----------------------------");
      break;
    case SLEEPDEEP:
      Serial.println("Sensor detects that the monitoring people is in deep sleeping.");
      Serial.println("----------------------------");
      break;
    case SLEEPNONE:
      Serial.println("Sleep state of the object is not detected.");
      Serial.println("----------------------------");
      break;
    case AWAKETIME:
      Serial.print("Sensor monitored the awake sleep time is: ");
      Serial.print(radar.awake_time);
      Serial.println(" min");
      Serial.println("----------------------------");
      break;
    case LIGHTTIME:
      Serial.print("Sensor monitored the light sleep time is: ");
      Serial.print(radar.light_time);
      Serial.println(" min");
      Serial.println("----------------------------");
      break;
    case DEEPTIME:
      Serial.print("Sensor monitored the deep sleep time is: ");
      Serial.print(radar.deep_time);
      Serial.println(" min");
      Serial.println("----------------------------");
      break;
    case SLEEPSCORE:
      Serial.print("Sensor judgment sleep score is: ");
      Serial.println(radar.sleep_score);
      Serial.println("----------------------------");
      break;
    case SLEEPSTATUE:
      Serial.println("Sleep integrated state information -- ");
      Serial.print("Human existence: ");
      if (radar.existence)Serial.println("human exis");
      else Serial.println("human non-existent");
      Serial.print("Sleep state: ");
      if (radar.sleep_status == SLEEPDEEP)Serial.println("sleeping soundly");
      else if (radar.sleep_status == SLEEPLIGHT)Serial.println("light sleep");
      else if (radar.sleep_status == SLEEPAWAKE)Serial.println("awake");
      else if (radar.sleep_status == SLEEPNONE)Serial.println("off the bed");
      Serial.print("Average breathing: ");
      Serial.println(radar.breath_rate);
      Serial.print("Average heart rate: ");
      Serial.println(radar.heart_rate);
      Serial.print("Number of turning over during sleep: ");
      Serial.println(radar.turn_num);
      Serial.print("Percentage of substantial exercise during sleep: ");
      Serial.println(radar.substantial_move_ratio);
      Serial.print("Percentage of small-amplitude movements during sleep: ");
      Serial.println(radar.samll_move_ratio);
      Serial.print("Number of apnea: ");
      Serial.println(radar.apnea_num);
      Serial.println("----------------------------");
      break;
    case SLEEPQUALITY:
      Serial.println("Quality of sleep information -- ");
      Serial.print("Sleep score: ");
      Serial.println(radar.sleep_score);
      Serial.print("Total time of sleep: ");
      Serial.print(radar.sleep_time);
      Serial.println(" min");
      Serial.print("Percentage of waking time: ");
      Serial.println(radar.awake_time_radio);
      Serial.print("Percentage of light sleep time: ");
      Serial.println(radar.light_time_radio);
      Serial.print("Percentage of deep sleep time: ");
      Serial.println(radar.deep_time_radio);
      Serial.print("Total time away from bed: ");
      Serial.print(radar.outbed_time);
      Serial.println(" min");
      Serial.print("Total number of times out of bed: ");
      Serial.println(radar.outbed_num);
      Serial.print("The number of turning over during sleep: ");
      Serial.println(radar.turn_num);
      Serial.print("Average breathing: ");
      Serial.println(radar.breath_rate);
      Serial.print("Average heart rate: ");
      Serial.println(radar.heart_rate);
      Serial.print("Number of apnea: ");
      Serial.println(radar.apnea_num);
      Serial.println("----------------------------");
      break;
    case SLEEPLESS4H:
      Serial.print("The monitored subjects slept for less than 4 hours.");
      Serial.println("----------------------------");
      break;
    case SLEEPOVER12H:
      Serial.print("The length of sleep of the monitored subjects exceeded 12 hours.");
      Serial.println("----------------------------");
      break;
    case LONGTIMENOONE:
      Serial.print("Abnormally unoccupied for long periods of time.");
      Serial.println("----------------------------");
      break;
    case ERRORNONE:
      Serial.print("No abnormal information.");
      Serial.println("----------------------------");
      break;
  }
  }
  delay(200);
}
```
软件代码：

```python
# 心率呼吸查询
@app.route('/heart_rate_respiration', methods=['GET'])
def get_heart_rate_respiration():
  reply = {"result": "ok", "message": "success"}
  device_id = request.args.get('device_id')
  start_date = request.args.get('start_date')
  end_date = request.args.get('end_date')
  if device_id and start_date and end_date:
  # 先在心率查询，再在呼吸查询
  heart_rate_data = HeartRateData.query.filter(
    HeartRateData.device_id == device_id,
    HeartRateData.timestamp >= start_date,
    HeartRateData.timestamp <= end_date
  ).all()
  respiration_data = RespirationData.query.filter(
    RespirationData.device_id == device_id,
    RespirationData.timestamp >= start_date,
    RespirationData.timestamp <= end_date
  ).all()
  heart_rate_data = [
    {
      'device_id': heart_rate.device_id,
      'heart_rate': heart_rate.heart_rate,
      'timestamp': heart_rate.timestamp
    }
    for heart_rate in heart_rate_data
  ]
  respiration_data = [
    {
      'device_id': respiration.device_id,
      'breathing': respiration.breathing,
      'timestamp': respiration.timestamp
    }
    for respiration in respiration_data
  ]
  return json.dumps(heart_rate_data + respiration_data), 200

```

```python
@app.route('/heart_rate', methods=['POST'])
def heart_rate():
  reply = {"result": "ok", "message": "success"}
  """
  {'publish_received_at': 1723569671836, 'pub_props': {'User-Property': {}}, 'peerhost': '39.85.60.209', 'qos': 0, 'topic': 't/heart_rate', 'clientid': 'mqttx_7492d77a', 'payload': '{
  \n"msg": "hello HTTP Server"\n}', 'username': 'undefined', 'event': 'message.publish', 'metadata': {'rule_id': 'heart_rate_WH_D'}, 'timestamp': 1723569671836,
  """
  raw_data = request.get_json()
  print(raw_data)
  device_id = raw_data['clientid']
  device = DeviceInfo.query.filter_by(device_id=device_id).first()
  if device and raw_data['payload'] != '0':
  # payload转化为 json

heart_rate_data = HeartRateData(
    device_id=device_id,
    timestamp=datetime.utcnow(),
    user_id=device.user_id,
    heart_rate=raw_data['payload']
  )
  db.session.add(heart_rate_data)
  db.session.commit()
  socketio.emit('message', '心率数据：' + device_id + ' ' + raw_data['payload'])

return json.dumps(reply), 200

```

### 总结

通过开发健康监护模块可以将心率、呼吸、温湿度等重要的信息传输到服务器，以便于 APP 和 LCD 查看，为后面的数据分析打下了数据的基础。

【2024 DigiKey创意大赛】- 基于毫米波雷达的生命体征检测及健康监护系统-监护模块 [复制链接]

浏览过的版块