opt: common ctr

opt: state

Signed-off-by: bggRGjQaUbCoE <githubaccount56556@proton.me>
This commit is contained in:
bggRGjQaUbCoE
2025-05-11 12:21:42 +08:00
parent 5bff1747e6
commit 574bf861f0
129 changed files with 1065 additions and 1058 deletions

View File

@@ -30,15 +30,12 @@ abstract class CommonController<R, T> extends GetxController
@override
final ScrollController scrollController = ScrollController();
late int currentPage = 1;
bool isLoading = false;
late bool isEnd = false;
Rx<LoadingState> get loadingState;
bool? hasFooter;
Future<LoadingState<R>> customGetData();
void handleListResponse(List<T> dataList) {}
Future<void> queryData([bool isRefresh = true]);
bool customHandleResponse(bool isRefresh, Success<R> response) {
return false;
@@ -48,53 +45,8 @@ abstract class CommonController<R, T> extends GetxController
return false;
}
List<T>? getDataList(R response) {
return response as List<T>?;
}
void checkIsEnd(int length) {}
Future<void> queryData([bool isRefresh = true]) async {
if (isLoading || (isRefresh.not && isEnd)) return;
isLoading = true;
LoadingState<R> response = await customGetData();
if (response is Success<R>) {
if (!customHandleResponse(isRefresh, response)) {
List<T>? dataList = getDataList(response.response);
if (dataList.isNullOrEmpty) {
isEnd = true;
if (isRefresh) {
loadingState.value = LoadingState<List<T>?>.success(dataList);
} else if (hasFooter == true) {
loadingState.refresh();
}
isLoading = false;
return;
}
handleListResponse(dataList!);
if (isRefresh) {
checkIsEnd(dataList.length);
loadingState.value = LoadingState<List<T>?>.success(dataList);
} else if (loadingState.value is Success) {
final list = (loadingState.value.data! as List<T>)..addAll(dataList);
checkIsEnd(list.length);
loadingState.refresh();
}
}
currentPage++;
} else {
if (isRefresh &&
handleError(response is Error ? response.errMsg : null).not) {
loadingState.value = response;
}
}
isLoading = false;
}
@override
Future<void> onRefresh() {
currentPage = 1;
isEnd = false;
return queryData();
}
@@ -103,7 +55,6 @@ abstract class CommonController<R, T> extends GetxController
}
Future<void> onReload() {
loadingState.value = LoadingState.loading();
return onRefresh();
}

View File

@@ -5,4 +5,28 @@ import 'package:get/get.dart';
abstract class CommonDataController<R, T> extends CommonController<R, T> {
@override
Rx<LoadingState<T>> loadingState = LoadingState<T>.loading().obs;
@override
Future<void> queryData([bool isRefresh = true]) async {
if (isLoading) return;
isLoading = true;
LoadingState<R> response = await customGetData();
if (response is Success<R>) {
if (!customHandleResponse(isRefresh, response)) {
loadingState.value = response as LoadingState<T>;
}
} else {
if (isRefresh &&
!handleError(response is Error ? response.errMsg : null)) {
loadingState.value = response as LoadingState<T>;
}
}
isLoading = false;
}
@override
Future<void> onReload() {
loadingState.value = LoadingState<T>.loading();
return super.onReload();
}
}

View File

@@ -1,9 +1,73 @@
import 'package:PiliPlus/http/loading_state.dart';
import 'package:PiliPlus/pages/common/common_controller.dart';
import 'package:PiliPlus/utils/extension.dart';
import 'package:get/get.dart';
abstract class CommonListController<R, T> extends CommonController<R, T> {
int page = 1;
bool isEnd = false;
bool? hasFooter;
@override
Rx<LoadingState<List<T>?>> loadingState =
LoadingState<List<T>?>.loading().obs;
void handleListResponse(List<T> dataList) {}
List<T>? getDataList(R response) {
return response as List<T>?;
}
void checkIsEnd(int length) {}
@override
Future<void> queryData([bool isRefresh = true]) async {
if (isLoading || (!isRefresh && isEnd)) return;
isLoading = true;
LoadingState<R> response = await customGetData();
if (response is Success<R>) {
if (!customHandleResponse(isRefresh, response)) {
List<T>? dataList = getDataList(response.response);
if (dataList.isNullOrEmpty) {
isEnd = true;
if (isRefresh) {
loadingState.value = Success(dataList);
} else if (hasFooter == true) {
loadingState.refresh();
}
isLoading = false;
return;
}
handleListResponse(dataList!);
if (isRefresh) {
checkIsEnd(dataList.length);
loadingState.value = Success(dataList);
} else if (loadingState.value is Success) {
final list = loadingState.value.data!..addAll(dataList);
checkIsEnd(list.length);
loadingState.refresh();
}
}
page++;
} else {
if (isRefresh &&
!handleError(response is Error ? response.errMsg : null)) {
loadingState.value = response as LoadingState<List<T>?>;
}
}
isLoading = false;
}
@override
Future<void> onRefresh() {
page = 1;
isEnd = false;
return super.onRefresh();
}
@override
Future<void> onReload() {
loadingState.value = LoadingState<List<T>?>.loading();
return super.onReload();
}
}

View File

@@ -65,13 +65,13 @@ abstract class CommonSearchPageState<S extends CommonSearchPage, R, T>
Widget _buildBody(LoadingState<List<T>?> loadingState) {
return switch (loadingState) {
Loading() => const HttpError(),
Success() => loadingState.response?.isNotEmpty == true
? buildList(loadingState.response!)
Success(:var response) => response?.isNotEmpty == true
? buildList(response!)
: HttpError(
onReload: controller.onReload,
),
Error() => HttpError(
errMsg: loadingState.errMsg,
Error(:var errMsg) => HttpError(
errMsg: errMsg,
onReload: controller.onReload,
),
};

View File

@@ -63,7 +63,7 @@ abstract class CommonWhisperController<R>
Future<void> onDeleteList() async {
var res = await ImGrpc.deleteSessionList(pageType: sessionPageType);
if (res.isSuccess) {
loadingState.value = LoadingState.success(null);
loadingState.value = Success(null);
} else {
res.toast();
}

View File

@@ -178,7 +178,7 @@ abstract class ReplyController<R> extends CommonListController<R, ReplyInfo> {
if (loadingState.value is Success) {
List<ReplyInfo>? list = (loadingState.value as Success).response;
if (list == null) {
loadingState.value = LoadingState.success([replyInfo]);
loadingState.value = Success([replyInfo]);
} else {
if (oid != null) {
list.insert(hasUpTop ? 1 : 0, replyInfo);
@@ -188,7 +188,7 @@ abstract class ReplyController<R> extends CommonListController<R, ReplyInfo> {
loadingState.refresh();
}
} else {
loadingState.value = LoadingState.success([replyInfo]);
loadingState.value = Success([replyInfo]);
}
count.value += 1;
@@ -382,7 +382,7 @@ abstract class ReplyController<R> extends CommonListController<R, ReplyInfo> {
// not found
if (context.mounted) {
showReplyCheckResult(
res2.errMsg.startsWith('12022')
res2.errMsg?.startsWith('12022') == true
? '你的评论被shadow ban仅自己可见\n\n你的评论: $message'
: '评论不可见(${res2.errMsg}): $message',
);