智能工厂.apk(点击下载) / b.java


package cn.jpush.android.d;

import android.content.Context;
import android.content.Intent;
import android.text.TextUtils;
import androidx.core.view.PointerIconCompat;
import cn.jpush.android.api.CustomMessage;
import cn.jpush.android.api.JPushInterface;
import cn.jpush.android.cache.a;
import cn.jpush.android.helper.JCoreHelper;
import cn.jpush.android.helper.Logger;
import cn.jpush.android.helper.c;
import cn.jpush.android.local.JPushConstants;
import cn.jpush.android.p.d;
import java.io.LineNumberReader;
import java.io.StringReader;
import java.util.Locale;
import org.json.JSONObject;

public class b {
    public static CustomMessage a(Intent intent) {
        CustomMessage customMessage;
        Throwable th;
        try {
            String stringExtra = intent.getStringExtra("data");
            String stringExtra2 = intent.getStringExtra("msgid");
            JSONObject jSONObject = new JSONObject(stringExtra);
            customMessage = new CustomMessage();
            try {
                customMessage.messageId = stringExtra2;
                customMessage.appId = intent.getStringExtra("appId");
                customMessage.senderId = intent.getStringExtra("senderId");
                customMessage.message = jSONObject.optString("message", "");
                customMessage.contentType = jSONObject.optString("content_type", "");
                customMessage.title = jSONObject.optString("title", "");
                customMessage.extra = jSONObject.optString("extras", "");
            } catch (Throwable th2) {
                th = th2;
            }
        } catch (Throwable th3) {
            th = th3;
            customMessage = null;
            Logger.w("MessageHelper", "processMessage failed:" + th.getMessage());
            return customMessage;
        }
        return customMessage;
    }

    private static cn.jpush.android.b.b a(d dVar) {
        try {
            cn.jpush.android.b.b a = cn.jpush.android.b.b.a(new JSONObject(dVar.g).optJSONObject("geofence"));
            if (a == null) {
                return null;
            }
            a.t = dVar;
            return a;
        } catch (Throwable unused) {
            return null;
        }
    }

    private static void a(Context context, int i, long j, long j2) {
        JCoreHelper.sendData(context, JPushConstants.SDK_TYPE, 4, 2, j2, cn.jpush.android.r.b.a(0, (byte) i, j));
    }

    public static void a(Context context, int i, String str, String str2, String str3, long j, byte b) {
        if (!str2.equals(context.getPackageName())) {
            Logger.e("MessageHelper", "msg appId is not mine pkgname,appid:" + str2 + ",pkgname:" + context.getPackageName());
            return;
        }
        Logger.d("MessageHelper", "action:receivedPushMessage msgId = " + j);
        d a = d.a(str, str2, str3, j);
        if (a != null && !c.a(context, a.a()) && !d.a(context, a.c, a.f)) {
            a.ab = b;
            cn.jpush.android.b.b a2 = a(a);
            if (a2 == null || TextUtils.isEmpty(a2.a)) {
                a(context, a);
            } else {
                cn.jpush.android.b.d.a(context).a(a2);
            }
        }
    }

    public static void a(Context context, d dVar) {
        Logger.d("MessageHelper", "processBasicEntity type:" + dVar.e);
        dVar.e = dVar.i ? dVar.h == 4 ? 3 : 1 : 2;
        if ((dVar.e & 2) != 0) {
            Logger.d("MessageHelper", "processBasicEntity user-defined message.");
            if (!TextUtils.isEmpty(dVar.l) || !TextUtils.isEmpty(dVar.o)) {
                b(context, dVar);
            } else {
                Logger.ww("MessageHelper", "no message or extra send to user");
            }
        }
        if ((dVar.e & 1) != 0) {
            Logger.d("MessageHelper", "processBasicEntity notification");
            if (a.d(context)) {
                Logger.i("MessageHelper", "Service is stoped, give up all the message");
                return;
            }
            dVar.a(context);
            if (!cn.jpush.android.p.b.b(context)) {
                c.a(dVar.c, 986, context);
                Logger.ii("MessageHelper", "push is invalidPushTime,Intercept the message");
                return;
            }
            d.b(context, dVar.c);
            cn.jpush.android.p.b.a(context, dVar);
        }
    }

    public static void a(Context context, cn.jpush.android.r.c cVar) {
        a(context, cVar.a(), cVar.b(), cVar.getRid());
        long b = cVar.b();
        int a = cVar.a();
        String c = cVar.c();
        Logger.d("MessageHelper", "msgType = " + a + ", msgId = " + b);
        StringBuilder sb = new StringBuilder();
        sb.append("msgContent: \n");
        sb.append(c);
        Logger.v("MessageHelper", sb.toString());
        Logger.d("MessageHelper", "msgContent size:" + c.getBytes().length);
        LineNumberReader lineNumberReader = new LineNumberReader(new StringReader(c));
        try {
            String readLine = lineNumberReader.readLine();
            String readLine2 = lineNumberReader.readLine();
            if (readLine == null) {
                Logger.e("MessageHelper", "NO appId");
            } else if (readLine2 == null) {
                Logger.e("MessageHelper", "NO senderId");
            } else {
                int length = readLine.length() + readLine2.length() + 2;
                if (c.length() > length + 1) {
                    String substring = c.substring(length);
                    if (!readLine2.equals(JCoreHelper.getAppKey(context))) {
                        Logger.e("MessageHelper", "msg senderId is not mine appkey,senderId:" + readLine2 + ",appkey:" + JCoreHelper.getAppKey(context));
                        return;
                    }
                    Logger.v("MessageHelper", "Message Fields - appId:" + readLine + ", senderId:" + readLine2 + ", msgContent:" + substring);
                    if (!(a == 0 || a == 2)) {
                        if (a != 20) {
                            switch (a) {
                                case 100:
                                case 101:
                                    break;
                                default:
                                    Logger.ww("MessageHelper", "unkown msg type");
                                    return;
                            }
                        } else {
                            cn.jpush.android.s.a.a(context, substring, 0, -1L);
                            return;
                        }
                    }
                    a(context, a, substring, readLine, readLine2, b, (byte) 0);
                    return;
                }
                Logger.d("MessageHelper", "No msgContent");
            }
        } catch (Throwable th) {
            Logger.e("MessageHelper", "Parse msgContent failed", th);
        }
    }

    public static void b(Context context, d dVar) {
        try {
            String messageReceiverClass = JPushConstants.getMessageReceiverClass(context);
            if (!TextUtils.isEmpty(messageReceiverClass)) {
                Intent intent = new Intent(context, Class.forName(messageReceiverClass));
                intent.setAction(cn.jpush.android.u.a.e(context, "custom_msg"));
                intent.putExtra("data", dVar.g);
                intent.putExtra("msgid", dVar.c);
                intent.putExtra("appId", dVar.a);
                intent.putExtra("senderId", dVar.b);
                if (JPushConstants.getPushMessageReceiver(context) != null) {
                    JPushConstants.getPushMessageReceiver(context).onMessage(context, a(intent));
                } else {
                    context.sendBroadcast(intent);
                }
            } else {
                Logger.dd("MessageHelper", "not found user push message,use old action to user");
                Intent intent2 = new Intent(JPushInterface.ACTION_MESSAGE_RECEIVED);
                intent2.putExtra(JPushInterface.EXTRA_APP_KEY, dVar.b);
                intent2.putExtra(JPushInterface.EXTRA_MESSAGE, dVar.l);
                intent2.putExtra(JPushInterface.EXTRA_CONTENT_TYPE, dVar.m);
                intent2.putExtra(JPushInterface.EXTRA_TITLE, dVar.n);
                intent2.putExtra(JPushInterface.EXTRA_EXTRA, dVar.o);
                intent2.putExtra(JPushInterface.EXTRA_MSG_ID, dVar.c);
                intent2.addCategory(dVar.a);
                intent2.setPackage(context.getPackageName());
                context.sendBroadcast(intent2, String.format(Locale.ENGLISH, "%s.permission.JPUSH_MESSAGE", dVar.a));
                Logger.i("MessageHelper", "Send broadcast to app: " + String.format(Locale.ENGLISH, "%s.permission.JPUSH_MESSAGE", dVar.a));
            }
            if (dVar.ab != 0) {
                c.a(dVar.c, "", dVar.ab, PointerIconCompat.TYPE_ZOOM_IN, context);
            } else {
                c.a(dVar.c, PointerIconCompat.TYPE_ZOOM_IN, context);
            }
        } catch (Throwable th) {
            Logger.e("MessageHelper", "sendBroadcastToApp error:" + th.getMessage());
        }
    }
}