package com.ubt.jimu.user.presenter;

import com.ubt.jimu.base.entities.ApiStatus;
import com.ubt.jimu.course.repository.CourseResult;
import com.ubt.jimu.user.contract.VerifyContract$Presenter;
import com.ubt.jimu.user.contract.VerifyContract$View;
import com.ubt.jimu.user.repository.UserRepository;
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: classes2.dex */
public class VerifyPresenter implements VerifyContract$Presenter {
    private final CompositeDisposable a = new CompositeDisposable();
    private VerifyContract$View b;

    public VerifyPresenter(VerifyContract$View verifyContract$View) {
        this.b = verifyContract$View;
    }

    @Override // com.ubt.jimu.user.contract.VerifyContract$Presenter
    public void getCaptcha(String str, String str2, String str3, String str4, String str5) {
        UserRepository.a(str, str2, str3, str4, str5).observeOn(AndroidSchedulers.a()).subscribeOn(Schedulers.b()).subscribe(new Observer<ApiStatus>() { // from class: com.ubt.jimu.user.presenter.VerifyPresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(ApiStatus apiStatus) {
                if (apiStatus == null || apiStatus.getCode() != 0) {
                    VerifyPresenter.this.b.c(new Exception("获取验证码失败"));
                } else {
                    VerifyPresenter.this.b.e(apiStatus);
                }
            }

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

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
                VerifyPresenter.this.b.c(th);
            }

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

    @Override // com.ubt.jimu.user.contract.VerifyContract$Presenter
    public void a(String str, String str2) {
        UserRepository.b(str, str2).observeOn(AndroidSchedulers.a()).subscribeOn(Schedulers.b()).subscribe(new Observer<ApiStatus>() { // from class: com.ubt.jimu.user.presenter.VerifyPresenter.2
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(ApiStatus apiStatus) {
                if (apiStatus.getCode() == 0 || CourseResult.SUCCESS.equals(apiStatus.getMessage())) {
                    VerifyPresenter.this.b.g(apiStatus);
                } else {
                    VerifyPresenter.this.b.b(new Exception("验证失败"));
                }
            }

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

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

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