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() { 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 replies = response.response.replies; 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.page.count ?? 0; } else { replies.insertAll( 0, loadingState.value is Success ? (loadingState.value as Success).response : []); } 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); } }