bygzvr.zip_C#_according174_create33w_unusual9i1

package com.caij.emore.present.imp; import com.caij.emore.api.ex.ResponseSubscriber; import com.caij.emore.bean.Attitude; import com.caij.emore.bean.response.AttitudeResponse; import com.caij.emore.data.local.NotifyManager; import com.caij.emore.database.bean.UnReadMessage; import com.caij.emore.present.RefreshListPresent; import com.caij.emore.data.remote.AttitudeApi; import com.caij.emore.data.remote.NotifyApi; import com.caij.emore.ui.view.RefreshListView; import com.caij.emore.api.ex.ErrorCheckerTransformer; import com.caij.emore.api.ex.SchedulerTransformer; import com.caij.emore.utils.weibo.MessageUtil; import java.util.ArrayList; import java.util.List; import rx.Observable; import rx.Subscription; import rx.functions.Func1; /** * Created by Caij on 2016/7/4. */ public class AttitudesToMePresentImp extends AbsBasePresent implements RefreshListPresent { private static final int COUNT = 20; private long mUid; private RefreshListView<Attitude> mView; private List<Attitude> mAttitudes; private AttitudeApi mAttitudeApi; private NotifyApi mNotifyApi; private NotifyManager mNotifyManager; private int mPage; public AttitudesToMePresentImp(long uid, AttitudeApi attitudeApi, NotifyApi notifyApi, NotifyManager notifyManager, RefreshListView<Attitude> view) { super(); mUid = uid; mAttitudeApi = attitudeApi; mView = view; mNotifyApi = notifyApi; mNotifyManager = notifyManager; mAttitudes = new ArrayList<>(); } @Override public void onCreate() { refresh(); } @Override public void userFirstVisible() { } @Override public void refresh() { Subscription su = createGetAttitudeObservable(1, true) .subscribe(new ResponseSubscriber<List<Attitude>>(mView) { @Override protected void onFail(Throwable e) { mView.onRefreshComplete(); } @Override public void onNext(List<Attitude> attitudes) { mAttitudes.clear(); mAttitudes.addAll(attitudes); mView.notifyItemChanged(mAttitudes); mView.onRefreshComplete(); mView.onLoadComplete(attitudes.size() > 0); MessageUtil.resetUnReadMessage(UnReadMessage.TYPE_ATTITUDE, mUid, mNotifyApi, mNotifyManager); mPage = 2; } }); addSubscription(su); } @Override public void loadMore() { Subscription su = createGetAttitudeObservable(mPage, false) .subscribe(new ResponseSubscriber<List<Attitude>>(mView) { @Override protected void onFail(Throwable e) { mView.onLoadComplete(true); } @Override public void onCompleted() { } @Override public void onNext(List<Attitude> attitudes) { mAttitudes.addAll(attitudes); mView.notifyItemRangeInserted(mAttitudes, mAttitudes.size() - attitudes.size(), attitudes.size()); mView.onLoadComplete(attitudes.size() > 0); mPage ++; } }); addSubscription(su); } private Observable<List<Attitude>> createGetAttitudeObservable(int page, final boolean isRefresh) { return mAttitudeApi.getToMeAttitudes(0, 0, page, COUNT) .compose(new ErrorCheckerTransformer<AttitudeResponse>()) .flatMap(new Func1<AttitudeResponse, Observable<Attitude>>() { @Override public Observable<Attitude> call(AttitudeResponse queryWeiboAttitudeResponse) { return Observable.from(queryWeiboAttitudeResponse.getAttitudes()); } }) .filter(new Func1<Attitude, Boolean>() { @Override public Boolean call(Attitude attitude) { return !mAttitudes.contains(attitude) || isRefresh; } }) .toList() .compose(new SchedulerTransformer<List<Attitude>>()); } }