大漢易經書院.apk(点击下载) / MiPushClient.java


package com.xiaomi.mipush.sdk;

import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.SharedPreferences;
import android.content.pm.PackageInfo;
import android.content.pm.ServiceInfo;
import android.os.Build;
import android.text.TextUtils;
import com.huawei.hms.push.constant.RemoteMessageConst;
import com.umeng.analytics.pro.d;
import com.xiaomi.channel.commonutils.logger.b;
import com.xiaomi.clientreport.data.Config;
import com.xiaomi.clientreport.manager.ClientReportClient;
import com.xiaomi.clientreport.manager.a;
import com.xiaomi.mipush.sdk.MiTinyDataClient;
import com.xiaomi.push.Cdo;
import com.xiaomi.push.al;
import com.xiaomi.push.ba;
import com.xiaomi.push.bp;
import com.xiaomi.push.dd;
import com.xiaomi.push.dn;
import com.xiaomi.push.em;
import com.xiaomi.push.en;
import com.xiaomi.push.eo;
import com.xiaomi.push.ez;
import com.xiaomi.push.g;
import com.xiaomi.push.hj;
import com.xiaomi.push.hn;
import com.xiaomi.push.ho;
import com.xiaomi.push.ht;
import com.xiaomi.push.hw;
import com.xiaomi.push.hx;
import com.xiaomi.push.i;
import com.xiaomi.push.id;
import com.xiaomi.push.ii;
import com.xiaomi.push.ij;
import com.xiaomi.push.in;
import com.xiaomi.push.ip;
import com.xiaomi.push.ir;
import com.xiaomi.push.iu;
import com.xiaomi.push.l;
import com.xiaomi.push.n;
import com.xiaomi.push.o;
import com.xiaomi.push.service.ax;
import com.xiaomi.push.service.receivers.NetworkStatusReceiver;
import com.xiaomi.push.t;
import com.xiaomi.push.v;
import java.lang.Thread;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.TimeZone;

public abstract class MiPushClient {
    public static final String COMMAND_REGISTER = "register";
    public static final String COMMAND_SET_ACCEPT_TIME = "accept-time";
    public static final String COMMAND_SET_ACCOUNT = "set-account";
    public static final String COMMAND_SET_ALIAS = "set-alias";
    public static final String COMMAND_SUBSCRIBE_TOPIC = "subscribe-topic";
    public static final String COMMAND_UNREGISTER = "unregister";
    public static final String COMMAND_UNSET_ACCOUNT = "unset-account";
    public static final String COMMAND_UNSET_ALIAS = "unset-alias";
    public static final String COMMAND_UNSUBSCRIBE_TOPIC = "unsubscibe-topic";
    public static final String PREF_EXTRA = "mipush_extra";
    private static Context sContext;
    private static long sCurMsgId = System.currentTimeMillis();

    public static class CodeResult {
        private long resultCode = -1;

        public long getResultCode() {
            return this.resultCode;
        }

        /* access modifiers changed from: protected */
        public void setResultCode(long j) {
            this.resultCode = j;
        }
    }

    public interface ICallbackResult<R> {
        void onResult(R r);
    }

    @Deprecated
    public static abstract class MiPushClientCallback {
        private String category;

        /* access modifiers changed from: protected */
        public String getCategory() {
            return this.category;
        }

        public void onCommandResult(String str, long j, String str2, List<String> list) {
        }

        public void onInitializeResult(long j, String str, String str2) {
        }

        public void onReceiveMessage(MiPushMessage miPushMessage) {
        }

        public void onReceiveMessage(String str, String str2, String str3, boolean z) {
        }

        public void onSubscribeResult(long j, String str, String str2) {
        }

        public void onUnsubscribeResult(long j, String str, String str2) {
        }

        /* access modifiers changed from: protected */
        public void setCategory(String str) {
            this.category = str;
        }
    }

    public static class TokenResult {
        private long resultCode = -1;
        private String token = null;

        public long getResultCode() {
            return this.resultCode;
        }

        public String getToken() {
            return this.token;
        }

        /* access modifiers changed from: protected */
        public void setResultCode(long j) {
            this.resultCode = j;
        }

        /* access modifiers changed from: protected */
        public void setToken(String str) {
            this.token = str;
        }
    }

    public interface UPSRegisterCallBack extends ICallbackResult<TokenResult> {
    }

    public interface UPSTurnCallBack extends ICallbackResult<CodeResult> {
    }

    public interface UPSUnRegisterCallBack extends ICallbackResult<TokenResult> {
    }

    private static boolean acceptTimeSet(Context context, String str, String str2) {
        String acceptTime = getAcceptTime(context);
        return TextUtils.equals(acceptTime, str + Constants.ACCEPT_TIME_SEPARATOR_SP + str2);
    }

    public static long accountSetTime(Context context, String str) {
        SharedPreferences sharedPreferences = context.getSharedPreferences("mipush_extra", 0);
        return sharedPreferences.getLong("account_" + str, -1);
    }

    static synchronized void addAcceptTime(Context context, String str, String str2) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.putString(Constants.EXTRA_KEY_ACCEPT_TIME, str + Constants.ACCEPT_TIME_SEPARATOR_SP + str2);
            t.a(edit);
        }
    }

    static synchronized void addAccount(Context context, String str) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.putLong("account_" + str, System.currentTimeMillis()).commit();
        }
    }

    static synchronized void addAlias(Context context, String str) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.putLong("alias_" + str, System.currentTimeMillis()).commit();
        }
    }

    private static void addPullNotificationTime(Context context) {
        SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
        edit.putLong("last_pull_notification", System.currentTimeMillis());
        t.a(edit);
    }

    private static void addRegRequestTime(Context context) {
        SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
        edit.putLong("last_reg_request", System.currentTimeMillis());
        t.a(edit);
    }

    static synchronized void addTopic(Context context, String str) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.putLong("topic_" + str, System.currentTimeMillis()).commit();
        }
    }

    public static long aliasSetTime(Context context, String str) {
        SharedPreferences sharedPreferences = context.getSharedPreferences("mipush_extra", 0);
        return sharedPreferences.getLong("alias_" + str, -1);
    }

    public static void awakeApps(final Context context, final String[] strArr) {
        al.a(context).a(new Runnable() {
            /* class com.xiaomi.mipush.sdk.MiPushClient.AnonymousClass4 */

            public void run() {
                PackageInfo packageInfo;
                try {
                    String[] strArr = strArr;
                    for (String str : strArr) {
                        if (!TextUtils.isEmpty(str) && (packageInfo = context.getPackageManager().getPackageInfo(str, 4)) != null) {
                            MiPushClient.awakePushServiceByPackageInfo(context, packageInfo);
                        }
                    }
                } catch (Throwable th) {
                    b.a(th);
                }
            }
        });
    }

    /* access modifiers changed from: private */
    public static void awakePushServiceByPackageInfo(Context context, PackageInfo packageInfo) {
        ServiceInfo[] serviceInfoArr = packageInfo.services;
        if (serviceInfoArr != null) {
            for (ServiceInfo serviceInfo : serviceInfoArr) {
                if (serviceInfo.exported && serviceInfo.enabled && "com.xiaomi.mipush.sdk.PushMessageHandler".equals(serviceInfo.name) && !context.getPackageName().equals(serviceInfo.packageName)) {
                    try {
                        Thread.sleep(((long) ((Math.random() * 2.0d) + 1.0d)) * 1000);
                        Intent intent = new Intent();
                        intent.setClassName(serviceInfo.packageName, serviceInfo.name);
                        intent.setAction("com.xiaomi.mipush.sdk.WAKEUP");
                        intent.putExtra("waker_pkgname", context.getPackageName());
                        PushMessageHandler.a(context, intent);
                        return;
                    } catch (Throwable unused) {
                        return;
                    }
                }
            }
        }
    }

    private static void checkNotNull(Object obj, String str) {
        if (obj == null) {
            throw new IllegalArgumentException("param " + str + " is not nullable");
        }
    }

    protected static void clearExtras(Context context) {
        SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
        edit.clear();
        edit.commit();
    }

    private static void clearExtrasForInitialize(Context context) {
        SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
        Iterator<String> it = getAllAlias(context).iterator();
        while (it.hasNext()) {
            edit.remove("alias_" + it.next());
        }
        Iterator<String> it2 = getAllUserAccount(context).iterator();
        while (it2.hasNext()) {
            edit.remove("account_" + it2.next());
        }
        Iterator<String> it3 = getAllTopic(context).iterator();
        while (it3.hasNext()) {
            edit.remove("topic_" + it3.next());
        }
        edit.remove(Constants.EXTRA_KEY_ACCEPT_TIME);
        edit.commit();
    }

    public static void clearLocalNotificationType(Context context) {
        ao.a(context).m9085e();
    }

    public static void clearNotification(Context context) {
        ao.a(context).a(-1);
    }

    public static void clearNotification(Context context, int i) {
        ao.a(context).a(i);
    }

    public static void clearNotification(Context context, String str, String str2) {
        ao.a(context).a(str, str2);
    }

    public static void disablePush(Context context) {
        ao.a(context).a(true);
    }

    public static void enablePush(Context context) {
        ao.a(context).a(false);
    }

    protected static String getAcceptTime(Context context) {
        return context.getSharedPreferences("mipush_extra", 0).getString(Constants.EXTRA_KEY_ACCEPT_TIME, "00:00-23:59");
    }

    public static List<String> getAllAlias(Context context) {
        ArrayList arrayList = new ArrayList();
        for (String str : context.getSharedPreferences("mipush_extra", 0).getAll().keySet()) {
            if (str.startsWith("alias_")) {
                arrayList.add(str.substring(6));
            }
        }
        return arrayList;
    }

    public static List<String> getAllTopic(Context context) {
        ArrayList arrayList = new ArrayList();
        for (String str : context.getSharedPreferences("mipush_extra", 0).getAll().keySet()) {
            if (str.startsWith("topic_") && !str.contains("**ALL**")) {
                arrayList.add(str.substring(6));
            }
        }
        return arrayList;
    }

    public static List<String> getAllUserAccount(Context context) {
        ArrayList arrayList = new ArrayList();
        for (String str : context.getSharedPreferences("mipush_extra", 0).getAll().keySet()) {
            if (str.startsWith("account_")) {
                arrayList.add(str.substring(8));
            }
        }
        return arrayList;
    }

    public static String getAppRegion(Context context) {
        if (b.m9086a(context).m9095c()) {
            return b.m9086a(context).f();
        }
        return null;
    }

    private static boolean getDefaultSwitch() {
        return l.m9612b();
    }

    protected static boolean getOpenFCMPush(Context context) {
        checkNotNull(context, d.R);
        return f.a(context).b(e.ASSEMBLE_PUSH_FCM);
    }

    protected static boolean getOpenHmsPush(Context context) {
        checkNotNull(context, d.R);
        return f.a(context).b(e.ASSEMBLE_PUSH_HUAWEI);
    }

    protected static boolean getOpenOPPOPush(Context context) {
        checkNotNull(context, d.R);
        return f.a(context).b(e.ASSEMBLE_PUSH_COS);
    }

    protected static boolean getOpenVIVOPush(Context context) {
        return f.a(context).b(e.ASSEMBLE_PUSH_FTOS);
    }

    public static String getRegId(Context context) {
        if (b.m9086a(context).m9095c()) {
            return b.m9086a(context).m9094c();
        }
        return null;
    }

    private static void initEventPerfLogic(final Context context) {
        eo.a(new eo.a() {
            /* class com.xiaomi.mipush.sdk.MiPushClient.AnonymousClass5 */

            @Override // com.xiaomi.push.eo.a
            public void uploader(Context context, hn hnVar) {
                MiTinyDataClient.upload(context, hnVar);
            }
        });
        Config a = eo.a(context);
        a.a(context).a("4_5_0");
        ClientReportClient.init(context, a, new em(context), new en(context));
        a.a(context);
        t.a(context, a);
        ax.a(context).a(new ax.a(100, "perf event job update") {
            /* class com.xiaomi.mipush.sdk.MiPushClient.AnonymousClass6 */

            /* access modifiers changed from: protected */
            @Override // com.xiaomi.push.service.ax.a
            public void onCallback() {
                eo.m9317a(context);
            }
        });
    }

    @Deprecated
    public static void initialize(Context context, String str, String str2, MiPushClientCallback miPushClientCallback) {
        initialize(context, str, str2, miPushClientCallback, null, null);
    }

    /* access modifiers changed from: private */
    public static void initialize(Context context, String str, String str2, MiPushClientCallback miPushClientCallback, String str3, ICallbackResult iCallbackResult) {
        try {
            b.a(context.getApplicationContext());
            b.e("sdk_version = 4_5_0");
            ba.a(context).m9145a();
            dd.a(context);
            if (miPushClientCallback != null) {
                PushMessageHandler.a(miPushClientCallback);
            }
            if (iCallbackResult != null) {
                PushMessageHandler.a(iCallbackResult);
            }
            if (v.m9753a(sContext)) {
                v.a(sContext);
            }
            boolean z = b.m9086a(sContext).a() != Constants.a();
            if (z || shouldSendRegRequest(sContext)) {
                if (z || !b.m9086a(sContext).a(str, str2) || b.m9086a(sContext).m9098f()) {
                    String a = bp.a(6);
                    b.m9086a(sContext).m9088a();
                    b.m9086a(sContext).a(Constants.a());
                    b.m9086a(sContext).a(str, str2, a);
                    MiTinyDataClient.a.a().b(MiTinyDataClient.PENDING_REASON_APPID);
                    clearExtras(sContext);
                    clearNotification(context);
                    ij ijVar = new ij();
                    ijVar.a(com.xiaomi.push.service.ba.a());
                    ijVar.b(str);
                    ijVar.e(str2);
                    ijVar.d(sContext.getPackageName());
                    ijVar.f(a);
                    ijVar.c(g.m9381a(sContext, sContext.getPackageName()));
                    ijVar.b(g.a(sContext, sContext.getPackageName()));
                    ijVar.h("4_5_0");
                    ijVar.a(40050);
                    ijVar.a(hx.Init);
                    if (!TextUtils.isEmpty(str3)) {
                        ijVar.g(str3);
                    }
                    if (!l.m9614d()) {
                        String g = i.g(sContext);
                        if (!TextUtils.isEmpty(g)) {
                            ijVar.i(bp.a(g) + Constants.ACCEPT_TIME_SEPARATOR_SP + i.j(sContext));
                        }
                    }
                    int a2 = i.a();
                    if (a2 >= 0) {
                        ijVar.c(a2);
                    }
                    ao.a(sContext).a(ijVar, z);
                    sContext.getSharedPreferences("mipush_extra", 4).getBoolean("mipush_registed", true);
                } else {
                    if (1 == PushMessageHelper.getPushMode(sContext)) {
                        checkNotNull(miPushClientCallback, "callback");
                        miPushClientCallback.onInitializeResult(0, null, b.m9086a(sContext).m9094c());
                    } else {
                        ArrayList arrayList = new ArrayList();
                        arrayList.add(b.m9086a(sContext).m9094c());
                        PushMessageHelper.sendCommandMessageBroadcast(sContext, PushMessageHelper.generateCommandMessage(ez.COMMAND_REGISTER.f6970a, arrayList, 0, null, null));
                    }
                    ao.a(sContext).m9077a();
                    if (b.m9086a(sContext).m9090a()) {
                        ii iiVar = new ii();
                        iiVar.b(b.m9086a(sContext).m9087a());
                        iiVar.c(ht.ClientInfoUpdate.f7140a);
                        iiVar.a(com.xiaomi.push.service.ba.a());
                        iiVar.f7282a = new HashMap();
                        iiVar.f7282a.put("app_version", g.m9381a(sContext, sContext.getPackageName()));
                        iiVar.f7282a.put(Constants.EXTRA_KEY_APP_VERSION_CODE, Integer.toString(g.a(sContext, sContext.getPackageName())));
                        iiVar.f7282a.put("push_sdk_vn", "4_5_0");
                        iiVar.f7282a.put("push_sdk_vc", Integer.toString(40050));
                        i.a(sContext, iiVar.f7282a);
                        String e = b.m9086a(sContext).e();
                        if (!TextUtils.isEmpty(e)) {
                            iiVar.f7282a.put("deviceid", e);
                        }
                        ao.a(sContext).a((iu) iiVar, hj.Notification, false, (hw) null);
                    }
                    if (!n.m9616a(sContext, "update_devId", false)) {
                        updateImeiOrOaid();
                        n.a(sContext, "update_devId", true);
                    }
                    String c = i.c(sContext);
                    if (!TextUtils.isEmpty(c)) {
                        id idVar = new id();
                        idVar.a(com.xiaomi.push.service.ba.a());
                        idVar.b(str);
                        idVar.c(ez.COMMAND_CHK_VDEVID.f6970a);
                        ArrayList arrayList2 = new ArrayList();
                        String b = i.b(sContext);
                        if (!TextUtils.isEmpty(b)) {
                            arrayList2.add(b);
                        }
                        String str4 = "";
                        if (c == null) {
                            c = str4;
                        }
                        arrayList2.add(c);
                        arrayList2.add(Build.MODEL != null ? Build.MODEL : str4);
                        if (Build.BOARD != null) {
                            str4 = Build.BOARD;
                        }
                        arrayList2.add(str4);
                        idVar.a(arrayList2);
                        ao.a(sContext).a((iu) idVar, hj.Command, false, (hw) null);
                    }
                    if (shouldUseMIUIPush(sContext) && shouldPullNotification(sContext)) {
                        ii iiVar2 = new ii();
                        iiVar2.b(b.m9086a(sContext).m9087a());
                        iiVar2.c(ht.PullOfflineMessage.f7140a);
                        iiVar2.a(com.xiaomi.push.service.ba.a());
                        iiVar2.a(false);
                        ao.a(sContext).a((iu) iiVar2, hj.Notification, false, (hw) null, false);
                        addPullNotificationTime(sContext);
                    }
                }
                addRegRequestTime(sContext);
                scheduleOcVersionCheckJob();
                scheduleDataCollectionJobs(sContext);
                initEventPerfLogic(sContext);
                av.a(sContext);
                if (!sContext.getPackageName().equals("com.xiaomi.xmsf")) {
                    if (Logger.getUserLogger() != null) {
                        Logger.setLogger(sContext, Logger.getUserLogger());
                    }
                    b.a(2);
                }
                operateSyncAction(context);
                return;
            }
            ao.a(sContext).m9077a();
            b.m9051a("Could not send  register message within 5s repeatly .");
        } catch (Throwable th) {
            b.a(th);
        }
    }

    private static void operateSyncAction(Context context) {
        if ("syncing".equals(af.a(sContext).a(au.DISABLE_PUSH))) {
            disablePush(sContext);
        }
        if ("syncing".equals(af.a(sContext).a(au.ENABLE_PUSH))) {
            enablePush(sContext);
        }
        if ("syncing".equals(af.a(sContext).a(au.UPLOAD_HUAWEI_TOKEN))) {
            syncAssemblePushToken(sContext);
        }
        if ("syncing".equals(af.a(sContext).a(au.UPLOAD_FCM_TOKEN))) {
            syncAssembleFCMPushToken(sContext);
        }
        if ("syncing".equals(af.a(sContext).a(au.UPLOAD_COS_TOKEN))) {
            syncAssembleCOSPushToken(context);
        }
        if ("syncing".equals(af.a(sContext).a(au.UPLOAD_FTOS_TOKEN))) {
            syncAssembleFTOSPushToken(context);
        }
    }

    public static void pausePush(Context context, String str) {
        setAcceptTime(context, 0, 0, 0, 0, str);
    }

    static void reInitialize(Context context, hx hxVar) {
        b.e("re-register reason: " + hxVar);
        String a = bp.a(6);
        String a2 = b.m9086a(context).m9087a();
        String b = b.m9086a(context).b();
        b.m9086a(context).m9088a();
        clearExtrasForInitialize(context);
        clearNotification(context);
        b.m9086a(context).a(Constants.a());
        b.m9086a(context).a(a2, b, a);
        ij ijVar = new ij();
        ijVar.a(com.xiaomi.push.service.ba.a());
        ijVar.b(a2);
        ijVar.e(b);
        ijVar.f(a);
        ijVar.d(context.getPackageName());
        ijVar.c(g.m9381a(context, context.getPackageName()));
        ijVar.b(g.a(context, context.getPackageName()));
        ijVar.h("4_5_0");
        ijVar.a(40050);
        ijVar.a(hxVar);
        int a3 = i.a();
        if (a3 >= 0) {
            ijVar.c(a3);
        }
        ao.a(context).a(ijVar, false);
    }

    @Deprecated
    public static void registerCrashHandler(Thread.UncaughtExceptionHandler uncaughtExceptionHandler) {
        Thread.setDefaultUncaughtExceptionHandler(uncaughtExceptionHandler);
    }

    private static void registerNetworkReceiver(Context context) {
        try {
            IntentFilter intentFilter = new IntentFilter();
            intentFilter.addAction("android.net.conn.CONNECTIVITY_CHANGE");
            intentFilter.addCategory("android.intent.category.DEFAULT");
            o.a(context.getApplicationContext(), new NetworkStatusReceiver(null), intentFilter);
            o.a(context, NetworkStatusReceiver.class);
        } catch (Throwable th) {
            b.m9051a("dynamic register network status receiver failed:" + th);
        }
    }

    public static void registerPush(Context context, String str, String str2) {
        registerPush(context, str, str2, new PushConfiguration());
    }

    public static void registerPush(Context context, String str, String str2, PushConfiguration pushConfiguration) {
        registerPush(context, str, str2, pushConfiguration, null, null);
    }

    private static void registerPush(Context context, final String str, final String str2, PushConfiguration pushConfiguration, final String str3, final ICallbackResult iCallbackResult) {
        checkNotNull(context, d.R);
        checkNotNull(str, "appID");
        checkNotNull(str2, "appToken");
        Context applicationContext = context.getApplicationContext();
        sContext = applicationContext;
        if (applicationContext == null) {
            sContext = context;
        }
        Context context2 = sContext;
        v.m9751a(context2);
        if (!NetworkStatusReceiver.a()) {
            registerNetworkReceiver(sContext);
        }
        f.a(sContext).a(pushConfiguration);
        al.a(context2).a(new Runnable() {
            /* class com.xiaomi.mipush.sdk.MiPushClient.AnonymousClass1 */

            public void run() {
                MiPushClient.initialize(MiPushClient.sContext, str, str2, null, str3, iCallbackResult);
            }
        });
    }

    public static void registerPush(Context context, String str, String str2, String str3) {
        registerPush(context, str, str2, new PushConfiguration(), str3, null);
    }

    public static void registerToken(Context context, String str, String str2, String str3, UPSRegisterCallBack uPSRegisterCallBack) {
        registerPush(context, str, str2, new PushConfiguration(), null, uPSRegisterCallBack);
    }

    static synchronized void removeAcceptTime(Context context) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.remove(Constants.EXTRA_KEY_ACCEPT_TIME);
            t.a(edit);
        }
    }

    static synchronized void removeAccount(Context context, String str) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.remove("account_" + str).commit();
        }
    }

    static synchronized void removeAlias(Context context, String str) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.remove("alias_" + str).commit();
        }
    }

    static synchronized void removeAllAccounts(Context context) {
        synchronized (MiPushClient.class) {
            for (String str : getAllUserAccount(context)) {
                removeAccount(context, str);
            }
        }
    }

    static synchronized void removeAllAliases(Context context) {
        synchronized (MiPushClient.class) {
            for (String str : getAllAlias(context)) {
                removeAlias(context, str);
            }
        }
    }

    static synchronized void removeAllTopics(Context context) {
        synchronized (MiPushClient.class) {
            for (String str : getAllTopic(context)) {
                removeTopic(context, str);
            }
        }
    }

    static synchronized void removeTopic(Context context, String str) {
        synchronized (MiPushClient.class) {
            SharedPreferences.Editor edit = context.getSharedPreferences("mipush_extra", 0).edit();
            edit.remove("topic_" + str).commit();
        }
    }

    public static void reportAppRunInBackground(Context context, boolean z) {
        if (b.m9086a(context).m9093b()) {
            ht htVar = z ? ht.APP_SLEEP : ht.APP_WAKEUP;
            ii iiVar = new ii();
            iiVar.b(b.m9086a(context).m9087a());
            iiVar.c(htVar.f7140a);
            iiVar.d(context.getPackageName());
            iiVar.a(com.xiaomi.push.service.ba.a());
            iiVar.a(false);
            ao.a(context).a((iu) iiVar, hj.Notification, false, (hw) null, false);
        }
    }

    static void reportIgnoreRegMessageClicked(Context context, String str, hw hwVar, String str2, String str3) {
        ii iiVar = new ii();
        if (TextUtils.isEmpty(str3)) {
            b.d("do not report clicked message");
            return;
        }
        iiVar.b(str3);
        iiVar.c("bar:click");
        iiVar.a(str);
        iiVar.a(false);
        ao.a(context).a(iiVar, hj.Notification, false, true, hwVar, true, str2, str3);
    }

    public static void reportMessageClicked(Context context, MiPushMessage miPushMessage) {
        hw hwVar = new hw();
        hwVar.a(miPushMessage.getMessageId());
        hwVar.b(miPushMessage.getTopic());
        hwVar.d(miPushMessage.getDescription());
        hwVar.c(miPushMessage.getTitle());
        hwVar.c(miPushMessage.getNotifyId());
        hwVar.a(miPushMessage.getNotifyType());
        hwVar.b(miPushMessage.getPassThrough());
        hwVar.a(miPushMessage.getExtra());
        reportMessageClicked(context, miPushMessage.getMessageId(), hwVar, null);
    }

    @Deprecated
    public static void reportMessageClicked(Context context, String str) {
        reportMessageClicked(context, str, null, null);
    }

    static void reportMessageClicked(Context context, String str, hw hwVar, String str2) {
        ii iiVar = new ii();
        if (TextUtils.isEmpty(str2)) {
            if (b.m9086a(context).m9093b()) {
                str2 = b.m9086a(context).m9087a();
            } else {
                b.d("do not report clicked message");
                return;
            }
        }
        iiVar.b(str2);
        iiVar.c("bar:click");
        iiVar.a(str);
        iiVar.a(false);
        ao.a(context).a((iu) iiVar, hj.Notification, false, hwVar);
    }

    public static void resumePush(Context context, String str) {
        setAcceptTime(context, 0, 0, 23, 59, str);
    }

    private static void scheduleDataCollectionJobs(Context context) {
        if (ax.a(sContext).a(ho.DataCollectionSwitch.a(), getDefaultSwitch())) {
            dn.a().a(new r(context));
            al.a(sContext).a(new Runnable() {
                /* class com.xiaomi.mipush.sdk.MiPushClient.AnonymousClass2 */

                public void run() {
                    Cdo.a(MiPushClient.sContext);
                }
            }, 10);
        }
    }

    private static void scheduleOcVersionCheckJob() {
        al.a(sContext).a(new ae(sContext), ax.a(sContext).a(ho.OcVersionCheckFrequency.a(), RemoteMessageConst.DEFAULT_TTL), 5);
    }

    public static void setAcceptTime(Context context, int i, int i2, int i3, int i4, String str) {
        if (i < 0 || i >= 24 || i3 < 0 || i3 >= 24 || i2 < 0 || i2 >= 60 || i4 < 0 || i4 >= 60) {
            throw new IllegalArgumentException("the input parameter is not valid.");
        }
        long rawOffset = (long) (((TimeZone.getTimeZone("GMT+08").getRawOffset() - TimeZone.getDefault().getRawOffset()) / 1000) / 60);
        long j = ((((long) ((i * 60) + i2)) + rawOffset) + 1440) % 1440;
        long j2 = ((((long) ((i3 * 60) + i4)) + rawOffset) + 1440) % 1440;
        ArrayList arrayList = new ArrayList();
        arrayList.add(String.format("%1$02d:%2$02d", Long.valueOf(j / 60), Long.valueOf(j % 60)));
        arrayList.add(String.format("%1$02d:%2$02d", Long.valueOf(j2 / 60), Long.valueOf(j2 % 60)));
        ArrayList arrayList2 = new ArrayList();
        arrayList2.add(String.format("%1$02d:%2$02d", Integer.valueOf(i), Integer.valueOf(i2)));
        arrayList2.add(String.format("%1$02d:%2$02d", Integer.valueOf(i3), Integer.valueOf(i4)));
        if (!acceptTimeSet(context, (String) arrayList.get(0), (String) arrayList.get(1))) {
            setCommand(context, ez.COMMAND_SET_ACCEPT_TIME.f6970a, arrayList, str);
        } else if (1 == PushMessageHelper.getPushMode(context)) {
            PushMessageHandler.a(context, str, ez.COMMAND_SET_ACCEPT_TIME.f6970a, 0, null, arrayList2);
        } else {
            PushMessageHelper.sendCommandMessageBroadcast(context, PushMessageHelper.generateCommandMessage(ez.COMMAND_SET_ACCEPT_TIME.f6970a, arrayList2, 0, null, null));
        }
    }

    public static void setAlias(Context context, String str, String str2) {
        if (!TextUtils.isEmpty(str)) {
            setCommand(context, ez.COMMAND_SET_ALIAS.f6970a, str, str2);
        }
    }

    protected static void setCommand(Context context, String str, String str2, String str3) {
        ArrayList arrayList = new ArrayList();
        if (!TextUtils.isEmpty(str2)) {
            arrayList.add(str2);
        }
        if (!ez.COMMAND_SET_ALIAS.f6970a.equalsIgnoreCase(str) || Math.abs(System.currentTimeMillis() - aliasSetTime(context, str2)) >= 86400000) {
            if (ez.COMMAND_UNSET_ALIAS.f6970a.equalsIgnoreCase(str) && aliasSetTime(context, str2) < 0) {
                b.m9051a("Don't cancel alias for " + bp.a(arrayList.toString(), 3) + " is unseted");
            } else if (!ez.COMMAND_SET_ACCOUNT.f6970a.equalsIgnoreCase(str) || Math.abs(System.currentTimeMillis() - accountSetTime(context, str2)) >= 3600000) {
                if (!ez.COMMAND_UNSET_ACCOUNT.f6970a.equalsIgnoreCase(str) || accountSetTime(context, str2) >= 0) {
                    setCommand(context, str, arrayList, str3);
                    return;
                }
                b.m9051a("Don't cancel account for " + bp.a(arrayList.toString(), 3) + " is unseted");
            } else if (1 == PushMessageHelper.getPushMode(context)) {
                PushMessageHandler.a(context, str3, str, 0, null, arrayList);
            } else {
                PushMessageHelper.sendCommandMessageBroadcast(context, PushMessageHelper.generateCommandMessage(ez.COMMAND_SET_ACCOUNT.f6970a, arrayList, 0, null, str3));
            }
        } else if (1 == PushMessageHelper.getPushMode(context)) {
            PushMessageHandler.a(context, str3, str, 0, null, arrayList);
        } else {
            PushMessageHelper.sendCommandMessageBroadcast(context, PushMessageHelper.generateCommandMessage(ez.COMMAND_SET_ALIAS.f6970a, arrayList, 0, null, str3));
        }
    }

    protected static void setCommand(Context context, String str, ArrayList<String> arrayList, String str2) {
        if (!TextUtils.isEmpty(b.m9086a(context).m9087a())) {
            id idVar = new id();
            String a = com.xiaomi.push.service.ba.a();
            idVar.a(a);
            idVar.b(b.m9086a(context).m9087a());
            idVar.c(str);
            Iterator<String> it = arrayList.iterator();
            while (it.hasNext()) {
                idVar.m9492a(it.next());
            }
            idVar.e(str2);
            idVar.d(context.getPackageName());
            b.e("cmd:" + str + ", " + a);
            ao.a(context).a(idVar, hj.Command, (hw) null);
        }
    }

    public static void setLocalNotificationType(Context context, int i) {
        ao.a(context).b(i & -1);
    }

    public static void setUserAccount(Context context, String str, String str2) {
        if (!TextUtils.isEmpty(str)) {
            setCommand(context, ez.COMMAND_SET_ACCOUNT.f6970a, str, str2);
        }
    }

    private static boolean shouldPullNotification(Context context) {
        return Math.abs(System.currentTimeMillis() - context.getSharedPreferences("mipush_extra", 0).getLong("last_pull_notification", -1)) > Constants.ASSEMBLE_PUSH_NETWORK_INTERVAL;
    }

    private static boolean shouldSendRegRequest(Context context) {
        return Math.abs(System.currentTimeMillis() - context.getSharedPreferences("mipush_extra", 0).getLong("last_reg_request", -1)) > 5000;
    }

    public static boolean shouldUseMIUIPush(Context context) {
        return ao.a(context).m9079a();
    }

    public static void subscribe(Context context, String str, String str2) {
        if (!TextUtils.isEmpty(b.m9086a(context).m9087a()) && !TextUtils.isEmpty(str)) {
            if (Math.abs(System.currentTimeMillis() - topicSubscribedTime(context, str)) > 86400000) {
                in inVar = new in();
                String a = com.xiaomi.push.service.ba.a();
                inVar.a(a);
                inVar.b(b.m9086a(context).m9087a());
                inVar.c(str);
                inVar.d(context.getPackageName());
                inVar.e(str2);
                b.e("cmd:" + ez.COMMAND_SUBSCRIBE_TOPIC + ", " + a);
                ao.a(context).a(inVar, hj.Subscription, (hw) null);
            } else if (1 == PushMessageHelper.getPushMode(context)) {
                PushMessageHandler.a(context, str2, 0, null, str);
            } else {
                ArrayList arrayList = new ArrayList();
                arrayList.add(str);
                PushMessageHelper.sendCommandMessageBroadcast(context, PushMessageHelper.generateCommandMessage(ez.COMMAND_SUBSCRIBE_TOPIC.f6970a, arrayList, 0, null, null));
            }
        }
    }

    public static void syncAssembleCOSPushToken(Context context) {
        ao.a(context).a((String) null, au.UPLOAD_COS_TOKEN, e.ASSEMBLE_PUSH_COS);
    }

    public static void syncAssembleFCMPushToken(Context context) {
        ao.a(context).a((String) null, au.UPLOAD_FCM_TOKEN, e.ASSEMBLE_PUSH_FCM);
    }

    public static void syncAssembleFTOSPushToken(Context context) {
        ao.a(context).a((String) null, au.UPLOAD_FTOS_TOKEN, e.ASSEMBLE_PUSH_FTOS);
    }

    public static void syncAssemblePushToken(Context context) {
        ao.a(context).a((String) null, au.UPLOAD_HUAWEI_TOKEN, e.ASSEMBLE_PUSH_HUAWEI);
    }

    public static long topicSubscribedTime(Context context, String str) {
        SharedPreferences sharedPreferences = context.getSharedPreferences("mipush_extra", 0);
        return sharedPreferences.getLong("topic_" + str, -1);
    }

    public static void turnOffPush(Context context, UPSTurnCallBack uPSTurnCallBack) {
        disablePush(context);
        if (uPSTurnCallBack != null) {
            CodeResult codeResult = new CodeResult();
            codeResult.setResultCode(0);
            codeResult.getResultCode();
            uPSTurnCallBack.onResult(codeResult);
        }
    }

    public static void turnOnPush(Context context, UPSTurnCallBack uPSTurnCallBack) {
        enablePush(context);
        if (uPSTurnCallBack != null) {
            CodeResult codeResult = new CodeResult();
            codeResult.setResultCode(0);
            codeResult.getResultCode();
            uPSTurnCallBack.onResult(codeResult);
        }
    }

    public static void unRegisterToken(Context context, UPSUnRegisterCallBack uPSUnRegisterCallBack) {
        unregisterPush(context);
        if (uPSUnRegisterCallBack != null) {
            TokenResult tokenResult = new TokenResult();
            tokenResult.setToken(null);
            tokenResult.getToken();
            tokenResult.setResultCode(0);
            tokenResult.getResultCode();
            uPSUnRegisterCallBack.onResult(tokenResult);
        }
    }

    public static void unregisterPush(Context context) {
        i.c(context);
        ax.a(context).a();
        if (b.m9086a(context).m9093b()) {
            ip ipVar = new ip();
            ipVar.a(com.xiaomi.push.service.ba.a());
            ipVar.b(b.m9086a(context).m9087a());
            ipVar.c(b.m9086a(context).m9094c());
            ipVar.e(b.m9086a(context).b());
            ipVar.d(context.getPackageName());
            ao.a(context).a(ipVar);
            PushMessageHandler.a();
            PushMessageHandler.b();
            b.m9086a(context).m9092b();
            clearLocalNotificationType(context);
            clearNotification(context);
            clearExtras(context);
        }
    }

    public static void unsetAlias(Context context, String str, String str2) {
        setCommand(context, ez.COMMAND_UNSET_ALIAS.f6970a, str, str2);
    }

    public static void unsetUserAccount(Context context, String str, String str2) {
        setCommand(context, ez.COMMAND_UNSET_ACCOUNT.f6970a, str, str2);
    }

    public static void unsubscribe(Context context, String str, String str2) {
        if (b.m9086a(context).m9093b()) {
            if (topicSubscribedTime(context, str) < 0) {
                b.m9051a("Don't cancel subscribe for " + str + " is unsubscribed");
                return;
            }
            ir irVar = new ir();
            String a = com.xiaomi.push.service.ba.a();
            irVar.a(a);
            irVar.b(b.m9086a(context).m9087a());
            irVar.c(str);
            irVar.d(context.getPackageName());
            irVar.e(str2);
            b.e("cmd:" + ez.COMMAND_UNSUBSCRIBE_TOPIC + ", " + a);
            ao.a(context).a(irVar, hj.UnSubscription, (hw) null);
        }
    }

    private static void updateImeiOrOaid() {
        new Thread(new Runnable() {
            /* class com.xiaomi.mipush.sdk.MiPushClient.AnonymousClass3 */

            public void run() {
                if (l.m9614d()) {
                    return;
                }
                if (i.f(MiPushClient.sContext) != null || ba.a(MiPushClient.sContext).m9146a()) {
                    ii iiVar = new ii();
                    iiVar.b(b.m9086a(MiPushClient.sContext).m9087a());
                    iiVar.c(ht.ClientInfoUpdate.f7140a);
                    iiVar.a(com.xiaomi.push.service.ba.a());
                    iiVar.a(new HashMap());
                    String str = "";
                    String f = i.f(MiPushClient.sContext);
                    if (!TextUtils.isEmpty(f)) {
                        str = str + bp.a(f);
                    }
                    String h = i.h(MiPushClient.sContext);
                    if (!TextUtils.isEmpty(str) && !TextUtils.isEmpty(h)) {
                        str = str + Constants.ACCEPT_TIME_SEPARATOR_SP + h;
                    }
                    if (!TextUtils.isEmpty(str)) {
                        iiVar.m9517a().put(Constants.EXTRA_KEY_IMEI_MD5, str);
                    }
                    ba.a(MiPushClient.sContext).a(iiVar.m9517a());
                    i.a(MiPushClient.sContext, iiVar.f7282a);
                    int a = i.a();
                    if (a >= 0) {
                        iiVar.m9517a().put("space_id", Integer.toString(a));
                    }
                    ao.a(MiPushClient.sContext).a((iu) iiVar, hj.Notification, false, (hw) null);
                }
            }
        }).start();
    }
}