package com.ubt.jimu.community.presenter;

import android.content.Context;
import android.text.TextUtils;
import com.ubt.jimu.base.cache.Cache;
import com.ubt.jimu.base.entities.Constant;
import com.ubt.jimu.base.entities.FavouriteBean;
import com.ubt.jimu.base.entities.GuessEnjoyEntities;
import com.ubt.jimu.community.contract.MyFavouriteContract$Presenter;
import com.ubt.jimu.community.contract.MyFavouriteContract$View;
import com.ubt.jimu.community.model.MyFavouriteModel;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

/* loaded from: classes.dex */
public class MyFavouritePresenter implements MyFavouriteContract$Presenter {
    private MyFavouriteContract$View a;
    private CompositeDisposable b = new CompositeDisposable();

    /* JADX WARN: Multi-variable type inference failed */
    public MyFavouritePresenter(Context context) {
        this.a = (MyFavouriteContract$View) context;
    }

    public void a() {
        b();
    }

    public void b() {
        MyFavouriteModel.a(1).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Observer<GuessEnjoyEntities>() { // from class: com.ubt.jimu.community.presenter.MyFavouritePresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(GuessEnjoyEntities guessEnjoyEntities) {
                if (guessEnjoyEntities == null || guessEnjoyEntities.getRecords().size() == 0) {
                    MyFavouritePresenter.this.a.q();
                    return;
                }
                MyFavouritePresenter.this.a.a(guessEnjoyEntities);
                String userId = Cache.getInstance().getUserId();
                if (!"local".equals(userId) && !TextUtils.isEmpty(userId)) {
                    MyFavouritePresenter.this.a(0);
                } else {
                    MyFavouritePresenter.this.a.b(Constant.Community.LinkEmptyState.NotLoggedIn);
                    MyFavouritePresenter.this.a.j();
                }
            }

            @Override // io.reactivex.Observer
            public void onComplete() {
            }

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
                MyFavouritePresenter.this.a.o();
            }

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                MyFavouritePresenter.this.a.c();
                MyFavouritePresenter.this.b.b(disposable);
            }
        });
    }

    public void a(int i, final Constant.Community.LinkEmptyState linkEmptyState) {
        MyFavouriteModel.a(i).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Observer<GuessEnjoyEntities>() { // from class: com.ubt.jimu.community.presenter.MyFavouritePresenter.2
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(GuessEnjoyEntities guessEnjoyEntities) {
                if (guessEnjoyEntities == null || guessEnjoyEntities.getRecords().size() <= 0) {
                    MyFavouritePresenter.this.a.a(linkEmptyState);
                } else {
                    MyFavouritePresenter.this.a.a(guessEnjoyEntities, linkEmptyState);
                }
            }

            @Override // io.reactivex.Observer
            public void onComplete() {
            }

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
            }

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                MyFavouritePresenter.this.b.b(disposable);
            }
        });
    }

    public void a(int i) {
        MyFavouriteModel.b(i).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Observer<FavouriteBean>() { // from class: com.ubt.jimu.community.presenter.MyFavouritePresenter.3
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(FavouriteBean favouriteBean) {
                MyFavouritePresenter.this.a.j();
                if (favouriteBean == null || favouriteBean.getRecords().size() == 0) {
                    MyFavouritePresenter.this.a.b(Constant.Community.LinkEmptyState.NotSubscription);
                } else {
                    MyFavouritePresenter.this.a.a(favouriteBean);
                }
            }

            @Override // io.reactivex.Observer
            public void onComplete() {
            }

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
                MyFavouritePresenter.this.a.o();
            }

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                MyFavouritePresenter.this.b.b(disposable);
            }
        });
    }
}