[Change]

开始直播功能开发

Signed-off-by: donghongyu <donghongyu@zhidaoauto.com>

core/function-impl/mogo-core-function-hmi/src/main/java/com/mogo/eagle/core/function/hmi/ui/carcorder/CarcorderPreviewView.kt

@@ -8,7 +8,9 @@ import android.os.Looper
 import android.util.Log
 import android.view.*
 import android.view.animation.OvershootInterpolator
-import android.widget.Toast
+import com.mogo.cloud.live.manager.ILiveStreamManager
+import com.mogo.cloud.live.manager.LiveStreamManagerImpl
+import com.mogo.cloud.passport.MoGoAiCloudClientConfig
 import com.mogo.eagle.core.function.hmi.R
 import com.mogo.eagle.core.function.hmi.notification.WarningFloat
 import com.mogo.eagle.core.function.hmi.notification.anim.DefaultAnimator
@@ -39,6 +41,8 @@ class CarcorderPreviewView private constructor(
     private var isRequest = false
     private var isPreview = false
 
+    private var liveStreamManager: ILiveStreamManager? = null
+
     init {
         LayoutInflater.from(context).inflate(R.layout.view_carcorder_preview, this, true)
     }
@@ -178,7 +182,14 @@ class CarcorderPreviewView private constructor(
         mCameraHelper?.setDefaultFrameFormat(UVCCameraHelper.FRAME_FORMAT_MJPEG)
         mCameraHelper?.initUSBMonitor(context as Activity, carcorderPreview, listener)
 
-        mCameraHelper?.setOnPreviewFrameListener { nv21Yuv -> Log.d(TAG, "onPreviewResult: " + nv21Yuv.size) }
+        mCameraHelper?.setOnPreviewFrameListener { nv21Yuv ->
+            Log.d(TAG, "onPreviewResult: " + nv21Yuv.size)
+            //Log.i(TAG, "onVideoFrame byte length: " + bytesLength);
+            if (liveStreamManager != null) {
+                // 将摄像头采集的YUV数据推送到ZEGO
+                liveStreamManager!!.notifyYUVData(nv21Yuv, 1280, 720, 2)
+            }
+        }
     }
 
 
@@ -189,6 +200,19 @@ class CarcorderPreviewView private constructor(
         if (mCameraHelper != null) {
             mCameraHelper!!.registerUSB()
         }
+        // 初始化直播流管理
+        // 初始化直播流管理
+        liveStreamManager = LiveStreamManagerImpl.getInstance((context as Activity).application,
+                MoGoAiCloudClientConfig.getInstance().sn, true)
+
+        // 设置状态回调
+        liveStreamManager!!.setLiveStatusChangeCallback { status ->
+            if (status == 0) {
+                Logger.d(TAG, "直播中……")
+            } else {
+                Logger.d(TAG, "直播结束……")
+            }
+        }
     }
 
     override fun onDetachedFromWindow() {
@@ -197,6 +221,13 @@ class CarcorderPreviewView private constructor(
         if (mCameraHelper != null) {
             mCameraHelper!!.unregisterUSB()
         }
+
+        if (liveStreamManager != null) {
+            // 停止
+            liveStreamManager!!.stopLiveStream()
+            // 释放资源
+            liveStreamManager!!.release()
+        }
     }
 
     override fun onSurfaceCreated(view: CameraViewInterface?, surface: Surface?) {

core/function-impl/mogo-core-function-hmi/src/main/res/layout/view_carcorder_preview.xml

@@ -1,15 +1,14 @@
 <?xml version="1.0" encoding="utf-8"?>
 <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
     xmlns:app="http://schemas.android.com/apk/res-auto"
-    android:layout_width="@dimen/dp_768"
-    android:layout_height="@dimen/dp_432"
-    android:background="#FFFFFF">
+    android:layout_width="1px"
+    android:layout_height="1px">
 
 
     <com.serenegiant.usb.widget.UVCCameraTextureView
         android:id="@+id/carcorderPreview"
         android:layout_width="match_parent"
-        android:layout_height="wrap_content"
+        android:layout_height="match_parent"
         android:layout_gravity="center"
         app:layout_constraintBottom_toBottomOf="parent"
         app:layout_constraintLeft_toLeftOf="parent"