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


package com.xiaomi.mipush.sdk;

import android.app.ActivityManager;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.text.TextUtils;
import com.huawei.hms.support.api.entity.auth.AuthCode;
import com.meizu.cloud.pushsdk.constants.PushConstants;
import com.xiaomi.channel.commonutils.logger.b;
import com.xiaomi.mipush.sdk.PushMessageHandler;
import com.xiaomi.push.Cif;
import com.xiaomi.push.bp;
import com.xiaomi.push.bx;
import com.xiaomi.push.db;
import com.xiaomi.push.eo;
import com.xiaomi.push.ep;
import com.xiaomi.push.ez;
import com.xiaomi.push.hj;
import com.xiaomi.push.ho;
import com.xiaomi.push.ht;
import com.xiaomi.push.hv;
import com.xiaomi.push.hw;
import com.xiaomi.push.hx;
import com.xiaomi.push.hz;
import com.xiaomi.push.i;
import com.xiaomi.push.ia;
import com.xiaomi.push.ie;
import com.xiaomi.push.ig;
import com.xiaomi.push.ih;
import com.xiaomi.push.ii;
import com.xiaomi.push.ik;
import com.xiaomi.push.im;
import com.xiaomi.push.io;
import com.xiaomi.push.iq;
import com.xiaomi.push.is;
import com.xiaomi.push.it;
import com.xiaomi.push.iu;
import com.xiaomi.push.iz;
import com.xiaomi.push.service.aj;
import com.xiaomi.push.service.av;
import com.xiaomi.push.service.ax;
import com.xiaomi.push.service.ay;
import com.xiaomi.push.service.bh;
import com.xiaomi.push.service.bo;
import com.xiaomi.push.t;
import com.xiaomi.push.w;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Queue;
import java.util.TimeZone;

public class am {
    private static am a;

    /* renamed from: a  reason: collision with other field name */
    private static Object f6689a = new Object();

    /* renamed from: a  reason: collision with other field name */
    private static Queue<String> f6690a;

    /* renamed from: a  reason: collision with other field name */
    private Context f6691a;

    private am(Context context) {
        Context applicationContext = context.getApplicationContext();
        this.f6691a = applicationContext;
        if (applicationContext == null) {
            this.f6691a = context;
        }
    }

    public static Intent a(Context context, String str, Map<String, String> map, int i) {
        return aj.b(context, str, map, i);
    }

    private PushMessageHandler.a a(Cif ifVar, boolean z, byte[] bArr, String str, int i, Intent intent) {
        ep a2;
        String packageName;
        String a3;
        String str2;
        String str3;
        String str4;
        MiPushMessage miPushMessage;
        String str5;
        int i2;
        String str6;
        String str7;
        ep epVar;
        ArrayList arrayList = null;
        try {
            iu a4 = ai.a(this.f6691a, ifVar);
            if (a4 == null) {
                b.d("receiving an un-recognized message. " + ifVar.f7263a);
                ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "18");
                s.c(this.f6691a, ifVar, z);
                return null;
            }
            hj a5 = ifVar.a();
            b.m9051a("processing a message, action=" + a5);
            switch (an.a[a5.ordinal()]) {
                case 1:
                    if (!ifVar.m9509b()) {
                        b.d("receiving an un-encrypt message(SendMessage).");
                        return null;
                    } else if (!b.m9086a(this.f6691a).m9097e() || z) {
                        im imVar = (im) a4;
                        hv a6 = imVar.a();
                        if (a6 == null) {
                            b.d("receive an empty message without push content, drop it");
                            ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "22");
                            s.d(this.f6691a, ifVar, z);
                            return null;
                        }
                        int intExtra = intent.getIntExtra("notification_click_button", 0);
                        if (z) {
                            if (aj.m9665a(ifVar)) {
                                MiPushClient.reportIgnoreRegMessageClicked(this.f6691a, a6.m9449a(), ifVar.m9501a(), ifVar.f7270b, a6.b());
                            } else {
                                hw hwVar = ifVar.m9501a() != null ? new hw(ifVar.m9501a()) : new hw();
                                if (hwVar.m9458a() == null) {
                                    hwVar.a(new HashMap());
                                }
                                hwVar.m9458a().put("notification_click_button", String.valueOf(intExtra));
                                MiPushClient.reportMessageClicked(this.f6691a, a6.m9449a(), hwVar, a6.b());
                            }
                        }
                        if (!z) {
                            if (!TextUtils.isEmpty(imVar.d()) && MiPushClient.aliasSetTime(this.f6691a, imVar.d()) < 0) {
                                MiPushClient.addAlias(this.f6691a, imVar.d());
                            } else if (!TextUtils.isEmpty(imVar.c()) && MiPushClient.topicSubscribedTime(this.f6691a, imVar.c()) < 0) {
                                MiPushClient.addTopic(this.f6691a, imVar.c());
                            }
                        }
                        if (ifVar.f7264a == null || ifVar.f7264a.m9458a() == null) {
                            str4 = null;
                            str3 = null;
                        } else {
                            str4 = ifVar.f7264a.f7175a.get("jobkey");
                            str3 = str4;
                        }
                        if (TextUtils.isEmpty(str4)) {
                            str4 = a6.m9449a();
                        }
                        if (z || !m9070a(this.f6691a, str4)) {
                            MiPushMessage generateMessage = PushMessageHelper.generateMessage(imVar, ifVar.m9501a(), z);
                            if (generateMessage.getPassThrough() != 0 || z || !aj.m9666a(generateMessage.getExtra())) {
                                b.m9051a("receive a message, msgid=" + a6.m9449a() + ", jobkey=" + str4 + ", btn=" + intExtra);
                                String a7 = aj.a(generateMessage.getExtra(), intExtra);
                                if (!z || generateMessage.getExtra() == null || TextUtils.isEmpty(a7)) {
                                    miPushMessage = generateMessage;
                                } else {
                                    Map<String, String> extra = generateMessage.getExtra();
                                    if (!(intExtra == 0 || ifVar.m9501a() == null)) {
                                        ao.a(this.f6691a).a(ifVar.m9501a().c(), intExtra);
                                    }
                                    if (aj.m9665a(ifVar)) {
                                        Intent a8 = a(this.f6691a, ifVar.f7270b, extra, intExtra);
                                        a8.putExtra("eventMessageType", i);
                                        a8.putExtra("messageId", str);
                                        a8.putExtra("jobkey", str3);
                                        if (a8 == null) {
                                            b.m9051a("Getting Intent fail from ignore reg message. ");
                                            ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "23");
                                            return null;
                                        }
                                        String c = a6.c();
                                        if (!TextUtils.isEmpty(c)) {
                                            a8.putExtra("payload", c);
                                        }
                                        this.f6691a.startActivity(a8);
                                        s.a(this.f6691a, ifVar);
                                        ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, 3006, a7);
                                        return null;
                                    }
                                    Context context = this.f6691a;
                                    Intent a9 = a(context, context.getPackageName(), extra, intExtra);
                                    if (a9 == null) {
                                        return null;
                                    }
                                    if (!a7.equals(bh.c)) {
                                        a9.putExtra(PushMessageHelper.KEY_MESSAGE, generateMessage);
                                        a9.putExtra("eventMessageType", i);
                                        a9.putExtra("messageId", str);
                                        a9.putExtra("jobkey", str3);
                                    }
                                    this.f6691a.startActivity(a9);
                                    s.a(this.f6691a, ifVar);
                                    b.m9051a("start activity succ");
                                    ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, 1006, a7);
                                    if (!a7.equals(bh.c)) {
                                        return null;
                                    }
                                    ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, "13");
                                    return null;
                                }
                            } else {
                                aj.m9662a(this.f6691a, ifVar, bArr);
                                return null;
                            }
                        } else {
                            b.m9051a("drop a duplicate message, key=" + str4);
                            ep a10 = ep.a(this.f6691a);
                            String packageName2 = this.f6691a.getPackageName();
                            String a11 = eo.m9316a(i);
                            a10.c(packageName2, a11, str, "2:" + str4);
                            miPushMessage = null;
                        }
                        if (ifVar.m9501a() == null && !z) {
                            a(imVar, ifVar);
                        }
                        return miPushMessage;
                    } else {
                        b.m9051a("receive a message in pause state. drop it");
                        ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, "12");
                        return null;
                    }
                case 2:
                    ik ikVar = (ik) a4;
                    String str8 = b.m9086a(this.f6691a).f6707a;
                    if (TextUtils.isEmpty(str8) || !TextUtils.equals(str8, ikVar.m9530a())) {
                        b.m9051a("bad Registration result:");
                        ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "21");
                        return null;
                    }
                    b.m9086a(this.f6691a).f6707a = null;
                    int i3 = (ikVar.f7326a > 0 ? 1 : (ikVar.f7326a == 0 ? 0 : -1));
                    Context context2 = this.f6691a;
                    if (i3 == 0) {
                        b.m9086a(context2).b(ikVar.f7336e, ikVar.f7337f, ikVar.f7343l);
                        epVar = ep.a(this.f6691a);
                        str7 = this.f6691a.getPackageName();
                        str6 = eo.m9316a(i);
                        i2 = AuthCode.StatusCode.PERMISSION_EXPIRED;
                        str5 = "1";
                    } else {
                        epVar = ep.a(context2);
                        str7 = this.f6691a.getPackageName();
                        str6 = eo.m9316a(i);
                        i2 = AuthCode.StatusCode.PERMISSION_EXPIRED;
                        str5 = PushConstants.PUSH_TYPE_UPLOAD_LOG;
                    }
                    epVar.a(str7, str6, str, i2, str5);
                    if (!TextUtils.isEmpty(ikVar.f7336e)) {
                        arrayList = new ArrayList();
                        arrayList.add(ikVar.f7336e);
                    }
                    MiPushCommandMessage generateCommandMessage = PushMessageHelper.generateCommandMessage(ez.COMMAND_REGISTER.f6970a, arrayList, ikVar.f7326a, ikVar.f7335d, null);
                    ao.a(this.f6691a).m9084d();
                    return generateCommandMessage;
                case 3:
                    if (((iq) a4).f7402a == 0) {
                        b.m9086a(this.f6691a).m9088a();
                        MiPushClient.clearExtras(this.f6691a);
                    }
                    PushMessageHandler.a();
                    break;
                case 4:
                    io ioVar = (io) a4;
                    if (ioVar.f7377a == 0) {
                        MiPushClient.addTopic(this.f6691a, ioVar.b());
                    }
                    if (!TextUtils.isEmpty(ioVar.b())) {
                        arrayList = new ArrayList();
                        arrayList.add(ioVar.b());
                    }
                    b.e("resp-cmd:" + ez.COMMAND_SUBSCRIBE_TOPIC + ", " + ioVar.a());
                    return PushMessageHelper.generateCommandMessage(ez.COMMAND_SUBSCRIBE_TOPIC.f6970a, arrayList, ioVar.f7377a, ioVar.f7383d, ioVar.c());
                case 5:
                    is isVar = (is) a4;
                    if (isVar.f7422a == 0) {
                        MiPushClient.removeTopic(this.f6691a, isVar.b());
                    }
                    if (!TextUtils.isEmpty(isVar.b())) {
                        arrayList = new ArrayList();
                        arrayList.add(isVar.b());
                    }
                    b.e("resp-cmd:" + ez.COMMAND_UNSUBSCRIBE_TOPIC + ", " + isVar.a());
                    return PushMessageHelper.generateCommandMessage(ez.COMMAND_UNSUBSCRIBE_TOPIC.f6970a, arrayList, isVar.f7422a, isVar.f7428d, isVar.c());
                case 6:
                    db.a(this.f6691a.getPackageName(), this.f6691a, a4, hj.Command, bArr.length);
                    ie ieVar = (ie) a4;
                    String b = ieVar.b();
                    List<String> a12 = ieVar.m9495a();
                    if (ieVar.f7251a == 0) {
                        if (TextUtils.equals(b, ez.COMMAND_SET_ACCEPT_TIME.f6970a) && a12 != null && a12.size() > 1) {
                            MiPushClient.addAcceptTime(this.f6691a, a12.get(0), a12.get(1));
                            if (!"00:00".equals(a12.get(0)) || !"00:00".equals(a12.get(1))) {
                                b.m9086a(this.f6691a).a(false);
                            } else {
                                b.m9086a(this.f6691a).a(true);
                            }
                            a12 = a(TimeZone.getTimeZone("GMT+08"), TimeZone.getDefault(), a12);
                        } else if (TextUtils.equals(b, ez.COMMAND_SET_ALIAS.f6970a) && a12 != null && a12.size() > 0) {
                            MiPushClient.addAlias(this.f6691a, a12.get(0));
                        } else if (TextUtils.equals(b, ez.COMMAND_UNSET_ALIAS.f6970a) && a12 != null && a12.size() > 0) {
                            MiPushClient.removeAlias(this.f6691a, a12.get(0));
                        } else if (TextUtils.equals(b, ez.COMMAND_SET_ACCOUNT.f6970a) && a12 != null && a12.size() > 0) {
                            MiPushClient.addAccount(this.f6691a, a12.get(0));
                        } else if (TextUtils.equals(b, ez.COMMAND_UNSET_ACCOUNT.f6970a) && a12 != null && a12.size() > 0) {
                            MiPushClient.removeAccount(this.f6691a, a12.get(0));
                        } else if (TextUtils.equals(b, ez.COMMAND_CHK_VDEVID.f6970a)) {
                            if (a12 != null && a12.size() > 0) {
                                i.a(this.f6691a, a12.get(0));
                            }
                            return null;
                        }
                    }
                    b.e("resp-cmd:" + b + ", " + ieVar.a());
                    return PushMessageHelper.generateCommandMessage(b, a12, ieVar.f7251a, ieVar.f7259d, ieVar.c());
                case 7:
                    db.a(this.f6691a.getPackageName(), this.f6691a, a4, hj.Notification, bArr.length);
                    if (!(a4 instanceof ia)) {
                        if (a4 instanceof ii) {
                            ii iiVar = (ii) a4;
                            if (!"registration id expired".equalsIgnoreCase(iiVar.f7287d)) {
                                if (ht.ClientInfoUpdateOk.f7140a.equalsIgnoreCase(iiVar.f7287d)) {
                                    if (iiVar.m9517a() != null && iiVar.m9517a().containsKey("app_version")) {
                                        b.m9086a(this.f6691a).m9089a(iiVar.m9517a().get("app_version"));
                                        break;
                                    }
                                } else if (ht.AwakeApp.f7140a.equalsIgnoreCase(iiVar.f7287d)) {
                                    if (ifVar.m9509b() && iiVar.m9517a() != null && iiVar.m9517a().containsKey("awake_info")) {
                                        Context context3 = this.f6691a;
                                        o.a(context3, b.m9086a(context3).m9087a(), ax.a(this.f6691a).a(ho.AwakeInfoUploadWaySwitch.a(), 0), iiVar.m9517a().get("awake_info"));
                                        break;
                                    }
                                } else if (!ht.NormalClientConfigUpdate.f7140a.equalsIgnoreCase(iiVar.f7287d)) {
                                    if (!ht.CustomClientConfigUpdate.f7140a.equalsIgnoreCase(iiVar.f7287d)) {
                                        if (!ht.SyncInfoResult.f7140a.equalsIgnoreCase(iiVar.f7287d)) {
                                            if (!ht.ForceSync.f7140a.equalsIgnoreCase(iiVar.f7287d)) {
                                                if (!ht.CancelPushMessage.f7140a.equals(iiVar.f7287d)) {
                                                    if (!ht.HybridRegisterResult.f7140a.equals(iiVar.f7287d)) {
                                                        if (!ht.HybridUnregisterResult.f7140a.equals(iiVar.f7287d)) {
                                                            if (!ht.PushLogUpload.f7140a.equals(iiVar.f7287d)) {
                                                                if (!ht.DetectAppAlive.f7140a.equals(iiVar.f7287d)) {
                                                                    if (com.xiaomi.push.service.i.a(iiVar)) {
                                                                        b.b("receive notification handle by cpra");
                                                                        break;
                                                                    }
                                                                } else {
                                                                    b.b("receive detect msg");
                                                                    b(iiVar);
                                                                    break;
                                                                }
                                                            }
                                                        } else {
                                                            iq iqVar = new iq();
                                                            it.a(iqVar, iiVar.m9522a());
                                                            MiPushClient4Hybrid.onReceiveUnregisterResult(this.f6691a, iqVar);
                                                            break;
                                                        }
                                                    } else {
                                                        try {
                                                            ik ikVar2 = new ik();
                                                            it.a(ikVar2, iiVar.m9522a());
                                                            MiPushClient4Hybrid.onReceiveRegisterResult(this.f6691a, ikVar2);
                                                            break;
                                                        } catch (iz e) {
                                                            b.a(e);
                                                            break;
                                                        }
                                                    }
                                                } else {
                                                    b.e("resp-type:" + iiVar.f7287d + ", " + iiVar.m9516a());
                                                    if (iiVar.m9517a() != null) {
                                                        int i4 = -2;
                                                        if (iiVar.m9517a().containsKey(bh.L)) {
                                                            String str9 = iiVar.m9517a().get(bh.L);
                                                            if (!TextUtils.isEmpty(str9)) {
                                                                try {
                                                                    i4 = Integer.parseInt(str9);
                                                                } catch (NumberFormatException e2) {
                                                                    e2.printStackTrace();
                                                                }
                                                            }
                                                        }
                                                        if (i4 >= -1) {
                                                            MiPushClient.clearNotification(this.f6691a, i4);
                                                        } else {
                                                            MiPushClient.clearNotification(this.f6691a, iiVar.m9517a().containsKey(bh.J) ? iiVar.m9517a().get(bh.J) : "", iiVar.m9517a().containsKey(bh.K) ? iiVar.m9517a().get(bh.K) : "");
                                                        }
                                                    }
                                                    a(iiVar);
                                                    break;
                                                }
                                            } else {
                                                b.m9051a("receive force sync notification");
                                                av.a(this.f6691a, false);
                                                break;
                                            }
                                        } else {
                                            av.a(this.f6691a, iiVar);
                                            break;
                                        }
                                    } else {
                                        ig igVar = new ig();
                                        it.a(igVar, iiVar.m9522a());
                                        ay.a(ax.a(this.f6691a), igVar);
                                        break;
                                    }
                                } else {
                                    ih ihVar = new ih();
                                    try {
                                        it.a(ihVar, iiVar.m9522a());
                                        ay.a(ax.a(this.f6691a), ihVar);
                                        break;
                                    } catch (iz unused) {
                                        break;
                                    }
                                }
                            } else {
                                List<String> allAlias = MiPushClient.getAllAlias(this.f6691a);
                                List<String> allTopic = MiPushClient.getAllTopic(this.f6691a);
                                List<String> allUserAccount = MiPushClient.getAllUserAccount(this.f6691a);
                                String acceptTime = MiPushClient.getAcceptTime(this.f6691a);
                                b.e("resp-type:" + iiVar.f7287d + ", " + iiVar.m9516a());
                                MiPushClient.reInitialize(this.f6691a, hx.RegIdExpired);
                                for (String str10 : allAlias) {
                                    MiPushClient.removeAlias(this.f6691a, str10);
                                    MiPushClient.setAlias(this.f6691a, str10, null);
                                }
                                for (String str11 : allTopic) {
                                    MiPushClient.removeTopic(this.f6691a, str11);
                                    MiPushClient.subscribe(this.f6691a, str11, null);
                                }
                                for (String str12 : allUserAccount) {
                                    MiPushClient.removeAccount(this.f6691a, str12);
                                    MiPushClient.setUserAccount(this.f6691a, str12, null);
                                }
                                String[] split = acceptTime.split(Constants.ACCEPT_TIME_SEPARATOR_SP);
                                if (split.length == 2) {
                                    MiPushClient.removeAcceptTime(this.f6691a);
                                    MiPushClient.addAcceptTime(this.f6691a, split[0], split[1]);
                                    break;
                                }
                            }
                        }
                    } else {
                        ia iaVar = (ia) a4;
                        String a13 = iaVar.a();
                        b.e("resp-type:" + iaVar.b() + ", code:" + iaVar.f7221a + ", " + a13);
                        if (ht.DisablePushMessage.f7140a.equalsIgnoreCase(iaVar.f7228d)) {
                            if (iaVar.f7221a != 0) {
                                if ("syncing".equals(af.a(this.f6691a).a(au.DISABLE_PUSH))) {
                                    synchronized (af.class) {
                                        if (af.a(this.f6691a).m9069a(a13)) {
                                            if (af.a(this.f6691a).a(a13) < 10) {
                                                af.a(this.f6691a).b(a13);
                                                ao.a(this.f6691a).a(true, a13);
                                            } else {
                                                af.a(this.f6691a).c(a13);
                                            }
                                        }
                                    }
                                    break;
                                }
                            } else {
                                synchronized (af.class) {
                                    if (af.a(this.f6691a).m9069a(a13)) {
                                        af.a(this.f6691a).c(a13);
                                        if ("syncing".equals(af.a(this.f6691a).a(au.DISABLE_PUSH))) {
                                            af.a(this.f6691a).a(au.DISABLE_PUSH, "synced");
                                            MiPushClient.clearNotification(this.f6691a);
                                            MiPushClient.clearLocalNotificationType(this.f6691a);
                                            PushMessageHandler.a();
                                            ao.a(this.f6691a).m9081b();
                                        }
                                    }
                                }
                                break;
                            }
                        } else if (ht.EnablePushMessage.f7140a.equalsIgnoreCase(iaVar.f7228d)) {
                            if (iaVar.f7221a != 0) {
                                if ("syncing".equals(af.a(this.f6691a).a(au.ENABLE_PUSH))) {
                                    synchronized (af.class) {
                                        if (af.a(this.f6691a).m9069a(a13)) {
                                            if (af.a(this.f6691a).a(a13) < 10) {
                                                af.a(this.f6691a).b(a13);
                                                ao.a(this.f6691a).a(false, a13);
                                            } else {
                                                af.a(this.f6691a).c(a13);
                                            }
                                        }
                                    }
                                    break;
                                }
                            } else {
                                synchronized (af.class) {
                                    if (af.a(this.f6691a).m9069a(a13)) {
                                        af.a(this.f6691a).c(a13);
                                        if ("syncing".equals(af.a(this.f6691a).a(au.ENABLE_PUSH))) {
                                            af.a(this.f6691a).a(au.ENABLE_PUSH, "synced");
                                        }
                                    }
                                }
                                break;
                            }
                        } else if (!ht.ThirdPartyRegUpdate.f7140a.equalsIgnoreCase(iaVar.f7228d)) {
                            if (ht.UploadTinyData.f7140a.equalsIgnoreCase(iaVar.f7228d)) {
                                a(iaVar);
                                break;
                            }
                        } else {
                            b(iaVar);
                            break;
                        }
                        af.a(this.f6691a).c(a13);
                        break;
                    }
                    break;
            }
            return null;
        } catch (u e3) {
            b.a(e3);
            a(ifVar);
            a2 = ep.a(this.f6691a);
            packageName = this.f6691a.getPackageName();
            a3 = eo.m9316a(i);
            str2 = "19";
            a2.b(packageName, a3, str, str2);
            s.c(this.f6691a, ifVar, z);
            return null;
        } catch (iz e4) {
            b.a(e4);
            b.d("receive a message which action string is not valid. is the reg expired?");
            a2 = ep.a(this.f6691a);
            packageName = this.f6691a.getPackageName();
            a3 = eo.m9316a(i);
            str2 = "20";
            a2.b(packageName, a3, str, str2);
            s.c(this.f6691a, ifVar, z);
            return null;
        }
    }

    private PushMessageHandler.a a(Cif ifVar, byte[] bArr) {
        String str;
        String str2 = null;
        try {
            iu a2 = ai.a(this.f6691a, ifVar);
            if (a2 == null) {
                b.d("message arrived: receiving an un-recognized message. " + ifVar.f7263a);
                return null;
            }
            hj a3 = ifVar.a();
            b.m9051a("message arrived: processing an arrived message, action=" + a3);
            if (an.a[a3.ordinal()] != 1) {
                return null;
            }
            if (!ifVar.m9509b()) {
                str = "message arrived: receiving an un-encrypt message(SendMessage).";
            } else {
                im imVar = (im) a2;
                hv a4 = imVar.a();
                if (a4 == null) {
                    str = "message arrived: receive an empty message without push content, drop it";
                } else {
                    if (!(ifVar.f7264a == null || ifVar.f7264a.m9458a() == null)) {
                        str2 = ifVar.f7264a.f7175a.get("jobkey");
                    }
                    MiPushMessage generateMessage = PushMessageHelper.generateMessage(imVar, ifVar.m9501a(), false);
                    generateMessage.setArrivedMessage(true);
                    b.m9051a("message arrived: receive a message, msgid=" + a4.m9449a() + ", jobkey=" + str2);
                    return generateMessage;
                }
            }
            b.d(str);
            return null;
        } catch (u e) {
            b.a(e);
            str = "message arrived: receive a message but decrypt failed. report when click.";
        } catch (iz e2) {
            b.a(e2);
            str = "message arrived: receive a message which action string is not valid. is the reg expired?";
        }
    }

    public static am a(Context context) {
        if (a == null) {
            a = new am(context);
        }
        return a;
    }

    private void a() {
        SharedPreferences sharedPreferences = this.f6691a.getSharedPreferences("mipush_extra", 0);
        long currentTimeMillis = System.currentTimeMillis();
        if (Math.abs(currentTimeMillis - sharedPreferences.getLong(Constants.SP_KEY_LAST_REINITIALIZE, 0)) > 1800000) {
            MiPushClient.reInitialize(this.f6691a, hx.PackageUnregistered);
            sharedPreferences.edit().putLong(Constants.SP_KEY_LAST_REINITIALIZE, currentTimeMillis).commit();
        }
    }

    public static void a(Context context, String str) {
        synchronized (f6689a) {
            f6690a.remove(str);
            b.m9086a(context);
            SharedPreferences a2 = b.a(context);
            String a3 = bp.a(f6690a, Constants.ACCEPT_TIME_SEPARATOR_SP);
            SharedPreferences.Editor edit = a2.edit();
            edit.putString("pref_msg_ids", a3);
            t.a(edit);
        }
    }

    private void a(ia iaVar) {
        String a2 = iaVar.a();
        b.b("receive ack " + a2);
        Map<String, String> a3 = iaVar.m9482a();
        if (a3 != null) {
            String str = a3.get("real_source");
            if (!TextUtils.isEmpty(str)) {
                b.b("receive ack : messageId = " + a2 + "  realSource = " + str);
                bx.a(this.f6691a).a(a2, str, Boolean.valueOf(iaVar.f7221a == 0));
            }
        }
    }

    private void a(Cif ifVar) {
        b.m9051a("receive a message but decrypt failed. report now.");
        ii iiVar = new ii(ifVar.m9501a().f7173a, false);
        iiVar.c(ht.DecryptMessageFail.f7140a);
        iiVar.b(ifVar.m9502a());
        iiVar.d(ifVar.f7270b);
        iiVar.f7282a = new HashMap();
        iiVar.f7282a.put("regid", MiPushClient.getRegId(this.f6691a));
        ao.a(this.f6691a).a((iu) iiVar, hj.Notification, false, (hw) null);
    }

    private void a(ii iiVar) {
        ia iaVar = new ia();
        iaVar.c(ht.CancelPushMessageACK.f7140a);
        iaVar.a(iiVar.m9516a());
        iaVar.a(iiVar.a());
        iaVar.b(iiVar.b());
        iaVar.e(iiVar.c());
        iaVar.a(0);
        iaVar.d("success clear push message.");
        ao.a(this.f6691a).a(iaVar, hj.Notification, false, true, null, false, this.f6691a.getPackageName(), b.m9086a(this.f6691a).m9087a(), false);
    }

    private void a(im imVar, Cif ifVar) {
        hw a2 = ifVar.m9501a();
        if (a2 != null) {
            a2 = bo.a(a2.m9456a());
        }
        hz hzVar = new hz();
        hzVar.b(imVar.b());
        hzVar.a(imVar.m9537a());
        hzVar.a(imVar.a().a());
        if (!TextUtils.isEmpty(imVar.c())) {
            hzVar.c(imVar.c());
        }
        if (!TextUtils.isEmpty(imVar.d())) {
            hzVar.d(imVar.d());
        }
        hzVar.a(it.a(this.f6691a, ifVar));
        ao.a(this.f6691a).a(hzVar, hj.AckMessage, a2);
    }

    private void a(String str, long j, e eVar) {
        au a2 = l.a(eVar);
        if (a2 != null) {
            if (j == 0) {
                synchronized (af.class) {
                    if (af.a(this.f6691a).m9069a(str)) {
                        af.a(this.f6691a).c(str);
                        if ("syncing".equals(af.a(this.f6691a).a(a2))) {
                            af.a(this.f6691a).a(a2, "synced");
                        }
                    }
                }
            } else if ("syncing".equals(af.a(this.f6691a).a(a2))) {
                synchronized (af.class) {
                    if (af.a(this.f6691a).m9069a(str)) {
                        if (af.a(this.f6691a).a(str) < 10) {
                            af.a(this.f6691a).b(str);
                            ao.a(this.f6691a).a(str, a2, eVar);
                        } else {
                            af.a(this.f6691a).c(str);
                        }
                    }
                }
            } else {
                af.a(this.f6691a).c(str);
            }
        }
    }

    /* renamed from: a  reason: collision with other method in class */
    private static boolean m9070a(Context context, String str) {
        synchronized (f6689a) {
            b.m9086a(context);
            SharedPreferences a2 = b.a(context);
            if (f6690a == null) {
                String[] split = a2.getString("pref_msg_ids", "").split(Constants.ACCEPT_TIME_SEPARATOR_SP);
                f6690a = new LinkedList();
                for (String str2 : split) {
                    f6690a.add(str2);
                }
            }
            if (f6690a.contains(str)) {
                return true;
            }
            f6690a.add(str);
            if (f6690a.size() > 25) {
                f6690a.poll();
            }
            String a3 = bp.a(f6690a, Constants.ACCEPT_TIME_SEPARATOR_SP);
            SharedPreferences.Editor edit = a2.edit();
            edit.putString("pref_msg_ids", a3);
            t.a(edit);
            return false;
        }
    }

    /* renamed from: a  reason: collision with other method in class */
    private boolean m9071a(Cif ifVar) {
        Map<String, String> a2 = ifVar.m9501a() == null ? null : ifVar.m9501a().m9458a();
        if (a2 == null) {
            return false;
        }
        String str = a2.get(Constants.EXTRA_KEY_PUSH_SERVER_ACTION);
        return TextUtils.equals(str, Constants.EXTRA_VALUE_HYBRID_MESSAGE) || TextUtils.equals(str, Constants.EXTRA_VALUE_PLATFORM_MESSAGE);
    }

    private void b(ia iaVar) {
        long j;
        e eVar;
        b.c("ASSEMBLE_PUSH : " + iaVar.toString());
        String a2 = iaVar.a();
        Map<String, String> a3 = iaVar.m9482a();
        if (a3 != null) {
            String str = a3.get(Constants.ASSEMBLE_PUSH_REG_INFO);
            if (!TextUtils.isEmpty(str)) {
                if (str.contains("brand:" + ag.FCM.name())) {
                    b.m9051a("ASSEMBLE_PUSH : receive fcm token sync ack");
                    i.b(this.f6691a, e.ASSEMBLE_PUSH_FCM, str);
                    j = iaVar.f7221a;
                    eVar = e.ASSEMBLE_PUSH_FCM;
                } else {
                    if (str.contains("brand:" + ag.HUAWEI.name())) {
                        b.m9051a("ASSEMBLE_PUSH : receive hw token sync ack");
                        i.b(this.f6691a, e.ASSEMBLE_PUSH_HUAWEI, str);
                        j = iaVar.f7221a;
                        eVar = e.ASSEMBLE_PUSH_HUAWEI;
                    } else {
                        if (str.contains("brand:" + ag.OPPO.name())) {
                            b.m9051a("ASSEMBLE_PUSH : receive COS token sync ack");
                            i.b(this.f6691a, e.ASSEMBLE_PUSH_COS, str);
                            j = iaVar.f7221a;
                            eVar = e.ASSEMBLE_PUSH_COS;
                        } else {
                            if (str.contains("brand:" + ag.VIVO.name())) {
                                b.m9051a("ASSEMBLE_PUSH : receive FTOS token sync ack");
                                i.b(this.f6691a, e.ASSEMBLE_PUSH_FTOS, str);
                                a(a2, iaVar.f7221a, e.ASSEMBLE_PUSH_FTOS);
                                return;
                            }
                            return;
                        }
                    }
                }
                a(a2, j, eVar);
            }
        }
    }

    private void b(Cif ifVar) {
        hw a2 = ifVar.m9501a();
        if (a2 != null) {
            a2 = bo.a(a2.m9456a());
        }
        hz hzVar = new hz();
        hzVar.b(ifVar.m9502a());
        hzVar.a(a2.m9457a());
        hzVar.a(a2.m9455a());
        if (!TextUtils.isEmpty(a2.m9462b())) {
            hzVar.c(a2.m9462b());
        }
        hzVar.a(it.a(this.f6691a, ifVar));
        ao.a(this.f6691a).a((iu) hzVar, hj.AckMessage, false, a2);
    }

    private void b(ii iiVar) {
        String str;
        Map<String, String> a2 = iiVar.m9517a();
        if (a2 == null) {
            str = "detect failed because null";
        } else {
            String str2 = (String) av.a(a2, "pkgList", (Object) null);
            if (TextUtils.isEmpty(str2)) {
                str = "detect failed because empty";
            } else {
                try {
                    List<ActivityManager.RunningAppProcessInfo> runningAppProcesses = ((ActivityManager) this.f6691a.getSystemService(PushConstants.INTENT_ACTIVITY_NAME)).getRunningAppProcesses();
                    if (!w.a(runningAppProcesses)) {
                        String[] split = str2.split(Constants.ACCEPT_TIME_SEPARATOR_SP);
                        HashMap hashMap = new HashMap();
                        for (String str3 : split) {
                            String[] split2 = str3.split(Constants.WAVE_SEPARATOR);
                            if (split2.length >= 2) {
                                hashMap.put(split2[1], split2[0]);
                            }
                        }
                        w.a aVar = new w.a(Constants.WAVE_SEPARATOR, Constants.ACCEPT_TIME_SEPARATOR_SP);
                        for (ActivityManager.RunningAppProcessInfo runningAppProcessInfo : runningAppProcesses) {
                            if (hashMap.containsKey(runningAppProcessInfo.processName)) {
                                aVar.a((String) hashMap.get(runningAppProcessInfo.processName), String.valueOf(runningAppProcessInfo.importance));
                                hashMap.remove(runningAppProcessInfo.processName);
                            }
                        }
                        if (aVar.toString().length() > 0) {
                            ii iiVar2 = new ii();
                            iiVar2.a(iiVar.m9516a());
                            iiVar2.b(iiVar.b());
                            iiVar2.d(iiVar.c());
                            iiVar2.c(ht.DetectAppAliveResult.f7140a);
                            iiVar2.f7282a = new HashMap();
                            iiVar2.f7282a.put("alive", aVar.toString());
                            if (Boolean.parseBoolean((String) av.a(a2, "reportNotAliveApp", "false")) && hashMap.size() > 0) {
                                w.a aVar2 = new w.a("", Constants.ACCEPT_TIME_SEPARATOR_SP);
                                for (String str4 : hashMap.keySet()) {
                                    aVar2.a((String) hashMap.get(str4), "");
                                }
                                iiVar2.f7282a.put("notAlive", aVar2.toString());
                            }
                            ao.a(this.f6691a).a((iu) iiVar2, hj.Notification, false, (hw) null);
                            return;
                        }
                        b.b("detect failed because no alive process");
                        return;
                    }
                    b.m9051a("detect failed because params illegal");
                    return;
                } catch (Throwable th) {
                    str = "detect failed " + th;
                }
            }
        }
        b.m9051a(str);
    }

    public PushMessageHandler.a a(Intent intent) {
        String str;
        String str2;
        String str3;
        ep epVar;
        Throwable e;
        ep a2;
        String packageName;
        String format;
        String action = intent.getAction();
        b.m9051a("receive an intent from server, action=" + action);
        String stringExtra = intent.getStringExtra("mrt");
        if (stringExtra == null) {
            stringExtra = Long.toString(System.currentTimeMillis());
        }
        String stringExtra2 = intent.getStringExtra("messageId");
        int intExtra = intent.getIntExtra("eventMessageType", -1);
        if ("com.xiaomi.mipush.RECEIVE_MESSAGE".equals(action)) {
            byte[] byteArrayExtra = intent.getByteArrayExtra("mipush_payload");
            boolean booleanExtra = intent.getBooleanExtra("mipush_notified", false);
            if (byteArrayExtra == null) {
                b.d("receiving an empty message, drop");
                ep.a(this.f6691a).a(this.f6691a.getPackageName(), intent, "12");
                return null;
            }
            Cif ifVar = new Cif();
            try {
                it.a(ifVar, byteArrayExtra);
                b a3 = b.m9086a(this.f6691a);
                hw a4 = ifVar.m9501a();
                if (ifVar.a() == hj.SendMessage && a4 != null && !a3.m9097e() && !booleanExtra) {
                    a4.a("mrt", stringExtra);
                    a4.a("mat", Long.toString(System.currentTimeMillis()));
                    if (!m9071a(ifVar)) {
                        b(ifVar);
                    } else {
                        b.b("this is a mina's message, ack later");
                        a4.a(Constants.EXTRA_KEY_HYBRID_MESSAGE_TS, String.valueOf(a4.m9455a()));
                        a4.a(Constants.EXTRA_KEY_HYBRID_DEVICE_STATUS, String.valueOf((int) it.a(this.f6691a, ifVar)));
                    }
                }
                String str4 = "";
                if (ifVar.a() == hj.SendMessage && !ifVar.m9509b()) {
                    if (aj.m9665a(ifVar)) {
                        Object[] objArr = new Object[2];
                        objArr[0] = ifVar.b();
                        if (a4 != null) {
                            str4 = a4.m9457a();
                        }
                        objArr[1] = str4;
                        b.m9051a(String.format("drop an un-encrypted wake-up messages. %1$s, %2$s", objArr));
                        a2 = ep.a(this.f6691a);
                        packageName = this.f6691a.getPackageName();
                        format = String.format("13: %1$s", ifVar.b());
                    } else {
                        Object[] objArr2 = new Object[2];
                        objArr2[0] = ifVar.b();
                        if (a4 != null) {
                            str4 = a4.m9457a();
                        }
                        objArr2[1] = str4;
                        b.m9051a(String.format("drop an un-encrypted messages. %1$s, %2$s", objArr2));
                        a2 = ep.a(this.f6691a);
                        packageName = this.f6691a.getPackageName();
                        format = String.format("14: %1$s", ifVar.b());
                    }
                    a2.a(packageName, intent, format);
                    s.a(this.f6691a, ifVar, booleanExtra);
                    return null;
                } else if (ifVar.a() == hj.SendMessage && ifVar.m9509b() && aj.m9665a(ifVar) && (!booleanExtra || a4 == null || a4.m9458a() == null || !a4.m9458a().containsKey("notify_effect"))) {
                    Object[] objArr3 = new Object[2];
                    objArr3[0] = ifVar.b();
                    if (a4 != null) {
                        str4 = a4.m9457a();
                    }
                    objArr3[1] = str4;
                    b.m9051a(String.format("drop a wake-up messages which not has 'notify_effect' attr. %1$s, %2$s", objArr3));
                    ep.a(this.f6691a).a(this.f6691a.getPackageName(), intent, String.format("25: %1$s", ifVar.b()));
                    s.b(this.f6691a, ifVar, booleanExtra);
                    return null;
                } else if (a3.m9095c() || ifVar.f7263a == hj.Registration) {
                    if (!a3.m9095c() || !a3.m9098f()) {
                        return a(ifVar, booleanExtra, byteArrayExtra, stringExtra2, intExtra, intent);
                    }
                    if (ifVar.f7263a == hj.UnRegistration) {
                        a3.m9088a();
                        MiPushClient.clearExtras(this.f6691a);
                        PushMessageHandler.a();
                    } else {
                        s.e(this.f6691a, ifVar, booleanExtra);
                        MiPushClient.unregisterPush(this.f6691a);
                    }
                } else if (aj.m9665a(ifVar)) {
                    return a(ifVar, booleanExtra, byteArrayExtra, stringExtra2, intExtra, intent);
                } else {
                    s.e(this.f6691a, ifVar, booleanExtra);
                    boolean d = a3.m9096d();
                    b.d("receive message without registration. need re-register!registered?" + d);
                    ep.a(this.f6691a).a(this.f6691a.getPackageName(), intent, "15");
                    if (d) {
                        a();
                    }
                }
            } catch (iz e2) {
                e = e2;
                epVar = ep.a(this.f6691a);
                str3 = this.f6691a.getPackageName();
                str2 = "16";
                epVar.a(str3, intent, str2);
                b.a(e);
                return null;
            } catch (Exception e3) {
                e = e3;
                epVar = ep.a(this.f6691a);
                str3 = this.f6691a.getPackageName();
                str2 = "17";
                epVar.a(str3, intent, str2);
                b.a(e);
                return null;
            }
        } else if ("com.xiaomi.mipush.ERROR".equals(action)) {
            MiPushCommandMessage miPushCommandMessage = new MiPushCommandMessage();
            Cif ifVar2 = new Cif();
            try {
                byte[] byteArrayExtra2 = intent.getByteArrayExtra("mipush_payload");
                if (byteArrayExtra2 != null) {
                    it.a(ifVar2, byteArrayExtra2);
                }
            } catch (iz unused) {
            }
            miPushCommandMessage.setCommand(String.valueOf(ifVar2.a()));
            miPushCommandMessage.setResultCode((long) intent.getIntExtra("mipush_error_code", 0));
            miPushCommandMessage.setReason(intent.getStringExtra("mipush_error_msg"));
            b.d("receive a error message. code = " + intent.getIntExtra("mipush_error_code", 0) + ", msg= " + intent.getStringExtra("mipush_error_msg"));
            return miPushCommandMessage;
        } else if ("com.xiaomi.mipush.MESSAGE_ARRIVED".equals(action)) {
            byte[] byteArrayExtra3 = intent.getByteArrayExtra("mipush_payload");
            if (byteArrayExtra3 == null) {
                b.d("message arrived: receiving an empty message, drop");
                return null;
            }
            Cif ifVar3 = new Cif();
            try {
                it.a(ifVar3, byteArrayExtra3);
                b a5 = b.m9086a(this.f6691a);
                if (aj.m9665a(ifVar3)) {
                    str = "message arrived: receive ignore reg message, ignore!";
                } else if (!a5.m9095c()) {
                    str = "message arrived: receive message without registration. need unregister or re-register!";
                } else if (!a5.m9095c() || !a5.m9098f()) {
                    return a(ifVar3, byteArrayExtra3);
                } else {
                    str = "message arrived: app info is invalidated";
                }
                b.d(str);
            } catch (Exception e4) {
                b.d("fail to deal with arrived message. " + e4);
            }
        }
        return null;
    }

    public List<String> a(TimeZone timeZone, TimeZone timeZone2, List<String> list) {
        if (timeZone.equals(timeZone2)) {
            return list;
        }
        long rawOffset = (long) (((timeZone.getRawOffset() - timeZone2.getRawOffset()) / 1000) / 60);
        long parseLong = Long.parseLong(list.get(0).split(Constants.COLON_SEPARATOR)[0]);
        long parseLong2 = Long.parseLong(list.get(0).split(Constants.COLON_SEPARATOR)[1]);
        long j = ((((parseLong * 60) + parseLong2) - rawOffset) + 1440) % 1440;
        long parseLong3 = ((((Long.parseLong(list.get(1).split(Constants.COLON_SEPARATOR)[0]) * 60) + Long.parseLong(list.get(1).split(Constants.COLON_SEPARATOR)[1])) - 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(parseLong3 / 60), Long.valueOf(parseLong3 % 60)));
        return arrayList;
    }
}