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
123
124
125
|
private void loadPreClassPreviewData() {
Observable<List<PreClassPreviewInfoBean>> observablePreClassPreview =
Observable.create(new Observable.OnSubscribe<List<PreClassPreviewInfoBean>>() {
@Override
public void call(final Subscriber<? super List<PreClassPreviewInfoBean>> subscriber) {
model.loadPreClassPreviewData(selectIds, unitIds, lessonIds, new ILoadDataListener() {
@Override
public void success(YQZYReqType api) {
if (mView != null) {
subscriber.onNext(model.getPreClassPreviewInfoBeanList());
}
}
@Override
public void error(YQZYReqType api, int errorCode, String errorMessage) {
if (mView != null) {
subscriber.onError(new Throwable(errorMessage));
}
}
});
}
}).onErrorReturn(new Func1<Throwable, List<PreClassPreviewInfoBean>>() {
@Override
public List<PreClassPreviewInfoBean> call(Throwable throwable) {
return null;
}
});
Observable<List<ReviewAfterInfoBean>> observableReviewAfter =
Observable.create(new Observable.OnSubscribe<List<ReviewAfterInfoBean>>() {
@Override
public void call(final Subscriber<? super List<ReviewAfterInfoBean>> subscriber) {
model.loadReviewAfterClassData(selectIds, lessonIds, unitIds, clazzLevels, new
ILoadDataListener() {
@Override
public void success(YQZYReqType api) {
if (mView != null) {
subscriber.onNext(model.getReviewAfterInfoBeanList());
}
}
@Override
public void error(YQZYReqType api, int errorCode, String errorMessage) {
if (mView != null) {
subscriber.onError(new Throwable(errorMessage));
}
}
});
}
}).onErrorReturn(new Func1<Throwable, List<ReviewAfterInfoBean>>() {
@Override
public List<ReviewAfterInfoBean> call(Throwable throwable) {
return null;
}
});
Observable<List<HeightWrongInfoBean>> observableHeightWrong =
Observable.create(new Observable.OnSubscribe<List<HeightWrongInfoBean>>() {
@Override
public void call(final Subscriber<? super List<HeightWrongInfoBean>> subscriber) {
model.loadHeightWrongData(selectIds, lessonIds, unitIds, new
ILoadDataListener() {
@Override
public void success(YQZYReqType api) {
if (mView != null) {
subscriber.onNext(model.getHeightWrongInfoBeanList());
}
}
@Override
public void error(YQZYReqType api, int errorCode, String errorMessage) {
if (mView != null) {
subscriber.onError(new Throwable(errorMessage));
}
}
});
}
}).onErrorReturn(new Func1<Throwable, List<HeightWrongInfoBean>>() {
@Override
public List<HeightWrongInfoBean> call(Throwable throwable) {
return null;
}
});
Observable.zip(observablePreClassPreview, observableReviewAfter, observableHeightWrong,
new Func3<List<PreClassPreviewInfoBean>, List<ReviewAfterInfoBean>,
List<HeightWrongInfoBean>, ArrayList<SynPracticeQuestionBean>>() {
@Override
public ArrayList<SynPracticeQuestionBean>
call(List<PreClassPreviewInfoBean> preClassPreviewInfoBeans,
List<ReviewAfterInfoBean> reviewAfterInfoBeans,
List<HeightWrongInfoBean> heightWrongInfoBeans) {
previewAnalyticData();
reviewAnalyticData();
heightWrongData();
baseBean = new ArrayList<SynPracticeQuestionBean>();
if (previewBeanList != null) {
baseBean.addAll(previewBeanList);
}
if (reviewBeanList != null) {
baseBean.addAll(reviewBeanList);
}
if (heightWrongBeanList != null) {
baseBean.addAll(heightWrongBeanList);
}
mView.loadSuccess();
mView.refreshView(baseBean);
return baseBean;
}
}).subscribe();
}
|