VitalApp/lib/mock/services/followup.dart

import 'package:fis_jsonrpc/services/followUp.dart';
import 'package:fis_jsonrpc/services/followUp.m.dart';
import 'package:uuid/uuid.dart';
import 'package:vitalapp/database/db.dart';
import 'package:vitalapp/database/entities/defines.dart';
import 'package:vitalapp/database/entities/followup.dart';
import 'package:vitalapp/store/store.dart';

class FollowUpServiceMock extends VitalFollowUpService {
  FollowUpServiceMock(super.host);

  @override
  Future<String> createFollowUpAsync(CreateFollowUpRequest request) async {
    final entity = FollowUpEntity();
    final patientCode = Store.user.currentSelectPatientInfo!.code!;
    // 本地先生成一个Code，上传后更新
    final uuid = const Uuid().v4().replaceAll('-', '');
    entity.code = "mock_$uuid";
    entity.isValid = true;
    entity.syncType = OfflineDataSyncType.create;
    entity.userCode = Store.user.userCode!;
    entity.patientCode = patientCode;
    entity.contractDoctor = Store.user.principalName;
    entity.typeKey = request.key!;
    entity.templateCode = request.templateCode!;
    entity.mode = request.followUpMode;
    entity.followUpTime = request.followUpTime!;
    if (request.nextFollowUpTime != null) {
      // TODO: 理论不能为空，但是这个默认值目前没有确定
      entity.nextFollowUpTime = request.nextFollowUpTime!;
    }

    entity.followUpPhtots = request.followUpPhotos!;
    entity.dataJson = request.followUpData!;

    final id = await db.repositories.followUp.insert(entity);
    final success = id > 0;
    if (success) {
      // 统计数量+1
      await db.repositories.patient.increaseFollowUpCount(patientCode);
    }
    final result = success ? entity.code : "";
    return result;
  }

  @override
  Future<bool> updateFollowUpAsync(UpdateFollowUpRequest request) async {
    FollowUpEntity? entity =
        await db.repositories.followUp.singleByCode(request.code!);
    if (entity == null) {
      entity = FollowUpEntity();
      entity.isValid = true;
      entity.syncType = OfflineDataSyncType.update;
    }
    final patientCode = Store.user.currentSelectPatientInfo!.code!;
    entity.code = request.code!;
    entity.userCode = Store.user.userCode!;
    entity.patientCode = patientCode;
    entity.contractDoctor = Store.user.principalName;
    entity.typeKey = request.key!;
    entity.mode = request.followUpMode!;
    entity.followUpTime = request.followUpTime!;
    entity.nextFollowUpTime = request.nextFollowUpTime!;
    entity.followUpPhtots = request.followUpPhotos!;
    entity.dataJson = request.followUpData!;

    int result;
    if (entity.id == 0) {
      result = await db.repositories.followUp.insert(entity);
      if (result > 0) {
        // 统计数量+1
        await db.repositories.patient.increaseFollowUpCount(patientCode);
      }
    } else {
      result = await db.repositories.followUp.update(entity);
    }
    return result > 0;
  }

  @override
  Future<List<FollowUpRecordDTO>> getFollowUpRecordListAsync(
      GetFollowUpRecordListRequest request) async {
    final entities = await db.repositories.followUp
        .queryAllListByPatient(request.patientCode!, Store.user.userCode!);
    if (entities.isEmpty) {
      return [];
    }

    // 都放一个Record里
    final record = FollowUpRecordDTO();
    final patient = Store.user.currentSelectPatientInfo;
    record.patientName = patient?.patientName ?? "";
    // record.contractedDoctor = patient?.contractedDoctorName ?? "";
    record.contractedDoctor = entities.first.contractDoctor;
    record.followUpRecordDatas = entities
        .map(
          (e) => FollowUpRecordDataDTO(
            code: e.code,
            templateCode: e.templateCode,
            key: e.typeKey,
            followUpDoctor: e.contractDoctor,
            followUpState: FollowUpStateEnum.FollowUpVisit,
            followUpMode: e.mode,
            followUpTime: e.followUpTime,
            nextFollowUpTime: e.nextFollowUpTime,
            followUpPhotos: e.followUpPhtots,
            followUpData: e.dataJson,
          ),
        )
        .toList();

    return [record];
  }
}