From 36a6785ec246af85446f7cc58e754bbaae77152a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=91=A3=E5=AE=8F=E5=AE=87?= <martindhy@gmail.com>
Date: Wed, 3 Feb 2021 14:08:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E5=A7=8B=E7=BC=96=E5=86=99=E7=9B=B4?=
 =?UTF-8?q?=E6=92=AD=E6=A8=A1=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/gradle.xml                              |    1 +
 config.gradle                                 |   14 +-
 foudations/mogo-common/.gitignore             |    1 +
 foudations/mogo-common/build.gradle           |   36 +
 foudations/mogo-common/consumer-rules.pro     |    0
 foudations/mogo-common/gradle.properties      |    4 +
 foudations/mogo-common/proguard-rules.pro     |   21 +
 .../mogo-common/src/main/AndroidManifest.xml  |    5 +
 .../mogo/cloud/common/utils/DevicesUtils.java |    7 +
 foudations/mogo-live/build.gradle             |   20 +
 .../mogo/cloud/live/ILiveStatusCallback.java  |    8 +
 .../com/mogo/cloud/live/IYUVDataCallback.java |    8 +
 .../live/listener/ILiveProgressListener.java  |   55 +
 .../cloud/live/manager/MGLivePushConfig.java  |   83 +
 .../cloud/live/manager/ZeGoLiveManager.java   |  441 +++
 .../com/mogo/cloud/live/model/BaseData.java   |   21 +
 .../mogo/cloud/live/model/LiveStatusInfo.java |   19 +
 .../mogo/cloud/live/model/PlaybackModel.java  |   20 +
 .../cloud/live/model/ResqReportCarAlarm.java  |   18 +
 .../cloud/live/model/StartCarAlarmInfo.java   |    9 +
 .../com/mogo/cloud/live/model/VideoModel.java |   22 +
 .../cloud/live/network/LiveApiServer.java     |   34 +
 .../com/mogo/cloud/live/push/PushService.java |  142 +
 .../cloud/live/utils/FrameManagerUtils.java   |  115 +
 .../shadow/server/protocol/DeviceInfo.java    | 3088 +++++++++++++++++
 settings.gradle                               |    1 +
 26 files changed, 4183 insertions(+), 10 deletions(-)
 create mode 100644 foudations/mogo-common/.gitignore
 create mode 100644 foudations/mogo-common/build.gradle
 create mode 100644 foudations/mogo-common/consumer-rules.pro
 create mode 100644 foudations/mogo-common/gradle.properties
 create mode 100644 foudations/mogo-common/proguard-rules.pro
 create mode 100644 foudations/mogo-common/src/main/AndroidManifest.xml
 create mode 100644 foudations/mogo-common/src/main/java/com/mogo/cloud/common/utils/DevicesUtils.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/ILiveStatusCallback.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/IYUVDataCallback.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/listener/ILiveProgressListener.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/MGLivePushConfig.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/ZeGoLiveManager.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/BaseData.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/LiveStatusInfo.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/PlaybackModel.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/ResqReportCarAlarm.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/StartCarAlarmInfo.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/VideoModel.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/network/LiveApiServer.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/push/PushService.java
 create mode 100644 foudations/mogo-live/src/main/java/com/mogo/cloud/live/utils/FrameManagerUtils.java
 create mode 100644 foudations/mogo-live/src/main/java/com/zhidao/ptech/shadow/server/protocol/DeviceInfo.java

diff --git a/.idea/gradle.xml b/.idea/gradle.xml
index dcd727a..3064d5f 100644
--- a/.idea/gradle.xml
+++ b/.idea/gradle.xml
@@ -13,6 +13,7 @@
             <option value="$PROJECT_DIR$" />
             <option value="$PROJECT_DIR$/app" />
             <option value="$PROJECT_DIR$/foudations" />
+            <option value="$PROJECT_DIR$/foudations/mogo-common" />
             <option value="$PROJECT_DIR$/foudations/mogo-httpdns" />
             <option value="$PROJECT_DIR$/foudations/mogo-live" />
             <option value="$PROJECT_DIR$/foudations/mogo-network" />
diff --git a/config.gradle b/config.gradle
index 1b9ae0e..402fea0 100644
--- a/config.gradle
+++ b/config.gradle
@@ -86,25 +86,19 @@ ext {
             // crash
             crashSdk                 : "com.zhidaoauto.crash.log:library:1.0.5",
 
-            //探路
-            videoarmv7               : "com.shuyu:gsyVideoPlayer-armv7a:7.1.2",
-            videoarm64               : "com.shuyu:gsyVideoPlayer-arm64:7.1.2",
-            videojava                : "com.shuyu:gsyVideoPlayer-java:7.1.2",
-            eventbus                 : "org.greenrobot:eventbus:3.1.1",
             videoprocessor           : "com.zhidao.video:video-processor:1.0.2.1",
-            livesdk                  : "com.tencent.liteavsdk:LiteAVSDK_Smart:7.4.9211",
 
+            // 直播SDK
+            live_sdk_zego                  : "im.zego:express-video:2.0.1",
+
+            //
             coroutinescore           : "org.jetbrains.kotlinx:kotlinx-coroutines-core:1.3.3",
             coroutinesandroid        : "org.jetbrains.kotlinx:kotlinx-coroutines-android:1.3.3",
 
             aspectj                  : "org.aspectj:aspectjrt:1.8.9",
-
             adasapi                  : "com.zhidao.autopilot.support:adas:1.0.6.6",
             adasconfigapi            : "com.zhidao.adasconfig:adasconfig:1.1.5.2",
 
-            // 个人中心的SDK
-            personalsdk              : "com.zhidaoauto.person.info:data:1.0.1",
-
             // obu sdk
             obusdk                   : "com.zhidao.enterprise.smartv2x:smartv2x:1.0.0.3",
 
diff --git a/foudations/mogo-common/.gitignore b/foudations/mogo-common/.gitignore
new file mode 100644
index 0000000..42afabf
--- /dev/null
+++ b/foudations/mogo-common/.gitignore
@@ -0,0 +1 @@
+/build
\ No newline at end of file
diff --git a/foudations/mogo-common/build.gradle b/foudations/mogo-common/build.gradle
new file mode 100644
index 0000000..8a5d99c
--- /dev/null
+++ b/foudations/mogo-common/build.gradle
@@ -0,0 +1,36 @@
+apply plugin: 'com.android.library'
+
+android {
+    compileSdkVersion rootProject.ext.android.compileSdkVersion
+
+    defaultConfig {
+        minSdkVersion rootProject.ext.android.minSdkVersion
+        targetSdkVersion rootProject.ext.android.targetSdkVersion
+
+        versionCode 1
+        versionName "${MOGO_LIVE_VERSION}"
+
+        testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+        consumerProguardFiles "consumer-rules.pro"
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+        }
+    }
+
+
+    compileOptions {
+        sourceCompatibility JavaVersion.VERSION_1_8
+        targetCompatibility JavaVersion.VERSION_1_8
+    }
+
+}
+
+dependencies {
+    implementation fileTree(dir: "libs", include: ["*.jar"])
+    implementation rootProject.ext.dependencies.androidxappcompat
+
+}
\ No newline at end of file
diff --git a/foudations/mogo-common/consumer-rules.pro b/foudations/mogo-common/consumer-rules.pro
new file mode 100644
index 0000000..e69de29
diff --git a/foudations/mogo-common/gradle.properties b/foudations/mogo-common/gradle.properties
new file mode 100644
index 0000000..2d94279
--- /dev/null
+++ b/foudations/mogo-common/gradle.properties
@@ -0,0 +1,4 @@
+GROUP=com.mogo.cloud
+POM_ARTIFACT_ID=common
+VERSION_CODE=1
+VERSION_NAME=1.0.2-SNAPSHOT
\ No newline at end of file
diff --git a/foudations/mogo-common/proguard-rules.pro b/foudations/mogo-common/proguard-rules.pro
new file mode 100644
index 0000000..481bb43
--- /dev/null
+++ b/foudations/mogo-common/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# 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 *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
\ No newline at end of file
diff --git a/foudations/mogo-common/src/main/AndroidManifest.xml b/foudations/mogo-common/src/main/AndroidManifest.xml
new file mode 100644
index 0000000..d29531b
--- /dev/null
+++ b/foudations/mogo-common/src/main/AndroidManifest.xml
@@ -0,0 +1,5 @@
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="com.mogo.cloud.common">
+
+    /
+</manifest>
\ No newline at end of file
diff --git a/foudations/mogo-common/src/main/java/com/mogo/cloud/common/utils/DevicesUtils.java b/foudations/mogo-common/src/main/java/com/mogo/cloud/common/utils/DevicesUtils.java
new file mode 100644
index 0000000..1f0b8bb
--- /dev/null
+++ b/foudations/mogo-common/src/main/java/com/mogo/cloud/common/utils/DevicesUtils.java
@@ -0,0 +1,7 @@
+package com.mogo.cloud.common.utils;
+
+/**
+ * 设备信息
+ */
+public class DevicesUtils {
+}
diff --git a/foudations/mogo-live/build.gradle b/foudations/mogo-live/build.gradle
index 308d24b..22869f9 100644
--- a/foudations/mogo-live/build.gradle
+++ b/foudations/mogo-live/build.gradle
@@ -20,11 +20,31 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
         }
     }
+
+
+    compileOptions {
+        sourceCompatibility JavaVersion.VERSION_1_8
+        targetCompatibility JavaVersion.VERSION_1_8
+    }
+
+
 }
 
 dependencies {
     implementation fileTree(dir: "libs", include: ["*.jar"])
     implementation rootProject.ext.dependencies.androidxappcompat
+    implementation rootProject.ext.dependencies.live_sdk_zego
+
+    implementation 'com.zhidao.ptech:connsvr-protoco:0.1.37'
+    implementation 'com.google.protobuf:protobuf-java:3.10.0'
+
+    if (Boolean.valueOf(RELEASE)) {
+        implementation "com.mogo.cloud:network:${MOGO_NETWORK_VERSION}"
+        implementation "com.mogo.cloud:socket:${MOGO_SOCKET_VERSION}"
+    } else {
+        implementation project(":foudations:mogo-network")
+        implementation project(":foudations:mogo-socket")
+    }
 
 }
 
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/ILiveStatusCallback.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/ILiveStatusCallback.java
new file mode 100644
index 0000000..45a1d12
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/ILiveStatusCallback.java
@@ -0,0 +1,8 @@
+package com.mogo.cloud.live;
+
+/**
+ * 直播状态回调用
+ */
+public interface ILiveStatusCallback {
+    void onChange(String camId, int status);
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/IYUVDataCallback.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/IYUVDataCallback.java
new file mode 100644
index 0000000..00f8f48
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/IYUVDataCallback.java
@@ -0,0 +1,8 @@
+package com.mogo.cloud.live;
+
+/**
+ * YUV数据回调
+ */
+public interface IYUVDataCallback {
+    void onFrame(byte[] data);
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/listener/ILiveProgressListener.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/listener/ILiveProgressListener.java
new file mode 100644
index 0000000..4543ab9
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/listener/ILiveProgressListener.java
@@ -0,0 +1,55 @@
+package com.mogo.cloud.live.listener;
+
+/**
+ * 直播进度监听
+ */
+public interface ILiveProgressListener {
+
+    /**
+     * 开始
+     */
+    default void onStart() {
+    }
+
+    /**
+     * 结束
+     */
+    default void onStop() {
+    }
+
+    /**
+     * 连接成功
+     */
+    void onConnecting();
+
+    /**
+     * 连接成功
+     *
+     * @param roomId 房间ID
+     */
+    void onConnected(String roomId);
+
+    /**
+     * 断开连接
+     */
+    void onDisConnect();
+
+    /**
+     * 当房间数据流更新
+     *
+     * @param streamId 直播流ID
+     * @param isLive   是否是直播
+     */
+    default void onRoomStreamUpdate(String streamId, boolean isLive) {
+    }
+
+    /**
+     * 调试错误信息回调
+     *
+     * @param errorCode 错误码，详情请参考 常见错误码文档 https://doc-zh.zego.im/zh/4378.html
+     * @param funcName  函数名
+     * @param errorInfo 错误的详细信息
+     */
+    void onDebugError(int errorCode, String funcName, String errorInfo);
+
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/MGLivePushConfig.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/MGLivePushConfig.java
new file mode 100644
index 0000000..24995f6
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/MGLivePushConfig.java
@@ -0,0 +1,83 @@
+package com.mogo.cloud.live.manager;
+
+/**
+ * 直播配置对象
+ */
+public class MGLivePushConfig {
+    private int mWidth = 1280;
+    private int mHeight = 720;
+    private int mVideoBitrate = 1200;
+    private int mVideoFPS = 20;
+    private int mAudioSampleRate = 44100;
+    private int mAudioChannels = 1;
+    private int mAudioFormat = 2;
+    private boolean isMute = true;
+
+    public MGLivePushConfig() {
+    }
+
+    public int getWidth() {
+        return this.mWidth;
+    }
+
+    public void setWidth(int width) {
+        this.mWidth = width;
+    }
+
+    public int getHeight() {
+        return this.mHeight;
+    }
+
+    public void setHeight(int height) {
+        this.mHeight = height;
+    }
+
+    public int getVideoBitrate() {
+        return this.mVideoBitrate;
+    }
+
+    public void setVideoBitrate(int videoBitrate) {
+        this.mVideoBitrate = videoBitrate;
+    }
+
+    public int getVideoFPS() {
+        return this.mVideoFPS;
+    }
+
+    public void setVideoFPS(int videoFPS) {
+        this.mVideoFPS = videoFPS;
+    }
+
+    public int getAudioSampleRate() {
+        return this.mAudioSampleRate;
+    }
+
+    public void setAudioSampleRate(int audioSampleRate) {
+        this.mAudioSampleRate = audioSampleRate;
+    }
+
+    public int getAudioChannels() {
+        return this.mAudioChannels;
+    }
+
+    public void setAudioChannels(int audioChannels) {
+        this.mAudioChannels = audioChannels;
+    }
+
+    public int getAudioFormat() {
+        return this.mAudioFormat;
+    }
+
+    public void setAudioFormat(int audioFormat) {
+        this.mAudioFormat = audioFormat;
+    }
+
+    public boolean isMute() {
+        return this.isMute;
+    }
+
+    public void setMute(boolean mute) {
+        this.isMute = mute;
+    }
+}
+
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/ZeGoLiveManager.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/ZeGoLiveManager.java
new file mode 100644
index 0000000..4041ac5
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/ZeGoLiveManager.java
@@ -0,0 +1,441 @@
+package com.mogo.cloud.live.manager;
+
+import android.app.Application;
+import android.os.Environment;
+import android.util.Log;
+import android.view.SurfaceView;
+
+import com.mogo.cloud.live.listener.ILiveProgressListener;
+
+import org.json.JSONObject;
+
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+
+import im.zego.zegoexpress.ZegoExpressEngine;
+import im.zego.zegoexpress.callback.IZegoCustomVideoCaptureHandler;
+import im.zego.zegoexpress.callback.IZegoDestroyCompletionCallback;
+import im.zego.zegoexpress.callback.IZegoEventHandler;
+import im.zego.zegoexpress.constants.ZegoEngineState;
+import im.zego.zegoexpress.constants.ZegoNetworkMode;
+import im.zego.zegoexpress.constants.ZegoPlayerState;
+import im.zego.zegoexpress.constants.ZegoPublishChannel;
+import im.zego.zegoexpress.constants.ZegoPublisherState;
+import im.zego.zegoexpress.constants.ZegoRoomState;
+import im.zego.zegoexpress.constants.ZegoScenario;
+import im.zego.zegoexpress.constants.ZegoUpdateType;
+import im.zego.zegoexpress.constants.ZegoVideoBufferType;
+import im.zego.zegoexpress.constants.ZegoVideoCodecID;
+import im.zego.zegoexpress.constants.ZegoVideoFrameFormat;
+import im.zego.zegoexpress.constants.ZegoViewMode;
+import im.zego.zegoexpress.entity.ZegoCanvas;
+import im.zego.zegoexpress.entity.ZegoCustomVideoCaptureConfig;
+import im.zego.zegoexpress.entity.ZegoEngineConfig;
+import im.zego.zegoexpress.entity.ZegoLogConfig;
+import im.zego.zegoexpress.entity.ZegoPlayStreamQuality;
+import im.zego.zegoexpress.entity.ZegoStream;
+import im.zego.zegoexpress.entity.ZegoUser;
+import im.zego.zegoexpress.entity.ZegoVideoConfig;
+import im.zego.zegoexpress.entity.ZegoVideoFrameParam;
+
+/**
+ * 即构直播管理
+ */
+public class ZeGoLiveManager {
+    public static final String TAG = "ZeGoLiveManager";
+
+    /**
+     * 即构平台分配 APP_ID
+     */
+    private long appId = 1759603340;
+    /**
+     * 即构平台分配的 APP_KEY
+     */
+    private String appKey = "a9b02ca6122c585b434c498417bb623c5e9f07c71e8a1b5143dc3dc2e9e4439d";
+    /**
+     * 存储即构的日志路径
+     */
+    private static final String ZEGO_LOG_PATH = Environment.getExternalStorageDirectory().getAbsolutePath() + "/ZegoLog";
+    /**
+     * 直播推送配置对象
+     */
+    private MGLivePushConfig mLivePushConfig;
+    /**
+     * 直播会议ID，使用推流端的车机信息建立房间ID，这里采用格式为：ROOM_ID_车机SN编号
+     */
+    private static final String ROOM_ID_PREFIX = "ROOM_ID_";
+    /**
+     * 直播用户名称的
+     */
+    private static final String NAME_PREFIX = "MoGoCar_";
+    /**
+     * 直播流ID，发起推送的直播流ID
+     */
+    private static final String STREAM_ID_PREFIX = "STREAM_ID_";  //+ "_" + System.currentTimeMillis()
+    /**
+     * 定义 即构SDK 引擎对象
+     */
+    private ZegoExpressEngine mExpressEngine;
+    /**
+     * 创建自定义视频采集对象
+     */
+    private ZegoCustomVideoCaptureConfig customVideoCaptureConfig;
+    /**
+     * 直播进度回调用
+     */
+    private ILiveProgressListener listener;
+    /**
+     * 当前的房间ID
+     */
+    private String currentRoomId = "";
+    /**
+     * 推送状态，true-推流中，false-没有推流
+     */
+    private boolean isPushing;
+    /**
+     * 播放状态，true-播放中，false-没有播放
+     */
+    private boolean isPlaying;
+
+    private static final class Holder {
+        private static final ZeGoLiveManager manager = new ZeGoLiveManager();
+    }
+
+    /**
+     * 获取即构直播管理
+     */
+    public static ZeGoLiveManager getInstance() {
+        return Holder.manager;
+    }
+
+    private ZeGoLiveManager() {
+    }
+
+    public void setAppId(long appId) {
+        this.appId = appId;
+    }
+
+    public void setAppKey(String appKey) {
+        this.appKey = appKey;
+    }
+
+    public boolean isPlaying() {
+        return isPlaying;
+    }
+
+    public boolean isPushing() {
+        return isPushing;
+    }
+
+    /**
+     * 初始化直播SDK
+     *
+     * @param application    上下文
+     * @param livePushConfig 是否需要配置
+     */
+    public void init(Application application, MGLivePushConfig livePushConfig) {
+        mLivePushConfig = livePushConfig;
+        // 通过 advancedConfig 设置 uuid 过滤字段，设置之后 SDK 只会抛出前 12 个字节为开发者所设置 uuid 的 SEI
+        ZegoEngineConfig zegoEngineConfig = new ZegoEngineConfig();
+        // 设置即构的直播日志配置
+        ZegoLogConfig zegoLogConfig = new ZegoLogConfig();
+        // 存储日志路径
+        zegoLogConfig.logPath = ZEGO_LOG_PATH;
+        // 配置日志到引擎中
+        zegoEngineConfig.logConfig = zegoLogConfig;
+        // 设置配置到引擎中
+        ZegoExpressEngine.setEngineConfig(zegoEngineConfig);
+        // 创建 enging 对象, appID, appSign 为开发者在 ZEGO 管理控制台申请的凭证信息,
+        // 未上线的开发者 isTestEnvironment 为 true, application 为安卓应用的上下文
+        mExpressEngine =
+                ZegoExpressEngine.createEngine(
+                        appId,
+                        appKey,
+                        true,
+                        ZegoScenario.GENERAL,
+                        application,
+                        mEventHandler);
+        if (mLivePushConfig != null) {
+            // 创建自定义视频采集对象
+            customVideoCaptureConfig = new ZegoCustomVideoCaptureConfig();
+            // 设置自定义视频采集视频帧数据类型
+            customVideoCaptureConfig.bufferType = ZegoVideoBufferType.RAW_DATA;
+            // 开始或停止自定义视频采集，支持设置其他通道的推流
+            mExpressEngine.enableCustomVideoCapture(true, customVideoCaptureConfig, ZegoPublishChannel.MAIN);
+            // 设置自定义视频采集回调
+            mExpressEngine.setCustomVideoCaptureHandler(new IZegoCustomVideoCaptureHandler() {
+                @Override
+                public void onStart(ZegoPublishChannel channel) {
+                    super.onStart(channel);
+                    Log.i(TAG, "setCustomVideoCaptureHandler onStart");
+                    if (listener != null) {
+                        listener.onStart();
+                    }
+                }
+
+                @Override
+                public void onStop(ZegoPublishChannel channel) {
+                    super.onStop(channel);
+                    Log.i(TAG, "setCustomVideoCaptureHandler onStop");
+                    if (listener != null) {
+                        listener.onStop();
+                    }
+                }
+            });
+
+            // 视频配追
+            ZegoVideoConfig zegoVideoConfig = new ZegoVideoConfig();
+            // 采集分辨率，控制摄像头图像采集的分辨率。SDK 要求将宽和高设置为偶数。
+            zegoVideoConfig.setCaptureResolution(mLivePushConfig.getWidth(), mLivePushConfig.getHeight());
+            // 编码分辨率，控制编码器编码推流的图像分辨率。SDK 要求将宽和高设置为偶数。推流前后设置均可生效
+            zegoVideoConfig.setEncodeResolution(mLivePushConfig.getWidth(), mLivePushConfig.getHeight());
+            // 设置视频帧率
+            zegoVideoConfig.setVideoFPS(mLivePushConfig.getVideoFPS());
+            // 设置视频比特率
+            zegoVideoConfig.setVideoBitrate(mLivePushConfig.getVideoBitrate());
+            // 设置转码的ID，使用H.264
+            zegoVideoConfig.setCodecID(ZegoVideoCodecID.DEFAULT);
+            // 将视频信息设置到推流引擎
+            mExpressEngine.setVideoConfig(zegoVideoConfig);
+        }
+    }
+
+    /**
+     * 事件回调用
+     */
+    private IZegoEventHandler mEventHandler = new IZegoEventHandler() {
+
+        @Override
+        public void onDebugError(int errorCode, String funcName, String info) {
+            super.onDebugError(errorCode, funcName, info);
+            if (listener != null) {
+                listener.onDebugError(errorCode, funcName, info);
+            }
+            // 停止推送数据
+            stopPublishingStream();
+        }
+
+        @Override
+        public void onEngineStateUpdate(ZegoEngineState state) {
+            super.onEngineStateUpdate(state);
+            Log.i(TAG, "onEngineStateUpdate state : " + state.name());
+            if (state == ZegoEngineState.START) {
+                if (listener != null) {
+                    listener.onStart();
+                }
+            } else {
+                if (listener != null) {
+                    listener.onStop();
+                }
+            }
+        }
+
+        // 房间状态变化通知
+        @Override
+        public void onRoomStateUpdate(String roomID, ZegoRoomState state, int errorCode, JSONObject extendedData) {
+            super.onRoomStateUpdate(roomID, state, errorCode, extendedData);
+            //房间状态更新
+            if (state == ZegoRoomState.CONNECTING) {
+                if (listener != null) {
+                    listener.onConnecting();
+                }
+            } else if (state == ZegoRoomState.CONNECTED) {
+                if (listener != null) {
+                    listener.onConnected(roomID);
+                }
+            } else {
+                if (listener != null) {
+                    listener.onDisConnect();
+                }
+            }
+        }
+
+        @Override
+        public void onRoomUserUpdate(String roomID, ZegoUpdateType updateType, ArrayList<ZegoUser> userList) {
+            super.onRoomUserUpdate(roomID, updateType, userList);
+            //用户状态更新
+            Log.i(TAG, "onRoomUserUpdate roomId 房间内其他用户增加或减少的通知回调: " + roomID + " , updateType : " + updateType.name());
+        }
+
+        @Override
+        public void onRoomStreamUpdate(String roomID, ZegoUpdateType updateType, ArrayList<ZegoStream> streamList, JSONObject extendedData) {
+            super.onRoomStreamUpdate(roomID, updateType, streamList, extendedData);
+            //有用户新推送或者删除音视频时，更新流状态
+            Log.i(TAG, "onRoomStreamUpdate roomId 相同房间内其他用户推的流增加或减少的通知: " + roomID + " , ZegoUpdateType : " + updateType.name());
+            for (ZegoStream stream : streamList) {
+                String streamID = stream.streamID;
+                Log.i(TAG, "onRoomStreamUpdate streamId: " + streamID);
+                if (listener != null && updateType == ZegoUpdateType.ADD) {
+                    listener.onRoomStreamUpdate(streamID, true);
+                } else {
+                    listener.onRoomStreamUpdate(streamID, false);
+                }
+            }
+        }
+
+        @Override
+        public void onPublisherStateUpdate(String streamID, ZegoPublisherState state,
+                                           int errorCode, JSONObject extendedData) {
+            super.onPublisherStateUpdate(streamID, state, errorCode, extendedData);
+            Log.i(TAG, "onPublisherStateUpdate streamID 推流状态回调: " + streamID + " , state : " + state.name() + " , errorCode : " + errorCode);
+            isPushing = state == ZegoPublisherState.PUBLISHING;
+        }
+
+        @Override
+        public void onPlayerStateUpdate(String streamID, ZegoPlayerState state, int errorCode, JSONObject extendedData) {
+            super.onPlayerStateUpdate(streamID, state, errorCode, extendedData);
+            Log.i(TAG, "onPlayerStateUpdate streamId 拉流状态变更回调: " + streamID + " , state : " + state.name() + " , errorCode : " + errorCode + " , extendData : " + extendedData.toString());
+            isPlaying = state == ZegoPlayerState.PLAYING;
+        }
+
+        @Override
+        public void onPlayerQualityUpdate(String streamID, ZegoPlayStreamQuality quality) {
+            super.onPlayerQualityUpdate(streamID, quality);
+            Log.i(TAG, "onPlayerQualityUpdate quality 拉流质量回调: " + quality.toString());
+        }
+
+        @Override
+        public void onNetworkModeChanged(ZegoNetworkMode mode) {
+            super.onNetworkModeChanged(mode);
+            Log.i(TAG, "onNetworkModeChanged mode : " + mode.name());
+        }
+
+    };
+
+
+    /**
+     * 设置直播进度监听
+     *
+     * @param liveProgressListener 监听回调用
+     */
+    public void setLiveProgressListener(ILiveProgressListener liveProgressListener) {
+        this.listener = liveProgressListener;
+    }
+
+    /**
+     * 销毁即构引擎
+     */
+    private void destroyEngine() {
+        ZegoExpressEngine.destroyEngine(() -> {
+
+        });
+    }
+
+    /**
+     * 进入房间
+     *
+     * @param userId 当前用户ID
+     * @param roomId 要进入的房间ID
+     */
+    private void loginRoom(String userId, String roomId) {
+        currentRoomId = ROOM_ID_PREFIX + roomId;
+        ZegoUser zegoUser = new ZegoUser(userId, NAME_PREFIX + userId);
+        mExpressEngine.loginRoom(currentRoomId, zegoUser);
+    }
+
+    /**
+     * 退出房间
+     */
+    private void logOutRoom() {
+        mExpressEngine.logoutRoom(currentRoomId);
+        mExpressEngine.enableCustomVideoCapture(false, customVideoCaptureConfig, ZegoPublishChannel.MAIN);
+        mExpressEngine.setEventHandler(null);
+    }
+
+    /**
+     * 开始推送
+     */
+    public void startPush(String streamId) {
+        mExpressEngine.startPublishingStream(STREAM_ID_PREFIX + streamId);
+    }
+
+    /**
+     * 开始直播
+     *
+     * @param streamId    直播流ID
+     * @param surfaceView 渲染直播的视图
+     */
+    public void startLive(String streamId, SurfaceView surfaceView) {
+        ZegoCanvas zegoCanvas = new ZegoCanvas(surfaceView);
+        zegoCanvas.viewMode = ZegoViewMode.SCALE_TO_FILL;
+        mExpressEngine.startPlayingStream(streamId, zegoCanvas);
+    }
+
+    /**
+     * 停止直播
+     *
+     * @param streamId 数据流ID
+     */
+    public void stopLive(String streamId) {
+        mExpressEngine.stopPlayingStream(streamId);
+    }
+
+    /**
+     * 开始发布视频流
+     *
+     * @param byteBuffer               数据缓存
+     * @param dataLength               数据长度
+     * @param referenceTimeMillisecond 视频帧参考时间，UNIX时间戳，以毫秒为单位。音视频同步用的，
+     */
+    public void startPublishingStream(ByteBuffer byteBuffer, int dataLength, long referenceTimeMillisecond) {
+        ZegoVideoFrameParam zegoVideoFrameParam = new ZegoVideoFrameParam();
+        zegoVideoFrameParam.format = ZegoVideoFrameFormat.I420;
+        zegoVideoFrameParam.width = mLivePushConfig.getWidth();
+        zegoVideoFrameParam.height = mLivePushConfig.getHeight();
+        zegoVideoFrameParam.strides[0] = mLivePushConfig.getWidth();
+        zegoVideoFrameParam.strides[1] = mLivePushConfig.getWidth();
+        mExpressEngine.sendCustomVideoCaptureRawData(byteBuffer, dataLength, zegoVideoFrameParam, referenceTimeMillisecond);
+    }
+
+    /**
+     * 结束发布的直播
+     */
+    public void onDestroyPublish() {
+        stopPublish();
+        logOutRoom();
+        destroyEngine();
+    }
+
+    /**
+     * 开始预览
+     *
+     * @param surfaceView 预览承载视图
+     */
+    public void startPreview(SurfaceView surfaceView) {
+        ZegoCanvas zegoCanvas = new ZegoCanvas(surfaceView);
+        zegoCanvas.viewMode = ZegoViewMode.SCALE_TO_FILL; //填充整个View
+        mExpressEngine.startPreview(zegoCanvas);
+    }
+
+    /**
+     * 停止预览
+     */
+    private void stopPreview() {
+        ZegoExpressEngine.getEngine().stopPreview();
+    }
+
+    /**
+     * 停止推送
+     */
+    public void stopPublish() {
+        stopPreview();
+        stopPublishingStream();
+    }
+
+    /**
+     * 停止推送数据
+     */
+    private void stopPublishingStream() {
+        // 停止推送
+        ZegoExpressEngine.getEngine().stopPublishingStream();
+    }
+
+    /**
+     * 停止观看直播
+     */
+    public void onDestroyLive() {
+        logOutRoom();
+        destroyEngine();
+    }
+}
+
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/BaseData.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/BaseData.java
new file mode 100644
index 0000000..035b97b
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/BaseData.java
@@ -0,0 +1,21 @@
+package com.mogo.cloud.live.model;
+
+import com.elegant.network.NetConstants;
+
+import java.io.Serializable;
+
+public class BaseData implements Serializable, Cloneable {
+
+    public int code = NetConstants.NO_DATA;
+    public String msg;
+
+    public BaseData clone() {
+        BaseData obj = null;
+        try {
+            obj = (BaseData) super.clone();
+        } catch (CloneNotSupportedException var3) {
+            var3.printStackTrace();
+        }
+        return obj;
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/LiveStatusInfo.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/LiveStatusInfo.java
new file mode 100644
index 0000000..1dc0053
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/LiveStatusInfo.java
@@ -0,0 +1,19 @@
+package com.mogo.cloud.live.model;
+
+import java.util.List;
+
+public class LiveStatusInfo extends BaseData{
+
+    public Result result;
+
+    public class Result {
+        public int alarmStatus;
+        public List<LiveData> list;
+    }
+
+    public class LiveData {
+        public int status;     // 0开始 1 结束
+        public String livePushUrl;
+        public String videoChannel;
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/PlaybackModel.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/PlaybackModel.java
new file mode 100644
index 0000000..cb0e2e8
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/PlaybackModel.java
@@ -0,0 +1,20 @@
+package com.mogo.cloud.live.model;
+
+import com.zhidao.utils.common.TelephoneUtil;
+
+import java.util.List;
+
+public class PlaybackModel {
+    private String sn;
+    private String caller;
+    private List<VideoModel> videoList;
+
+    public PlaybackModel() {
+        this.sn = TelephoneUtil.getSerialNumber();
+        //this.caller = CarAlarmConstants.CALLER;
+    }
+
+    public void setVideoList(List<VideoModel> videoList) {
+        this.videoList = videoList;
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/ResqReportCarAlarm.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/ResqReportCarAlarm.java
new file mode 100644
index 0000000..186baa4
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/ResqReportCarAlarm.java
@@ -0,0 +1,18 @@
+package com.mogo.cloud.live.model;
+
+public class ResqReportCarAlarm {
+    public String userId;
+    public String sn;
+    public double lat;
+    public double lng;
+    public long clientTime;
+    public String eventId;
+    public String caller;
+    public String sdkVersion;
+    public CamStatus cameraStatus;
+
+    public static class CamStatus {
+        public int C_1;
+        public int C_2;
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/StartCarAlarmInfo.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/StartCarAlarmInfo.java
new file mode 100644
index 0000000..dbc242e
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/StartCarAlarmInfo.java
@@ -0,0 +1,9 @@
+package com.mogo.cloud.live.model;
+
+public class StartCarAlarmInfo extends BaseData{
+    public Result result;
+
+    public class Result {
+        public String eventId;
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/VideoModel.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/VideoModel.java
new file mode 100644
index 0000000..a05e314
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/model/VideoModel.java
@@ -0,0 +1,22 @@
+package com.mogo.cloud.live.model;
+
+/**
+ * 视频
+ */
+public class VideoModel {
+    public String videoChannel;
+    public long videoStartTime;
+    public long videoEndTime;
+    private String videoName;
+    public String url;
+    public int status;// 0 未备份 1 已备份 2 已删除，必传：上传元数据时为0，补充url时为1，文件已删除时为2
+    public String localPath;
+
+    public void setVideoName(String path) {
+        //this.videoName =  CustomUtils.getFileName(path);
+    }
+
+    public String getVideoName() {
+        return videoName;
+    }
+}
\ No newline at end of file
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/network/LiveApiServer.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/network/LiveApiServer.java
new file mode 100644
index 0000000..ab2c03c
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/network/LiveApiServer.java
@@ -0,0 +1,34 @@
+package com.mogo.cloud.live.network;
+
+import com.mogo.cloud.live.model.BaseData;
+import com.mogo.cloud.live.model.LiveStatusInfo;
+import com.mogo.cloud.live.model.StartCarAlarmInfo;
+
+import okhttp3.RequestBody;
+import retrofit2.http.Body;
+import retrofit2.http.Headers;
+import retrofit2.http.POST;
+import rx.Observable;
+
+/**
+ * 直播功能使用到的接口
+ */
+public interface LiveApiServer {
+
+    @Headers({"Content-Type:application/json", "Accept:application/json"})
+    @POST("/alarm/car/report")
+    Observable<StartCarAlarmInfo> reportAlarm(@Body RequestBody body);
+
+    @Headers({"Content-Type:application/json", "Accept:application/json"})
+    @POST("/alarm/car/report/cancel")
+    Observable<BaseData> cancelAlarm(@Body RequestBody body);
+
+    @Headers({"Content-Type:application/json", "Accept:application/json"})
+    @POST("/alarm/car/v2/video/liveStatus")
+    Observable<LiveStatusInfo> requestLiveStatus(@Body RequestBody body);
+
+    @Headers({"Content-Type:application/json", "Accept:application/json"})
+    @POST("/alarm/car/video/reportCameraStatus")
+    Observable<BaseData> uploadCamStatus(@Body RequestBody body);
+
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/push/PushService.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/push/PushService.java
new file mode 100644
index 0000000..2be9c78
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/push/PushService.java
@@ -0,0 +1,142 @@
+package com.mogo.cloud.live.push;
+
+import android.app.Service;
+import android.content.Context;
+import android.content.Intent;
+import android.media.AudioFormat;
+import android.os.IBinder;
+import android.text.TextUtils;
+import android.util.Log;
+
+import com.mogo.cloud.live.IYUVDataCallback;
+import com.mogo.cloud.live.manager.MGLivePushConfig;
+import com.mogo.cloud.live.manager.ZeGoLiveManager;
+
+
+public class PushService extends Service implements IYUVDataCallback {
+    public static final String ACTION_START_RTMP_PUSH = "action_start_rtmp_push";
+    public static final String ACTION_STOP_RTMP_PUSH = "action_stop_rtmp_push";
+
+    private static final String TAG = "PushService";
+
+    private static final String RTMP_URL = "rtmp_url";
+    private static final String CAM_ID = "cam_id";
+
+    private static final int WIDTH = 1280;
+    private static final int HEIGHT = 720;
+
+    // 自研直播SDK
+    private MGLivePushConfig mLivePushConfig;
+    private ZeGoLiveManager mLivePusher;
+
+    private static volatile String mRtmpUrl;
+
+    public static void startService(Context context, String action, String rtmpurl, String camId) {
+        Intent intent = new Intent(context, PushService.class);
+        intent.setAction(action);
+        intent.putExtra(RTMP_URL, rtmpurl);
+        intent.putExtra(CAM_ID, camId);
+        context.startService(intent);
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+        Log.d(TAG, "初始化推流服务……");
+        mLivePushConfig = new MGLivePushConfig();
+        mLivePushConfig.setWidth(1280);
+        mLivePushConfig.setHeight(720);
+        mLivePushConfig.setVideoBitrate(1500);
+        mLivePushConfig.setVideoFPS(15);
+        mLivePushConfig.setAudioChannels(2);
+        mLivePushConfig.setAudioSampleRate(44100);
+        mLivePushConfig.setAudioFormat(AudioFormat.ENCODING_PCM_16BIT);
+        mLivePushConfig.setMute(true);
+
+        mLivePusher = ZeGoLiveManager.getInstance();
+        mLivePusher.init(getApplication(),mLivePushConfig);
+    }
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        if (intent != null) {
+            if (ACTION_START_RTMP_PUSH.equals(intent.getAction())) {
+                try {
+                    String url = intent.getStringExtra(RTMP_URL);
+                    startRtmpPush(url);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            } else if (ACTION_STOP_RTMP_PUSH.equals(intent.getAction())) {
+                stopRtmpPush();
+            }
+        }
+        return super.onStartCommand(intent, flags, startId);
+    }
+
+    @Override
+    public IBinder onBind(Intent intent) {
+        return null;
+    }
+
+    private void startRtmpPush(String url) {
+        if (mRtmpUrl != null && mRtmpUrl.equals(url)
+                && mLivePusher != null && mLivePusher.isPushing()) {
+            return;
+        }
+
+        mRtmpUrl = url;
+
+        String rtmpUrl = null;
+        if (!TextUtils.isEmpty(mRtmpUrl)) {
+            String url1[] = mRtmpUrl.split("###");
+            if (url1.length > 0) {
+                rtmpUrl = url1[0];
+            }
+        }
+
+        if (TextUtils.isEmpty(rtmpUrl) || (!rtmpUrl.trim().toLowerCase().startsWith("rtmp://"))) {
+            //TODO rtmp url 地址有误
+            Log.e(TAG, "rtmp url 地址有误");
+            return;
+        }
+
+        //int customModeType = 0;
+        //customModeType |= TXLiveConstants.CUSTOM_MODE_VIDEO_CAPTURE;
+        //mLivePusher.setVideoQuality(TXLiveConstants.VIDEO_QUALITY_HIGH_DEFINITION, true, true);
+        //mLivePushConfig.setVideoResolution(TXLiveConstants.VIDEO_RESOLUTION_TYPE_1280_720);
+        //mLivePushConfig.setAutoAdjustBitrate(false);
+        //mLivePushConfig.setHomeOrientation(TXLiveConstants.VIDEO_ANGLE_HOME_LEFT);
+        //mLivePushConfig.setVideoBitrate(900);
+        //mLivePushConfig.setVideoEncodeGop(1);
+        //mLivePushConfig.setVideoFPS(15);
+        //mLivePushConfig.setCustomModeType(customModeType);
+
+
+        FrameManagerUtils.getInstance().addYuvDataCallback(this);
+
+        mLivePusher.startPusher(rtmpUrl.trim());
+
+        Log.d(TAG, "startRtmpPush :" + rtmpUrl);
+    }
+
+    private void stopRtmpPush() {
+        try {
+            mRtmpUrl = "";
+            if (mLivePusher.isPushing()) {
+                mLivePusher.stopPusher();
+            }
+            FrameManagerUtils.getInstance().rmYuvDataCallback(this);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Override
+    public void onFrame(byte[] data) {
+        if (mLivePusher != null && mLivePusher.isPushing() && data != null) {
+            int ret = mLivePusher.sendCustomVideoData(data, 3, WIDTH, HEIGHT);
+            if (BuildConfig.DEBUG) Log.d(TAG, "onFrame push ret is:" + ret);
+        }
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/mogo/cloud/live/utils/FrameManagerUtils.java b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/utils/FrameManagerUtils.java
new file mode 100644
index 0000000..8d4788f
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/mogo/cloud/live/utils/FrameManagerUtils.java
@@ -0,0 +1,115 @@
+package com.mogo.cloud.live.utils;
+
+
+import com.mogo.cloud.live.IYUVDataCallback;
+
+import java.util.HashSet;
+import java.util.Set;
+
+public class FrameManagerUtils {
+    private static final int DST_WIDTH = 1280;
+    private static final int DST_HEIGHT = 720;
+
+    byte[] dst = null;
+    byte[] tmp = null;
+
+    private final Set<IYUVDataCallback> globalDataListener = new HashSet<>();
+
+    public static FrameManagerUtils getInstance() {
+        return SingletonHolder.INSTANCE;
+    }
+
+    private static final class SingletonHolder {
+        private static final FrameManagerUtils INSTANCE = new FrameManagerUtils();
+    }
+
+    public void notifyYUVData(byte[] data, int width, int height, int type) {
+        dispatchData(handleData(data, width, height, type));
+    }
+
+    /*
+     * @param data origin yuv data
+     * @param width data width
+     * @param height data height
+     * @param type 1:YV12 2:NV21 3:I420 4 nv12
+     */
+    private byte[] handleData(byte[] data, int width, int height, int type) {
+        if (dst == null) {
+            dst = new byte[DST_WIDTH * DST_HEIGHT * 3 / 2];
+        }
+
+        if (tmp == null) {
+            tmp = new byte[848 * 480 * 3 / 2];
+        }
+
+        if (type == 4) {
+            if (DST_WIDTH == width && DST_HEIGHT == height) {
+                YuvUtils.NV12ToI420(data, dst, width, height);
+                return dst;
+            } else {
+                YuvUtils.NV12ToI420(data, tmp, width, height);
+                YuvUtils.I420Scale(tmp, width, height, dst, DST_WIDTH, DST_HEIGHT, Key.SCALE_MODE_NONE, false);
+                return dst;
+            }
+        } else if (type == 3) {
+            if (DST_WIDTH == width && DST_HEIGHT == height) {
+                return data;
+            } else {
+                YuvUtils.I420Scale(data, width, height, dst, DST_WIDTH, DST_HEIGHT, Key.SCALE_MODE_NONE, false);
+                return dst;
+            }
+        } else if (type == 2) {
+            if (DST_WIDTH == width && DST_HEIGHT == height) {
+                YuvUtils.NV21ToI420(data, dst, width, height, false);
+                return dst;
+            } else {
+                YuvUtils.NV21ToI420(data, tmp, width, height, false);
+                YuvUtils.I420Scale(tmp, width, height, dst, DST_WIDTH, DST_HEIGHT, Key.SCALE_MODE_NONE, false);
+                return dst;
+            }
+        } else if (type == 1) {
+            if (DST_WIDTH == width && DST_HEIGHT == height) {
+                swapYV12toI420(data, dst, width, height);
+                return dst;
+            } else {
+                swapYV12toI420(data, tmp, width, height);
+                YuvUtils.I420Scale(tmp, width, height, dst, DST_WIDTH, DST_HEIGHT, Key.SCALE_MODE_NONE, false);
+                return dst;
+            }
+        }
+        return new byte[0];
+    }
+
+    public synchronized void addYuvDataCallback(IYUVDataCallback callback) {
+        if (callback != null) {
+            globalDataListener.add(callback);
+        }
+    }
+
+    public synchronized void rmYuvDataCallback(IYUVDataCallback callback) {
+        if (callback != null) {
+            globalDataListener.remove(callback);
+        }
+    }
+
+    public synchronized void release() {
+        dst = null;
+        tmp = null;
+    }
+
+    private void dispatchData(byte[] data) {
+        if (globalDataListener != null && globalDataListener.size() > 0) {
+            for (IYUVDataCallback callback : globalDataListener) {
+                if (callback != null) {
+                    callback.onFrame(data);
+                }
+            }
+        }
+    }
+
+    private void swapYV12toI420(byte[] yv12bytes, byte[] i420bytes, int width, int height) {
+        System.arraycopy(yv12bytes, 0, i420bytes, 0, width * height);
+        System.arraycopy(yv12bytes, width * height + width * height / 4, i420bytes, width * height, width * height / 4);
+        System.arraycopy(yv12bytes, width * height, i420bytes, width * height + width * height / 4, width * height / 4);
+    }
+}
diff --git a/foudations/mogo-live/src/main/java/com/zhidao/ptech/shadow/server/protocol/DeviceInfo.java b/foudations/mogo-live/src/main/java/com/zhidao/ptech/shadow/server/protocol/DeviceInfo.java
new file mode 100644
index 0000000..8a6d5f7
--- /dev/null
+++ b/foudations/mogo-live/src/main/java/com/zhidao/ptech/shadow/server/protocol/DeviceInfo.java
@@ -0,0 +1,3088 @@
+// Generated by the protocol buffer compiler.  DO NOT EDIT!
+// source: DeviceInfo.proto
+
+package com.zhidao.ptech.shadow.server.protocol;
+
+public final class DeviceInfo {
+  private DeviceInfo() {}
+  public static void registerAllExtensions(
+      com.google.protobuf.ExtensionRegistryLite registry) {
+  }
+
+  public static void registerAllExtensions(
+      com.google.protobuf.ExtensionRegistry registry) {
+    registerAllExtensions(
+        (com.google.protobuf.ExtensionRegistryLite) registry);
+  }
+  /**
+   * <pre>
+   * 摄像头状态
+   * </pre>
+   *
+   * Protobuf enum {@code com.zhidao.ptech.shadow.server.protocol.CameraStatus}
+   */
+  public enum CameraStatus
+      implements com.google.protobuf.ProtocolMessageEnum {
+    /**
+     * <pre>
+     * 未知
+     * </pre>
+     *
+     * <code>CAMERA_STATUS_UNKNOW = 0;</code>
+     */
+    CAMERA_STATUS_UNKNOW(0),
+    /**
+     * <pre>
+     * 可用
+     * </pre>
+     *
+     * <code>CAMERA_STATUS_AVAILABLE = 1;</code>
+     */
+    CAMERA_STATUS_AVAILABLE(1),
+    /**
+     * <pre>
+     * 不可用
+     * </pre>
+     *
+     * <code>CAMERA_STATUS_UNAVAILABLE = 2;</code>
+     */
+    CAMERA_STATUS_UNAVAILABLE(2),
+    UNRECOGNIZED(-1),
+    ;
+
+    /**
+     * <pre>
+     * 未知
+     * </pre>
+     *
+     * <code>CAMERA_STATUS_UNKNOW = 0;</code>
+     */
+    public static final int CAMERA_STATUS_UNKNOW_VALUE = 0;
+    /**
+     * <pre>
+     * 可用
+     * </pre>
+     *
+     * <code>CAMERA_STATUS_AVAILABLE = 1;</code>
+     */
+    public static final int CAMERA_STATUS_AVAILABLE_VALUE = 1;
+    /**
+     * <pre>
+     * 不可用
+     * </pre>
+     *
+     * <code>CAMERA_STATUS_UNAVAILABLE = 2;</code>
+     */
+    public static final int CAMERA_STATUS_UNAVAILABLE_VALUE = 2;
+
+
+    public final int getNumber() {
+      if (this == UNRECOGNIZED) {
+        throw new IllegalArgumentException(
+            "Can't get the number of an unknown enum value.");
+      }
+      return value;
+    }
+
+    /**
+     * @deprecated Use {@link #forNumber(int)} instead.
+     */
+    @Deprecated
+    public static CameraStatus valueOf(int value) {
+      return forNumber(value);
+    }
+
+    public static CameraStatus forNumber(int value) {
+      switch (value) {
+        case 0: return CAMERA_STATUS_UNKNOW;
+        case 1: return CAMERA_STATUS_AVAILABLE;
+        case 2: return CAMERA_STATUS_UNAVAILABLE;
+        default: return null;
+      }
+    }
+
+    public static com.google.protobuf.Internal.EnumLiteMap<CameraStatus>
+        internalGetValueMap() {
+      return internalValueMap;
+    }
+    private static final com.google.protobuf.Internal.EnumLiteMap<
+        CameraStatus> internalValueMap =
+          new com.google.protobuf.Internal.EnumLiteMap<CameraStatus>() {
+            public CameraStatus findValueByNumber(int number) {
+              return CameraStatus.forNumber(number);
+            }
+          };
+
+    public final com.google.protobuf.Descriptors.EnumValueDescriptor
+        getValueDescriptor() {
+      return getDescriptor().getValues().get(ordinal());
+    }
+    public final com.google.protobuf.Descriptors.EnumDescriptor
+        getDescriptorForType() {
+      return getDescriptor();
+    }
+    public static final com.google.protobuf.Descriptors.EnumDescriptor
+        getDescriptor() {
+      return DeviceInfo.getDescriptor().getEnumTypes().get(0);
+    }
+
+    private static final CameraStatus[] VALUES = values();
+
+    public static CameraStatus valueOf(
+        com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+      if (desc.getType() != getDescriptor()) {
+        throw new IllegalArgumentException(
+          "EnumValueDescriptor is not for this type.");
+      }
+      if (desc.getIndex() == -1) {
+        return UNRECOGNIZED;
+      }
+      return VALUES[desc.getIndex()];
+    }
+
+    private final int value;
+
+    private CameraStatus(int value) {
+      this.value = value;
+    }
+
+    // @@protoc_insertion_point(enum_scope:com.zhidao.ptech.shadow.server.protocol.CameraStatus)
+  }
+
+  /**
+   * Protobuf enum {@code com.zhidao.ptech.shadow.server.protocol.CoordinateType}
+   */
+  public enum CoordinateType
+      implements com.google.protobuf.ProtocolMessageEnum {
+    /**
+     * <pre>
+     * 火星经纬度，国内GPS默认取的是火星坐标系
+     * </pre>
+     *
+     * <code>GCJ = 0;</code>
+     */
+    GCJ(0),
+    /**
+     * <pre>
+     * 百度坐标系
+     * </pre>
+     *
+     * <code>BAIDU_COORDINATE = 1;</code>
+     */
+    BAIDU_COORDINATE(1),
+    /**
+     * <pre>
+     * 腾讯和高德和国测局坐标系
+     * </pre>
+     *
+     * <code>SOSO_GCJ_COORDINATE = 2;</code>
+     */
+    SOSO_GCJ_COORDINATE(2),
+    /**
+     * <pre>
+     * 地球经纬度
+     * </pre>
+     *
+     * <code>WGS84 = 3;</code>
+     */
+    WGS84(3),
+    UNRECOGNIZED(-1),
+    ;
+
+    /**
+     * <pre>
+     * 火星经纬度，国内GPS默认取的是火星坐标系
+     * </pre>
+     *
+     * <code>GCJ = 0;</code>
+     */
+    public static final int GCJ_VALUE = 0;
+    /**
+     * <pre>
+     * 百度坐标系
+     * </pre>
+     *
+     * <code>BAIDU_COORDINATE = 1;</code>
+     */
+    public static final int BAIDU_COORDINATE_VALUE = 1;
+    /**
+     * <pre>
+     * 腾讯和高德和国测局坐标系
+     * </pre>
+     *
+     * <code>SOSO_GCJ_COORDINATE = 2;</code>
+     */
+    public static final int SOSO_GCJ_COORDINATE_VALUE = 2;
+    /**
+     * <pre>
+     * 地球经纬度
+     * </pre>
+     *
+     * <code>WGS84 = 3;</code>
+     */
+    public static final int WGS84_VALUE = 3;
+
+
+    public final int getNumber() {
+      if (this == UNRECOGNIZED) {
+        throw new IllegalArgumentException(
+            "Can't get the number of an unknown enum value.");
+      }
+      return value;
+    }
+
+    /**
+     * @deprecated Use {@link #forNumber(int)} instead.
+     */
+    @Deprecated
+    public static CoordinateType valueOf(int value) {
+      return forNumber(value);
+    }
+
+    public static CoordinateType forNumber(int value) {
+      switch (value) {
+        case 0: return GCJ;
+        case 1: return BAIDU_COORDINATE;
+        case 2: return SOSO_GCJ_COORDINATE;
+        case 3: return WGS84;
+        default: return null;
+      }
+    }
+
+    public static com.google.protobuf.Internal.EnumLiteMap<CoordinateType>
+        internalGetValueMap() {
+      return internalValueMap;
+    }
+    private static final com.google.protobuf.Internal.EnumLiteMap<
+        CoordinateType> internalValueMap =
+          new com.google.protobuf.Internal.EnumLiteMap<CoordinateType>() {
+            public CoordinateType findValueByNumber(int number) {
+              return CoordinateType.forNumber(number);
+            }
+          };
+
+    public final com.google.protobuf.Descriptors.EnumValueDescriptor
+        getValueDescriptor() {
+      return getDescriptor().getValues().get(ordinal());
+    }
+    public final com.google.protobuf.Descriptors.EnumDescriptor
+        getDescriptorForType() {
+      return getDescriptor();
+    }
+    public static final com.google.protobuf.Descriptors.EnumDescriptor
+        getDescriptor() {
+      return DeviceInfo.getDescriptor().getEnumTypes().get(1);
+    }
+
+    private static final CoordinateType[] VALUES = values();
+
+    public static CoordinateType valueOf(
+        com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+      if (desc.getType() != getDescriptor()) {
+        throw new IllegalArgumentException(
+          "EnumValueDescriptor is not for this type.");
+      }
+      if (desc.getIndex() == -1) {
+        return UNRECOGNIZED;
+      }
+      return VALUES[desc.getIndex()];
+    }
+
+    private final int value;
+
+    private CoordinateType(int value) {
+      this.value = value;
+    }
+
+    // @@protoc_insertion_point(enum_scope:com.zhidao.ptech.shadow.server.protocol.CoordinateType)
+  }
+
+  /**
+   * Protobuf enum {@code com.zhidao.ptech.shadow.server.protocol.LockType}
+   */
+  public enum LockType
+      implements com.google.protobuf.ProtocolMessageEnum {
+    /**
+     * <pre>
+     * 未知
+     * </pre>
+     *
+     * <code>LOCK_TYPE_UNKNOW = 0;</code>
+     */
+    LOCK_TYPE_UNKNOW(0),
+    /**
+     * <pre>
+     * GPS定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_GPS = 1;</code>
+     */
+    LOCK_TYPE_GPS(1),
+    /**
+     * <pre>
+     * 前次定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_LAST = 2;</code>
+     */
+    LOCK_TYPE_LAST(2),
+    /**
+     * <pre>
+     * 缓存定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_CACHE = 4;</code>
+     */
+    LOCK_TYPE_CACHE(4),
+    /**
+     * <pre>
+     * wifi定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_WIFI = 5;</code>
+     */
+    LOCK_TYPE_WIFI(5),
+    UNRECOGNIZED(-1),
+    ;
+
+    /**
+     * <pre>
+     * 未知
+     * </pre>
+     *
+     * <code>LOCK_TYPE_UNKNOW = 0;</code>
+     */
+    public static final int LOCK_TYPE_UNKNOW_VALUE = 0;
+    /**
+     * <pre>
+     * GPS定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_GPS = 1;</code>
+     */
+    public static final int LOCK_TYPE_GPS_VALUE = 1;
+    /**
+     * <pre>
+     * 前次定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_LAST = 2;</code>
+     */
+    public static final int LOCK_TYPE_LAST_VALUE = 2;
+    /**
+     * <pre>
+     * 缓存定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_CACHE = 4;</code>
+     */
+    public static final int LOCK_TYPE_CACHE_VALUE = 4;
+    /**
+     * <pre>
+     * wifi定位
+     * </pre>
+     *
+     * <code>LOCK_TYPE_WIFI = 5;</code>
+     */
+    public static final int LOCK_TYPE_WIFI_VALUE = 5;
+
+
+    public final int getNumber() {
+      if (this == UNRECOGNIZED) {
+        throw new IllegalArgumentException(
+            "Can't get the number of an unknown enum value.");
+      }
+      return value;
+    }
+
+    /**
+     * @deprecated Use {@link #forNumber(int)} instead.
+     */
+    @Deprecated
+    public static LockType valueOf(int value) {
+      return forNumber(value);
+    }
+
+    public static LockType forNumber(int value) {
+      switch (value) {
+        case 0: return LOCK_TYPE_UNKNOW;
+        case 1: return LOCK_TYPE_GPS;
+        case 2: return LOCK_TYPE_LAST;
+        case 4: return LOCK_TYPE_CACHE;
+        case 5: return LOCK_TYPE_WIFI;
+        default: return null;
+      }
+    }
+
+    public static com.google.protobuf.Internal.EnumLiteMap<LockType>
+        internalGetValueMap() {
+      return internalValueMap;
+    }
+    private static final com.google.protobuf.Internal.EnumLiteMap<
+        LockType> internalValueMap =
+          new com.google.protobuf.Internal.EnumLiteMap<LockType>() {
+            public LockType findValueByNumber(int number) {
+              return LockType.forNumber(number);
+            }
+          };
+
+    public final com.google.protobuf.Descriptors.EnumValueDescriptor
+        getValueDescriptor() {
+      return getDescriptor().getValues().get(ordinal());
+    }
+    public final com.google.protobuf.Descriptors.EnumDescriptor
+        getDescriptorForType() {
+      return getDescriptor();
+    }
+    public static final com.google.protobuf.Descriptors.EnumDescriptor
+        getDescriptor() {
+      return DeviceInfo.getDescriptor().getEnumTypes().get(2);
+    }
+
+    private static final LockType[] VALUES = values();
+
+    public static LockType valueOf(
+        com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+      if (desc.getType() != getDescriptor()) {
+        throw new IllegalArgumentException(
+          "EnumValueDescriptor is not for this type.");
+      }
+      if (desc.getIndex() == -1) {
+        return UNRECOGNIZED;
+      }
+      return VALUES[desc.getIndex()];
+    }
+
+    private final int value;
+
+    private LockType(int value) {
+      this.value = value;
+    }
+
+    // @@protoc_insertion_point(enum_scope:com.zhidao.ptech.shadow.server.protocol.LockType)
+  }
+
+  public interface DeviceInfoDataOrBuilder extends
+      // @@protoc_insertion_point(interface_extends:com.zhidao.ptech.shadow.server.protocol.DeviceInfoData)
+      com.google.protobuf.MessageOrBuilder {
+
+    /**
+     * <pre>
+     * 精确到毫秒的时间戳
+     * </pre>
+     *
+     * <code>int64 timestamp = 1;</code>
+     */
+    long getTimestamp();
+
+    /**
+     * <pre>
+     * sn码
+     * </pre>
+     *
+     * <code>string sn = 2;</code>
+     */
+    String getSn();
+    /**
+     * <pre>
+     * sn码
+     * </pre>
+     *
+     * <code>string sn = 2;</code>
+     */
+    com.google.protobuf.ByteString
+        getSnBytes();
+
+    /**
+     * <pre>
+     * uid
+     * </pre>
+     *
+     * <code>int64 uid = 3;</code>
+     */
+    long getUid();
+
+    /**
+     * <pre>
+     * 数据版本
+     * </pre>
+     *
+     * <code>int64 version = 4;</code>
+     */
+    long getVersion();
+
+    /**
+     * <pre>
+     * 纬度
+     * </pre>
+     *
+     * <code>double lat = 5;</code>
+     */
+    double getLat();
+
+    /**
+     * <pre>
+     * 经度
+     * </pre>
+     *
+     * <code>double lon = 6;</code>
+     */
+    double getLon();
+
+    /**
+     * <pre>
+     * 坐标系类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+     */
+    int getCoordinateTypeValue();
+    /**
+     * <pre>
+     * 坐标系类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+     */
+    CoordinateType getCoordinateType();
+
+    /**
+     * <pre>
+     * 坐标类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+     */
+    int getLockTypeValue();
+    /**
+     * <pre>
+     * 坐标类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+     */
+    LockType getLockType();
+
+    /**
+     * <code>string cityCode = 9;</code>
+     */
+    String getCityCode();
+    /**
+     * <code>string cityCode = 9;</code>
+     */
+    com.google.protobuf.ByteString
+        getCityCodeBytes();
+
+    /**
+     * <code>string adCode = 10;</code>
+     */
+    String getAdCode();
+    /**
+     * <code>string adCode = 10;</code>
+     */
+    com.google.protobuf.ByteString
+        getAdCodeBytes();
+
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+     */
+    boolean hasCameraInfo();
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+     */
+    CameraInfo getCameraInfo();
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+     */
+    CameraInfoOrBuilder getCameraInfoOrBuilder();
+  }
+  /**
+   * Protobuf type {@code com.zhidao.ptech.shadow.server.protocol.DeviceInfoData}
+   */
+  public  static final class DeviceInfoData extends
+      com.google.protobuf.GeneratedMessageV3 implements
+      // @@protoc_insertion_point(message_implements:com.zhidao.ptech.shadow.server.protocol.DeviceInfoData)
+      DeviceInfoDataOrBuilder {
+  private static final long serialVersionUID = 0L;
+    // Use DeviceInfoData.newBuilder() to construct.
+    private DeviceInfoData(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
+      super(builder);
+    }
+    private DeviceInfoData() {
+      sn_ = "";
+      coordinateType_ = 0;
+      lockType_ = 0;
+      cityCode_ = "";
+      adCode_ = "";
+    }
+
+    @Override
+    public final com.google.protobuf.UnknownFieldSet
+    getUnknownFields() {
+      return this.unknownFields;
+    }
+    private DeviceInfoData(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      this();
+      if (extensionRegistry == null) {
+        throw new NullPointerException();
+      }
+      int mutable_bitField0_ = 0;
+      com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder();
+      try {
+        boolean done = false;
+        while (!done) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              done = true;
+              break;
+            case 8: {
+
+              timestamp_ = input.readInt64();
+              break;
+            }
+            case 18: {
+              String s = input.readStringRequireUtf8();
+
+              sn_ = s;
+              break;
+            }
+            case 24: {
+
+              uid_ = input.readInt64();
+              break;
+            }
+            case 32: {
+
+              version_ = input.readInt64();
+              break;
+            }
+            case 41: {
+
+              lat_ = input.readDouble();
+              break;
+            }
+            case 49: {
+
+              lon_ = input.readDouble();
+              break;
+            }
+            case 56: {
+              int rawValue = input.readEnum();
+
+              coordinateType_ = rawValue;
+              break;
+            }
+            case 64: {
+              int rawValue = input.readEnum();
+
+              lockType_ = rawValue;
+              break;
+            }
+            case 74: {
+              String s = input.readStringRequireUtf8();
+
+              cityCode_ = s;
+              break;
+            }
+            case 82: {
+              String s = input.readStringRequireUtf8();
+
+              adCode_ = s;
+              break;
+            }
+            case 810: {
+              CameraInfo.Builder subBuilder = null;
+              if (cameraInfo_ != null) {
+                subBuilder = cameraInfo_.toBuilder();
+              }
+              cameraInfo_ = input.readMessage(CameraInfo.parser(), extensionRegistry);
+              if (subBuilder != null) {
+                subBuilder.mergeFrom(cameraInfo_);
+                cameraInfo_ = subBuilder.buildPartial();
+              }
+
+              break;
+            }
+            default: {
+              if (!parseUnknownField(
+                  input, unknownFields, extensionRegistry, tag)) {
+                done = true;
+              }
+              break;
+            }
+          }
+        }
+      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+        throw e.setUnfinishedMessage(this);
+      } catch (java.io.IOException e) {
+        throw new com.google.protobuf.InvalidProtocolBufferException(
+            e).setUnfinishedMessage(this);
+      } finally {
+        this.unknownFields = unknownFields.build();
+        makeExtensionsImmutable();
+      }
+    }
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_descriptor;
+    }
+
+    @Override
+    protected FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_fieldAccessorTable
+          .ensureFieldAccessorsInitialized(
+              DeviceInfoData.class, Builder.class);
+    }
+
+    public static final int TIMESTAMP_FIELD_NUMBER = 1;
+    private long timestamp_;
+    /**
+     * <pre>
+     * 精确到毫秒的时间戳
+     * </pre>
+     *
+     * <code>int64 timestamp = 1;</code>
+     */
+    public long getTimestamp() {
+      return timestamp_;
+    }
+
+    public static final int SN_FIELD_NUMBER = 2;
+    private volatile Object sn_;
+    /**
+     * <pre>
+     * sn码
+     * </pre>
+     *
+     * <code>string sn = 2;</code>
+     */
+    public String getSn() {
+      Object ref = sn_;
+      if (ref instanceof String) {
+        return (String) ref;
+      } else {
+        com.google.protobuf.ByteString bs = 
+            (com.google.protobuf.ByteString) ref;
+        String s = bs.toStringUtf8();
+        sn_ = s;
+        return s;
+      }
+    }
+    /**
+     * <pre>
+     * sn码
+     * </pre>
+     *
+     * <code>string sn = 2;</code>
+     */
+    public com.google.protobuf.ByteString
+        getSnBytes() {
+      Object ref = sn_;
+      if (ref instanceof String) {
+        com.google.protobuf.ByteString b = 
+            com.google.protobuf.ByteString.copyFromUtf8(
+                (String) ref);
+        sn_ = b;
+        return b;
+      } else {
+        return (com.google.protobuf.ByteString) ref;
+      }
+    }
+
+    public static final int UID_FIELD_NUMBER = 3;
+    private long uid_;
+    /**
+     * <pre>
+     * uid
+     * </pre>
+     *
+     * <code>int64 uid = 3;</code>
+     */
+    public long getUid() {
+      return uid_;
+    }
+
+    public static final int VERSION_FIELD_NUMBER = 4;
+    private long version_;
+    /**
+     * <pre>
+     * 数据版本
+     * </pre>
+     *
+     * <code>int64 version = 4;</code>
+     */
+    public long getVersion() {
+      return version_;
+    }
+
+    public static final int LAT_FIELD_NUMBER = 5;
+    private double lat_;
+    /**
+     * <pre>
+     * 纬度
+     * </pre>
+     *
+     * <code>double lat = 5;</code>
+     */
+    public double getLat() {
+      return lat_;
+    }
+
+    public static final int LON_FIELD_NUMBER = 6;
+    private double lon_;
+    /**
+     * <pre>
+     * 经度
+     * </pre>
+     *
+     * <code>double lon = 6;</code>
+     */
+    public double getLon() {
+      return lon_;
+    }
+
+    public static final int COORDINATETYPE_FIELD_NUMBER = 7;
+    private int coordinateType_;
+    /**
+     * <pre>
+     * 坐标系类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+     */
+    public int getCoordinateTypeValue() {
+      return coordinateType_;
+    }
+    /**
+     * <pre>
+     * 坐标系类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+     */
+    public CoordinateType getCoordinateType() {
+      @SuppressWarnings("deprecation")
+      CoordinateType result = CoordinateType.valueOf(coordinateType_);
+      return result == null ? CoordinateType.UNRECOGNIZED : result;
+    }
+
+    public static final int LOCKTYPE_FIELD_NUMBER = 8;
+    private int lockType_;
+    /**
+     * <pre>
+     * 坐标类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+     */
+    public int getLockTypeValue() {
+      return lockType_;
+    }
+    /**
+     * <pre>
+     * 坐标类型
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+     */
+    public LockType getLockType() {
+      @SuppressWarnings("deprecation")
+      LockType result = LockType.valueOf(lockType_);
+      return result == null ? LockType.UNRECOGNIZED : result;
+    }
+
+    public static final int CITYCODE_FIELD_NUMBER = 9;
+    private volatile Object cityCode_;
+    /**
+     * <code>string cityCode = 9;</code>
+     */
+    public String getCityCode() {
+      Object ref = cityCode_;
+      if (ref instanceof String) {
+        return (String) ref;
+      } else {
+        com.google.protobuf.ByteString bs = 
+            (com.google.protobuf.ByteString) ref;
+        String s = bs.toStringUtf8();
+        cityCode_ = s;
+        return s;
+      }
+    }
+    /**
+     * <code>string cityCode = 9;</code>
+     */
+    public com.google.protobuf.ByteString
+        getCityCodeBytes() {
+      Object ref = cityCode_;
+      if (ref instanceof String) {
+        com.google.protobuf.ByteString b = 
+            com.google.protobuf.ByteString.copyFromUtf8(
+                (String) ref);
+        cityCode_ = b;
+        return b;
+      } else {
+        return (com.google.protobuf.ByteString) ref;
+      }
+    }
+
+    public static final int ADCODE_FIELD_NUMBER = 10;
+    private volatile Object adCode_;
+    /**
+     * <code>string adCode = 10;</code>
+     */
+    public String getAdCode() {
+      Object ref = adCode_;
+      if (ref instanceof String) {
+        return (String) ref;
+      } else {
+        com.google.protobuf.ByteString bs = 
+            (com.google.protobuf.ByteString) ref;
+        String s = bs.toStringUtf8();
+        adCode_ = s;
+        return s;
+      }
+    }
+    /**
+     * <code>string adCode = 10;</code>
+     */
+    public com.google.protobuf.ByteString
+        getAdCodeBytes() {
+      Object ref = adCode_;
+      if (ref instanceof String) {
+        com.google.protobuf.ByteString b = 
+            com.google.protobuf.ByteString.copyFromUtf8(
+                (String) ref);
+        adCode_ = b;
+        return b;
+      } else {
+        return (com.google.protobuf.ByteString) ref;
+      }
+    }
+
+    public static final int CAMERAINFO_FIELD_NUMBER = 101;
+    private CameraInfo cameraInfo_;
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+     */
+    public boolean hasCameraInfo() {
+      return cameraInfo_ != null;
+    }
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+     */
+    public CameraInfo getCameraInfo() {
+      return cameraInfo_ == null ? CameraInfo.getDefaultInstance() : cameraInfo_;
+    }
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+     */
+    public CameraInfoOrBuilder getCameraInfoOrBuilder() {
+      return getCameraInfo();
+    }
+
+    private byte memoizedIsInitialized = -1;
+    @Override
+    public final boolean isInitialized() {
+      byte isInitialized = memoizedIsInitialized;
+      if (isInitialized == 1) return true;
+      if (isInitialized == 0) return false;
+
+      memoizedIsInitialized = 1;
+      return true;
+    }
+
+    @Override
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (timestamp_ != 0L) {
+        output.writeInt64(1, timestamp_);
+      }
+      if (!getSnBytes().isEmpty()) {
+        com.google.protobuf.GeneratedMessageV3.writeString(output, 2, sn_);
+      }
+      if (uid_ != 0L) {
+        output.writeInt64(3, uid_);
+      }
+      if (version_ != 0L) {
+        output.writeInt64(4, version_);
+      }
+      if (lat_ != 0D) {
+        output.writeDouble(5, lat_);
+      }
+      if (lon_ != 0D) {
+        output.writeDouble(6, lon_);
+      }
+      if (coordinateType_ != CoordinateType.GCJ.getNumber()) {
+        output.writeEnum(7, coordinateType_);
+      }
+      if (lockType_ != LockType.LOCK_TYPE_UNKNOW.getNumber()) {
+        output.writeEnum(8, lockType_);
+      }
+      if (!getCityCodeBytes().isEmpty()) {
+        com.google.protobuf.GeneratedMessageV3.writeString(output, 9, cityCode_);
+      }
+      if (!getAdCodeBytes().isEmpty()) {
+        com.google.protobuf.GeneratedMessageV3.writeString(output, 10, adCode_);
+      }
+      if (cameraInfo_ != null) {
+        output.writeMessage(101, getCameraInfo());
+      }
+      unknownFields.writeTo(output);
+    }
+
+    @Override
+    public int getSerializedSize() {
+      int size = memoizedSize;
+      if (size != -1) return size;
+
+      size = 0;
+      if (timestamp_ != 0L) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt64Size(1, timestamp_);
+      }
+      if (!getSnBytes().isEmpty()) {
+        size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, sn_);
+      }
+      if (uid_ != 0L) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt64Size(3, uid_);
+      }
+      if (version_ != 0L) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt64Size(4, version_);
+      }
+      if (lat_ != 0D) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeDoubleSize(5, lat_);
+      }
+      if (lon_ != 0D) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeDoubleSize(6, lon_);
+      }
+      if (coordinateType_ != CoordinateType.GCJ.getNumber()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeEnumSize(7, coordinateType_);
+      }
+      if (lockType_ != LockType.LOCK_TYPE_UNKNOW.getNumber()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeEnumSize(8, lockType_);
+      }
+      if (!getCityCodeBytes().isEmpty()) {
+        size += com.google.protobuf.GeneratedMessageV3.computeStringSize(9, cityCode_);
+      }
+      if (!getAdCodeBytes().isEmpty()) {
+        size += com.google.protobuf.GeneratedMessageV3.computeStringSize(10, adCode_);
+      }
+      if (cameraInfo_ != null) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeMessageSize(101, getCameraInfo());
+      }
+      size += unknownFields.getSerializedSize();
+      memoizedSize = size;
+      return size;
+    }
+
+    @Override
+    public boolean equals(final Object obj) {
+      if (obj == this) {
+       return true;
+      }
+      if (!(obj instanceof DeviceInfoData)) {
+        return super.equals(obj);
+      }
+      DeviceInfoData other = (DeviceInfoData) obj;
+
+      if (getTimestamp()
+          != other.getTimestamp()) return false;
+      if (!getSn()
+          .equals(other.getSn())) return false;
+      if (getUid()
+          != other.getUid()) return false;
+      if (getVersion()
+          != other.getVersion()) return false;
+      if (Double.doubleToLongBits(getLat())
+          != Double.doubleToLongBits(
+              other.getLat())) return false;
+      if (Double.doubleToLongBits(getLon())
+          != Double.doubleToLongBits(
+              other.getLon())) return false;
+      if (coordinateType_ != other.coordinateType_) return false;
+      if (lockType_ != other.lockType_) return false;
+      if (!getCityCode()
+          .equals(other.getCityCode())) return false;
+      if (!getAdCode()
+          .equals(other.getAdCode())) return false;
+      if (hasCameraInfo() != other.hasCameraInfo()) return false;
+      if (hasCameraInfo()) {
+        if (!getCameraInfo()
+            .equals(other.getCameraInfo())) return false;
+      }
+      if (!unknownFields.equals(other.unknownFields)) return false;
+      return true;
+    }
+
+    @Override
+    public int hashCode() {
+      if (memoizedHashCode != 0) {
+        return memoizedHashCode;
+      }
+      int hash = 41;
+      hash = (19 * hash) + getDescriptor().hashCode();
+      hash = (37 * hash) + TIMESTAMP_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+          getTimestamp());
+      hash = (37 * hash) + SN_FIELD_NUMBER;
+      hash = (53 * hash) + getSn().hashCode();
+      hash = (37 * hash) + UID_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+          getUid());
+      hash = (37 * hash) + VERSION_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+          getVersion());
+      hash = (37 * hash) + LAT_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+          Double.doubleToLongBits(getLat()));
+      hash = (37 * hash) + LON_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+          Double.doubleToLongBits(getLon()));
+      hash = (37 * hash) + COORDINATETYPE_FIELD_NUMBER;
+      hash = (53 * hash) + coordinateType_;
+      hash = (37 * hash) + LOCKTYPE_FIELD_NUMBER;
+      hash = (53 * hash) + lockType_;
+      hash = (37 * hash) + CITYCODE_FIELD_NUMBER;
+      hash = (53 * hash) + getCityCode().hashCode();
+      hash = (37 * hash) + ADCODE_FIELD_NUMBER;
+      hash = (53 * hash) + getAdCode().hashCode();
+      if (hasCameraInfo()) {
+        hash = (37 * hash) + CAMERAINFO_FIELD_NUMBER;
+        hash = (53 * hash) + getCameraInfo().hashCode();
+      }
+      hash = (29 * hash) + unknownFields.hashCode();
+      memoizedHashCode = hash;
+      return hash;
+    }
+
+    public static DeviceInfoData parseFrom(
+        java.nio.ByteBuffer data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static DeviceInfoData parseFrom(
+        java.nio.ByteBuffer data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static DeviceInfoData parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static DeviceInfoData parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static DeviceInfoData parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static DeviceInfoData parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static DeviceInfoData parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input);
+    }
+    public static DeviceInfoData parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static DeviceInfoData parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseDelimitedWithIOException(PARSER, input);
+    }
+    public static DeviceInfoData parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static DeviceInfoData parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input);
+    }
+    public static DeviceInfoData parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    @Override
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder() {
+      return DEFAULT_INSTANCE.toBuilder();
+    }
+    public static Builder newBuilder(DeviceInfoData prototype) {
+      return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+    }
+    @Override
+    public Builder toBuilder() {
+      return this == DEFAULT_INSTANCE
+          ? new Builder() : new Builder().mergeFrom(this);
+    }
+
+    @Override
+    protected Builder newBuilderForType(
+        BuilderParent parent) {
+      Builder builder = new Builder(parent);
+      return builder;
+    }
+    /**
+     * Protobuf type {@code com.zhidao.ptech.shadow.server.protocol.DeviceInfoData}
+     */
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
+        // @@protoc_insertion_point(builder_implements:com.zhidao.ptech.shadow.server.protocol.DeviceInfoData)
+        DeviceInfoDataOrBuilder {
+      public static final com.google.protobuf.Descriptors.Descriptor
+          getDescriptor() {
+        return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_descriptor;
+      }
+
+      @Override
+      protected FieldAccessorTable
+          internalGetFieldAccessorTable() {
+        return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_fieldAccessorTable
+            .ensureFieldAccessorsInitialized(
+                DeviceInfoData.class, Builder.class);
+      }
+
+      // Construct using com.zhidao.ptech.shadow.server.protocol.DeviceInfo.DeviceInfoData.newBuilder()
+      private Builder() {
+        maybeForceBuilderInitialization();
+      }
+
+      private Builder(
+          BuilderParent parent) {
+        super(parent);
+        maybeForceBuilderInitialization();
+      }
+      private void maybeForceBuilderInitialization() {
+        if (com.google.protobuf.GeneratedMessageV3
+                .alwaysUseFieldBuilders) {
+        }
+      }
+      @Override
+      public Builder clear() {
+        super.clear();
+        timestamp_ = 0L;
+
+        sn_ = "";
+
+        uid_ = 0L;
+
+        version_ = 0L;
+
+        lat_ = 0D;
+
+        lon_ = 0D;
+
+        coordinateType_ = 0;
+
+        lockType_ = 0;
+
+        cityCode_ = "";
+
+        adCode_ = "";
+
+        if (cameraInfoBuilder_ == null) {
+          cameraInfo_ = null;
+        } else {
+          cameraInfo_ = null;
+          cameraInfoBuilder_ = null;
+        }
+        return this;
+      }
+
+      @Override
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_descriptor;
+      }
+
+      @Override
+      public DeviceInfoData getDefaultInstanceForType() {
+        return DeviceInfoData.getDefaultInstance();
+      }
+
+      @Override
+      public DeviceInfoData build() {
+        DeviceInfoData result = buildPartial();
+        if (!result.isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return result;
+      }
+
+      @Override
+      public DeviceInfoData buildPartial() {
+        DeviceInfoData result = new DeviceInfoData(this);
+        result.timestamp_ = timestamp_;
+        result.sn_ = sn_;
+        result.uid_ = uid_;
+        result.version_ = version_;
+        result.lat_ = lat_;
+        result.lon_ = lon_;
+        result.coordinateType_ = coordinateType_;
+        result.lockType_ = lockType_;
+        result.cityCode_ = cityCode_;
+        result.adCode_ = adCode_;
+        if (cameraInfoBuilder_ == null) {
+          result.cameraInfo_ = cameraInfo_;
+        } else {
+          result.cameraInfo_ = cameraInfoBuilder_.build();
+        }
+        onBuilt();
+        return result;
+      }
+
+      @Override
+      public Builder clone() {
+        return super.clone();
+      }
+      @Override
+      public Builder setField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          Object value) {
+        return super.setField(field, value);
+      }
+      @Override
+      public Builder clearField(
+          com.google.protobuf.Descriptors.FieldDescriptor field) {
+        return super.clearField(field);
+      }
+      @Override
+      public Builder clearOneof(
+          com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+        return super.clearOneof(oneof);
+      }
+      @Override
+      public Builder setRepeatedField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          int index, Object value) {
+        return super.setRepeatedField(field, index, value);
+      }
+      @Override
+      public Builder addRepeatedField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          Object value) {
+        return super.addRepeatedField(field, value);
+      }
+      @Override
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof DeviceInfoData) {
+          return mergeFrom((DeviceInfoData)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+
+      public Builder mergeFrom(DeviceInfoData other) {
+        if (other == DeviceInfoData.getDefaultInstance()) return this;
+        if (other.getTimestamp() != 0L) {
+          setTimestamp(other.getTimestamp());
+        }
+        if (!other.getSn().isEmpty()) {
+          sn_ = other.sn_;
+          onChanged();
+        }
+        if (other.getUid() != 0L) {
+          setUid(other.getUid());
+        }
+        if (other.getVersion() != 0L) {
+          setVersion(other.getVersion());
+        }
+        if (other.getLat() != 0D) {
+          setLat(other.getLat());
+        }
+        if (other.getLon() != 0D) {
+          setLon(other.getLon());
+        }
+        if (other.coordinateType_ != 0) {
+          setCoordinateTypeValue(other.getCoordinateTypeValue());
+        }
+        if (other.lockType_ != 0) {
+          setLockTypeValue(other.getLockTypeValue());
+        }
+        if (!other.getCityCode().isEmpty()) {
+          cityCode_ = other.cityCode_;
+          onChanged();
+        }
+        if (!other.getAdCode().isEmpty()) {
+          adCode_ = other.adCode_;
+          onChanged();
+        }
+        if (other.hasCameraInfo()) {
+          mergeCameraInfo(other.getCameraInfo());
+        }
+        this.mergeUnknownFields(other.unknownFields);
+        onChanged();
+        return this;
+      }
+
+      @Override
+      public final boolean isInitialized() {
+        return true;
+      }
+
+      @Override
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        DeviceInfoData parsedMessage = null;
+        try {
+          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          parsedMessage = (DeviceInfoData) e.getUnfinishedMessage();
+          throw e.unwrapIOException();
+        } finally {
+          if (parsedMessage != null) {
+            mergeFrom(parsedMessage);
+          }
+        }
+        return this;
+      }
+
+      private long timestamp_ ;
+      /**
+       * <pre>
+       * 精确到毫秒的时间戳
+       * </pre>
+       *
+       * <code>int64 timestamp = 1;</code>
+       */
+      public long getTimestamp() {
+        return timestamp_;
+      }
+      /**
+       * <pre>
+       * 精确到毫秒的时间戳
+       * </pre>
+       *
+       * <code>int64 timestamp = 1;</code>
+       */
+      public Builder setTimestamp(long value) {
+        
+        timestamp_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 精确到毫秒的时间戳
+       * </pre>
+       *
+       * <code>int64 timestamp = 1;</code>
+       */
+      public Builder clearTimestamp() {
+        
+        timestamp_ = 0L;
+        onChanged();
+        return this;
+      }
+
+      private Object sn_ = "";
+      /**
+       * <pre>
+       * sn码
+       * </pre>
+       *
+       * <code>string sn = 2;</code>
+       */
+      public String getSn() {
+        Object ref = sn_;
+        if (!(ref instanceof String)) {
+          com.google.protobuf.ByteString bs =
+              (com.google.protobuf.ByteString) ref;
+          String s = bs.toStringUtf8();
+          sn_ = s;
+          return s;
+        } else {
+          return (String) ref;
+        }
+      }
+      /**
+       * <pre>
+       * sn码
+       * </pre>
+       *
+       * <code>string sn = 2;</code>
+       */
+      public com.google.protobuf.ByteString
+          getSnBytes() {
+        Object ref = sn_;
+        if (ref instanceof String) {
+          com.google.protobuf.ByteString b = 
+              com.google.protobuf.ByteString.copyFromUtf8(
+                  (String) ref);
+          sn_ = b;
+          return b;
+        } else {
+          return (com.google.protobuf.ByteString) ref;
+        }
+      }
+      /**
+       * <pre>
+       * sn码
+       * </pre>
+       *
+       * <code>string sn = 2;</code>
+       */
+      public Builder setSn(
+          String value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  
+        sn_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * sn码
+       * </pre>
+       *
+       * <code>string sn = 2;</code>
+       */
+      public Builder clearSn() {
+        
+        sn_ = getDefaultInstance().getSn();
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * sn码
+       * </pre>
+       *
+       * <code>string sn = 2;</code>
+       */
+      public Builder setSnBytes(
+          com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  checkByteStringIsUtf8(value);
+        
+        sn_ = value;
+        onChanged();
+        return this;
+      }
+
+      private long uid_ ;
+      /**
+       * <pre>
+       * uid
+       * </pre>
+       *
+       * <code>int64 uid = 3;</code>
+       */
+      public long getUid() {
+        return uid_;
+      }
+      /**
+       * <pre>
+       * uid
+       * </pre>
+       *
+       * <code>int64 uid = 3;</code>
+       */
+      public Builder setUid(long value) {
+        
+        uid_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * uid
+       * </pre>
+       *
+       * <code>int64 uid = 3;</code>
+       */
+      public Builder clearUid() {
+        
+        uid_ = 0L;
+        onChanged();
+        return this;
+      }
+
+      private long version_ ;
+      /**
+       * <pre>
+       * 数据版本
+       * </pre>
+       *
+       * <code>int64 version = 4;</code>
+       */
+      public long getVersion() {
+        return version_;
+      }
+      /**
+       * <pre>
+       * 数据版本
+       * </pre>
+       *
+       * <code>int64 version = 4;</code>
+       */
+      public Builder setVersion(long value) {
+        
+        version_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 数据版本
+       * </pre>
+       *
+       * <code>int64 version = 4;</code>
+       */
+      public Builder clearVersion() {
+        
+        version_ = 0L;
+        onChanged();
+        return this;
+      }
+
+      private double lat_ ;
+      /**
+       * <pre>
+       * 纬度
+       * </pre>
+       *
+       * <code>double lat = 5;</code>
+       */
+      public double getLat() {
+        return lat_;
+      }
+      /**
+       * <pre>
+       * 纬度
+       * </pre>
+       *
+       * <code>double lat = 5;</code>
+       */
+      public Builder setLat(double value) {
+        
+        lat_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 纬度
+       * </pre>
+       *
+       * <code>double lat = 5;</code>
+       */
+      public Builder clearLat() {
+        
+        lat_ = 0D;
+        onChanged();
+        return this;
+      }
+
+      private double lon_ ;
+      /**
+       * <pre>
+       * 经度
+       * </pre>
+       *
+       * <code>double lon = 6;</code>
+       */
+      public double getLon() {
+        return lon_;
+      }
+      /**
+       * <pre>
+       * 经度
+       * </pre>
+       *
+       * <code>double lon = 6;</code>
+       */
+      public Builder setLon(double value) {
+        
+        lon_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 经度
+       * </pre>
+       *
+       * <code>double lon = 6;</code>
+       */
+      public Builder clearLon() {
+        
+        lon_ = 0D;
+        onChanged();
+        return this;
+      }
+
+      private int coordinateType_ = 0;
+      /**
+       * <pre>
+       * 坐标系类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+       */
+      public int getCoordinateTypeValue() {
+        return coordinateType_;
+      }
+      /**
+       * <pre>
+       * 坐标系类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+       */
+      public Builder setCoordinateTypeValue(int value) {
+        coordinateType_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 坐标系类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+       */
+      public CoordinateType getCoordinateType() {
+        @SuppressWarnings("deprecation")
+        CoordinateType result = CoordinateType.valueOf(coordinateType_);
+        return result == null ? CoordinateType.UNRECOGNIZED : result;
+      }
+      /**
+       * <pre>
+       * 坐标系类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+       */
+      public Builder setCoordinateType(CoordinateType value) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        
+        coordinateType_ = value.getNumber();
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 坐标系类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CoordinateType coordinateType = 7;</code>
+       */
+      public Builder clearCoordinateType() {
+        
+        coordinateType_ = 0;
+        onChanged();
+        return this;
+      }
+
+      private int lockType_ = 0;
+      /**
+       * <pre>
+       * 坐标类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+       */
+      public int getLockTypeValue() {
+        return lockType_;
+      }
+      /**
+       * <pre>
+       * 坐标类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+       */
+      public Builder setLockTypeValue(int value) {
+        lockType_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 坐标类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+       */
+      public LockType getLockType() {
+        @SuppressWarnings("deprecation")
+        LockType result = LockType.valueOf(lockType_);
+        return result == null ? LockType.UNRECOGNIZED : result;
+      }
+      /**
+       * <pre>
+       * 坐标类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+       */
+      public Builder setLockType(LockType value) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        
+        lockType_ = value.getNumber();
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 坐标类型
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.LockType lockType = 8;</code>
+       */
+      public Builder clearLockType() {
+        
+        lockType_ = 0;
+        onChanged();
+        return this;
+      }
+
+      private Object cityCode_ = "";
+      /**
+       * <code>string cityCode = 9;</code>
+       */
+      public String getCityCode() {
+        Object ref = cityCode_;
+        if (!(ref instanceof String)) {
+          com.google.protobuf.ByteString bs =
+              (com.google.protobuf.ByteString) ref;
+          String s = bs.toStringUtf8();
+          cityCode_ = s;
+          return s;
+        } else {
+          return (String) ref;
+        }
+      }
+      /**
+       * <code>string cityCode = 9;</code>
+       */
+      public com.google.protobuf.ByteString
+          getCityCodeBytes() {
+        Object ref = cityCode_;
+        if (ref instanceof String) {
+          com.google.protobuf.ByteString b = 
+              com.google.protobuf.ByteString.copyFromUtf8(
+                  (String) ref);
+          cityCode_ = b;
+          return b;
+        } else {
+          return (com.google.protobuf.ByteString) ref;
+        }
+      }
+      /**
+       * <code>string cityCode = 9;</code>
+       */
+      public Builder setCityCode(
+          String value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  
+        cityCode_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>string cityCode = 9;</code>
+       */
+      public Builder clearCityCode() {
+        
+        cityCode_ = getDefaultInstance().getCityCode();
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>string cityCode = 9;</code>
+       */
+      public Builder setCityCodeBytes(
+          com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  checkByteStringIsUtf8(value);
+        
+        cityCode_ = value;
+        onChanged();
+        return this;
+      }
+
+      private Object adCode_ = "";
+      /**
+       * <code>string adCode = 10;</code>
+       */
+      public String getAdCode() {
+        Object ref = adCode_;
+        if (!(ref instanceof String)) {
+          com.google.protobuf.ByteString bs =
+              (com.google.protobuf.ByteString) ref;
+          String s = bs.toStringUtf8();
+          adCode_ = s;
+          return s;
+        } else {
+          return (String) ref;
+        }
+      }
+      /**
+       * <code>string adCode = 10;</code>
+       */
+      public com.google.protobuf.ByteString
+          getAdCodeBytes() {
+        Object ref = adCode_;
+        if (ref instanceof String) {
+          com.google.protobuf.ByteString b = 
+              com.google.protobuf.ByteString.copyFromUtf8(
+                  (String) ref);
+          adCode_ = b;
+          return b;
+        } else {
+          return (com.google.protobuf.ByteString) ref;
+        }
+      }
+      /**
+       * <code>string adCode = 10;</code>
+       */
+      public Builder setAdCode(
+          String value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  
+        adCode_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>string adCode = 10;</code>
+       */
+      public Builder clearAdCode() {
+        
+        adCode_ = getDefaultInstance().getAdCode();
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>string adCode = 10;</code>
+       */
+      public Builder setAdCodeBytes(
+          com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  checkByteStringIsUtf8(value);
+        
+        adCode_ = value;
+        onChanged();
+        return this;
+      }
+
+      private CameraInfo cameraInfo_;
+      private com.google.protobuf.SingleFieldBuilderV3<
+          CameraInfo, CameraInfo.Builder, CameraInfoOrBuilder> cameraInfoBuilder_;
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public boolean hasCameraInfo() {
+        return cameraInfoBuilder_ != null || cameraInfo_ != null;
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public CameraInfo getCameraInfo() {
+        if (cameraInfoBuilder_ == null) {
+          return cameraInfo_ == null ? CameraInfo.getDefaultInstance() : cameraInfo_;
+        } else {
+          return cameraInfoBuilder_.getMessage();
+        }
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public Builder setCameraInfo(CameraInfo value) {
+        if (cameraInfoBuilder_ == null) {
+          if (value == null) {
+            throw new NullPointerException();
+          }
+          cameraInfo_ = value;
+          onChanged();
+        } else {
+          cameraInfoBuilder_.setMessage(value);
+        }
+
+        return this;
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public Builder setCameraInfo(
+          CameraInfo.Builder builderForValue) {
+        if (cameraInfoBuilder_ == null) {
+          cameraInfo_ = builderForValue.build();
+          onChanged();
+        } else {
+          cameraInfoBuilder_.setMessage(builderForValue.build());
+        }
+
+        return this;
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public Builder mergeCameraInfo(CameraInfo value) {
+        if (cameraInfoBuilder_ == null) {
+          if (cameraInfo_ != null) {
+            cameraInfo_ =
+              CameraInfo.newBuilder(cameraInfo_).mergeFrom(value).buildPartial();
+          } else {
+            cameraInfo_ = value;
+          }
+          onChanged();
+        } else {
+          cameraInfoBuilder_.mergeFrom(value);
+        }
+
+        return this;
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public Builder clearCameraInfo() {
+        if (cameraInfoBuilder_ == null) {
+          cameraInfo_ = null;
+          onChanged();
+        } else {
+          cameraInfo_ = null;
+          cameraInfoBuilder_ = null;
+        }
+
+        return this;
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public CameraInfo.Builder getCameraInfoBuilder() {
+        
+        onChanged();
+        return getCameraInfoFieldBuilder().getBuilder();
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      public CameraInfoOrBuilder getCameraInfoOrBuilder() {
+        if (cameraInfoBuilder_ != null) {
+          return cameraInfoBuilder_.getMessageOrBuilder();
+        } else {
+          return cameraInfo_ == null ?
+              CameraInfo.getDefaultInstance() : cameraInfo_;
+        }
+      }
+      /**
+       * <pre>
+       * 摄像头信息
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraInfo cameraInfo = 101;</code>
+       */
+      private com.google.protobuf.SingleFieldBuilderV3<
+          CameraInfo, CameraInfo.Builder, CameraInfoOrBuilder>
+          getCameraInfoFieldBuilder() {
+        if (cameraInfoBuilder_ == null) {
+          cameraInfoBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+              CameraInfo, CameraInfo.Builder, CameraInfoOrBuilder>(
+                  getCameraInfo(),
+                  getParentForChildren(),
+                  isClean());
+          cameraInfo_ = null;
+        }
+        return cameraInfoBuilder_;
+      }
+      @Override
+      public final Builder setUnknownFields(
+          final com.google.protobuf.UnknownFieldSet unknownFields) {
+        return super.setUnknownFields(unknownFields);
+      }
+
+      @Override
+      public final Builder mergeUnknownFields(
+          final com.google.protobuf.UnknownFieldSet unknownFields) {
+        return super.mergeUnknownFields(unknownFields);
+      }
+
+
+      // @@protoc_insertion_point(builder_scope:com.zhidao.ptech.shadow.server.protocol.DeviceInfoData)
+    }
+
+    // @@protoc_insertion_point(class_scope:com.zhidao.ptech.shadow.server.protocol.DeviceInfoData)
+    private static final DeviceInfoData DEFAULT_INSTANCE;
+    static {
+      DEFAULT_INSTANCE = new DeviceInfoData();
+    }
+
+    public static DeviceInfoData getDefaultInstance() {
+      return DEFAULT_INSTANCE;
+    }
+
+    private static final com.google.protobuf.Parser<DeviceInfoData>
+        PARSER = new com.google.protobuf.AbstractParser<DeviceInfoData>() {
+      @Override
+      public DeviceInfoData parsePartialFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        return new DeviceInfoData(input, extensionRegistry);
+      }
+    };
+
+    public static com.google.protobuf.Parser<DeviceInfoData> parser() {
+      return PARSER;
+    }
+
+    @Override
+    public com.google.protobuf.Parser<DeviceInfoData> getParserForType() {
+      return PARSER;
+    }
+
+    @Override
+    public DeviceInfoData getDefaultInstanceForType() {
+      return DEFAULT_INSTANCE;
+    }
+
+  }
+
+  public interface CameraInfoOrBuilder extends
+      // @@protoc_insertion_point(interface_extends:com.zhidao.ptech.shadow.server.protocol.CameraInfo)
+      com.google.protobuf.MessageOrBuilder {
+
+    /**
+     * <pre>
+     * 前置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+     */
+    int getC1Value();
+    /**
+     * <pre>
+     * 前置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+     */
+    CameraStatus getC1();
+
+    /**
+     * <pre>
+     * 后置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+     */
+    int getC2Value();
+    /**
+     * <pre>
+     * 后置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+     */
+    CameraStatus getC2();
+
+    /**
+     * <pre>
+     * 数据有效时间：数据失效时间 = 当前时间 + expireTime
+     * </pre>
+     *
+     * <code>int64 expireTime = 3;</code>
+     */
+    long getExpireTime();
+  }
+  /**
+   * <pre>
+   * 摄像头信息
+   * </pre>
+   *
+   * Protobuf type {@code com.zhidao.ptech.shadow.server.protocol.CameraInfo}
+   */
+  public  static final class CameraInfo extends
+      com.google.protobuf.GeneratedMessageV3 implements
+      // @@protoc_insertion_point(message_implements:com.zhidao.ptech.shadow.server.protocol.CameraInfo)
+      CameraInfoOrBuilder {
+  private static final long serialVersionUID = 0L;
+    // Use CameraInfo.newBuilder() to construct.
+    private CameraInfo(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
+      super(builder);
+    }
+    private CameraInfo() {
+      c1_ = 0;
+      c2_ = 0;
+    }
+
+    @Override
+    public final com.google.protobuf.UnknownFieldSet
+    getUnknownFields() {
+      return this.unknownFields;
+    }
+    private CameraInfo(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      this();
+      if (extensionRegistry == null) {
+        throw new NullPointerException();
+      }
+      int mutable_bitField0_ = 0;
+      com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+          com.google.protobuf.UnknownFieldSet.newBuilder();
+      try {
+        boolean done = false;
+        while (!done) {
+          int tag = input.readTag();
+          switch (tag) {
+            case 0:
+              done = true;
+              break;
+            case 8: {
+              int rawValue = input.readEnum();
+
+              c1_ = rawValue;
+              break;
+            }
+            case 16: {
+              int rawValue = input.readEnum();
+
+              c2_ = rawValue;
+              break;
+            }
+            case 24: {
+
+              expireTime_ = input.readInt64();
+              break;
+            }
+            default: {
+              if (!parseUnknownField(
+                  input, unknownFields, extensionRegistry, tag)) {
+                done = true;
+              }
+              break;
+            }
+          }
+        }
+      } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+        throw e.setUnfinishedMessage(this);
+      } catch (java.io.IOException e) {
+        throw new com.google.protobuf.InvalidProtocolBufferException(
+            e).setUnfinishedMessage(this);
+      } finally {
+        this.unknownFields = unknownFields.build();
+        makeExtensionsImmutable();
+      }
+    }
+    public static final com.google.protobuf.Descriptors.Descriptor
+        getDescriptor() {
+      return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_descriptor;
+    }
+
+    @Override
+    protected FieldAccessorTable
+        internalGetFieldAccessorTable() {
+      return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_fieldAccessorTable
+          .ensureFieldAccessorsInitialized(
+              CameraInfo.class, Builder.class);
+    }
+
+    public static final int C_1_FIELD_NUMBER = 1;
+    private int c1_;
+    /**
+     * <pre>
+     * 前置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+     */
+    public int getC1Value() {
+      return c1_;
+    }
+    /**
+     * <pre>
+     * 前置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+     */
+    public CameraStatus getC1() {
+      @SuppressWarnings("deprecation")
+      CameraStatus result = CameraStatus.valueOf(c1_);
+      return result == null ? CameraStatus.UNRECOGNIZED : result;
+    }
+
+    public static final int C_2_FIELD_NUMBER = 2;
+    private int c2_;
+    /**
+     * <pre>
+     * 后置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+     */
+    public int getC2Value() {
+      return c2_;
+    }
+    /**
+     * <pre>
+     * 后置
+     * </pre>
+     *
+     * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+     */
+    public CameraStatus getC2() {
+      @SuppressWarnings("deprecation")
+      CameraStatus result = CameraStatus.valueOf(c2_);
+      return result == null ? CameraStatus.UNRECOGNIZED : result;
+    }
+
+    public static final int EXPIRETIME_FIELD_NUMBER = 3;
+    private long expireTime_;
+    /**
+     * <pre>
+     * 数据有效时间：数据失效时间 = 当前时间 + expireTime
+     * </pre>
+     *
+     * <code>int64 expireTime = 3;</code>
+     */
+    public long getExpireTime() {
+      return expireTime_;
+    }
+
+    private byte memoizedIsInitialized = -1;
+    @Override
+    public final boolean isInitialized() {
+      byte isInitialized = memoizedIsInitialized;
+      if (isInitialized == 1) return true;
+      if (isInitialized == 0) return false;
+
+      memoizedIsInitialized = 1;
+      return true;
+    }
+
+    @Override
+    public void writeTo(com.google.protobuf.CodedOutputStream output)
+                        throws java.io.IOException {
+      if (c1_ != CameraStatus.CAMERA_STATUS_UNKNOW.getNumber()) {
+        output.writeEnum(1, c1_);
+      }
+      if (c2_ != CameraStatus.CAMERA_STATUS_UNKNOW.getNumber()) {
+        output.writeEnum(2, c2_);
+      }
+      if (expireTime_ != 0L) {
+        output.writeInt64(3, expireTime_);
+      }
+      unknownFields.writeTo(output);
+    }
+
+    @Override
+    public int getSerializedSize() {
+      int size = memoizedSize;
+      if (size != -1) return size;
+
+      size = 0;
+      if (c1_ != CameraStatus.CAMERA_STATUS_UNKNOW.getNumber()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeEnumSize(1, c1_);
+      }
+      if (c2_ != CameraStatus.CAMERA_STATUS_UNKNOW.getNumber()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeEnumSize(2, c2_);
+      }
+      if (expireTime_ != 0L) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt64Size(3, expireTime_);
+      }
+      size += unknownFields.getSerializedSize();
+      memoizedSize = size;
+      return size;
+    }
+
+    @Override
+    public boolean equals(final Object obj) {
+      if (obj == this) {
+       return true;
+      }
+      if (!(obj instanceof CameraInfo)) {
+        return super.equals(obj);
+      }
+      CameraInfo other = (CameraInfo) obj;
+
+      if (c1_ != other.c1_) return false;
+      if (c2_ != other.c2_) return false;
+      if (getExpireTime()
+          != other.getExpireTime()) return false;
+      if (!unknownFields.equals(other.unknownFields)) return false;
+      return true;
+    }
+
+    @Override
+    public int hashCode() {
+      if (memoizedHashCode != 0) {
+        return memoizedHashCode;
+      }
+      int hash = 41;
+      hash = (19 * hash) + getDescriptor().hashCode();
+      hash = (37 * hash) + C_1_FIELD_NUMBER;
+      hash = (53 * hash) + c1_;
+      hash = (37 * hash) + C_2_FIELD_NUMBER;
+      hash = (53 * hash) + c2_;
+      hash = (37 * hash) + EXPIRETIME_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
+          getExpireTime());
+      hash = (29 * hash) + unknownFields.hashCode();
+      memoizedHashCode = hash;
+      return hash;
+    }
+
+    public static CameraInfo parseFrom(
+        java.nio.ByteBuffer data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static CameraInfo parseFrom(
+        java.nio.ByteBuffer data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static CameraInfo parseFrom(
+        com.google.protobuf.ByteString data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static CameraInfo parseFrom(
+        com.google.protobuf.ByteString data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static CameraInfo parseFrom(byte[] data)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data);
+    }
+    public static CameraInfo parseFrom(
+        byte[] data,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws com.google.protobuf.InvalidProtocolBufferException {
+      return PARSER.parseFrom(data, extensionRegistry);
+    }
+    public static CameraInfo parseFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input);
+    }
+    public static CameraInfo parseFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static CameraInfo parseDelimitedFrom(java.io.InputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseDelimitedWithIOException(PARSER, input);
+    }
+    public static CameraInfo parseDelimitedFrom(
+        java.io.InputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
+    }
+    public static CameraInfo parseFrom(
+        com.google.protobuf.CodedInputStream input)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input);
+    }
+    public static CameraInfo parseFrom(
+        com.google.protobuf.CodedInputStream input,
+        com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+        throws java.io.IOException {
+      return com.google.protobuf.GeneratedMessageV3
+          .parseWithIOException(PARSER, input, extensionRegistry);
+    }
+
+    @Override
+    public Builder newBuilderForType() { return newBuilder(); }
+    public static Builder newBuilder() {
+      return DEFAULT_INSTANCE.toBuilder();
+    }
+    public static Builder newBuilder(CameraInfo prototype) {
+      return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
+    }
+    @Override
+    public Builder toBuilder() {
+      return this == DEFAULT_INSTANCE
+          ? new Builder() : new Builder().mergeFrom(this);
+    }
+
+    @Override
+    protected Builder newBuilderForType(
+        BuilderParent parent) {
+      Builder builder = new Builder(parent);
+      return builder;
+    }
+    /**
+     * <pre>
+     * 摄像头信息
+     * </pre>
+     *
+     * Protobuf type {@code com.zhidao.ptech.shadow.server.protocol.CameraInfo}
+     */
+    public static final class Builder extends
+        com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
+        // @@protoc_insertion_point(builder_implements:com.zhidao.ptech.shadow.server.protocol.CameraInfo)
+        CameraInfoOrBuilder {
+      public static final com.google.protobuf.Descriptors.Descriptor
+          getDescriptor() {
+        return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_descriptor;
+      }
+
+      @Override
+      protected FieldAccessorTable
+          internalGetFieldAccessorTable() {
+        return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_fieldAccessorTable
+            .ensureFieldAccessorsInitialized(
+                CameraInfo.class, Builder.class);
+      }
+
+      // Construct using com.zhidao.ptech.shadow.server.protocol.DeviceInfo.CameraInfo.newBuilder()
+      private Builder() {
+        maybeForceBuilderInitialization();
+      }
+
+      private Builder(
+          BuilderParent parent) {
+        super(parent);
+        maybeForceBuilderInitialization();
+      }
+      private void maybeForceBuilderInitialization() {
+        if (com.google.protobuf.GeneratedMessageV3
+                .alwaysUseFieldBuilders) {
+        }
+      }
+      @Override
+      public Builder clear() {
+        super.clear();
+        c1_ = 0;
+
+        c2_ = 0;
+
+        expireTime_ = 0L;
+
+        return this;
+      }
+
+      @Override
+      public com.google.protobuf.Descriptors.Descriptor
+          getDescriptorForType() {
+        return DeviceInfo.internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_descriptor;
+      }
+
+      @Override
+      public CameraInfo getDefaultInstanceForType() {
+        return CameraInfo.getDefaultInstance();
+      }
+
+      @Override
+      public CameraInfo build() {
+        CameraInfo result = buildPartial();
+        if (!result.isInitialized()) {
+          throw newUninitializedMessageException(result);
+        }
+        return result;
+      }
+
+      @Override
+      public CameraInfo buildPartial() {
+        CameraInfo result = new CameraInfo(this);
+        result.c1_ = c1_;
+        result.c2_ = c2_;
+        result.expireTime_ = expireTime_;
+        onBuilt();
+        return result;
+      }
+
+      @Override
+      public Builder clone() {
+        return super.clone();
+      }
+      @Override
+      public Builder setField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          Object value) {
+        return super.setField(field, value);
+      }
+      @Override
+      public Builder clearField(
+          com.google.protobuf.Descriptors.FieldDescriptor field) {
+        return super.clearField(field);
+      }
+      @Override
+      public Builder clearOneof(
+          com.google.protobuf.Descriptors.OneofDescriptor oneof) {
+        return super.clearOneof(oneof);
+      }
+      @Override
+      public Builder setRepeatedField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          int index, Object value) {
+        return super.setRepeatedField(field, index, value);
+      }
+      @Override
+      public Builder addRepeatedField(
+          com.google.protobuf.Descriptors.FieldDescriptor field,
+          Object value) {
+        return super.addRepeatedField(field, value);
+      }
+      @Override
+      public Builder mergeFrom(com.google.protobuf.Message other) {
+        if (other instanceof CameraInfo) {
+          return mergeFrom((CameraInfo)other);
+        } else {
+          super.mergeFrom(other);
+          return this;
+        }
+      }
+
+      public Builder mergeFrom(CameraInfo other) {
+        if (other == CameraInfo.getDefaultInstance()) return this;
+        if (other.c1_ != 0) {
+          setC1Value(other.getC1Value());
+        }
+        if (other.c2_ != 0) {
+          setC2Value(other.getC2Value());
+        }
+        if (other.getExpireTime() != 0L) {
+          setExpireTime(other.getExpireTime());
+        }
+        this.mergeUnknownFields(other.unknownFields);
+        onChanged();
+        return this;
+      }
+
+      @Override
+      public final boolean isInitialized() {
+        return true;
+      }
+
+      @Override
+      public Builder mergeFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws java.io.IOException {
+        CameraInfo parsedMessage = null;
+        try {
+          parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+        } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+          parsedMessage = (CameraInfo) e.getUnfinishedMessage();
+          throw e.unwrapIOException();
+        } finally {
+          if (parsedMessage != null) {
+            mergeFrom(parsedMessage);
+          }
+        }
+        return this;
+      }
+
+      private int c1_ = 0;
+      /**
+       * <pre>
+       * 前置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+       */
+      public int getC1Value() {
+        return c1_;
+      }
+      /**
+       * <pre>
+       * 前置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+       */
+      public Builder setC1Value(int value) {
+        c1_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 前置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+       */
+      public CameraStatus getC1() {
+        @SuppressWarnings("deprecation")
+        CameraStatus result = CameraStatus.valueOf(c1_);
+        return result == null ? CameraStatus.UNRECOGNIZED : result;
+      }
+      /**
+       * <pre>
+       * 前置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+       */
+      public Builder setC1(CameraStatus value) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        
+        c1_ = value.getNumber();
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 前置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_1 = 1;</code>
+       */
+      public Builder clearC1() {
+        
+        c1_ = 0;
+        onChanged();
+        return this;
+      }
+
+      private int c2_ = 0;
+      /**
+       * <pre>
+       * 后置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+       */
+      public int getC2Value() {
+        return c2_;
+      }
+      /**
+       * <pre>
+       * 后置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+       */
+      public Builder setC2Value(int value) {
+        c2_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 后置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+       */
+      public CameraStatus getC2() {
+        @SuppressWarnings("deprecation")
+        CameraStatus result = CameraStatus.valueOf(c2_);
+        return result == null ? CameraStatus.UNRECOGNIZED : result;
+      }
+      /**
+       * <pre>
+       * 后置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+       */
+      public Builder setC2(CameraStatus value) {
+        if (value == null) {
+          throw new NullPointerException();
+        }
+        
+        c2_ = value.getNumber();
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 后置
+       * </pre>
+       *
+       * <code>.com.zhidao.ptech.shadow.server.protocol.CameraStatus C_2 = 2;</code>
+       */
+      public Builder clearC2() {
+        
+        c2_ = 0;
+        onChanged();
+        return this;
+      }
+
+      private long expireTime_ ;
+      /**
+       * <pre>
+       * 数据有效时间：数据失效时间 = 当前时间 + expireTime
+       * </pre>
+       *
+       * <code>int64 expireTime = 3;</code>
+       */
+      public long getExpireTime() {
+        return expireTime_;
+      }
+      /**
+       * <pre>
+       * 数据有效时间：数据失效时间 = 当前时间 + expireTime
+       * </pre>
+       *
+       * <code>int64 expireTime = 3;</code>
+       */
+      public Builder setExpireTime(long value) {
+        
+        expireTime_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * 数据有效时间：数据失效时间 = 当前时间 + expireTime
+       * </pre>
+       *
+       * <code>int64 expireTime = 3;</code>
+       */
+      public Builder clearExpireTime() {
+        
+        expireTime_ = 0L;
+        onChanged();
+        return this;
+      }
+      @Override
+      public final Builder setUnknownFields(
+          final com.google.protobuf.UnknownFieldSet unknownFields) {
+        return super.setUnknownFields(unknownFields);
+      }
+
+      @Override
+      public final Builder mergeUnknownFields(
+          final com.google.protobuf.UnknownFieldSet unknownFields) {
+        return super.mergeUnknownFields(unknownFields);
+      }
+
+
+      // @@protoc_insertion_point(builder_scope:com.zhidao.ptech.shadow.server.protocol.CameraInfo)
+    }
+
+    // @@protoc_insertion_point(class_scope:com.zhidao.ptech.shadow.server.protocol.CameraInfo)
+    private static final CameraInfo DEFAULT_INSTANCE;
+    static {
+      DEFAULT_INSTANCE = new CameraInfo();
+    }
+
+    public static CameraInfo getDefaultInstance() {
+      return DEFAULT_INSTANCE;
+    }
+
+    private static final com.google.protobuf.Parser<CameraInfo>
+        PARSER = new com.google.protobuf.AbstractParser<CameraInfo>() {
+      @Override
+      public CameraInfo parsePartialFrom(
+          com.google.protobuf.CodedInputStream input,
+          com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+          throws com.google.protobuf.InvalidProtocolBufferException {
+        return new CameraInfo(input, extensionRegistry);
+      }
+    };
+
+    public static com.google.protobuf.Parser<CameraInfo> parser() {
+      return PARSER;
+    }
+
+    @Override
+    public com.google.protobuf.Parser<CameraInfo> getParserForType() {
+      return PARSER;
+    }
+
+    @Override
+    public CameraInfo getDefaultInstanceForType() {
+      return DEFAULT_INSTANCE;
+    }
+
+  }
+
+  private static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_descriptor;
+  private static final 
+    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+      internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_fieldAccessorTable;
+  private static final com.google.protobuf.Descriptors.Descriptor
+    internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_descriptor;
+  private static final 
+    com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
+      internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_fieldAccessorTable;
+
+  public static com.google.protobuf.Descriptors.FileDescriptor
+      getDescriptor() {
+    return descriptor;
+  }
+  private static  com.google.protobuf.Descriptors.FileDescriptor
+      descriptor;
+  static {
+    String[] descriptorData = {
+      "\n\020DeviceInfo.proto\022\'com.zhidao.ptech.sha" +
+      "dow.server.protocol\"\350\002\n\016DeviceInfoData\022\021" +
+      "\n\ttimestamp\030\001 \001(\003\022\n\n\002sn\030\002 \001(\t\022\013\n\003uid\030\003 \001" +
+      "(\003\022\017\n\007version\030\004 \001(\003\022\013\n\003lat\030\005 \001(\001\022\013\n\003lon\030" +
+      "\006 \001(\001\022O\n\016coordinateType\030\007 \001(\01627.com.zhid" +
+      "ao.ptech.shadow.server.protocol.Coordina" +
+      "teType\022C\n\010lockType\030\010 \001(\01621.com.zhidao.pt" +
+      "ech.shadow.server.protocol.LockType\022\020\n\010c" +
+      "ityCode\030\t \001(\t\022\016\n\006adCode\030\n \001(\t\022G\n\ncameraI" +
+      "nfo\030e \001(\01323.com.zhidao.ptech.shadow.serv" +
+      "er.protocol.CameraInfo\"\250\001\n\nCameraInfo\022B\n" +
+      "\003C_1\030\001 \001(\01625.com.zhidao.ptech.shadow.ser" +
+      "ver.protocol.CameraStatus\022B\n\003C_2\030\002 \001(\01625" +
+      ".com.zhidao.ptech.shadow.server.protocol" +
+      ".CameraStatus\022\022\n\nexpireTime\030\003 \001(\003*d\n\014Cam" +
+      "eraStatus\022\030\n\024CAMERA_STATUS_UNKNOW\020\000\022\033\n\027C" +
+      "AMERA_STATUS_AVAILABLE\020\001\022\035\n\031CAMERA_STATU" +
+      "S_UNAVAILABLE\020\002*S\n\016CoordinateType\022\007\n\003GCJ" +
+      "\020\000\022\024\n\020BAIDU_COORDINATE\020\001\022\027\n\023SOSO_GCJ_COO" +
+      "RDINATE\020\002\022\t\n\005WGS84\020\003*p\n\010LockType\022\024\n\020LOCK" +
+      "_TYPE_UNKNOW\020\000\022\021\n\rLOCK_TYPE_GPS\020\001\022\022\n\016LOC" +
+      "K_TYPE_LAST\020\002\022\023\n\017LOCK_TYPE_CACHE\020\004\022\022\n\016LO" +
+      "CK_TYPE_WIFI\020\005B\014B\nDeviceInfob\006proto3"
+    };
+    com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
+        new com.google.protobuf.Descriptors.FileDescriptor.    InternalDescriptorAssigner() {
+          public com.google.protobuf.ExtensionRegistry assignDescriptors(
+              com.google.protobuf.Descriptors.FileDescriptor root) {
+            descriptor = root;
+            return null;
+          }
+        };
+    com.google.protobuf.Descriptors.FileDescriptor
+      .internalBuildGeneratedFileFrom(descriptorData,
+        new com.google.protobuf.Descriptors.FileDescriptor[] {
+        }, assigner);
+    internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_descriptor =
+      getDescriptor().getMessageTypes().get(0);
+    internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+        internal_static_com_zhidao_ptech_shadow_server_protocol_DeviceInfoData_descriptor,
+        new String[] { "Timestamp", "Sn", "Uid", "Version", "Lat", "Lon", "CoordinateType", "LockType", "CityCode", "AdCode", "CameraInfo", });
+    internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_descriptor =
+      getDescriptor().getMessageTypes().get(1);
+    internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_fieldAccessorTable = new
+      com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
+        internal_static_com_zhidao_ptech_shadow_server_protocol_CameraInfo_descriptor,
+        new String[] { "C1", "C2", "ExpireTime", });
+  }
+
+  // @@protoc_insertion_point(outer_class_scope)
+}
diff --git a/settings.gradle b/settings.gradle
index 3df0b58..9cce782 100644
--- a/settings.gradle
+++ b/settings.gradle
@@ -1,3 +1,4 @@
+include ':foudations:mogo-common'
 include ':foudations:mogo-live'
 include ':foudations:mogo-socket'
 include ':modules:mogo-realtime'