package com.ubt.jimu.user.presenter;

import android.content.Context;
import android.view.View;
import com.ubt.jimu.JimuApplication;
import com.ubt.jimu.R;
import com.ubt.jimu.base.cache.SharePreferenceHelper;
import com.ubt.jimu.base.entities.ApiStatus;
import com.ubt.jimu.base.entities.Robot;
import com.ubt.jimu.community.view.WebViewShopActivity;
import com.ubt.jimu.unity.bluetooth.UnityActivity;
import com.ubt.jimu.user.contract.SettingContract$Presenter;
import com.ubt.jimu.user.contract.SettingContract$View;
import com.ubt.jimu.user.repository.UserRepository;
import com.ubt.jimu.user.view.setting.AboutJimuActivity;
import com.ubt.jimu.user.view.setting.FeedbackActivity;
import com.ubt.jimu.user.view.setting.SettingActivity;
import com.ubt.jimu.user.view.setting.TeachActivity;
import com.ubt.jimu.utils.ThreadManagerUtils;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.CompositeDisposable;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;

/* loaded from: classes2.dex */
public class SettingPresenter implements SettingContract$Presenter {
    private SharePreferenceHelper a;
    private Context b;
    private SettingContract$View c;
    private CompositeDisposable d = new CompositeDisposable();

    public SettingPresenter(Context context, SettingContract$View settingContract$View) {
        this.b = context;
        this.c = settingContract$View;
        this.c.setPresenter(this);
        this.a = new SharePreferenceHelper();
    }

    public void c(View view) {
        view.setPressed(true);
        UnityActivity.startUnityActivity((SettingActivity) this.b, (Robot) null, 1, -1, UnityActivity.BLOCKLY_TYPE_NONE);
    }

    public void d(View view) {
        view.setPressed(true);
        this.a.put(SharePreferenceHelper.SP_KEY_WIFI_VIEW, Boolean.valueOf(this.c.s()));
    }

    public void e(View view) {
        view.setPressed(true);
        String g = JimuApplication.l().g();
        if (!"zh-hans".equals(g)) {
            g = "en";
        }
        String format = String.format("https://video.ubtrobot.com/jimu/product/h5/QA/index_%s.html", g);
        Context context = this.b;
        WebViewShopActivity.a(context, context.getString(R.string.setting_qa), format, "", 0);
    }

    public void f(View view) {
        view.setPressed(true);
        this.a.put(SharePreferenceHelper.SP_KEY_INFO_TO, Boolean.valueOf(this.c.t()));
    }

    public void g(View view) {
        view.setPressed(true);
        TeachActivity.start(this.b);
    }

    public void h(View view) {
        view.setPressed(true);
        FeedbackActivity.start(this.b);
    }

    public void a(boolean z) {
        this.a.put(SharePreferenceHelper.SP_KEY_AUTO_CONNECT, Boolean.valueOf(z));
    }

    public void b(View view) {
        view.setPressed(true);
        this.a.put(SharePreferenceHelper.SP_KEY_ELECTRICITY_PROTECT, Boolean.valueOf(this.c.r()));
    }

    public void a(View view) {
        view.setPressed(true);
        AboutJimuActivity.start(this.b);
    }

    public void b() {
        UserRepository.a().observeOn(AndroidSchedulers.a()).subscribeOn(Schedulers.b()).subscribe(new Observer<ApiStatus>() { // from class: com.ubt.jimu.user.presenter.SettingPresenter.1
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(ApiStatus apiStatus) {
                if (apiStatus == null || apiStatus.getCode() != 0) {
                    SettingPresenter.this.c.h();
                } else {
                    SettingPresenter.this.c.a(apiStatus);
                }
            }

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

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
                th.printStackTrace();
                SettingPresenter.this.c.h();
            }

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

    public void a(String str) {
        UserRepository.a(str).observeOn(AndroidSchedulers.a()).subscribeOn(Schedulers.b()).subscribe(new Observer<ApiStatus>() { // from class: com.ubt.jimu.user.presenter.SettingPresenter.2
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(ApiStatus apiStatus) {
                if (SettingPresenter.this.c == null) {
                    return;
                }
                if (apiStatus == null) {
                    SettingPresenter.this.c.f("");
                } else if (apiStatus.getCode() == 0) {
                    SettingPresenter.this.c.c(apiStatus);
                } else {
                    SettingPresenter.this.c.f(apiStatus.getMessage());
                }
            }

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

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
                if (SettingPresenter.this.c != null) {
                    SettingPresenter.this.c.f("");
                }
            }

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

    public void a() {
        ThreadManagerUtils.a().a();
        this.d.dispose();
        this.d.a();
    }
}