PiliPlus/lib/pages/msg_feed_top/at_me/controller.dart

import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
import 'package:get/get.dart';
import 'package:PiliPlus/http/msg.dart';
import 'package:PiliPlus/models/msg/msgfeed_at_me.dart';

class AtMeController extends GetxController {
  RxList<AtMeItems> msgFeedAtMeList = <AtMeItems>[].obs;
  bool isLoading = false;
  int cursor = -1;
  int cursorTime = -1;
  bool isEnd = false;

  Future queryMsgFeedAtMe() async {
    if (isLoading) return;
    isLoading = true;
    var res = await MsgHttp.msgFeedAtMe(cursor: cursor, cursorTime: cursorTime);
    isLoading = false;
    if (res['status']) {
      MsgFeedAtMe data = MsgFeedAtMe.fromJson(res['data']);
      isEnd = data.cursor?.isEnd ?? false;
      if (cursor == -1) {
        msgFeedAtMeList.assignAll(data.items!);
      } else {
        msgFeedAtMeList.addAll(data.items!);
      }
      cursor = data.cursor?.id ?? -1;
      cursorTime = data.cursor?.time ?? -1;
    } else {
      SmartDialog.showToast(res['msg']);
    }
  }

  Future onLoad() async {
    if (isEnd) return;
    queryMsgFeedAtMe();
  }

  Future onRefresh() async {
    cursor = -1;
    cursorTime = -1;
    queryMsgFeedAtMe();
  }
}