package com.bytedance.sdk.openadsdk.core.jnr;

import android.content.Context;
import android.os.SystemClock;
import android.text.TextUtils;
import com.bytedance.sdk.component.utils.jnr;
import com.bytedance.sdk.component.utils.wey;
import com.bytedance.sdk.component.utils.wsy;
import com.bytedance.sdk.openadsdk.CacheDirFactory;
import com.bytedance.sdk.openadsdk.core.fhx.lb.lb;
import com.bytedance.sdk.openadsdk.core.gof;
import com.bytedance.sdk.openadsdk.core.model.lse;
import com.bytedance.sdk.openadsdk.irt.ro;
import com.bytedance.sdk.openadsdk.irt.yz;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;
import org.json.JSONException;
import org.json.JSONObject;

/* JADX INFO: loaded from: classes2.dex */
public class fm {
    private final List<String> fm = new CopyOnWriteArrayList();
    private final lb ro = new lb(5, 5, true);

    /* JADX INFO: renamed from: lb, reason: collision with root package name */
    private final ConcurrentHashMap<String, Long> f7140lb = new ConcurrentHashMap<>();

    /* JADX INFO: renamed from: com.bytedance.sdk.openadsdk.core.jnr.fm$fm, reason: collision with other inner class name */
    public static class C0074fm {
        private static final fm fm = new fm();
    }

    private boolean lb(String str) {
        return !this.fm.contains(str);
    }

    public File ro(String str) {
        String strFm = jnr.fm(str);
        if (strFm == null) {
            return null;
        }
        File fileFm = fm(gof.fm());
        fileFm.getAbsoluteFile();
        return new File(fileFm, strFm);
    }

    public void lb() {
        yz.fm("music_preload_start", false, new ro() { // from class: com.bytedance.sdk.openadsdk.core.jnr.fm.2
            @Override // com.bytedance.sdk.openadsdk.irt.ro
            public com.bytedance.sdk.openadsdk.irt.fm.lb fm() throws Exception {
                com.bytedance.sdk.openadsdk.irt.fm.yz yzVarFm = com.bytedance.sdk.openadsdk.irt.fm.yz.ro().fm("music_preload_start");
                yzVarFm.fm();
                return yzVarFm;
            }
        });
    }

    public static fm fm() {
        return C0074fm.fm;
    }

    public void fm(com.bytedance.sdk.openadsdk.core.model.fm fmVar) {
        List<lse> listJnr = fmVar.jnr();
        if (listJnr == null || listJnr.size() == 0) {
            return;
        }
        for (int i10 = 0; i10 < listJnr.size(); i10++) {
            lse lseVar = listJnr.get(i10);
            if (lseVar != null) {
                fm(lseVar);
            }
        }
    }

    public void ro() {
        File fileFm = fm(gof.fm());
        fileFm.getAbsolutePath();
        try {
            this.ro.fm(fileFm);
        } catch (IOException e10) {
            wey.fm("MusicCacheManager", "trimFileCache fail", e10);
        }
    }

    public InputStream fm(String str) {
        File fileRo = ro(str);
        if (fileRo != null && fm(fileRo)) {
            try {
                return new FileInputStream(fileRo);
            } catch (Exception e10) {
                wey.lb("MusicCacheManager", e10.getMessage());
            }
        }
        return null;
    }

    private void fm(lse lseVar) {
        lse.fm fmVarZzn;
        String strEf;
        if (lseVar == null || (fmVarZzn = lseVar.zzn()) == null || (strEf = fmVarZzn.ef()) == null || !strEf.contains("music_url")) {
            return;
        }
        lb();
        String strRo = fmVarZzn.ro();
        if (TextUtils.isEmpty(strRo)) {
            try {
                new JSONObject().put("result", 0);
            } catch (JSONException e10) {
                wey.lb("MusicCacheManager", e10.getMessage());
            }
            fm(0, -1L, 10001, "music url string is null");
            return;
        }
        File fileRo = ro(strRo);
        if (fileRo == null) {
            return;
        }
        fileRo.getPath();
        if (fm(fileRo)) {
            fm(2, -1L, -1, null);
        } else {
            fm(lseVar, strRo, fileRo);
        }
    }

    private File fm(Context context) {
        return wsy.ro(context, new File(CacheDirFactory.getRootDir()).getName() + "/music");
    }

    private boolean fm(File file) {
        return file.exists() && file.length() != 0;
    }

    private void fm(lse lseVar, String str, File file) {
        if (lb(str)) {
            this.f7140lb.put(str, Long.valueOf(SystemClock.elapsedRealtime()));
            com.bytedance.sdk.component.wsy.ro.fm fmVarYz = com.bytedance.sdk.openadsdk.wey.ro.ro().lb().yz();
            fmVarYz.lb(str);
            fmVarYz.fm(file.getParent(), file.getName());
            fmVarYz.yz(str);
            this.fm.add(str);
            fmVarYz.ro(new com.bytedance.sdk.component.wsy.fm.fm() { // from class: com.bytedance.sdk.openadsdk.core.jnr.fm.1
                @Override // com.bytedance.sdk.component.wsy.fm.fm
                public void fm(com.bytedance.sdk.component.wsy.ro.lb lbVar, com.bytedance.sdk.component.wsy.ro roVar) {
                    roVar.lb();
                    roVar.fm();
                    String strYz = lbVar.yz();
                    Long l10 = (Long) fm.this.f7140lb.get(strYz);
                    if (roVar.ajl() && roVar.jnr() != null && roVar.jnr().exists()) {
                        roVar.jnr();
                        if (l10 != null) {
                            fm.this.f7140lb.remove(strYz);
                            fm.this.fm(1, SystemClock.elapsedRealtime() - l10.longValue(), -1, null);
                        }
                        try {
                            wsy.ro(roVar.jnr());
                        } catch (IOException e10) {
                            wey.lb("MusicCacheManager", e10.getMessage());
                        }
                    }
                    if (roVar.ajl() || l10 == null) {
                        return;
                    }
                    fm.this.fm(0, SystemClock.elapsedRealtime() - l10.longValue(), -2, "http response status code isn't 200");
                }

                @Override // com.bytedance.sdk.component.wsy.fm.fm
                public void fm(com.bytedance.sdk.component.wsy.ro.lb lbVar, IOException iOException) {
                    Long l10 = (Long) fm.this.f7140lb.get(lbVar.yz());
                    if (l10 != null) {
                        fm.this.fm(0, SystemClock.elapsedRealtime() - l10.longValue(), -2, "http response status code isn't 200");
                    }
                }
            });
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void fm(final int i10, final long j10, final int i11, final String str) {
        yz.fm("music_preload_finish", false, new ro() { // from class: com.bytedance.sdk.openadsdk.core.jnr.fm.3
            @Override // com.bytedance.sdk.openadsdk.irt.ro
            public com.bytedance.sdk.openadsdk.irt.fm.lb fm() throws Exception {
                JSONObject jSONObject = new JSONObject();
                jSONObject.put("result", i10);
                long j11 = j10;
                if (j11 != -1) {
                    jSONObject.put("load_duration", j11);
                }
                com.bytedance.sdk.openadsdk.irt.fm.yz yzVarRo = com.bytedance.sdk.openadsdk.irt.fm.yz.ro().fm("music_preload_finish").ro(jSONObject.toString());
                if (!TextUtils.isEmpty(str)) {
                    yzVarRo.ro(i11);
                    yzVarRo.ajl(str);
                }
                yzVarRo.fm();
                return yzVarRo;
            }
        });
    }

    public void fm(final boolean z10) {
        yz.fm("music_cache", false, new ro() { // from class: com.bytedance.sdk.openadsdk.core.jnr.fm.4
            @Override // com.bytedance.sdk.openadsdk.irt.ro
            public com.bytedance.sdk.openadsdk.irt.fm.lb fm() throws Exception {
                JSONObject jSONObject = new JSONObject();
                jSONObject.put("result", z10);
                com.bytedance.sdk.openadsdk.irt.fm.yz yzVarRo = com.bytedance.sdk.openadsdk.irt.fm.yz.ro().fm("music_cache").ro(jSONObject.toString());
                yzVarRo.fm();
                return yzVarRo;
            }
        });
    }
}