|
@@ -50,7 +50,13 @@ import io.reactivex.rxjava3.schedulers.Schedulers;
|
|
|
*/
|
|
|
public class HomePresenter extends BasePresenter<HomeContract.HomeView> implements HomeContract.Presenter {
|
|
|
public void appHome() {
|
|
|
- getView().showLoading();
|
|
|
+ appHome(false);
|
|
|
+ }
|
|
|
+
|
|
|
+ public void appHome(boolean isShowLoading) {
|
|
|
+ if (isShowLoading && getView() != null) {
|
|
|
+ getView().showLoading();
|
|
|
+ }
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
|
try {
|
|
|
jsonObject.putOpt("platform", "android");
|
|
@@ -234,32 +240,32 @@ public class HomePresenter extends BasePresenter<HomeContract.HomeView> implemen
|
|
|
Observable<BaseResponse<HomeStyleBean>> observable = create(APIService.class).getStylePage(RequestBodyUtil.convertToRequestBodyJson(jsonObject.toString()));
|
|
|
Observable<BaseResponse<ArrayList<TempLiveTeacherListBean>>> tempLiveObservable = create(APIService.class).getTempLiveList();
|
|
|
tempLiveObservable.flatMap(new Function<BaseResponse<ArrayList<TempLiveTeacherListBean>>, ObservableSource<BaseResponse<HomeStyleBean>>>() {
|
|
|
- @Override
|
|
|
- public ObservableSource<BaseResponse<HomeStyleBean>> apply(BaseResponse<ArrayList<TempLiveTeacherListBean>> arrayListBaseResponse) throws Throwable {
|
|
|
- return observable.map(new Function<BaseResponse<HomeStyleBean>, BaseResponse<HomeStyleBean>>() {
|
|
|
@Override
|
|
|
- public BaseResponse<HomeStyleBean> apply(BaseResponse<HomeStyleBean> homeStyleBeanBaseResponse) throws Throwable {
|
|
|
- if (arrayListBaseResponse != null && page == 1) {
|
|
|
- //只有第一页合并添加数据
|
|
|
- ArrayList<TempLiveTeacherListBean> data = arrayListBaseResponse.getData();
|
|
|
- if (homeStyleBeanBaseResponse != null && homeStyleBeanBaseResponse.getData() != null) {
|
|
|
- List<HomeStyleBean.RowsBean> rows = homeStyleBeanBaseResponse.getData().rows;
|
|
|
- if (rows == null) {
|
|
|
- rows = new ArrayList<>();
|
|
|
- }
|
|
|
- if (data != null && data.size() > 0) {
|
|
|
- for (int i = data.size() - 1; i >= 0; i--) {
|
|
|
- TempLiveTeacherListBean tempLiveTeacherListBean = data.get(i);
|
|
|
- HomeStyleBean.RowsBean rowsBean = new HomeStyleBean.RowsBean();
|
|
|
- rowsBean.liveCoverImg = tempLiveTeacherListBean.liveCoverImg;
|
|
|
- rowsBean.liveTitle = tempLiveTeacherListBean.liveTitle;
|
|
|
- rowsBean.roomUid = tempLiveTeacherListBean.roomUid;
|
|
|
- rowsBean.liveStatus = Constants.ON_LIVING_TAG;
|
|
|
- rowsBean.avatar = tempLiveTeacherListBean.avatar;
|
|
|
- rowsBean.username = tempLiveTeacherListBean.username;
|
|
|
- rows.add(0, rowsBean);
|
|
|
- }
|
|
|
- }
|
|
|
+ public ObservableSource<BaseResponse<HomeStyleBean>> apply(BaseResponse<ArrayList<TempLiveTeacherListBean>> arrayListBaseResponse) throws Throwable {
|
|
|
+ return observable.map(new Function<BaseResponse<HomeStyleBean>, BaseResponse<HomeStyleBean>>() {
|
|
|
+ @Override
|
|
|
+ public BaseResponse<HomeStyleBean> apply(BaseResponse<HomeStyleBean> homeStyleBeanBaseResponse) throws Throwable {
|
|
|
+ if (arrayListBaseResponse != null && page == 1) {
|
|
|
+ //只有第一页合并添加数据
|
|
|
+ ArrayList<TempLiveTeacherListBean> data = arrayListBaseResponse.getData();
|
|
|
+ if (homeStyleBeanBaseResponse != null && homeStyleBeanBaseResponse.getData() != null) {
|
|
|
+ List<HomeStyleBean.RowsBean> rows = homeStyleBeanBaseResponse.getData().rows;
|
|
|
+ if (rows == null) {
|
|
|
+ rows = new ArrayList<>();
|
|
|
+ }
|
|
|
+ if (data != null && data.size() > 0) {
|
|
|
+ for (int i = data.size() - 1; i >= 0; i--) {
|
|
|
+ TempLiveTeacherListBean tempLiveTeacherListBean = data.get(i);
|
|
|
+ HomeStyleBean.RowsBean rowsBean = new HomeStyleBean.RowsBean();
|
|
|
+ rowsBean.liveCoverImg = tempLiveTeacherListBean.liveCoverImg;
|
|
|
+ rowsBean.liveTitle = tempLiveTeacherListBean.liveTitle;
|
|
|
+ rowsBean.roomUid = tempLiveTeacherListBean.roomUid;
|
|
|
+ rowsBean.liveStatus = Constants.ON_LIVING_TAG;
|
|
|
+ rowsBean.avatar = tempLiveTeacherListBean.avatar;
|
|
|
+ rowsBean.username = tempLiveTeacherListBean.username;
|
|
|
+ rows.add(0, rowsBean);
|
|
|
+ }
|
|
|
+ }
|
|
|
// for (int i = 0; i < data.size(); i++) {
|
|
|
// TempLiveTeacherListBean tempLiveTeacherListBean = data.get(i);
|
|
|
// if (homeStyleBeanBaseResponse != null && homeStyleBeanBaseResponse.getData() != null && homeStyleBeanBaseResponse.getData().rows != null && homeStyleBeanBaseResponse.getData().rows.size() > 0) {
|
|
@@ -275,44 +281,44 @@ public class HomePresenter extends BasePresenter<HomeContract.HomeView> implemen
|
|
|
// }
|
|
|
// }
|
|
|
// }
|
|
|
- } else {
|
|
|
- Log.i("pq", "直播列表为空");
|
|
|
+ } else {
|
|
|
+ Log.i("pq", "直播列表为空");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return homeStyleBeanBaseResponse;
|
|
|
}
|
|
|
- }
|
|
|
- return homeStyleBeanBaseResponse;
|
|
|
+ });
|
|
|
}
|
|
|
- });
|
|
|
- }
|
|
|
- }).subscribeOn(Schedulers.newThread())
|
|
|
+ }).subscribeOn(Schedulers.newThread())
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
.subscribe(new Observer<BaseResponse<HomeStyleBean>>() {
|
|
|
- @Override
|
|
|
- public void onSubscribe(@NonNull Disposable d) {
|
|
|
+ @Override
|
|
|
+ public void onSubscribe(@NonNull Disposable d) {
|
|
|
|
|
|
- }
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public void onNext(@NonNull BaseResponse<HomeStyleBean> homeStyleBeanBaseResponse) {
|
|
|
- if (getView() != null && homeStyleBeanBaseResponse != null) {
|
|
|
- getView().getStylePageSuccess(page, homeStyleBeanBaseResponse.getData());
|
|
|
- }
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public void onNext(@NonNull BaseResponse<HomeStyleBean> homeStyleBeanBaseResponse) {
|
|
|
+ if (getView() != null && homeStyleBeanBaseResponse != null) {
|
|
|
+ getView().getStylePageSuccess(page, homeStyleBeanBaseResponse.getData());
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public void onError(@NonNull Throwable e) {
|
|
|
- if (getView() != null) {
|
|
|
- getView().onError(e);
|
|
|
- getView().hideLoading();
|
|
|
- }
|
|
|
- }
|
|
|
+ @Override
|
|
|
+ public void onError(@NonNull Throwable e) {
|
|
|
+ if (getView() != null) {
|
|
|
+ getView().onError(e);
|
|
|
+ getView().hideLoading();
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- @Override
|
|
|
- public void onComplete() {
|
|
|
- if (getView() != null) {
|
|
|
- getView().hideLoading();
|
|
|
- }
|
|
|
- }
|
|
|
- });
|
|
|
+ @Override
|
|
|
+ public void onComplete() {
|
|
|
+ if (getView() != null) {
|
|
|
+ getView().hideLoading();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
// addSubscribe(create(APIService.class).getStylePage(RequestBodyUtil.convertToRequestBodyJson(jsonObject.toString())), new BaseObserver<HomeStyleBean>(getView()) {
|
|
|
// @Override
|
|
|
// protected void onSuccess(HomeStyleBean data) {
|