yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[6.7.0] finish the func of car

Browse Source
This commit is contained in:
EmArrow
2024-09-25 21:17:52 +08:00
parent 6f05f9247b
commit 24d820cc64
35 changed files with 180 additions and 367 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/aicloud/AiCloudSocketBizProvider.kt
View File

@@ -1,28 +0,0 @@
package com.mogo.eagle.core.function.datacenter.aicloud
import android.content.Context
import com.alibaba.android.arouter.facade.annotation.Route
import com.mogo.cloud.socket.SocketManager
import com.mogo.eagle.core.data.constants.MogoServicePaths
import com.mogo.eagle.core.function.api.base.IMoGoFunctionServerProvider
@Route(path = MogoServicePaths.PATH_AI_CLOUD)
class AiCloudSocketBizProvider : IMoGoFunctionServerProvider {
override val functionName: String
get() = "AiCloudSocketBizProvider"
override fun init(context: Context?) {
context?.let {
SocketManager.getInstance().registerOnMessageListener(401012, V2XMessageListener401012())
SocketManager.getInstance().registerOnMessageListener(401018, V2XMessageListener401018())
SocketManager.getInstance().registerOnMessageListener(402000, V2XMessageListener402000())
SocketManager.getInstance().registerOnMessageListener(404000, V2XMessageListener404000())
//SocketManager.getInstance().registerOnMessageListener(503000, V2XMessageListener503000())
SocketManager.getInstance().registerOnMessageListener(70001, V2XMessageListener70001())
}
}
override fun onDestroy() {
}
}

96
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/aicloud/V2XMessageListener.kt
View File

@@ -1,96 +0,0 @@
package com.mogo.eagle.core.function.datacenter.aicloud
import com.mogo.cloud.socket.IMogoCloudSocketOnMessageListener
import com.mogo.eagle.core.data.v2x.*
import com.mogo.eagle.core.function.call.cloud.CallerCloudListenerManager
import roadwork.Road
internal class V2XMessageListener70001: IMogoCloudSocketOnMessageListener<V2XRoadXData> {
override fun target(msgType: Int): Class<V2XRoadXData> = V2XRoadXData::class.java
override fun onMsgReceived(msgType: Int, data: V2XRoadXData?) {
if (msgType != 70001) {
return
}
if (data == null) {
return
}
CallerCloudListenerManager.invokeSocketAck(V2XEvent.RoadEventX(data = data))
}
}
internal class V2XMessageListener401012: IMogoCloudSocketOnMessageListener<V2XMarkerCardResult> {
override fun target(msgType: Int): Class<V2XMarkerCardResult> = V2XMarkerCardResult::class.java
override fun onMsgReceived(msgType: Int, data: V2XMarkerCardResult?) {
if (msgType != 401012) {
return
}
if (data == null) {
return
}
CallerCloudListenerManager.invokeSocketAck(V2XEvent.Road(data = data))
}
}
internal class V2XMessageListener401018: IMogoCloudSocketOnMessageListener<V2XWarningTarget> {
override fun target(msgType: Int): Class<V2XWarningTarget> = V2XWarningTarget::class.java
override fun onMsgReceived(msgType: Int, data: V2XWarningTarget?) {
if (msgType != 401018) {
return
}
if (data == null) {
return
}
CallerCloudListenerManager.invokeSocketAck(V2XEvent.Warning(data = data))
}
}
internal class V2XMessageListener402000: IMogoCloudSocketOnMessageListener<V2XOptimalRoute> {
override fun target(msgType: Int): Class<V2XOptimalRoute> = V2XOptimalRoute::class.java
override fun onMsgReceived(msgType: Int, data: V2XOptimalRoute?) {
if (msgType != 402000) {
return
}
if (data == null) {
return
}
CallerCloudListenerManager.invokeSocketAck(V2XEvent.OptimalRoute(data = data))
}
}
internal class V2XMessageListener404000: IMogoCloudSocketOnMessageListener<V2XAdvanceWarning> {
override fun target(msgType: Int): Class<V2XAdvanceWarning> = V2XAdvanceWarning::class.java
override fun onMsgReceived(msgType: Int, data: V2XAdvanceWarning?) {
if (msgType != 404000) {
return
}
if (data == null) {
return
}
CallerCloudListenerManager.invokeSocketAck(V2XEvent.ForwardsWarning(data = data))
}
}
internal class V2XMessageListener503000: IMogoCloudSocketOnMessageListener<Road.RW_PB> {
override fun target(msgType: Int): Class<Road.RW_PB> = Road.RW_PB::class.java
override fun onMsgReceived(msgType: Int, data: Road.RW_PB?) {
if (msgType != 503000) {
return
}
if (data == null) {
return
}
CallerCloudListenerManager.invokeSocketAck(V2XEvent.RoadAI(data = data))
}
}

34
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/biz/DataCenterBizProvider.kt Normal file
View File

@@ -0,0 +1,34 @@
package com.mogo.eagle.core.function.datacenter.biz
import android.content.Context
import com.alibaba.android.arouter.facade.annotation.Route
import com.mogo.eagle.core.data.constants.MogoServicePaths
import com.mogo.eagle.core.data.enums.Carmodel
import com.mogo.eagle.core.function.api.datacenter.IDataCenterBizProvider
import com.mogo.eagle.core.function.call.datacenter.CallerDataCenterBizListener
@Route(path = MogoServicePaths.PATH_DATA_CENTER_BIZ_FUNCTION)
class DataCenterBizProvider:IDataCenterBizProvider {
override val functionName: String
get() = "DataCenterBizProvider"
override fun init(context: Context?) {
}
override fun notifyCarMode(carModel: Carmodel) {
CallerDataCenterBizListener.invokeCarRes(carModel.resId)
}
override fun notifyPlateNumber(plateNumber: String?) {
CallerDataCenterBizListener.invokeCarNo(plateNumber)
}
override fun onDestroy() {
}
}

1
core/function-impl/mogo-core-function-datacenter/src/main/java/com/mogo/eagle/core/function/datacenter/v2x/SpeedLimitDispatcher.kt
View File

@@ -31,7 +31,6 @@ class SpeedLimitDispatcher : ILimitingVelocityListener {
/**
* 地图限速数据
*/
// @BizConfig(FuncBizConfig.V2I, "", FuncBizConfig.BIZ_SLW) //todo emArrow 重新考虑放的位置
override fun onUnion(limitingVelocity: Int, sourceType: DataSourceType) {
super.onUnion(limitingVelocity, sourceType)
when (sourceType) { // obu 优先级高于 map，体现链路能力