package com.taobao.accs.data;
import android.content.Context;
import android.content.Intent;
import android.text.TextUtils;
import com.taobao.accs.IAppReceiver;
import com.taobao.accs.IAppReceiverV1;
import com.taobao.accs.base.AccsAbstractDataListener;
import com.taobao.accs.base.TaoBaseService;
import com.taobao.accs.client.GlobalClientInfo;
import com.taobao.accs.common.Constants;
import com.taobao.accs.common.ThreadPoolExecutorFactory;
import com.taobao.accs.net.b;
import com.taobao.accs.utl.ALog;
import com.taobao.accs.utl.BaseMonitor;
import com.taobao.accs.utl.UTMini;
import com.taobao.accs.utl.UtilityImpl;
import com.taobao.accs.utl.a;
import com.tencent.tauth.AuthActivity;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
/* compiled from: Taobao */
public class g {
/* renamed from: a reason: collision with root package name */
private static Set<String> f11408a;
/* renamed from: b reason: collision with root package name */
private static volatile g f11409b;
/* access modifiers changed from: protected */
public String b() {
return a.msgService;
}
public static g a() {
if (f11409b == null) {
synchronized (g.class) {
if (f11409b == null) {
f11409b = new g();
}
}
}
return f11409b;
}
public static void a(Context context, Intent intent) {
a(context, null, intent);
}
public static void a(Context context, b bVar, Intent intent) {
try {
ThreadPoolExecutorFactory.getScheduledExecutor().execute(new h(context, bVar, intent));
} catch (Throwable th) {
if (!(bVar == null || intent == null)) {
String stringExtra = intent.getStringExtra(Constants.KEY_CONFIG_TAG);
String stringExtra2 = intent.getStringExtra(Constants.KEY_DATA_ID);
if (!TextUtils.isEmpty(stringExtra) && !TextUtils.isEmpty(stringExtra2)) {
bVar.b(Message.a(stringExtra2, intent.getStringExtra(Constants.KEY_SERVICE_ID), bVar.b((String) null), 3), true);
}
}
ALog.e("MsgDistribute", "distribMessage", th, new Object[0]);
UTMini instance = UTMini.getInstance();
instance.commitEvent(66001, "MsgToBuss8", "distribMessage" + th.toString(), Integer.valueOf((int) Constants.SDK_VERSION_CODE));
}
}
/* JADX DEBUG: Failed to insert an additional move for type inference into block B:105:0x025c */
/* JADX WARN: Multi-variable type inference failed */
/* JADX WARN: Type inference failed for: r4v0 */
/* JADX WARN: Type inference failed for: r4v9 */
/* JADX WARN: Type inference failed for: r4v12 */
/* JADX WARN: Type inference failed for: r4v13 */
/* access modifiers changed from: private */
/* JADX WARNING: Removed duplicated region for block: B:132:0x02c1 */
/* JADX WARNING: Unknown variable types count: 1 */
public void b(Context context, b bVar, Intent intent) {
String str;
Object obj;
Object obj2;
char c;
String str2;
int i;
boolean z;
String str3;
int i2;
Throwable th;
boolean z2;
boolean z3;
boolean z4;
boolean z5;
int intExtra;
int i3;
IAppReceiver iAppReceiver;
String str4;
boolean z6;
boolean z7;
boolean z8;
String stringExtra = intent.getStringExtra(Constants.KEY_DATA_ID);
String stringExtra2 = intent.getStringExtra(Constants.KEY_SERVICE_ID);
String action = intent.getAction();
String str5 = "MsgDistribute";
?? r4 = 3;
String str6 = null;
if (ALog.isPrintLog(ALog.Level.D)) {
ALog.d(str5, "distribute ready", AuthActivity.ACTION_KEY, action, Constants.KEY_DATA_ID, stringExtra, Constants.KEY_SERVICE_ID, stringExtra2);
}
if (TextUtils.isEmpty(action)) {
if (bVar != null) {
bVar.b(Message.a(stringExtra, stringExtra2, bVar.b((String) null), 3), true);
}
ALog.e(str5, "action null", new Object[0]);
UTMini.getInstance().commitEvent(66001, "MsgToBuss9", "action null", Integer.valueOf((int) Constants.SDK_VERSION_CODE));
return;
}
try {
if (TextUtils.equals(action, Constants.ACTION_RECEIVE)) {
try {
intExtra = intent.getIntExtra("command", -1);
} catch (Throwable th2) {
th = th2;
str2 = null;
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
c = 2;
str6 = stringExtra2;
str3 = stringExtra;
i2 = 0;
z2 = true;
i = 4;
z = z2;
Object[] objArr = new Object[i];
objArr[0] = obj;
char c2 = z ? 1 : 0;
char c3 = z ? 1 : 0;
char c4 = z ? 1 : 0;
char c5 = z ? 1 : 0;
char c6 = z ? 1 : 0;
char c7 = z ? 1 : 0;
char c8 = z ? 1 : 0;
char c9 = z ? 1 : 0;
char c10 = z ? 1 : 0;
char c11 = z ? 1 : 0;
char c12 = z ? 1 : 0;
char c13 = z ? 1 : 0;
char c14 = z ? 1 : 0;
char c15 = z ? 1 : 0;
objArr[c2] = str3;
objArr[c] = obj2;
objArr[3] = str6;
ALog.e(str5, "distribMessage", th, objArr);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
try {
String stringExtra3 = intent.getStringExtra(Constants.KEY_USER_ID);
int intExtra2 = intent.getIntExtra(Constants.KEY_ERROR_CODE, 0);
String stringExtra4 = intent.getStringExtra(Constants.KEY_APP_KEY);
String stringExtra5 = intent.getStringExtra(Constants.KEY_CONFIG_TAG);
if (intent.getPackage() == null) {
try {
intent.setPackage(context.getPackageName());
} catch (Throwable th3) {
th = th3;
i2 = intExtra;
str6 = stringExtra2;
obj2 = Constants.KEY_SERVICE_ID;
str3 = stringExtra;
obj = Constants.KEY_DATA_ID;
str = "accs";
z7 = true;
}
}
try {
if ("accs".equals(stringExtra2)) {
i = 4;
try {
Object[] objArr2 = new Object[4];
objArr2[0] = "appkey";
objArr2[1] = stringExtra4;
objArr2[2] = "config";
objArr2[3] = stringExtra5;
ALog.e(str5, "distribute start", objArr2);
} catch (Throwable th4) {
th = th4;
i2 = intExtra;
str6 = stringExtra2;
obj2 = Constants.KEY_SERVICE_ID;
str3 = stringExtra;
obj = Constants.KEY_DATA_ID;
str = "accs";
z8 = true;
str2 = null;
z6 = z8;
c = 2;
z = z6;
Object[] objArr3 = new Object[i];
objArr3[0] = obj;
char c22 = z ? 1 : 0;
char c32 = z ? 1 : 0;
char c42 = z ? 1 : 0;
char c52 = z ? 1 : 0;
char c62 = z ? 1 : 0;
char c72 = z ? 1 : 0;
char c82 = z ? 1 : 0;
char c92 = z ? 1 : 0;
char c102 = z ? 1 : 0;
char c112 = z ? 1 : 0;
char c122 = z ? 1 : 0;
char c132 = z ? 1 : 0;
char c142 = z ? 1 : 0;
char c152 = z ? 1 : 0;
objArr3[c22] = str3;
objArr3[c] = obj2;
objArr3[3] = str6;
ALog.e(str5, "distribMessage", th, objArr3);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
} else {
ALog.d(str5, "distribute start", "appkey", stringExtra4, "config", stringExtra5);
}
if (!a(context, intent, stringExtra, stringExtra2)) {
if (intExtra < 0) {
if (bVar != null) {
try {
bVar.b(Message.a(stringExtra, stringExtra2, bVar.b((String) null), 3), true);
} catch (Throwable th5) {
th = th5;
str2 = null;
i2 = intExtra;
str6 = stringExtra2;
obj2 = Constants.KEY_SERVICE_ID;
str3 = stringExtra;
obj = Constants.KEY_DATA_ID;
str = "accs";
z6 = true;
i = 4;
c = 2;
z = z6;
Object[] objArr32 = new Object[i];
objArr32[0] = obj;
char c222 = z ? 1 : 0;
char c322 = z ? 1 : 0;
char c422 = z ? 1 : 0;
char c522 = z ? 1 : 0;
char c622 = z ? 1 : 0;
char c722 = z ? 1 : 0;
char c822 = z ? 1 : 0;
char c922 = z ? 1 : 0;
char c1022 = z ? 1 : 0;
char c1122 = z ? 1 : 0;
char c1222 = z ? 1 : 0;
char c1322 = z ? 1 : 0;
char c1422 = z ? 1 : 0;
char c1522 = z ? 1 : 0;
objArr32[c222] = str3;
objArr32[c] = obj2;
objArr32[3] = str6;
ALog.e(str5, "distribMessage", th, objArr32);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
}
String str7 = "command error:" + intExtra;
Object[] objArr4 = new Object[2];
objArr4[0] = Constants.KEY_SERVICE_ID;
z7 = true;
try {
objArr4[1] = stringExtra2;
ALog.e(str5, str7, objArr4);
} catch (Throwable th6) {
th = th6;
i2 = intExtra;
str6 = stringExtra2;
obj2 = Constants.KEY_SERVICE_ID;
str3 = stringExtra;
obj = Constants.KEY_DATA_ID;
str = "accs";
i = 4;
z8 = z7;
str2 = null;
z6 = z8;
c = 2;
z = z6;
Object[] objArr322 = new Object[i];
objArr322[0] = obj;
char c2222 = z ? 1 : 0;
char c3222 = z ? 1 : 0;
char c4222 = z ? 1 : 0;
char c5222 = z ? 1 : 0;
char c6222 = z ? 1 : 0;
char c7222 = z ? 1 : 0;
char c8222 = z ? 1 : 0;
char c9222 = z ? 1 : 0;
char c10222 = z ? 1 : 0;
char c11222 = z ? 1 : 0;
char c12222 = z ? 1 : 0;
char c13222 = z ? 1 : 0;
char c14222 = z ? 1 : 0;
char c15222 = z ? 1 : 0;
objArr322[c2222] = str3;
objArr322[c] = obj2;
objArr322[3] = str6;
ALog.e(str5, "distribMessage", th, objArr322);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
} else if (!a(intExtra, stringExtra2)) {
try {
if (!b(context, intent, stringExtra, stringExtra2)) {
Map<String, IAppReceiver> appReceiver = GlobalClientInfo.getInstance(context).getAppReceiver();
if (!TextUtils.isEmpty(stringExtra5)) {
iAppReceiver = appReceiver != null ? appReceiver.get(stringExtra5) : null;
str4 = stringExtra5;
} else {
str4 = stringExtra5;
iAppReceiver = null;
}
str2 = null;
c = 2;
try {
if (!a(context, stringExtra2, stringExtra, intent, iAppReceiver)) {
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
try {
a(context, bVar, intent, str4, stringExtra4, intExtra, stringExtra3, stringExtra2, stringExtra, iAppReceiver, intExtra2);
if (!TextUtils.isEmpty(stringExtra2)) {
a(context, bVar, iAppReceiver, intent, stringExtra2, stringExtra, intExtra, intExtra2);
} else {
a(context, appReceiver, intent, intExtra, intExtra2);
}
} catch (Throwable th7) {
th = th7;
str6 = stringExtra2;
i2 = intExtra;
str5 = str5;
str3 = stringExtra;
z2 = true;
i = 4;
z = z2;
Object[] objArr3222 = new Object[i];
objArr3222[0] = obj;
char c22222 = z ? 1 : 0;
char c32222 = z ? 1 : 0;
char c42222 = z ? 1 : 0;
char c52222 = z ? 1 : 0;
char c62222 = z ? 1 : 0;
char c72222 = z ? 1 : 0;
char c82222 = z ? 1 : 0;
char c92222 = z ? 1 : 0;
char c102222 = z ? 1 : 0;
char c112222 = z ? 1 : 0;
char c122222 = z ? 1 : 0;
char c132222 = z ? 1 : 0;
char c142222 = z ? 1 : 0;
char c152222 = z ? 1 : 0;
objArr3222[c22222] = str3;
objArr3222[c] = obj2;
objArr3222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr3222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
}
} catch (Throwable th8) {
th = th8;
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
str6 = stringExtra2;
str3 = stringExtra;
i2 = intExtra;
str5 = str5;
z2 = true;
i = 4;
z = z2;
Object[] objArr32222 = new Object[i];
objArr32222[0] = obj;
char c222222 = z ? 1 : 0;
char c322222 = z ? 1 : 0;
char c422222 = z ? 1 : 0;
char c522222 = z ? 1 : 0;
char c622222 = z ? 1 : 0;
char c722222 = z ? 1 : 0;
char c822222 = z ? 1 : 0;
char c922222 = z ? 1 : 0;
char c1022222 = z ? 1 : 0;
char c1122222 = z ? 1 : 0;
char c1222222 = z ? 1 : 0;
char c1322222 = z ? 1 : 0;
char c1422222 = z ? 1 : 0;
char c1522222 = z ? 1 : 0;
objArr32222[c222222] = str3;
objArr32222[c] = obj2;
objArr32222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr32222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
}
} catch (Throwable th9) {
th = th9;
i3 = intExtra;
str2 = null;
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
c = 2;
str6 = stringExtra2;
str3 = stringExtra;
i2 = i3;
z2 = true;
i = 4;
z = z2;
Object[] objArr322222 = new Object[i];
objArr322222[0] = obj;
char c2222222 = z ? 1 : 0;
char c3222222 = z ? 1 : 0;
char c4222222 = z ? 1 : 0;
char c5222222 = z ? 1 : 0;
char c6222222 = z ? 1 : 0;
char c7222222 = z ? 1 : 0;
char c8222222 = z ? 1 : 0;
char c9222222 = z ? 1 : 0;
char c10222222 = z ? 1 : 0;
char c11222222 = z ? 1 : 0;
char c12222222 = z ? 1 : 0;
char c13222222 = z ? 1 : 0;
char c14222222 = z ? 1 : 0;
char c15222222 = z ? 1 : 0;
objArr322222[c2222222] = str3;
objArr322222[c] = obj2;
objArr322222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr322222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
} else if (bVar != null) {
try {
bVar.b(Message.a(stringExtra, stringExtra2, bVar.b((String) null), 3), true);
} catch (Throwable th10) {
th = th10;
i2 = intExtra;
str2 = null;
}
}
}
} catch (Throwable th11) {
th = th11;
i3 = intExtra;
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
str2 = null;
c = 2;
str6 = stringExtra2;
str3 = stringExtra;
i2 = i3;
z2 = true;
i = 4;
z = z2;
Object[] objArr3222222 = new Object[i];
objArr3222222[0] = obj;
char c22222222 = z ? 1 : 0;
char c32222222 = z ? 1 : 0;
char c42222222 = z ? 1 : 0;
char c52222222 = z ? 1 : 0;
char c62222222 = z ? 1 : 0;
char c72222222 = z ? 1 : 0;
char c82222222 = z ? 1 : 0;
char c92222222 = z ? 1 : 0;
char c102222222 = z ? 1 : 0;
char c112222222 = z ? 1 : 0;
char c122222222 = z ? 1 : 0;
char c132222222 = z ? 1 : 0;
char c142222222 = z ? 1 : 0;
char c152222222 = z ? 1 : 0;
objArr3222222[c22222222] = str3;
objArr3222222[c] = obj2;
objArr3222222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr3222222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
} catch (Throwable th12) {
th = th12;
i3 = intExtra;
str2 = null;
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
c = 2;
str6 = stringExtra2;
str3 = stringExtra;
i2 = i3;
z2 = true;
i = 4;
z = z2;
Object[] objArr32222222 = new Object[i];
objArr32222222[0] = obj;
char c222222222 = z ? 1 : 0;
char c322222222 = z ? 1 : 0;
char c422222222 = z ? 1 : 0;
char c522222222 = z ? 1 : 0;
char c622222222 = z ? 1 : 0;
char c722222222 = z ? 1 : 0;
char c822222222 = z ? 1 : 0;
char c922222222 = z ? 1 : 0;
char c1022222222 = z ? 1 : 0;
char c1122222222 = z ? 1 : 0;
char c1222222222 = z ? 1 : 0;
char c1322222222 = z ? 1 : 0;
char c1422222222 = z ? 1 : 0;
char c1522222222 = z ? 1 : 0;
objArr32222222[c222222222] = str3;
objArr32222222[c] = obj2;
objArr32222222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr32222222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
} else {
str2 = null;
obj2 = Constants.KEY_SERVICE_ID;
obj = Constants.KEY_DATA_ID;
str = "accs";
c = 2;
if (bVar != null) {
try {
str6 = stringExtra2;
str3 = stringExtra;
r4 = 5;
} catch (Throwable th13) {
th = th13;
str6 = stringExtra2;
str3 = stringExtra;
z5 = true;
str5 = str5;
z3 = z5;
i2 = 0;
z2 = z3;
i = 4;
z = z2;
Object[] objArr322222222 = new Object[i];
objArr322222222[0] = obj;
char c2222222222 = z ? 1 : 0;
char c3222222222 = z ? 1 : 0;
char c4222222222 = z ? 1 : 0;
char c5222222222 = z ? 1 : 0;
char c6222222222 = z ? 1 : 0;
char c7222222222 = z ? 1 : 0;
char c8222222222 = z ? 1 : 0;
char c9222222222 = z ? 1 : 0;
char c10222222222 = z ? 1 : 0;
char c11222222222 = z ? 1 : 0;
char c12222222222 = z ? 1 : 0;
char c13222222222 = z ? 1 : 0;
char c14222222222 = z ? 1 : 0;
char c15222222222 = z ? 1 : 0;
objArr322222222[c2222222222] = str3;
objArr322222222[c] = obj2;
objArr322222222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr322222222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
try {
r4 = 1;
z4 = true;
bVar.b(Message.a(str3, str6, bVar.b((String) null), 5), true);
} catch (Throwable th14) {
th = th14;
z5 = r4;
str5 = str5;
z3 = z5;
i2 = 0;
z2 = z3;
i = 4;
z = z2;
Object[] objArr3222222222 = new Object[i];
objArr3222222222[0] = obj;
char c22222222222 = z ? 1 : 0;
char c32222222222 = z ? 1 : 0;
char c42222222222 = z ? 1 : 0;
char c52222222222 = z ? 1 : 0;
char c62222222222 = z ? 1 : 0;
char c72222222222 = z ? 1 : 0;
char c82222222222 = z ? 1 : 0;
char c92222222222 = z ? 1 : 0;
char c102222222222 = z ? 1 : 0;
char c112222222222 = z ? 1 : 0;
char c122222222222 = z ? 1 : 0;
char c132222222222 = z ? 1 : 0;
char c142222222222 = z ? 1 : 0;
char c152222222222 = z ? 1 : 0;
objArr3222222222[c22222222222] = str3;
objArr3222222222[c] = obj2;
objArr3222222222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr3222222222);
if (bVar != null) {
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
} else {
str6 = stringExtra2;
str3 = stringExtra;
z4 = true;
}
str5 = str5;
try {
ALog.e(str5, "distribMessage action error", new Object[0]);
UTMini.getInstance().commitEvent(66001, "MsgToBuss10", action, Integer.valueOf((int) Constants.SDK_VERSION_CODE));
} catch (Throwable th15) {
th = th15;
z3 = z4;
}
}
} catch (Throwable th16) {
th = th16;
str2 = null;
str6 = stringExtra2;
obj2 = Constants.KEY_SERVICE_ID;
str3 = stringExtra;
obj = Constants.KEY_DATA_ID;
str = "accs";
z3 = true;
c = 2;
i2 = 0;
z2 = z3;
i = 4;
z = z2;
Object[] objArr32222222222 = new Object[i];
objArr32222222222[0] = obj;
char c222222222222 = z ? 1 : 0;
char c322222222222 = z ? 1 : 0;
char c422222222222 = z ? 1 : 0;
char c522222222222 = z ? 1 : 0;
char c622222222222 = z ? 1 : 0;
char c722222222222 = z ? 1 : 0;
char c822222222222 = z ? 1 : 0;
char c922222222222 = z ? 1 : 0;
char c1022222222222 = z ? 1 : 0;
char c1122222222222 = z ? 1 : 0;
char c1222222222222 = z ? 1 : 0;
char c1322222222222 = z ? 1 : 0;
char c1422222222222 = z ? 1 : 0;
char c1522222222222 = z ? 1 : 0;
objArr32222222222[c222222222222] = str3;
objArr32222222222[c] = obj2;
objArr32222222222[3] = str6;
ALog.e(str5, "distribMessage", th, objArr32222222222);
if (bVar != null) {
bVar.b(Message.a(str3, str6, bVar.b(str2), 3), z);
}
com.taobao.accs.utl.b.a(str, BaseMonitor.ALARM_POINT_REQ_ERROR, str6, "1", "distribute error " + i2 + UtilityImpl.a(th));
}
}
/* access modifiers changed from: protected */
public boolean a(int i, String str) {
if (i != 100 && !GlobalClientInfo.AGOO_SERVICE_ID.equals(str)) {
long a2 = UtilityImpl.a();
if (a2 != -1 && a2 <= 5242880) {
com.taobao.accs.utl.b.a("accs", BaseMonitor.ALARM_POINT_REQ_ERROR, str, "1", "space low " + a2);
ALog.e("MsgDistribute", "user space low, don't distribute", "size", Long.valueOf(a2), Constants.KEY_SERVICE_ID, str);
return true;
}
}
return false;
}
/* access modifiers changed from: protected */
public boolean a(Context context, String str, String str2, Intent intent, IAppReceiver iAppReceiver) {
try {
if (TextUtils.isEmpty(str)) {
return false;
}
String str3 = null;
if (iAppReceiver != null) {
str3 = iAppReceiver.getService(str);
}
if (TextUtils.isEmpty(str3)) {
str3 = GlobalClientInfo.getInstance(context).getService(str);
}
if (!TextUtils.isEmpty(str3) || UtilityImpl.isMainProcess(context)) {
return false;
}
if ("accs".equals(str)) {
ALog.e("MsgDistribute", "start MsgDistributeService", Constants.KEY_DATA_ID, str2);
} else {
ALog.i("MsgDistribute", "start MsgDistributeService", Constants.KEY_DATA_ID, str2);
}
intent.setClassName(intent.getPackage(), b());
com.taobao.accs.a.a.a(context, intent, false);
return true;
} catch (Throwable th) {
ALog.e("MsgDistribute", "handleMsgInChannelProcess", th, new Object[0]);
return false;
}
}
private void a(Context context, b bVar, Intent intent, String str, String str2, int i, String str3, String str4, String str5, IAppReceiver iAppReceiver, int i2) {
if (ALog.isPrintLog(ALog.Level.D)) {
Object[] objArr = new Object[12];
objArr[0] = Constants.KEY_CONFIG_TAG;
objArr[1] = str;
objArr[2] = Constants.KEY_DATA_ID;
objArr[3] = str5;
objArr[4] = Constants.KEY_SERVICE_ID;
objArr[5] = str4;
objArr[6] = "command";
objArr[7] = Integer.valueOf(i);
objArr[8] = Constants.KEY_ERROR_CODE;
objArr[9] = Integer.valueOf(i2);
objArr[10] = "appReceiver";
objArr[11] = iAppReceiver == null ? null : iAppReceiver.getClass().getName();
ALog.d("MsgDistribute", "handleControlMsg", objArr);
}
if (iAppReceiver != null) {
if (i != 1) {
if (i == 2) {
if (i2 == 200) {
UtilityImpl.disableService(context);
}
iAppReceiver.onUnbindApp(i2);
} else if (i == 3) {
iAppReceiver.onBindUser(str3, i2);
} else if (i == 4) {
iAppReceiver.onUnbindUser(i2);
} else if (i != 100) {
if (i == 101 && TextUtils.isEmpty(str4)) {
ALog.d("MsgDistribute", "handleControlMsg serviceId isEmpty", new Object[0]);
byte[] byteArrayExtra = intent.getByteArrayExtra(Constants.KEY_DATA);
if (byteArrayExtra != null) {
iAppReceiver.onData(str3, str5, byteArrayExtra);
}
}
} else if (TextUtils.isEmpty(str4)) {
iAppReceiver.onSendData(str5, i2);
}
} else if (iAppReceiver instanceof IAppReceiverV1) {
((IAppReceiverV1) iAppReceiver).onBindApp(i2, null);
} else {
iAppReceiver.onBindApp(i2);
}
}
if (i == 1 && GlobalClientInfo.f11384b != null && str2 != null && str2.equals(GlobalClientInfo.f11384b.getAppkey())) {
ALog.d("MsgDistribute", "handleControlMsg agoo receiver onBindApp", new Object[0]);
GlobalClientInfo.f11384b.onBindApp(i2, null);
} else if (iAppReceiver == null && i != 104 && i != 103 && i != 100) {
if (bVar != null) {
bVar.b(Message.a(str5, str4, bVar.b((String) null), 0), true);
}
com.taobao.accs.utl.b.a("accs", BaseMonitor.ALARM_POINT_REQ_ERROR, str4, "1", "appReceiver null return");
UTMini.getInstance().commitEvent(66001, "MsgToBuss7", "commandId=" + i, "serviceId=" + str4 + " errorCode=" + i2 + " dataId=" + str5, Integer.valueOf((int) Constants.SDK_VERSION_CODE));
}
}
/* access modifiers changed from: protected */
public void a(Context context, b bVar, IAppReceiver iAppReceiver, Intent intent, String str, String str2, int i, int i2) {
ALog.i("MsgDistribute", "handleBusinessMsg start", Constants.KEY_DATA_ID, str2, Constants.KEY_SERVICE_ID, str, "command", Integer.valueOf(i));
String service = iAppReceiver != null ? iAppReceiver.getService(str) : null;
if (TextUtils.isEmpty(service)) {
service = GlobalClientInfo.getInstance(context).getService(str);
}
if (!TextUtils.isEmpty(service)) {
if (ALog.isPrintLog(ALog.Level.D)) {
ALog.d("MsgDistribute", "handleBusinessMsg to start service", "className", service);
}
intent.setClassName(context, service);
com.taobao.accs.a.a.a(context, intent, true);
} else {
AccsAbstractDataListener listener = GlobalClientInfo.getInstance(context).getListener(str);
if (listener != null) {
if (ALog.isPrintLog(ALog.Level.D)) {
ALog.d("MsgDistribute", "handleBusinessMsg getListener not null", new Object[0]);
}
AccsAbstractDataListener.onReceiveData(context, intent, listener);
} else {
if (bVar != null) {
bVar.b(Message.a(str2, str, bVar.b((String) null), 0), true);
}
ALog.e("MsgDistribute", "handleBusinessMsg getListener also null", new Object[0]);
com.taobao.accs.utl.b.a("accs", BaseMonitor.ALARM_POINT_REQ_ERROR, str, "1", "service is null");
}
}
UTMini.getInstance().commitEvent(66001, "MsgToBuss", "commandId=" + i, "serviceId=" + str + " errorCode=" + i2 + " dataId=" + str2, Integer.valueOf((int) Constants.SDK_VERSION_CODE));
StringBuilder sb = new StringBuilder();
sb.append("2commandId=");
sb.append(i);
sb.append("serviceId=");
sb.append(str);
com.taobao.accs.utl.b.a("accs", BaseMonitor.COUNT_POINT_TO_BUSS, sb.toString(), 0.0d);
}
/* access modifiers changed from: protected */
public void a(Context context, Map<String, IAppReceiver> map, Intent intent, int i, int i2) {
ALog.i("MsgDistribute", "handBroadCastMsg", "command", Integer.valueOf(i));
HashMap hashMap = new HashMap();
if (map != null) {
for (Map.Entry<String, IAppReceiver> entry : map.entrySet()) {
Map<String, String> allServices = entry.getValue().getAllServices();
if (allServices != null) {
hashMap.putAll(allServices);
}
}
}
if (i == 103) {
for (String str : hashMap.keySet()) {
if ("accs".equals(str) || "windvane".equals(str) || "motu-remote".equals(str)) {
String str2 = (String) hashMap.get(str);
if (TextUtils.isEmpty(str2)) {
str2 = GlobalClientInfo.getInstance(context).getService(str);
}
if (!TextUtils.isEmpty(str2)) {
intent.setClassName(context, str2);
com.taobao.accs.a.a.a(context, intent, true);
}
}
}
boolean booleanExtra = intent.getBooleanExtra(Constants.KEY_CONNECT_AVAILABLE, false);
String stringExtra = intent.getStringExtra(Constants.KEY_HOST);
String stringExtra2 = intent.getStringExtra(Constants.KEY_ERROR_DETAIL);
boolean booleanExtra2 = intent.getBooleanExtra(Constants.KEY_TYPE_INAPP, false);
boolean booleanExtra3 = intent.getBooleanExtra(Constants.KEY_CENTER_HOST, false);
TaoBaseService.ConnectInfo connectInfo = null;
if (!TextUtils.isEmpty(stringExtra)) {
if (booleanExtra) {
connectInfo = new TaoBaseService.ConnectInfo(stringExtra, booleanExtra2, booleanExtra3);
} else {
connectInfo = new TaoBaseService.ConnectInfo(stringExtra, booleanExtra2, booleanExtra3, i2, stringExtra2);
}
connectInfo.connected = booleanExtra;
}
if (connectInfo != null) {
ALog.d("MsgDistribute", "handBroadCastMsg ACTION_CONNECT_INFO", connectInfo);
Intent intent2 = new Intent(Constants.ACTION_CONNECT_INFO);
intent2.setPackage(context.getPackageName());
intent2.putExtra(Constants.KEY_CONNECT_INFO, connectInfo);
context.sendBroadcast(intent2);
return;
}
ALog.e("MsgDistribute", "handBroadCastMsg connect info null, host empty", new Object[0]);
} else if (i == 104) {
for (String str3 : hashMap.keySet()) {
String str4 = (String) hashMap.get(str3);
if (TextUtils.isEmpty(str4)) {
str4 = GlobalClientInfo.getInstance(context).getService(str3);
}
if (!TextUtils.isEmpty(str4)) {
intent.setClassName(context, str4);
com.taobao.accs.a.a.a(context, intent, true);
}
}
} else {
ALog.w("MsgDistribute", "handBroadCastMsg not handled command", new Object[0]);
}
}
private boolean a(Context context, Intent intent, String str, String str2) {
boolean z;
boolean booleanExtra = intent.getBooleanExtra("routingAck", false);
boolean booleanExtra2 = intent.getBooleanExtra("routingMsg", false);
if (booleanExtra) {
ALog.e("MsgDistribute", "recieve routiong ack", Constants.KEY_DATA_ID, str, Constants.KEY_SERVICE_ID, str2);
Set<String> set = f11408a;
if (set != null) {
set.remove(str);
}
com.taobao.accs.utl.b.a("accs", BaseMonitor.ALARM_MSG_ROUTING_RATE, "");
z = true;
} else {
z = false;
}
if (booleanExtra2) {
try {
String stringExtra = intent.getStringExtra(Constants.KEY_PACKAGE_NAME);
ALog.e("MsgDistribute", "send routiong ack", Constants.KEY_DATA_ID, str, "to pkg", stringExtra, Constants.KEY_SERVICE_ID, str2);
Intent intent2 = new Intent(Constants.ACTION_COMMAND);
intent2.putExtra("command", 106);
intent2.setClassName(stringExtra, a.channelService);
intent2.putExtra("routingAck", true);
intent2.putExtra(Constants.KEY_PACKAGE_NAME, stringExtra);
intent2.putExtra(Constants.KEY_DATA_ID, str);
com.taobao.accs.a.a.a(context, intent, false);
} catch (Throwable th) {
ALog.e("MsgDistribute", "send routing ack", th, Constants.KEY_SERVICE_ID, str2);
}
}
return z;
}
private boolean b(Context context, Intent intent, String str, String str2) {
if (context.getPackageName().equals(intent.getPackage())) {
return false;
}
try {
ALog.e("MsgDistribute", "start MsgDistributeService", "receive pkg", context.getPackageName(), "target pkg", intent.getPackage(), Constants.KEY_SERVICE_ID, str2);
intent.setClassName(intent.getPackage(), a.msgService);
intent.putExtra("routingMsg", true);
intent.putExtra(Constants.KEY_PACKAGE_NAME, context.getPackageName());
context.startService(intent);
if (f11408a == null) {
f11408a = new HashSet();
}
f11408a.add(str);
ThreadPoolExecutorFactory.schedule(new i(this, str, str2, intent), 10, TimeUnit.SECONDS);
} catch (Throwable th) {
com.taobao.accs.utl.b.a("accs", BaseMonitor.ALARM_MSG_ROUTING_RATE, "", com.umeng.analytics.pro.b.ao, th.toString());
ALog.e("MsgDistribute", "routing msg error, try election", th, Constants.KEY_SERVICE_ID, str2, Constants.KEY_DATA_ID, str);
}
return true;
}
}