kotlin
package com.wifihealth.monitor
import android.os.Bundle
import androidx.appcompat.app.AppCompatActivity
import androidx.lifecycle.*
import com.github.mikephil.charting.charts.LineChart
import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*
/**
* 主界面: 实时显示心率、呼吸、CSI波形
*/
class MainActivity : AppCompatActivity() {
private lateinit var binding: ActivityMainBinding
// 核心组件
private lateinit var bleManager: Esp32BleManager
private lateinit var csiProcessor: CsiDataProcessor
private lateinit var signalProcessor: SignalProcessor
private lateinit var vitalExtractor: VitalSignExtractor
private lateinit var fallDetector: FallDetector
private lateinit var alertManager: AlertManager
// 状态流
private val _uiState = MutableStateFlow(UiState())
val uiState: StateFlow<UiState> = _uiState.asStateFlow()
private val scope = CoroutineScope(SupervisorJob() + Dispatchers.Main)
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
binding = ActivityMainBinding.inflate(layoutInflater)
setContentView(binding.root)
initComponents()
setupUI()
startMonitoring()
}
private fun initComponents() {
csiProcessor = CsiDataProcessor()
signalProcessor = SignalProcessor()
vitalExtractor = VitalSignExtractor(signalProcessor)
fallDetector = FallDetector(this)
alertManager = AlertManager(this)
bleManager = Esp32BleManager(this) { csiFrame ->
// CSI数据回调
processCsiFrame(csiFrame)
}
}
private fun setupUI() {
// 绑定图表
setupHeartChart(binding.chartHeart)
setupBreathChart(binding.chartBreath)
setupCsiChart(binding.chartCsi)
// 连接状态
lifecycleScope.launch {
bleManager.connectionState.collect { state ->
updateConnectionUI(state)
}
}
// UI状态更新
lifecycleScope.launch {
uiState.collect { state ->
updateVitalDisplay(state)
}
}
// 按钮事件
binding.btnConnect.setOnClickListener { scanAndConnect() }
binding.btnStart.setOnClickListener { bleManager.startCsiCollection() }
binding.btnStop.setOnClickListener { bleManager.stopCsiCollection() }
}
/**
* 处理每一帧CSI数据 (运行在IO线程)
*/
private fun processCsiFrame(frame: CsiFrame) {
scope.launch(Dispatchers.Default) {
// 1. 预处理
val processed = csiProcessor.processNewFrame(frame) ?: return@launch
// 2. 获取最近的时间序列
val recentData = csiProcessor.getRecentSequence(
SignalProcessor.SAMPLING_RATE.toInt() * 30 // 30秒窗口
)
if (recentData.size < 100) return@launch // 数据不足
val phaseSequence = recentData.map { it.phase.toDouble() }.toDoubleArray()
// 3. 提取生命体征 (每5秒执行一次)
if (frame.sequenceNumber % (5 * 500) == 0) {
val vitals = vitalExtractor.extractVitalSigns(phaseSequence)
checkVitalAlerts(vitals)
withContext(Dispatchers.Main) {
_uiState.update {
it.copy(
heartRate = vitals.heartRate,
breathRate = vitals.breathRate,
heartConfidence = vitals.heartConfidence,
breathConfidence = vitals.breathConfidence,
heartWaveform = vitals.heartWaveform,
breathWaveform = vitals.breathWaveform
)
}
}
}
// 4. 跌倒检测 (每1秒执行)
if (frame.sequenceNumber % 500 == 0) {
val amplitudeSequence = recentData.map { it.amplitude.toDouble() }.toDoubleArray()
val spectrogram = signalProcessor.computeSpectrogram(amplitudeSequence)
val fallResult = fallDetector.processFrame(spectrogram, signalProcessor)
if (fallResult.isFallDetected) {
withContext(Dispatchers.Main) {
alertManager.triggerFallAlert(
confidence = fallResult.confidence
)
}
}
}
// 5. 更新实时CSI波形
withContext(Dispatchers.Main) {
updateCsiWaveform(processed)
}
}
}
private fun checkVitalAlerts(vitals: VitalSignsResult) {
// 心率异常
when {
vitals.heartRate < AlertManager.HEART_RATE_MIN -> {
alertManager.triggerHeartRateAlert(vitals.heartRate, isTooLow = true)
}
vitals.heartRate > AlertManager.HEART_RATE_MAX -> {
alertManager.triggerHeartRateAlert(vitals.heartRate, isTooLow = false)
}
}
// 呼吸异常
when {
vitals.breathRate < AlertManager.BREATH_RATE_MIN -> {
alertManager.triggerBreathAlert(vitals.breathRate)
}
vitals.breathRate > AlertManager.BREATH_RATE_MAX -> {
alertManager.triggerBreathAlert(vitals.breathRate)
}
}
// 呼吸暂停检测 (呼吸频率接近0且持续)
if (vitals.breathRate < 3 && vitals.breathConfidence > 0.7) {
alertManager.triggerBreathAlert(vitals.breathRate, isApnea = true)
}
}
private fun scanAndConnect() {
// 扫描并连接ESP32设备
}
override fun onDestroy() {
super.onDestroy()
fallDetector.close()
scope.cancel()
}
}
data class UiState(
val isConnected: Boolean = false,
val isMonitoring: Boolean = false,
val heartRate: Double = 0.0,
val breathRate: Double = 0.0,
val heartConfidence: Double = 0.0,
val breathConfidence: Double = 0.0,
val heartWaveform: List<Double> = emptyList(),
val breathWaveform: List<Double> = emptyList(),
val csiAmplitude: List<Float> = emptyList()
)