package com.ubt.jimu.user.presenter;

import android.content.Context;
import com.ubt.jimu.base.cache.Cache;
import com.ubt.jimu.base.db.diy.DiyDBModel;
import com.ubt.jimu.base.entities.UserExtraInfo;
import com.ubt.jimu.base.http.ApiObserver;
import com.ubt.jimu.transport3.DiyTransportServiceImpl;
import com.ubt.jimu.transport3.dao.DiyDBModelDBHandler;
import com.ubt.jimu.user.contract.UserInfoContract$Presenter;
import com.ubt.jimu.user.contract.UserInfoContract$View;
import com.ubt.jimu.user.repository.UserRepository;
import com.ubt.jimu.utils.RxSchedulers;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
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;
import java.util.List;

/* loaded from: classes2.dex */
public class UserInfoPresenter implements UserInfoContract$Presenter {
    private CompositeDisposable a;
    private UserInfoContract$View b;

    public UserInfoPresenter(Context context, UserInfoContract$View userInfoContract$View) {
        this.b = userInfoContract$View;
        this.b.setPresenter(this);
        this.a = new CompositeDisposable();
    }

    @Override // com.ubtech.presenter.BasePresenter
    public void subscribe() {
        long d = this.b.d();
        a(this.b.S(), d);
        if (String.valueOf(d).equals(Cache.getInstance().getUserId())) {
            a(String.valueOf(d));
        } else {
            this.b.E();
        }
    }

    @Override // com.ubtech.presenter.BasePresenter
    public void unSubscribe() {
        this.a.dispose();
        this.a.a();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void b(final String str) {
        Observable.create(new ObservableOnSubscribe<List<DiyDBModel>>(this) { // from class: com.ubt.jimu.user.presenter.UserInfoPresenter.5
            @Override // io.reactivex.ObservableOnSubscribe
            public void subscribe(ObservableEmitter<List<DiyDBModel>> observableEmitter) {
                observableEmitter.onNext(DiyDBModelDBHandler.getInstance().getUserDiyModels(str));
                observableEmitter.onComplete();
            }
        }).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Observer<List<DiyDBModel>>() { // from class: com.ubt.jimu.user.presenter.UserInfoPresenter.6
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(List<DiyDBModel> list) {
                UserInfoPresenter.this.b.r(list);
            }

            @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) {
                UserInfoPresenter.this.a.b(disposable);
            }
        });
    }

    @Override // com.ubt.jimu.user.contract.UserInfoContract$Presenter
    public void a(long j, long j2) {
        UserRepository.a(j, j2).compose(RxSchedulers.a()).subscribe(new Observer<UserExtraInfo>() { // from class: com.ubt.jimu.user.presenter.UserInfoPresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(UserExtraInfo userExtraInfo) {
                UserInfoPresenter.this.b.a(userExtraInfo);
            }

            @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) {
                UserInfoPresenter.this.a.b(disposable);
            }
        });
    }

    public void a(final String str) {
        DiyTransportServiceImpl.getInstance().getModels(str, new ApiObserver<List<DiyDBModel>>(null) { // from class: com.ubt.jimu.user.presenter.UserInfoPresenter.4
            @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
            public void onError(Throwable th) {
                super.onError(th);
                UserInfoPresenter.this.b(str);
            }

            @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                super.onSubscribe(disposable);
                UserInfoPresenter.this.a.b(disposable);
            }

            @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
            public void onNext(List<DiyDBModel> list) {
                super.onNext((AnonymousClass4) list);
                UserInfoPresenter.this.b.r(list);
            }
        });
    }
}