package com.ubt.jimu.pack.presenter;

import android.content.Context;
import android.content.DialogInterface;
import com.ubt.jimu.base.dialog.JimuSimpleDialog;
import com.ubt.jimu.base.download.Downloader;
import com.ubt.jimu.base.entities.ApiResult;
import com.ubt.jimu.base.entities.Package;
import com.ubt.jimu.base.entities.Story;
import com.ubt.jimu.discover.CourseRepository;
import com.ubt.jimu.pack.contract.PackageContract$Presenter;
import com.ubt.jimu.pack.contract.PackageContract$View;
import com.ubt.jimu.pack.repository.PackageRepository;
import com.ubt.jimu.utils.RxSchedulers;
import io.reactivex.Observer;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;
import java.util.List;

/* loaded from: classes2.dex */
public class PackagePresenter implements PackageContract$Presenter {
    private Context a;
    private PackageContract$View b;
    private Story c;
    private CompositeDisposable d;

    /* JADX WARN: Multi-variable type inference failed */
    public PackagePresenter(Context context) {
        this.a = context;
        this.b = (PackageContract$View) context;
        this.b.setPresenter(this);
        this.d = new CompositeDisposable();
    }

    static /* synthetic */ void b(DialogInterface dialogInterface, int i) {
    }

    private void e() {
        CourseRepository.a().compose(RxSchedulers.a()).subscribe(new Observer<List<Story>>() { // from class: com.ubt.jimu.pack.presenter.PackagePresenter.4
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(List<Story> list) {
                if (list == null || list.size() <= 0) {
                    PackagePresenter.this.b.C();
                    return;
                }
                for (Story story : list) {
                    if ("AstroBot".equals(story.getStoryName())) {
                        PackagePresenter.this.c = story;
                        PackagePresenter.this.a(story);
                        return;
                    }
                }
            }

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

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

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

    public void c() {
        PackageRepository.b().compose(RxSchedulers.a()).subscribe(new Observer<ApiResult<Package>>() { // from class: com.ubt.jimu.pack.presenter.PackagePresenter.2
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(ApiResult<Package> apiResult) {
                PackagePresenter.this.b.h(apiResult.getModels());
                PackagePresenter.this.b.K();
            }

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

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

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                PackagePresenter.this.d.b(disposable);
                PackagePresenter.this.b.v();
            }
        });
    }

    public void d() {
        PackageRepository.a(this.a).compose(RxSchedulers.a()).subscribe(new Observer<List<Package>>() { // from class: com.ubt.jimu.pack.presenter.PackagePresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(List<Package> list) {
                PackagePresenter.this.b.h(list);
                PackagePresenter.this.b.K();
            }

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

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

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                PackagePresenter.this.d.b(disposable);
                PackagePresenter.this.b.v();
            }
        });
    }

    public void a() {
        JimuSimpleDialog.showWifiOnlyDialog(this.a, new DialogInterface.OnClickListener() { // from class: com.ubt.jimu.pack.presenter.b
            @Override // android.content.DialogInterface.OnClickListener
            public final void onClick(DialogInterface dialogInterface, int i) {
                PackagePresenter.b(dialogInterface, i);
            }
        }, new DialogInterface.OnClickListener() { // from class: com.ubt.jimu.pack.presenter.a
            @Override // android.content.DialogInterface.OnClickListener
            public final void onClick(DialogInterface dialogInterface, int i) {
                PackagePresenter.this.a(dialogInterface, i);
            }
        }, false);
    }

    public void b() {
        PackageRepository.a().compose(RxSchedulers.a()).subscribe(new Observer<ApiResult<Package>>() { // from class: com.ubt.jimu.pack.presenter.PackagePresenter.3
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(ApiResult<Package> apiResult) {
                PackagePresenter.this.b.h(apiResult.getModels());
                PackagePresenter.this.b.K();
            }

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

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

            @Override // io.reactivex.Observer
            public void onSubscribe(Disposable disposable) {
                PackagePresenter.this.d.b(disposable);
                PackagePresenter.this.b.v();
            }
        });
    }

    public /* synthetic */ void a(DialogInterface dialogInterface, int i) {
        Story story = this.c;
        if (story == null) {
            e();
        } else {
            a(story);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void a(final Story story) {
        this.b.b(Downloader.downloadStarCourse(story, new Downloader.IDownloadJimuRobotListener() { // from class: com.ubt.jimu.pack.presenter.PackagePresenter.5
            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onFailed() {
                PackagePresenter.this.b.C();
            }

            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onPrepareStart() {
                PackagePresenter.this.b.W();
            }

            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onProgress(int i, int i2, int i3) {
                PackagePresenter.this.b.h(i3);
            }

            @Override // com.ubt.jimu.base.download.Downloader.IDownloadJimuRobotListener
            public void onSuccess() {
                PackagePresenter.this.b.a(story);
            }
        }));
    }
}