location2025/lib/module/track/track_day_detail/track_day_detail_controller.dart

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

import 'package:flutter/cupertino.dart';
import 'package:get/get.dart';
import 'package:get/get_core/src/get_main.dart';
import 'package:location/base/base_controller.dart';
import 'package:location/data/bean/track_daily_bean.dart';
import 'package:location/data/repositories/track_repository.dart';
import 'package:location/dialog/loading_dialog.dart';
import 'package:location/handler/error_handler.dart';
import 'package:location/module/track/track_controller.dart';
import 'package:location/module/track/track_day_detail/time_proportion/pie_chat_data.dart';
import 'package:location/resource/string.gen.dart';
import 'package:location/utils/async_util.dart';
import 'package:location/utils/atmob_log.dart';
import 'package:location/utils/common_expand.dart';
import 'package:location/utils/pair.dart';
import 'package:location/utils/toast_util.dart';
import 'package:url_launcher/url_launcher.dart';
import '../../../data/api/response/track_daily_summary_response.dart';
import '../../../data/bean/stream_chat_origin_data.dart';
import '../../../data/bean/track_days.dart';
import '../../../utils/http_handler.dart';
import '../../../widget/gradually_print_text.dart';
import '../track_status.dart';

class TrackDayDetailController extends BaseController {
  final TrackDays days;

  late TrackRepository trackRepository;
  final RxBool _trackNoData = RxBool(false);
  final RxList<TrackDailyBean> trackDailyList = RxList<TrackDailyBean>();

  final RxBool _isExpanded = RxBool(false);
  final RxBool _isRequested = RxBool(false);
  final RxBool _isHideExpand = RxBool(false);

  bool get isHideExpand => _isHideExpand.value;

  bool get isRequested => _isRequested.value;

  bool get isExpanded => _isExpanded.value;

  bool get trackNoData => _trackNoData.value;

  final Rxn<Pair<TrackExpandType, TrackDailyBean>> _expandSituation = Rxn();

  Pair<TrackExpandType, TrackDailyBean>? get expandSituation =>
      _expandSituation.value;

  final RxList<PieChatData> pieChatData = RxList<PieChatData>();
  int indexPieChatColor = 0;

  final TrackController trackController = Get.find<TrackController>();

  final RxBool _isShowGradually = RxBool(false);

  bool get isShowGradually => _isShowGradually.value;

  final Rxn<TrackDailySummaryResponse> _trackDailySummary = Rxn();

  TrackDailySummaryResponse? get trackDailySummary => _trackDailySummary.value;

  final GraduallyController graduallyController = GraduallyController();
  StreamSubscription? _streamChatSubscription;

  final RxnString _summaryError = RxnString();

  String? get summaryError => _summaryError.value;

  CancelableFuture? summaryFuture;

  TrackDayDetailController(this.days, bool isExpand) {
    trackRepository = TrackRepository.getInstance();
    _isExpanded.value = isExpand;
  }

  @override
  void onInit() {
    super.onInit();
    _requestTrackDaily();
    _requestTrackDailySummary();
    _requestTrackHistoryPoints();
  }

  void _requestTrackHistoryPoints() {}

  void _requestTrackDailySummary() {
    summaryFuture?.cancel();
    summaryFuture = AsyncUtil.retry(
        () => _requestTrackSummary(), Duration(seconds: 2),
        maxRetry: 5);

    summaryFuture!.catchError((error) {
      ToastUtil.show(StringName.trackDetailDailySummaryGetFail);
    });
  }

  Future<TrackDailySummaryResponse> _requestTrackSummary() {
    return trackRepository
        .trackDailySummary(
            startTime: days.start,
            endTime: days.end,
            userId: trackController.userInfo?.id)
        .then((response) {
      _trackDailySummary.value = response;
      return response;
    });
  }

  void _requestTrackDaily() {
    _isRequested.value = false;
    CustomLoadingDialog.show(loadingTxt: StringName.trackLoadingTxt);
    trackRepository
        .trackDailyQuery(
            startTime: days.start,
            endTime: days.end,
            userId: trackController.userInfo?.id)
        .then((list) {
      CustomLoadingDialog.hide();
      _isRequested.value = true;
      _trackNoData.value = (list == null || list.isEmpty == true);
      trackDailyList.assignAll(list ?? []);
      if (list != null && list.length == 1) {
        _isExpanded.value = true;
        _isHideExpand.value = true;
      }
      _dealPieChatData();
      _dealTrackExpandData();
    }).catchError((error) {
      CustomLoadingDialog.hide();
      _isRequested.value = false;
      ErrorHandler.toastError(error);
    });
  }

  void _dealPieChatData() {
    pieChatData.clear();
    final list = trackDailyList;
    if (list.isEmpty) {
      return;
    }
    indexPieChatColor = 0;
    int totalDuration = 0;
    final Map<String, PieChatData> addrMap = {};
    for (var bean in list) {
      if (bean.status == TrackStatus.error) {
        continue;
      }
      final addr = bean.addr;
      if (addr == null) {
        continue;
      }
      if (indexPieChatColor >= pieChatColors.length) {
        indexPieChatColor = 0;
      }
      totalDuration += bean.duration;
      if (addrMap.containsKey(addr)) {
        addrMap[addr]!.duration += bean.duration;
      } else {
        addrMap[addr] = PieChatData(
          address: addr,
          duration: bean.duration,
          color: pieChatColors[indexPieChatColor++],
        );
      }
    }
    for (var data in addrMap.values) {
      data.proportion =
          (data.duration / totalDuration * 100).toFormattedDouble(1);
    }
    pieChatData.addAll(addrMap.values.toList());
  }

  void _dealTrackExpandData() {
    final list = trackDailyList;
    if (list.isNotEmpty && list.length > 1) {
      TrackExpandType? expandType;
      TrackDailyBean? expandBean;
      for (var i = 0; i < list.length; i++) {
        final bean = list[i];
        if (bean.status == TrackStatus.error) {
          expandType = TrackExpandType.error;
          expandBean = bean;
          break;
        } else if (bean.status == TrackStatus.stay) {
          if (expandBean == null) {
            expandType = TrackExpandType.stay;
            expandBean = bean;
          }
          continue;
        }
      }
      if (expandType != null && expandBean != null) {
        if (expandType == TrackExpandType.error &&
            list.indexOf(expandBean) == list.length - 1) {
          expandType = TrackExpandType.errorNow;
        } else if (expandType == TrackExpandType.stay &&
            list.indexOf(expandBean) == list.length - 1) {
          expandType = TrackExpandType.stayNow;
        }
        _expandSituation.value = Pair(expandType, expandBean);
      }
    }
  }

  void onTrackDetailFoldClick() {
    _isExpanded.value = !_isExpanded.value;
  }

  void checkGraduallyPrintTextVisible(double visibleFraction) {
    if (!isShowGradually && visibleFraction >= 0.3) {
      _isShowGradually.value = true;
      //流式获取轨迹情况
      _requestStreamTrackDaily();
    }
  }

  void _requestStreamTrackDaily() {
    graduallyController.dispose();
    _streamChatSubscription?.cancel();
    trackRepository
        .streamDailySummary(
            startTime: days.start,
            endTime: days.end,
            userId: trackController.userInfo?.id)
        .then((stream) {
      //
      graduallyController.setGraduallyFinishedListener(() {
        _trackDailySummary.value?.trackSituation =
            graduallyController.graduallyTxt;
        _trackDailySummary.refresh();
      });
      _streamChatSubscription = stream.listen((event) {
        try {
          Map<String, dynamic> json = jsonDecode(event.data);
          if (json.isEmpty) {
            return;
          }
          StreamChatOriginData data = StreamChatOriginData.fromJson(json);
          if (data.choices == null || data.choices!.isEmpty) {
            return;
          }
          Delta? delta = data.choices![0].delta;
          if (delta == null) {
            return;
          }
          graduallyController.append(delta.content ?? "");
        } catch (ignore) {}
      }, onDone: () {
        graduallyController.appendDone();
      }, onError: (error) {
        _summaryError.value = "网络错误，请检查网络连接";
        debugPrint("error: $error");
        debugPrintStack();
      });
    }).catchError((error) {
      if (error is ServerErrorException) {
        _summaryError.value = error.message ?? "服务出错，请稍后再试";
      } else {
        _summaryError.value = "网络错误，请检查网络连接";
        debugPrint("error: $error");
        debugPrintStack();
      }
    });
  }

  void onPhoneCallClick() async {
    final Uri uri = Uri.parse('tel:${trackController.userInfo?.phoneNumber}');
    if (await canLaunchUrl(uri)) {
      await launchUrl(uri);
    } else {
      ToastUtil.show(StringName.trackDailySkipCallPhoneFail);
    }
  }

  @override
  void onClose() {
    super.onClose();
    _streamChatSubscription?.cancel();
    graduallyController.dispose();
  }
}