add yunba push library

display-client/AndroidManifest.xml

@@ -37,6 +37,9 @@
    <uses-permission android:name="android.permission.CHANGE_WIFI_STATE" />
    <uses-permission android:name="android.permission.CHANGE_CONFIGURATION" />
    <uses-permission android:name="android.permission.KILL_BACKGROUND_PROCESSES" />
    
    <uses-permission android:name="android.permission.RECEIVE_USER_PRESENT" />
    <uses-permission android:name="android.permission.WAKE_LOCK" />
    <application
        android:allowBackup="true"
@@ -116,6 +119,24 @@
            android:name="com.wade.mobile.common.map.activity.SelectLocationActivity"
            android:screenOrientation="portrait" >
        </activity>
        
         <!-- YunBa Start -->
        <meta-data
            android:name="YUNBA_APPKEY"
            android:value="5630418ff085fc471efdf2c9" />
        <service android:name="io.yunba.android.core.YunBaService" >
        </service>
        <receiver android:name="io.yunba.android.core.YunBaReceiver" >
            <intent-filter>
                <action android:name="android.intent.action.USER_PRESENT" />
                <action android:name="android.net.conn.CONNECTIVITY_CHANGE" />
            </intent-filter>
        </receiver>
        
        <!-- YunBa End -->
    </application>
</manifest>

display-client/assets/mobile-action.xml

@@ -101,10 +101,16 @@
	<action name="selectFirst" class="com.wade.mobile.func.MobileDB" method="selectFirst"></action>
	
	<!-- MobilePush -->
	<!-- 
	<action name="registerForPush" class="com.ai.mobile.im.func.MobilePush" method="registerForPush"></action>
	<action name="unregisterForPush" class="com.ai.mobile.im.func.MobilePush" method="unregisterForPush"></action>
	<action name="sendText" class="com.ai.mobile.im.func.MobilePush" method="sendText"></action>
	<action name="setCallbackForPush" class="com.ai.mobile.im.func.MobilePush" method="setCallbackForPush"></action>
	 -->
	<action name="registerForPushWithYunba"    class="com.ai.ipu.mobile.push.YunBaPush" method="registerForPush"></action>
	<action name="unregisterForPushWithYunba"  class="com.ai.ipu.mobile.push.YunBaPush" method="unregisterForPush"></action>
	<action name="sendTextWithYunba"           class="com.ai.ipu.mobile.push.YunBaPush" method="sendText"></action>
	<action name="setCallbackForPushWithYunba" class="com.ai.ipu.mobile.push.YunBaPush" method="setCallbackForPush"></action>
	
	<action name="getContacts" class="com.wade.mobile.func.MobileContactDetail" method="getContacts"></action>
</actions>

wade-mobile-push-yunba/.gitignore

@@ -0,0 +1,7 @@
/.settings
/bin
/gen
/proguard
/.classpath
/project.properties

wade-mobile-push-yunba/.project

@@ -0,0 +1,33 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
	<name>wade-mobile-push-yunba</name>
	<comment></comment>
	<projects>
	</projects>
	<buildSpec>
		<buildCommand>
			<name>com.android.ide.eclipse.adt.ResourceManagerBuilder</name>
			<arguments>
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>com.android.ide.eclipse.adt.PreCompilerBuilder</name>
			<arguments>
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>org.eclipse.jdt.core.javabuilder</name>
			<arguments>
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>com.android.ide.eclipse.adt.ApkBuilder</name>
			<arguments>
			</arguments>
		</buildCommand>
	</buildSpec>
	<natures>
		<nature>com.android.ide.eclipse.adt.AndroidNature</nature>
		<nature>org.eclipse.jdt.core.javanature</nature>
	</natures>
</projectDescription>

wade-mobile-push-yunba/AndroidManifest.xml

@@ -0,0 +1,17 @@
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.ai.ipu.mobile.push"
    android:versionCode="1"
    android:versionName="1.0" >
    <uses-sdk
        android:minSdkVersion="8"
        android:targetSdkVersion="15" />
    <application
        android:allowBackup="true"
        android:icon="@drawable/ic_launcher"
        android:label="@string/app_name"
        android:theme="@style/AppTheme" >
    </application>
</manifest>

wade-mobile-push-yunba/proguard-project.txt

@@ -0,0 +1,20 @@
# To enable ProGuard in your project, edit project.properties
# to define the proguard.config property as described in that file.
#
# Add project specific ProGuard rules here.
# By default, the flags in this file are appended to flags specified
# in ${sdk.dir}/tools/proguard/proguard-android.txt
# You can edit the include path and order by changing the ProGuard
# include property in project.properties.
#
# For more details, see
#   http://developer.android.com/guide/developing/tools/proguard.html
# Add any project specific keep options here:
# If your project uses WebView with JS, uncomment the following
# and specify the fully qualified class name to the JavaScript interface
# class:
#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
#   public *;
#}

wade-mobile-push-yunba/readme.md

@@ -0,0 +1,18 @@
 ### 添加以下代码到主工程，YUNBA_APPKEY 需要到云巴官网申请
 <!-- YunBa Start -->
	<meta-data
	    android:name="YUNBA_APPKEY"
	    android:value="55f8e4994a481fa955f393e4" />
	
	<service android:name="io.yunba.android.core.YunBaService" >
	</service>
	
	<receiver android:name="io.yunba.android.core.YunBaReceiver" >
	    <intent-filter>
	        <action android:name="android.intent.action.USER_PRESENT" />
	        <action android:name="android.net.conn.CONNECTIVITY_CHANGE" />
	    </intent-filter>
	</receiver>
<!-- YunBa End -->

wade-mobile-push-yunba/res/values-v11/styles.xml

@@ -0,0 +1,11 @@
<resources>
    <!--
        Base application theme for API 11+. This theme completely replaces
        AppBaseTheme from res/values/styles.xml on API 11+ devices.
    -->
    <style name="AppBaseTheme" parent="android:Theme.Holo.Light">
        <!-- API 11 theme customizations can go here. -->
    </style>
</resources>

wade-mobile-push-yunba/res/values-v14/styles.xml

@@ -0,0 +1,12 @@
<resources>
    <!--
        Base application theme for API 14+. This theme completely replaces
        AppBaseTheme from BOTH res/values/styles.xml and
        res/values-v11/styles.xml on API 14+ devices.
    -->
    <style name="AppBaseTheme" parent="android:Theme.Holo.Light.DarkActionBar">
        <!-- API 14 theme customizations can go here. -->
    </style>
</resources>

wade-mobile-push-yunba/res/values/strings.xml

@@ -0,0 +1,5 @@
<resources>
    <string name="app_name">wade-mobile-push-yunba</string>
</resources>

wade-mobile-push-yunba/res/values/styles.xml

@@ -0,0 +1,20 @@
<resources>
    <!--
        Base application theme, dependent on API level. This theme is replaced
        by AppBaseTheme from res/values-vXX/styles.xml on newer devices.
    -->
    <style name="AppBaseTheme" parent="android:Theme.Light">
        <!--
            Theme customizations available in newer API levels can go in
            res/values-vXX/styles.xml, while customizations related to
            backward-compatibility can go here.
        -->
    </style>
    <!-- Application theme. -->
    <style name="AppTheme" parent="AppBaseTheme">
        <!-- All customizations that are NOT specific to a particular API-level can go here. -->
    </style>
</resources>

wade-mobile-push-yunba/src/com/ai/ipu/mobile/push/YunBaPush.java

@@ -0,0 +1,268 @@
package com.ai.ipu.mobile.push;
import io.yunba.android.manager.YunBaManager;
import org.eclipse.paho.client.mqttv3.IMqttActionListener;
import org.eclipse.paho.client.mqttv3.IMqttToken;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.util.Log;
import com.ai.mobile.im.PushManager;
import com.ai.mobile.im.util.PushSharedPrefHelper;
import com.wade.mobile.frame.IWadeMobile;
import com.wade.mobile.frame.plugin.Plugin;
import com.wade.mobile.helper.SharedPrefHelper;
import com.wade.mobile.util.EscapeUnescape;
public class YunBaPush extends Plugin {
	private final String PUSH_CALLBACK = "PUSH_CALLBACK";
	private BroadcastReceiver msgReceiver;
	private String topic = "IPU";
	private String alias;
	public YunBaPush(IWadeMobile wademobile) {
		super(wademobile);
	}
	public void registerForPush(JSONArray param) throws Exception {
		/* YunBa Start */
		YunBaManager.start(context.getApplicationContext());
		// 订阅
		subscribeTopic(new String[] { topic });
		// 注册昵称
		alias = param.getString(0);
		reigisterYuBaAlias(alias);
		// Receiver
		registerYuBaReceiver();
		/* YunBa End */
	}
	private void subscribeTopic(String[] topics) {
		YunBaManager.subscribe(context.getApplicationContext(), topics,
				new IMqttActionListener() {
					@Override
					public void onSuccess(IMqttToken arg0) {
						YunBaUtil.showToast("连接成功", context);
						YunBaPush.this.callback("SUC");
					}
					@Override
					public void onFailure(IMqttToken arg0, Throwable arg1) {
						Log.d(TAG, "Subscribe topic failed");
					}
				});
	}
	private void reigisterYuBaAlias(String alias) {
		if (YunBaUtil.isEmpty(alias)) {
			YunBaUtil.showToast("alias不能为空", context);
			return;
		}
		YunBaManager.setAlias(context.getApplicationContext(), alias,
				new IMqttActionListener() {
					@Override
					public void onSuccess(IMqttToken asyncActionToken) {
						Log.d(TAG, "success");
					}
					@Override
					public void onFailure(IMqttToken asyncActionToken,
							Throwable exception) {
						if (exception instanceof MqttException) {
							MqttException ex = (MqttException) exception;
							String msg = "setAlias failed with error code : "
									+ ex.getReasonCode();
							YunBaUtil.showToast(msg,
									context.getApplicationContext());
						}
					}
				});
	}
	private void registerYuBaReceiver() {
		if (msgReceiver == null) {
			msgReceiver = new BroadcastReceiver() {
				@Override
				public void onReceive(Context context, Intent intent) {
					if (YunBaManager.MESSAGE_RECEIVED_ACTION.equals(intent
							.getAction())) {
						String topic = intent
								.getStringExtra(YunBaManager.MQTT_TOPIC);
						String msg = intent
								.getStringExtra(YunBaManager.MQTT_MSG);
						//  在这里处理从服务器发布下来的消息， 比如显示通知栏， 打开 Activity 等等
						StringBuilder showMsg = new StringBuilder();
						showMsg.append("Received message from server: ")
								.append(YunBaManager.MQTT_TOPIC).append(" = ")
								.append(topic).append(" ")
								.append(YunBaManager.MQTT_MSG).append(" = ")
								.append(msg);
						// YunBaUtil.showNotifation(context, topic, msg);
						Log.d("", showMsg.toString());
						try {
							String aliasStr = null;
							String contentStr = null;
							String resultStr = null;
							if (!msg.startsWith("{")) {
								resultStr = "{\"ALIAS\":\"匿名用户\",\"MSG\":\""
										+ msg + "\"}";
							} else {
								JSONObject msgJson = new JSONObject(msg);
								aliasStr = msgJson.getString("ALIAS");
								contentStr = msgJson.getString("MSG");
								aliasStr = YunBaUtil.isEmpty(aliasStr) ? "匿名用户"
										: aliasStr;
								resultStr = "{\"ALIAS\":\"" + aliasStr
										+ "\",\"MSG\":\"" + contentStr + "\"}";
							}
							sendCallbackMsg(resultStr);
						} catch (JSONException e) {
							e.printStackTrace();
						}
					}else if(YunBaManager.PRESENCE_RECEIVED_ACTION.equals(intent.getAction())) {
						 //此消息由当前客户端发出，暂时不处理
						
							
					}
				}
			};
			IntentFilter msgFilter = new IntentFilter();
			msgFilter.addAction("io.yunba.android.MESSAGE_RECEIVED_ACTION");
			msgFilter.addCategory(context.getPackageName());
			context.registerReceiver(msgReceiver, msgFilter);
		}
	}
	public void unregisterForPush(JSONArray param) {
		if (msgReceiver != null) {
			context.unregisterReceiver(msgReceiver);
			msgReceiver = null;
			YunBaManager.unsubscribe(context.getApplicationContext(),
					new String[] { topic }, new IMqttActionListener() {
						@Override
						public void onSuccess(IMqttToken arg0) {
							Log.d(TAG, "unsubscribe topic succeed");
						}
						@Override
						public void onFailure(IMqttToken arg0, Throwable arg1) {
							Log.d(TAG, "unsubscribe topic failed");
						}
					});
		}
	}
	@Override
	public void onStop() {
		YunBaManager.stop(context.getApplicationContext());
		super.onStop();
	}
	public void setCallbackForPush(JSONArray param) throws Exception {
		String callback = param.getString(0);
		new SharedPrefHelper(context).put(PushManager.PUSH_STORAGE,
				PUSH_CALLBACK, callback);
	}
	public void sendText(JSONArray param) throws Exception {
		String receiver = param.getString(0);
		String msg = param.getString(1);
		final String content = "{\"ALIAS\":\"" + alias + "\",\"MSG\":\"" + msg
				+ "\"}";
		if ("ALL".equals(receiver)) {
			YunBaManager.publish(context.getApplicationContext(), topic,
					content, new IMqttActionListener() {
						@Override
						public void onSuccess(IMqttToken asyncActionToken) {
							String topic = YunBaUtil.join(
									asyncActionToken.getTopics(), ", ");
							String msgLog = "publish to alias succeed : "
									+ topic;
							YunBaUtil.showToast(msgLog,
									context.getApplicationContext());
							YunBaPush.this.callback("SUC");
						}
						@Override
						public void onFailure(IMqttToken asyncActionToken,
								Throwable exception) {
							if (exception instanceof MqttException) {
								MqttException ex = (MqttException) exception;
								String msg = "publishToAlias failed with error code : "
										+ ex.getReasonCode();
								YunBaUtil.showToast(msg,
										context.getApplicationContext());
							}
						}
					});
		} else {
			YunBaManager.publishToAlias(context.getApplicationContext(),
					receiver, content, new IMqttActionListener() {
						@Override
						public void onSuccess(IMqttToken asyncActionToken) {
							String topic = YunBaUtil.join(
									asyncActionToken.getTopics(), ", ");
							String msgLog = "publish to alias succeed : "
									+ topic;
							YunBaUtil.showToast(msgLog,
									context.getApplicationContext());
							YunBaPush.this.callback("SUC");
							sendCallbackMsg(content);
						}
						@Override
						public void onFailure(IMqttToken asyncActionToken,
								Throwable exception) {
							if (exception instanceof MqttException) {
								MqttException ex = (MqttException) exception;
								String msg = "publishToAlias failed with error code : "
										+ ex.getReasonCode();
								YunBaUtil.showToast(msg,
										context.getApplicationContext());
							}
						}
					});
		}
	}
	private void sendCallbackMsg(String resultStr) {
		callback = PushSharedPrefHelper.get(wademobile.getActivity(),
				PushManager.PUSH_STORAGE, PUSH_CALLBACK, "alert");
		callback = "(function(msg){" + callback + "(unescape(msg));})";// 转义
		wademobile.getCurrentWebView().executeJs(
				callback + "('" + EscapeUnescape.escape(resultStr) + "')");
	}
}

wade-mobile-push-yunba/src/com/ai/ipu/mobile/push/YunBaUtil.java

@@ -0,0 +1,173 @@
package com.ai.ipu.mobile.push;
import io.yunba.android.manager.YunBaManager;
import java.util.List;
import java.util.Random;
import android.app.ActivityManager;
import android.app.ActivityManager.RunningAppProcessInfo;
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.PackageManager;
import android.content.pm.PackageManager.NameNotFoundException;
import android.media.RingtoneManager;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.net.Uri;
import android.os.Bundle;
import android.os.Looper;
import android.support.v4.app.NotificationCompat;
import android.support.v4.app.TaskStackBuilder;
import android.telephony.TelephonyManager;
import android.widget.Toast;
public class YunBaUtil {
	public static boolean isEmpty(String s) {
		if (null == s)
			return true;
		if (s.length() == 0)
			return true;
		if (s.trim().length() == 0)
			return true;
		return false;
	}
	public static boolean showNotifation(Context context, String topic,
			String msg) {
		try {
			Uri alarmSound = RingtoneManager
					.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION);
			long[] pattern = { 500, 500, 500 };
			NotificationCompat.Builder mBuilder = new NotificationCompat.Builder(
					context).setSmallIcon(R.drawable.ic_launcher)
					.setContentTitle(topic).setContentText(msg)
					.setSound(alarmSound).setVibrate(pattern)
					.setAutoCancel(true);
			// Creates an explicit intent for an Activity in your app
			Intent resultIntent = new Intent(context, context.getClass());
			if (!YunBaUtil.isEmpty(topic))
				resultIntent.putExtra(YunBaManager.MQTT_TOPIC, topic);
			if (!YunBaUtil.isEmpty(msg))
				resultIntent.putExtra(YunBaManager.MQTT_MSG, msg);
			// The stack builder object will contain an artificial back stack
			// for the
			// started Activity.
			// This ensures that navigating backward from the Activity leads out
			// of
			// your application to the Home screen.
			TaskStackBuilder stackBuilder = TaskStackBuilder.create(context);
			// Adds the back stack for the Intent (but not the Intent itself)
			stackBuilder.addParentStack(context.getClass());
			// Adds the Intent that starts the Activity to the top of the stack
			stackBuilder.addNextIntent(resultIntent);
			PendingIntent resultPendingIntent = stackBuilder.getPendingIntent(
					0, PendingIntent.FLAG_UPDATE_CURRENT);
//			mBuilder.setContentIntent(resultPendingIntent);
			NotificationManager mNotificationManager = (NotificationManager) context
					.getSystemService(Context.NOTIFICATION_SERVICE);
			// mId allows you to update the notification later on.
			Random r = new Random();
			mNotificationManager.notify(r.nextInt(), mBuilder.build());
		} catch (Exception e) {
			return false;
		}
		return true;
	}
	public static void showToast(final String toast, final Context context) {
		if (!isAppOnForeground(context))
			return;
		new Thread(new Runnable() {
			@Override
			public void run() {
				Looper.prepare();
				Toast.makeText(context, toast, Toast.LENGTH_SHORT).show();
				Looper.loop();
			}
		}).start();
	}
	public static boolean isAppOnForeground(Context context) {
		ActivityManager activityManager = (ActivityManager) context
				.getSystemService(Context.ACTIVITY_SERVICE);
		// Returns a list of application processes that are running on the
		// device
		List<RunningAppProcessInfo> appProcesses = activityManager
				.getRunningAppProcesses();
		if (appProcesses == null)
			return false;
		for (RunningAppProcessInfo appProcess : appProcesses) {
			// importance:
			// The relative importance level that the system places
			// on this process.
			// May be one of IMPORTANCE_FOREGROUND, IMPORTANCE_VISIBLE,
			// IMPORTANCE_SERVICE, IMPORTANCE_BACKGROUND, or IMPORTANCE_EMPTY.
			// These constants are numbered so that "more important" values are
			// always smaller than "less important" values.
			// processName:
			// The name of the process that this object is associated with.
			if (appProcess.processName.equals(context.getPackageName())
					&& appProcess.importance == RunningAppProcessInfo.IMPORTANCE_FOREGROUND) {
				return true;
			}
		}
		return false;
	}
	public static <T> String join(T[] array, String cement) {
		StringBuilder builder = new StringBuilder();
		if (array == null || array.length == 0) {
			return null;
		}
		for (T t : array) {
			builder.append(t).append(cement);
		}
		builder.delete(builder.length() - cement.length(), builder.length());
		return builder.toString();
	}
	public static boolean isNetworkEnabled(Context context) {
		ConnectivityManager conn = (ConnectivityManager) context
				.getSystemService(Context.CONNECTIVITY_SERVICE);
		NetworkInfo info = conn.getActiveNetworkInfo();
		return (info != null && info.isConnected());
	}
	public static String getImei(Context context, String imei) {
		TelephonyManager telephonyManager = (TelephonyManager) context
				.getSystemService(Context.TELEPHONY_SERVICE);
		imei = telephonyManager.getDeviceId();
		return imei;
	}
	public static String getAppKey(Context context) {
		Bundle metaData = null;
		String appKey = null;
		try {
			ApplicationInfo ai = context.getPackageManager()
					.getApplicationInfo(context.getPackageName(),
							PackageManager.GET_META_DATA);
			if (null != ai) {
				metaData = ai.metaData;
			}
			if (null != metaData) {
				appKey = metaData.getString("YUNBA_APPKEY");
				if ((null == appKey) || appKey.length() != 24) {
					appKey = "Error";
				}
			}
		} catch (NameNotFoundException e) {
		}
		return appKey;
	}
}