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(); } }