package cn.jpush.android.t;
import android.content.Context;
import android.content.Intent;
import android.os.Build;
import android.os.Bundle;
import android.text.TextUtils;
import cn.jiguang.api.JCoreManager;
import cn.jpush.android.api.JThirdPlatFormInterface;
import cn.jpush.android.asus.b;
import cn.jpush.android.cache.Key;
import cn.jpush.android.cache.Sp;
import cn.jpush.android.helper.JCoreHelper;
import cn.jpush.android.helper.Logger;
import cn.jpush.android.local.JPushConstants;
import cn.jpush.android.service.PushReceiver;
import cn.jpush.android.u.e;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class c {
private static Map<String, Byte> b = new HashMap();
private static c d;
private static final Object e = new Object();
private List<JThirdPlatFormInterface> a = new ArrayList();
private boolean c;
/* access modifiers changed from: package-private */
public class a {
String a;
int b;
String c;
byte d;
a() {
}
public String toString() {
return "ThirdMessage{msgid='" + this.a + '\'' + ", notiId=" + this.b + ", content='" + this.c + '\'' + ", platform=" + ((int) this.d) + '}';
}
}
static {
b.put("cn.jpush.android.thirdpush.meizu.MeizuPushManager", (byte) 3);
b.put("cn.jpush.android.thirdpush.xiaomi.XMPushManager", (byte) 1);
b.put("cn.jpush.android.thirdpush.huawei.HWPushManager", (byte) 2);
b.put("cn.jpush.android.thirdpush.fcm.FCMPushManager", (byte) 8);
b.put("cn.jpush.android.thridpush.oppo.OPushManager", (byte) 4);
b.put("cn.jpush.android.thirdpush.vivo.VivoPushManager", (byte) 5);
b.put(b.class.getName(), (byte) 6);
}
private c() {
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private a a(Bundle bundle) {
a aVar;
if (bundle != null) {
aVar = new a();
aVar.c = bundle.getString("data");
aVar.a = bundle.getString(JThirdPlatFormInterface.KEY_MSG_ID);
aVar.b = bundle.getInt(JThirdPlatFormInterface.KEY_NOTI_ID, 0);
aVar.d = bundle.getByte(JThirdPlatFormInterface.KEY_PLATFORM, (byte) -1).byteValue();
} else {
aVar = null;
}
Logger.d("ThirdPushManager", "parse third messgae:" + aVar);
return aVar;
}
public static c a() {
if (d == null) {
synchronized (e) {
if (d == null) {
d = new c();
}
}
}
return d;
}
private void a(Context context, JThirdPlatFormInterface jThirdPlatFormInterface) {
if (jThirdPlatFormInterface != null && jThirdPlatFormInterface.isNeedClearToken(context)) {
byte romType = jThirdPlatFormInterface.getRomType(context);
Sp.set(context, Key.ThirdPush_RegUpload(romType).set(false));
Sp.set(context, Key.ThirdPush_RegID(romType).set(null));
}
}
private void a(Context context, JThirdPlatFormInterface jThirdPlatFormInterface, String str) {
Logger.d("ThirdPushManager", "sendBroadCastToUploadToken:" + str);
String token = jThirdPlatFormInterface.getToken(context);
if (!TextUtils.isEmpty(token)) {
b(context, jThirdPlatFormInterface.getRomType(context), token);
return;
}
try {
Intent intent = new Intent(context, PushReceiver.class);
intent.setAction(str);
Bundle bundle = new Bundle();
bundle.putString("sdktype", JPushConstants.SDK_TYPE);
bundle.putByte(JThirdPlatFormInterface.KEY_PLATFORM, jThirdPlatFormInterface.getRomType(context));
intent.putExtras(bundle);
intent.setPackage(context.getPackageName());
context.sendBroadcast(intent);
} catch (Throwable th) {
Logger.ww("ThirdPushManager", "send " + str + " failed:" + th);
}
}
private void b(Context context, byte b2, String str) {
Logger.ii("ThirdPushManager", "[uploadInService] regid:" + str + ",romtype:" + ((int) b2));
a(context);
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
if (jThirdPlatFormInterface.getRomType(context) == b2) {
a(context, jThirdPlatFormInterface);
if (b(context, (int) b2, str)) {
c(context, b2, str);
}
}
}
}
private boolean b(Context context, int i, String str) {
String str2;
String str3;
byte b2 = (byte) i;
if (!((Boolean) Sp.get(context, Key.ThirdPush_RegUpload(b2))).booleanValue()) {
str2 = "ThirdPushManager";
str3 = "need upload -- last upload failed or never upload success";
} else if (!TextUtils.equals((String) Sp.get(context, Key.ThirdPush_RegID(b2)), str)) {
str2 = "ThirdPushManager";
str3 = "need upload -- regId changed";
} else {
Logger.ii("ThirdPushManager", "need not upload regId");
return false;
}
Logger.ii(str2, str3);
return true;
}
private void c(Context context, byte b2, String str) {
Logger.d("ThirdPushManager", "sendUpdateRegIDRequest, WhichPlatform:" + ((int) b2) + ",regID:" + str);
Sp.set(context, Key.ThirdPush_RegUpload(b2).set(false));
Sp.set(context, Key.ThirdPush_RegID(b2).set(str));
a.a().a(context, b2, str);
}
private void j(Context context) {
Object newInstance;
Logger.d("ThirdPushManager", "[loadThirdPush]");
for (Map.Entry<String, Byte> entry : b.entrySet()) {
try {
Class<?> loadClass = context.getClassLoader().loadClass(entry.getKey());
if (!(loadClass == null || (newInstance = loadClass.newInstance()) == null || !(newInstance instanceof JThirdPlatFormInterface))) {
((JThirdPlatFormInterface) newInstance).init(context);
if (((JThirdPlatFormInterface) newInstance).isSupport(context)) {
this.a.add((JThirdPlatFormInterface) newInstance);
} else {
Byte value = entry.getValue();
Sp.set(context, Key.ThirdPush_RegID(value.byteValue()).set(null));
Sp.set(context, Key.ThirdPush_RegUpload(value.byteValue()).set(false));
}
}
} catch (Throwable th) {
Byte value2 = entry.getValue();
Sp.set(context, Key.ThirdPush_RegID(value2.byteValue()).set(null));
Sp.set(context, Key.ThirdPush_RegUpload(value2.byteValue()).set(false));
if ((th instanceof RuntimeException) && th.getMessage().contains("Please check") && JCoreManager.getDebugMode()) {
if (cn.jpush.android.l.a.c >= 238) {
JCoreHelper.futureExecutor(context, new e("ThirdPushManager#loadThirdPush") {
/* class cn.jpush.android.t.c.AnonymousClass1 */
@Override // cn.jpush.android.u.e
public void a() {
throw new RuntimeException(th);
}
});
} else {
new Thread(new Runnable() {
/* class cn.jpush.android.t.c.AnonymousClass2 */
public void run() {
throw new RuntimeException(th);
}
}).start();
}
}
Logger.w("ThirdPushManager", "loadThirdPush error:" + th.getMessage());
}
}
if (Build.VERSION.SDK_INT >= 26 && !this.a.isEmpty()) {
cn.jpush.android.p.a.a(context);
}
}
public byte a(Context context, String str) {
if (!cn.jpush.android.l.a.a()) {
return -1;
}
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
byte romType = jThirdPlatFormInterface.getRomType(context);
if (romType == 1) {
int nofiticationID = JThirdPlatFormInterface.getNofiticationID(str, romType);
Logger.d("ThirdPushManager", "clearThirdNotificaiton msgid:" + str + ", romType:" + ((int) romType) + " , notificationId:" + nofiticationID);
jThirdPlatFormInterface.clearNotification(context, nofiticationID);
return romType;
}
}
return -1;
}
public synchronized void a(Context context) {
if (!this.c) {
if (context != null) {
try {
Class.forName("cn.jpush.android.dy.JPushThirdDyManager").getDeclaredMethod("loadByJPush", Context.class).invoke(null, context);
} catch (Throwable unused) {
}
j(context);
this.c = true;
}
}
}
public void a(Context context, byte b2, String str) {
if (cn.jpush.android.l.a.a()) {
if (context == null) {
context = JPushConstants.mApplicationContext;
}
if (context == null) {
Logger.e("ThirdPushManager", "context was null");
return;
}
Logger.ii("ThirdPushManager", "uploadRegID regid:" + str);
a(context);
Bundle bundle = new Bundle();
bundle.putString(JThirdPlatFormInterface.KEY_TOKEN, str);
bundle.putByte(JThirdPlatFormInterface.KEY_PLATFORM, b2);
JCoreHelper.runActionWithService(context, JPushConstants.SDK_TYPE, "third_push_upload_regid", bundle);
}
}
public void a(Context context, int i, String str) {
try {
Logger.dd("ThirdPushManager", "[callBackTokenToUser] platform:" + i + ",token:" + str);
Bundle bundle = new Bundle();
bundle.putInt(JThirdPlatFormInterface.KEY_PLATFORM, i);
bundle.putString(JThirdPlatFormInterface.KEY_TOKEN, str);
cn.jpush.android.p.b.a(context, 10000, 0, "", bundle);
} catch (Throwable th) {
Logger.ww("ThirdPushManager", "callBackTokenToUser failed:" + th.getMessage());
}
}
public void a(Context context, Bundle bundle) {
if (context == null) {
context = JPushConstants.mApplicationContext;
}
if (context == null) {
Logger.e("ThirdPushManager", "context was null");
} else if (bundle == null) {
Logger.ww("ThirdPushManager", "bundle is null");
} else {
b(context, bundle.getByte(JThirdPlatFormInterface.KEY_PLATFORM, (byte) 0).byteValue(), bundle.getString(JThirdPlatFormInterface.KEY_TOKEN));
}
}
public void a(final Context context, final String str, final Bundle bundle) {
try {
Logger.dd("ThirdPushManager", "doAction,action:" + str + ",bundle:" + bundle + ",enable:" + cn.jpush.android.l.a.a());
if (cn.jpush.android.l.a.a()) {
JCoreHelper.majorExecutor(context, "ThirdPushManager", new e("ThirdPushManager#doAction") {
/* class cn.jpush.android.t.c.AnonymousClass3 */
@Override // cn.jpush.android.u.e
public void a() {
try {
if (TextUtils.isEmpty(str)) {
return;
}
if (str.equals(JThirdPlatFormInterface.ACTION_NOTIFICATION_ARRIVED)) {
a a2 = c.this.a((c) bundle);
if (a2 != null) {
b.a(context, a2.c, a2.a, a2.b, a2.d, 1);
}
} else if (str.equals(JThirdPlatFormInterface.ACTION_NOTIFICATION_CLCKED)) {
a a3 = c.this.a((c) bundle);
if (a3 != null) {
b.a(context, a3.c, a3.a, a3.b, a3.d, 0);
}
} else if (str.equals(JThirdPlatFormInterface.ACTION_NOTIFICATION_UN_SHOW)) {
a a4 = c.this.a((c) bundle);
if (a4 != null) {
b.a(context, a4.c, a4.a, a4.b, a4.d, 2);
}
} else if (!str.equals(JThirdPlatFormInterface.ACTION_NOTIFICATION_SHOW)) {
if (str.equals(JThirdPlatFormInterface.ACTION_REGISTER_TOKEN) && bundle != null) {
String string = bundle.getString(JThirdPlatFormInterface.KEY_TOKEN);
c.this.a(context, bundle.getByte(JThirdPlatFormInterface.KEY_PLATFORM, (byte) -1).byteValue(), string);
}
}
} catch (Throwable th) {
Logger.ww("ThirdPushManager", "doAction failed internal:" + th.getMessage());
}
}
});
}
} catch (Throwable th) {
Logger.ww("ThirdPushManager", "doAction failed:" + th.getMessage());
}
}
public void b(Context context) {
if (cn.jpush.android.l.a.a()) {
a(context);
if (!cn.jpush.android.cache.a.d(context.getApplicationContext())) {
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
try {
jThirdPlatFormInterface.register(context);
} catch (Throwable th) {
Logger.ww("ThirdPushManager", "Third push register failed#", th);
}
}
return;
}
Logger.d("ThirdPushManager", "push has close");
}
}
public void b(Context context, Bundle bundle) {
if (!cn.jpush.android.l.a.a()) {
Logger.dd("ThirdPushManager", "[refreshToken] third disabled");
return;
}
a(context);
byte byteValue = bundle.getByte(JThirdPlatFormInterface.KEY_PLATFORM, (byte) -1).byteValue();
if (byteValue <= 0) {
Logger.w("ThirdPushManager", "refreshToken romtype is <= 0");
return;
}
Logger.dd("ThirdPushManager", "[refreshToken] romType: " + ((int) byteValue));
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
if (jThirdPlatFormInterface.getRomType(context) == byteValue) {
String token = jThirdPlatFormInterface.getToken(context);
if (!TextUtils.isEmpty(token)) {
a(context, byteValue, token);
} else {
jThirdPlatFormInterface.register(context);
}
}
}
}
public void c(Context context) {
if (cn.jpush.android.l.a.a()) {
a(context);
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
jThirdPlatFormInterface.resumePush(context);
}
}
}
public void d(Context context) {
if (cn.jpush.android.l.a.a()) {
a(context);
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
jThirdPlatFormInterface.stopPush(context);
}
}
}
public byte e(Context context) {
int i;
byte b2 = 0;
if (!cn.jpush.android.l.a.a()) {
return 0;
}
a(context);
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
byte romType = jThirdPlatFormInterface.getRomType(context);
b2 = (byte) (b2 | romType);
byte b3 = (byte) romType;
String str = (String) Sp.get(context, Key.ThirdPush_RegID(b3));
boolean booleanValue = ((Boolean) Sp.get(context, Key.ThirdPush_RegUpload(b3))).booleanValue();
if (jThirdPlatFormInterface.getRomType(context) == 8) {
b2 = (byte) (b2 | 8);
if (booleanValue && !TextUtils.isEmpty(str)) {
i = b2 | 32;
}
} else {
if (jThirdPlatFormInterface.getRomType(context) == 2) {
b2 = (byte) (b2 | 64);
}
if (!booleanValue || TextUtils.isEmpty(str)) {
i = b2 | 128;
}
}
b2 = (byte) i;
}
Logger.d("ThirdPushManager", "getRomType,romType:" + ((int) b2));
return b2;
}
public String f(Context context) {
if (!cn.jpush.android.l.a.a()) {
return null;
}
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
if (jThirdPlatFormInterface.getRomType(context) != 8) {
return (String) Sp.get(context, Key.ThirdPush_RegID(jThirdPlatFormInterface.getRomType(context)));
}
}
return null;
}
public void g(Context context) {
try {
if (this.a != null) {
if (!this.a.isEmpty()) {
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
c(context, jThirdPlatFormInterface.getRomType(context), null);
}
return;
}
}
if (b != null) {
for (Byte b2 : b.values()) {
Sp.set(context, Key.ThirdPush_RegUpload(b2.byteValue()).set(false));
Sp.set(context, Key.ThirdPush_RegID(b2.byteValue()).set(null));
}
}
} catch (Throwable unused) {
}
}
public void h(Context context) {
if (cn.jpush.android.l.a.a()) {
if (context == null) {
context = JPushConstants.mApplicationContext;
}
if (context == null) {
Logger.e("ThirdPushManager", "context was null");
return;
}
a(context);
Logger.ii("ThirdPushManager", "uploadRegIdAfterLogin");
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
a(context, jThirdPlatFormInterface, JThirdPlatFormInterface.ACTION_PLUGIN_PALTFORM_REFRESSH_REGID);
}
}
}
public void i(Context context) {
Logger.dd("ThirdPushManager", "reRegisterInPushReceiver");
a(context);
for (JThirdPlatFormInterface jThirdPlatFormInterface : this.a) {
a(context, jThirdPlatFormInterface, JThirdPlatFormInterface.ACTION_PLUGIN_PALTFORM_REFRESSH_REGID);
}
}
}