base_page_presenter.dart
3.08 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
import 'dart:io';
import 'package:dio/dio.dart';
import 'package:one_poem/net/dio_utils.dart';
import 'package:one_poem/net/error_handle.dart';
import 'package:one_poem/net/http_api.dart';
import 'base_presenter.dart';
import 'mvps.dart';
class BasePagePresenter<V extends IMvpView> extends BasePresenter<V> {
BasePagePresenter() {
_cancelToken = CancelToken();
}
late CancelToken _cancelToken;
@override
void dispose() {
/// 销毁时,将请求取消
if (!_cancelToken.isCancelled) {
_cancelToken.cancel();
}
}
/// 返回Future 适用于刷新,加载更多
Future requestNetwork<T>(Method method, {
required String url,
bool isShow = true,
bool isClose = true,
NetSuccessCallback<T?>? onSuccess,
NetErrorCallback? onError,
dynamic params,
Map<String, dynamic>? queryParameters,
CancelToken? cancelToken,
Options? options,
}) {
if (isShow) {
view.showProgress();
}
return DioUtils.instance.requestNetwork<T>(method, url,
params: params,
queryParameters: queryParameters,
options: options,
cancelToken: cancelToken?? _cancelToken,
onSuccess: (data) {
if (isClose) {
view.closeProgress();
}
onSuccess?.call(data);
},
onError: (code, msg) {
_onError(code, msg, onError);
},
);
}
void asyncRequestNetwork<T>(Method method, {
required String url,
bool isShow = true,
bool isClose = true,
NetSuccessCallback<T?>? onSuccess,
NetErrorCallback? onError,
dynamic params,
Map<String, dynamic>? queryParameters,
CancelToken? cancelToken,
Options? options,
}) {
if (isShow) {
view.showProgress();
}
DioUtils.instance.asyncRequestNetwork<T>(method, url,
params: params,
queryParameters: queryParameters,
options: options,
cancelToken: cancelToken?? _cancelToken,
onSuccess: (data) {
if (isClose) {
view.closeProgress();
}
onSuccess?.call(data);
},
onError: (code, msg) {
_onError(code, msg, onError);
},
);
}
/// 上传图片实现
Future<String> uploadImg(File image) async {
String imgPath = '';
try{
final String path = image.path;
final String name = path.substring(path.lastIndexOf('/') + 1);
final FormData formData = FormData.fromMap(<String, dynamic>{
'uploadIcon': await MultipartFile.fromFile(path, filename: name)
});
await requestNetwork<String>(Method.post,
url: HttpApi.upload,
params: formData,
onSuccess: (data) {
imgPath = data ?? '';
}
);
} catch(e) {
view.showToast('图片上传失败!');
}
return imgPath;
}
void _onError(int code, String msg, NetErrorCallback? onError) {
/// 异常时直接关闭加载圈,不受isClose影响
view.closeProgress();
if (code != ExceptionHandle.cancel_error) {
view.showToast(msg);
}
/// 页面如果dispose,则不回调onError
if (onError != null) {
onError(code, msg);
}
}
}