package com.ubt.jimu.community.presenter;

import android.content.Context;
import android.widget.ImageView;
import android.widget.Toast;
import com.ubt.jimu.JimuApplication;
import com.ubt.jimu.R;
import com.ubt.jimu.base.entities.CommentBean;
import com.ubt.jimu.base.entities.FollowEntities;
import com.ubt.jimu.base.entities.ReportBean;
import com.ubt.jimu.base.http.ApiObserver;
import com.ubt.jimu.base.http.manager.CommunityManager;
import com.ubt.jimu.community.contract.PublishDetailContact$Presenter;
import com.ubt.jimu.community.contract.PublishDetailContact$View;
import com.ubt.jimu.community.view.PublishDetailActivity;
import com.ubt.jimu.community.view.popwindow.ReportPopwindow;
import com.ubt.jimu.widgets.LoadingView;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;

/* loaded from: classes.dex */
public class PublishDetailPresenter implements PublishDetailContact$Presenter {
    private ApiObserver<ReportBean> a;
    private ApiObserver<FollowEntities> b;
    private ApiObserver<FollowEntities> c;
    private PublishDetailContact$View d;
    public ApiObserver<CommentBean> e;
    private Context f;
    private CompositeDisposable g = new CompositeDisposable();
    private int h;
    private int i;

    public PublishDetailPresenter(Context context, PublishDetailContact$View publishDetailContact$View) {
        this.d = publishDetailContact$View;
        this.f = context;
        publishDetailContact$View.V();
    }

    @Override // com.ubtech.presenter.BasePresenter
    public void unSubscribe() {
        this.g.dispose();
        this.g.a();
    }

    public void a(String str, int i, int i2, final ReportPopwindow reportPopwindow, final LoadingView loadingView) {
        if (this.a == null) {
            this.a = new ApiObserver<ReportBean>(loadingView) { // from class: com.ubt.jimu.community.presenter.PublishDetailPresenter.1
                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(ReportBean reportBean) {
                    loadingView.b();
                    if (reportBean.isStatus()) {
                        ((PublishDetailActivity) PublishDetailPresenter.this.f).imgReport.setBackgroundResource(R.drawable.community_publish_report);
                        Toast.makeText(JimuApplication.l(), PublishDetailPresenter.this.f.getString(R.string.report_success), 1).show();
                        reportPopwindow.dismiss();
                    } else {
                        Toast.makeText(JimuApplication.l(), PublishDetailPresenter.this.f.getString(R.string.report_fail), 1).show();
                        ((PublishDetailActivity) PublishDetailPresenter.this.f).imgReport.setBackgroundResource(R.drawable.community_publish_report);
                        reportPopwindow.dismiss();
                    }
                }

                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                public void onSubscribe(Disposable disposable) {
                    super.onSubscribe(disposable);
                    PublishDetailPresenter.this.g.b(disposable);
                }
            };
        }
        CommunityManager.create().reportProblem(i2, i, str, this.a);
    }

    public void b(int i, final ImageView imageView, int i2) {
        this.i = i2;
        if (this.b == null) {
            this.b = new ApiObserver<FollowEntities>(null) { // from class: com.ubt.jimu.community.presenter.PublishDetailPresenter.3
                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(FollowEntities followEntities) {
                    if (imageView.isSelected()) {
                        PublishDetailPresenter.this.d.b(false, PublishDetailPresenter.this.i - 1);
                    } else {
                        PublishDetailPresenter.this.d.b(true, PublishDetailPresenter.this.i + 1);
                    }
                }

                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                public void onSubscribe(Disposable disposable) {
                    super.onSubscribe(disposable);
                    PublishDetailPresenter.this.g.b(disposable);
                }
            };
        }
        CommunityManager.create().praise(i, this.b);
    }

    public void a(int i, int i2, int i3, boolean z, final LoadingView loadingView) {
        if (this.e == null) {
            this.e = new ApiObserver<CommentBean>(loadingView) { // from class: com.ubt.jimu.community.presenter.PublishDetailPresenter.2
                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(CommentBean commentBean) {
                    loadingView.b();
                    PublishDetailPresenter.this.d.a(commentBean);
                }

                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                public void onSubscribe(Disposable disposable) {
                    super.onSubscribe(disposable);
                    PublishDetailPresenter.this.g.b(disposable);
                }
            };
        }
        this.e.refreshOrLoad(z);
        CommunityManager.create().commentList(i, i2, i3, this.e);
    }

    public void a(int i, final ImageView imageView, int i2) {
        this.h = i2;
        if (this.c == null) {
            this.c = new ApiObserver<FollowEntities>(null) { // from class: com.ubt.jimu.community.presenter.PublishDetailPresenter.4
                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                /* renamed from: a, reason: merged with bridge method [inline-methods] */
                public void onNext(FollowEntities followEntities) {
                    if (imageView.isSelected()) {
                        PublishDetailPresenter.this.d.a(false, PublishDetailPresenter.this.h - 1);
                    } else {
                        PublishDetailPresenter.this.d.a(true, PublishDetailPresenter.this.h + 1);
                    }
                }

                @Override // com.ubt.jimu.base.http.ApiObserver, io.reactivex.Observer
                public void onSubscribe(Disposable disposable) {
                    super.onSubscribe(disposable);
                    PublishDetailPresenter.this.g.b(disposable);
                }
            };
        }
        CommunityManager.create().collectionPost(i, this.c);
    }
}