VitalApp/lib/pages/medical/widgets/heart_rate.dart

import 'dart:async';
import 'dart:convert';

import 'package:flutter/material.dart';
import 'package:get/get.dart';
import 'package:vitalapp/managers/interfaces/data_convert.dart';
import 'package:vitalapp/managers/interfaces/models/device.dart';
import 'package:vitalapp/pages/medical/controllers/heart.dart';
import 'package:vitalapp/pages/medical/widgets/device_status.dart';
import 'package:vitalapp/pages/medical/widgets/device_status_position.dart';
import 'package:vitalapp/pages/medical/widgets/ecg_view/index.dart';
import 'package:vnote_device_plugin/consts/types.dart';
import 'package:vnote_device_plugin/devices/heart.dart';
import 'package:vitalapp/pages/check/widgets/exam_configurable/exam_card.dart';

import 'package:vitalapp/pages/medical/controller.dart';
import 'package:vitalapp/pages/medical/models/worker.dart';
import 'package:vitalapp/pages/medical/widgets/side_bar.dart';
import 'dart:ui' as ui;
import 'dart:typed_data';
import 'package:fis_common/logger/logger.dart';
import 'package:vnote_device_plugin/models/exams/heart.dart';

class HeartRate extends StatefulWidget {
  const HeartRate({
    super.key,
  });

  @override
  State<HeartRate> createState() => _HeartRateState();
}

class _HeartRateState extends State<HeartRate> {
  var controller = Get.find<MedicalController>();
  late HeartDeviceController heart;
  late HeartDeviceWorker worker;
  final dataConvertManager = Get.find<IDataConvertManager>();
  WorkerStatus _connectStatus = WorkerStatus.connecting;
  List<int> ecgPoint = [];
  int errorCount = 0;
  bool isConnectFail = false;
  late String _heart =
      controller.diagnosisDataValue['Heart']?['HEART']?.toString() ?? '';
  late String _assess = controller.diagnosisDataValue['Heart']?['ASSESS'] ?? '';
  late final String _ecg = controller.diagnosisDataValue['Heart']?['ECG'] ?? '';
  late final String _ecgPoint =
      controller.diagnosisDataValue['Heart']?['ECG_POINT'] ?? '';
  late final heartRate = controller.diagnosisDataValue['Heart']?['HEART'] ?? 0;

  String _deviceError = '';
  @override
  void initState() {
    WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
      initHeart();
    });
    print(controller.diagnosisDataValue['Heart']?['ECG_POINT']);
    super.initState();
  }

  Future<void> connect() async {
    await worker.connect();
  }

  Future<void> disconnect() async {
    if (!(worker == null)) {
      await worker.disconnect();
      releaseListeners();
    }
  }

  void releaseListeners() {
    worker.connectErrorEvent.removeListener(_onConnectFail);
    worker.connectedEvent.removeListener(_onConnectSuccess);
    // worker.successEvent.removeListener(_onSuccess);
    worker.disconnectedEvent.removeListener(_onDisconnected);
    worker.hrValueUpdateEvent.removeListener(_onHrValueUpdate);
    worker.ecgValueUpdateEvent.removeListener(_onEcgValueUpdate);
    worker.resultReceivedEvent.removeListener(_onRCesultReceived);
    worker.errorEvent.removeListener(_onError);
  }

  @override
  void dispose() {
    disconnect();
    super.dispose();
  }

  void loadListeners() {
    // worker.successEvent.addListener(_onSuccess);
    worker.connectErrorEvent.addListener(_onConnectFail);
    worker.connectedEvent.addListener(_onConnectSuccess);
    worker.disconnectedEvent.addListener(_onDisconnected);
    worker.hrValueUpdateEvent.addListener(_onHrValueUpdate);
    worker.ecgValueUpdateEvent.addListener(_onEcgValueUpdate);
    worker.resultReceivedEvent.addListener(_onRCesultReceived);
    worker.errorEvent.addListener(_onError);
    worker.connect();
  }

  Future<void> currentDevice() async {
    DeviceModel? device = await controller.getDevice(DeviceTypes.HEART);
    if (device == null) {
      _connectStatus = WorkerStatus.unboundDevice;
      setState(() {});
      return;
    }
    heart = HeartDeviceController(device.model, device.mac);
    worker = heart.worker;
    _connectStatus = heart.connectStatus;

    loadListeners();
  }

  Future<void> initHeart() async {
    currentDevice();

    await initData();
  }

  Future<void> initData() async {
    // await Future.delayed(const Duration(milliseconds: 800));
    await controller.readCachedRecord();
    if (controller.diagnosisDataValue['Heart'] == null) {
      controller.diagnosisDataValue['Heart'] = {};
    }

    setState(() {});
  }

  void _onHrValueUpdate(_, int e) {
    logger.i('心率更新：$e');
    if (_deviceError.isNotEmpty) {
      _deviceError = '';
    }
    setState(() {
      _heart = e.toString();
    });
  }

  void _onError(_, String e) {
    logger.i('心率更新失败：$e');
    _deviceError = e;
    ecgPoint = [];
    try {
      EcgViewController ecgViewController = Get.find<EcgViewController>();
      ecgPoint = [];
      ecgViewController.reset();
    } catch (e) {}
    setState(() {});
  }

  void _onRCesultReceived(_, HeartExamResult e) async {
    logger.i('心率更新接收结果：${e.heartRate}');
    print(ecgPoint.toString());
    // _heart = e.toString();
    _assess = e.analysis.first;
    _heart = e.heartRate.toString();
    controller.diagnosisDataValue['Heart']?['HEART'] = e.heartRate.toString();
    controller.diagnosisDataValue['Heart']?['ASSESS'] =
        dataConvertManager.heartRateConversion(int.parse(heartRate));

    try {
      EcgViewController ecgViewController = Get.find<EcgViewController>();
      controller.diagnosisDataValue['Heart']?['ECG_POINT'] =
          jsonEncode(ecgViewController.allPoints);
      controller.diagnosisDataValue['Heart']?['ECG'] =
          await ecgViewController.getFullDataImageBase64();
    } catch (e) {
      print(e);
    }
    controller.saveCachedRecord();
    print(controller.diagnosisDataValue);
    setState(() {});
  }

  void _onEcgValueUpdate(_, List<int> e) {
    try {
      EcgViewController ecgViewController = Get.find<EcgViewController>();
      ecgPoint.addAll(e);
      if (ecgPoint.length > 125 * 3) {
        ecgViewController.addData(e);
      }
    } catch (e) {
      print(e);
    }
  }

  void _onConnectFail(sender, e) {
    logger.i("设备连接失败:${worker.mac}");
    if (errorCount < 3) {
      errorCount++;
      disconnect();
      loadListeners();
    } else {
      isConnectFail = true;
    }
    _connectStatus = WorkerStatus.connectionFailed;

    setState(() {});
  }

  void _onDisconnected(sender, e) {
    print('设备连接中断');
    logger.i("设备连接中断:${worker.mac}");
    if (errorCount < 3) {
      errorCount++;
      disconnect();
      loadListeners();
    } else {
      isConnectFail = true;
    }
    _connectStatus = WorkerStatus.disconnected;
    setState(() {});
  }

  void _onConnectSuccess(sender, e) {
    logger.e('_HeartRateState ${worker.mac}, 设备连接成功');
    isConnectFail = false;
    errorCount = 0;
    _connectStatus = WorkerStatus.connected;
    setState(() {});
  }

  Future<String> createEcgImageBase64(List<int> points) async {
    final int width = points.length ~/ 2;
    const int height = 240;
    final ui.PictureRecorder recorder = ui.PictureRecorder();
    final Canvas canvas = Canvas(recorder);
    final Path path = Path();
    final Paint paint = Paint();
    const double strokeWidth = 1.5;

    paint.color = Colors.green;
    paint.style = PaintingStyle.stroke;
    paint.isAntiAlias = true;
    paint.strokeWidth = strokeWidth;

    path.reset();
    int pointCount = points.length;
    if (pointCount > 0) {
      path.moveTo(0, points[0].toDouble());
      int i = 0;
      int j = pointCount ~/ 2;
      while (i < j) {
        path.lineTo(i.toDouble(), points[i].toDouble());
        path.lineTo((i + 1).toDouble(), points[i + 1].toDouble());
        i += 2;
      }
      canvas.drawPath(path, paint);
    }

    final ui.Picture picture = recorder.endRecording();
    final ui.Image image = await picture.toImage(width, height);
    final ByteData? byteData =
        await image.toByteData(format: ui.ImageByteFormat.png);
    final Uint8List pngBytes = byteData!.buffer.asUint8List();

    final String base64Image = base64Encode(pngBytes);
    return base64Image;
  }

  /// 需要封装一下
  Widget _buildErrorButton() {
    return DeviceStatusPosition(
      deviceStatus: Row(
        children: [
          const Text(
            '请确认设备是否启动',
            style: TextStyle(fontSize: 24, color: Colors.red),
          ),
          IconButton(
            onPressed: () {
              worker.connect();
              setState(() {
                _connectStatus = WorkerStatus.connecting;
                isConnectFail = false;
              });
            },
            icon: const Icon(Icons.refresh),
            iconSize: 32,
          ),
        ],
      ),
    );
  }

  @override
  Widget build(BuildContext context) {
    return Stack(
      children: [
        ExamCard(
            titleText: const SizedBox(),
            // clickCard: () {},
            content: Column(
              mainAxisAlignment: MainAxisAlignment.start,
              children: [
                Row(
                  mainAxisAlignment: MainAxisAlignment.end,
                  children: [
                    const SideBar(
                      title: '心率',
                      value: '',
                      unit: '',
                    ),
                    const Expanded(child: SizedBox()),
                    Text(
                      _heart.isEmpty ? '--' : _heart,
                      style: const TextStyle(
                        fontSize: 60,
                        color: Colors.black,
                      ),
                    ),
                    const Text(
                      "  bpm",
                      style: TextStyle(fontSize: 25),
                    ),
                    const SizedBox(
                      width: 15,
                    )
                  ],
                ),
                if (_deviceError.isNotEmpty)
                  Row(
                    mainAxisAlignment: MainAxisAlignment.spaceBetween,
                    crossAxisAlignment: CrossAxisAlignment.start,
                    children: [
                      Container(
                        padding: const EdgeInsets.symmetric(
                          horizontal: 30,
                        ),
                        child: const Text(
                          '心率测量出错',
                          style: TextStyle(
                            fontSize: 25,
                          ),
                        ),
                      ),
                      Container(
                        padding: const EdgeInsets.symmetric(
                          horizontal: 50,
                        ),
                        child: Text(
                          _deviceError,
                          style: const TextStyle(
                            fontSize: 24,
                          ),
                        ),
                      ),
                    ],
                  ),
                if (_assess.isNotEmpty)
                  Row(
                    mainAxisAlignment: MainAxisAlignment.spaceBetween,
                    crossAxisAlignment: CrossAxisAlignment.start,
                    children: [
                      Container(
                        padding: const EdgeInsets.symmetric(
                          horizontal: 30,
                        ),
                        child: const Text(
                          '心率评估',
                          style: TextStyle(
                            fontSize: 25,
                          ),
                        ),
                      ),
                      Container(
                        padding: const EdgeInsets.symmetric(
                          horizontal: 50,
                        ),
                        child: Text(
                          dataConvertManager
                              .heartRateConversion(int.parse(heartRate)),
                          style: const TextStyle(
                            fontSize: 24,
                          ),
                        ),
                      ),
                    ],
                  ),
                const SizedBox(
                  height: 10,
                ),
                SizedBox(
                  height: 240,
                  child: LayoutBuilder(builder: (context, constraints) {
                    List<int> initData = [];
                    if (controller.diagnosisDataValue['Heart']?['ECG_POINT'] !=
                        null) {
                      initData = jsonDecode(controller
                              .diagnosisDataValue['Heart']?['ECG_POINT'])
                          .cast<int>();
                    }
                    return EcgView(
                      width: constraints.maxWidth,
                      height: constraints.maxHeight,
                      initData: initData, // TODO: 传入初始数据
                    );
                  }),
                )
              ],
            )),
        if (!isConnectFail)
          DeviceStatusPosition(
            deviceStatus: DeviceStatus(connectStatus: _connectStatus),
          )
        else
          _buildErrorButton(),
      ],
    );
  }
}