|
|
@@ -200,7 +200,10 @@ func RunWaitingCluster() {
|
|
|
s1, s2, s3, s4, xodrPath, osgbPath := util.ParseXosc(xoscLocalPath)
|
|
|
firstTaskCache.Task.Scenario.ScenarioOdr = xodrPath
|
|
|
firstTaskCache.Task.Scenario.ScenarioOsgb = osgbPath
|
|
|
-
|
|
|
+ // ------- 修改OGT传感器显示目标物框 -------
|
|
|
+ for i := range firstTaskCache.Task.Vehicle.Sensors.OGT {
|
|
|
+ firstTaskCache.Task.Vehicle.Sensors.OGT[i].SensorDisplay = true
|
|
|
+ }
|
|
|
// --------------- 发送 kafka 消息（获取偏移量和分区） ---------------
|
|
|
// 获取任务消息转json
|
|
|
firstTaskCache.Task.Vehicle.Sensors.Camera = global.DefaultCameras
|
|
|
@@ -209,10 +212,7 @@ func RunWaitingCluster() {
|
|
|
infra.GlobalLogger.Error(err)
|
|
|
continue
|
|
|
}
|
|
|
- // ------- 修改OGT传感器显示目标物框 -------
|
|
|
- for i := range firstTaskCache.Task.Vehicle.Sensors.OGT {
|
|
|
- firstTaskCache.Task.Vehicle.Sensors.OGT[i].SensorDisplay = true
|
|
|
- }
|
|
|
+
|
|
|
// ------- 发送 -------
|
|
|
topic := projectId
|
|
|
// 创建一个Message，并指定分区为0
|
