commit

aarch64/pjibot_delivery/common/config/c_cloud.go

@@ -178,7 +178,7 @@ func InitCloudConfig() {
 	util.CreateDir(CloudConfig.BagCopyDir)
 }
 
-// refreshCloudConfig 更新业务配置
+// 更新业务配置
 func refreshCloudConfig() {
 	// 获取文件的目录
 	_ = util.CreateParentDir(LocalConfig.CloudConfigLocalPath)
@@ -189,6 +189,7 @@ func refreshCloudConfig() {
 	isExist, err := OssBucket.IsObjectExist(cloudConfigObjectKey)
 	if err != nil {
 		c_log.GlobalLogger.Errorf("判断配置文件是否存在失败，错误信息为：%v", err)
+		return
 	}
 	if !isExist {
 		cloudConfigObjectKey = LocalConfig.OssBasePrefix + LocalConfig.CloudConfigFilename // 默认配置文件路径
@@ -199,13 +200,13 @@ func refreshCloudConfig() {
 	OssMutex.Unlock()
 	if err != nil {
 		c_log.GlobalLogger.Error("下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
-		//os.Exit(-1)
+		return
 	}
 
 	content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
 	if err != nil {
 		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
-		os.Exit(-1)
+		return
 	}
 
 	// 4 ------- 解析YAML内容 -------
@@ -213,7 +214,7 @@ func refreshCloudConfig() {
 	err = yaml.Unmarshal(content, &newCloudConfig)
 	if err != nil {
 		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
-		os.Exit(-1)
+		return
 	}
 
 	// 5 ------- 校验 yaml -------
@@ -223,7 +224,7 @@ func refreshCloudConfig() {
 		CloudConfigMutex.RUnlock()
 	} else {
 		c_log.GlobalLogger.Error("配置文件格式错误：", newCloudConfig)
-		os.Exit(-1)
+		return
 	}
 	util.CreateDir(CloudConfig.BagDataDir)
 	util.CreateDir(CloudConfig.BagCopyDir)

aarch64/pjibot_guide/common/config/c_cloud.go

@@ -188,7 +188,7 @@ func InitCloudConfig() {
 	util.CreateDir(CloudConfig.BagCopyDir)
 }
 
-// refreshCloudConfig 更新业务配置
+// 更新业务配置
 func refreshCloudConfig() {
 	// 获取文件的目录
 	_ = util.CreateParentDir(LocalConfig.CloudConfigLocalPath)
@@ -199,6 +199,7 @@ func refreshCloudConfig() {
 	isExist, err := OssBucket.IsObjectExist(cloudConfigObjectKey)
 	if err != nil {
 		c_log.GlobalLogger.Errorf("判断配置文件是否存在失败，错误信息为：%v", err)
+		return
 	}
 	if !isExist {
 		cloudConfigObjectKey = LocalConfig.OssBasePrefix + LocalConfig.CloudConfigFilename // 默认配置文件路径
@@ -209,13 +210,12 @@ func refreshCloudConfig() {
 	OssMutex.Unlock()
 	if err != nil {
 		c_log.GlobalLogger.Error("下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
-		//os.Exit(-1)
 	}
 
 	content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
 	if err != nil {
 		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
-		os.Exit(-1)
+		return
 	}
 
 	// 4 ------- 解析YAML内容 -------
@@ -223,7 +223,7 @@ func refreshCloudConfig() {
 	err = yaml.Unmarshal(content, &newCloudConfig)
 	if err != nil {
 		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
-		os.Exit(-1)
+		return
 	}
 
 	// 5 ------- 校验 yaml -------
@@ -233,11 +233,10 @@ func refreshCloudConfig() {
 		CloudConfigMutex.RUnlock()
 	} else {
 		c_log.GlobalLogger.Error("配置文件格式错误：", newCloudConfig)
-		os.Exit(-1)
+		return
 	}
 	util.CreateDir(CloudConfig.BagDataDir)
 	util.CreateDir(CloudConfig.BagCopyDir)
-
 }
 
 // RefreshCloudConfig 轮询oss上的配置文件更新到本地

aarch64/pjibot_guide/common/service/rosbag_upload.go

@@ -161,10 +161,15 @@ outLoop:
 			err = util.ZipDir(commonConfig.CloudConfig.DataDir.Src, commonConfig.CloudConfig.DataDir.Dest, commonConfig.CloudConfig.DataDir.Exclude)
 			if err != nil {
 				c_log.GlobalLogger.Error("压缩data目录失败：", err)
+			} else {
+				c_log.GlobalLogger.Infof("压缩data目录【%v】->【%v】成功", commonConfig.CloudConfig.DataDir.Src, commonConfig.CloudConfig.DataDir.Dest)
 			}
-			err = commonConfig.OssBucket.PutObjectFromFile(objectKey3+"data.zip", commonConfig.CloudConfig.DataDir.Dest)
+			dataZipKey := objectKey3 + "data.zip"
+			err = commonConfig.OssBucket.PutObjectFromFile(dataZipKey, commonConfig.CloudConfig.DataDir.Dest)
 			if err != nil {
 				c_log.GlobalLogger.Error("上传 data 目录压缩文件失败：", err)
+			} else {
+				c_log.GlobalLogger.Infof("上传data目录压缩包【%v】->【%v】成功", commonConfig.CloudConfig.DataDir.Dest, dataZipKey)
 			}
 			commonConfig.OssMutex.Unlock()
 		}

aarch64/pjibot_patrol/common/config/c_cloud.go

@@ -178,7 +178,7 @@ func InitCloudConfig() {
 	util.CreateDir(CloudConfig.BagCopyDir)
 }
 
-// refreshCloudConfig 更新业务配置
+// 更新业务配置
 func refreshCloudConfig() {
 	// 获取文件的目录
 	_ = util.CreateParentDir(LocalConfig.CloudConfigLocalPath)
@@ -205,7 +205,7 @@ func refreshCloudConfig() {
 	content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
 	if err != nil {
 		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
-		os.Exit(-1)
+		return
 	}
 
 	// 4 ------- 解析YAML内容 -------
@@ -213,7 +213,7 @@ func refreshCloudConfig() {
 	err = yaml.Unmarshal(content, &newCloudConfig)
 	if err != nil {
 		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
-		os.Exit(-1)
+		return
 	}
 
 	// 5 ------- 校验 yaml -------
@@ -223,7 +223,7 @@ func refreshCloudConfig() {
 		CloudConfigMutex.RUnlock()
 	} else {
 		c_log.GlobalLogger.Error("配置文件格式错误：", newCloudConfig)
-		os.Exit(-1)
+		return
 	}
 	util.CreateDir(CloudConfig.BagDataDir)
 	util.CreateDir(CloudConfig.BagCopyDir)

aarch64/pjisuv/common/config/c_cloud.go

@@ -141,7 +141,7 @@ func InitCloudConfig() {
 	}
 }
 
-// RefreshCloudConfig 刷新配置文件
+// 刷新配置文件
 func refreshCloudConfig() {
 	// 获取文件的目录
 	_ = util.CreateParentDir(LocalConfig.CloudConfigLocalPath)
@@ -152,6 +152,7 @@ func refreshCloudConfig() {
 	isExist, err := OssBucket.IsObjectExist(cloudConfigObjectKey)
 	if err != nil {
 		c_log.GlobalLogger.Errorf("判断配置文件是否存在失败，错误信息为：%v", err)
+		return
 	}
 	if !isExist {
 		cloudConfigObjectKey = LocalConfig.OssBasePrefix + LocalConfig.CloudConfigFilename // 默认配置文件路径