PiliPlus/lib/pages/member_video/controller.dart

import 'package:PiliPlus/http/loading_state.dart';
import 'package:PiliPlus/http/member.dart';
import 'package:PiliPlus/http/search.dart';
import 'package:PiliPlus/models/common/member/contribute_type.dart';
import 'package:PiliPlus/models/space_archive/data.dart';
import 'package:PiliPlus/models/space_archive/episodic_button.dart';
import 'package:PiliPlus/models/space_archive/item.dart';
import 'package:PiliPlus/pages/common/common_list_controller.dart';
import 'package:PiliPlus/utils/extension.dart';
import 'package:PiliPlus/utils/id_utils.dart';
import 'package:PiliPlus/utils/page_utils.dart';
import 'package:PiliPlus/utils/utils.dart';
import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
import 'package:get/get.dart';

class MemberVideoCtr
    extends CommonListController<SpaceArchiveData, SpaceArchiveItem> {
  MemberVideoCtr({
    required this.type,
    required this.mid,
    required this.seasonId,
    required this.seriesId,
    this.username,
    this.title,
  });

  ContributeType type;
  int? seasonId;
  int? seriesId;
  final int mid;
  late RxString order = 'pubdate'.obs;
  late RxString sort = 'desc'.obs;
  RxInt count = (-1).obs;
  int? next;
  Rx<EpisodicButton> episodicButton = EpisodicButton().obs;
  final String? username;
  final String? title;

  String? firstAid;
  String? lastAid;
  String? fromViewAid;
  bool? isLocating;
  bool? isLoadPrevious;
  bool? hasPrev;

  @override
  Future onRefresh() async {
    if (isLocating == true) {
      if (hasPrev == true) {
        isLoadPrevious = true;
        await queryData();
      }
    } else {
      firstAid = null;
      lastAid = null;
      next = null;
      isEnd = false;
      currentPage = 0;
      await queryData();
    }
  }

  @override
  void onInit() {
    super.onInit();
    if (type == ContributeType.video) {
      fromViewAid = Get.parameters['from_view_aid'];
    }
    currentPage = 0;
    queryData();
  }

  @override
  bool customHandleResponse(
      bool isRefresh, Success<SpaceArchiveData> response) {
    SpaceArchiveData data = response.response;
    episodicButton
      ..value = data.episodicButton ?? EpisodicButton()
      ..refresh();
    next = data.next;
    if (currentPage == 0 || isLoadPrevious == true) {
      hasPrev = data.hasPrev;
    }
    if (currentPage == 0 || isLoadPrevious != true) {
      if ((type == ContributeType.video
              ? data.hasNext == false
              : data.next == 0) ||
          data.item.isNullOrEmpty) {
        isEnd = true;
      }
    }
    count.value = type == ContributeType.season
        ? (data.item?.length ?? -1)
        : (data.count ?? -1);
    if (currentPage != 0 && loadingState.value is Success) {
      data.item ??= <SpaceArchiveItem>[];
      if (isLoadPrevious == true) {
        data.item!.addAll((loadingState.value as Success).response);
      } else {
        data.item!.insertAll(0, (loadingState.value as Success).response);
      }
    }
    firstAid = data.item?.firstOrNull?.param;
    lastAid = data.item?.lastOrNull?.param;
    isLoadPrevious = null;
    loadingState.value = LoadingState.success(data.item);
    return true;
  }

  @override
  Future<LoadingState<SpaceArchiveData>> customGetData() =>
      MemberHttp.spaceArchive(
        type: type,
        mid: mid,
        aid: type == ContributeType.video
            ? isLoadPrevious == true
                ? firstAid
                : lastAid
            : null,
        order: type == ContributeType.video ? order.value : null,
        sort: type == ContributeType.video
            ? isLoadPrevious == true
                ? 'asc'
                : null
            : sort.value,
        pn: type == ContributeType.charging ? currentPage : null,
        next: next,
        seasonId: seasonId,
        seriesId: seriesId,
        includeCursor: isLocating == true && currentPage == 0 ? true : null,
      );

  void queryBySort() {
    if (type == ContributeType.video) {
      isLocating = null;
      order.value = order.value == 'pubdate' ? 'click' : 'pubdate';
    } else {
      sort.value = sort.value == 'desc' ? 'asc' : 'desc';
    }
    onReload();
  }

  Future<void> toViewPlayAll() async {
    if (loadingState.value is Success) {
      List<SpaceArchiveItem>? list = (loadingState.value as Success).response;

      if (list.isNullOrEmpty) return;

      if (episodicButton.value.text == '继续播放') {
        dynamic oid = RegExp(r'oid=([\d]+)')
            .firstMatch('${episodicButton.value.uri}')
            ?.group(1);
        dynamic bvid = IdUtils.av2bv(int.tryParse(oid) ?? 0);
        dynamic cid = await SearchHttp.ab2c(aid: oid, bvid: bvid);
        PageUtils.toVideoPage(
          'bvid=$bvid&cid=$cid',
          arguments: {
            'heroTag': Utils.makeHeroTag(oid),
            'sourceType': 'archive',
            'mediaId': seasonId ?? seriesId ?? mid,
            'oid': oid,
            'favTitle':
                '$username: ${title ?? episodicButton.value.text ?? '播放全部'}',
            if (seriesId == null) 'count': count.value,
            if (seasonId != null || seriesId != null)
              'mediaType': RegExp(r'page_type=([\d]+)')
                  .firstMatch('${episodicButton.value.uri}')
                  ?.group(1),
            'desc': RegExp(r'desc=([\d]+)')
                    .firstMatch('${episodicButton.value.uri}')
                    ?.group(1) ==
                '1',
            'sortField': RegExp(r'sort_field=([\d]+)')
                .firstMatch('${episodicButton.value.uri}')
                ?.group(1),
            'isContinuePlaying': true,
          },
        );
        return;
      }

      for (SpaceArchiveItem element in list!) {
        if (element.cid == null) {
          continue;
        } else {
          if (element.bvid != list.first.bvid) {
            SmartDialog.showToast('已跳过不支持播放的视频');
          }
          bool desc = seasonId != null ? false : true;
          desc = (seasonId != null || seriesId != null) &&
                  (type == ContributeType.video
                      ? order.value == 'click'
                      : sort.value == 'asc')
              ? desc.not
              : desc;
          PageUtils.toVideoPage(
            'bvid=${element.bvid}&cid=${element.cid}',
            arguments: {
              'videoItem': element,
              'heroTag': Utils.makeHeroTag(element.bvid),
              'sourceType': 'archive',
              'mediaId': seasonId ?? seriesId ?? mid,
              'oid': IdUtils.bv2av(element.bvid!),
              'favTitle':
                  '$username: ${title ?? episodicButton.value.text ?? '播放全部'}',
              if (seriesId == null) 'count': count.value,
              if (seasonId != null || seriesId != null)
                'mediaType': RegExp(r'page_type=([\d]+)')
                    .firstMatch('${episodicButton.value.uri}')
                    ?.group(1),
              'desc': desc,
              if (type == ContributeType.video)
                'sortField': order.value == 'click' ? 2 : 1,
            },
          );
          break;
        }
      }
    }
  }

  @override
  Future onReload() {
    isLocating = null;
    return super.onReload();
  }
}