unknownBigTargetAhead.go 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  1. package main
  2. import (
  3. "cicv-data-closedloop/pjisuv_msgs"
  4. "fmt"
  5. "math"
  6. )
  7. func Topic() string {
  8. return "/tpperception"
  9. }
  10. // Label todo 禁止存在下划线_
  11. func Label() string {
  12. return "UnknownBigTargetAhead"
  13. }
  14. type Object struct {
  15. ID uint32
  16. StableFrame int
  17. LastExistingTime float64
  18. }
  19. var objectsStability = make(map[uint32]Object)
  20. // typeCheck 目标物类型检测
  21. // × 金龙车:CAR_TYPE=0, TRUCK_TYPE=1, PEDESTRIAN_TYPE=2, CYCLIST_TYPE=3, UNKNOWN_TYPE=4, UNKNOWN_MOVABLE_TYPE=5, UNKNOWN_UNMOVABLE_TYPE=6
  22. // √ 多功能车:UNKNOWN TYPE=O, PEDESTRIAN TYPE=1, CAR TYPE=2, TRUCK TYPE=3, Bicycle TYPE=4, Tricycle TYPE=5, Traffic Cone TYPE=6
  23. func typeCheck(obj *pjisuv_msgs.PerceptionObject) bool {
  24. const targetType uint8 = 0
  25. return targetType == obj.Type
  26. }
  27. // sizeCheck 目标物大小检测
  28. func sizeCheck(obj *pjisuv_msgs.PerceptionObject) bool {
  29. // 多功能车
  30. const targetMinLength = 3.6 // m
  31. const targetMinWidth = 1.605 // m
  32. const targetMinHeight = 1.995 // m
  33. // 金龙车
  34. //targetMinLength := 5.99
  35. //targetMinWidth := 2.065
  36. //targetMinHeight := 2.82
  37. // 至少满足两个条件
  38. counter := 0
  39. if obj.Length >= targetMinLength {
  40. counter++
  41. }
  42. if obj.Width >= targetMinWidth {
  43. counter++
  44. }
  45. if obj.Height >= targetMinHeight {
  46. counter++
  47. }
  48. return counter > 1
  49. }
  50. // posCheck 判断目标物位置关系
  51. func posCheck(obj *pjisuv_msgs.PerceptionObject) bool {
  52. const laneWidth = 3.5 // m
  53. return obj.X > 0 && math.Abs(float64(obj.Y)) < laneWidth*1.5
  54. }
  55. // Rule 检测前方未知大目标物
  56. func Rule(msg *pjisuv_msgs.PerceptionObjects) string {
  57. defer func() {
  58. if r := recover(); r != nil {
  59. fmt.Println(fmt.Sprintf("Recovered from panic: [%s], [%#v]", Label(), r))
  60. }
  61. }()
  62. const MinStableFrameCount = 5 // frame
  63. const MaxTimeBetweenFrame = 0.5 // second
  64. for _, obj := range msg.Objs {
  65. // 判断目标物是否满足筛选条件
  66. if typeCheck(&obj) && posCheck(&obj) && sizeCheck(&obj) {
  67. // 目标物初见存档
  68. if prevObjRecord, exists := objectsStability[obj.Id]; exists == false {
  69. objectsStability[obj.Id] = Object{
  70. ID: obj.Id,
  71. StableFrame: 1,
  72. LastExistingTime: msg.Header.TimeStamp,
  73. }
  74. } else {
  75. currObjRecord := Object{
  76. ID: obj.Id,
  77. StableFrame: 1,
  78. LastExistingTime: msg.Header.TimeStamp,
  79. }
  80. // 目标物确认/更新/重置
  81. if currObjRecord.LastExistingTime-prevObjRecord.LastExistingTime <= MaxTimeBetweenFrame { // 目标物消失不超过0.5s
  82. currObjRecord.StableFrame = prevObjRecord.StableFrame + 1
  83. if currObjRecord.StableFrame == MinStableFrameCount {
  84. delete(objectsStability, obj.Id)
  85. return Label()
  86. }
  87. }
  88. objectsStability[obj.Id] = currObjRecord
  89. }
  90. }
  91. }
  92. return ""
  93. }