OurPlay v5.5.9版本的 MD5 值为:d4e139798f4c2243a1145c8af5e21046

以下内容为反编译后的 InitObserver.java 源代码,内容仅作参考


package com.excelliance.kxqp.gs.main;

import android.accounts.Account;
import android.accounts.AccountManager;
import android.annotation.TargetApi;
import android.app.AlarmManager;
import android.app.Application;
import android.app.PendingIntent;
import android.content.Context;
import android.content.Intent;
import android.os.Handler;
import android.os.HandlerThread;
import android.support.v4.media.session.PlaybackStateCompat;
import android.text.TextUtils;
import android.util.Log;
import androidx.core.app.NotificationCompat;
import androidx.lifecycle.Lifecycle;
import androidx.lifecycle.LifecycleObserver;
import androidx.lifecycle.OnLifecycleEvent;
import com.alipay.sdk.util.i;
import com.android.spush.util.WebActionRouter;
import com.excean.bytedancebi.manager.BiManager;
import com.excelliance.kxqp.GameUtil;
import com.excelliance.kxqp.PlatSdk;
import com.excelliance.kxqp.SmtServService;
import com.excelliance.kxqp.VersionManager;
import com.excelliance.kxqp.api.f;
import com.excelliance.kxqp.background_resident.a.n;
import com.excelliance.kxqp.bitmap.bean.RankingItem;
import com.excelliance.kxqp.gs.bean.CooperationAPPContent;
import com.excelliance.kxqp.gs.bean.InitialGameBean;
import com.excelliance.kxqp.gs.discover.model.ResponseData;
import com.excelliance.kxqp.gs.g.ac;
import com.excelliance.kxqp.gs.g.x;
import com.excelliance.kxqp.gs.game.GameAttributesHelper;
import com.excelliance.kxqp.gs.main.ContainerFragment;
import com.excelliance.kxqp.gs.service.ProxyDelayService;
import com.excelliance.kxqp.gs.thpool.tp;
import com.excelliance.kxqp.gs.ui.add.AddGamesActivity;
import com.excelliance.kxqp.gs.ui.share.core.ui.BaseAssistActivity;
import com.excelliance.kxqp.gs.util.ai;
import com.excelliance.kxqp.gs.util.as;
import com.excelliance.kxqp.gs.util.au;
import com.excelliance.kxqp.gs.util.ay;
import com.excelliance.kxqp.gs.util.az;
import com.excelliance.kxqp.gs.util.bc;
import com.excelliance.kxqp.gs.util.bd;
import com.excelliance.kxqp.gs.util.bf;
import com.excelliance.kxqp.gs.util.bg;
import com.excelliance.kxqp.gs.util.bn;
import com.excelliance.kxqp.gs.util.bp;
import com.excelliance.kxqp.gs.util.by;
import com.excelliance.kxqp.gs.util.bz;
import com.excelliance.kxqp.gs.util.cb;
import com.excelliance.kxqp.gs.util.cc;
import com.excelliance.kxqp.gs.util.cd;
import com.excelliance.kxqp.gs.util.cf;
import com.excelliance.kxqp.gs.util.cn;
import com.excelliance.kxqp.gs.util.q;
import com.excelliance.kxqp.gs.util.s;
import com.excelliance.kxqp.platforms.ExcellianceAppInfo;
import com.excelliance.kxqp.sdk.StatisticsBase;
import com.excelliance.kxqp.sdk.StatisticsBuilder;
import com.excelliance.kxqp.sdk.StatisticsGS;
import com.excelliance.kxqp.util.aa;
import com.excelliance.kxqp.util.ab;
import com.excelliance.kxqp.util.ap;
import com.excelliance.user.account.f.e;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.ListIterator;
import java.util.Map;
import java.util.Set;
import org.apache.http.cookie.ClientCookie;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

public class InitObserver implements LifecycleObserver {

    private Context f7315a;

    private Handler f7316b;

    public InitObserver(Context context) {
        this.f7315a = context.getApplicationContext();
        HandlerThread handlerThread = new HandlerThread("InitObserver", 10);
        handlerThread.start();
        this.f7316b = new Handler(handlerThread.getLooper());
    }

    @OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
    public void initWork() {
        az.d("InitObserver", String.format("InitObserver/initWork:thread(%s)", Thread.currentThread().getName()));
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                PlatSdk.h(InitObserver.this.f7315a.getApplicationContext());
            }
        });
        StatisticsBuilder.getInstance().builder().setDescription("initWork").setPriKey1(148000).setPriKey2(12).setIntKey0().build(this.f7315a);
        tp.f(new Runnable() {
            @Override
            public void run() {
                VersionManager.getInstance().i(InitObserver.this.f7315a.getApplicationContext());
                VersionManager.getInstance().j(InitObserver.this.f7315a.getApplicationContext());
                VersionManager.getInstance().k(InitObserver.this.f7315a.getApplicationContext());
                if (com.excelliance.kxqp.gs.router.a.a.d.isCopyFromAsset()) {
                    return;
                }
                VersionManager.getInstance().l(InitObserver.this.f7315a.getApplicationContext());
            }
        });
        b();
        d();
        g();
        f(this.f7315a.getApplicationContext());
        g(this.f7315a.getApplicationContext());
        n(this.f7315a.getApplicationContext());
        j(this.f7315a.getApplicationContext());
        p(this.f7315a);
        h();
        i();
        a();
        a(this.f7315a, new Intent());
        q(this.f7315a);
        r(this.f7315a);
        a(this.f7315a);
        s(this.f7315a);
        b(this.f7315a);
        a(this.f7315a, 1);
        t(this.f7315a);
        u(this.f7315a);
        v(this.f7315a);
        w(this.f7315a);
        j();
        e();
        x(this.f7315a);
        y(this.f7315a);
        z(this.f7315a);
        A(this.f7315a);
        B(this.f7315a);
        k();
        C(this.f7315a);
        c(this.f7315a);
        d(this.f7315a);
        f();
        GameAttributesHelper.getInstance().a(this.f7315a, true);
        Runnable runnable = new Runnable() {
            @Override
            public void run() {
                InitObserver.this.a(com.excelliance.kxqp.repository.a.a(InitObserver.this.f7315a).b());
            }
        };
        e(this.f7315a.getApplicationContext());
        i(this.f7315a.getApplicationContext());
        k(this.f7315a.getApplicationContext());
        m(this.f7315a);
        this.f7316b.post(runnable);
        l(this.f7315a.getApplicationContext());
        o(this.f7315a.getApplicationContext());
        h(this.f7315a);
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                StatisticsBuilder.getInstance().builder().setDescription("广告相关-最后一个交互").setPriKey1(148000).setPriKey2(7).setIntKey0().buildImmediate(InitObserver.this.f7315a.getApplicationContext());
            }
        });
        c();
    }

    private void c() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                ab.a(InitObserver.this.f7315a, f.b(InitObserver.this.f7315a));
            }
        });
    }

    private void d() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                if (by.a(InitObserver.this.f7315a, "extractInfo").b("sp_extractInfo_log_enable", false).booleanValue()) {
                    cf.a(InitObserver.this.f7315a, "已开启日志", 0);
                    Intent intent = new Intent();
                    intent.setAction("notification_clicked_action");
                    intent.putExtra("type", 0);
                    aa.a(InitObserver.this.f7315a, null, "日志收集", "日志收集中...点击完成日志收集", PendingIntent.getBroadcast(InitObserver.this.f7315a, 0, intent, 134217728), 3, 233, true, true);
                }
            }
        });
    }

    private void e() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                List<ExcellianceAppInfo> b2 = com.excelliance.kxqp.repository.a.a(InitObserver.this.f7315a).b();
                if (s.a(b2)) {
                    return;
                }
                for (ExcellianceAppInfo excellianceAppInfo : b2) {
                    boolean z = !TextUtils.isEmpty(excellianceAppInfo.getPath()) && new File(excellianceAppInfo.getPath()).exists();
                    if (au.a().u(excellianceAppInfo.getAppPackageName()) && !as.i(InitObserver.this.f7315a, excellianceAppInfo.getAppPackageName()) && !z) {
                        com.excelliance.kxqp.repository.a.a(InitObserver.this.f7315a).a(excellianceAppInfo.getAppPackageName());
                    }
                }
            }
        });
    }

    public void a(List<ExcellianceAppInfo> list) {
        if (list == null || list.size() == 0) {
            return;
        }
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < list.size(); i++) {
            sb.append(list.get(i).getAppPackageName());
            if (i != list.size() - 1) {
                sb.append(i.f491b);
            }
        }
        ProxyDelayService.b(this.f7315a, sb.toString());
    }

    private void f() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                com.excelliance.kxqp.repository.a.a(InitObserver.this.f7315a).f();
                com.excelliance.kxqp.repository.a.a(InitObserver.this.f7315a).g();
            }
        });
    }

    private void g() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/initGlide:thread(%s)", Thread.currentThread().getName()));
                com.bumptech.glide.i.b(InitObserver.this.f7315a);
            }
        });
    }

    @OnLifecycleEvent(Lifecycle.Event.ON_DESTROY)
    public void cancelWork() {
        az.d("InitObserver", String.format("InitObserver/cancelWork:thread(%s)", Thread.currentThread().getName()));
        this.f7316b.getLooper().quit();
    }

    private void h() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/initYuedong:thread(%s)", Thread.currentThread().getName()));
                ac.a().b(InitObserver.this.f7315a.getApplicationContext());
            }
        });
    }

    private void i() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/initMarketSwitch:thread(%s)", Thread.currentThread().getName()));
                as.l(InitObserver.this.f7315a.getApplicationContext());
            }
        });
    }

    public void a() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/getRemoteUpdateList:thread(%s)", Thread.currentThread().getName()));
                com.excelliance.kxqp.gs.ui.update.b.d(InitObserver.this.f7315a).c(InitObserver.this.f7315a);
            }
        });
    }

    private void a(final Context context, final Intent intent) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/getOauthId:thread(%s)", Thread.currentThread().getName()));
                int intExtra = intent.getIntExtra("judge", 1);
                String stringExtra = intent.getStringExtra("idAuth");
                String stringExtra2 = intent.getStringExtra("account");
                String stringExtra3 = intent.getStringExtra("rip");
                String stringExtra4 = intent.getStringExtra("rport");
                HashMap hashMap = new HashMap();
                hashMap.put("id", TextUtils.isEmpty(stringExtra) ? "" : stringExtra.trim());
                hashMap.put("account", TextUtils.isEmpty(stringExtra2) ? "" : stringExtra2.trim());
                if (!TextUtils.isEmpty(stringExtra3) && !TextUtils.isEmpty(stringExtra4)) {
                    hashMap.put("rip", stringExtra3);
                    hashMap.put("rport", stringExtra4);
                }
                az.d("InitObserver", "getOauthId judge: " + intExtra + " idAuth: " + stringExtra + " account: " + stringExtra2 + " oauthId: " + as.a(context, intExtra, (HashMap<String, String>) hashMap));
                if (intExtra != 3 || TextUtils.isEmpty(stringExtra) || TextUtils.isEmpty(stringExtra2)) {
                    return;
                }
                StatisticsGS.getInstance().uploadUserAction(context, StatisticsBase.UA_GOOGLE_ACCOUNT_OPERATION, 1, stringExtra2);
                bz.a().k(InitObserver.this.f7315a.getApplicationContext());
            }
        });
    }

    private void q(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/initExtra:thread(%s)", Thread.currentThread().getName()));
                try {
                    by a2 = by.a(context, "sp_total_info");
                    long a3 = a2.a("sp_pull_extra_gameinfo_time_out", (Long) 0L);
                    if (a3 == 0 || System.currentTimeMillis() - a3 > 7200000) {
                        String d = as.d(context);
                        try {
                            if (!TextUtils.isEmpty(d)) {
                                az.d("InitObserver", "initExtra");
                                List<String> b2 = ay.b(d);
                                if (b2.size() > 0) {
                                    com.excelliance.kxqp.gs.c.b a4 = com.excelliance.kxqp.gs.c.b.a(context);
                                    a4.c();
                                    a4.a(b2);
                                }
                                a2.a("sp_pull_extra_gameinfo_time_out", System.currentTimeMillis());
                            }
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                        try {
                            List<String> b3 = ay.b(context, d);
                            if (b3.size() > 0) {
                                by a5 = by.a(context, "SP_UNPRESTART_GAME_LIST");
                                a5.d();
                                Iterator<String> it = b3.iterator();
                                while (it.hasNext()) {
                                    a5.a(it.next(), false);
                                }
                            }
                        } catch (Exception e2) {
                            e2.printStackTrace();
                        }
                        try {
                            List<String> c = ay.c(context, d);
                            if (c.size() > 0) {
                                by a6 = by.a(context, "SP_ALLOW_INNER_INSTALL");
                                a6.d();
                                Iterator<String> it2 = c.iterator();
                                while (it2.hasNext()) {
                                    a6.a(it2.next(), true);
                                }
                            }
                        } catch (Exception e3) {
                            e3.printStackTrace();
                        }
                        String d2 = ay.d(d, context);
                        if (TextUtils.isEmpty(d2)) {
                            return;
                        }
                        by.a(context, "sp_gp_down_address").a("sp_gp_down_address", com.excelliance.kxqp.gs.util.c.a(d2));
                    }
                } catch (Exception e4) {
                    e4.getMessage();
                }
            }
        });
    }

    private void r(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/initAPPCooperationExtra:thread(%s)", Thread.currentThread().getName()));
                if (by.a(context, "sp_app_cooperation_info").d()) {
                    az.d("InitObserver", "enter  initAPPCooperationExtra");
                    String jSONObject = cn.i(context).toString();
                    az.d("InitObserver", "request: " + jSONObject);
                    az.d("InitObserver", "encry request: " + cn.b(jSONObject));
                    String a2 = bd.a("https://api.ourplay.com.cn/rank/partner", jSONObject);
                    if (!cd.a(a2)) {
                        String a3 = cn.a(a2);
                        az.d("InitObserver", "response: " + a3);
                        try {
                            JSONObject jSONObject2 = new JSONObject(a3);
                            int optInt = jSONObject2.optInt("code");
                            if (optInt != 0) {
                                az.d("InitObserver", "code" + optInt + "msg: " + jSONObject2.optString("msg"));
                                return;
                            }
                            JSONArray optJSONArray = jSONObject2.optJSONArray("data");
                            if (optJSONArray != null) {
                                List<CooperationAPPContent> a4 = ay.a(optJSONArray);
                                if (a4 != null && a4.size() > 0) {
                                    by a5 = by.a(context, "sp_app_cooperation_info");
                                    HashMap hashMap = new HashMap();
                                    for (int i = 0; i < a4.size(); i++) {
                                        if (!cd.a(a4.get(i).getContent())) {
                                            hashMap.put(a4.get(i).getPkg_name(), a4.get(i).getContent());
                                        }
                                    }
                                    az.d("InitObserver", "put data");
                                    a5.a(hashMap);
                                    return;
                                }
                                az.d("InitObserver", "resultList is null ");
                                return;
                            }
                            az.d("InitObserver", "data is null ");
                            return;
                        } catch (Exception e) {
                            e.printStackTrace();
                            return;
                        }
                    }
                    az.d("InitObserver", "response data empty");
                    return;
                }
                az.d("InitObserver", "clear extra app cooperation fail!");
            }
        });
    }

    public void a(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                String str;
                az.d("InitObserver", String.format("InitObserver/initialGame:thread(%s)", Thread.currentThread().getName()));
                boolean booleanValue = by.a(context, "sp_total_info").b("sp_initial_game", false).booleanValue();
                Log.d("InitObserver", "[initialGame:" + booleanValue);
                if (booleanValue) {
                    return;
                }
                try {
                    String a2 = com.excelliance.kxqp.gs.util.f.a(new File(com.excelliance.kxqp.gs.ui.make_money.f.a(context)));
                    Log.d("InitObserver", "initialGame: " + a2);
                    if (TextUtils.isEmpty(a2)) {
                        if (by.a(context, "switcher").b("switcher", "false").contains("true") && !TextUtils.isEmpty("")) {
                            str = "";
                        }
                        return;
                    }
                    String a3 = bp.a(a2, "fuck_snsslmm_bslznw", "utf-8");
                    JSONObject jSONObject = new JSONObject(a3);
                    String optString = jSONObject.optString("sharelib");
                    az.d("InitObserver", "initialGame decrypt: " + a3 + " | sharelib: " + optString);
                    StringBuilder sb = new StringBuilder();
                    sb.append("decrypt : ");
                    sb.append(a3);
                    e.a("InitObserver", sb.toString());
                    if ("invitePlayGame".equals(jSONObject.optString("cmd"))) {
                        String optString2 = jSONObject.optString(BiManager.UQID);
                        Log.d("InitObserver", "initialGame apk: save uqid" + optString2);
                        by.a(InitObserver.this.f7315a, "sp_config").a("friends_quid", optString2);
                        com.excelliance.kxqp.bitmap.ui.b.a().b(new ContainerFragment.a());
                    }
                    str = optString;
                    if (cd.a(str)) {
                        return;
                    }
                    String c = as.c(context, str);
                    if (TextUtils.isEmpty(c)) {
                        return;
                    }
                    InitialGameBean f = ay.f(c);
                    Log.d("InitObserver", "---- bean: " + f);
                    if (f.isNull()) {
                        return;
                    }
                    Intent intent = new Intent();
                    String j = bn.j(context);
                    String str2 = f.getMd5() + ".png";
                    ai.a(f.getPic(), j, str2);
                    intent.setAction(context.getPackageName() + ".download.app.from.shared.pkg");
                    intent.putExtra(WebActionRouter.KEY_PKG, f.getLib());
                    intent.putExtra("image", j + str2);
                    intent.putExtra("name", f.getAppTitle());
                    context.sendBroadcast(intent);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    private void s(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/checkLocalImport:thread(%s)", Thread.currentThread().getName()));
                List<ExcellianceAppInfo> n = as.n(context);
                if (s.a(n)) {
                    return;
                }
                ListIterator<ExcellianceAppInfo> listIterator = n.listIterator();
                StringBuilder sb = new StringBuilder();
                while (listIterator.hasNext()) {
                    ExcellianceAppInfo next = listIterator.next();
                    if (TextUtils.equals(next.getGameType(), String.valueOf(5)) && next.getDownloadStatus() != 8) {
                        sb.append(next.getAppPackageName());
                        sb.append(i.f491b);
                    }
                }
                int lastIndexOf = sb.lastIndexOf(i.f491b);
                if (lastIndexOf != -1) {
                    sb.deleteCharAt(lastIndexOf);
                }
                if (sb.toString().trim().split(i.f491b).length <= 0) {
                    return;
                }
                AddGamesActivity.a(context, sb.toString(), false, 6, null);
            }
        });
    }

    public void b(final Context context) {
        tp.f(new Runnable() {
            @Override
            public void run() {
                com.excelliance.kxqp.gs.l.f.a(context).a(true);
            }
        });
    }

    private void a(final Context context, final int i) {
        tp.d(new Runnable() {
            @Override
            public void run() {
                boolean z;
                by a2 = by.a(context, "sp_total_info");
                if (a2.b(".hide.register.google.account", false).booleanValue()) {
                    az.d("InitObserver", "signAccountSuccess: " + a2.c(".user.back.count", 0));
                    return;
                }
                if (i == 1) {
                    if (!GameUtil.b()) {
                        PlatSdk.getInstance().initVM((Application) context.getApplicationContext());
                    }
                    List<com.excelliance.kxqp.gs.ui.account.c> list = null;
                    int i2 = 3;
                    while (i2 > 0) {
                        list = as.f();
                        if (list != null && list.size() > 0) {
                            break;
                        }
                        i2--;
                        try {
                            Thread.sleep(1000L);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    az.d("InitObserver", "startAppGame allAccounts: " + list);
                    if (list == null || list.size() <= 0) {
                        z = false;
                        if (z) {
                            return;
                        }
                        a2.a(".hide.register.google.account", true);
                        cb.a(false, 1, context);
                        if (a2.b("login.success.account", false).booleanValue()) {
                            cb.a(true, 2, context);
                        }
                        Intent intent = new Intent();
                        intent.setAction(context.getPackageName() + VersionManager.q);
                        context.sendBroadcast(intent);
                        return;
                    }
                }
                z = true;
                if (z) {
                }
            }
        });
    }

    private void t(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/registerAlarm:thread(%s)", Thread.currentThread().getName()));
                try {
                    AlarmManager alarmManager = (AlarmManager) context.getSystemService(NotificationCompat.CATEGORY_ALARM);
                    Intent intent = new Intent();
                    intent.setClass(context, SmtServService.class);
                    intent.setAction(InitObserver.this.f7315a.getPackageName() + ".upload.target.game.lib");
                    alarmManager.set(1, System.currentTimeMillis() + 60000, PendingIntent.getService(context, 10001001, intent, 1073741824));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    private void u(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                boolean z = false;
                az.d("InitObserver", String.format("InitObserver/refreshGoogleAccUi:thread(%s)", Thread.currentThread().getName()));
                String g = as.g(context);
                if (!TextUtils.isEmpty(g)) {
                    try {
                        z = new JSONObject(g).optBoolean("show");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
                az.d("InitObserver", "run allowShow: " + z);
                by.a(context, "sp_total_info").a("SP_GOOGLE_ACCOUNT_ENTRANCE", z);
                String packageName = context.getPackageName();
                try {
                    Intent intent = new Intent();
                    intent.setAction(packageName + VersionManager.q);
                    context.sendBroadcast(intent);
                } catch (Exception e2) {
                    e2.printStackTrace();
                }
                try {
                    Intent intent2 = new Intent();
                    intent2.setAction(packageName + ".refresh.google.acc.sell.ui");
                    intent2.putExtra("allowShow", z);
                    context.sendBroadcast(intent2);
                } catch (Exception e3) {
                    e3.printStackTrace();
                }
                if (com.excean.ab_builder.c.a.M(context)) {
                    as.a(context, as.a(InitObserver.this.f7315a, (Map<String, String>) null));
                }
            }
        });
    }

    private void v(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                long j;
                az.d("InitObserver", String.format("InitObserver/initDownloadLimitCfg:thread(%s)", Thread.currentThread().getName()));
                JSONObject i = cn.i(context);
                try {
                    i.put(ClientCookie.DOMAIN_ATTR, "cdn.excean.com");
                } catch (JSONException e) {
                    e.printStackTrace();
                }
                az.d("initDownloadLimitCfg", "request:" + i.toString());
                az.d("initDownloadLimitCfg", "encrypt request:" + cn.b(i.toString()));
                String a2 = bd.a("https://sdk.ourplay.com.cn/downloadcfg.php", i.toString());
                az.d("initDownloadLimitCfg", "response:" + a2);
                String a3 = cn.a(a2);
                az.d("initDownloadLimitCfg", "decrypt response:" + a3);
                long a4 = by.a(context, "global_config").a(com.excelliance.kxqp.gs.multi.down.b.f7518b, Long.valueOf(PlaybackStateCompat.ACTION_SET_CAPTIONING_ENABLED));
                try {
                    try {
                        j = new JSONObject(a3).getLong("bw");
                    } catch (Throwable th) {
                        th = th;
                    }
                } catch (Exception e2) {
                    e = e2;
                }
                try {
                    by a5 = by.a(context, "global_config");
                    String str = com.excelliance.kxqp.gs.multi.down.b.f7518b;
                    a5.a(str, j);
                    com.excelliance.kxqp.gs.multi.down.b.a(context, j);
                    a4 = str;
                } catch (Exception e3) {
                    e = e3;
                    a4 = j;
                    az.d("initDownloadLimitCfg", "ex:" + e.getMessage());
                    e.printStackTrace();
                    com.excelliance.kxqp.gs.multi.down.b.a(context, a4);
                    a4 = a4;
                } catch (Throwable th2) {
                    th = th2;
                    a4 = j;
                    com.excelliance.kxqp.gs.multi.down.b.a(context, a4);
                    throw th;
                }
            }
        });
    }

    private void w(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                InputStream inputStream;
                ?? r3;
                az.d("InitObserver", String.format("InitObserver/initUnpreStartList:thread(%s)", Thread.currentThread().getName()));
                by a2 = by.a(context, "SP_UNPRESTART_GAME_LIST");
                if (!a2.e()) {
                    return;
                }
                InputStream inputStream2 = null;
                try {
                    inputStream = context.getAssets().open("type1");
                    try {
                        try {
                            r3 = new BufferedReader(new InputStreamReader(inputStream));
                            while (true) {
                                try {
                                    String readLine = r3.readLine();
                                    if (readLine == null) {
                                        break;
                                    }
                                    az.d("InitObserver", "run line: " + readLine);
                                    if (!TextUtils.isEmpty(readLine)) {
                                        a2.a(readLine.trim(), false);
                                    }
                                } catch (IOException e) {
                                    e = e;
                                    inputStream2 = inputStream;
                                    r3 = r3;
                                    try {
                                        e.printStackTrace();
                                        q.a(inputStream2);
                                        q.a(r3);
                                        return;
                                    } catch (Throwable th) {
                                        th = th;
                                        inputStream = inputStream2;
                                        q.a(inputStream);
                                        q.a(r3);
                                        throw th;
                                    }
                                } catch (Exception e2) {
                                    e = e2;
                                    inputStream2 = r3;
                                    e.printStackTrace();
                                    q.a(inputStream);
                                    q.a(inputStream2);
                                } catch (Throwable th2) {
                                    th = th2;
                                    q.a(inputStream);
                                    q.a(r3);
                                    throw th;
                                }
                            }
                            inputStream2 = r3;
                        } catch (Exception e3) {
                            e = e3;
                        }
                        q.a(inputStream);
                        q.a(inputStream2);
                    } catch (IOException e4) {
                        e = e4;
                        r3 = inputStream2;
                    } catch (Throwable th3) {
                        th = th3;
                        r3 = inputStream2;
                    }
                } catch (IOException e5) {
                    e = e5;
                    r3 = 0;
                } catch (Throwable th4) {
                    th = th4;
                    inputStream = null;
                    r3 = 0;
                }
            }
        });
    }

    private void j() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/initGoogleCardData:thread(%s)", Thread.currentThread().getName()));
                String a2 = as.a(InitObserver.this.f7315a.getApplicationContext(), 3, (Map<String, String>) null);
                az.d("InitObserver", "initData googleCard: " + a2);
                if (TextUtils.isEmpty(a2)) {
                    return;
                }
                try {
                    boolean optBoolean = new JSONObject(a2).optBoolean("show");
                    by.a(InitObserver.this.f7315a.getApplicationContext(), "global_config").a("sp_key_google_card_total_count", optBoolean ? 1 : 0);
                    if (optBoolean) {
                        return;
                    }
                    com.excelliance.kxqp.gs.ui.novice.c.a(InitObserver.this.f7315a.getApplicationContext()).a(new Runnable() {
                        @Override
                        public void run() {
                            Context applicationContext = InitObserver.this.f7315a.getApplicationContext();
                            cc.a(applicationContext, "GOOGLE_CARD", false);
                            Intent intent = new Intent();
                            intent.setAction(applicationContext.getPackageName() + ".ACTION.REFRESH.FUNCTION.SWITCH");
                            InitObserver.this.f7315a.getApplicationContext().sendBroadcast(intent);
                        }
                    });
                } catch (JSONException e) {
                    e.printStackTrace();
                }
            }
        });
    }

    @TargetApi(5)
    private void x(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                AccountManager accountManager;
                Account[] accounts;
                az.d("InitObserver", String.format("InitObserver/reportUsrAccount:thread(%s)", Thread.currentThread().getName()));
                try {
                    by a2 = by.a(context, "sp_total_info");
                    long a3 = a2.a("SP_REPOST_NATIVE_GOOGLE_ACCOUNT_stamp", (Long) 0L);
                    if ((a3 != 0 && System.currentTimeMillis() - a3 <= 86400000) || (accountManager = (AccountManager) context.getSystemService("account")) == null || (accounts = accountManager.getAccounts()) == null) {
                        return;
                    }
                    ArrayList arrayList = new ArrayList();
                    for (Account account : accounts) {
                        String str = account.name;
                        if (TextUtils.equals("com.google", account.type)) {
                            arrayList.add(str);
                        }
                    }
                    az.d("InitObserver", "reportUsrAccount list: " + arrayList);
                    if (arrayList.size() > 0) {
                        as.a(context, 7, arrayList);
                        a2.a("SP_REPOST_NATIVE_GOOGLE_ACCOUNT_stamp", System.currentTimeMillis());
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    private void y(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/reportShareBooster:thread(%s)", Thread.currentThread().getName()));
                if (by.a(context, "sp_total_info").b("SP_HAVE_REPORT_SHARE_BOOSTER", false).booleanValue() || !bf.e(context)) {
                    return;
                }
                tp.f(new Runnable() {
                    @Override
                    public void run() {
                        String a2 = bg.a("accaid", context);
                        String a3 = bg.a("rid", context);
                        az.d("InitObserver", "reportShareBooster accaid: " + a2 + " | fromrid: " + a3);
                        if (!TextUtils.isEmpty(a2)) {
                            new com.excelliance.kxqp.gs.ui.accreceive.b(context).a(a2, a3);
                        }
                        by.a(context, "sp_total_info").a("SP_HAVE_REPORT_SHARE_BOOSTER", true);
                    }
                });
            }
        });
    }

    private void z(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                JSONObject jSONObject;
                String optString;
                String optString2;
                String optString3;
                String optString4;
                String optString5;
                az.d("InitObserver", String.format("InitObserver/reportSharePkgData:thread(%s)", Thread.currentThread().getName()));
                JSONObject i = cn.i(context);
                String b2 = by.a(context, "sharePackageInfo").b("sharedJsonInfo", "");
                az.d("VipUtil", "reportSharePkgData read apk jsonInfo:" + b2);
                if (cd.a(b2)) {
                    return;
                }
                String a2 = cn.a(b2);
                az.d("InitObserver", "reportSharePkgData decrypt:" + a2);
                try {
                    jSONObject = new JSONObject(a2);
                    optString = jSONObject.optString("from_aid");
                    optString2 = jSONObject.optString("from_chid");
                    optString3 = jSONObject.optString("from_subchid");
                    optString4 = jSONObject.optString("from_rid");
                    optString5 = jSONObject.optString(RankingItem.KEY_VER);
                } catch (Exception e) {
                    az.d("InitObserver", "ex:" + e.getMessage());
                    e.printStackTrace();
                }
                if (jSONObject.has(BaseAssistActivity.KEY_TYPE)) {
                    int optInt = jSONObject.optInt(BaseAssistActivity.KEY_TYPE);
                    az.d("VipUtil", "newyear_aid:" + optString);
                    i.put("from_aid", optString);
                    i.put("from_chid", optString2);
                    i.put("from_subchid", optString3);
                    i.put("from_rid", optString4);
                    i.put("from_ver", optString5);
                    i.put(BaseAssistActivity.KEY_TYPE, optInt);
                    ResponseData a3 = new com.excelliance.kxqp.gs.discover.bbs.c(context).a(i.toString(), "https://api.ourplay.com.cn/sharedown", new com.excelliance.kxqp.gs.discover.a.c<Object>() {
                        @Override
                        public ResponseData<Object> a(String str) {
                            try {
                                return (ResponseData) new Gson().a(str, new TypeToken<ResponseData<Object>>() {
                                }.getType());
                            } catch (Exception unused) {
                                return null;
                            }
                        }
                    });
                    if (a3 != null) {
                        if (a3.code == 1 || a3.code == 3) {
                            cn.c(context, 3);
                        }
                    }
                }
            }
        });
    }

    private void A(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/fetchPluginConfig:thread(%s)", Thread.currentThread().getName()));
                String a2 = bd.a(bc.g, cn.i(context).toString());
                az.d("InitObserver", "fetchPluginConfig/response: " + a2);
                if (TextUtils.isEmpty(a2)) {
                    return;
                }
                by.a(context, "global_config").a("sp_key_plugin_page_features", a2);
            }
        });
    }

    private void B(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/fetchImportLocalSortList:thread(%s)", Thread.currentThread().getName()));
                if (com.excelliance.kxqp.gs.util.b.aD(context)) {
                    new com.excelliance.kxqp.gs.discover.bbs.c(context).a(cn.i(context).toString(), "https://api.ourplay.com.cn//goneload/leadsort", new com.excelliance.kxqp.gs.discover.a.c<Object>() {
                        @Override
                        public ResponseData<Object> a(String str) {
                            by.a(context, "global_config").a("sp_key_import_local_sort_list", str);
                            return null;
                        }
                    });
                }
            }
        });
    }

    private void k() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/getVendingWhiteUrlList:thread(%s)", Thread.currentThread().getName()));
                as.m(InitObserver.this.f7315a.getApplicationContext());
            }
        });
    }

    private void C(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                try {
                    az.d("InitObserver", String.format("InitObserver/getSpecialUrlToInnerBrowser2:thread(%s)", Thread.currentThread().getName()));
                    String a2 = bd.a("https://api.ourplay.com.cn/attribute/link", cn.i(context).toString());
                    if (TextUtils.isEmpty(a2)) {
                        return;
                    }
                    String a3 = cn.a(a2);
                    Log.d("InitObserver", "run: " + a3);
                    if (TextUtils.isEmpty(a3)) {
                        return;
                    }
                    JSONObject jSONObject = new JSONObject(a3);
                    if (jSONObject.optInt("code") == 0) {
                        JSONArray optJSONArray = jSONObject.optJSONArray("data");
                        if (optJSONArray == null || optJSONArray.length() <= 0) {
                            by.a(InitObserver.this.f7315a, "sp_config").a("sp_key_special_urls_to_new_browser", (Set<String>) null);
                            return;
                        }
                        HashSet hashSet = new HashSet();
                        for (int i = 0; i < optJSONArray.length(); i++) {
                            String string = optJSONArray.getString(i);
                            if (!TextUtils.isEmpty(string)) {
                                hashSet.add(string);
                            }
                        }
                        if (hashSet.size() > 0) {
                            by.a(InitObserver.this.f7315a, "sp_config").a("sp_key_special_urls_to_new_browser", hashSet);
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    Log.d("InitObserver", "run:getSpecialUrlToInnerBrowser2:: " + e.toString());
                }
            }
        });
    }

    public void c(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                JSONObject optJSONObject;
                try {
                    boolean z = true;
                    az.d("InitObserver", String.format("InitObserver/getAntiAddictionSystemSwitchStatus:thread(%s)", Thread.currentThread().getName()));
                    String c = bd.c("https://api.ourplay.com.cn/user/verify-switch", cn.i(context).toString());
                    az.d("InitObserver", "getRealNameVerifyShowStatus:" + c);
                    if (TextUtils.isEmpty(c)) {
                        return;
                    }
                    JSONObject jSONObject = new JSONObject(c);
                    if (jSONObject.optInt("code") != 0 || (optJSONObject = jSONObject.optJSONObject("data")) == null) {
                        return;
                    }
                    int optInt = optJSONObject.optInt("status");
                    by a2 = by.a(InitObserver.this.f7315a, "sp_config");
                    if (optInt != 1) {
                        z = false;
                    }
                    a2.a("sp_key_anti_addiction_system_switch", z);
                } catch (Exception e) {
                    e.printStackTrace();
                    Log.d("InitObserver", "run: Exception::" + e.toString());
                }
            }
        });
    }

    public void d(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                try {
                    az.d("InitObserver", String.format("InitObserver/getAntiAddictionSystemSwitchStatus:thread(%s)", Thread.currentThread().getName()));
                    String c = bd.c("https://api.ourplay.com.cn/user/antiaddic-switch", cn.i(context).toString());
                    az.d("InitObserver", "getAntiAddictionSystemSwitchStatus:" + c);
                    if (TextUtils.isEmpty(c)) {
                        return;
                    }
                    JSONObject jSONObject = new JSONObject(c);
                    if (jSONObject.optInt("code") == 0) {
                        by.a(InitObserver.this.f7315a, "sp_config").a("sp_key_anti_addiction_system_switch", jSONObject.optBoolean("data"));
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    public void e(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/getNativeAppInfo:thread(%s)", Thread.currentThread().getName()));
                as.M(context.getApplicationContext());
            }
        });
    }

    public void f(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/getNativeWhiteAppInfo:thread(%s)", Thread.currentThread().getName()));
                as.N(context.getApplicationContext());
            }
        });
    }

    public void g(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                boolean booleanValue = by.a(InitObserver.this.f7315a, "hello").b("nav", false).booleanValue();
                Log.d("InitObserver", String.format("InitObserver/getStartPageNativeWhiteAppInfo:thread(%s)", Thread.currentThread().getName()) + "  mIsNav  " + booleanValue);
                if (com.excean.ab_builder.c.a.at(InitObserver.this.f7315a) && booleanValue) {
                    as.O(context.getApplicationContext());
                }
            }
        });
    }

    public void h(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/checkNativeHuaWeiSpecialApp:thread(%s)", Thread.currentThread().getName()));
                String b2 = n.b(context);
                az.d("InitObserver", String.format("InitObserver/checkNativeHuaWeiSpecialApp:thread(%s) manufacturer(%s)", Thread.currentThread().getName(), b2));
                if ("huawei".equals(b2)) {
                    as.P(context.getApplicationContext());
                }
            }
        });
    }

    public void i(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/uploadToutiaoAction:thread(%s)", Thread.currentThread().getName()));
                ap.a().b(context.getApplicationContext());
            }
        });
    }

    public void j(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/getSetUpRecommendAppInfo:thread(%s)", Thread.currentThread().getName()));
                if (x.a(InitObserver.this.f7315a)) {
                    return;
                }
                as.Q(context.getApplicationContext());
            }
        });
    }

    public void k(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/uploadFirstVIVOUpdateOfficial:thread(%s)", Thread.currentThread().getName()));
                x.c(context.getApplicationContext());
            }
        });
    }

    public void l(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/checkServerCacheConfigForSystemUpdate:thread(%s)", Thread.currentThread().getName()));
                VersionManager.getInstance().h(context);
            }
        });
    }

    public void m(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                com.excelliance.kxqp.task.g.a.a().a(context);
            }
        });
    }

    public void n(final Context context) {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                az.d("InitObserver", String.format("InitObserver/uploadNativeAppList:thread(%s)", Thread.currentThread().getName()));
                tp.f(new Runnable() {
                    @Override
                    public void run() {
                        com.excelliance.kxqp.gs.g.n.a().a(context);
                    }
                });
            }
        });
    }

    public void o(final Context context) {
        az.d("InitObserver", String.format("InitObserver/setForbidSocialSoftwareExternalStart:thread(%s)", Thread.currentThread().getName()));
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                as.X(context.getApplicationContext());
            }
        });
    }

    public void p(final Context context) {
        az.d("InitObserver", String.format("InitObserver/reinstallInfiniteflight:thread(%s)", Thread.currentThread().getName()));
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                boolean booleanValue = by.a(context, "sp_total_info").b("sp_key_com_fds_infiniteflight_reinstall", false).booleanValue();
                az.d("InitObserver", "InitObserver/reinstallInfiniteflight reinstall:" + booleanValue);
                if (booleanValue) {
                    return;
                }
                ExcellianceAppInfo b2 = com.excelliance.kxqp.repository.a.a(context).b("com.fds.infiniteflight");
                if (b2 != null && b2.isApkInstalled()) {
                    az.d("InitObserver", "InitObserver/reinstallInfiniteflight gs reinstall:" + booleanValue + " appinfo:" + b2);
                    as.c(context.getApplicationContext(), b2);
                }
                by.a(context, "sp_total_info").a("sp_key_com_fds_infiniteflight_reinstall", true);
            }
        });
    }

    public void b() {
        this.f7316b.post(new Runnable() {
            @Override
            public void run() {
                com.excelliance.kxqp.manager.e.a().a(InitObserver.this.f7315a.getApplicationContext());
            }
        });
    }
}