|
@@ -161,6 +161,26 @@ func RunWaitingCluster() {
|
|
|
|
|
|
|
|
// --------------- 发送 kafka 消息（获取偏移量和分区） ---------------
|
|
// --------------- 发送 kafka 消息（获取偏移量和分区） ---------------
|
|
|
// 获取任务消息转json
|
|
// 获取任务消息转json
|
|
|
|
|
+ // todo 将摄像头写死一个参数
|
|
|
|
|
+ firstTaskCache.Task.Vehicle.Sensors.Camera = []entity.SensorCamera{
|
|
|
|
|
+ {
|
|
|
|
|
+ Sensor: entity.Sensor{
|
|
|
|
|
+ SensorName: "custom_camera",
|
|
|
|
|
+ SensorNear: 1.0,
|
|
|
|
|
+ SensorFar: 1500.0,
|
|
|
|
|
+ SensorX: -15000.0,
|
|
|
|
|
+ SensorY: 0.0,
|
|
|
|
|
+ SensorZ: 5000.0,
|
|
|
|
|
+ SensorH: 0.0,
|
|
|
|
|
+ SensorP: 10.0,
|
|
|
|
|
+ SensorR: 0.0,
|
|
|
|
|
+ },
|
|
|
|
|
+ SensorForH: 45,
|
|
|
|
|
+ SensorForV: 27,
|
|
|
|
|
+ SensorResolution: "480*270",
|
|
|
|
|
+ SensorFrameRate: 25,
|
|
|
|
|
+ },
|
|
|
|
|
+ }
|
|
|
taskJson, err := TaskToJson(firstTaskCache.Task)
|
|
taskJson, err := TaskToJson(firstTaskCache.Task)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
infra.GlobalLogger.Error(err)
|
|
infra.GlobalLogger.Error(err)
|
