PiliPlus/lib/pages/common/reply_controller.dart

import 'package:PiliPalaX/http/loading_state.dart';
import 'package:PiliPalaX/models/common/reply_type.dart';
import 'package:PiliPalaX/pages/common/common_controller.dart';
import 'package:PiliPalaX/pages/video/detail/reply_new/reply_page.dart';
import 'package:easy_debounce/easy_throttle.dart';
import 'package:flutter/material.dart';
import 'package:get/get.dart';
import 'package:PiliPalaX/models/common/reply_sort_type.dart';
import 'package:PiliPalaX/models/video/reply/item.dart';
import 'package:PiliPalaX/utils/feed_back.dart';
import 'package:PiliPalaX/utils/storage.dart';
import 'package:get/get_navigation/src/dialog/dialog_route.dart';

abstract class ReplyController extends CommonController {
  String nextOffset = "";
  bool isLoadingMore = false;
  RxString noMore = ''.obs;
  RxInt count = (-1).obs;
  // 当前回复的回复
  ReplyItemModel? currentReplyItem;

  ReplySortType sortType = ReplySortType.time;
  RxString sortTypeTitle = ReplySortType.time.titles.obs;
  RxString sortTypeLabel = ReplySortType.time.labels.obs;

  late final savedReplies = {};

  @override
  void onInit() {
    super.onInit();
    int defaultReplySortIndex = GStorage.setting
        .get(SettingBoxKey.replySortType, defaultValue: 1) as int;
    if (defaultReplySortIndex == 2) {
      GStorage.setting.put(SettingBoxKey.replySortType, 0);
      defaultReplySortIndex = 0;
    }
    sortType = ReplySortType.values[defaultReplySortIndex];
    sortTypeTitle.value = sortType.titles;
    sortTypeLabel.value = sortType.labels;
  }

  @override
  Future onRefresh() {
    nextOffset = '';
    noMore.value = '';
    return super.onRefresh();
  }

  @override
  Future queryData([bool isRefresh = true]) {
    if (noMore.value == '没有更多了') return Future.value();
    return super.queryData(isRefresh);
  }

  @override
  bool customHandleResponse(Success response) {
    List<ReplyItemModel> replies = response.response.replies;
    nextOffset = response.response.cursor.paginationReply.nextOffset ?? "";
    if (replies.isNotEmpty) {
      noMore.value = '加载中...';

      /// 第一页回复数小于20
      if (currentPage == 1 && replies.length < 18) {
        noMore.value = '没有更多了';
      }
    } else {
      // 未登录状态replies可能返回null
      noMore.value = nextOffset == "" && currentPage == 1 ? '还没有评论' : '没有更多了';
    }
    if (currentPage == 1) {
      // 添加置顶回复
      if (response.response.upper.top != null) {
        final bool flag = response.response.topReplies.any(
            (ReplyItemModel reply) =>
                reply.rpid == response.response.upper.top.rpid) as bool;
        if (!flag) {
          replies.insert(0, response.response.upper.top);
        }
      }
      replies.insertAll(0, response.response.topReplies);
      count.value = response.response.cursor.allCount ?? 0;
    } else {
      replies.insertAll(
          0,
          loadingState.value is Success
              ? (loadingState.value as Success).response
              : <ReplyItemModel>[]);
    }
    loadingState.value = LoadingState.success(replies);
    return true;
  }

  // 排序搜索评论
  queryBySort() {
    EasyThrottle.throttle('queryBySort', const Duration(seconds: 1), () {
      feedBack();
      switch (sortType) {
        case ReplySortType.time:
          sortType = ReplySortType.like;
          break;
        case ReplySortType.like:
          sortType = ReplySortType.time;
          break;
        default:
      }
      sortTypeTitle.value = sortType.titles;
      sortTypeLabel.value = sortType.labels;
      nextOffset = "";
      noMore.value = '';
      loadingState.value = LoadingState.loading();
      onRefresh();
    });
  }

  void onReply(
    BuildContext context, {
    dynamic oid,
    dynamic replyItem,
    int index = 0,
  }) {
    dynamic key = oid ?? replyItem.oid + replyItem.rpid;
    Navigator.of(context)
        .push(
      GetDialogRoute(
        pageBuilder: (buildContext, animation, secondaryAnimation) {
          return ReplyPage(
            oid: oid ?? replyItem.oid,
            root: oid != null ? 0 : replyItem.rpid,
            parent: oid != null ? 0 : replyItem.rpid,
            replyType: ReplyType.video,
            replyItem: replyItem,
            savedReply: savedReplies[key],
            onSaveReply: (reply) {
              savedReplies[key] = reply;
            },
          );
        },
        transitionDuration: const Duration(milliseconds: 500),
        transitionBuilder: (context, animation, secondaryAnimation, child) {
          const begin = Offset(0.0, 1.0);
          const end = Offset.zero;
          const curve = Curves.linear;

          var tween =
              Tween(begin: begin, end: end).chain(CurveTween(curve: curve));

          return SlideTransition(
            position: animation.drive(tween),
            child: child,
          );
        },
      ),
    )
        .then(
      (value) {
        if (value != null && value['data'] != null) {
          savedReplies[key] = null;
          List list = loadingState.value is Success
              ? (loadingState.value as Success).response
              : [];
          if (index == 0) {
            list.insert(0, value['data']);
          } else {
            list[index].replies.add(value['data']);
          }
          loadingState.value = LoadingState.success(list);
        }
      },
    );
  }

  onMDelete(rpid, frpid) {
    List list = (loadingState.value as Success).response;
    list = frpid == null
        ? list.where((item) => item.rpid != rpid).toList()
        : list.map((item) {
            if (item.rpid == frpid) {
              return item
                ..replies =
                    item.replies?.where((reply) => reply.rpid != rpid).toList();
            } else {
              return item;
            }
          }).toList();
    loadingState.value = LoadingState.success(list);
  }
}