81 lines
3.3 KiB
Java
81 lines
3.3 KiB
Java
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);
|
|
}
|
|
});
|
|
}
|
|
}
|