app/lib/ui/party_room/party_room_home_ui_model.dart

171 lines
4.4 KiB
Dart

import 'package:fixnum/fixnum.dart';
import 'package:starcitizen_doctor/base/ui_model.dart';
import 'package:starcitizen_doctor/generated/grpc/party_room_server/index.pb.dart';
import 'package:starcitizen_doctor/grpc/party_room_server.dart';
import 'package:starcitizen_doctor/ui/party_room/dialogs/party_room_create_dialog_ui_model.dart';
import 'dialogs/party_room_create_dialog_ui.dart';
class PartyRoomHomeUIModel extends BaseUIModel {
String? pingServerMessage;
Map<String?, RoomType>? roomTypes;
RoomType? selectedRoomType;
RoomSubtype? selectedRoomSubType;
final roomStatus = <RoomStatus, String>{
RoomStatus.All: "全部",
RoomStatus.Open: "开启中",
RoomStatus.Full: "已满员",
RoomStatus.Closed: "已封闭",
RoomStatus.WillOffline: "房主离线",
RoomStatus.Offline: "已离线",
};
RoomStatus selectedStatus = RoomStatus.All;
final roomSorts = <RoomSortType, String>{
RoomSortType.Default: "默认",
RoomSortType.MostPlayerNumber: "最多玩家",
RoomSortType.MinimumPlayerNumber: "最少玩家",
RoomSortType.RecentlyCreated: "最近创建",
RoomSortType.OldestCreated: "最久创建",
};
RoomSortType selectedSortType = RoomSortType.Default;
int pageNum = 0;
List<RoomData>? rooms;
@override
void initModel() {
super.initModel();
_loadTypes();
}
@override
Future loadData() async {
if (pingServerMessage != "") {
pingServerMessage = null;
notifyListeners();
await _pingServer();
}
await _loadPage();
}
@override
reloadData() async {
pageNum = 0;
rooms = null;
notifyListeners();
return super.reloadData();
}
_loadPage() async {
final r = await handleError(() => PartyRoomGrpcServer.getRoomList(
RoomListPageReqData(
pageNum: Int64.tryParseInt("$pageNum"),
typeID: selectedRoomType?.id ?? "",
subTypeID: selectedRoomSubType?.id ?? "",
status: selectedStatus)));
if (r == null) return;
if (r.pageData.hasNext) {
pageNum++;
} else {
pageNum = -1;
}
rooms = r.rooms;
notifyListeners();
}
_pingServer() async {
try {
final r = await PartyRoomGrpcServer.pingServer();
dPrint(
"[PartyRoomHomeUIModel] Connected! serverVersion ==> ${r.serverVersion}");
pingServerMessage = "";
notifyListeners();
} catch (e) {
pingServerMessage = "服务器连接失败,请稍后重试。\n$e";
notifyListeners();
return;
}
}
Future<void> _loadTypes() async {
final r = await handleError(() => PartyRoomGrpcServer.getRoomTypes());
if (r == null) return;
selectedRoomType =
RoomType(id: "", name: "全部", desc: "查看所有类型的房间,寻找一起玩的伙伴。");
selectedRoomSubType = RoomSubtype(id: "", name: "全部");
roomTypes = {"": selectedRoomType!};
for (var element in r.roomTypes) {
roomTypes![element.id] = element;
}
notifyListeners();
}
Map<String, RoomSubtype>? getCurRoomSubTypes() {
if (selectedRoomType?.subTypes == null) return null;
Map<String, RoomSubtype> types = {};
for (var element in selectedRoomType!.subTypes) {
types[element.id] = element;
}
if (types.isEmpty) return null;
final allSubType = RoomSubtype(id: "", name: "全部");
selectedRoomSubType ??= allSubType;
return {"all": allSubType}..addAll(types);
}
void onChangeRoomType(RoomType? value) {
selectedRoomType = value;
selectedRoomSubType = null;
reloadData();
notifyListeners();
}
void onChangeRoomStatus(RoomStatus? value) {
if (value == null) return;
selectedStatus = value;
reloadData();
notifyListeners();
}
void onChangeRoomSort(RoomSortType? value) {
if (value == null) return;
selectedSortType = value;
reloadData();
notifyListeners();
}
void onChangeRoomSubType(RoomSubtype? value) {
if (value == null) return;
selectedRoomSubType = value;
reloadData();
notifyListeners();
}
onCreateRoom() async {
final room = await showDialog(
context: context!,
dismissWithEsc: false,
builder: (BuildContext context) {
return BaseUIContainer(
uiCreate: () => PartyRoomCreateDialogUI(),
modelCreate: () =>
PartyRoomCreateDialogUIModel(Map.from(roomTypes!)));
},
);
if (room == null) return;
dPrint(room);
reloadData();
}
onRefreshRoom() {
reloadData();
}
}