82 lines
2.5 KiB
Java
82 lines
2.5 KiB
Java
package com.ubt.jimu.discover;
|
|
|
|
import com.ubt.jimu.base.cache.Cache;
|
|
import com.ubt.jimu.base.entities.ActionResult;
|
|
import com.ubt.jimu.base.entities.Course;
|
|
import com.ubt.jimu.utils.RxSchedulers;
|
|
import io.reactivex.Observer;
|
|
import io.reactivex.disposables.Disposable;
|
|
|
|
/* loaded from: classes.dex */
|
|
public class CourseHelper {
|
|
private IUploadCourseListener a;
|
|
|
|
public interface IUploadCourseListener {
|
|
void onFailed();
|
|
|
|
void onFinished();
|
|
|
|
void onStart();
|
|
|
|
void onSuccess(ActionResult actionResult);
|
|
}
|
|
|
|
public CourseHelper(IUploadCourseListener iUploadCourseListener) {
|
|
this.a = iUploadCourseListener;
|
|
}
|
|
|
|
private void c() {
|
|
IUploadCourseListener iUploadCourseListener = this.a;
|
|
if (iUploadCourseListener != null) {
|
|
iUploadCourseListener.onStart();
|
|
}
|
|
}
|
|
|
|
private void b() {
|
|
IUploadCourseListener iUploadCourseListener = this.a;
|
|
if (iUploadCourseListener != null) {
|
|
iUploadCourseListener.onFinished();
|
|
}
|
|
}
|
|
|
|
public void a(long j) {
|
|
long loginUserIntId = Cache.getInstance().getLoginUserIntId();
|
|
if (loginUserIntId <= 0) {
|
|
a();
|
|
b();
|
|
} else {
|
|
c();
|
|
CourseRepository.a(loginUserIntId, j, Course.STATUS_COMPLETED).compose(RxSchedulers.a()).subscribe(new Observer<ActionResult>() { // from class: com.ubt.jimu.discover.CourseHelper.1
|
|
@Override // io.reactivex.Observer
|
|
/* renamed from: a, reason: merged with bridge method [inline-methods] */
|
|
public void onNext(ActionResult actionResult) {
|
|
if (CourseHelper.this.a != null) {
|
|
CourseHelper.this.a.onSuccess(actionResult);
|
|
}
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onComplete() {
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onError(Throwable th) {
|
|
CourseHelper.this.a();
|
|
}
|
|
|
|
@Override // io.reactivex.Observer
|
|
public void onSubscribe(Disposable disposable) {
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: private */
|
|
public void a() {
|
|
IUploadCourseListener iUploadCourseListener = this.a;
|
|
if (iUploadCourseListener != null) {
|
|
iUploadCourseListener.onFailed();
|
|
}
|
|
}
|
|
}
|