package com.gh.gamecenter; import android.annotation.SuppressLint; import android.app.Dialog; import android.app.NotificationManager; import android.content.Context; import android.content.Intent; import android.content.SharedPreferences; import android.content.pm.ApplicationInfo; import android.content.pm.PackageInfo; import android.content.pm.PackageManager; import android.os.Build; import android.os.Bundle; import android.os.Handler; import android.os.SystemClock; import android.preference.PreferenceManager; import android.text.TextUtils; import android.util.Log; import android.view.KeyEvent; import android.view.LayoutInflater; import android.view.View; import android.view.Window; import android.widget.TextView; import com.gh.base.AppUncaughtHandler; import com.gh.base.BaseActivity; import com.gh.base.fragment.BaseFragment_ViewPager; import com.gh.common.AppExecutor; import com.gh.common.constant.Config; import com.gh.common.constant.Constants; import com.gh.common.exposure.ExposureUtils; import com.gh.common.exposure.meta.MetaUtil; import com.gh.common.im.ImManager; import com.gh.common.repository.ReservationRepository; import com.gh.common.util.ActivationHelper; import com.gh.common.util.ClassUtils; import com.gh.common.util.ConcernUtils; import com.gh.common.util.DataCollectionUtils; import com.gh.common.util.DataLogUtils; import com.gh.common.util.DataUtils; import com.gh.common.util.DeviceTokenUtils; import com.gh.common.util.DeviceUtils; import com.gh.common.util.DialogUtils; import com.gh.common.util.DirectUtils; import com.gh.common.util.EntranceUtils; import com.gh.common.util.GsonUtils; import com.gh.common.util.LogUtils; import com.gh.common.util.LunchType; import com.gh.common.util.MtaHelper; import com.gh.common.util.NotificationHelper; import com.gh.common.util.PackageUtils; import com.gh.common.util.PlatformUtils; import com.gh.common.util.PushHelper; import com.gh.common.util.SPUtils; import com.gh.common.util.ThirdPartyPackageHelper; import com.gh.common.util.UrlFilterUtils; import com.gh.download.DownloadManager; import com.gh.download.DownloadNotification; import com.gh.gamecenter.download.DownloadFragment; import com.gh.gamecenter.entity.CommunityEntity; import com.gh.gamecenter.entity.GameDigestEntity; import com.gh.gamecenter.entity.GameEntity; import com.gh.gamecenter.entity.InnerMetaInfoEntity; import com.gh.gamecenter.entity.NotificationHint; import com.gh.gamecenter.entity.SettingsEntity; import com.gh.gamecenter.eventbus.EBNetworkState; import com.gh.gamecenter.eventbus.EBPackage; import com.gh.gamecenter.eventbus.EBReuse; import com.gh.gamecenter.eventbus.EBShowDialog; import com.gh.gamecenter.eventbus.EBSkip; import com.gh.gamecenter.fragment.MainWrapperFragment; import com.gh.gamecenter.manager.DataCollectionManager; import com.gh.gamecenter.manager.UpdateManager; import com.gh.gamecenter.manager.UserManager; import com.gh.gamecenter.normal.NormalFragment; import com.gh.gamecenter.packagehelper.PackageRepository; import com.gh.gamecenter.packagehelper.PackageViewModel; import com.gh.gamecenter.qa.CommunityFragment; import com.gh.gamecenter.retrofit.BiResponse; import com.gh.gamecenter.retrofit.EmptyResponse; import com.gh.gamecenter.retrofit.Response; import com.gh.gamecenter.retrofit.RetrofitManager; import com.gh.gamecenter.suggest.SuggestType; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; import com.halo.assistant.HaloApp; import com.lightgame.config.CommonDebug; import com.lightgame.download.DataWatcher; import com.lightgame.download.DownloadEntity; import com.lightgame.download.DownloadStatus; import com.lightgame.download.FileUtils; import com.lightgame.utils.Util_System_Phone_State; import com.tencent.bugly.beta.tinker.TinkerManager; import com.tencent.bugly.crashreport.CrashReport; import org.greenrobot.eventbus.EventBus; import org.greenrobot.eventbus.Subscribe; import org.greenrobot.eventbus.ThreadMode; import org.json.JSONObject; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.lang.reflect.Type; import java.util.Enumeration; import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.zip.ZipEntry; import java.util.zip.ZipFile; import androidx.annotation.NonNull; import androidx.lifecycle.ViewModelProviders; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.schedulers.Schedulers; import okhttp3.MediaType; import okhttp3.RequestBody; import okhttp3.ResponseBody; import static com.gh.common.util.EntranceUtils.KEY_TO; import static com.gh.gamecenter.fragment.MainWrapperFragment.INDEX_PERSONAL; import static com.gh.gamecenter.personal.PersonalFragment.LOGIN_TAG; import static com.gh.gamecenter.personal.PersonalFragment.LOGOUT_TAG; public class MainActivity extends BaseActivity { public final static String EB_MAINACTIVITY_TAG = "MainActivity"; public final static String EB_SKIP_GAMEFRAGMENT = "GameFragment"; public final static String SHOULD_INIT_IM = "should_init_im"; public final static String SWITCH_TO_COMMUNITY = "switch_to_community"; private final static String IS_SKIPPED = "is_skipped"; private PackageViewModel mPackageViewModel; private MainWrapperFragment mMainWrapperFragment; private SharedPreferences mSp; // 黄壮华 按连续按返回键两次才退出应用 private long[] mHits = new long[2]; private boolean isSkipped = false; public static boolean isNewFirstLaunch; private Handler handler = new Handler(); // 黄壮华 添加观察者 修改2015/8/15 private DataWatcher dataWatcher = new DataWatcher() { @Override public void onDataChanged(DownloadEntity downloadEntity) { if (DownloadStatus.hijack.equals(downloadEntity.getStatus())) { // 链接被劫持 processHijack(downloadEntity); String nameAndPlatform = downloadEntity.getName() + ":" + PlatformUtils.getInstance(getApplicationContext()).getPlatformName(downloadEntity.getPlatform()); DataUtils.onMtaEvent(getApplicationContext(), "下载劫持", "游戏名字", nameAndPlatform, "网络状态" + DeviceUtils.getNetwork(getApplication())); return; } else if (DownloadStatus.notfound.equals(downloadEntity.getStatus())) { // 404 Not Found // 删除任务 downloadEntity.setStatus(DownloadStatus.cancel); DownloadManager.getInstance(getApplicationContext()).cancel(downloadEntity.getUrl()); toast("该链接已失效！请联系管理员。"); EventBus.getDefault().post(new EBShowDialog("notfound", downloadEntity.getName())); MtaHelper.onEventWithBasicDeviceInfo("下载失败弹窗", "游戏", downloadEntity.getName(), "平台", downloadEntity.getPlatform()); return; } else if (DownloadStatus.neterror.equals(downloadEntity.getStatus()) || DownloadStatus.timeout.equals(downloadEntity.getStatus())) { DownloadNotification.showWaitingNotification(MainActivity.this); // 系统通知 toast("网络不稳定，下载任务已暂停"); DataLogUtils.uploadNeterrorLog(MainActivity.this, downloadEntity); MtaHelper.onEventWithBasicDeviceInfo("下载自动暂停", "游戏", downloadEntity.getName(), "平台", downloadEntity.getPlatform()); } if (DownloadStatus.done.equals(downloadEntity.getStatus())) { if (downloadEntity.getName().contains(getString(R.string.app_name))) { DataUtils.onEvent(MainActivity.this, "软件更新", "下载完成"); startActivity(PackageUtils.getInstallIntent(MainActivity.this, downloadEntity.getPath())); DataLogUtils.uploadUpgradeLog(MainActivity.this, "install"); //上传更新安装数据 } else { statDoneEvent(downloadEntity); String platform = PlatformUtils.getInstance(getApplicationContext()) .getPlatformName(downloadEntity.getPlatform()); if (platform != null) { if (downloadEntity.isPluggable()) { // 弹出插件化提示框 EventBus.getDefault().post(new EBShowDialog("plugin", downloadEntity.getPath())); } else if (downloadEntity.isPlugin()) { toast(downloadEntity.getName() + " - " + platform + " - 下载完成"); } else { toast(downloadEntity.getName() + " - 下载完成"); } } else { toast(downloadEntity.getName() + " - 下载完成"); } if (!downloadEntity.isPluggable()) { // 是否是自动安装 if (mSp.getBoolean("autoinstall", true)) { if (FileUtils.isEmptyFile(downloadEntity.getPath())) { toast(R.string.install_failure_hint); DownloadManager.getInstance(MainActivity.this).cancel(downloadEntity.getUrl()); } else { if (PackageUtils.isCanLaunchSetup(getApplicationContext(), downloadEntity.getPath())) { startActivity(PackageUtils.getInstallIntent(MainActivity.this, downloadEntity.getPath())); } else { // 弹出卸载提示框 EventBus.getDefault().post(new EBShowDialog("plugin", downloadEntity.getPath())); } } } } // 统计下载完成 uploadData(downloadEntity.getGameId(), downloadEntity.getPlatform()); } // 下载过程分析统计 PackageManager pm = getApplicationContext().getPackageManager(); PackageInfo packageInfo = pm.getPackageArchiveInfo(downloadEntity.getPath(), PackageManager.GET_ACTIVITIES); if (packageInfo == null) { MtaHelper.onEventWithBasicDeviceInfo("解析包错误分析" , "游戏名字", downloadEntity.getName() + ":" + PlatformUtils.getInstance(getApplicationContext()).getPlatformName(downloadEntity.getPlatform())); MtaHelper.onEventWithBasicDeviceInfo( "解析包错误_新", "游戏", downloadEntity.getName() + ":" + PlatformUtils.getInstance(getApplicationContext()).getPlatformName(downloadEntity.getPlatform())); } } } }; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); // 上传数据 DataCollectionManager.getInstance(getApplicationContext()).upload(); mSp = PreferenceManager.getDefaultSharedPreferences(this); if (savedInstanceState != null) { isSkipped = savedInstanceState.getBoolean(IS_SKIPPED); } mMainWrapperFragment = new MainWrapperFragment(); if (savedInstanceState != null) { mMainWrapperFragment.setArguments(savedInstanceState); } else if (getIntent() != null) { Bundle extras = getIntent().getExtras(); mMainWrapperFragment.setArguments(extras); } replaceFragment(mMainWrapperFragment); // 检查助手更新 UpdateManager.getInstance(this).checkUpdate(true, null); isNewFirstLaunch = mSp.getBoolean("isNewFirstLaunchV" + PackageUtils.getVersionName(), true); if (isNewFirstLaunch) { final LunchType lunchType = DeviceTokenUtils.getLaunchType(); // 延时两秒提交 APP 启动日志的，避免提交时还没获取到 GID AppExecutor.getUiExecutor().executeWithDelay(() -> { if (!this.isFinishing()) { LogUtils.uploadDevice(lunchType); } }, 2000L); getPluginUpdate(); ActivationHelper.sendActivationInfo(); mSp.edit().putBoolean("isNewFirstLaunchV" + PackageUtils.getVersionName(), false).apply(); checkDevice(); // 根据设备信息判断用户是否是新用户 } // 若 SplashActivity 没能获取到 Gid 这里再重试一次 if (TextUtils.isEmpty(HaloApp.getInstance().getGid())) { DataUtils.getGid(); } // 获取默认配置 getGhzsSettings(); // 初始化PlatformUtils PlatformUtils.getInstance(getApplicationContext()); // 添加观察者 DownloadManager.getInstance(this).addObserver(dataWatcher); mPackageViewModel = ViewModelProviders.of(this, new PackageViewModel.Factory()).get(PackageViewModel.class); final String message = Config.getExceptionMsg(); if (!TextUtils.isEmpty(message)) { Config.setExceptionMsg(null); AppUncaughtHandler.reportException(this, new Throwable(message)); DialogUtils.showWarningDialog(this, "发生闪退", "光环助手刚刚发生了闪退，马上反馈以帮助我们更好地修复问题？（只需简单描述你刚才的操作）" , "暂不", "马上反馈", () -> { SuggestionActivity.startSuggestionActivity(MainActivity.this, SuggestType.crash, "APP闪退："); MtaHelper.onEventWithBasicDeviceInfo( "闪退弹窗", "玩家操作", "点击反馈"); }, () -> MtaHelper.onEventWithBasicDeviceInfo( "闪退弹窗", "玩家操作", "点击关闭")); } // checkTinkerPath(); // todo　看情况是否需要显示弹窗 checkRetryDownload(); // 初始化 IM，只有在 APP 刚启动时执行 if (HaloApp.get(SHOULD_INIT_IM, false) != null) { HaloApp.put(SHOULD_INIT_IM, false); handler.postDelayed(ImManager::attachIm, 1000); } ReservationRepository.refreshReservations(); if (getIntent().getBooleanExtra(SWITCH_TO_COMMUNITY, false)) { handler.postDelayed(this::switchToCommunityTabAndRefresh, 800); } // 跳转至其它页面 if (getIntent() != null && getIntent().getExtras() != null && !isSkipped) { doSkip(); } handler.postDelayed(() -> { PushHelper.postPushClickAction(this.getApplicationContext(), null); }, 2000); showNotificationHintDialog(); } @Override protected void onDestroy() { super.onDestroy(); DownloadManager.getInstance(this).removeObserver(dataWatcher); handler.removeCallbacksAndMessages(null); } @NonNull public static Intent getMainIntent(Context context) { Intent intent = new Intent(context, MainActivity.class); intent.setFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP); return intent; } private void doSkip() { handler.postDelayed(() -> { isSkipped = true; Bundle bundle = getIntent().getExtras(); if (bundle != null) { String to = bundle.getString(KEY_TO); if (!TextUtils.isEmpty(to)) { Class clazz = ClassUtils.forName(to); if (clazz != null) { String entrance = bundle.getString(EntranceUtils.KEY_ENTRANCE); if (TextUtils.isEmpty(entrance) || !entrance.startsWith("(") || !entrance.endsWith(")")) { bundle.putString(EntranceUtils.KEY_ENTRANCE, "(插件跳转)"); } String packageName = bundle.getString("packageName"); if (packageName != null) { bundle.putInt(BaseFragment_ViewPager.ARGS_INDEX, 1); } if (NormalFragment.class.isAssignableFrom(clazz)) { NormalActivity.startFragment(MainActivity.this, (Class) clazz, bundle); } else { Intent skipIntent = new Intent(MainActivity.this, clazz); skipIntent.putExtras(bundle); startActivity(skipIntent); } } } } }, 500); } // 统计下载 private void uploadData(String id, String platform) { Map params = new HashMap<>(); params.put("game", id); params.put("platform", platform); RequestBody body = RequestBody.create(MediaType.parse("application/json"), new JSONObject(params).toString()); RetrofitManager.getInstance(this).getApi().postDownload(body) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Response<>()); } // 统计下载完成事件 private void statDoneEvent(DownloadEntity downloadEntity) { ExposureUtils.DownloadType type; String platform = PlatformUtils.getInstance(HaloApp.getInstance().getApplication()).getPlatformName(downloadEntity.getPlatform()); Map kv1 = new HashMap<>(); kv1.put("版本", platform); kv1.put("状态", "下载完成"); kv1.put("用户机型", Build.MODEL); kv1.put("设备IMEI", Util_System_Phone_State.getDeviceId(HaloApp.getInstance().getApplication())); kv1.put("网络状态", DeviceUtils.getNetwork(HaloApp.getInstance().getApplication())); kv1.put("光环助手版本", BuildConfig.VERSION_NAME); if (downloadEntity.isUpdate()) { type = ExposureUtils.DownloadType.UPDATE; DataUtils.onEvent(MainActivity.this, "游戏更新", downloadEntity.getName(), kv1); } else { type = ExposureUtils.DownloadType.DOWNLOAD; } Map kv2 = new HashMap<>(); kv2.put("版本", downloadEntity.getPlatform()); kv2.put("状态", "下载完成"); kv2.put("位置", downloadEntity.getEntrance()); kv2.put("游戏分平台", downloadEntity.getName() + "-" + platform); kv2.put("光环助手版本", BuildConfig.VERSION_NAME); DataUtils.onEvent(MainActivity.this, "游戏下载位置", downloadEntity.getName(), kv2); if (downloadEntity.isPluggable()) { Map kv3 = new HashMap<>(); kv3.put("下载", "下载完成"); kv3.put("版本", downloadEntity.getPlatform()); kv3.put("位置", downloadEntity.getEntrance()); type = ExposureUtils.DownloadType.PLUGIN_DOWNLOAD; DataUtils.onEvent(MainActivity.this, "插件化", downloadEntity.getName(), kv3); DataUtils.onMtaEvent(this, "插件化_新", "位置", downloadEntity.getEntrance(), "游戏", downloadEntity.getName() + "-" + downloadEntity.getPlatform(), "操作", "下载完成", "网络状态", DeviceUtils.getNetwork(HaloApp.getInstance().getApplication())); } ExposureUtils.logADownloadCompleteExposureEvent( new GameEntity(downloadEntity.getGameId(), downloadEntity.getName()), downloadEntity.getPlatform(), downloadEntity.getExposureTrace(), type); DataCollectionUtils.uploadDownload(this, downloadEntity, "完成"); } private void processHijack(DownloadEntity downloadEntity) { // 删除任务 downloadEntity.setStatus(DownloadStatus.cancel); DownloadManager.getInstance(getApplicationContext()).cancel(downloadEntity.getUrl()); // 弹出提示框 EventBus.getDefault().post(new EBShowDialog("hijack")); // 记录链接被劫持 DataCollectionUtils.uploadHijack(this, downloadEntity); // 上传劫持log DataLogUtils.uploadHijack(this, downloadEntity); } @Override public boolean onKeyDown(int keyCode, KeyEvent event) { if (keyCode == KeyEvent.KEYCODE_BACK && event.getRepeatCount() == 0) { DownloadEntity downloadEntity = null; for (DownloadEntity entity : DownloadManager.getInstance(getApplicationContext()).getAll()) { if (entity.getStatus().equals(DownloadStatus.done)) { if (PackageUtils.isInstalled(getApplicationContext(), entity.getPackageName()) && (!entity.isPlugin() || PackageUtils.isSignature(getApplicationContext(), entity.getPackageName()))) { continue; } if (downloadEntity == null) { downloadEntity = entity; } else if (entity.getEnd() > downloadEntity.getEnd()) { downloadEntity = entity; } } } if (downloadEntity != null) { String msg; if (downloadEntity.isPlugin()) { msg = "《" + downloadEntity.getName() + "-" + PlatformUtils.getInstance(getApplicationContext()).getPlatformName(downloadEntity.getPlatform()) + "》已下载完但还未安装，是否立即安装？"; } else { msg = "《" + downloadEntity.getName() + "》已下载完但还未安装，是否立即安装？"; } final String path = downloadEntity.getPath(); DialogUtils.showWarningDialog(this, "提示", msg, "直接退出", "立即安装", () -> handler.postDelayed(() -> PackageUtils.launchSetup(MainActivity.this, path), 200), this::finish); return true; } System.arraycopy(mHits, 1, mHits, 0, mHits.length - 1); mHits[mHits.length - 1] = SystemClock.uptimeMillis(); if (mHits[0] >= (SystemClock.uptimeMillis() - 1000)) { finish(); } else { toast("再按一次就退出光环助手了哦"); return true; } } return super.onKeyDown(keyCode, event); } @Override public void finish() { // 上传数据 DataCollectionManager.getInstance(getApplicationContext()).statClickData(); super.finish(); } @Override protected void onSaveInstanceState(Bundle outState) { super.onSaveInstanceState(outState); outState.putBoolean(IS_SKIPPED, isSkipped); if (mMainWrapperFragment != null) { outState.putInt(BaseFragment_ViewPager.ARGS_INDEX, mMainWrapperFragment.getCurrentItem()); } } @Override protected int getLayoutId() { return R.layout.layout_wrapper_activity; } @Override protected void onNewIntent(Intent intent) { super.onNewIntent(intent); // 跳转到问答社区并刷新 if (getIntent().getBooleanExtra(SWITCH_TO_COMMUNITY, false)) { switchToCommunityTabAndRefresh(); } } private void switchToCommunityTabAndRefresh() { getIntent().putExtra(SWITCH_TO_COMMUNITY, false); Log.e("Switch", "true"); EventBus.getDefault().post(new EBSkip(MainActivity.EB_SKIP_GAMEFRAGMENT, 1)); EventBus.getDefault().post(new EBReuse(CommunityFragment.EB_RETRY_PAGE)); } private void getGhzsSettings() { String channel = HaloApp.getInstance().getChannel(); RetrofitManager.getInstance(this) .getApi().getSettings(PackageUtils.getVersionName(), channel) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Response() { @Override public void onResponse(SettingsEntity response) { Config.setSettings(response); // 意见反馈 SharedPreferences.Editor edit = mSp.edit(); edit.putString(SuggestionActivity.SUGGESTION_HINT_TYPE, GsonUtils.toJson(response.getSuggestion())); edit.apply(); if (!mSp.getBoolean(Config.FIX_DOWNLOAD_KEY, false) && Config.isShow()) { mSp.edit().putBoolean(Config.FIX_DOWNLOAD_KEY, true).apply(); } EventBus.getDefault().post(new EBReuse("Refresh")); } }); } private void checkRetryDownload() { DownloadManager.getInstance(this).checkRetryDownload(); } private void checkTinkerPath() { CommonDebug.logMethodWithParams(this, TinkerManager.getTinkerId(), TinkerManager.getNewTinkerId()); CommonDebug.logMethodWithParams(this, CrashReport.getAppVer(), CrashReport.getAppID(), CrashReport.getAppChannel(), CrashReport.getSdkExtraData()); // 1.（母包）首次启动，tinkerId不为空，newTinkerId(patchTinkerId)应该是空的 // 2. 补丁包启动，tinkerId和之前一致，但newTinkerId不一致 // 2.1 显示更新信息弹窗，记录tinkerId+newTinkerId // 2.1.1 若tinkerId一致，但newTinkerId不一致才能认为是一次补丁更新 String tinkerId = TinkerManager.getTinkerId(); String newTinkerId = TinkerManager.getNewTinkerId(); if (TextUtils.isEmpty(newTinkerId)) { //这是一个新的母包，没有任何补丁信息 return; } final Gson gson = new Gson(); Type type = new TypeToken>>() { }.getType(); final Map> tinkerIdMap; final String tinkerMapJson = mSp.getString(Config.PATCHES, ""); if (!TextUtils.isEmpty(tinkerMapJson)) { tinkerIdMap = gson.fromJson(tinkerMapJson, type); } else { tinkerIdMap = new HashMap<>(); } Set tinkerIdSet = tinkerIdMap.get(tinkerId); if (tinkerIdSet == null) { tinkerIdSet = new HashSet<>(); tinkerIdMap.put(tinkerId, tinkerIdSet); } // 有新的补丁，没有显示过 if (!tinkerIdSet.contains(newTinkerId)) { tinkerIdSet.add(newTinkerId); final Dialog dialog = new Dialog(this, R.style.GhAlertDialog); View contentView = LayoutInflater.from(this).inflate(R.layout.dialog_alert, null); TextView contentTv = contentView.findViewById(R.id.dialog_content); TextView titleTv = contentView.findViewById(R.id.dialog_title); TextView negativeTv = contentView.findViewById(R.id.dialog_negative); TextView positiveTv = contentView.findViewById(R.id.dialog_positive); titleTv.setText("补丁更新成功"); contentTv.setText(("光环助手已成功更新到V" + PackageUtils.getVersionName() + "-" + newTinkerId)); positiveTv.setText("知道了"); negativeTv.setText(null); negativeTv.setOnClickListener(view -> dialog.dismiss()); positiveTv.setOnClickListener(view -> dialog.dismiss()); dialog.setOnDismissListener(dialog1 -> mSp.edit().putString(Config.PATCHES, gson.toJson(tinkerIdMap)).apply()); dialog.requestWindowFeature(Window.FEATURE_NO_TITLE); dialog.setContentView(contentView); dialog.show(); } } private void checkDevice() { String content = DeviceUtils.getUserDevice(MainActivity.this).toString(); RequestBody body = RequestBody.create(MediaType.parse("application/json"), content); RetrofitManager.getInstance(this).getApi().checkDevice(body) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Response() { @Override public void onResponse(ResponseBody response) { super.onResponse(response); try { String string = response.string(); JSONObject object = new JSONObject(string); String deviceId = object.getString("device_id"); if (!TextUtils.isEmpty(deviceId)) { oldUserSkip(deviceId); } } catch (Exception e) { e.printStackTrace(); } } }); } @SuppressLint("CheckResult") private void showNotificationHintDialog() { if (!SPUtils.getBoolean(Constants.SP_SHOWED_NOTIFICATION_HINT)) { RetrofitManager.getInstance(this).getApi().getBootPopup() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new BiResponse() { @Override public void onSuccess(NotificationHint data) { try { NotificationHelper.showEnableNotificationDialogIfItsDisabled(MainActivity.this, data); } catch (Exception ignore){ } } }); } } private void oldUserSkip(String deviceId) { mSp.edit().putString("syncDeviceID", deviceId).apply(); DialogUtils.showForceDialog(MainActivity.this, "数据同步提醒" , "系统检测到你是光环助手的老用户，为了避免数据丢失，请尽快登录" , "前往登录", "残忍拒绝", new DialogUtils.ConfirmListener() { @Override public void onConfirm() { EventBus.getDefault().post(new EBSkip(MainActivity.EB_SKIP_GAMEFRAGMENT, INDEX_PERSONAL)); } }, null); } // 获取META-INF中的plugin_update 文件，判断是否从游戏插件中下载的app，是则获取游戏id，启动游戏更新，下载该游戏 private void getPluginUpdate() { HaloApp.getInstance().getMainExecutor().execute(() -> { ApplicationInfo appinfo = getApplicationInfo(); String sourceDir = appinfo.sourceDir; ZipFile zipfile = null; try { zipfile = new ZipFile(sourceDir); Enumeration entries = zipfile.entries(); while (entries.hasMoreElements()) { ZipEntry entry = ((ZipEntry) entries.nextElement()); String entryName = entry.getName(); if (entryName.contains("gh_assist")) { String packageName = entryName.substring(entryName.lastIndexOf("_") + 1); startActivity(DownloadManagerActivity.getDownloadMangerIntent(MainActivity.this, packageName, DownloadFragment.INDEX_UPDATE, "(游戏插件)")); break; } else if (entryName.contains("halo_skip.json")) { InputStream in = zipfile.getInputStream(entry); if (in != null) { final Gson gson = new Gson(); final BufferedReader reader = new BufferedReader(new InputStreamReader(in)); InnerMetaInfoEntity info = gson.fromJson(reader, InnerMetaInfoEntity.class); if (info != null) { if (EntranceUtils.HOST_COMMUNITY.equals(info.getType())) { UserManager.getInstance().setCommunityData(new CommunityEntity(info.getLink(), info.getText())); runOnUiThread(() -> mMainWrapperFragment.setCurrentItem(MainWrapperFragment.INDEX_ASK)); } else { DirectUtils.directToSpecificPage(this, info.getType(), info.getLink(), info.getText(), EntranceUtils.KEY_PLUGIN, "特定包启动跳转"); } } } } } } catch (Exception e) { e.printStackTrace(); } finally { if (zipfile != null) { try { zipfile.close(); } catch (IOException e) { e.printStackTrace(); } } } }); } // 连接上网络事件 @Subscribe(threadMode = ThreadMode.MAIN) public void onEventMainThread(EBNetworkState busNetworkState) { if (busNetworkState.isNetworkConnected()) { checkRetryDownload(); if (Config.getSettings() == null) { getGhzsSettings(); } mPackageViewModel.checkData(); } } @Subscribe(threadMode = ThreadMode.MAIN) public void onEventMainThread(EBPackage busFour) { final String packageName = busFour.getPackageName(); String gameId = ""; DownloadEntity mDownloadEntity = null; for (DownloadEntity downloadEntity : DownloadManager.getInstance(getApplicationContext()).getAll()) { //todo 根据包名获取DownloadEntity? 假如存在相同包名的下载任务,有可能会删除错误 if (packageName.equals(downloadEntity.getPackageName())) { mDownloadEntity = downloadEntity; gameId = mDownloadEntity.getGameId(); break; } } if ("安装".equals(busFour.getType())) { mPackageViewModel.addInstalledGame(packageName); // 删除下载完成 弹窗 NotificationManager nManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE); nManager.cancel(packageName.hashCode()); if (mDownloadEntity != null) { if (mDownloadEntity.isPluggable()) { Map kv6 = new HashMap<>(); kv6.put("安装或卸载", "安装完成"); DataUtils.onEvent(this, "插件化", mDownloadEntity.getName(), kv6); DataUtils.onMtaEvent(this, "插件化_新", "位置", mDownloadEntity.getEntrance(), "游戏", mDownloadEntity.getName() + "-" + mDownloadEntity.getPlatform(), "操作", "安装完成", "网络状态", DeviceUtils.getNetwork(HaloApp.getInstance().getApplication())); } // 没有光环 ID 的都记录一下游戏 ID，供'我的游戏'区分同包名不同插件用 Object gh_id = PackageUtils.getMetaData(this, mDownloadEntity.getPackageName(), "gh_id"); if (gh_id == null) { ThirdPartyPackageHelper.saveGameId(mDownloadEntity.getPackageName(), mDownloadEntity.getGameId()); } DownloadManager.getInstance(getApplicationContext()).cancel( mDownloadEntity.getUrl(), false); // 默认不删除安装包 mSp.getBoolean("autodelete", true) } if (mSp.getBoolean("concerngame", true)) { //设置页面控制是否安装后自动关注 // 安装后关注游戏 DownloadEntity finalDownloadEntity = mDownloadEntity; RetrofitManager.getInstance(this).getApi().getGameDigestByPackageName(UrlFilterUtils.getFilterQuery("package", packageName)) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Response>() { @Override public void onResponse(List response) { for (GameDigestEntity gameDigestEntity : response) { if (!TextUtils.isEmpty(gameDigestEntity.getId())) { // 关注游戏 if (finalDownloadEntity != null && gameDigestEntity.getId().equals(finalDownloadEntity.getGameId())) { ConcernUtils.INSTANCE.postConcernGameId(MainActivity.this, gameDigestEntity.getId(), null, false); } } } } }); } postNewlyInstalledApp(gameId, packageName); } if ("卸载".equals(busFour.getType())) { mPackageViewModel.addUninstalledGame(packageName); if (mDownloadEntity != null && mDownloadEntity.isPluggable()) { Map kv6 = new HashMap<>(); kv6.put("安装或卸载", "卸载完成"); DataUtils.onEvent(this, "插件化", mDownloadEntity.getName(), kv6); DataUtils.onMtaEvent(this, "插件化_新", "位置", mDownloadEntity.getEntrance(), "游戏", mDownloadEntity.getName() + "-" + mDownloadEntity.getPlatform(), "操作", "卸载完成", "网络状态", DeviceUtils.getNetwork(HaloApp.getInstance().getApplication())); startActivity(PackageUtils.getInstallIntent(this, mDownloadEntity.getPath())); } // 更新已安装游戏 deleteInstalledPackage(packageName); } DataCollectionUtils.uploadInorunstall(this, busFour.getType(), busFour.getPackageName()); } @SuppressLint("CheckResult") private void postNewlyInstalledApp(String gameId, String packageName) { // 发送应用变更前都检查一下是否需要把所有应用都上传 PackageRepository.checkAndUploadAppList(); JSONObject packageObject = PackageUtils.getAppBasicInfoByPackageName(packageName); RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), packageObject.toString()); // 更新已安装游戏 RetrofitManager.getInstance(MainActivity.this).getApi() .postNewlyInstalledApp(HaloApp.getInstance().getGid(), requestBody) .subscribeOn(Schedulers.io()) .observeOn(Schedulers.io()) .subscribe(new EmptyResponse<>()); if (!TextUtils.isEmpty(gameId) && UserManager.getInstance().isLoggedIn()) { RetrofitManager.getInstance(MainActivity.this).getApi() .postPlayedGame(UserManager.getInstance().getUserId(), gameId) .subscribeOn(Schedulers.io()) .observeOn(Schedulers.io()) .subscribe(new EmptyResponse<>()); } } @SuppressLint("CheckResult") private void deleteInstalledPackage(String packageName) { // 发送应用变更前都检查一下是否需要把所有应用都上传 PackageRepository.checkAndUploadAppList(); // 删除已安装游戏 RetrofitManager.getInstance(MainActivity.this).getApi() .deleteInstalledApp(HaloApp.getInstance().getGid(), packageName) .subscribeOn(Schedulers.io()) .observeOn(Schedulers.io()) .subscribe(new EmptyResponse<>()); } // 接收登录和登出更新事件统计的 Meta @Subscribe(threadMode = ThreadMode.MAIN) public void onEventMainThread(EBReuse reuse) { if (reuse.getType().equals(LOGIN_TAG) || reuse.getType().equals(LOGOUT_TAG)) { MetaUtil.INSTANCE.refreshMeta(); } } }