diff --git a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
index 23f7365..f13fece 100644
--- a/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
+++ b/foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/SocketManager.java
@@ -12,6 +12,7 @@ import com.mogo.cloud.passport.MoGoAiCloudClientConfig;
 import com.mogo.utils.logger.Logger;
 import com.mogo.utils.network.utils.GsonUtil;
 import com.zhidao.locupload.Platform;
+import com.zhidao.ptech.connsvr.commom.protocol.MogoCommon;
 import com.zhidao.ptech.connsvr.protocol.MogoConnsvr;
 import com.zhidao.socket.Callback;
 import com.zhidao.socket.CallbackManager;
@@ -120,7 +121,7 @@ public class SocketManager implements IMogoCloudSocketManager, Callback {
     public void sendMsg(MsgBody body, IMogoCloudSocketMsgAckListener listener) {
         Logger.d(TAG, "sendMsg.");
         final byte[] pb = convertToPBBytes(body.getMsgType(), objectToBytes(body.getContent()));
-        RequestUtil.sendPayloadData(mAppId, 2, pb, 1, true, System.currentTimeMillis());
+        SocketClient.getInstance().sendData(mAppId, MogoCommon.Product.mogoBussiness.getNumber(), pb, 1, true, System.currentTimeMillis());
     }
 
     @Override