package com.gh.base; import android.app.Notification; import android.app.NotificationManager; import android.app.PendingIntent; import android.content.Context; import android.content.Intent; import android.content.pm.ApplicationInfo; import android.content.pm.PackageInfo; import android.graphics.BitmapFactory; import android.os.Build; import android.support.v4.app.NotificationCompat; import android.support.v4.util.ArrayMap; import android.util.Log; import android.widget.RemoteViews; import com.gh.common.util.FileUtils; import com.gh.common.util.PackageUtils; import com.gh.common.util.Utils; import com.gh.gamecenter.R; import com.xiaomi.mipush.sdk.MiPushCommandMessage; import com.xiaomi.mipush.sdk.MiPushMessage; import com.xiaomi.mipush.sdk.PushMessageReceiver; import org.json.JSONArray; import org.json.JSONException; import org.json.JSONObject; import java.io.File; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Locale; /** * 1、PushMessageReceiver是个抽象类,该类继承了BroadcastReceiver。 * 2、需要将自定义的DemoMessageReceiver注册在AndroidManifest.xml文件中 * * * * * 3、DemoMessageReceiver的onReceivePassThroughMessage方法用来接收服务器向客户端发送的透传消息 * 4、DemoMessageReceiver的onNotificationMessageClicked方法用来接收服务器向客户端发送的通知消息, * 这个回调方法会在用户手动点击通知后触发 * 5、DemoMessageReceiver的onNotificationMessageArrived方法用来接收服务器向客户端发送的通知消息, * 这个回调方法是在通知消息到达客户端时触发。另外应用在前台时不弹出通知的通知消息到达客户端也会触发这个回调函数 * 6、DemoMessageReceiver的onCommandResult方法用来接收客户端向服务器发送命令后的响应结果 * 7、DemoMessageReceiver的onReceiveRegisterResult方法用来接收客户端向服务器发送注册命令后的响应结果 * 8、以上这些方法运行在非UI线程中 * * @author mayixiang */ public class GHPushMessageReceiver extends PushMessageReceiver { @Override public void onReceivePassThroughMessage(Context context, MiPushMessage message) { // 1判断notifyid是否为4 try { if (message.getNotifyId() == 4) { JSONObject jsonObject = new JSONObject(message.getContent()); Utils.log(jsonObject.toString()); String channel = jsonObject.getString("channel"); Utils.log("channel = " + channel); // 1判断渠道号是否一致或是否为ALL String TD_CHANNEL_ID = (String) PackageUtils.getMetaData(context, context.getPackageName(), "TD_CHANNEL_ID"); if ("ALL".equals(channel) || channel.equalsIgnoreCase(TD_CHANNEL_ID)) { String type = jsonObject.getString("type"); Utils.log("type = " + type); if ("NEWS".equals(type)) { // 新闻推送 JSONArray jsonArray = jsonObject.getJSONArray("package"); ArrayMap map = getInstalledMapFromLocal(context); for (int i = 0; i < jsonArray.length(); i++) { Boolean b = map.get(jsonArray.getString(i)); if (b != null) { // 显示推送的消息 showNotification(context, jsonObject, 0); break; } } } else if ("PLUGIN_UPDATE".equals(type)) { // 插件更新推送 JSONArray jsonArray = jsonObject.getJSONArray("apk"); ArrayMap map = getInstalledMapFromLocal(context); for (int i = 0; i < jsonArray.length(); i++) { JSONObject apk = jsonArray.getJSONObject(i); String packageName = apk.getString("package"); Boolean b = map.get(packageName); if (b != null) { // 判断是否gh_version是否相同 String gh_version = (String) PackageUtils .getMetaData(context, packageName, "gh_version"); if (gh_version != null) { gh_version = gh_version.substring(2); // 判断gh_version是否相同 if (gh_version.equals(apk.getString("gh_version"))) { // 判断version是否相同 String version = PackageUtils.getVersionByPackage( context, packageName); if (apk.getString("version").equals(version)) { // 版本相同,无需显示插件更新,继续查看是否有可更新的游戏包 continue; } } } // 显示推送的消息 showNotification(context, jsonObject, 1); break; } } } else if ("NEW_GAME".equals(type)) { // 新游推送 showNotification(context, jsonObject, 2); } } } } catch (JSONException e) { e.printStackTrace(); } Log.v(AppController.TAG, "onReceivePassThroughMessage is called. " + message.toString()); } private void showNotification(Context context, JSONObject jsonObject, int id) throws JSONException { Intent intent = new Intent(); intent.setAction("com.gh.gamecenter.NOTIFICATION"); intent.putExtra("notifyId", id); intent.putExtra("notifyData", jsonObject.toString()); PendingIntent pendingIntent = PendingIntent.getBroadcast(context, id, intent, PendingIntent.FLAG_ONE_SHOT); NotificationManager nManager = (NotificationManager) context .getSystemService(Context.NOTIFICATION_SERVICE); Notification notification = new NotificationCompat.Builder(context) .setSmallIcon(R.drawable.logo) .setTicker(jsonObject.getString("pushTitle")) .setContentTitle(jsonObject.getString("pushTitle")) .setContentText(jsonObject.getString("pushDesc")) .setContentIntent(pendingIntent).build(); RemoteViews remoteViews = null; if (Build.MANUFACTURER.equals("Meizu") && (Build.MODEL.startsWith("m") || Build.MODEL.startsWith("MX"))) { remoteViews = new RemoteViews(context.getPackageName(), R.layout.notification_meizu); SimpleDateFormat format = new SimpleDateFormat("HH:mm", Locale.getDefault()); remoteViews.setTextViewText(R.id.time, format.format(new Date())); } else if (Build.MANUFACTURER.equals("Xiaomi") && (Build.MODEL.startsWith("MI") || Build.MODEL.startsWith("HM") || Build.MODEL.startsWith("Redmi"))) { // 小米系统 remoteViews = new RemoteViews(context.getPackageName(), R.layout.notification_xiaomi); SimpleDateFormat format = new SimpleDateFormat("ah:mm", Locale.getDefault()); remoteViews.setTextViewText(R.id.time, format.format(new Date())); } else if (Build.MANUFACTURER.equals("HUAWEI")) { // 华为系统 remoteViews = new RemoteViews(context.getPackageName(), R.layout.notification_huawei); } String url = jsonObject.getString("icon"); String path = context.getCacheDir() + File.separator + url.substring(url.lastIndexOf("/") + 1); try { int result = FileUtils.downloadFile(url, path); if (result == -1) { // 下载出错,使用光环logo path = null; } } catch (IOException e) { // 下载出错,使用光环logo path = null; e.printStackTrace(); } if (remoteViews != null) { if (path == null) { remoteViews.setImageViewBitmap(R.id.icon, BitmapFactory.decodeResource(context.getResources(), R.drawable.logo)); } else { remoteViews.setImageViewBitmap(R.id.icon, BitmapFactory.decodeFile(path)); } remoteViews.setTextViewText(R.id.title, jsonObject.getString("pushTitle")); remoteViews.setTextViewText(R.id.intro, jsonObject.getString("pushDesc")); notification.contentView = remoteViews; } else { NotificationCompat.Builder builder = new NotificationCompat.Builder(context) .setSmallIcon(R.drawable.logo_black) .setTicker(jsonObject.getString("pushTitle")) .setContentTitle(jsonObject.getString("pushTitle")) .setContentText(jsonObject.getString("pushDesc")) .setContentIntent(pendingIntent); if (path == null) { builder.setLargeIcon(BitmapFactory.decodeResource(context.getResources(), R.drawable.logo)); } else { builder.setLargeIcon(BitmapFactory.decodeFile(path)); } notification = builder.build(); } notification.defaults = Notification.DEFAULT_SOUND;// 添加系统默认声音 notification.flags |= Notification.FLAG_AUTO_CANCEL; // FLAG_AUTO_CANCEL表明当通知被用户点击时,通知将被清除。 nManager.notify(((int) System.currentTimeMillis() / 1000), notification);// 通过通知管理器来发起通知。如果id不同,则每click,在status哪里增加一个提示 } private ArrayMap getInstalledMapFromLocal(Context context) { ArrayMap map = new ArrayMap<>(); ArrayList list = getAllPackageName(context); for (String str : list) { map.put(str, true); } return map; } private ArrayList getAllPackageName(Context context) { ArrayList list = new ArrayList<>(); List packageInfos = context.getPackageManager() .getInstalledPackages(0); for (int i = 0, size = packageInfos.size(); i < size; i++) { PackageInfo packageInfo = packageInfos.get(i); if ((packageInfo.applicationInfo.flags & ApplicationInfo.FLAG_SYSTEM) == 0) { list.add(packageInfo.packageName); } } return list; } @Override public void onNotificationMessageClicked(Context context, MiPushMessage message) { Log.v(AppController.TAG, "onNotificationMessageClicked is called. " + message.toString()); } @Override public void onNotificationMessageArrived(Context context, MiPushMessage message) { Log.v(AppController.TAG, "onNotificationMessageArrived is called. " + message.toString()); } @Override public void onCommandResult(Context context, MiPushCommandMessage message) { Log.v(AppController.TAG, "onCommandResult is called. " + message.toString()); } @Override public void onReceiveRegisterResult(Context context, MiPushCommandMessage message) { Log.v(AppController.TAG, "onReceiveRegisterResult is called. " + message.toString()); } }