TrafficCongestion.go 988 B

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. package main
  2. import (
  3. "cicv-data-closedloop/pjisuv_msgs"
  4. "fmt"
  5. "math"
  6. "sync"
  7. )
  8. func Topic() string {
  9. return "/tpperception"
  10. }
  11. // Label todo 禁止存在下划线_
  12. func Label() string {
  13. return "TrafficCongestion"
  14. }
  15. func Rule(shareVars *sync.Map, data *pjisuv_msgs.PerceptionObjects) string {
  16. NumTargets := 0
  17. defer func() {
  18. if r := recover(); r != nil {
  19. fmt.Println("Recovered from panic:", r)
  20. }
  21. }()
  22. velocityXOfCicvLocation, ok := shareVars.Load("VelocityXOfCicvLocation")
  23. OutsideWorkshopFlag, ok1 := shareVars.Load("OutsideWorkshopFlag")
  24. OutsideWorkshopFlag = OutsideWorkshopFlag.(bool)
  25. if ok && ok1 {
  26. if velocityXOfCicvLocation.(float64) < 3.5 && len(data.Objs) > 3 {
  27. for _, obj := range data.Objs {
  28. if (obj.Type == 2 || obj.Type == 3) && math.Abs(float64(obj.Y)) <= 2.5 && math.Abs(float64(obj.X)) <= 20 && obj.Speed <= 4 {
  29. NumTargets++
  30. }
  31. }
  32. if NumTargets >= 3 && OutsideWorkshopFlag == true {
  33. return Label()
  34. }
  35. }
  36. }
  37. return ""
  38. }