package main import ( "cicv-data-closedloop/pjisuv_msgs" "fmt" "math" "sync" ) type Point struct { Latitude float64 Longitude float64 } var ( threshold float64 = 5 IsCurve bool count1 int64 //定义园区T字路口的经纬度坐标值 point3 = Point{39.73040966605621, 116.48995329696209} point4 = Point{39.73083727413453, 116.49079780188244} point5 = Point{39.72976753711939, 116.49043130389033} point6 = Point{39.73012466515933, 116.49128381717591} point7 = Point{39.729251498328246, 116.49077484625299} point8 = Point{39.72964529630643, 116.49164592200161} pointlist = []Point{point3, point4, point5, point6, point7, point8} ) func Topic() string { return "/cicv_location" } // 禁止存在下划线_ func Label() string { return "JunctionOverspeed" } func IfEnter(pointlist []Point, radius float64, lat, lon float64) bool { // 判断是否进入点列表中的区域 point1 := Point{Latitude: lat, Longitude: lon} for _, point := range pointlist { d := distance(point1, point) if d <= radius { return true } } return false } // 计算两点之间的距离(米) func distance(point1, point2 Point) float64 { // 经纬度转弧度 lat1 := point1.Latitude * math.Pi / 180 lon1 := point1.Longitude * math.Pi / 180 lat2 := point2.Latitude * math.Pi / 180 lon2 := point2.Longitude * math.Pi / 180 // 计算距离 dlon := lon2 - lon1 dlat := lat2 - lat1 a := math.Sin(dlat/2)*math.Sin(dlat/2) + math.Sin(dlon/2)*math.Sin(dlon/2)*math.Cos(lat1)*math.Cos(lat2) c := 2 * math.Atan2(math.Sqrt(a), math.Sqrt(1-a)) d := 6371000 * c return d } func Rule(shareVars *sync.Map, data *pjisuv_msgs.PerceptionLocalization) string { defer func() { if r := recover(); r != nil { fmt.Println("Recovered from panic:", r) } }() if count1%10 == 0 { Automode, _ := shareVars.Load("AutomodeOfPjVehicleFdbPub") Automode = Automode.(int16) IsCurve = IfEnter(pointlist, 16.0, data.Latitude, data.Longitude) if Automode == 1 && IsCurve { absspeed := math.Sqrt(math.Pow(data.VelocityX, 2) + math.Pow(data.VelocityY, 2)) if absspeed >= threshold { eventLabel := "JunctionOverspeed" fmt.Println(eventLabel) count1 = 1 return Label() } } } count1++ return "" }