replace push sdk

config.gradle

@@ -112,7 +112,7 @@ ext {
             //统一返回键
             mogomoduleback           : "com.mogo.module:module-back:${MOGO_MODULE_BACK_VERSION}",
             // 长链
-            socketsdk                : 'com.zhidao.socketsdk:socketsdk:2.1.0',
+            socketsdk                : 'com.zhidao.socketsdk:socketsdk:2.1.1',
             socketsdkconnsvrprotoco  : 'com.zhidao.ptech:connsvr-protoco:0.1.23',
             socketsdkprotobufjava    : 'com.google.protobuf:protobuf-java:3.5.1',
 

foudations/mogo-connection/src/main/java/com/mogo/connection/socket/IMessageResponse.java

@@ -0,0 +1,17 @@
+package com.mogo.connection.socket;
+
+/**
+ * @author congtaowang
+ * @since 2020-02-20
+ * <p>
+ * 长链接口数据接口
+ */
+public interface IMessageResponse {
+
+    /**
+     * 设置消息id
+     *
+     * @param msgId
+     */
+    void setMsgId( long msgId );
+}

foudations/mogo-connection/src/main/java/com/mogo/connection/socket/SocketManager.java

@@ -82,7 +82,7 @@ public class SocketManager implements IMogoSocketManager, OnSocketReceiveCallbac
     }
 
     @Override
-    public void onMessageReceived( byte[] content ) {
+    public void onMessageReceived( byte[] content, long msgId ) {
         try {
             MogoConnsvr.Payload payload = MogoConnsvr.Payload.parseFrom( content );
             int msgType = payload.getMsgType();
@@ -93,8 +93,12 @@ public class SocketManager implements IMogoSocketManager, OnSocketReceiveCallbac
                 while ( iterator.hasNext() ) {
                     IMogoOnMessageListener listener = iterator.next();
                     if ( listener != null ) {
-                        Logger.d(TAG, "received msg ==" + payload.getPayload().toStringUtf8());
-                        listener.onMsgReceived( GsonUtil.objectFromJson( payload.getPayload().toStringUtf8(), listener.target() ) );
+                        Object obj = GsonUtil.objectFromJson( payload.getPayload().toStringUtf8(), listener.target() );
+                        if ( obj instanceof IMessageResponse ) {
+                            ( ( IMessageResponse ) obj ).setMsgId( msgId );
+                        }
+                        Logger.d(TAG, "received msg == %s, msgId = %s", payload.getPayload().toStringUtf8(), msgId);
+                        listener.onMsgReceived( obj );
                     }
                 }
             }