message_model.dart 2.65 KB
import 'package:flutter/material.dart';
import 'package:one_key/constant/constant.dart';
import 'package:one_key/models/message.dart';
import 'package:one_key/net/base_resp.dart';
import 'package:one_key/net/dio_util.dart';
import 'package:one_key/net/http_url.dart';
import 'package:one_key/utils/log_util.dart';
import 'package:one_key/utils/utils.dart';


class MessageModel extends ChangeNotifier{

  List<Message> untreatedMsgs=[];//未处理在线预订消息
  List<Message> treatedMsgs=[];//已处理在线预订消息

  bool connect_timeout=true;

  //获取未处理在线预订消息
  getUntreatedMsg(BuildContext context,Map<String,String> params) async {
    connect_timeout=true;
    notifyListeners();
    BaseResp<List> baseResp = await DioUtil()
        .request<List>(context, Method.get, HttpUrl.get_message_list,
        data: params)
        .catchError((error) {
      print(error.toString());
      connect_timeout=false;
      notifyListeners();
    });
    if (baseResp!=null&&baseResp.code == Constant.status_success) {
      untreatedMsgs=baseResp.data.map<Message>((value){
        return Message.fromJson(value);
      }).toList();
      untreatedMsgs.removeWhere((message){
        if(message.message_type.toString()=="10"){
          if(message.status=="4"){
            return true;
          }
          return false;
        }else if(message.message_type.toString()=="11"){
          return false;
        }
        return true;
      });
      notifyListeners();
    }
  }

  //获取未处理在线预订消息
  getTreatedMsg(BuildContext context,Map<String,String> params) async {
    connect_timeout=true;
    notifyListeners();
    BaseResp<List> baseResp = await DioUtil()
        .request<List>(context, Method.get, HttpUrl.get_message_list,
        data: params)
        .catchError((error) {
      print(error.toString());
      connect_timeout=false;
      notifyListeners();
    });
    if (baseResp!=null&&baseResp.code == Constant.status_success) {
      if(params["offset"]=="0"){//第一页
        treatedMsgs=baseResp.data.map<Message>((value){
          return Message.fromJson(value);
        }).toList();
      }else{
        treatedMsgs.addAll(baseResp.data.map<Message>((value){
          return Message.fromJson(value);
        }).toList());
      }
      treatedMsgs.removeWhere((message){
        if(message.message_type.toString()=="10"||message.message_type.toString()=="11"){
          return false;
        }
        return true;
      });
      notifyListeners();
    }
  }

  //移除未处理在线预订消息
  removeUntreatedMessageByMid(String mid){
    untreatedMsgs.removeWhere((message)=>message.id==mid);
    notifyListeners();
  }
}