From 107509682332dfe827db44b7cd0adb1a29bd2905 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=91=A3=E5=AE=8F=E5=AE=87?= Date: Sun, 7 Feb 2021 11:34:00 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E5=AD=98=E5=82=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/mogo/cloud/live/socket/SocketMsgUtils.java | 4 ++-- .../com/mogo/cloud/live/socket/SocketRequestUtils.java | 9 --------- 2 files changed, 2 insertions(+), 11 deletions(-) diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java index f123665..843aaa9 100644 --- a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java +++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketMsgUtils.java @@ -15,7 +15,7 @@ public class SocketMsgUtils implements IMogoCloudSocketMsgAckListener { private static final String TAG = "SocketMsgUtils"; private static final String appId = "liveStream"; - private static final int msgType = 1973; + private static final int headerType = 1973; private static volatile SocketMsgUtils sInstance; @@ -56,7 +56,7 @@ public class SocketMsgUtils implements IMogoCloudSocketMsgAckListener { * @param body 数据包 */ public void uploadCamInfo(MsgBody body) { - mSocketManager.sendMsg(appId, msgType, body, this); + mSocketManager.sendMsg(appId, headerType, body, this); } /** diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketRequestUtils.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketRequestUtils.java index b4df8dd..a2e2634 100644 --- a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketRequestUtils.java +++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/socket/SocketRequestUtils.java @@ -1,7 +1,5 @@ package com.mogo.cloud.live.socket; -import com.google.protobuf.ByteString; -import com.zhidao.ptech.connsvr.protocol.MogoConnsvr; import com.zhidao.ptech.shadow.server.protocol.DeviceInfo; import com.zhidao.utils.common.TelephoneUtil; @@ -20,12 +18,5 @@ public class SocketRequestUtils { return data; } - private static byte[] buildSocketPayload(byte[] payload, int payloadType) { - MogoConnsvr.Payload payloadData = MogoConnsvr.Payload.newBuilder() - .setMsgType(payloadType) - .setPayload(ByteString.copyFrom(payload)).build(); - return payloadData.toByteArray(); - } - }