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();
        }
    }
}