package d.f.a.o2;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.net.Uri;
import android.os.Handler;
import android.os.Looper;
import android.os.Process;
import android.util.Log;
import com.seewo.sdk.OpenSDK;
import com.seewo.sdk.interfaces.OnSdkConnected;
import g.h0.c.l;
import g.h0.c.m;
import g.i;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.concurrent.CountDownLatch;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

/* JADX INFO: compiled from: UdiHandlerService.kt */
/* JADX INFO: loaded from: classes.dex */
@i
public final class h {
    public static final h a = null;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final Uri f2661b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final Context f2662c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final g.g f2663d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public CountDownLatch f2664e;

    /* JADX INFO: compiled from: UdiHandlerService.kt */
    @i
    public static final class a extends m implements g.h0.b.a<Handler> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public static final a f2665b = new a();

        public a() {
            super(0);
        }

        @Override // g.h0.b.a
        public Handler invoke() {
            return new Handler(Looper.getMainLooper());
        }
    }

    static {
        StringBuilder sbB = d.b.a.a.a.B("content://com.ifpdos.service.log.LogProvider.Provider?pid=");
        sbB.append(Process.myPid());
        f2661b = Uri.parse(sbB.toString());
    }

    public h(Context context) {
        l.f(context, "context");
        this.f2662c = context;
        this.f2663d = f.a.y.a.v0(a.f2665b);
        this.f2664e = new CountDownLatch(1);
        if (OpenSDK.getInstance().isConnected()) {
            return;
        }
        OpenSDK.getInstance().connect(context, new OnSdkConnected() { // from class: d.f.a.o2.d
            @Override // com.seewo.sdk.interfaces.OnSdkConnected
            public final void onSdkConnected() {
                h hVar = this.a;
                l.f(hVar, "this$0");
                Log.d("UdiHandlerService", "connect to opensdk success,notify opensdkLock");
                CountDownLatch countDownLatch = hVar.f2664e;
                if (countDownLatch != null) {
                    countDownLatch.countDown();
                }
                hVar.f2664e = null;
            }
        });
    }

    public static final void a(Context context, File file) {
        l.f(context, "context");
        l.f(file, "file");
        Cursor cursorQuery = context.getContentResolver().query(f2661b, new String[]{"LogFiles"}, null, null);
        if (cursorQuery == null) {
            return;
        }
        if (!file.getParentFile().exists()) {
            file.getParentFile().mkdirs();
        }
        ZipOutputStream zipOutputStream = new ZipOutputStream(new FileOutputStream(file));
        while (cursorQuery.moveToNext()) {
            try {
                InputStream inputStreamOpenInputStream = context.getContentResolver().openInputStream(Uri.parse(cursorQuery.getString(1)));
                if (inputStreamOpenInputStream != null) {
                    File file2 = new File(cursorQuery.getString(0));
                    Log.d("UdiHandlerService", "export " + file2 + " to " + file);
                    try {
                        zipOutputStream.putNextEntry(new ZipEntry(cursorQuery.getString(2) + '/' + file2.getName()));
                        Class.forName("android.os.FileUtils").getMethod("copy", InputStream.class, OutputStream.class).invoke(null, inputStreamOpenInputStream, zipOutputStream);
                        zipOutputStream.closeEntry();
                        f.a.y.a.B(inputStreamOpenInputStream, null);
                    } finally {
                    }
                }
            } finally {
            }
        }
        f.a.y.a.B(zipOutputStream, null);
        ContentValues contentValues = new ContentValues();
        contentValues.put("resume", Boolean.TRUE);
        context.getContentResolver().update(f2661b, contentValues, "", null);
        d.i.c.a.c("sync", false);
    }
}