commit

aarch64/pjisuv/common/service/rosbag_upload.go

@@ -108,12 +108,14 @@ outLoop:
 			startOne := time.Now()
 			bagSlice := strings.Split(bag, "/")
 			for {
-				commonConfig.OssMutex.Lock()
+				{
-				err := commonConfig.OssBucket.PutObjectFromFile(objectKey1+bagSlice[len(bagSlice)-1], bag)
+					//commonConfig.OssMutex.Lock()
-				commonConfig.OssMutex.Unlock()
+					//err := commonConfig.OssBucket.PutObjectFromFile(objectKey1+bagSlice[len(bagSlice)-1], bag)
-				if err != nil {
+					//commonConfig.OssMutex.Unlock()
-					c_log.GlobalLogger.Info("因网络原因上传包 ", bag, " 时报错，需要等待网络恢复后重新上传：", err)
+					//if err != nil {
-					continue
+					//	c_log.GlobalLogger.Info("因网络原因上传包 ", bag, " 时报错，需要等待网络恢复后重新上传：", err)
+					//	continue
+					//}
 				}
 				c_log.GlobalLogger.Info("上传耗时 ", time.Since(startOne), "，【FaultTime】=", currentTimeWindow.FaultTime, "【Label】=", currentTimeWindow.Labels, "，进度", i+1, "/", bagNumber, "。【", bag, "】-------【", objectKey1+bagSlice[len(bagSlice)-1], "】")
 				break

trigger/pjisuv/cicv_location/rapidaccel/main/rapidaccel.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"cicv-data-closedloop/pjisuv_msgs"
+	"fmt"
 )
 
 func Topic() string {
@@ -13,6 +14,7 @@ func Label() string {
 }
 
 func Rule(data *pjisuv_msgs.PerceptionLocalization) string {
+	fmt.Println("当前减速度为：", data.AccelX)
 	if data.AccelX*9.8 > 2.0 {
 		return "rapidaccel"
 	} else {