|
...
|
...
|
@@ -9,71 +9,69 @@ 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 = []; //已处理在线预订消息
|
|
|
|
|
|
|
|
class MessageModel extends ChangeNotifier{
|
|
|
|
|
|
|
|
List<Message> untreatedMsgs=[];//未处理在线预订消息
|
|
|
|
List<Message> treatedMsgs=[];//已处理在线预订消息
|
|
|
|
|
|
|
|
PageState unPageState = PageState.Loading;
|
|
|
|
PageState pageState = PageState.Loading;
|
|
|
|
|
|
|
|
//获取未处理在线预订消息
|
|
|
|
getUntreatedMsg(BuildContext context,Map<String,String> params) async {
|
|
|
|
pageState = PageState.Loading;
|
|
|
|
getUntreatedMsg(BuildContext context, Map<String, String> params) async {
|
|
|
|
unPageState = PageState.Loading;
|
|
|
|
notifyListeners();
|
|
|
|
BaseResp<List> baseResp = await DioUtil()
|
|
|
|
.request<List>(context, Method.get, HttpUrl.get_message_list,
|
|
|
|
data: params,showLoading: false)
|
|
|
|
data: params, showLoading: false)
|
|
|
|
.catchError((error) {
|
|
|
|
print(error.toString());
|
|
|
|
if (error is MyError) {
|
|
|
|
switch (error.type) {
|
|
|
|
case 1:
|
|
|
|
pageState = PageState.ConnectivityError;
|
|
|
|
unPageState = PageState.ConnectivityError;
|
|
|
|
break;
|
|
|
|
case 2:
|
|
|
|
pageState = PageState.ConnectivityTimeOut;
|
|
|
|
unPageState = PageState.ConnectivityTimeOut;
|
|
|
|
break;
|
|
|
|
default:
|
|
|
|
pageState = PageState.ConnectivityError;
|
|
|
|
unPageState = PageState.ConnectivityError;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
notifyListeners();
|
|
|
|
});
|
|
|
|
if (baseResp!=null&&baseResp.code == Constant.status_success) {
|
|
|
|
untreatedMsgs=baseResp.data.map<Message>((value){
|
|
|
|
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"){
|
|
|
|
untreatedMsgs.removeWhere((message) {
|
|
|
|
if (message.message_type.toString() == "10") {
|
|
|
|
if (message.status == "4") {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
return false;
|
|
|
|
}else if(message.message_type.toString()=="11"){
|
|
|
|
} else if (message.message_type.toString() == "11") {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
return true;
|
|
|
|
});
|
|
|
|
if (untreatedMsgs.isEmpty) {
|
|
|
|
pageState = PageState.Empty;
|
|
|
|
unPageState = PageState.Empty;
|
|
|
|
} else {
|
|
|
|
pageState = PageState.Success;
|
|
|
|
unPageState = PageState.Success;
|
|
|
|
}
|
|
|
|
notifyListeners();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
//获取未处理在线预订消息
|
|
|
|
getTreatedMsg(BuildContext context,Map<String,String> params) async {
|
|
|
|
//获取已处理在线预订消息
|
|
|
|
getTreatedMsg(BuildContext context, Map<String, String> params) async {
|
|
|
|
if (params["offset"] == "0") {
|
|
|
|
pageState = PageState.Loading;
|
|
|
|
notifyListeners();
|
|
|
|
}
|
|
|
|
BaseResp<List> baseResp = await DioUtil()
|
|
|
|
.request<List>(context, Method.get, HttpUrl.get_message_list,
|
|
|
|
data: params,showLoading: false)
|
|
|
|
data: params, showLoading: false)
|
|
|
|
.catchError((error) {
|
|
|
|
print(error.toString());
|
|
|
|
if (error is MyError) {
|
|
...
|
...
|
@@ -91,18 +89,20 @@ class MessageModel extends ChangeNotifier{ |
|
|
|
}
|
|
|
|
notifyListeners();
|
|
|
|
});
|
|
|
|
if (baseResp!=null&&baseResp.code == Constant.status_success) {
|
|
|
|
if(params["offset"]=="0"){//第一页
|
|
|
|
treatedMsgs=baseResp.data.map<Message>((value){
|
|
|
|
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){
|
|
|
|
} 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"){
|
|
|
|
treatedMsgs.removeWhere((message) {
|
|
|
|
if (message.message_type.toString() == "10" ||
|
|
|
|
message.message_type.toString() == "11") {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
return true;
|
|
...
|
...
|
@@ -117,8 +117,8 @@ class MessageModel extends ChangeNotifier{ |
|
|
|
}
|
|
|
|
|
|
|
|
//移除未处理在线预订消息
|
|
|
|
removeUntreatedMessageByMid(String mid){
|
|
|
|
untreatedMsgs.removeWhere((message)=>message.id==mid);
|
|
|
|
removeUntreatedMessageByMid(String mid) {
|
|
|
|
untreatedMsgs.removeWhere((message) => message.id == mid);
|
|
|
|
notifyListeners();
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|