package com.ubt.jimu.user.setting.view;

import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.os.Build;
import android.text.TextUtils;
import com.ubt.jimu.JimuApplication;
import com.ubt.jimu.R;
import com.ubt.jimu.base.db.user.UserDbHandler;
import com.ubt.jimu.base.entities.FeedbackEntities;
import com.ubt.jimu.base.entities.PublishType;
import com.ubt.jimu.base.entities.User;
import com.ubt.jimu.base.http.ApiClient;
import com.ubt.jimu.base.http.ApiConstants;
import com.ubt.jimu.base.http.service.UserService;
import com.ubt.jimu.base.mvp.BaseRxView;
import com.ubt.jimu.base.mvp.RxPresenter;
import com.ubt.jimu.community.presenter.PublishCommunityPresenter;
import com.ubt.jimu.upload.DataUploadProxy;
import com.ubt.jimu.upload.ProgressUploadCallback;
import com.ubt.jimu.upload.UploadRequest;
import com.ubt.jimu.upload.UploadResponse;
import com.ubt.jimu.user.feedback.FeedBackIconBean;
import com.ubt.jimu.user.feedback.FeedbackPostBean;
import com.ubt.jimu.user.feedback.LogUploadWorker;
import com.ubt.jimu.utils.EncryptUtils;
import com.ubt.jimu.utils.Md5Utils;
import com.ubt.jimu.utils.videoUtil.CompressUtil;
import com.ubt.jimu.video.Configuration;
import com.ubt.jimu.video.OnCompressListener;
import com.ubt.jimu.video.VideoCompressUtils;
import com.ubt.jimu.widgets.choosePhotos.AlbumActivity;
import com.ubt.jimu.widgets.choosePhotos.media.HPMedia;
import com.ubtech.permission.JimuPermissionRequest;
import com.ubtech.permission.PermissionRequestListener;
import com.ubtech.utils.StringUtils;
import com.ubtech.view.widget.ToastView;
import com.ubtrobot.log.ALog;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.disposables.Disposable;
import io.reactivex.schedulers.Schedulers;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

/* loaded from: classes2.dex */
public class FeedBackPresenter extends RxPresenter<FeedBackView> {
    private Context a;
    private FeedBackView b;
    private FeedbackPostBean c;
    private ArrayList<HPMedia> d;
    private IChooseImg e;
    private boolean f;
    private boolean g;
    private PublishCommunityPresenter.CompressionProgressListener h;

    public interface FeedBackView extends BaseRxView {
        void a(int i);

        void a(FeedbackEntities feedbackEntities);

        void a(UploadRequest uploadRequest, double d);

        void a(UploadResponse uploadResponse);

        void allUploadSucceed();

        void g();

        void k();

        void n();
    }

    public interface IChooseImg {
        void a(List<HPMedia> list);
    }

    public FeedBackPresenter(Context context, FeedBackView feedBackView) {
        this.a = context;
        this.b = feedBackView;
    }

    private void d() {
        VideoCompressUtils.a(JimuApplication.k).a();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void e() {
        FeedbackPostBean c = c();
        c.setAppType("2");
        c.setServiceVersion(ApiConstants.getAppVersion());
        long currentTimeMillis = System.currentTimeMillis();
        c.setRequestTime(String.valueOf(currentTimeMillis));
        c.setRequestKey(EncryptUtils.a(currentTimeMillis + ApiConstants.ENCODE_KEY, 32));
        c.setSystemLanguage(JimuApplication.l().g());
        c.setSystemArea(JimuApplication.l().c());
        c.setAppSource("Jimu");
        c.setLanguage(JimuApplication.l().g());
        ALog.a("FeedBackFragment").d("请求参数：" + c.toString());
        ((UserService) ApiClient.getService(UserService.class)).sendFeedback(c).subscribeOn(Schedulers.b()).observeOn(AndroidSchedulers.a()).subscribe(new Observer<FeedbackEntities>() { // from class: com.ubt.jimu.user.setting.view.FeedBackPresenter.5
            @Override // io.reactivex.Observer
            /* renamed from: a, reason: merged with bridge method [inline-methods] */
            public void onNext(FeedbackEntities feedbackEntities) {
                ALog.a("FeedBackFragment").d("反馈完成:" + feedbackEntities);
                FeedBackPresenter.this.b.hideLoadingDialog();
                FeedBackPresenter.this.b.a(feedbackEntities);
            }

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

            @Override // io.reactivex.Observer
            public void onError(Throwable th) {
                ALog.a("FeedBackFragment").d("反馈失败:" + th.getMessage());
                FeedBackPresenter.this.b.hideLoadingDialog();
                ToastView.a(FeedBackPresenter.this.a, FeedBackPresenter.this.a.getString(R.string.failed_to_send_feedback), ToastView.Type.SUCCESS).a();
            }

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

    public void b(List<FeedBackIconBean> list) {
        int i = 0;
        this.g = false;
        final ArrayList arrayList = new ArrayList();
        for (FeedBackIconBean feedBackIconBean : list) {
            if (!feedBackIconBean.isAddFlag()) {
                arrayList.add(feedBackIconBean);
            }
        }
        if (arrayList.size() <= 0) {
            this.b.showLoadingDialog(JimuApplication.l().getString(R.string.feedback_sending));
            a(false);
            return;
        }
        this.b.n();
        this.c.setmMediaList(arrayList);
        Iterator<FeedBackIconBean> it = arrayList.iterator();
        while (it.hasNext()) {
            if (1 == it.next().getmType()) {
                i++;
            }
        }
        if (i > 0) {
            this.b.a((i * 100) + 10);
            a(arrayList);
        } else {
            this.b.k();
            Observable.create(new ObservableOnSubscribe() { // from class: com.ubt.jimu.user.setting.view.a0
                @Override // io.reactivex.ObservableOnSubscribe
                public final void subscribe(ObservableEmitter observableEmitter) {
                    FeedBackPresenter.this.a(arrayList, observableEmitter);
                }
            }).subscribeOn(Schedulers.b()).subscribe();
        }
        a(true);
    }

    public FeedbackPostBean c() {
        return this.c;
    }

    public void a(String str, String str2, String str3, long j) {
        this.c = new FeedbackPostBean();
        if (!TextUtils.isEmpty(str) && StringUtils.d(str)) {
            this.c.setFeedbackEmail(str);
        } else if (!TextUtils.isEmpty(str) && StringUtils.a((CharSequence) str)) {
            this.c.setFeedbackPhone(str);
        }
        User user = UserDbHandler.getUser();
        if (user == null || user.getUserId() > 0) {
            this.c.setFeedbackUser(Long.valueOf(user.getUserId()));
        }
        this.c.setFeedbackContent(str2);
        this.c.setDeviceType(Build.MODEL);
        this.c.setDeviceVersion("android-" + Build.VERSION.RELEASE);
        this.c.setFeedbackType(str3);
        this.c.setPackageId((int) j);
        this.c.setLanguage(JimuApplication.l().g());
        this.c.setArea(JimuApplication.l().c());
    }

    public void c(List<FeedBackIconBean> list) {
        ArrayList arrayList = new ArrayList();
        ArrayList arrayList2 = new ArrayList();
        for (int i = 0; i < list.size(); i++) {
            FeedBackIconBean feedBackIconBean = list.get(i);
            int i2 = feedBackIconBean.getmType();
            if (i2 == 0 || i2 == 1) {
                UploadRequest uploadRequest = new UploadRequest();
                ALog.a("FeedBackFragment").d("\"MD5后数值" + Md5Utils.a(feedBackIconBean.getmName(), 8));
                uploadRequest.a("jimu/post/" + (Md5Utils.a(feedBackIconBean.getmName(), 8) + (i2 == 1 ? ".mp4" : ".jpg")));
                uploadRequest.b(feedBackIconBean.getPath());
                uploadRequest.a(i);
                if (i2 == 0) {
                    uploadRequest.a(PublishType.IMAGE);
                }
                arrayList.add(uploadRequest);
                if (i2 == 1) {
                    arrayList2.add(uploadRequest);
                }
            }
        }
        this.f = false;
        DataUploadProxy.c().a(arrayList, new ProgressUploadCallback() { // from class: com.ubt.jimu.user.setting.view.FeedBackPresenter.3
            @Override // com.ubt.jimu.upload.ProgressUploadCallback
            public void a(UploadRequest uploadRequest2, double d) {
                if (FeedBackPresenter.this.g) {
                    return;
                }
                FeedBackPresenter.this.b.a(uploadRequest2, d);
            }

            @Override // com.ubt.jimu.upload.ProgressUploadCallback, com.ubt.jimu.upload.IUploadCallback
            public void allComplete() {
            }

            @Override // com.ubt.jimu.upload.ProgressUploadCallback, com.ubt.jimu.upload.IUploadCallback
            public void allUploadSucceed() {
                ALog.a("FeedBackFragment").d("所有任务执行完成");
                if (FeedBackPresenter.this.g) {
                    return;
                }
                FeedBackPresenter.this.c().setMediaUploadFinishFlag(true);
                FeedBackPresenter.this.b.allUploadSucceed();
                if (FeedBackPresenter.this.c().isLogUploadFinisgFlag()) {
                    FeedBackPresenter.this.e();
                }
            }

            @Override // com.ubt.jimu.upload.IUploadCallback
            public void uploadFaulted(UploadRequest uploadRequest2, Exception exc) {
                ALog.a("FeedBackFragment").d("上传失败");
                if (FeedBackPresenter.this.f) {
                    return;
                }
                FeedBackPresenter.this.f = true;
                DataUploadProxy.c().a();
                FeedBackPresenter.this.b.g();
            }

            @Override // com.ubt.jimu.upload.IUploadCallback
            public void uploadSucceed(UploadResponse uploadResponse) {
                if (FeedBackPresenter.this.g) {
                    return;
                }
                FeedBackPresenter.this.b.a(uploadResponse);
            }
        });
    }

    public void a(final Activity activity) {
        if (this.d == null) {
            this.d = new ArrayList<>();
        }
        JimuPermissionRequest.c(activity, new PermissionRequestListener() { // from class: com.ubt.jimu.user.setting.view.FeedBackPresenter.1
            @Override // com.ubtech.permission.PermissionRequestListener
            public void onDenied() {
            }

            @Override // com.ubtech.permission.PermissionRequestListener
            public void onGranted() {
                AlbumActivity.a(activity, 999, 6, FeedBackPresenter.this.d, 5, "MULTITERM_VIDEO_IMAGE");
            }
        });
    }

    public void b() {
        ArrayList<HPMedia> arrayList = this.d;
        if (arrayList != null) {
            arrayList.clear();
        }
    }

    public /* synthetic */ void a(List list, ObservableEmitter observableEmitter) throws Exception {
        c((List<FeedBackIconBean>) list);
    }

    public void a(List<FeedBackIconBean> list) {
        ArrayList arrayList = new ArrayList();
        for (int i = 0; i < list.size(); i++) {
            FeedBackIconBean feedBackIconBean = list.get(i);
            if (feedBackIconBean.getmType() == 1) {
                String path = feedBackIconBean.getPath();
                Configuration configuration = new Configuration();
                String a = CompressUtil.a(path, i);
                configuration.a = path;
                configuration.b = a;
                configuration.f = i;
                arrayList.add(configuration);
            }
        }
        VideoCompressUtils.a(JimuApplication.k).a(arrayList, new OnCompressListener() { // from class: com.ubt.jimu.user.setting.view.FeedBackPresenter.2
            @Override // com.ubt.jimu.video.OnCompressListener
            public void onAllCompressFail() {
                if (FeedBackPresenter.this.h != null) {
                    FeedBackPresenter.this.h.onAllCompressFail();
                }
            }

            @Override // com.ubt.jimu.video.OnCompressListener
            public void onAllCompressSuccess() {
                if (FeedBackPresenter.this.h != null) {
                    FeedBackPresenter.this.h.m();
                }
            }

            @Override // com.ubt.jimu.video.OnCompressListener
            public void onFail(boolean z) {
                if (FeedBackPresenter.this.h != null) {
                    FeedBackPresenter.this.h.c(z);
                }
            }

            @Override // com.ubt.jimu.video.OnCompressListener
            public void onProgress(float f) {
                if (FeedBackPresenter.this.g) {
                    ALog.a("FeedBackFragment").d("压缩视频被取消");
                } else if (FeedBackPresenter.this.h != null) {
                    FeedBackPresenter.this.h.d((int) f);
                }
            }

            @Override // com.ubt.jimu.video.OnCompressListener
            public void onSuccess(Configuration configuration2) {
                if (FeedBackPresenter.this.h != null) {
                    FeedBackPresenter.this.h.a(configuration2.f, configuration2.b);
                }
            }

            @Override // com.ubt.jimu.video.OnCompressListener
            public void prepareCompress() {
                if (FeedBackPresenter.this.h != null) {
                    FeedBackPresenter.this.h.U();
                }
            }
        });
    }

    public /* synthetic */ void a(final boolean z, ObservableEmitter observableEmitter) throws Exception {
        new LogUploadWorker().c(new LogUploadWorker.LogWorkerCallBack() { // from class: com.ubt.jimu.user.setting.view.FeedBackPresenter.4
            @Override // com.ubt.jimu.user.feedback.LogUploadWorker.LogWorkerCallBack
            public void a(String str) {
                ALog.a("FeedBackFragment").d("日志上传成功");
                FeedBackPresenter.this.c().setLogFilePath(str);
                FeedBackPresenter.this.c().setLogUploadFinisgFlag(true);
                if (z && FeedBackPresenter.this.c().isMediaUploadFinishFlag()) {
                    ALog.a("FeedBackFragment").d("媒体上传完成:发布反馈");
                    FeedBackPresenter.this.e();
                } else {
                    if (z) {
                        return;
                    }
                    ALog.a("FeedBackFragment").d("不需要等待媒体上传完成:发布反馈");
                    FeedBackPresenter.this.e();
                }
            }

            @Override // com.ubt.jimu.user.feedback.LogUploadWorker.LogWorkerCallBack
            public void b(String str) {
                ALog.a("FeedBackFragment").d("日志上传失败");
                FeedBackPresenter.this.c().setLogFilePath("");
                FeedBackPresenter.this.c().setLogUploadFinisgFlag(true);
                if (z) {
                    return;
                }
                ALog.a("FeedBackFragment").d("不需要等待媒体上传完成:发布反馈");
                FeedBackPresenter.this.e();
            }
        });
    }

    public void a(final boolean z) {
        Observable.create(new ObservableOnSubscribe() { // from class: com.ubt.jimu.user.setting.view.z
            @Override // io.reactivex.ObservableOnSubscribe
            public final void subscribe(ObservableEmitter observableEmitter) {
                FeedBackPresenter.this.a(z, observableEmitter);
            }
        }).subscribeOn(Schedulers.b()).subscribe();
    }

    public void a() {
        this.g = true;
        d();
    }

    public void a(int i) {
        ArrayList<HPMedia> arrayList = this.d;
        if (arrayList == null || arrayList.size() <= i) {
            return;
        }
        this.d.remove(i);
    }

    public void a(PublishCommunityPresenter.CompressionProgressListener compressionProgressListener) {
        this.h = compressionProgressListener;
    }

    public void a(IChooseImg iChooseImg) {
        this.e = iChooseImg;
    }

    public void a(int i, int i2, Intent intent) {
        if (-1 == i2 && intent != null && i == 999) {
            List list = (List) intent.getSerializableExtra("result_data");
            ALog.a("FeedBackFragment").d("选中的列表:" + list.size());
            this.d.clear();
            this.d.addAll(list);
            IChooseImg iChooseImg = this.e;
            if (iChooseImg != null) {
                iChooseImg.a(this.d);
            }
        }
    }
}