package com.ubt.jimu.community.activity.presenter;

import android.content.Context;
import com.ubt.jimu.R;
import com.ubt.jimu.base.entities.AwardItem;
import com.ubt.jimu.base.entities.InfoStatus;
import com.ubt.jimu.base.entities.Push;
import com.ubt.jimu.community.activity.contract.AwardContract$Presenter;
import com.ubt.jimu.community.activity.contract.AwardContract$View;
import com.ubt.jimu.community.activity.repository.ActivityRepository;
import com.ubt.jimu.utils.NetWorkUtil;
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: classes.dex */
public class AwardPresenter implements AwardContract$Presenter {
    private Context a;
    private AwardContract$View b;
    private CompositeDisposable c;

    public AwardPresenter(Context context, AwardContract$View awardContract$View) {
        this.a = context;
        this.b = awardContract$View;
        this.b.setPresenter(this);
        this.c = new CompositeDisposable();
    }

    @Override // com.ubt.jimu.community.activity.contract.AwardContract$Presenter
    public void n() {
        if (!NetWorkUtil.b(this.a)) {
            this.b.a(this.a.getString(R.string.network_error));
        } else {
            this.b.a();
            ActivityRepository.b(this.b.w()).compose(RxSchedulers.a()).subscribe(new Observer<List<AwardItem>>() { // from class: com.ubt.jimu.community.activity.presenter.AwardPresenter.1
                @Override // io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(List<AwardItem> list) {
                    AwardPresenter.this.b.i(list);
                }

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

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

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

    @Override // com.ubt.jimu.community.activity.contract.AwardContract$Presenter
    public void a(String str, long j) {
        if (NetWorkUtil.b(this.a)) {
            ActivityRepository.a(str, j).compose(RxSchedulers.a()).subscribe(new Observer<List<Push>>() { // from class: com.ubt.jimu.community.activity.presenter.AwardPresenter.2
                @Override // io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(List<Push> list) {
                    AwardPresenter.this.b.m(list);
                }

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

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

                @Override // io.reactivex.Observer
                public void onSubscribe(Disposable disposable) {
                    AwardPresenter.this.c.b(disposable);
                }
            });
        } else {
            this.b.a(this.a.getString(R.string.network_error));
        }
    }

    @Override // com.ubt.jimu.community.activity.contract.AwardContract$Presenter
    public void b(String str, int i) {
        if (NetWorkUtil.b(this.a)) {
            ActivityRepository.a(i).compose(RxSchedulers.a()).subscribe(new Observer<InfoStatus>() { // from class: com.ubt.jimu.community.activity.presenter.AwardPresenter.3
                @Override // io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(InfoStatus infoStatus) {
                }

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

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

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