diff --git a/ZD_README/README_VersionHistory.md b/ZD_README/README_VersionHistory.md
index 56f59fab4a..aa6e59dedd 100644
--- a/ZD_README/README_VersionHistory.md
+++ b/ZD_README/README_VersionHistory.md
@@ -57,9 +57,6 @@ mogoservice : "com.mogo.service:mogo-service:${MOGO_COMMONS_VER
mogoserviceapi : "com.mogo.service:mogo-service-api:${MOGO_COMMONS_VERSION}",
moduleapps : "com.mogo.module:module-apps:${MOGO_COMMONS_VERSION}",
moduleextensions : "com.mogo.module:module-extensions:${MOGO_COMMONS_VERSION}",
-chat : "com.mogo.module.carchatout:module-chat:${MOGO_COMMONS_VERSION}",
-callchat : "com.mogo.module.carchatout:module-carchatting:${MOGO_COMMONS_VERSION}",
-callchatprovider : "com.mogo.module.carchatout:module-carchatting-provider:${MOGO_COMMONS_VERSION}",
// V2X
moduleV2x : "com.mogo.module:module-v2x:${MOGO_COMMONS_VERSION}",
diff --git a/app/build.gradle b/app/build.gradle
index a0c72dcba9..cd627761b2 100644
--- a/app/build.gradle
+++ b/app/build.gradle
@@ -220,7 +220,7 @@ repositories {
}
aspectjx {
- include "com.mogo.chat"
+ include "com.mogo.eagle.core.function.chat"
}
diff --git a/build.gradle b/build.gradle
index 8da9516e51..7091777dfd 100644
--- a/build.gradle
+++ b/build.gradle
@@ -115,3 +115,20 @@ afterEvaluate {
}
}
}
+
+subprojects.each {
+ Class kotlinCompile = null
+ try {
+ kotlinCompile = Class.forName("org.jetbrains.kotlin.gradle.tasks.KotlinCompile")
+ } catch (Throwable t) {
+ t.printStackTrace()
+ }
+ if (kotlinCompile != null) {
+ it.tasks.withType(kotlinCompile).configureEach {
+ kotlinOptions {
+ jvmTarget = '1.8'
+ freeCompilerArgs += ["-Xopt-in=kotlin.RequiresOptIn"]
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/config.gradle b/config.gradle
index 6a3e76a787..f99a5852dc 100644
--- a/config.gradle
+++ b/config.gradle
@@ -127,6 +127,7 @@ ext {
// androidx-lifecycle-process
androidxlifecycleprocess : "androidx.lifecycle:lifecycle-process:2.4.0",
+ androidxlifecycleservice : "androidx.lifecycle:lifecycle-service:2.4.0",
// rxjava2 with room
roomRxjava : 'androidx.room:room-rxjava2:2.2.3',
circleimageview : "de.hdodenhof:circleimageview:3.0.1",
diff --git a/core/function-impl/mogo-core-function-chat/.gitignore b/core/function-impl/mogo-core-function-chat/.gitignore
new file mode 100644
index 0000000000..42afabfd2a
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/.gitignore
@@ -0,0 +1 @@
+/build
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/build.gradle b/core/function-impl/mogo-core-function-chat/build.gradle
new file mode 100644
index 0000000000..b016d5a2a4
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/build.gradle
@@ -0,0 +1,82 @@
+plugins {
+ id 'com.android.library'
+ id 'kotlin-android'
+ id 'kotlin-android-extensions'
+ id 'kotlin-kapt'
+ id 'com.alibaba.arouter'
+}
+android {
+ compileSdkVersion rootProject.ext.android.compileSdkVersion
+ defaultConfig {
+ minSdkVersion rootProject.ext.android.minSdkVersion
+ targetSdkVersion rootProject.ext.android.targetSdkVersion
+ versionCode Integer.valueOf(VERSION_CODE)
+ versionName getValueFromRootProperties("${project.name.replace("-", "_").toUpperCase()}_VERSION")
+
+ testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+ consumerProguardFiles 'consumer-rules.pro'
+ //ARouter apt 参数
+ kapt {
+ useBuildCache = false
+ arguments {
+ arg("AROUTER_MODULE_NAME", project.getName())
+ }
+ }
+
+ ndk {
+ abiFilters "armeabi-v7a", "arm64-v8a"
+ }
+ }
+
+ sourceSets {
+ main {
+ jniLibs.srcDirs = ['libs']
+ }
+ }
+
+ 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.androidxccorektx
+ implementation rootProject.ext.dependencies.androidxappcompat
+ implementation rootProject.ext.dependencies.arouter
+ implementation rootProject.ext.dependencies.rxandroid
+ compileOnly rootProject.ext.dependencies.aspectj
+ kapt rootProject.ext.dependencies.aroutercompiler
+ implementation rootProject.ext.dependencies.mogowebsocket
+ implementation rootProject.ext.dependencies.circleimageview
+ implementation rootProject.ext.dependencies.androidxconstraintlayout
+ implementation rootProject.ext.dependencies.androidxrecyclerview
+
+ if (Boolean.valueOf(USE_MAVEN_PACKAGE)) {
+ implementation rootProject.ext.dependencies.modulecommon
+ implementation rootProject.ext.dependencies.moduleservice
+ implementation rootProject.ext.dependencies.mogo_core_data
+ implementation rootProject.ext.dependencies.mogo_core_utils
+ implementation rootProject.ext.dependencies.mogo_core_function_api
+ implementation rootProject.ext.dependencies.mogo_core_function_call
+ implementation rootProject.ext.dependencies.mogo_core_res
+ } else {
+ implementation project(':modules:mogo-module-common')
+ implementation project(':modules:mogo-module-service')
+ implementation project(':core:mogo-core-data')
+ implementation project(':core:mogo-core-utils')
+ implementation project(':core:mogo-core-function-api')
+ implementation project(':core:mogo-core-function-call')
+ implementation project(':core:mogo-core-res')
+ }
+}
+
+apply from: new File(rootProject.rootDir, "gradle/upload.gradle").toString()
diff --git a/core/function-impl/mogo-core-function-chat/consumer-rules.pro b/core/function-impl/mogo-core-function-chat/consumer-rules.pro
new file mode 100644
index 0000000000..e69de29bb2
diff --git a/core/function-impl/mogo-core-function-chat/gradle.properties b/core/function-impl/mogo-core-function-chat/gradle.properties
new file mode 100644
index 0000000000..63866596d3
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/gradle.properties
@@ -0,0 +1,3 @@
+GROUP=com.mogo.eagle.core.function.impl
+POM_ARTIFACT_ID=v2x
+VERSION_CODE=1
diff --git a/core/function-impl/mogo-core-function-chat/libs/arm64-v8a/libgmesdk.so b/core/function-impl/mogo-core-function-chat/libs/arm64-v8a/libgmesdk.so
new file mode 100644
index 0000000000..b65f686af8
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/libs/arm64-v8a/libgmesdk.so differ
diff --git a/core/function-impl/mogo-core-function-chat/libs/armeabi-v7a/libgmecodec.so b/core/function-impl/mogo-core-function-chat/libs/armeabi-v7a/libgmecodec.so
new file mode 100644
index 0000000000..ef0012b4fd
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/libs/armeabi-v7a/libgmecodec.so differ
diff --git a/core/function-impl/mogo-core-function-chat/libs/armeabi-v7a/libgmesdk.so b/core/function-impl/mogo-core-function-chat/libs/armeabi-v7a/libgmesdk.so
new file mode 100644
index 0000000000..9bdb9f2e54
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/libs/armeabi-v7a/libgmesdk.so differ
diff --git a/core/function-impl/mogo-core-function-chat/libs/gmesdk.jar b/core/function-impl/mogo-core-function-chat/libs/gmesdk.jar
new file mode 100644
index 0000000000..ddafacefb7
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/libs/gmesdk.jar differ
diff --git a/core/function-impl/mogo-core-function-chat/proguard-rules.pro b/core/function-impl/mogo-core-function-chat/proguard-rules.pro
new file mode 100644
index 0000000000..481bb43481
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/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/core/function-impl/mogo-core-function-chat/src/main/AndroidManifest.xml b/core/function-impl/mogo-core-function-chat/src/main/AndroidManifest.xml
new file mode 100644
index 0000000000..cd75fea39d
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/AndroidManifest.xml
@@ -0,0 +1,4 @@
+
+
+
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/MoGoChatProvider.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/MoGoChatProvider.kt
new file mode 100644
index 0000000000..ca37017785
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/MoGoChatProvider.kt
@@ -0,0 +1,37 @@
+package com.mogo.eagle.core.function.chat
+
+import android.content.Context
+import com.alibaba.android.arouter.facade.annotation.Route
+import com.mogo.eagle.core.function.api.chat.IMoGoChatProvider
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoChatFacade
+import com.mogo.eagle.core.function.chat.facade.MoGoChatFacade
+import com.mogo.eagle.core.function.chat.facade.ui.CallChatWindowManager
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+
+@Route(path = ChatConsts.CHAT_PROVIDER_PATH)
+class MoGoChatProvider: IMoGoChatProvider {
+
+ private val facade by lazy {
+ MoGoChatFacade
+ }
+
+ private val chatWindowManager by lazy {
+ CallChatWindowManager()
+ }
+
+ override val functionName = "MoGoChatProvider"
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun init(context: Context?) {
+ facade.init(context)
+ chatWindowManager.init()
+ }
+
+ override fun onDestroy() {
+ facade.onDestroy()
+ chatWindowManager.destroy()
+ }
+
+ override fun chat(): IMoGoChatFacade = facade
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/MoGoChatFacade.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/MoGoChatFacade.kt
new file mode 100644
index 0000000000..3a249b884c
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/MoGoChatFacade.kt
@@ -0,0 +1,1140 @@
+package com.mogo.eagle.core.function.chat.facade
+
+import android.content.Context
+import android.os.Handler
+import android.os.Looper
+import android.text.TextUtils
+import com.google.gson.Gson
+import com.mogo.eagle.core.function.chat.facade.gme.GMEApi
+import com.mogo.cloud.passport.MoGoAiCloudClientConfig
+import com.mogo.eagle.core.data.chat.UserInfo
+import com.mogo.eagle.core.data.chat.socket.Message
+import com.mogo.eagle.core.data.chat.socket.TeammateInfo
+import com.mogo.eagle.core.function.api.chat.biz.*
+import com.mogo.eagle.core.function.api.chat.biz.IMCallType.CALL_TYPE_DEFAULT
+import com.mogo.eagle.core.function.api.chat.biz.IMCallType.CALL_TYPE_VEHICLE_TEAM
+import com.mogo.eagle.core.function.api.chat.biz.IMCallType.CALL_TYPE_VOICE
+import com.mogo.eagle.core.function.api.chat.biz.IMType.*
+import com.mogo.eagle.core.function.chat.facade.analytics.ChatAnalyticsFacade
+import com.mogo.eagle.core.function.chat.facade.audio.AudioFocusFacade
+import com.mogo.eagle.core.function.chat.facade.bridge.BridgeApi
+import com.mogo.eagle.core.function.chat.facade.consts.PUSH_MSG_AGREE_ENTER
+import com.mogo.eagle.core.function.chat.facade.consts.PUSH_MSG_CREATE_ROOM
+import com.mogo.eagle.core.function.chat.facade.consts.PUSH_MSG_DENY_ENTER
+import com.mogo.eagle.core.function.chat.facade.consts.PUSH_MSG_HANG_UP
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState.EnterRoomFail
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState.EnterRoomSuccess
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState.ExitRoomSuccess
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState.InitFail
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState.InitSuccess
+import com.mogo.eagle.core.function.chat.facade.gme.GmeState.UserChangeInRoom
+import com.mogo.eagle.core.function.chat.facade.media.MedialControlFacade
+import com.mogo.eagle.core.function.chat.facade.net.ChatServiceModel
+import com.mogo.eagle.core.function.chat.facade.net.bean.CallRequestParam
+import com.mogo.eagle.core.function.chat.facade.net.bean.ConnectStatusParam
+import com.mogo.eagle.core.function.chat.facade.socket.SocketConnectManager
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import com.mogo.eagle.core.function.chat.facade.voice.VoiceControlFacade
+import com.mogo.eagle.core.utilcode.kotlin.safeCancel
+import com.mogo.eagle.core.utilcode.util.Utils
+import kotlinx.coroutines.*
+import kotlinx.coroutines.android.asCoroutineDispatcher
+import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.channels.Channel.Factory.RENDEZVOUS
+import kotlinx.coroutines.flow.*
+import kotlinx.coroutines.selects.select
+import java.lang.ref.WeakReference
+import java.util.concurrent.TimeUnit.SECONDS
+import java.util.concurrent.atomic.AtomicBoolean
+import java.util.concurrent.atomic.AtomicInteger
+import java.util.concurrent.atomic.AtomicReference
+import kotlin.properties.Delegates
+
+object MoGoChatFacade: IMoGoChatFacade {
+
+ /**
+ * 是否初始化的标记
+ */
+ private val hasInit by lazy { AtomicBoolean(false) }
+
+ private var contextHolder: WeakReference? = null
+
+ /**
+ * SocketClient实例
+ */
+ private val client by lazy {
+ SocketConnectManager.instance()
+ }
+
+ /**
+ * 车聊相关后台接口
+ */
+ private val serverApi by lazy {
+ ChatServiceModel()
+ }
+
+ /**
+ * 负责处理长链接下行数据的管道
+ */
+ @ExperimentalCoroutinesApi
+ private var channel4SocketMsg : Channel = Channel(RENDEZVOUS)
+ @Synchronized
+ get() {
+ return if (field.isClosedForSend || field.isClosedForReceive) {
+ field = Channel(RENDEZVOUS)
+ field
+ } else {
+ field
+ }
+ }
+
+ /**
+ * 负责处理GmeSdk的各种消息类型
+ */
+ @ExperimentalCoroutinesApi
+ private var channel4GmeState: Channel = Channel(RENDEZVOUS)
+ @Synchronized
+ get() {
+ return if (field.isClosedForReceive || field.isClosedForSend) {
+ field = Channel(RENDEZVOUS)
+ field
+ } else {
+ field
+ }
+ }
+
+ private var onInComingCallback: WeakReference? = null
+
+ private var onCallingInterrupt: WeakReference? = null
+
+ private var roomId by Delegates.observable(0) { _, _, newValue ->
+ SocketConnectManager.setRoomId(newValue)
+ }
+
+ private val openId by lazy {
+ AtomicReference()
+ }
+
+ private val scopeIndex by lazy {
+ AtomicInteger(0)
+ }
+
+ private var mainScope: CoroutineScope = acquireScope()
+ @Synchronized
+ get() {
+ if (field.isActive) {
+ return field
+ }
+ val scope = acquireScope()
+ field = scope
+ return field
+ }
+
+ private fun acquireScope(): CoroutineScope {
+ return CoroutineScope(Handler(Looper.getMainLooper()).asCoroutineDispatcher("chat-service") + SupervisorJob() + CoroutineName("chat-service-${scopeIndex.getAndIncrement()}"))
+ }
+
+ private var callStatus by Delegates.observable(INIT_CALL) { _, _, newValue ->
+ log(ChatConsts.TAG, "call-status: ${newValue.toText()}")
+ }
+
+ @ExperimentalCoroutinesApi
+ private val gmeCallback: ((state: GmeState) -> Unit) = { state ->
+ mainScope.launch {
+ channel4GmeState.send(state)
+ }
+ }
+
+ private var callType by Delegates.observable(CALL_TYPE_DEFAULT) { _, oldValue, newValue ->
+ log(ChatConsts.TAG, "call type change: oldValue: $oldValue - newValue: $newValue")
+ }
+
+ private val sender by lazy { AtomicReference(null) }
+ private val receiver by lazy { AtomicReference(null) }
+ private val mySelf by lazy { AtomicReference(null) }
+
+ @ExperimentalCoroutinesApi
+ internal fun init(context: Context?) {
+ BridgeApi.init(context)
+ context?.let {
+ contextHolder = WeakReference(it)
+ }
+ if (hasInit.compareAndSet(false, true)) {
+ initSocketService()
+ voice().register()
+ }
+ }
+
+ private fun context(): Context = contextHolder?.get() ?: Utils.getApp()
+
+ @ExperimentalCoroutinesApi
+ private fun initSocketService() {
+ log(ChatConsts.TAG, "-- initSocketService --")
+ SocketConnectManager.setOnMsgReceiveCb {
+ handleMessage(it)
+ }
+ SocketConnectManager.init()
+ }
+
+ @ExperimentalCoroutinesApi
+ private fun handleMessage(msg: String) {
+ mainScope.launch {
+ log(ChatConsts.TAG, "长链下行消息: $msg")
+ val map = Gson().fromJson>(msg, Map::class.java)
+ val temp = map ?: return@launch
+ val msgType = temp["msgType"]
+ if (msgType != null && msgType is Double) {
+ when(val t = msgType.toInt()) {
+ 0 -> {
+ val openId = (temp["localUserId"] as? Double ?: return@launch).toInt().toString()
+ log(ChatConsts.TAG, "handleMessage --- openId:$openId")
+ //初始化房间
+ GMEApi.init(context(), openId = openId, cb = gmeCallback)
+ }
+ else ->
+ log(ChatConsts.TAG, "handleMessage --- $t")
+ }
+ } else {
+ val message = withContext(Dispatchers.Default) { Gson().fromJson(msg, Message::class.java) } ?: return@launch
+ if (message.type.toCallType() == CALL_TYPE_VOICE && message.snSender == MoGoAiCloudClientConfig.getInstance().sn) {
+ return@launch
+ }
+ when(message.status) {
+ PUSH_MSG_AGREE_ENTER -> {
+ //接收者接受通话请求
+ when(message.type.toCallType()) {
+ CALL_TYPE_VOICE -> {
+ if (GMEApi.isRoomEntered() && callType == CALL_TYPE_VEHICLE_TEAM) {
+ log(ChatConsts.TAG, "收到来电进房消息，此时正在车队通话。需要挂断电话")
+ try {
+ serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, message.snSender, message.roomId, PUSH_MSG_HANG_UP, message.type))
+ } catch (t : Throwable) {
+ t.printStackTrace()
+ }
+ return@launch
+ }
+ callType = message.type.toCallType()
+ channel4SocketMsg.send(message)
+ }
+ CALL_TYPE_VEHICLE_TEAM -> {
+ if (callStatus.isReadyCalling()) {
+ try {
+ serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, message.snSender, message.roomId, PUSH_MSG_HANG_UP, message.type))
+ } catch (t : Throwable) {
+ t.printStackTrace()
+ }
+ return@launch
+ }
+ callType = message.type.toCallType()
+ channel4SocketMsg.send(message)
+ }
+ else -> log(ChatConsts.TAG, "-- 接收者同意通话，但是呼叫类型不对: ${message.type}")
+ }
+ }
+ PUSH_MSG_DENY_ENTER -> {
+ //接收者拒绝通话请求
+ when(message.type.toCallType()) {
+ CALL_TYPE_VOICE -> {
+ if (GMEApi.isRoomEntered() && callType == CALL_TYPE_VEHICLE_TEAM) {
+ log(ChatConsts.TAG, "已经进房，收到被拒绝消息，则不处理(为兼容车队需求)，否则会引发退房操作")
+ return@launch
+ }
+ if (callStatus == READY_TO_CALL_RECEIVER && message.snReceiver == MoGoAiCloudClientConfig.getInstance().sn) {
+ //如果当前是来电状态，并且收到拒绝消息，说明呼叫方呼出又挂断
+ log(ChatConsts.TAG, "呼叫方呼出后，又挂断")
+ onCallingInterrupt?.get()?.invoke(false, message.toUser())
+ return@launch
+ }
+ callType = message.type.toCallType()
+ channel4SocketMsg.send(message)
+ }
+ CALL_TYPE_VEHICLE_TEAM -> {
+ if (callStatus == READY_TO_CALL_RECEIVER && message.snReceiver == MoGoAiCloudClientConfig.getInstance().sn) {
+ //如果当前是来电状态，并且收到拒绝消息，说明呼叫方呼出又挂断
+ onCallingInterrupt?.get()?.invoke(true, message.toUser())
+ callStatus = INIT_CALL
+ return@launch
+ }
+ callType = message.type.toCallType()
+ channel4SocketMsg.send(message)
+ }
+ else -> log(ChatConsts.TAG, "-- 接收者拒绝，但是呼叫类型不对: ${message.type}")
+ }
+ }
+ PUSH_MSG_HANG_UP -> {
+ callType = message.type.toCallType()
+ channel4SocketMsg.send(message)
+ }
+ PUSH_MSG_CREATE_ROOM -> {
+ //来电
+ when(message.type.toCallType()) {
+ CALL_TYPE_VOICE, CALL_TYPE_VEHICLE_TEAM -> {
+ if (callStatus.isCalling()) {
+ //如果正在通话, 直接拒接
+ try {
+ serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, message.snSender, message.roomId, PUSH_MSG_DENY_ENTER, message.type))
+ } catch (t: Throwable) {
+ t.printStackTrace()
+ }
+ return@launch
+ }
+ val user = message.toUser()
+ onInComingCallback?.get()?.also {
+ it.invoke(callType.isTeam(), user)
+ callType = message.type.toCallType()
+ callStatus = READY_TO_CALL_RECEIVER
+ roomId = message.roomId
+ channel4SocketMsg.send(message)
+ }
+ }
+ else -> log(ChatConsts.TAG, "-- 收到来电，但是呼叫类型不对: ${message.type}")
+ }
+ }
+ }
+ }
+ }
+ }
+
+ override fun onInComingCall(cb: (isTeam: Boolean, user: UserInfo) -> Unit) {
+ this.onInComingCallback = WeakReference(cb)
+ }
+
+ override fun onCallingInterrupt(cb: (isTeam: Boolean, user: UserInfo) -> Unit) {
+ this.onCallingInterrupt = WeakReference(cb)
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun call(params: ChatParams): Flow {
+ return channelFlow {
+ send(CallState.Init)
+ if (callStatus != INIT_CALL) {
+ send(CallState.Error(CallState.CODE_CALL_STATE_ERROR, "[Call] - ${"呼叫状态不匹配，当前状态：${callStatus.toText()}"}"))
+ return@channelFlow
+ }
+ callStatus = READY_TO_CALL_SENDER
+ if (TextUtils.isEmpty(params.sn)) {
+ send(CallState.Error(CallState.CODE_CALL_PARAMS_INCOMPLETE, "[Call] - ${"请求参数缺少sn参数， 当前参数$params"}"))
+ return@channelFlow
+ }
+ if (GMEApi.isRoomEntered()) {
+ send(CallState.Error(CallState.CODE_USER_IN_ROOM, "[Call] - 当前用户已经进入房间了"))
+ return@channelFlow
+ }
+ if (params.sn == MoGoAiCloudClientConfig.getInstance().sn) {
+ send(CallState.Error(CallState.CODE_CALL_MYSELF, "[Call] - 不能呼叫自己"))
+ return@channelFlow
+ }
+ if (!client.isOpen) {
+ send(CallState.Error(CallState.CODE_CALL_SOCKET_DISCONNECT, "[Call] - 长链接已断开"))
+ return@channelFlow
+ }
+ val isOnline = try {
+ serverApi.isOnline(params.sn)
+ } catch (t: Throwable) {
+ false
+ }
+ if (!isOnline) {
+ send(CallState.Error(CallState.CODE_ANSWER_OFFLINE, "[Call] - 接收方不在线"))
+ return@channelFlow
+ }
+ if (mySelf.get() == null || mySelf.get().isIncomplete()) {
+ try {
+ val pair = serverApi.queryUserInfo(MoGoAiCloudClientConfig.getInstance().sn)
+ if (pair == null || pair.first != null || pair.second == null) {
+ send(CallState.Error(CallState.CODE_CALLER_USER_INFO_FAIL, "[Call] - 获取用户信息失败 - ${pair?.first?.msg}"))
+ return@channelFlow
+ }
+ mySelf.set(pair.second)
+ } catch (t: Throwable) {
+ send(CallState.Error(CallState.CODE_CALLER_USER_INFO_FAIL, t.message ?: "[Call] - 获取用户信息失败-未知异常"))
+ return@channelFlow
+ }
+ }
+ sender.set(mySelf.get())
+ // 获取房间信息
+ try {
+ val response = serverApi.requestRoomInfo(CallRequestParam().also {
+ it.snReceiver = params.sn
+ it.snSender = sender.get().sn
+ it.nickName = sender.get().name
+ it.headImgUrl = sender.get().icon
+ it.carInfo = sender.get().brand
+ it.type = CALL_TYPE_VOICE.type
+ })
+ if (response.code != 0 && response.code != 200) {
+ send(CallState.Error(CallState.CODE_ROOM_INFO_FAIL, "[Call] - ${response.msg}", mutableMapOf().also {
+ it["code"] = response.code.toString()
+ it["msg"] = response.msg
+ }))
+ return@channelFlow
+ }
+ val roomInfo = response.result
+ if (roomInfo.roomId <= 0) {
+ send(CallState.Error(CallState.CODE_ROOM_INFO_FAIL, "[Call] - 服务端返回的房间ID不合法：roomId: ${roomInfo.roomId}"))
+ return@channelFlow
+ }
+ roomId = roomInfo.roomId
+ } catch (ex: Throwable) {
+ send(CallState.Error(CallState.CODE_ROOM_INFO_FAIL, "[Call] - 房间数据请求异常：$ex"))
+ return@channelFlow
+ }
+ //获取房间数据成功，等着对方响应
+ client.startHeartBeat()
+ val teamMembers = AtomicReference>()
+ val d1 = mainScope.async {
+ val members = mutableListOf()
+ while (!channel4GmeState.isClosedForReceive) {
+ when(val state = channel4GmeState.receive()) {
+ is InitFail -> {
+ send(CallState.Error(CallState.CODE_GME_INIT_FAIL, "[Call] - GmeSdk初始化失败，Code: ${state.code}"))
+ return@async
+ }
+ is InitSuccess -> {
+ openId.set(state.openId)
+ continue
+ }
+ is EnterRoomFail -> {
+ send(CallState.Error(CallState.CODE_ENTER_ROOM_FAIL, "[Call] - 进入房间失败:code -> ${state.code} :: msg -> ${state.msg}"))
+ return@async
+ }
+ EnterRoomSuccess -> {
+ members += openId.get()
+ realEnterRoom()
+ callStatus = CALLING_SENDER
+ send(CallState.EnterRoomSuccess)
+ }
+ ExitRoomSuccess -> {
+ realExitRoom()
+ send(CallState.ExitRoomSuccess)
+ return@async
+ }
+ is UserChangeInRoom -> {
+ log(ChatConsts.TAG, "openIds: ${state.left.joinToString(",")}")
+ if (!state.isEnter && state.left.isEmpty()) {
+ exitRoom()
+ continue
+ }
+ val newL = state.left
+ val subs = newL.subtract(members)
+ members.clear()
+ members += newL
+ val isMySelf = subs.isEmpty() || subs.contains(openId.get())
+ if (state.isEnter) {
+ send(CallState.RoomMemberUpdate(isMySelf, true, teamMembers.get()))
+ } else {
+ send(CallState.RoomMemberUpdate(isMySelf, false, teamMembers.get()))
+ if (!callType.isTeam()) {
+ exitRoom()
+ }
+ }
+ }
+ }
+ }
+ }
+ val d2 = mainScope.async {
+ while (!channel4SocketMsg.isClosedForReceive) {
+ val msg = channel4SocketMsg.receive()
+ when(msg.status) {
+ PUSH_MSG_AGREE_ENTER -> {
+ //接收方同意进房
+ log(ChatConsts.TAG, "[Call] - [Agree] - roomId: $roomId-msg: $msg")
+ if (roomId == msg.roomId) {
+ if (callType == CALL_TYPE_VOICE) {
+ send(CallState.AgreeCall(false, msg))
+ enterRoom()
+ } else {
+ //接受车队邀请
+ send(CallState.AgreeCall(true, msg))
+ if (!GMEApi.isRoomEntered()) {
+ enterRoom()
+ }
+ }
+ }
+ }
+ PUSH_MSG_DENY_ENTER -> {
+ //接收方拒绝进房
+ log(ChatConsts.TAG, "[Call] - [Refuse] - roomId: $roomId-msg: $msg")
+ if (roomId == msg.roomId) {
+ teamMembers.set(msg.teamMember ?: emptyList())
+ if (callType == CALL_TYPE_VOICE) {
+ //拒绝通话邀请
+ send(CallState.RefuseCall(false, msg))
+ return@async
+ }
+ if (callType == CALL_TYPE_VEHICLE_TEAM) {
+ send(CallState.RefuseCall(true, msg))
+ }
+ }
+ }
+
+ PUSH_MSG_HANG_UP -> {
+ log(ChatConsts.TAG, "[Call] - [hangUp] - roomId: $roomId-msg: $msg")
+ teamMembers.set(msg.teamMember ?: emptyList())
+ if (callType == CALL_TYPE_VOICE) {
+ send(CallState.HangUp(false, msg))
+ exitRoom()
+ } else {
+ //车除成员有挂断的情况
+ send(CallState.HangUp(true, msg))
+ }
+ }
+ }
+ }
+ }
+ val state = select {
+ d1.onAwait { 1 }
+ d2.onAwait { 2 }
+ }
+ when(state) {
+ 1 -> {
+ d2.safeCancel()
+ }
+ 2 -> {
+ d1.safeCancel()
+ }
+ }
+ }.catch {
+ log(ChatConsts.TAG, "unknow exption：$it")
+ emit(CallState.Error(CallState.CODE_UNKNOWN_ERROR, "[Call] - ${it.message ?: "未知异常"}"))
+ }.onCompletion {
+ resetState()
+ }
+ }
+
+ private fun enableAudio() {
+ GMEApi.enableAudio()
+ }
+
+ private fun disableAudio() {
+ GMEApi.disableAudio()
+ }
+
+ /**
+ * 进入房间
+ * @param roomId: 服务端分配的房间id
+ */
+ private fun enterRoom() {
+ if (GMEApi.isRoomEntered()) {
+ return
+ }
+ GMEApi.enterRoom(roomId.toString())
+ }
+
+ /**
+ * 退房执行的动作
+ * @param duration: 超时时长
+ * @param unit: 时间单位
+ * @param block: 超时后执行的行为
+ */
+ private fun exitRoom() {
+ if (!GMEApi.isRoomEntered()) {
+ return
+ }
+ GMEApi.exitRoom()
+ }
+
+ @ExperimentalCoroutinesApi
+ private fun realExitRoom() {
+ disableAudio()
+ resetState()
+ }
+
+ private fun realEnterRoom() {
+ enableAudio()
+ }
+
+ override fun canCall(): Boolean = client.isOpen && callStatus.isInit()
+
+ override fun canAnswer(): Boolean = client.isOpen && callStatus == READY_TO_CALL_RECEIVER
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun answer(sn: String): Flow {
+ return channelFlow {
+ send(AnswerState.Init)
+ if (callStatus != READY_TO_CALL_RECEIVER) {
+ send(AnswerState.Error(AnswerState.CODE_ANSWER_STATE_ERROR, "[Answer] - 应答状态错误 -> 当前状态：${callStatus.toText()}"))
+ return@channelFlow
+ }
+ val mySn = MoGoAiCloudClientConfig.getInstance().sn
+ if (TextUtils.isEmpty(mySn)) {
+ send(AnswerState.Error(AnswerState.CODE_ANSWER_PARAMS_INCOMPLETE, "[Answer] - 当前用户/应答方- sn参数不存在"))
+ return@channelFlow
+ }
+ if (!client.isOpen) {
+ send(AnswerState.Error(AnswerState.CODE_ANSWER_SOCKET_DISCONNECT, "[Answer] - 当前车机长链接断开"))
+ return@channelFlow
+ }
+ if (mySelf.get() == null || mySelf.get().isIncomplete()) {
+ try {
+ val pair = serverApi.queryUserInfo(MoGoAiCloudClientConfig.getInstance().sn)
+ if (pair == null || pair.first != null || pair.second == null) {
+ send(AnswerState.Error(AnswerState.CODE_CALLER_USER_INFO_FAIL, "[Answer] - 获取应答方用户信息失败"))
+ return@channelFlow
+ }
+ mySelf.set(pair.second)
+ } catch (t: Throwable) {
+ send(AnswerState.Error(AnswerState.CODE_CALLER_USER_INFO_FAIL, t.message ?: "[Answer] - 获取用户信息失败-未知异常"))
+ return@channelFlow
+ }
+ }
+ //告之服务器给发送方下发接收通话消息
+ try {
+ val location = BridgeApi.locationClient()?.lastKnowLocation
+ val response = serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, sn, roomId, PUSH_MSG_AGREE_ENTER, CALL_TYPE_VOICE.type).also {
+ it.nickName = mySelf.get().name
+ it.headImgUrl = mySelf.get().icon
+ it.carInfo = mySelf.get().brand
+ it.cardIdAge = mySelf.get().age
+ it.cardIdSex = mySelf.get().sex
+ it.cityName = mySelf.get().city
+ it.lat = location?.latitude ?: 0.0
+ it.lon = location?.longitude ?: 0.0
+ })
+ if (response.code != 0 && response.code != 200) {
+ send(AnswerState.Error(AnswerState.CODE_ANSWER_API_REQ_FAIL, "[Answer] - ${response.msg}", mutableMapOf().also {
+ it["code"] = response.code.toString()
+ it["msg"] = response.msg
+ }))
+ return@channelFlow
+ }
+ } catch (t: Throwable) {
+ send(AnswerState.Error(AnswerState.CODE_ANSWER_API_REQ_FAIL, "[Answer] - ${t.message ?: "同步应答状态接口异常：$t"}"))
+ return@channelFlow
+ }
+ val teamMembers = AtomicReference>()
+ client.startHeartBeat()
+ enterRoom()
+ //成功
+ val d1 = mainScope.async {
+ while (!channel4SocketMsg.isClosedForReceive) {
+ val msg = channel4SocketMsg.receive()
+ when(msg.status) {
+ PUSH_MSG_HANG_UP -> {
+ log(ChatConsts.TAG, "[Answer] - [hangUp] - msg -> $msg")
+ if (callType == CALL_TYPE_VOICE) {
+ send(AnswerState.HangUp(false, msg))
+ exitRoom()
+ } else {
+ //车除成员有挂断的情况
+ send(AnswerState.HangUp(true, msg))
+ teamMembers.set(msg.teamMember ?: emptyList())
+ }
+ }
+ PUSH_MSG_AGREE_ENTER -> {
+ log(ChatConsts.TAG, "[Answer] - [Agree] - msg -> $msg")
+ if (callType.isTeam()) {
+ //接受车队邀请
+ log(ChatConsts.TAG, "[Answer] - [Agree] - [Team] - msg -> $msg")
+ send(AnswerState.AcceptTeamInvite(msg))
+ teamMembers.set(msg.teamMember)
+ }
+ }
+ PUSH_MSG_DENY_ENTER -> {
+ log(ChatConsts.TAG, "[Answer] - [hangUp] - msg -> $msg")
+ if (callType.isTeam()) {
+ log(ChatConsts.TAG, "[Answer] - [hangUp] - [Team] - msg -> $msg")
+ send(AnswerState.RefuseTeamInvite(msg))
+ teamMembers.set(msg.teamMember)
+ }
+ }
+ }
+ }
+ }
+ val d2 = mainScope.async {
+ val members = mutableListOf()
+ while (!channel4GmeState.isClosedForReceive) {
+ when(val state = channel4GmeState.receive()) {
+ is InitFail -> {
+ send(AnswerState.Error(AnswerState.CODE_GME_INIT_FAIL, "[Answer] - GmeSdk初始化失败"))
+ return@async
+ }
+ is InitSuccess -> {
+ openId.set(state.openId)
+ continue
+ }
+ is EnterRoomSuccess -> {
+ members += openId.get()
+ callStatus = CALLING_RECEIVER
+ realEnterRoom()
+ send(AnswerState.EnterRoomSuccess)
+ }
+ is EnterRoomFail -> {
+ send(AnswerState.Error(AnswerState.CODE_ANSWER_EXIT_ROOM_FAIL, "[Answer] - 应答者退房失败: code : ${state.code} - msg : ${state.msg}"))
+ return@async
+ }
+ ExitRoomSuccess -> {
+ send(AnswerState.ExitRoomSuccess)
+ realExitRoom()
+ return@async
+ }
+ is UserChangeInRoom -> {
+ log(ChatConsts.TAG, "openIds: ${state.left.joinToString(",")}")
+ if (!state.isEnter && state.left.isEmpty()) {
+ exitRoom()
+ continue
+ }
+ val newL = state.left
+ val subs = newL.subtract(members)
+ members.clear()
+ members += newL
+ val isMySelf = subs.isEmpty() || subs.contains(openId.get())
+ if (state.isEnter) {
+ send(AnswerState.RoomMemberUpdate(isMySelf, true, teamMembers.get()))
+ } else {
+ send(AnswerState.RoomMemberUpdate(isMySelf, false, teamMembers.get()))
+ if (!callType.isTeam()) {
+ exitRoom()
+ }
+ }
+ }
+ }
+ }
+ }
+ val state = select {
+ d1.onAwait { 1 }
+ d2.onAwait { 2 }
+ }
+ when (state) {
+ 1 -> {
+ d2.safeCancel()
+ }
+ 2 -> {
+ d1.safeCancel()
+ }
+ }
+ }.catch {
+ log(ChatConsts.TAG, "unknow exption：$it")
+ emit(AnswerState.Error(AnswerState.CODE_UNKNOWN_ERROR, it.message ?: "未知异常"))
+ }.onCompletion {
+ resetState()
+ }
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun handUp(sn: String): Flow {
+ return flow {
+ emit(HangUpState.Init)
+ if (!callStatus.isCalling()) {
+ emit(HangUpState.Error(HangUpState.CODE_HANG_UP_STATE_ERROR, "[HangUp] - 当前通话状态不匹配"))
+ return@flow
+ }
+ if (!GMEApi.isRoomEntered()) {
+ emit(HangUpState.Error(HangUpState.CODE_HANG_UP_NOT_IN_ROOM, "[HangUp] - 当前用户尚未进入房间"))
+ return@flow
+ }
+ try {
+ val response = serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, sn, roomId, PUSH_MSG_HANG_UP, callType.type))
+ val code = response.code
+ if (code != 0 && code != 200) {
+ emit(HangUpState.Error(HangUpState.CODE_HANG_UP_API_ERROR, response.msg, mutableMapOf().also {
+ it["code"] = code.toString()
+ it["msg"] = response.msg
+ }))
+ return@flow
+ }
+ emit(HangUpState.Success)
+ exitRoom()
+ } catch (t: Throwable) {
+ emit(HangUpState.Error(HangUpState.CODE_HANG_UP_API_ERROR, "[HangUp] - ${t.message ?: "接口请求异常"}"))
+ }
+ }.catch {
+ emit(HangUpState.Error(HangUpState.CODE_UNKNOWN_ERROR, "[HangUp] - ${it.message ?: "未知错误"}"))
+ }
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun refuse(sn: String): Flow {
+ return flow {
+ emit(RefuseState.Init)
+ if (!callStatus.isReadyCalling()) {
+ emit(RefuseState.Error(RefuseState.CODE_REFUSE_STATE_ERROR, "[Refuse] - 当前不是来电状态或者呼出状态，不能执行拒绝操作"))
+ return@flow
+ }
+ try {
+ val response = serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, sn, 0, PUSH_MSG_DENY_ENTER, callType.type))
+ val code = response.code
+ if (code != 0 && code != 200) {
+ emit(RefuseState.Error(RefuseState.CODE_REFUSE_API_ERROR, response.msg, mutableMapOf().also {
+ it["code"] = code.toString()
+ it["msg"] = response.msg
+ }))
+ return@flow
+ }
+ emit(RefuseState.Success)
+ } catch (t: Throwable) {
+ emit(RefuseState.Error(RefuseState.CODE_REFUSE_API_ERROR, "[Refuse] - ${t.message ?: "接口请求异常"}"))
+ }
+ }.catch {
+ emit(RefuseState.Error(RefuseState.CODE_UNKNOWN_ERROR, "[Refuse] - ${it.message ?: "未知错误"}"))
+ }
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun inviteJoinVehicleTeam(sn: String): Flow {
+ return channelFlow {
+ send(InviteState.Init)
+ if (callStatus.isCalling() && GMEApi.isRoomEntered() && !callType.isTeam()) {
+ send(InviteState.Error(InviteState.CODE_INVITE_STATE_ERROR, "[InviteTeam] - 当前正在语音通话"))
+ return@channelFlow
+ }
+ val mySn = MoGoAiCloudClientConfig.getInstance().sn
+ if (TextUtils.isEmpty(mySn)){
+ send(InviteState.Error(InviteState.CODE_INVITE_SN_NOT_IN, "[InviteTeam] - 当前车机sn不存在"))
+ return@channelFlow
+ }
+ if (mySn == sn) {
+ send(InviteState.Error(InviteState.CODE_INVITE_TO_MYSELF, "[InviteTeam] - 不能邀请自己"))
+ return@channelFlow
+ }
+ val isOnline = try {
+ serverApi.isOnline(sn)
+ } catch (t: Throwable) {
+ false
+ }
+ if (!isOnline) {
+ send(InviteState.Error(InviteState.CODE_INVITEE_OFFLINE, "[InviteTeam] - 被邀请方不在线"))
+ return@channelFlow
+ }
+ if (mySelf.get() == null || mySelf.get().isIncomplete()) {
+ try {
+ val pair = serverApi.queryUserInfo(mySn)
+ if (pair == null || pair.first != null || pair.second == null) {
+ send(InviteState.Error(InviteState.CODE_INVITE_USR_REQ_ERROR, "[InviteTeam] - 当前车机请求用户信息失败: msg-> ${pair?.first}"))
+ return@channelFlow
+ }
+ mySelf.set(pair.second)
+ } catch (t: Throwable) {
+ send(InviteState.Error(InviteState.CODE_INVITE_USR_REQ_ERROR, "[InviteTeam] - ${t.message ?: "请求用户信息接口失败 - 未知异常"}"))
+ return@channelFlow
+ }
+ }
+ val response = serverApi.inviteJoinVehicleTeam(CallRequestParam().also {
+ val user = mySelf.get()
+ val location = BridgeApi.locationClient()?.lastKnowLocation
+ it.snSender = mySn
+ it.snReceiver = sn
+ it.nickName = user.name
+ it.headImgUrl = user.icon
+ it.carInfo = user.brand
+ it.lat = location?.latitude ?: 0.0
+ it.lon = location?.longitude ?: 0.0
+ })
+ val code = response.code
+ if (code != 0 && code != 200) {
+ send(InviteState.Error(InviteState.CODE_INVITE_API_ERROR, response.msg, mutableMapOf().also {
+ it["code"] = code.toString()
+ it["msg"] = response.msg
+ }))
+ return@channelFlow
+ }
+ if (GMEApi.isRoomEntered() && callStatus.isCalling()) {
+ send(InviteState.EnterRoomSuccess)
+ }
+ val teamMembers = AtomicReference>()
+ val d1 = mainScope.async {
+ while (!channel4SocketMsg.isClosedForReceive) {
+ val msg = channel4SocketMsg.receive()
+ when(msg.status) {
+ PUSH_MSG_AGREE_ENTER -> {
+ if (msg.type.toCallType().isTeam()) {
+ teamMembers.set(msg.teamMember ?: emptyList())
+ if (!GMEApi.isRoomEntered()) {
+ enterRoom()
+ }
+ }
+ }
+ PUSH_MSG_DENY_ENTER -> {
+ if (msg.type.toCallType().isTeam()) {
+ teamMembers.set(msg.teamMember ?: emptyList())
+ send(InviteState.Refused)
+ }
+ }
+ }
+ }
+ }
+ val d2 = mainScope.async {
+ val members = mutableListOf()
+ while (!channel4GmeState.isClosedForReceive) {
+ if (!callType.isTeam()) {
+ delay(SECONDS.toMillis(1))
+ continue
+ }
+ when(val state = channel4GmeState.receive()) {
+ is InitFail -> {
+ send(InviteState.Error(InviteState.CODE_GME_INIT_FAIL, "[InviteTeam] - GmeSdk初始化失败，Code: ${state.code}"))
+ return@async
+ }
+ is InitSuccess -> {
+ openId.set(state.openId)
+ continue
+ }
+ is EnterRoomFail -> {
+ send(InviteState.Error(InviteState.CODE_ENTER_ROOM_FAIL, "[InviteTeam] - 进入房间失败:code -> ${state.code} :: msg -> ${state.msg}"))
+ return@async
+ }
+ EnterRoomSuccess -> {
+ members += openId.get()
+ callStatus = CALLING_SENDER
+ send(InviteState.EnterRoomSuccess)
+ }
+ ExitRoomSuccess -> {
+ realExitRoom()
+ send(InviteState.ExitRoomSuccess)
+ return@async
+ }
+ is UserChangeInRoom -> {
+ log(ChatConsts.TAG, "openIds: ${state.left.joinToString(",")}")
+ if (!state.isEnter && state.left.isEmpty()) {
+ exitRoom()
+ continue
+ }
+ val newL = state.left
+ val subs = newL.subtract(members)
+ members.clear()
+ members += newL
+ val isMySelf = subs.isEmpty() || subs.contains(openId.get())
+ if (state.isEnter) {
+ send(InviteState.RoomMemberUpdate(isMySelf, true, teamMembers.get()))
+ } else {
+ send(InviteState.RoomMemberUpdate(isMySelf, false, teamMembers.get()))
+ }
+ }
+ }
+ }
+ }
+ val state = select {
+ d1.onAwait { 1 }
+ d2.onAwait { 2 }
+ }
+ when(state) {
+ 1 -> {
+ d2.safeCancel()
+ }
+ 2 -> {
+ d1.safeCancel()
+ }
+ }
+ }.catch {
+ emit(InviteState.Error(InviteState.CODE_UNKNOWN_ERROR, it.message ?: "未知错误"))
+ }
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ override fun joinVehicleTeam(sn: String): Flow {
+ return channelFlow {
+ send(JoinState.Init)
+ if (callStatus != READY_TO_CALL_RECEIVER) {
+ send(JoinState.Error(JoinState.CODE_INVITE_STATE_ERROR, "[JoinTeam]-当前车机不是来电状态: status -> ${callStatus.toText()}"))
+ return@channelFlow
+ }
+ val mySn = MoGoAiCloudClientConfig.getInstance().sn
+ if (TextUtils.isEmpty(mySn)){
+ send(JoinState.Error(JoinState.CODE_JOIN_SN_NOT_IN, "[JoinTeam] - 当前车机sn不存在"))
+ return@channelFlow
+ }
+ if (mySn == sn) {
+ send(JoinState.Error(JoinState.CODE_JOIN_TO_MYSELF, "[JoinTeam] - 不能自己加入自己"))
+ return@channelFlow
+ }
+ if (!client.isOpen) {
+ send(JoinState.Error(JoinState.CODE_INVITE_STATE_SOCKET_DISCONNECT, "[JoinTeam] - 当前车机长链接断开"))
+ return@channelFlow
+ }
+ if (mySelf.get() == null || mySelf.get().isIncomplete()) {
+ try {
+ val pair = serverApi.queryUserInfo(MoGoAiCloudClientConfig.getInstance().sn)
+ if (pair == null || pair.first != null || pair.second == null) {
+ send(JoinState.Error(JoinState.CODE_CALLER_USER_INFO_FAIL, "[JoinTeam] - 获取呼叫方用户信息失败"))
+ return@channelFlow
+ }
+ mySelf.set(pair.second)
+ } catch (t: Throwable) {
+ send(JoinState.Error(JoinState.CODE_CALLER_USER_INFO_FAIL, "[JoinTeam] - ${t.message ?: "获取呼叫方用户信息失败 - 未知异常"}"))
+ return@channelFlow
+ }
+
+ }
+ //告之服务器给发送方下发接收通话消息
+ try {
+ val location = BridgeApi.locationClient()?.lastKnowLocation
+ val response = serverApi.requestConnectStatus(ConnectStatusParam(MoGoAiCloudClientConfig.getInstance().sn, sn, roomId, PUSH_MSG_AGREE_ENTER, CALL_TYPE_VEHICLE_TEAM.type).also {
+ it.nickName = mySelf.get().name
+ it.headImgUrl = mySelf.get().icon
+ it.carInfo = mySelf.get().brand
+ it.cardIdAge = mySelf.get().age
+ it.cardIdSex = mySelf.get().sex
+ it.cityName = mySelf.get().city
+ it.lat = location?.latitude ?: 0.0
+ it.lon = location?.longitude ?: 0.0
+ })
+ if (response.code != 0 && response.code != 200) {
+ send(JoinState.Error(AnswerState.CODE_ANSWER_API_REQ_FAIL, "[JoinTeam] - ${response.msg}", mutableMapOf().also {
+ it["code"] = response.code.toString()
+ it["msg"] = response.msg
+ }))
+ return@channelFlow
+ }
+ } catch (t: Throwable) {
+ send(JoinState.Error(AnswerState.CODE_ANSWER_API_REQ_FAIL, "[JoinTeam] - ${t.message ?: "同步应答状态接口异常：$t"}"))
+ return@channelFlow
+ }
+ //成功
+ val teamMembers = AtomicReference>()
+ enterRoom()
+ client.startHeartBeat()
+ val d1 = mainScope.async {
+ while (!channel4SocketMsg.isClosedForReceive) {
+ val msg = channel4SocketMsg.receive()
+ if (!callType.isTeam()) {
+ delay(SECONDS.toMillis(1))
+ continue
+ }
+ when(msg.status) {
+ PUSH_MSG_HANG_UP -> {
+ log(ChatConsts.TAG, "[JoinTeam] - [hangUp] - msg -> $msg")
+ teamMembers.set(msg.teamMember ?: emptyList())
+ }
+ PUSH_MSG_AGREE_ENTER -> {
+ log(ChatConsts.TAG, "[JoinTeam] - [Agree] - msg -> $msg")
+ teamMembers.set(msg.teamMember ?: emptyList())
+ }
+ PUSH_MSG_DENY_ENTER -> {
+ log(ChatConsts.TAG, "[JoinTeam] - [Deny] - msg -> $msg")
+ teamMembers.set(msg.teamMember ?: emptyList())
+ }
+ }
+ }
+ }
+
+ val d2 = mainScope.async {
+ val members = mutableListOf()
+ while (!channel4GmeState.isClosedForReceive) {
+ if (!callType.isTeam()) {
+ delay(SECONDS.toMillis(1))
+ continue
+ }
+ when(val state = channel4GmeState.receive()) {
+ is InitFail -> {
+ send(JoinState.Error(JoinState.CODE_GME_INIT_FAIL, "[JoinTeam] - GmeSdk初始化失败"))
+ return@async
+ }
+ is InitSuccess -> {
+ openId.set(state.openId)
+ continue
+ }
+ is EnterRoomSuccess -> {
+ members += openId.get()
+ callStatus = CALLING_RECEIVER
+ realEnterRoom()
+ send(JoinState.EnterRoomSuccess)
+ }
+ is EnterRoomFail -> {
+ send(JoinState.Error(JoinState.CODE_ENTER_ROOM_FAIL, "[JoinTeam] - 进入房间失败：code: ${state.code} - msg: ${state.msg}"))
+ return@async
+ }
+ ExitRoomSuccess -> {
+ realExitRoom()
+ send(JoinState.ExitRoomSuccess)
+ return@async
+ }
+ is UserChangeInRoom -> {
+ log(ChatConsts.TAG, "openIds: ${state.left.joinToString(",")}")
+ if (!state.isEnter && state.left.isEmpty()) {
+ exitRoom()
+ continue
+ }
+ val newL = state.left
+ val subs = newL.subtract(members)
+ members.clear()
+ members += newL
+ val isMySelf = subs.isEmpty() || subs.contains(openId.get())
+ if (state.isEnter) {
+ send(JoinState.RoomMemberUpdate(isMySelf, true, teamMembers.get()))
+ } else {
+ send(JoinState.RoomMemberUpdate(isMySelf, false, teamMembers.get()))
+ }
+ }
+ }
+ }
+ }
+ val state = select {
+ d1.onAwait { 1 }
+ d2.onAwait { 2 }
+ }
+ when(state) {
+ 1 -> {
+ d2.safeCancel()
+ }
+ 2 -> {
+ d1.safeCancel()
+ }
+ }
+ }.catch {
+ emit(JoinState.Error(JoinState.CODE_UNKNOWN_ERROR, it.message ?: "未知错误"))
+ }
+ }
+
+ @ExperimentalCoroutinesApi
+ private fun resetState() {
+ callStatus = INIT_CALL
+ callType = CALL_TYPE_DEFAULT
+ try {
+ client.stopHeartBeat()
+ } catch (t: Throwable) {
+ log(ChatConsts.TAG, "$t")
+ }
+ channel4GmeState.safeCancel()
+ channel4SocketMsg.safeCancel()
+ sender.set(null)
+ receiver.set(null)
+ roomId = 0
+ }
+
+ override fun muteVoice(mute: Boolean) {
+ GMEApi.muteVoice(mute)
+ }
+
+ override fun audioFocus(): IMoGoAudioFocusFacade = AudioFocusFacade
+
+ override fun voice(): IMoGoVoiceControlFacade = VoiceControlFacade
+
+ override fun media(): IMoGoMediaFacade = MedialControlFacade
+
+ override fun analytics(): IMoGoAnalyticsFacade = ChatAnalyticsFacade
+
+ fun onDestroy() {
+ if (!hasInit.get()) {
+ return
+ }
+ hasInit.set(false)
+ voice().unRegister()
+ GMEApi.unInit()
+ mainScope.safeCancel()
+ SocketConnectManager.destroy()
+ }
+}
+
+private fun Int.toCallType(): IMCallType {
+ return when(this) {
+ 0 -> CALL_TYPE_VOICE
+ 3 -> CALL_TYPE_VEHICLE_TEAM
+ else -> CALL_TYPE_DEFAULT
+ }
+}
+
+private fun Message.toUser(): UserInfo = UserInfo().also {
+ it.sn = this.snSender
+ it.name = this.nickName
+ it.icon = this.headImgUrl
+ it.age = this.cardIdAge
+ it.brand = this.carInfo
+ it.city = this.cityName
+ it.sex = this.cardIdSex
+ it.lat = this.lat
+ it.lon = this.lon
+}
+
+typealias OnInComingCallback = (isTeam: Boolean, user: UserInfo) -> Unit
+
+typealias OnCallingInterrupt = (isTeam: Boolean, user: UserInfo) -> Unit
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/analytics/ChatAnalyticsEvents.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/analytics/ChatAnalyticsEvents.kt
new file mode 100644
index 0000000000..7a02105507
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/analytics/ChatAnalyticsEvents.kt
@@ -0,0 +1,17 @@
+package com.mogo.eagle.core.function.chat.facade.analytics
+
+
+object ChatAnalyticsEvents {
+
+ const val INVOKE_TRACK_REQUEST_CALL_SHOW = "carchat_requestcall_card_show"
+ const val INVOKE_TRACK_REQUEST_CALL = "carchat_cardetail_click"
+ const val INVOKE_TRACK_REFUSE = "carchat_refuse_card_show"
+ const val INVOKE_TRACK_CHATTING = "carchat_phoneing_card_show"
+ const val INVOKE_TRACK_MATCH_SHOW = "carchat_carphonecall_match_show"
+ const val INVOKE_TRACK_MATCH_FAIL_CLOSE_CLICK = "carchat_match_fail_close_click"
+
+ const val MATCH_TYPE_MANUAL = 1
+ const val MATCH_TYPE_VOICE = 2
+
+}
+
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/analytics/ChatAnalyticsFacade.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/analytics/ChatAnalyticsFacade.kt
new file mode 100644
index 0000000000..33aae26880
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/analytics/ChatAnalyticsFacade.kt
@@ -0,0 +1,11 @@
+package com.mogo.eagle.core.function.chat.facade.analytics
+
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoAnalyticsFacade
+import com.mogo.eagle.core.function.chat.facade.bridge.BridgeApi
+
+object ChatAnalyticsFacade: IMoGoAnalyticsFacade {
+
+ override fun track(eventType: String, data: Map?) {
+ BridgeApi.analytics()?.track(eventType, data)
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/BaseAspectj.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/BaseAspectj.kt
new file mode 100644
index 0000000000..032eefd2eb
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/BaseAspectj.kt
@@ -0,0 +1,73 @@
+package com.mogo.eagle.core.function.chat.facade.aop
+
+import android.os.Looper
+import android.util.Log
+import com.mogo.commons.debug.DebugConfig
+import org.aspectj.lang.ProceedingJoinPoint
+import org.aspectj.lang.reflect.CodeSignature
+import org.aspectj.lang.reflect.MethodSignature
+
+open class BaseAspectj {
+
+ companion object {
+ @Volatile
+ private var enable: Boolean = DebugConfig.isDebug()
+ }
+
+ fun enterMethod(joinPoint: ProceedingJoinPoint) {
+ if (!enable) return
+
+ val signature = joinPoint.signature as CodeSignature
+ val cls = signature.declaringType
+ val methodName = signature.name
+ val parameterNames = signature.parameterNames
+ val parameterValues = joinPoint.args
+
+ val builder = StringBuilder("\u21E2 ")
+ builder.append(methodName).append('(')
+ parameterValues.forEachIndexed { index, _ ->
+ if (index > 0) {
+ builder.append(",")
+ }
+ builder.append(parameterNames[index]).append('=')
+ builder.append(parameterValues[index])
+ }
+ builder.append(')')
+
+ if (Looper.myLooper() != Looper.getMainLooper()) {
+ builder.append("[Thread:\"").append(Thread.currentThread().name).append("\"]")
+ }
+ Log.i(asTag(cls), builder.toString())
+ }
+
+ fun exitMethod(joinPoint: ProceedingJoinPoint, result: Any?, lengthMill: Long) {
+ if (!enable) return
+
+ val signature = joinPoint.signature
+ val cls = signature.declaringType
+ val methodName = signature.name
+ val hasReturnType = signature is MethodSignature
+ && signature.returnType != Void.TYPE
+
+ val builder = StringBuilder("\u21E0 ")
+ .append(methodName)
+ .append("[")
+ .append(lengthMill)
+ .append("ms]")
+
+ if (hasReturnType) {
+ builder.append(" = ")
+ builder.append(result.let {
+ result.toString()
+ })
+ }
+ Log.i(asTag(cls), builder.toString())
+ }
+
+ private fun asTag(cls: Class<*>): String {
+ if (cls.isAnonymousClass) {
+ return asTag(cls.enclosingClass!!)
+ }
+ return cls.simpleName
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/DebugLog.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/DebugLog.kt
new file mode 100644
index 0000000000..85dbbbb6d7
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/DebugLog.kt
@@ -0,0 +1,5 @@
+package com.mogo.eagle.core.function.chat.facade.aop
+
+@Target(AnnotationTarget.ANNOTATION_CLASS, AnnotationTarget.CLASS, AnnotationTarget.FUNCTION, AnnotationTarget.PROPERTY_GETTER, AnnotationTarget.PROPERTY_SETTER, AnnotationTarget.CONSTRUCTOR)
+@kotlin.annotation.Retention(AnnotationRetention.RUNTIME)
+annotation class DebugLog
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/LogAspectj.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/LogAspectj.kt
new file mode 100644
index 0000000000..6b75cc9d7a
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/aop/LogAspectj.kt
@@ -0,0 +1,42 @@
+package com.mogo.eagle.core.function.chat.facade.aop
+
+import org.aspectj.lang.ProceedingJoinPoint
+import org.aspectj.lang.annotation.Around
+import org.aspectj.lang.annotation.Aspect
+import org.aspectj.lang.annotation.Pointcut
+import java.util.concurrent.TimeUnit
+
+@Aspect
+class LogAspectj : BaseAspectj() {
+
+
+ @Pointcut("within(@com.mogo.eagle.core.function.chat.facade.aop.DebugLog *)")
+ fun withinAnnotatedClass() {
+ }
+
+ @Pointcut("execution(!synthetic * *(..))&& withinAnnotatedClass()")
+ fun methodInsideAnnotatedType() {
+ }
+
+ @Pointcut("execution(!synthetic *.new(..))&& withinAnnotatedClass()")
+ fun constructorInsideAnnotatedType() {
+ }
+
+ @Pointcut("execution(@com.mogo.eagle.core.function.chat.facade.aop.DebugLog * *(..))|| methodInsideAnnotatedType()")
+ fun method() {
+ }
+
+ @Pointcut("execution(@com.mogo.eagle.core.function.chat.facade.aop.DebugLog *.new(..))|| constructorInsideAnnotatedType()")
+ fun constructor() {
+ }
+
+ @Around("method() || constructor()")
+ fun logExecute(joinPoint: ProceedingJoinPoint) {
+ enterMethod(joinPoint)
+ val startNanos = System.nanoTime()
+ val result = joinPoint.proceed()
+ val stopNanos = System.nanoTime()
+ val lengthMill = TimeUnit.NANOSECONDS.toMillis(stopNanos - startNanos)
+ exitMethod(joinPoint, result, lengthMill)
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/audio/AudioFocusFacade.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/audio/AudioFocusFacade.kt
new file mode 100644
index 0000000000..68e8cb5573
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/audio/AudioFocusFacade.kt
@@ -0,0 +1,115 @@
+package com.mogo.eagle.core.function.chat.facade.audio
+
+import android.content.Context
+import android.media.AudioAttributes
+import android.media.AudioFocusRequest
+import android.media.AudioManager
+import android.media.AudioManager.OnAudioFocusChangeListener
+import android.os.Build
+import android.os.Handler
+import android.os.Looper
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoAudioFocusFacade
+import com.mogo.eagle.core.function.chat.facade.bridge.BridgeApi
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import kotlinx.coroutines.*
+import kotlinx.coroutines.android.asCoroutineDispatcher
+import java.util.concurrent.TimeUnit.SECONDS
+import java.util.concurrent.atomic.AtomicReference
+
+object AudioFocusFacade: IMoGoAudioFocusFacade {
+
+
+ private val audioListener: MyAudioFocusChangeListener by lazy {
+ MyAudioFocusChangeListener()
+ }
+
+ private val audioManager: AudioManager by lazy {
+ BridgeApi.context().getSystemService(Context.AUDIO_SERVICE) as AudioManager
+ }
+
+ private var audioFocusRequest: Any? = null
+
+ private val scope by lazy {
+ CoroutineScope(Handler(Looper.getMainLooper()).asCoroutineDispatcher() + SupervisorJob())
+ }
+
+ private val focusJob by lazy { AtomicReference() }
+
+ @Volatile
+ private var hasAudioFocus = false
+
+ override fun requireAudioFocus(onGetFocus: () -> Unit) {
+ log(ChatConsts.TAG, "requireDuck===$hasAudioFocus")
+ scope.launch {
+ if (!hasAudioFocus) {
+ while (true) {
+ try {
+ val res = audioManager.let {
+ if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) {
+ it.requestAudioFocus(audioListener, AudioManager.STREAM_MUSIC, AudioManager.AUDIOFOCUS_GAIN_TRANSIENT)
+ } else {
+ val audioFocusRequest =
+ AudioFocusRequest.Builder(AudioManager.AUDIOFOCUS_GAIN_TRANSIENT)
+ .setAcceptsDelayedFocusGain(true)
+ .setAudioAttributes(
+ AudioAttributes.Builder()
+ .setContentType(AudioAttributes.CONTENT_TYPE_MUSIC)
+ .build())
+ .setOnAudioFocusChangeListener(audioListener).build()
+ this@AudioFocusFacade.audioFocusRequest = audioFocusRequest
+ it.requestAudioFocus(audioFocusRequest)
+ }
+ }
+ if (res == AudioManager.AUDIOFOCUS_REQUEST_GRANTED) {
+ hasAudioFocus = true
+ onGetFocus.invoke()
+ break
+ }
+ } catch (e: Exception) {
+ e.printStackTrace()
+ } finally {
+ delay(SECONDS.toMillis(1))
+ }
+ }
+ } else {
+ onGetFocus.invoke()
+ }
+ }.also { focusJob.set(it) }
+ }
+
+ override fun releaseAudioFocus() {
+ log(ChatConsts.TAG, "releaseDuck===$hasAudioFocus")
+ focusJob.get()?.takeIf { it.isActive }?.cancel()
+ scope.launch {
+ if (hasAudioFocus) {
+ hasAudioFocus = false
+ try {
+ if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) {
+ audioManager.abandonAudioFocus(audioListener)
+ } else {
+ (audioFocusRequest as? AudioFocusRequest)?.also {
+ audioManager.abandonAudioFocusRequest(it)
+ }
+ }
+ } catch (e: Exception) {
+ e.printStackTrace()
+ }
+ }
+ }
+ }
+
+ private class MyAudioFocusChangeListener : OnAudioFocusChangeListener {
+ override fun onAudioFocusChange(focusChange: Int) {
+ log(ChatConsts.TAG, "onAudioFocusChange: $focusChange")
+ when (focusChange) {
+ AudioManager.AUDIOFOCUS_GAIN -> {
+ hasAudioFocus = true
+ }
+ AudioManager.AUDIOFOCUS_LOSS,
+ AudioManager.AUDIOFOCUS_LOSS_TRANSIENT,
+ AudioManager.AUDIOFOCUS_LOSS_TRANSIENT_CAN_DUCK -> hasAudioFocus = false
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/bridge/BridgeApi.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/bridge/BridgeApi.kt
new file mode 100644
index 0000000000..14e2a87d78
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/bridge/BridgeApi.kt
@@ -0,0 +1,35 @@
+package com.mogo.eagle.core.function.chat.facade.bridge
+
+import android.content.Context
+import com.mogo.eagle.core.utilcode.util.Utils
+import com.mogo.module.common.MogoApisHandler
+import java.lang.ref.WeakReference
+
+internal object BridgeApi {
+
+ private var contextHolder: WeakReference? = null
+
+ private val apis by lazy {
+ MogoApisHandler.getInstance().apis
+ }
+
+ internal fun init(context: Context?) {
+ context?.let {
+ contextHolder = WeakReference(context)
+ }
+ }
+
+ internal fun context(): Context = contextHolder?.get() ?: Utils.getApp()
+
+ internal fun locationClient() = apis?.mapServiceApi?.getSingletonLocationClient(context())
+
+ internal fun intentManager() = apis?.intentManagerApi
+
+ internal fun statusManager() = apis?.statusManagerApi
+
+ internal fun analytics() = apis?.analyticsApi
+
+ internal fun topViewManager() = apis?.topViewManager
+
+ internal fun floatViewManager() = apis?.windowManagerApi
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/consts/Consts.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/consts/Consts.kt
new file mode 100644
index 0000000000..aa3480e8fa
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/consts/Consts.kt
@@ -0,0 +1,79 @@
+package com.mogo.eagle.core.function.chat.facade.consts
+
+import com.mogo.commons.debug.DebugConfig
+
+//WebSocket发送数据相关
+const val SOCKET_HAND_SHAKE = 0
+const val SOCKET_HEART_BEAT = 1
+
+// 与相关接口复用
+/**
+ * 服务端下发消息状态为0存在三种场景：
+ * 1.语音聊天创建房间成功，给拨打方发送创建房间消息。
+ * 2.有匹配过的车机，表示愿意聊天，如果有人匹配不到，会给有愿意聊天的用户发来打电话邀请
+ * 3.接收车队邀请消息
+ */
+const val PUSH_MSG_CREATE_ROOM = 0
+
+/**
+ * 服务端下发消息状态为1存在三种场景：
+ * 1.语音聊天对方同意，下发同意消息
+ * 2.匹配成功消息
+ * 3.车队邀请对方同意，下发同意消息
+ */
+const val PUSH_MSG_AGREE_ENTER = 1
+
+/**
+ * 服务端下发消息状态为2存在三种场景：
+ * 1.语音邀请被拒绝
+ * 2.被动匹配接收到来电邀请，被拒绝
+ * 3.车队邀请被拒绝
+ */
+const val PUSH_MSG_DENY_ENTER = 2
+
+/**
+ * 服务端下发消息状态为3存在两种场景：
+ * 1.语音和匹配接收到消息下发，挂断电话
+ * 2.车队接收到消息下发，如果消息中有队员，则接收到队员退房消息，若无队员，则挂断车队电话
+ */
+const val PUSH_MSG_HANG_UP = 3
+
+
+class ChatHttp {
+
+ companion object {
+
+ private const val DEV_BASE_URL_OWNER = "http://dzt-show.zhidaohulian.com/"
+ private const val DEV_CONFIG_URL = "http://dzt-test.zhidaohulian.com/"
+ private const val RELEASE_BASE_URL_OWNER = "http://dzt.zhidaohulian.com/"
+
+ private const val SOCKET_SERVER = "ws://62.234.196.121:4001/ws"
+ private const val DEV_SOCKET_SERVER = "ws://dzt-test.zhidaohulian.com/ws"
+
+ fun getBaseUrl(): String {
+ return when (DebugConfig.getNetMode()) {
+ DebugConfig.NET_MODE_DEV, DebugConfig.NET_MODE_QA, DebugConfig.NET_MODE_DEMO -> DEV_BASE_URL_OWNER
+ DebugConfig.NET_MODE_RELEASE -> RELEASE_BASE_URL_OWNER
+ else -> RELEASE_BASE_URL_OWNER
+ }
+ }
+
+ fun getSocketServer(): String {
+ return when (DebugConfig.getNetMode()) {
+ DebugConfig.NET_MODE_DEV, DebugConfig.NET_MODE_QA, DebugConfig.NET_MODE_DEMO -> DEV_SOCKET_SERVER
+ DebugConfig.NET_MODE_RELEASE -> SOCKET_SERVER
+ else -> SOCKET_SERVER
+ }
+ }
+
+ fun getConfig(): String {
+ return when (DebugConfig.getNetMode()) {
+ DebugConfig.NET_MODE_DEV, DebugConfig.NET_MODE_QA, DebugConfig.NET_MODE_DEMO -> DEV_CONFIG_URL
+ DebugConfig.NET_MODE_RELEASE -> RELEASE_BASE_URL_OWNER
+ else -> RELEASE_BASE_URL_OWNER
+ }
+ }
+ }
+}
+
+
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/gme/Gme.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/gme/Gme.kt
new file mode 100644
index 0000000000..bac856ea26
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/gme/Gme.kt
@@ -0,0 +1,236 @@
+package com.mogo.eagle.core.function.chat.facade.gme
+
+import android.content.Context
+import android.content.Intent
+import android.os.Handler
+import android.text.TextUtils
+import android.util.Log
+import com.gme.TMG.ITMGContext
+import com.gme.av.sdk.AVError
+import com.gme.av.sig.AuthBuffer
+import com.mogo.commons.debug.DebugConfig
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import com.mogo.eagle.core.utilcode.util.BuildConfig
+import com.mogo.eagle.core.utilcode.util.Utils
+import java.lang.ref.WeakReference
+import java.util.concurrent.atomic.AtomicBoolean
+
+internal object GMEApi {
+
+ //GME相关信息
+ private const val ROOM_TYPE = 1
+ private const val SDKID = "1400280276"
+ private const val SDKKEY = "I0USylN9YQq0CAiq"
+
+ private var openId: String? = null
+
+ private val hasInit by lazy {
+ AtomicBoolean(false)
+ }
+
+ private val Intent.result: Int
+ get() = getIntExtra("result" , -1)
+
+ private val Intent.errorInfo: String
+ get() = getStringExtra("error_info") ?: ""
+
+ private val Intent.eventId: Int
+ get() = getIntExtra("event_id", 0)
+
+ private val Intent.users: Array
+ get() = getStringArrayExtra("user_list") ?: emptyArray()
+
+ private var cb: ((state: GmeState) -> Unit)? = null
+
+ private var ctx: WeakReference? = null
+
+ private val tmgCtx by lazy {
+ ITMGContext.GetInstance(ctx?.get()?: Utils.getApp())
+ }
+
+ private val delegate = object : ITMGContext.ITMGDelegate() {
+
+ override fun OnEvent(type: ITMGContext.ITMG_MAIN_EVENT_TYPE?, data: Intent?) {
+ super.OnEvent(type, data)
+ type ?: return
+ data ?: return
+ if (type == ITMGContext.ITMG_MAIN_EVENT_TYPE.ITMG_MAIN_EVENT_TYPE_ENTER_ROOM) {
+ val code = data.result
+ if (code == AVError.AV_OK) {
+ cb?.invoke(GmeState.EnterRoomSuccess)
+ } else {
+ cb?.invoke(GmeState.EnterRoomFail(code, data.errorInfo))
+ }
+ }
+ if (type == ITMGContext.ITMG_MAIN_EVENT_TYPE.ITMG_MAIN_EVENT_TYPE_EXIT_ROOM) {
+ cb?.invoke(GmeState.ExitRoomSuccess)
+ }
+ if (type == ITMGContext.ITMG_MAIN_EVENT_TYPE.ITMG_MAIN_EVNET_TYPE_USER_UPDATE) {
+ val eventId = data.eventId
+ val users = data.users
+ log(ChatConsts.TAG, "RoomMembersUpdate: ${users.joinToString(",")}")
+ if (users.isEmpty()) {
+ log(ChatConsts.TAG, "没人了，准备退房")
+ cb?.invoke(GmeState.UserChangeInRoom(isEnter = false, emptyArray()))
+ return
+ }
+ val filtered = users.filter {
+ log(ChatConsts.TAG, "成员进房====$it===ownId:$openId")
+ it.toInt() > 99999
+ }.toTypedArray()
+ if (filtered.isEmpty()) {
+ log(ChatConsts.TAG, "成员为空，无操作")
+ return
+ }
+ if (eventId == ITMGContext.ITMG_EVENT_ID_USER_ENTER) {
+ log(ChatConsts.TAG, "成员进房==去掉99999====$filtered")
+ cb?.invoke(GmeState.UserChangeInRoom(isEnter = true, filtered))
+ }
+ if (eventId == ITMGContext.ITMG_EVENT_ID_USER_EXIT) {
+ cb?.invoke(GmeState.UserChangeInRoom(isEnter = false, filtered))
+ }
+ }
+ }
+ }
+
+ fun enableAudio() {
+ Log.d(ChatConsts.TAG, "-- enable audio --- 1 ---")
+ if (!hasInit.get()) {
+ return
+ }
+ Log.d(ChatConsts.TAG, "-- enable audio --- 2 ---")
+ val audioCtrl = tmgCtx.GetAudioCtrl()
+ //开启麦克
+ audioCtrl?.EnableMic(true)
+ //开启扬声器
+ audioCtrl?.EnableSpeaker(true)
+ //设置扬声器音量
+ audioCtrl?.SetSpeakerVolume(200)
+ //解除麦克风静音
+ audioCtrl?.SetMicVolume(100)
+ }
+
+ fun disableAudio() {
+ Log.d(ChatConsts.TAG, "-- disable audio --- 1 ---")
+ if (!hasInit.get()) {
+ return
+ }
+ Log.d(ChatConsts.TAG, "-- disable audio --- 2 ---")
+ val audioCtrl = tmgCtx.GetAudioCtrl()
+ audioCtrl?.EnableSpeaker(false)
+ //开启麦克
+ audioCtrl?.EnableMic(false)
+ }
+
+ fun init(ctx: Context, openId: String, cb: ((s: GmeState) -> Unit)? = null) {
+ if (hasInit.get()) {
+ log(ChatConsts.TAG, "Error: GmeApi has initialized.")
+ return
+ }
+ hasInit.set(true)
+ try {
+ this.ctx = WeakReference(ctx)
+ this.cb = cb
+ tmgCtx.SetTMGDelegate(delegate)
+
+ tmgCtx.SetLogLevel(ITMGContext.ITMG_LOG_LEVEL_INFO, ITMGContext.ITMG_LOG_LEVEL_VERBOSE)
+
+
+ this.openId = openId
+ val ret = tmgCtx.Init(SDKID, openId)
+ if (ret == AVError.AV_OK) {
+ GmePoller.start()
+ cb?.invoke(GmeState.InitSuccess(openId))
+ } else {
+ cb?.invoke(GmeState.InitFail(ret))
+ }
+ } catch (t: Throwable) {
+ log(ChatConsts.TAG, "GMEAPI - error: $t")
+ }
+ }
+
+ fun enterRoom(roomId: String) {
+ if (tmgCtx.IsRoomEntered()) {
+ return
+ }
+ tmgCtx.EnterRoom(roomId, ROOM_TYPE, createAuthBuffer(roomId))
+ }
+
+ fun exitRoom() {
+ if (!tmgCtx.IsRoomEntered()) {
+ return
+ }
+ tmgCtx.ExitRoom()
+ }
+
+ fun isRoomEntered() = tmgCtx.IsRoomEntered()
+
+ fun unInit() {
+ if (!hasInit.get()) {
+ return
+ }
+ hasInit.set(false)
+ cb = null
+ tmgCtx.SetTMGDelegate(null)
+ GmePoller.stop()
+ tmgCtx.Uninit()
+ }
+
+ private fun createAuthBuffer(roomId: String?): ByteArray? {
+ return if (TextUtils.isEmpty(roomId)) {
+ AuthBuffer.getInstance().genAuthBuffer(SDKID.toInt(), "0", openId, SDKKEY)
+ } else {
+ AuthBuffer.getInstance().genAuthBuffer(SDKID.toInt(), roomId, openId, SDKKEY)
+ }
+ }
+
+ fun muteVoice(mute: Boolean) {
+ if (!isRoomEntered()) {
+ return
+ }
+ if (mute) {
+ tmgCtx.GetAudioCtrl()?.SetMicVolume(0)
+ } else {
+ tmgCtx.GetAudioCtrl()?.SetMicVolume(100)
+ }
+ }
+}
+
+sealed class GmeState {
+
+ class InitSuccess(val openId: String): GmeState()
+
+ class InitFail(val code: Int): GmeState()
+
+ object EnterRoomSuccess: GmeState()
+
+ class EnterRoomFail(val code: Int, val msg: String): GmeState()
+
+ class UserChangeInRoom(val isEnter: Boolean, val left: Array): GmeState()
+
+ object ExitRoomSuccess: GmeState()
+}
+
+
+internal object GmePoller {
+
+ private val handler by lazy { Handler() }
+
+ private val poll: Runnable = object : Runnable {
+ override fun run() {
+ if (ITMGContext.GetInstance(null) != null) {
+ ITMGContext.GetInstance(null).Poll()
+ }
+ handler.postDelayed(this, 30)
+ }
+ }
+
+ internal fun start() {
+ handler.postDelayed(poll, 30)
+ }
+
+ internal fun stop() {
+ handler.removeCallbacks(poll)
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/media/MedialControlFacade.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/media/MedialControlFacade.kt
new file mode 100644
index 0000000000..0d09802484
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/media/MedialControlFacade.kt
@@ -0,0 +1,61 @@
+package com.mogo.eagle.core.function.chat.facade.media
+
+import android.content.Context
+import android.media.AudioAttributes
+import android.media.MediaPlayer
+import android.os.Build
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoMediaFacade
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import java.lang.ref.WeakReference
+import java.util.concurrent.atomic.AtomicReference
+
+internal object MedialControlFacade : IMoGoMediaFacade {
+
+ private val player by lazy {
+ AtomicReference>()
+ }
+
+ override fun play(context: Context, audioSources: Int, isLoop: Boolean, channel: Int) {
+ val player = player.get()?.get() ?: MediaPlayer().also { player.set(WeakReference(it)) }
+ resetStatus(player)
+ val file = context.resources.openRawResourceFd(audioSources)
+ player.apply {
+ if (Build.VERSION.SDK_INT < Build.VERSION_CODES.O) {
+ setAudioStreamType(channel)
+ } else {
+ setAudioAttributes(AudioAttributes.Builder().setLegacyStreamType(channel).build())
+ }
+ setDataSource(file.fileDescriptor, file.startOffset, file.length)
+ file.close()
+ isLooping = isLoop
+ prepareAsync()
+ setOnPreparedListener { player ->
+ log(ChatConsts.TAG,"real play 准备播放音频====")
+ player.start()
+ }
+ setOnCompletionListener { player ->
+ log(ChatConsts.TAG,"播放完成====")
+ player.reset()
+ }
+ }
+ }
+
+ override fun release() {
+ val player = this.player.get()?.get() ?: return
+ log(ChatConsts.TAG,"release 释放音频播放====")
+ player.run {
+ resetStatus(this)
+ release()
+ }
+ }
+
+ private fun resetStatus(player: MediaPlayer) {
+ player.run {
+ if (isPlaying) {
+ stop()
+ }
+ reset()
+ }
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/ChatServiceModel.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/ChatServiceModel.kt
new file mode 100644
index 0000000000..e1ffcaef0e
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/ChatServiceModel.kt
@@ -0,0 +1,156 @@
+package com.mogo.eagle.core.function.chat.facade.net
+
+import com.alibaba.android.arouter.launcher.ARouter
+import com.google.gson.Gson
+import com.google.gson.JsonElement
+import com.google.gson.JsonObject
+import com.mogo.cloud.passport.MoGoAiCloudClientConfig
+import com.mogo.eagle.core.data.BaseResponse
+import com.mogo.eagle.core.data.chat.UserInfo
+import com.mogo.eagle.core.data.constants.MogoServicePaths
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.api.chat.biz.IMCallType.CALL_TYPE_VOICE
+import com.mogo.eagle.core.function.chat.facade.bridge.BridgeApi
+import com.mogo.eagle.core.function.chat.facade.consts.ChatHttp
+import com.mogo.eagle.core.function.chat.facade.consts.ChatHttp.Companion.getConfig
+import com.mogo.eagle.core.function.chat.facade.net.bean.*
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import com.mogo.service.IMogoServiceApis
+import retrofit2.http.*
+import java.lang.IllegalStateException
+
+
+internal class ChatServiceModel {
+
+ suspend fun isOnline(sn: String): Boolean {
+ val map = hashMapOf()
+ map["sn"] = sn
+ return apiCall {
+ getNetWorkApi()?.isOnLine(map) ?: throw IllegalStateException("apis is null.")
+ }.takeIf { it.code == 0 || it.code == 200 }?.let {
+ val result = it.result
+ return@let result.carOnLine == 1 && result.onLine == 1
+ } ?: false
+ }
+
+ suspend fun queryUserInfo(sn: String): Pair? {
+ val sns = arrayListOf(sn)
+ val requestData = SnArrayRequestBody().also { it.sns = sns }
+ return apiCall {
+ getNetWorkApi(getConfig())?.queryUserInfoBySnS(requestData) ?: throw IllegalStateException("apis is null.")
+ }.let { itx ->
+ if (itx.code != 0 && itx.code != 200) {
+ return@let Pair(Error(itx.code, itx.msg), null)
+ }
+ val result = UserInfo()
+ val json = itx.result
+ val array = json.getAsJsonArray("info")
+ if (array == null || array.size() == 0) {
+ return Pair(null, null)
+ }
+ val first = array[0] as? JsonObject ?: return@let null
+ val userInfo = first.getAsJsonObject("carAndUserInfoRedisVo")
+ val location = first.getAsJsonObject("realTimeLocationVo")
+ if (userInfo == null) {
+ return@let Pair(null, null)
+ }
+ result.sn = userInfo.get("sn")?.takeIf { !it.isJsonNull }?.asString ?: sn
+ result.name = userInfo.get("userNickName")?.takeIf { !it.isJsonNull }?.asString ?: "小蘑菇"
+ result.icon = userInfo.get("headImgUrl")?.takeIf { !it.isJsonNull }?.asString
+ result.sex = userInfo.get("cardIdSex")?.takeIf { !it.isJsonNull }?.asString ?: "未设置"
+ result.age = userInfo.get("cardIdAge")?.takeIf { !it.isJsonNull }?.asString
+ result.brand = userInfo.get("lastBrandName")?.takeIf { !it.isJsonNull }?.asString
+ result.city = userInfo.get("lastActiveCity")?.takeIf { !it.isJsonNull }?.asString
+ if (location != null) {
+ result.lat = location.get("lat")?.takeIf { !it.isJsonNull }?.asDouble ?: 0.0
+ result.lon = location.get("lon")?.takeIf { !it.isJsonNull }?.asDouble ?: 0.0
+ }
+ return@let Pair(null, result)
+ }
+ }
+
+ suspend fun requestConnectStatus(params: ConnectStatusParam): BaseResponse {
+ val map = hashMapOf()
+ val sn = MoGoAiCloudClientConfig.getInstance().sn
+ val location = BridgeApi.locationClient()?.lastKnowLocation
+ if (location != null) {
+ params.lon = location.longitude
+ params.lat = location.latitude
+ }
+ log(ChatConsts.TAG, "connectStatusParam:$params")
+ map["sn"] = MoGoAiCloudClientConfig.getInstance().sn
+ map["data"] = Gson().toJson(params)
+ return if (params.type == CALL_TYPE_VOICE.type) {
+ apiCall {
+ getNetWorkApi()?.requestConnectStatus(sn, map) ?: throw IllegalStateException("apis is null.")
+ }
+ } else {
+ apiCall {
+ getNetWorkApi()?.requestVehicleTeamConnectStatus(map) ?: throw IllegalStateException("apis is null.")
+ }
+ }
+ }
+
+ suspend fun inviteJoinVehicleTeam(param: CallRequestParam): BaseResponse {
+ val map = hashMapOf()
+ log(ChatConsts.TAG, "inviteJoinVehicleTeam paras: $param")
+ map["sn"] = MoGoAiCloudClientConfig.getInstance().sn
+ map["data"] = Gson().toJson(param)
+ return apiCall {
+ getNetWorkApi()?.inviteJoinVehicleTeam(map) ?: throw IllegalStateException("apis is null.")
+ }
+ }
+
+ suspend fun requestRoomInfo(param: CallRequestParam): BaseResponse {
+ val map = hashMapOf()
+ val location = BridgeApi.locationClient()?.lastKnowLocation
+ if (location != null) {
+ param.lat = location.latitude
+ param.lon = location.longitude
+ }
+ log(ChatConsts.TAG, "roomParam:$param")
+ map["data"] = Gson().toJson(param)
+ return apiCall {
+ getNetWorkApi()?.requestRoomInfo(map) ?: throw IllegalStateException("apis is null.")
+ }
+ }
+
+ private suspend fun apiCall(call: suspend () -> BaseResponse): BaseResponse {
+ return call.invoke()
+ }
+
+ private fun getNetWorkApi(baseUrl: String = ChatHttp.getBaseUrl()): HttpApi? {
+ val serviceApi: IMogoServiceApis? = ARouter.getInstance().build(MogoServicePaths.PATH_SERVICE_APIS).navigation() as? IMogoServiceApis
+ return serviceApi?.networkApi?.createNoCallAdapter(HttpApi::class.java, baseUrl)
+ }
+}
+
+internal interface HttpApi {
+
+ @FormUrlEncoded
+ @POST("/yycp-chat-service/car/voiceRoom/no/operate/v1")
+ suspend fun requestConnectStatus(@Query("sn") sn: String, @FieldMap connectStatus: Map): BaseResponse
+
+ //邀请加入车队
+ @FormUrlEncoded
+ @POST("/yycp-chat-service/car/chat/no/inviteJoinTeam/v1")
+ suspend fun inviteJoinVehicleTeam(@FieldMap inviteVehicleTeam: Map): BaseResponse
+
+ //车队状态同步
+ @FormUrlEncoded
+ @POST("/yycp-chat-service/car/chat/no/operateTeamRoom/v1")
+ suspend fun requestVehicleTeamConnectStatus(@FieldMap connectStatus: Map): BaseResponse
+
+ //查询用户是否在线
+ @FormUrlEncoded
+ @POST("/yycp-chat-service/car/queryOnLineBySn/v1")
+ suspend fun isOnLine(@FieldMap onLine: Map): BaseResponse
+
+ @POST("/yycp-realtimeLocations/realTimeLocationServer/queryRsAncCarAndUserInfoBySns")
+ suspend fun queryUserInfoBySnS(@Body body: SnArrayRequestBody): BaseResponse
+
+ //语音房间信息，原路径dataService
+ @FormUrlEncoded
+ @POST("/yycp-chat-service/car/sender/no/createRoom/v1")
+ suspend fun requestRoomInfo(@FieldMap roomInfo: Map): BaseResponse
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/CallRequestParam.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/CallRequestParam.kt
new file mode 100644
index 0000000000..e16a5ec083
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/CallRequestParam.kt
@@ -0,0 +1,50 @@
+package com.mogo.eagle.core.function.chat.facade.net.bean
+
+import androidx.annotation.Keep
+import com.google.gson.annotations.Expose
+import com.google.gson.annotations.SerializedName
+import com.mogo.eagle.core.function.api.chat.biz.IMCallType
+import com.mogo.eagle.core.function.api.chat.biz.IMCallType.CALL_TYPE_VOICE
+
+@Keep class CallRequestParam {
+ /**
+ * 发送者sn
+ */
+ var snSender: String = ""
+
+ /**
+ * 接收者sn
+ */
+ var snReceiver: String = ""
+
+ /**
+ * 发送者用户名
+ */
+ var nickName:String? = null
+
+ /**
+ * 发送者头像链接
+ */
+ var headImgUrl:String? = null
+
+ /**
+ * 发送者车辆信息
+ */
+ var carInfo:String? = null
+
+ /**
+ * 发送者经度
+ */
+ var lon:Double = 0.0
+
+ /**
+ * 发送者纬度
+ */
+ var lat: Double = 0.0
+
+ /**
+ * 呼叫类型
+ */
+ var type = CALL_TYPE_VOICE.type
+
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/ConnectStatusParam.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/ConnectStatusParam.kt
new file mode 100644
index 0000000000..fd9676cc86
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/ConnectStatusParam.kt
@@ -0,0 +1,24 @@
+package com.mogo.eagle.core.function.chat.facade.net.bean
+
+class ConnectStatusParam (var snSender: String, var snReceiver: String, var roomId: Int, var status: Int, var type: Int) {
+
+ var lat: Double? = null//发送方的纬度
+
+ var lon: Double? = null//发送方的经度
+
+ var nickName: String? = null//发送方的昵称
+
+ var headImgUrl: String? = null//发送方的用户头像
+
+ var carInfo: String? = null//发送方的车辆信息
+
+ var cardIdAge: String? = null //发送方年龄
+
+ var cardIdSex: String? = null//发送发性别
+
+ var cityName: String? = null//发送方城市
+
+ override fun toString(): String {
+ return "ConnectStatusParam(snSender='$snSender', snReceiver='$snReceiver', roomId=$roomId, status=$status, type=$type, lat=$lat, lon=$lon, nickName=$nickName, headImgUrl=$headImgUrl, carInfo=$carInfo, cardIdAge=$cardIdAge, cardIdSex=$cardIdSex, cityName=$cityName)"
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/Error.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/Error.kt
new file mode 100644
index 0000000000..a84cd9d2f8
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/Error.kt
@@ -0,0 +1,3 @@
+package com.mogo.eagle.core.function.chat.facade.net.bean
+
+data class Error(val code: Int, val msg: String)
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/OnLineStatus.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/OnLineStatus.kt
new file mode 100644
index 0000000000..c294ae9e90
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/OnLineStatus.kt
@@ -0,0 +1,11 @@
+package com.mogo.eagle.core.function.chat.facade.net.bean
+
+
+/**
+ * carOnLine：ACC ON状态 1:在线 2:不在线
+ * onLine:是否隐身 1:在线 2:隐身
+ */
+internal class OnLineStatus {
+ var carOnLine: Int = -1
+ var onLine: Int = -1
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/RoomInfo.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/RoomInfo.kt
new file mode 100644
index 0000000000..94ad79e381
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/RoomInfo.kt
@@ -0,0 +1,8 @@
+package com.mogo.eagle.core.function.chat.facade.net.bean
+
+import androidx.annotation.Keep
+
+@Keep class RoomInfo {
+
+ var roomId:Int = -1
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/SnArrayRequestBody.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/SnArrayRequestBody.kt
new file mode 100644
index 0000000000..be8d5f08ac
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/net/bean/SnArrayRequestBody.kt
@@ -0,0 +1,8 @@
+package com.mogo.eagle.core.function.chat.facade.net.bean
+
+import androidx.annotation.Keep
+
+@Keep
+internal class SnArrayRequestBody {
+ var sns: List? = null
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/socket/SocketConnectManager.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/socket/SocketConnectManager.kt
new file mode 100644
index 0000000000..6eac99fc9d
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/socket/SocketConnectManager.kt
@@ -0,0 +1,97 @@
+package com.mogo.eagle.core.function.chat.facade.socket
+
+import com.google.gson.Gson
+import com.mogo.cloud.passport.MoGoAiCloudClientConfig
+import com.mogo.eagle.core.data.chat.socket.HeartBeat
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.chat.facade.consts.ChatHttp
+import com.mogo.eagle.core.function.chat.facade.consts.SOCKET_HAND_SHAKE
+import com.mogo.eagle.core.function.chat.facade.consts.SOCKET_HEART_BEAT
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import com.mogo.websocket.ISocketMsgCallBack
+import com.mogo.websocket.ISocketMsgSetting
+import com.mogo.websocket.SocketClient
+import java.util.concurrent.atomic.AtomicInteger
+
+/**
+ * 长链接管理类
+ */
+internal object SocketConnectManager {
+
+ private val client by lazy {
+ SocketClient()
+ }
+
+ private var msgCallback: ((msg: String) -> Unit)? = null
+
+ private val roomId by lazy {
+ AtomicInteger(0)
+ }
+
+ fun init() {
+ //开启长连服务
+ client.initSocketServer(ChatHttp.getSocketServer())
+ client.getMessageSettings(socketMsgSetting)
+ client.addISocketMsgCallBack(socketMsgCallBack)
+ client.startConnect()
+ }
+
+ fun setOnMsgReceiveCb(cb: ((msg: String) -> Unit)) {
+ msgCallback = cb
+ }
+
+ fun setRoomId(roomId: Int) {
+ this.roomId.set(roomId)
+ }
+
+ private val socketMsgSetting: ISocketMsgSetting = object : ISocketMsgSetting {
+ override fun getHandShakeMsg(): String {
+ log(ChatConsts.TAG, "getHandShakeMsg")
+ val socketMsg = HeartBeat(SOCKET_HAND_SHAKE, MoGoAiCloudClientConfig.getInstance().sn)
+ return Gson().toJson(socketMsg)
+ }
+
+ override fun getHeartBeatMsg(): String {
+ log(ChatConsts.TAG, "getHeartBeatMsg")
+ val socketMsg = HeartBeat(SOCKET_HEART_BEAT, MoGoAiCloudClientConfig.getInstance().sn, roomId.get())
+ return Gson().toJson(socketMsg)
+ }
+ }
+
+ private val socketMsgCallBack: ISocketMsgCallBack = object : ISocketMsgCallBack {
+ override fun onConnectOpen() {
+ log(ChatConsts.TAG, "onConnectOpen ---> ")
+ }
+
+ override fun handleError(e: Exception) {
+ log(ChatConsts.TAG, "handleError ---> msg: ${e.message}")
+ client.stopHeartBeat()
+ }
+
+ override fun onConnectClose() {
+ log(ChatConsts.TAG, "onConnectClose ---> stop web socket thread ,and ready to reconnect")
+ client.stop()
+ log(ChatConsts.TAG, "onConnectClose ---> stop Heart Beat")
+ client.stopHeartBeat()
+ log(ChatConsts.TAG, "ready to reconnect")
+ client.reConnect()
+ }
+
+ override fun handleMessage(message: String) {
+ log(ChatConsts.TAG, "handleMessage ---> $message")
+ msgCallback?.invoke(message)
+ }
+ }
+
+ fun instance() = client
+
+ fun destroy() {
+ try {
+ client.stopHeartBeat()
+ client.disConnect()
+ client.stop()
+ } catch (t: Throwable) {
+ log(ChatConsts.TAG, "IMService -- destroy -- ex: $t")
+ }
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/ui/CallChatWindowManager.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/ui/CallChatWindowManager.kt
new file mode 100644
index 0000000000..f9db3ded23
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/ui/CallChatWindowManager.kt
@@ -0,0 +1,606 @@
+package com.mogo.eagle.core.function.chat.facade.ui
+
+import android.content.Context
+import android.media.AudioManager
+import android.view.LayoutInflater
+import android.view.View
+import android.widget.FrameLayout
+import android.widget.ImageView
+import android.widget.TextView
+import androidx.core.view.ViewCompat
+import androidx.lifecycle.Lifecycle.Event.ON_CREATE
+import androidx.lifecycle.Lifecycle.Event.ON_DESTROY
+import com.bumptech.glide.request.RequestOptions
+import com.mogo.eagle.core.data.chat.UserInfo
+import com.mogo.eagle.core.function.api.chat.biz.AnswerState
+import com.mogo.eagle.core.function.api.chat.biz.AnswerState.EnterRoomSuccess
+import com.mogo.eagle.core.function.api.chat.biz.AnswerState.Error
+import com.mogo.eagle.core.function.api.chat.biz.AnswerState.ExitRoomSuccess
+import com.mogo.eagle.core.function.api.chat.biz.AnswerState.RoomMemberUpdate
+import com.mogo.eagle.core.function.api.chat.biz.ChatConsts
+import com.mogo.eagle.core.function.api.chat.biz.HangUpState
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoVoiceControlFacade.IMoGoVoiceCallback
+import com.mogo.eagle.core.function.api.chat.biz.RefuseState
+import com.mogo.eagle.core.function.chat.R
+import com.mogo.eagle.core.function.chat.facade.MoGoChatFacade
+import com.mogo.eagle.core.function.chat.facade.OnCallingInterrupt
+import com.mogo.eagle.core.function.chat.facade.OnInComingCallback
+import com.mogo.eagle.core.function.chat.facade.bridge.BridgeApi
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import com.mogo.eagle.core.function.chat.facade.voice.VoiceControlFacade.REQUEST_CLOUD_VOICE_CALL
+import com.mogo.eagle.core.utilcode.kotlin.lifeCycleScope
+import com.mogo.eagle.core.utilcode.kotlin.observe
+import com.mogo.eagle.core.utilcode.kotlin.onClick
+import com.mogo.eagle.core.utilcode.kotlin.safeCancel
+import com.mogo.eagle.core.utilcode.mogo.glide.GlideRoundedCornersTransform
+import com.mogo.eagle.core.utilcode.mogo.glide.GlideRoundedCornersTransform.CornerType.LEFT
+import kotlinx.coroutines.*
+import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.channels.Channel.Factory.RENDEZVOUS
+import kotlinx.coroutines.flow.*
+import kotlinx.coroutines.selects.select
+import java.util.concurrent.atomic.AtomicReference
+import com.mogo.eagle.core.utilcode.mogo.glide.GlideApp
+import com.mogo.eagle.core.utilcode.util.ToastUtils
+import java.text.SimpleDateFormat
+import java.util.*
+
+internal class CallChatWindowManager {
+
+ companion object {
+ const val TAG = "TeamChatWindowManager"
+
+ const val DEFAULT_MAX_DIALING_TIME = 30 * 1000L
+ }
+
+ private val facade by lazy {
+ MoGoChatFacade
+ }
+
+ private val context by lazy {
+ BridgeApi.context()
+ }
+
+ private val scope by lazy {
+ BridgeApi.context().lifeCycleScope
+ }
+
+ private var hasAnswered = false
+
+ private var hasRefused = false
+
+ private var hasHangUpped = false
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private var interrupt = Channel(RENDEZVOUS)
+ @Synchronized
+ get() = if (field.isClosedForReceive || field.isClosedForSend) {
+ field = Channel(RENDEZVOUS)
+ field
+ } else field
+
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private var exitRoom = Channel(RENDEZVOUS)
+ @Synchronized
+ get() = if (field.isClosedForReceive || field.isClosedForSend) {
+ field = Channel(RENDEZVOUS)
+ field
+ } else field
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private var callerEnter = Channel(RENDEZVOUS)
+ @Synchronized
+ get() = if (field.isClosedForReceive || field.isClosedForSend) {
+ field = Channel(RENDEZVOUS)
+ field
+ } else field
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private var refused = Channel(RENDEZVOUS)
+ @Synchronized
+ get() = if (field.isClosedForReceive || field.isClosedForSend) {
+ field = Channel(RENDEZVOUS)
+ field
+ } else field
+
+
+ private val onInComingCall = object : OnInComingCallback {
+ override fun invoke(isTeam: Boolean, user: UserInfo) {
+ if (isTeam) {
+ log(TAG, "车队邀请，不做处理....")
+ } else {
+ showInComingView(user)
+ }
+ }
+ }
+
+ private val onCallInterrupt = object : OnCallingInterrupt {
+ override fun invoke(isTeam: Boolean, user: UserInfo) {
+ if (isTeam) {
+ log(TAG, "车队邀请拒绝，不做处理....")
+ } else {
+ onCallInterrupt()
+ }
+ }
+ }
+
+ fun init() {
+ facade.let {
+ it.onInComingCall(onInComingCall)
+ it.onCallingInterrupt(onCallInterrupt)
+ }
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private fun showInComingView(user: UserInfo) {
+ val context = BridgeApi.context()
+ scope.launchWhenResumed {
+ var incomingView = LayoutInflater.from(context)
+ .inflate(R.layout.module_car_chatting_launcher_incoming_hawk_eye_view, null)
+ incomingView.isClickable = true
+ var answer = incomingView.findViewById(R.id.module_carchatting_incoming_answer)
+ var refuse = incomingView.findViewById(R.id.module_carchatting_incoming_hangUp)
+ val dismissJob = AtomicReference()
+ var timer: Job? = null
+ var ring: Job? = null
+ launch {
+ speak(REQUEST_CLOUD_VOICE_CALL)
+ calling()
+ }.also { ring = it }
+ answer.onClick {
+ timer = resetInComingTimer(timer, user, incomingView)
+ if (hasAnswered) {
+ ToastUtils.showShort("正在处理, 请稍候...")
+ return@onClick
+ }
+ doAnswer(user, incomingView)
+ }
+ refuse.onClick {
+ timer = resetInComingTimer(timer, user, incomingView)
+ if (hasRefused) {
+ ToastUtils.showShort("正在处理, 请稍候...")
+ return@onClick
+ }
+ doRefuse(user)
+ }
+ incomingView.observe(arrayOf(ON_CREATE, ON_DESTROY)) { itx ->
+ if (itx == ON_CREATE) {
+ timer = inComingTimer(user, incomingView)
+ launch(Dispatchers.Main) {
+ val d1 = async {
+ log(TAG, "监听对方呼出，又挂断状态...")
+ var interrupted = interrupt.receive()
+ while (!interrupted) {
+ interrupted = interrupt.receive()
+ }
+ log(TAG, "收到对方呼出又挂断状态...")
+ }
+ val d2 = async {
+ log(TAG, "监听拒绝状态...")
+ var isRefuse = refused.receive()
+ while (!isRefuse) {
+ isRefuse = refused.receive()
+ }
+ log(TAG, "收到拒绝状态, 隐藏来电界面")
+ }
+ val state = select {
+ d1.onAwait { 1 }
+ d2.onAwait { 2 }
+ }
+ when (state) {
+ 1 -> {
+ log(TAG, "由于对方呼出又挂断，导致来电界面隐藏")
+ d2.safeCancel()
+ }
+ 2 -> {
+ log(TAG, "由于自己主动拒接，导致来电界面隐藏")
+ d1.safeCancel()
+ }
+ }
+ hide(incomingView)
+ releaseAudioAndVoice()
+ }.also { dismissJob.set(it) }
+ }
+ if (itx == ON_DESTROY) {
+ ring?.safeCancel()
+ timer?.safeCancel()
+ hasAnswered = false
+ hasRefused = false
+ refused.safeCancel()
+ interrupt.safeCancel()
+ dismissJob.get()?.safeCancel()
+ incomingView = null
+ answer = null
+ refuse = null
+ }
+ }
+ show(incomingView, getInComingLayoutParams(context))
+ }
+ }
+
+ private suspend fun speak(text: String) = suspendCancellableCoroutine {
+ val voiceCallback = object : IMoGoVoiceCallback {
+ override fun onSpeakEnd() {
+ it.resumeWith(Result.success(Unit))
+ }
+ }
+ val voiceCtl = facade.voice()
+ it.invokeOnCancellation {
+ voiceCtl.stopTTS(context, text)
+ }
+ voiceCtl.speak(context, text, voiceCallback)
+ }
+
+ private suspend fun calling() = suspendCancellableCoroutine {
+ it.invokeOnCancellation {
+ releaseAudioAndVoice()
+ }
+ playAudioCall {
+ it.resumeWith(Result.success(Unit))
+ }
+ }
+
+
+ private fun getInComingLayoutParams(context: Context): FrameLayout.LayoutParams {
+ return FrameLayout.LayoutParams(
+ context.resources.getDimension(R.dimen.module_call_chat_state_incoming_hawk_eye_width).toInt(),
+ context.resources.getDimension(R.dimen.module_call_chat_state_incoming_hawk_eye_height).toInt())
+ .also {
+ val x = context.resources.getDimension(R.dimen.module_call_chat_state_location_hawk_eye_x)
+ val y = context.resources.getDimension(R.dimen.module_call_chat_state_location_hawk_eye_y)
+ it.leftMargin = x.toInt()
+ it.topMargin = y.toInt()
+ }
+ }
+
+ /**
+ * 重新开始计时
+ */
+ private fun CoroutineScope.resetInComingTimer(old: Job?, user: UserInfo, incomingView: View): Job {
+ old?.safeCancel()
+ return inComingTimer(user, incomingView)
+ }
+
+ private fun CoroutineScope.inComingTimer(user: UserInfo, incomingView: View) = launch {
+ log(TAG, "延迟30s消失计时开始...")
+ delay(DEFAULT_MAX_DIALING_TIME)
+ log(TAG, "延迟30s消失计时结束...")
+ doRefuse(user, false)
+ hide(incomingView)
+ releaseAudioAndVoice()
+ }
+
+ private fun showCallingView(user: UserInfo) {
+ val context = BridgeApi.context()
+ scope.launchWhenResumed {
+ var callingView = LayoutInflater.from(context)
+ .inflate(R.layout.module_car_chatting_launcher_calling_hawk_eye_view, null)
+ callingView.isClickable = true
+ var calling= callingView.findViewById(R.id.module_carchatting_rl_call_view)
+ var head = callingView.findViewById(R.id.module_carchatting_call_head)
+ var hangUp = callingView.findViewById(R.id.module_carchatting_call_hangUp)
+ var name = callingView.findViewById(R.id.module_carchatting_call_nickname)
+ var timer = callingView.findViewById(R.id.module_carchatting_call_time)
+ calling.visibility = View.VISIBLE
+ name.text = "云平台"
+ timer.text = context.resources.getString(R.string.module_car_chat_matching_wait)
+ GlideApp.with(context).load(user.icon)
+ .apply(
+ RequestOptions.bitmapTransform(
+ GlideRoundedCornersTransform(
+ 20f,
+ LEFT
+ )
+ )
+ )
+ .placeholder(R.mipmap.module_carchatting_hawk_eye_default_head_img)
+ .into(head)
+ hangUp.onClick {
+ if (hasHangUpped) {
+ ToastUtils.showShort("正在处理，请稍候...")
+ return@onClick
+ }
+ doHangUp(user, callingView)
+ }
+ callingView.observe(arrayOf(ON_CREATE, ON_DESTROY)) {
+ var job: Job? = null
+ if (it == ON_CREATE) {
+ launch(Dispatchers.Main) {
+ val d1 = async {
+ log(ChatConsts.TAG, "等着新用户进来...")
+ var isNewUserEnter = callerEnter.receive()
+ while (!isNewUserEnter) {
+ isNewUserEnter = callerEnter.receive()
+ }
+ //新用户进来了
+ log(ChatConsts.TAG, "新用户进来了...")
+ callingTimer()
+ .collect {
+ timer.text = parseTime(it)
+ }
+ }
+ val d2 = async {
+ log(ChatConsts.TAG, "等着退房通知...")
+ var exit = exitRoom.receive()
+ while (!exit) {
+ exit = exitRoom.receive()
+ }
+ }
+ val state = select {
+ d1.onAwait { 1 }
+ d2.onAwait { 2 }
+ }
+ when (state) {
+ 1 -> {
+ log(TAG, "通话中, 计时任务结束了(不般不会发生)...")
+ }
+ 2 -> {
+ log(TAG, "收到退房通知，可以移除通话状态的界面了...")
+ d1.safeCancel()
+ }
+ }
+ if (hasHangUpped) {
+ ToastUtils.showShort("已挂断")
+ }
+ hide(callingView)
+ facade.audioFocus().releaseAudioFocus()
+ }.also { job = it }
+ }
+ if (it == ON_DESTROY) {
+ job?.safeCancel()
+ callerEnter.safeCancel()
+ exitRoom.safeCancel()
+ hasHangUpped = false
+ callingView = null
+ calling = null
+ head = null
+ hangUp = null
+ name = null
+ timer = null
+ }
+ }
+ show(callingView, getCallingLayoutParams(context))
+ }
+ }
+
+ private fun getCallingLayoutParams(context: Context): FrameLayout.LayoutParams {
+ return FrameLayout.LayoutParams(
+ context.resources.getDimension(R.dimen.module_call_chat_state_hawk_eye_width).toInt(),
+ context.resources.getDimension(R.dimen.module_call_chat_state_hawk_eye_height).toInt()
+ )
+ .also {
+ it.leftMargin = context.resources.getDimension(R.dimen.module_call_chat_state_location_hawk_eye_x).toInt()
+ it.topMargin = context.resources.getDimension(R.dimen.module_call_chat_state_location_hawk_eye_y).toInt()
+ }
+ }
+
+ private fun parseTime(time: Long): String {
+ val date = Date(time)
+ val formatter = SimpleDateFormat("HH:mm:ss", Locale.CHINA)
+ formatter.timeZone = TimeZone.getTimeZone("GMT+00:00")
+ return formatter.format(date)
+ }
+
+ private fun show(view: View, params: FrameLayout.LayoutParams) {
+ BridgeApi.floatViewManager()?.addView(view, params, true)
+ }
+
+ private fun hide(view: View) {
+ if (!ViewCompat.isAttachedToWindow(view)) {
+ return
+ }
+ BridgeApi.floatViewManager()?.removeView(view)
+ }
+
+ private fun playAudioCall(onPlay:(() -> Unit)? = null) {
+ facade.also {
+ it.audioFocus().requireAudioFocus {
+ it.media().play(context, R.raw.call, true, AudioManager.STREAM_RING)
+ onPlay?.invoke()
+ }
+ }
+ }
+
+ private fun releaseAudioAndVoice() {
+ facade.also {
+ it.media().release()
+ }
+ }
+
+ private fun onNewUserEnterRoom() {
+ scope.launch {
+ callerEnter.send(true)
+ }
+ }
+
+ private fun onCallInterrupt() {
+ scope.launch {
+ interrupt.send(true)
+ }
+ }
+
+ private fun doAnswer(user: UserInfo, incommingView: View) {
+ answer(
+ user,
+ onEnter = {
+ releaseAudioAndVoice()
+ hide(incommingView)
+ showCallingView(user)
+ },
+ onNewEnter = {
+ onNewUserEnterRoom()
+ },
+ onExit = {
+ exitRoom()
+ },
+ onError = { code, msg, extra ->
+ log(TAG, "-- 应答失败 --: code:: $code; msg:: $msg; extra:: $extra")
+ when (code) {
+ AnswerState.CODE_ANSWER_SOCKET_DISCONNECT -> {
+ ToastUtils.showShort("连接已断开")
+ }
+ else -> {
+ ToastUtils.showShort("应答失败")
+ }
+ }
+ doRefuse(user, false)
+ releaseAudioAndVoice()
+ hide(incommingView)
+ facade.audioFocus().releaseAudioFocus()
+ }
+ )
+ }
+
+ /**
+ * @param user: 来电用户信息
+ * @param onEnter: 当前用户进房成功通知
+ * @param onExit: 当前用户退房通知（当前用户主动挂断或对方挂断）
+ */
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private fun answer(user: UserInfo, onEnter: () -> Unit, onNewEnter: () -> Unit, onExit: () -> Unit, onError: (code: Int, msg: String, extra: Map? ) -> Unit) {
+ facade.also { itx ->
+ if (hasAnswered) {
+ return
+ }
+ hasAnswered = true
+ itx.answer(user.sn)
+ .onEach {
+ when(it) {
+ is EnterRoomSuccess -> {
+ onEnter.invoke()
+ }
+ is RoomMemberUpdate -> {
+ if (!it.isMySelf && it.isEnter) {
+ onNewEnter.invoke()
+ }
+ }
+ is ExitRoomSuccess -> {
+ onExit.invoke()
+ }
+ is Error -> {
+ hasAnswered = false
+ onError.invoke(it.code, it.msg, it.extra)
+ }
+ else -> {
+ log(ChatConsts.TAG, "[Answer][Other]-> $it")
+ }
+ }
+ }
+ .launchIn(scope)
+ }
+ }
+
+ private fun doRefuse(user: UserInfo, notify: Boolean = true) {
+ refuse(user,
+ onSuccess = {
+ if (notify) {
+ ToastUtils.showShort("已拒接")
+ onRefuseOK()
+ }
+ },
+ onError = { code, msg, extra ->
+ log(TAG, "-- 拒绝失败 --: code:: $code; msg:: $msg; extra:: $extra")
+ ToastUtils.showShort("拒绝异常")
+ })
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private fun refuse(user: UserInfo, onSuccess: () -> Unit, onError: (code: Int, msg: String, extra: Map?) -> Unit){
+ facade.also {
+ if (hasRefused) {
+ return
+ }
+ hasRefused = true
+ it.refuse(user.sn)
+ .onEach { itx ->
+ when(itx) {
+ is RefuseState.Success -> {
+ onSuccess.invoke()
+ }
+ is RefuseState.Error -> {
+ hasRefused = false
+ onError.invoke(itx.code, itx.msg, itx.extra)
+ }
+ else -> {
+ log(ChatConsts.TAG, "[Refuse][Other]-> $it")
+ }
+ }
+ }
+ .launchIn(scope)
+ }
+ }
+
+ private fun doHangUp(user: UserInfo, callingView: View) {
+ hangUp(
+ user,
+ onSuccess = {
+ log(TAG, "挂断接口请求成功，等着退房...")
+ },
+ onError = { code, msg, extra ->
+ log(TAG, "挂断异常：code: $code; msg: $msg, ; extra: $extra")
+ ToastUtils.showShort("挂断异常")
+ })
+
+ }
+
+ private fun exitRoom() {
+ scope.launch {
+ exitRoom.send(true)
+ }
+ }
+
+ private fun onRefuseOK() {
+ scope.launch {
+ refused.send(true)
+ }
+ }
+
+ @OptIn(InternalCoroutinesApi::class)
+ private fun callingTimer(): Flow {
+ return flow {
+ var counter = 1
+ while (true) {
+ delay(1000)
+ emit(1000L * (counter ++))
+ }
+ }
+ }
+
+ @OptIn(ExperimentalCoroutinesApi::class)
+ private fun hangUp(user: UserInfo, onSuccess: () -> Unit, onError:(code: Int, msg: String, extra: Map?) -> Unit) {
+ facade.also {
+ if (hasHangUpped) {
+ return
+ }
+ hasHangUpped = true
+ it.handUp(user.sn)
+ .onEach { itx ->
+ when(itx) {
+ HangUpState.Success -> {
+ onSuccess.invoke()
+ }
+ is HangUpState.Error -> {
+ hasHangUpped = false
+ log(TAG, "-- 挂断失败 --: code:: ${itx.code}; msg:: ${itx.msg}; extra:: ${itx.extra}")
+ onError.invoke(itx.code, itx.msg, itx.extra)
+ }
+ else -> {
+ log(ChatConsts.TAG, "[HangUp][Other]-> $it")
+ }
+ }
+ }
+ .launchIn(scope)
+ }
+ }
+
+ fun destroy() {
+ hasAnswered = false
+ hasHangUpped = false
+ hasRefused = false
+ interrupt.safeCancel()
+ refused.safeCancel()
+ exitRoom.safeCancel()
+ callerEnter.safeCancel()
+ }
+}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/utils/LogUtil.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/utils/LogUtil.kt
new file mode 100644
index 0000000000..e32ad7d1e0
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/utils/LogUtil.kt
@@ -0,0 +1,9 @@
+@file:JvmName("LogUtil")
+
+package com.mogo.eagle.core.function.chat.facade.utils
+
+import com.mogo.eagle.core.function.chat.facade.aop.DebugLog
+
+
+@DebugLog
+fun log(tag: String, msg: String) {}
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/voice/VoiceControlFacade.kt b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/voice/VoiceControlFacade.kt
new file mode 100644
index 0000000000..31797c30b6
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/java/com/mogo/eagle/core/function/chat/facade/voice/VoiceControlFacade.kt
@@ -0,0 +1,232 @@
+package com.mogo.eagle.core.function.chat.facade.voice
+
+import android.content.Context
+import android.content.Intent
+import com.mogo.commons.AbsMogoApplication
+import com.mogo.commons.voice.AIAssist
+import com.mogo.commons.voice.IMogoVoiceCmdCallBack
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoVoiceControlFacade
+import com.mogo.eagle.core.function.api.chat.biz.IMoGoVoiceControlFacade.IMoGoVoiceCallback
+import com.mogo.eagle.core.function.chat.facade.bridge.BridgeApi
+import com.mogo.eagle.core.function.chat.facade.utils.log
+import com.mogo.service.intent.IMogoIntentListener
+import java.lang.ref.WeakReference
+import java.util.concurrent.CopyOnWriteArrayList
+import java.util.concurrent.atomic.AtomicBoolean
+
+object VoiceControlFacade: IMoGoVoiceControlFacade, IMogoVoiceCmdCallBack, IMogoIntentListener {
+
+ private const val TAG = "VoiceControl"
+
+ //WakeUp Command (Intent)
+ private const val VOICE_INTENT_CANCEL_CALL_COMMAND = "com.zhidao.commin.cancel" //取消呼叫,取消通话
+ private const val VOICE_INTENT_REFUSE_CALL = "com.ileja.phone.incoming.reject" //挂断
+
+ //unWakeUp Command
+ private const val VOICE_REGISTER_INVITE_JOIN_TEAM = "CMD_CAR_CHAT_INVITE_JOIN_TEAM"
+ private val customInviteJoinTeamArray: Array = arrayOf("邀请加入车队")
+ private const val VOICE_REGISTER_JOIN_TEAM = "CMD_CAR_CHAT_JOIN_TEAM"
+ private val customJoinTeamArray: Array = arrayOf("加入", "加入车队")
+ private const val VOICE_REGISTER_REFUSE_JOIN_TEAM = "CMD_CAR_CHAT_REFUSE_JOIN_TEAM"
+ private val customRefuseJoinTeamArray: Array = arrayOf("拒绝", "拒绝加入车队")
+ private const val VOICE_REGISTER_CANCEL_CALL = "CMD_CAR_CHAT_CANCEL_CALL"
+ private val customCancelCallArray: Array = arrayOf("取消通话", "取消呼叫", "挂断")
+
+ private const val VOICE_INTENT_ANSWER_CALL = "com.ileja.phone.incoming.accept" //接听
+
+ internal const val REQUEST_CLOUD_VOICE_CALL = "云平台请求跟你进行语音通话"
+ private val requestCallYArray: Array = arrayOf("接听")
+ private val requestCallNArray: Array = arrayOf("挂断")
+
+ private val hasRegister by lazy { AtomicBoolean(false) }
+
+ private val listeners by lazy {
+ CopyOnWriteArrayList>()
+ }
+
+ private var onCmdAgree: WeakReference? = null
+
+ private var onSpeechFinish: WeakReference? = null
+
+ private val intentManager by lazy {
+ BridgeApi.intentManager()
+ }
+
+ override fun speak(context: Context, content: String, listener: IMoGoVoiceCallback) {
+ listeners += WeakReference(listener)
+ AIAssist.getInstance(context).speakTTSVoice(content, this)
+ }
+
+ override fun onCmdSelected(cmd: String?) {
+ super.onCmdSelected(cmd)
+ cmd?.let { itx ->
+ listeners
+ .filter {
+ it.get() != null
+ }
+ .forEach {
+ when (itx) {
+ VOICE_REGISTER_CANCEL_CALL -> {
+ log(TAG, "语音免唤醒 取消打电话")
+ it.get()?.onVoiceCancelCall()
+ }
+ VOICE_REGISTER_INVITE_JOIN_TEAM -> {
+ log(TAG, "语音免唤醒 邀請加入车队")
+ it.get()?.onVoiceInviteJoinTeam()
+ }
+ VOICE_REGISTER_JOIN_TEAM -> {
+ log(TAG, "语音免唤醒 加入车队")
+ it.get()?.onVoiceJoinTeam()
+ }
+ VOICE_REGISTER_REFUSE_JOIN_TEAM -> {
+ log(TAG, "语音免唤醒 拒绝加入车队")
+ it.get()?.onVoiceRefuseJoinTeam()
+ }
+ VOICE_INTENT_ANSWER_CALL -> {
+ log(TAG, "语音免唤醒 接收电话邀请")
+ it.get()?.onVoiceAnswerCall()
+ }
+ VOICE_INTENT_REFUSE_CALL -> {
+ log(TAG, "语音免唤醒 来电拒接")
+ it.get()?.onVoiceRefuseCall()
+ }
+ }
+ }
+ }
+ }
+
+ override fun onSpeakEnd(speakText: String?) {
+ super.onSpeakEnd(speakText)
+ listeners
+ .filter {
+ it.get() != null
+ }
+ .forEach {
+ it.get()?.onSpeakEnd()
+ }
+ }
+
+ override fun onSpeakError(speakText: String?, errorMsg: String?) {
+ super.onSpeakError(speakText, errorMsg)
+ listeners
+ .filter {
+ it.get() != null
+ }
+ .forEach {
+ it.get()?.onSpeakEnd()
+ }
+ }
+
+ override fun register() {
+ if (hasRegister.get()) {
+ return
+ }
+ hasRegister.set(true)
+ AIAssist.getInstance(BridgeApi.context()).registerUnWakeupCommand(VOICE_REGISTER_CANCEL_CALL, customCancelCallArray, this)
+ intentManager?.also {
+ it.registerIntentListener(VOICE_INTENT_CANCEL_CALL_COMMAND, this)
+ it.registerIntentListener(VOICE_INTENT_REFUSE_CALL, this)
+ }
+ }
+
+ override fun registerInviteJoinTeam(context: Context, listener: IMoGoVoiceCallback) {
+ log(TAG, "registerInviteJoinTeam")
+ listeners += WeakReference(listener)
+ AIAssist.getInstance(context)
+ .registerUnWakeupCommand(VOICE_REGISTER_INVITE_JOIN_TEAM, customInviteJoinTeamArray, this)
+ }
+
+ override fun registerJoinTeam(context: Context, listener: IMoGoVoiceCallback) {
+ log(TAG, "registerJoinTeam")
+ listeners += WeakReference(listener)
+ AIAssist.getInstance(context)
+ .registerUnWakeupCommand(VOICE_REGISTER_JOIN_TEAM, customJoinTeamArray, this)
+ AIAssist.getInstance(context)
+ .registerUnWakeupCommand(VOICE_REGISTER_REFUSE_JOIN_TEAM, customRefuseJoinTeamArray, this)
+ }
+
+ override fun unRegisterInviteJoinTeam(context: Context) {
+ AIAssist.getInstance(context).unregisterUnWakeupCommand(VOICE_REGISTER_INVITE_JOIN_TEAM)
+ }
+
+ override fun unRegisterJoinTeam(context: Context) {
+ AIAssist.getInstance(context).unregisterUnWakeupCommand(VOICE_REGISTER_JOIN_TEAM)
+ AIAssist.getInstance(context).unregisterUnWakeupCommand(VOICE_REGISTER_REFUSE_JOIN_TEAM)
+ }
+
+ override fun registerIntentInComingCall(listener: IMoGoVoiceCallback) {
+ listeners += WeakReference(listener)
+ intentManager?.registerIntentListener(VOICE_INTENT_ANSWER_CALL, this)
+ intentManager?.registerIntentListener(VOICE_INTENT_REFUSE_CALL, this)
+ }
+
+ override fun unRegisterIntentInComingCall(context: Context) {
+ intentManager?.unregisterIntentListener(VOICE_INTENT_ANSWER_CALL, this)
+ intentManager?.unregisterIntentListener(VOICE_INTENT_REFUSE_CALL, this)
+ }
+
+ override fun speakAndRegisterCall(onCmdAgree: (Boolean) -> Unit, onSpeakFinish: () -> Unit, listener: IMoGoVoiceCallback) {
+ this.onCmdAgree = WeakReference(onCmdAgree)
+ this.onSpeechFinish = WeakReference(onSpeakFinish)
+ listeners += WeakReference(listener)
+
+ AIAssist.getInstance(AbsMogoApplication.getApp().applicationContext).speakQAndACmd(REQUEST_CLOUD_VOICE_CALL,
+ requestCallYArray, requestCallNArray, object : IMogoVoiceCmdCallBack {
+
+ override fun onCmdAction(speakText: String?) {
+ super.onCmdAction(speakText)
+ log(TAG, "onCmdAction ---> ")
+ this@VoiceControlFacade.onCmdAgree?.get()?.invoke(true)
+ }
+
+ override fun onCmdCancel(speakText: String?) {
+ super.onCmdCancel(speakText)
+ log(TAG, "onCmdCancel ---> ")
+ this@VoiceControlFacade.onCmdAgree?.get()?.invoke(false)
+ }
+
+ override fun onSpeakEnd(speakText: String?) {
+ super.onSpeakEnd(speakText)
+ log(TAG, "onSpeakEnd ---> ")
+ this@VoiceControlFacade.onSpeechFinish?.get()?.invoke()
+ }
+ })
+ }
+
+ override fun stopTTS(context: Context, text: String) {
+ AIAssist.getInstance(context).stopSpeakTts(text)
+ }
+
+ override fun unRegister() {
+ if (!hasRegister.get()) {
+ return
+ }
+ hasRegister.set(false)
+ listeners.clear()
+ AIAssist.getInstance(BridgeApi.context()).unregisterUnWakeupCommand(VOICE_REGISTER_CANCEL_CALL, this)
+ intentManager?.also {
+ it.unregisterIntentListener(VOICE_INTENT_CANCEL_CALL_COMMAND, this)
+ it.unregisterIntentListener(VOICE_INTENT_REFUSE_CALL, this)
+ }
+ }
+
+ override fun onIntentReceived(cmd: String?, intent: Intent?) {
+ val command = cmd ?: return
+ log(TAG, "handleOnIntentCmd: cmd -> $command")
+ when (command) {
+ VOICE_INTENT_CANCEL_CALL_COMMAND, VOICE_INTENT_REFUSE_CALL -> {
+ log(TAG, "语音唤醒 取消打电话")
+ listeners
+ .filter {
+ it.get() != null
+ }
+ .forEach {
+ it.get()?.onVoiceCancelCall()
+ }
+ }
+ }
+ }
+}
+
+typealias onCmdAgree = ((Boolean) -> Unit)
+typealias onSpeedFinish = (() -> Unit)
\ No newline at end of file
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_launcher_calling_bg.9.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_launcher_calling_bg.9.png
new file mode 100644
index 0000000000..96ddb81326
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_launcher_calling_bg.9.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment.png
new file mode 100644
index 0000000000..950d184e38
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_close_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_close_normal.png
new file mode 100644
index 0000000000..12ae03bfed
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_close_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_close_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_close_pressed.png
new file mode 100644
index 0000000000..f81ff730e4
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_close_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_x.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_x.png
new file mode 100644
index 0000000000..f7530c5024
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_fragment_x.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_head_default.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_head_default.png
new file mode 100644
index 0000000000..eacbf33bf8
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_head_default.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_join_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_join_normal.png
new file mode 100644
index 0000000000..6f301e97ab
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_join_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_join_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_join_pressed.png
new file mode 100644
index 0000000000..6f5411a704
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_join_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_refuse_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_refuse_normal.png
new file mode 100644
index 0000000000..ee7fbb5dfe
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_refuse_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_refuse_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_refuse_pressed.png
new file mode 100644
index 0000000000..0b1873ee8f
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_hawk_eye_refuse_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_head_default.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_head_default.png
new file mode 100644
index 0000000000..4a891e57e5
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_head_default.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_join_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_join_normal.png
new file mode 100644
index 0000000000..acf19225e1
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_join_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_join_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_join_pressed.png
new file mode 100644
index 0000000000..d13ff23373
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_join_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_refuse_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_refuse_normal.png
new file mode 100644
index 0000000000..f7530c5024
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_refuse_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_refuse_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_refuse_pressed.png
new file mode 100644
index 0000000000..950d184e38
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_invitation_refuse_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_quit_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_quit_normal.png
new file mode 100644
index 0000000000..0bd4b588e1
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_quit_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_quit_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_quit_pressed.png
new file mode 100644
index 0000000000..8954c0a15e
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-hdpi/module_carchatting_team_quit_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_launcher_calling_bg.9.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_launcher_calling_bg.9.png
new file mode 100644
index 0000000000..fa35eccafd
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_launcher_calling_bg.9.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment.png
new file mode 100644
index 0000000000..b04650a030
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_close_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_close_normal.png
new file mode 100644
index 0000000000..12ae03bfed
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_close_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_close_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_close_pressed.png
new file mode 100644
index 0000000000..f81ff730e4
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_close_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_x.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_x.png
new file mode 100644
index 0000000000..f274a5fa76
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_fragment_x.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_head_default.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_head_default.png
new file mode 100644
index 0000000000..53051d4e9e
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_head_default.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_join_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_join_normal.png
new file mode 100644
index 0000000000..cf3e4aa222
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_join_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_join_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_join_pressed.png
new file mode 100644
index 0000000000..b5a28f5583
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_join_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_refuse_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_refuse_normal.png
new file mode 100644
index 0000000000..f274a5fa76
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_refuse_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_refuse_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_refuse_pressed.png
new file mode 100644
index 0000000000..b04650a030
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_invitation_refuse_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_quit_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_quit_normal.png
new file mode 100644
index 0000000000..f22c026f58
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_quit_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_quit_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_quit_pressed.png
new file mode 100644
index 0000000000..a1f1234504
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-mdpi/module_carchatting_team_quit_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_launcher_calling_bg.9.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_launcher_calling_bg.9.png
new file mode 100644
index 0000000000..96ddb81326
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_launcher_calling_bg.9.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_launcher_hawk_eye_calling_bg.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_launcher_hawk_eye_calling_bg.png
new file mode 100644
index 0000000000..2357cb985b
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_launcher_hawk_eye_calling_bg.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_bg.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_bg.png
new file mode 100644
index 0000000000..c2c244c134
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_bg.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_head_default.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_head_default.png
new file mode 100644
index 0000000000..eacbf33bf8
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_head_default.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_join_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_join_normal.png
new file mode 100644
index 0000000000..6f301e97ab
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_join_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_join_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_join_pressed.png
new file mode 100644
index 0000000000..6f5411a704
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_join_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_refuse_normal.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_refuse_normal.png
new file mode 100644
index 0000000000..ee7fbb5dfe
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_refuse_normal.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_refuse_pressed.png b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_refuse_pressed.png
new file mode 100644
index 0000000000..0b1873ee8f
Binary files /dev/null and b/core/function-impl/mogo-core-function-chat/src/main/res/drawable-xhdpi/module_carchatting_team_invitation_hawk_eye_refuse_pressed.png differ
diff --git a/core/function-impl/mogo-core-function-chat/src/main/res/drawable/module_callchatting_shape_gradient_blue.xml b/core/function-impl/mogo-core-function-chat/src/main/res/drawable/module_callchatting_shape_gradient_blue.xml
new file mode 100644
index 0000000000..be1941fa09
--- /dev/null
+++ b/core/function-impl/mogo-core-function-chat/src/main/res/drawable/module_callchatting_shape_gradient_blue.xml
@@ -0,0 +1,5 @@
+
+
+