Petal Maps v4.7.0.310001 - TimeBarrierBroadcastReceiver.java 源代码

package com.huawei.maps.app.common.location;

import android.content.Context;
import android.content.Intent;
import com.huawei.hms.kit.awareness.barrier.BarrierStatus;
import com.huawei.maps.app.common.location.TimeBarrierBroadcastReceiver;
import com.huawei.maps.businessbase.manager.AbstractMapUIController;
import com.huawei.maps.businessbase.manager.location.a;
import com.huawei.maps.businessbase.report.b;
import com.huawei.secure.android.common.intent.SafeBroadcastReceiver;
import defpackage.hm4;
import defpackage.o41;
import defpackage.pw9;
import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.functions.Action;
import io.reactivex.rxjava3.schedulers.Schedulers;
import java.util.concurrent.TimeUnit;

public class TimeBarrierBroadcastReceiver extends SafeBroadcastReceiver {
    public static void b(Intent intent) throws Throwable {
        xr4.Q().F2("5");
        b.e().f();
        pw9.r().m(BarrierStatus.extract(intent).getBarrierLabel());
    }

    public void onReceiveMsg(Context context, final Intent intent) {
        hm4.p("TimeBarrierBroadcastReceiver", "onReceiveMsg");
        xr4.Q().F2("5");
        if (intent == null || context == null) {
            hm4.p("TimeBarrierBroadcastReceiver", "onReceiveMsg params null, interrupt ");
        } else {
            if (!o41.b().isAppBackground()) {
                hm4.p("TimeBarrierBroadcastReceiver", "is app front ground, interrupt Barrier Time Awakening");
                return;
            }
            if (!a.p()) {
                AbstractMapUIController.getInstance().startServicePermission("pushTokenUploadOnLocationAwakeningBroadcastReceiver");
            }
            Observable.empty().delay(15L, TimeUnit.SECONDS).subscribeOn(Schedulers.io()).observeOn(Schedulers.io()).doOnComplete(new Action() {
                public final void run() {
                    TimeBarrierBroadcastReceiver.b(intent);
                }
            }).subscribe();
        }
    }
}