ecg_list_view/lib/ecg_list/controller.dart

import 'dart:convert';

import 'package:ecg_list_view/entitys/resident_model.dart';
import 'package:ecg_list_view/rpc/rpc_bridge.dart';
import 'package:flutter/foundation.dart';
import 'package:get/get.dart';
import 'package:fis_jsonrpc/rpc.dart';
import 'package:fis_common/logger/logger.dart';
import 'package:fis_common/index.dart';

class EcgListController extends GetxController {
  RecordProcessStateEnum typeFilter = RecordProcessStateEnum.All;
  List<ExamStateEnum>? states;
  EcgListController();

  //右侧选中的Tab
  int selectedTabIndex = 0;

  ///展示下级的数据
  bool showLowerDatas = false;

  /// 表格loading
  bool tableLoading = true;

  /// 当前表格页数
  int currPageIndex = 1;

  /// 当前列表选中的
  int currectSelected = -1;
  DateTime? startTime;

  DateTime? endTime;

  List<ElectrocardiogramRecord> residentList = [];

  /// 列表的总数
  int tableCount = 0;

  /// 当前检测详情
  List<List<String>> tableData = [];

  List<ReportDTO> reports = [];

  Future<void> getDatas({
    int? pageSize = 10,
    int? pageIndex = 1,
    String? keyword = "",
  }) async {
    tableLoading = true;
    currPageIndex = pageIndex!;
    currectSelected = -1;

    tableData.clear();
    if (kDebugMode && startTime == null) {
      startTime = DateTime(2024, 01, 01);
    }
    final result = await RPCBridge.ins.rpc.vitalElectrocardiogram
        .getElectrocardiogramRecordPageAsync(
      ElectrocardiogramRecordPageRequest(
        token: RPCBridge.ins.token,
        pageSize: pageSize!,
        pageIndex: pageIndex,
        keyWord: keyword,
        startTime: startTime?.toUtc(),
        endTime: endTime?.toUtc(),
        isQuerySubordinate: showLowerDatas,
        states: states,
      ),
    );

    residentList.clear();
    residentList = result.pageData ?? [];
    tableCount = result.totalCount;
    residentList = residentList;
    tableLoading = false;
    update(["ecg_list"]);
    update(["table"]);
    update(["table_pagination"]);
  }

  Future<List<List<String>>> getTableData(String data) async {
    if (data.isEmpty) {
      return [];
    }
    var currentDiagnosis = <List<String>>[];

    var jsonData = json.decode(data);
    List<String> keys = jsonData.keys.toList();

    List<DictionaryWithUnitDTO>? dtos = [];

    dtos = await RPCBridge.ins.rpc.vitalDictionary
        .getDictionaryNameAndUnitByKeysAsync(
            GetDictionaryNameAndUnitByKeysRequest(
      keys: keys,
      token: RPCBridge.ins.token,
    ));

    for (var key in keys) {
      if (key == "ECG_POINT" || key == "ECG_POINT12") {
        continue;
      }
      var dto = dtos.firstWhereOrNull((item) => item.key == key);
      if (dto == null) {
        continue;
      }
      final value = jsonData[key].toString();
      if (value.isEmpty) {
        // 不展示空值
        continue;
      }
      currentDiagnosis.add([
        dto.name ?? '',
        value,
        dto.unit ?? '',
      ]);
    }

    return currentDiagnosis;
  }

  @override
  void onReady() {
    super.onReady();
    getDatas();
  }

  Future<void> onRowTap(int index) async {
    currectSelected = index;
    var examRecord = residentList[index];
    if (examRecord.examData.isNotNullOrEmpty) {
      tableData = await getTableData(examRecord.examData!);
    }
    loadReports();
    update(["ecg_list"]);
  }

  void changeDatas(bool v) {
    showLowerDatas = v;
  }

  void loadCurrentRecordInfo() {
    update(["ecg_list"]);
  }

  Future<void> loadReports() async {
    if (currectSelected == -1) {
      return;
    }
    var recordCode = residentList[currectSelected].code;
    try {
      reports = await RPCBridge.ins.rpc.ultrasoundReport.vitalFindReportsAsync(
        FindReportsRequest(
          token: RPCBridge.ins.token,
          recordCode: recordCode,
        ),
      );
    } catch (e) {
      logger.e('EcgListController loadReports ex:$e');
    }
    if (reports.isEmpty && kDebugMode) {
      reports.add(
        ReportDTO(
          reportCode: "AD96F326D881443BAE00712F78D9E45A",
          patientId: "01320240515007",
          reportUserName: "Loki",
          updateTime: DateTime.now(),
          reportPreviewList: [
            ReportPreviewDTO(
              fileToken:
                  "https://flyinsono-bj-1300984704.cos.ap-beijing.myqcloud.com/4D659CAE89B44E248653AAE6A158221B.jpg",
              fileType: UploadFileTypeEnum.JPG,
              language: "",
              thumbnailToken:
                  "https://flyinsono-bj-1300984704.cos.ap-beijing.myqcloud.com/ED4F2F0B011746FF86220D4DB2C2CE64.jpg",
            ),
            ReportPreviewDTO(
              fileToken:
                  "https://flyinsono-bj-1300984704.cos.ap-beijing.myqcloud.com/7392BDE8F90148D8B8772C7576465AFB.pdf",
              fileType: UploadFileTypeEnum.PDF,
              language: "",
              thumbnailToken:
                  "https://flyinsono-bj-1300984704.cos.ap-beijing.myqcloud.com/7392BDE8F90148D8B8772C7576465AFB.pdf",
            ),
          ],
        ),
      );
    }
    update(["ecg_list"]);
  }

  Future<void> changeTypeFilter(RecordProcessStateEnum value) async {
    typeFilter = value;
    if (value == RecordProcessStateEnum.All) {
      states = null;
    } else if (value == RecordProcessStateEnum.Done) {
      states = [ExamStateEnum.Reported];
    } else {
      states = [
        ExamStateEnum.Unchecked,
        ExamStateEnum.Invalid,
        ExamStateEnum.Inspected
      ];
    }
    await getDatas();
    update(["ecg_list"]);
  }

  // @override
  // void onClose() {
  //   super.onClose();
  // }
}