package o;

import com.scb.phone.data.entity.transfer.SingleDataEntity;
import com.scb.phone.data.network.service.ETBService;
import com.scb.phone.data.network.service.PDFService;
import com.scb.phone.domain.entity.mwpartner.EntityMappingException;
import java.io.File;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Callable;
import o.DiG;
import okhttp3.ResponseBody;
import org.threeten.bp.OffsetDateTime;
import retrofit2.Response;

/* loaded from: classes3.dex */
public final class moR implements Jsz {
    final ETBService a;
    final IRE b;
    final SnD c;
    final hHM d;
    final File e;
    final Uju f;
    private final hHv g;
    final C16850roI h;
    private final C15610hAe i;
    private final Pvh j;
    private final C2905anS k;
    private final PDFService m;
    private final DyK n;

    /* renamed from: o, reason: collision with root package name */
    private final wTT f9217o;

    @InterfaceC13391fZD
    public moR(ETBService eTBService, PDFService pDFService, Pvh pvh, C16850roI c16850roI, IRE ire, C2905anS c2905anS, hHM hhm, C15610hAe c15610hAe, SnD snD, DyK dyK, wTT wtt, Uju uju, hHv hhv, File file) {
        C14957gcv.e(eTBService, "");
        C14957gcv.e(pDFService, "");
        C14957gcv.e(pvh, "");
        C14957gcv.e(c16850roI, "");
        C14957gcv.e(ire, "");
        C14957gcv.e(c2905anS, "");
        C14957gcv.e(hhm, "");
        C14957gcv.e(c15610hAe, "");
        C14957gcv.e(snD, "");
        C14957gcv.e(dyK, "");
        C14957gcv.e(wtt, "");
        C14957gcv.e(uju, "");
        C14957gcv.e(hhv, "");
        C14957gcv.e(file, "");
        this.a = eTBService;
        this.m = pDFService;
        this.j = pvh;
        this.h = c16850roI;
        this.b = ire;
        this.k = c2905anS;
        this.d = hhm;
        this.i = c15610hAe;
        this.c = snD;
        this.n = dyK;
        this.f9217o = wtt;
        this.f = uju;
        this.g = hhv;
        this.e = file;
    }

    @Override // o.Jsz
    public final fRY b() {
        fRY b = fRY.b(this.a.eligibilityValidation());
        C14957gcv.c(b, "");
        return b;
    }

    /* loaded from: classes3.dex */
    static final class saX extends AbstractC14961gcz implements InterfaceC14894gbR<C14866gag, C14866gag> {
        public static final saX c = new saX();

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C14866gag invoke(C14866gag c14866gag) {
            DiG.Sts sts = DiG.a;
            DiG.Sts.c();
            return C14866gag.c;
        }

        saX() {
            super(1);
        }
    }

    /* loaded from: classes3.dex */
    static final class tOB extends AbstractC14961gcz implements InterfaceC14894gbR<C14866gag, InterfaceC13169fSq<? extends SingleDataEntity<C1286ZqO>>> {
        private String a;
        private KBa b;
        private moR c;
        private String d;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ InterfaceC13169fSq<? extends SingleDataEntity<C1286ZqO>> invoke(C14866gag c14866gag) {
            return this.c.a.verifyOtp(this.a, this.d, this.b);
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        tOB(moR mor, String str, String str2, KBa kBa) {
            super(1);
            this.c = mor;
            this.a = str;
            this.d = str2;
            this.b = kBa;
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<KUd> a(String str, String str2, KBa kBa) {
        C14957gcv.e(str, "");
        C14957gcv.e(str2, "");
        C14957gcv.e(kBa, "");
        InterfaceC13189fTc interfaceC13189fTc = new InterfaceC13189fTc() { // from class: o.Lbz
            @Override // o.InterfaceC13189fTc
            public final Object d() {
                DiG.Sts sts = DiG.a;
                DiG.Sts.d("1100");
                return C14866gag.c;
            }
        };
        final tOB tob = new tOB(this, str, str2, kBa);
        fSS fss = new fSS(tob) { // from class: o.sri
            private InterfaceC14894gbR c;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.c;
                C14957gcv.e(interfaceC14894gbR, "");
                return (InterfaceC13169fSq) interfaceC14894gbR.invoke(obj);
            }

            {
                this.c = tob;
            }
        };
        final saX sax = saX.c;
        AbstractC13163fSk using = AbstractC13163fSk.using(interfaceC13189fTc, fss, new fSQ(sax) { // from class: o.CRz
            private InterfaceC14894gbR b;

            @Override // o.fSQ
            public final void c(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.b;
                C14957gcv.e(interfaceC14894gbR, "");
                interfaceC14894gbR.invoke(obj);
            }

            {
                this.b = sax;
            }
        });
        final NHB nhb = new NHB(this);
        AbstractC13163fSk<KUd> map = using.map(new fSS(nhb) { // from class: o.tft
            private InterfaceC14894gbR c;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.c;
                C14957gcv.e(interfaceC14894gbR, "");
                return (KUd) interfaceC14894gbR.invoke(obj);
            }

            {
                this.c = nhb;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    /* loaded from: classes3.dex */
    static final class NHB extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<C1286ZqO>, KUd> {
        private moR d;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ KUd invoke(SingleDataEntity<C1286ZqO> singleDataEntity) {
            SingleDataEntity<C1286ZqO> singleDataEntity2 = singleDataEntity;
            C16850roI c16850roI = this.d.h;
            C1286ZqO data = singleDataEntity2.getData();
            KUd kUd = null;
            if (data != null) {
                OffsetDateTime offsetDateTime = (OffsetDateTime) ZTC.e(new Object[]{data.m, null}, 267499366, -267499366, (int) System.currentTimeMillis());
                String str = data.b;
                if (str == null) {
                    throw new EntityMappingException("Missing some mandatory fields.");
                }
                String str2 = data.a;
                if (str2 == null) {
                    throw new EntityMappingException("Missing some mandatory fields.");
                }
                String str3 = data.e;
                if (str3 == null) {
                    throw new EntityMappingException("Missing some mandatory fields.");
                }
                String str4 = data.i;
                if (str4 == null) {
                    throw new EntityMappingException("Missing some mandatory fields.");
                }
                String str5 = data.h;
                if (str5 == null) {
                    throw new EntityMappingException("Missing some mandatory fields.");
                }
                String str6 = data.j;
                String str7 = data.c;
                String str8 = data.d;
                String str9 = data.l;
                String str10 = data.f;
                String str11 = data.f8486o;
                List<String> list = data.g;
                if (list != null) {
                    kUd = new KUd(offsetDateTime, str, str2, str3, str4, str5, str6, str7, str8, str9, str10, str11, list, 8192);
                } else {
                    throw new EntityMappingException("Missing some mandatory fields.");
                }
            }
            if (kUd == null) {
                throw new IllegalArgumentException("Required value was null.".toString());
            }
            if (C14957gcv.b((Object) singleDataEntity2.getStatus().e, (Object) "1100")) {
                kUd.i = true;
            }
            return kUd;
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        NHB(moR mor) {
            super(1);
            this.d = mor;
        }
    }

    /* loaded from: classes3.dex */
    static final class LWm extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<YFq>, BHK> {
        private moR b;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ BHK invoke(SingleDataEntity<YFq> singleDataEntity) {
            IRE ire = this.b.b;
            return IRE.c(singleDataEntity.getData());
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        LWm(moR mor) {
            super(1);
            this.b = mor;
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<BHK> a() {
        AbstractC13163fSk<SingleDataEntity<YFq>> pdfUrl = this.a.getPdfUrl();
        final LWm lWm = new LWm(this);
        AbstractC13163fSk map = pdfUrl.map(new fSS(lWm) { // from class: o.XLh
            private InterfaceC14894gbR c;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.c;
                C14957gcv.e(interfaceC14894gbR, "");
                return (BHK) interfaceC14894gbR.invoke(obj);
            }

            {
                this.c = lWm;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<String> c(String str) {
        C14957gcv.e(str, "");
        AbstractC13163fSk flatMap = this.m.downloadPdfFile(str).flatMap(new fSS(this) { // from class: o.YBw
            private moR a;

            @Override // o.fSS
            public final Object a(Object obj) {
                final moR mor = this.a;
                final Response response = (Response) obj;
                C14957gcv.e(mor, "");
                C14957gcv.e(response, "");
                AbstractC13163fSk fromCallable = AbstractC13163fSk.fromCallable(new Callable(mor, response) { // from class: o.aLq
                    private Response b;
                    private moR c;

                    @Override // java.util.concurrent.Callable
                    public final Object call() {
                        InterfaceC15149gid source;
                        InterfaceC15168giw e;
                        moR mor2 = this.c;
                        Response response2 = this.b;
                        C14957gcv.e(mor2, "");
                        C14957gcv.e(response2, "");
                        File file = new File(mor2.e, "pdf");
                        if (!file.exists()) {
                            guQ.c("%s created %s", file.getAbsolutePath(), Boolean.valueOf(file.mkdir()));
                        }
                        long currentTimeMillis = System.currentTimeMillis();
                        StringBuilder sb = new StringBuilder("marketConductPDF");
                        sb.append(currentTimeMillis);
                        sb.append(".pdf");
                        File file2 = new File(file, sb.toString());
                        ResponseBody responseBody = (ResponseBody) response2.body();
                        if (responseBody != null && (source = responseBody.source()) != null) {
                            e = C15164gis.e(file2);
                            InterfaceC15148gic c = C15160gio.c(e);
                            c.c(source);
                            c.close();
                        }
                        return file2.getAbsolutePath();
                    }

                    {
                        this.c = mor;
                        this.b = response;
                    }
                });
                C14957gcv.c(fromCallable, "");
                return fromCallable;
            }

            {
                this.a = this;
            }
        });
        C14957gcv.c(flatMap, "");
        return flatMap;
    }

    /* loaded from: classes3.dex */
    static final class jbe extends AbstractC14961gcz implements InterfaceC14894gbR<C16562pOe, Pag> {
        private moR e;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ Pag invoke(C16562pOe c16562pOe) {
            Pag d = this.e.c.d(c16562pOe);
            if (d != null) {
                return d;
            }
            throw new IllegalArgumentException("Required value was null.".toString());
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        jbe(moR mor) {
            super(1);
            this.e = mor;
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<Pag> e(C7583cr c7583cr) {
        C14957gcv.e(c7583cr, "");
        AbstractC13163fSk<C16562pOe> submitFatca = this.a.submitFatca(c7583cr);
        final jbe jbeVar = new jbe(this);
        AbstractC13163fSk map = submitFatca.map(new fSS(jbeVar) { // from class: o.eNf
            private InterfaceC14894gbR d;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.d;
                C14957gcv.e(interfaceC14894gbR, "");
                return (Pag) interfaceC14894gbR.invoke(obj);
            }

            {
                this.d = jbeVar;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    /* loaded from: classes3.dex */
    static final class HBt extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<ivT>, C0548Jeh> {
        private moR b;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C0548Jeh invoke(SingleDataEntity<ivT> singleDataEntity) {
            hHM hhm = this.b.d;
            return hHM.d(singleDataEntity.getData());
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        HBt(moR mor) {
            super(1);
            this.b = mor;
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<C0548Jeh> d() {
        AbstractC13163fSk<SingleDataEntity<ivT>> profile = this.a.getProfile();
        final HBt hBt = new HBt(this);
        AbstractC13163fSk map = profile.map(new fSS(hBt) { // from class: o.UNl
            private InterfaceC14894gbR b;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.b;
                C14957gcv.e(interfaceC14894gbR, "");
                return (C0548Jeh) interfaceC14894gbR.invoke(obj);
            }

            {
                this.b = hBt;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<C17784zhb> b(Bmg bmg) {
        C14957gcv.e(bmg, "");
        DiG.Sts sts = DiG.a;
        DiG.Sts.d("3013");
        AbstractC13163fSk<SingleDataEntity<C17732zLw>> verifyIdentity = this.a.verifyIdentity(bmg);
        final ojQ ojq = new ojQ(this);
        AbstractC13163fSk<C17784zhb> doFinally = verifyIdentity.map(new fSS(ojq) { // from class: o.DAf
            private InterfaceC14894gbR e;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.e;
                C14957gcv.e(interfaceC14894gbR, "");
                return (C17784zhb) interfaceC14894gbR.invoke(obj);
            }

            {
                this.e = ojq;
            }
        }).doFinally(new fSP() { // from class: o.QLm
            @Override // o.fSP
            public final void c() {
                DiG.Sts sts2 = DiG.a;
                DiG.Sts.c();
            }
        });
        C14957gcv.c(doFinally, "");
        return doFinally;
    }

    /* loaded from: classes3.dex */
    static final class ojQ extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<C17732zLw>, C17784zhb> {
        private moR c;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C17784zhb invoke(SingleDataEntity<C17732zLw> singleDataEntity) {
            SingleDataEntity<C17732zLw> singleDataEntity2 = singleDataEntity;
            Uju uju = this.c.f;
            C14957gcv.c(singleDataEntity2, "");
            return Uju.b(singleDataEntity2);
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        ojQ(moR mor) {
            super(1);
            this.c = mor;
        }
    }

    /* loaded from: classes3.dex */
    static final class ZqN extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<C15669hct>, C17167uTB> {
        private moR b;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C17167uTB invoke(SingleDataEntity<C15669hct> singleDataEntity) {
            SnD snD = this.b.c;
            C15669hct data = singleDataEntity.getData();
            GuO guO = null;
            if (data == null) {
                return null;
            }
            C17167uTB c17167uTB = new C17167uTB();
            MGm b = SnD.b(data.e);
            MGm b2 = SnD.b(data.c);
            ioO ioo = data.b;
            if (ioo != null) {
                guO = new GuO();
                guO.d = ioo.d;
                guO.c = ioo.a;
                guO.e = ioo.e;
                guO.b = ioo.b.a;
            }
            rva rvaVar = data.a;
            int i = rvaVar != null ? rvaVar.c : 0;
            c17167uTB.b = b;
            c17167uTB.c = i;
            c17167uTB.j = b2;
            c17167uTB.a = guO;
            c17167uTB.d = data.d;
            return c17167uTB;
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        ZqN(moR mor) {
            super(1);
            this.b = mor;
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<C17167uTB> b(qFG qfg) {
        C14957gcv.e(qfg, "");
        AbstractC13163fSk<SingleDataEntity<C15669hct>> verifyOpenAccount = this.a.verifyOpenAccount(qfg);
        final ZqN zqN = new ZqN(this);
        AbstractC13163fSk map = verifyOpenAccount.map(new fSS(zqN) { // from class: o.fEA
            private InterfaceC14894gbR b;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.b;
                C14957gcv.e(interfaceC14894gbR, "");
                return (C17167uTB) interfaceC14894gbR.invoke(obj);
            }

            {
                this.b = zqN;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    /* loaded from: classes3.dex */
    static final class Sts extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<irD>, MkB> {
        public static final Sts d = new Sts();

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ MkB invoke(SingleDataEntity<irD> singleDataEntity) {
            SingleDataEntity<irD> singleDataEntity2 = singleDataEntity;
            String str = "";
            C14957gcv.e(singleDataEntity2, "");
            irD data = singleDataEntity2.getData();
            String str2 = data.a;
            if (str2 == null) {
                throw new EntityMappingException("Some mandatory is missing.");
            }
            String str3 = data.b;
            if (str3 == null) {
                throw new EntityMappingException("Some mandatory is missing.");
            }
            String str4 = data.e;
            if (str4 == null) {
                throw new EntityMappingException("Some mandatory is missing.");
            }
            String str5 = data.d;
            if (str5 == null) {
                throw new EntityMappingException("Some mandatory is missing.");
            }
            List<OeN> list = data.c;
            if (list == null) {
                throw new EntityMappingException("Some mandatory is missing.");
            }
            List<OeN> list2 = list;
            C14957gcv.e(list2, "");
            ArrayList arrayList = new ArrayList(list2 instanceof Collection ? list2.size() : 10);
            Iterator it = list2.iterator();
            while (it.hasNext()) {
                OeN oeN = (OeN) it.next();
                String str6 = oeN.g;
                String str7 = str6 == null ? str : str6;
                String str8 = oeN.f;
                if (str8 == null) {
                    throw new EntityMappingException("Some mandatory is missing.");
                }
                Integer num = oeN.h;
                if (num == null) {
                    throw new EntityMappingException("Some mandatory is missing.");
                }
                int intValue = num.intValue();
                String str9 = oeN.d;
                Integer num2 = oeN.e;
                if (num2 == null) {
                    throw new EntityMappingException("Some mandatory is missing.");
                }
                int intValue2 = num2.intValue();
                Integer num3 = oeN.b;
                if (num3 == null) {
                    throw new EntityMappingException("Some mandatory is missing.");
                }
                int intValue3 = num3.intValue();
                Integer num4 = oeN.c;
                if (num4 == null) {
                    throw new EntityMappingException("Some mandatory is missing.");
                }
                int intValue4 = num4.intValue();
                List<WKU> list3 = oeN.a;
                if (list3 == null) {
                    throw new EntityMappingException("Some mandatory is missing.");
                }
                List<WKU> list4 = list3;
                C14957gcv.e(list4, str);
                ArrayList arrayList2 = new ArrayList(list4 instanceof Collection ? list4.size() : 10);
                for (WKU wku : list4) {
                    String str10 = wku.a;
                    if (str10 == null) {
                        throw new EntityMappingException("Some mandatory is missing.");
                    }
                    List<C16603pew> list5 = wku.e;
                    if (list5 == null) {
                        throw new EntityMappingException("Some mandatory is missing.");
                    }
                    List<C16603pew> list6 = list5;
                    Iterator it2 = it;
                    C14957gcv.e(list6, str);
                    String str11 = str;
                    ArrayList arrayList3 = new ArrayList(list6 instanceof Collection ? list6.size() : 10);
                    for (Iterator it3 = list6.iterator(); it3.hasNext(); it3 = it3) {
                        String str12 = ((C16603pew) it3.next()).a;
                        if (str12 == null) {
                            throw new EntityMappingException("Some mandatory is missing.");
                        }
                        arrayList3.add(new mCN(str12));
                    }
                    arrayList2.add(new Ocq(str10, arrayList3));
                    it = it2;
                    str = str11;
                }
                arrayList.add(new C0272CuS(str7, str8, intValue, str9, intValue2, intValue3, intValue4, arrayList2));
                it = it;
                str = str;
            }
            return new MkB(str2, str3, str4, str5, arrayList);
        }

        Sts() {
            super(1);
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<MkB> d(String str, String str2, String str3, String str4) {
        C14957gcv.e(str, "");
        C14957gcv.e(str4, "");
        AbstractC13163fSk<SingleDataEntity<irD>> openAccountProductDetail = this.a.getOpenAccountProductDetail(str, str2, str3, str4);
        final Sts sts = Sts.d;
        AbstractC13163fSk map = openAccountProductDetail.map(new fSS(sts) { // from class: o.ReF
            private InterfaceC14894gbR c;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.c;
                C14957gcv.e(interfaceC14894gbR, "");
                return (MkB) interfaceC14894gbR.invoke(obj);
            }

            {
                this.c = sts;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    /* loaded from: classes3.dex */
    static final class RVV extends AbstractC14961gcz implements InterfaceC14894gbR<SingleDataEntity<lIP>, C16724qiz> {
        public static final RVV e = new RVV();

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C16724qiz invoke(SingleDataEntity<lIP> singleDataEntity) {
            SingleDataEntity<lIP> singleDataEntity2 = singleDataEntity;
            C14957gcv.e(singleDataEntity2, "");
            lIP data = singleDataEntity2.getData();
            String str = data.a;
            if (str != null) {
                return new C16724qiz(str, data.e);
            }
            throw new IllegalArgumentException("applicationId is mandatory must not be null".toString());
        }

        RVV() {
            super(1);
        }
    }

    @Override // o.Jsz
    public final AbstractC13163fSk<C16724qiz> c(XMt xMt) {
        C14957gcv.e(xMt, "");
        AbstractC13163fSk<SingleDataEntity<lIP>> eligibilityOpenAccountValidation = this.a.eligibilityOpenAccountValidation(xMt);
        final RVV rvv = RVV.e;
        AbstractC13163fSk map = eligibilityOpenAccountValidation.map(new fSS(rvv) { // from class: o.OZQ
            private InterfaceC14894gbR e;

            @Override // o.fSS
            public final Object a(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.e;
                C14957gcv.e(interfaceC14894gbR, "");
                return (C16724qiz) interfaceC14894gbR.invoke(obj);
            }

            {
                this.e = rvv;
            }
        });
        C14957gcv.c(map, "");
        return map;
    }

    /* loaded from: classes3.dex */
    public static final class IeS {
        private IeS() {
        }

        public /* synthetic */ IeS(byte b) {
            this();
        }
    }

    static {
        new IeS((byte) 0);
    }
}