commit

pji/common/cfg/cloud_cfg.go

@@ -1,8 +1,8 @@
 package cfg
 
 import (
+	"cicv-data-closedloop/common/config/c_log"
 	"cicv-data-closedloop/pji/common/cutil"
-	"cicv-data-closedloop/pji/common/log"
 	"gopkg.in/yaml.v3"
 	"os"
 	"sync"
@@ -54,7 +54,7 @@ var (
 
 // InitCloudConfig 初始化业务配置
 func InitCloudConfig() {
-	log.GlobalLogger.Info("初始化OSS配置文件 - 开始。")
+	c_log.GlobalLogger.Info("初始化OSS配置文件 - 开始。")
 	// 获取文件的目录
 	cutil.CreateParentDir(LocalConfig.CloudConfigLocalPath)
 	// 3 ------- 获取 yaml 字符串 -------
@@ -62,13 +62,13 @@ func InitCloudConfig() {
 	cloudConfigObjectKey := LocalConfig.OssBasePrefix + LocalConfig.EquipmentNo + "/" + LocalConfig.CloudConfigFilename
 	err := OssBucket.GetObjectToFile(cloudConfigObjectKey, LocalConfig.CloudConfigLocalPath)
 	if err != nil {
-		log.GlobalLogger.Error("程序崩溃，下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
+		c_log.GlobalLogger.Error("程序崩溃，下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
 		os.Exit(-1)
 	}
 
 	content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
 	if err != nil {
-		log.GlobalLogger.Error("程序崩溃，配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
+		c_log.GlobalLogger.Error("程序崩溃，配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
 		os.Exit(-1)
 	}
 
@@ -76,7 +76,7 @@ func InitCloudConfig() {
 	var newCloudConfig cloudConfig
 	err = yaml.Unmarshal(content, &newCloudConfig)
 	if err != nil {
-		log.GlobalLogger.Error("程序崩溃，配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
+		c_log.GlobalLogger.Error("程序崩溃，配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
 		os.Exit(-1)
 	}
 
@@ -86,10 +86,10 @@ func InitCloudConfig() {
 		CloudConfig = newCloudConfig
 		CloudConfigMutex.RUnlock()
 	} else {
-		log.GlobalLogger.Error("程序崩溃，配置文件格式错误：", newCloudConfig)
+		c_log.GlobalLogger.Error("程序崩溃，配置文件格式错误：", newCloudConfig)
 		os.Exit(-1)
 	}
-	log.GlobalLogger.Info("初始化OSS配置文件 - 成功。")
+	c_log.GlobalLogger.Info("初始化OSS配置文件 - 成功。")
 	cutil.CreateDir(CloudConfig.BagDataDir)
 	cutil.CreateDir(CloudConfig.BagCopyDir)
 }
@@ -103,13 +103,13 @@ func refreshCloudConfig() {
 	cloudConfigObjectKey := LocalConfig.OssBasePrefix + LocalConfig.EquipmentNo + "/" + LocalConfig.CloudConfigFilename
 	err := OssBucket.GetObjectToFile(cloudConfigObjectKey, LocalConfig.CloudConfigLocalPath)
 	if err != nil {
-		log.GlobalLogger.Error("下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
+		c_log.GlobalLogger.Error("下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
 		//os.Exit(-1)
 	}
 
 	content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
 	if err != nil {
-		log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
+		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
 		os.Exit(-1)
 	}
 
@@ -117,7 +117,7 @@ func refreshCloudConfig() {
 	var newCloudConfig cloudConfig
 	err = yaml.Unmarshal(content, &newCloudConfig)
 	if err != nil {
-		log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
+		c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
 		os.Exit(-1)
 	}
 
@@ -127,7 +127,7 @@ func refreshCloudConfig() {
 		CloudConfig = newCloudConfig
 		CloudConfigMutex.RUnlock()
 	} else {
-		log.GlobalLogger.Error("配置文件格式错误：", newCloudConfig)
+		c_log.GlobalLogger.Error("配置文件格式错误：", newCloudConfig)
 		os.Exit(-1)
 	}
 	cutil.CreateDir(CloudConfig.BagDataDir)
@@ -145,7 +145,7 @@ func RefreshCloudConfig() {
 // CheckConfig 校验 cfg.yaml 文件
 func checkConfig(check cloudConfig) bool {
 	if len(check.Hosts) != 1 {
-		log.GlobalLogger.Error("cloud-config.yaml中配置的hosts必须为1。")
+		c_log.GlobalLogger.Error("cloud-config.yaml中配置的hosts必须为1。")
 		os.Exit(-1)
 	}
 	return true

pji/common/cfg/kill_rpc_server_cfg.go

@@ -1,7 +1,7 @@
 package cfg
 
 import (
-	"cicv-data-closedloop/pji/common/log"
+	"cicv-data-closedloop/common/config/c_log"
 	"net"
 	"os"
 )
@@ -10,12 +10,12 @@ var KillSignalListener net.Listener
 
 func InitKillSignalListener(serverIp string) {
 	var err error
-	log.GlobalLogger.Info("初始化RPC端口监听Kill信号 - 开始。")
+	c_log.GlobalLogger.Info("初始化RPC端口监听Kill信号 - 开始。")
 	socket := serverIp + ":" + CloudConfig.RpcPort
 	KillSignalListener, err = net.Listen("tcp", socket)
 	if err != nil {
-		log.GlobalLogger.Error("监听rpc端口失败:", err)
+		c_log.GlobalLogger.Error("监听rpc端口失败:", err)
 		os.Exit(-1)
 	}
-	log.GlobalLogger.Info("初始化RPC端口监听Kill信号 - 成功：", socket)
+	c_log.GlobalLogger.Info("初始化RPC端口监听Kill信号 - 成功：", socket)
 }

pji/common/cfg/local_cfg.go

@@ -1,7 +1,7 @@
 package cfg
 
 import (
-	"cicv-data-closedloop/pji/common/log"
+	"cicv-data-closedloop/common/config/c_log"
 	"gopkg.in/yaml.v2"
 	"os"
 )
@@ -23,21 +23,21 @@ var (
 )
 
 func InitLocalConfig() {
-	log.GlobalLogger.Info("初始化本地配置文件 - 开始：", localConfigPath)
+	c_log.GlobalLogger.Info("初始化本地配置文件 - 开始：", localConfigPath)
 	// 读取YAML文件内容
 	content, err := os.ReadFile(localConfigPath)
 	if err != nil {
-		log.GlobalLogger.Error("读取本地配置文件失败。", err)
+		c_log.GlobalLogger.Error("读取本地配置文件失败。", err)
 		os.Exit(-1)
 	}
 
 	// 解析YAML内容
 	err = yaml.Unmarshal(content, &LocalConfig)
 	if err != nil {
-		log.GlobalLogger.Error("解析本地配置文件失败。", err)
+		c_log.GlobalLogger.Error("解析本地配置文件失败。", err)
 		os.Exit(-1)
 	}
 
-	log.GlobalLogger.Info("初始化本地配置文件 - 成功：", LocalConfig)
+	c_log.GlobalLogger.Info("初始化本地配置文件 - 成功：", LocalConfig)
 
 }

pji/common/cfg/oss_cfg.go

@@ -1,8 +1,8 @@
 package cfg
 
 import (
+	"cicv-data-closedloop/common/config/c_log"
 	"cicv-data-closedloop/pji/common/cutil"
-	"cicv-data-closedloop/pji/common/log"
 	"encoding/json"
 	"github.com/aliyun/aliyun-oss-go-sdk/oss"
 	"os"
@@ -19,29 +19,29 @@ var OssClient *oss.Client
 var OssBucket *oss.Bucket
 
 func InitOssConfig() {
-	log.GlobalLogger.Info("初始化OSS客户端对象 - 开始。")
+	c_log.GlobalLogger.Info("初始化OSS客户端对象 - 开始。")
 	// 1 访问 HTTP 服务获取 OSS 配置
 	get, err := cutil.HttpGet(LocalConfig.UrlGetOssConfig)
 	if err != nil {
-		log.GlobalLogger.Error("http获取oss配置时出错:", err)
+		c_log.GlobalLogger.Error("http获取oss配置时出错:", err)
 		os.Exit(-1)
 	}
 	var ossConnectInfo OssConnectInfoStruct
 	err = json.Unmarshal([]byte(get), &ossConnectInfo)
 	if err != nil {
-		log.GlobalLogger.Error("解析json时出错:", err)
+		c_log.GlobalLogger.Error("解析json时出错:", err)
 		os.Exit(-1)
 	}
 
 	OssClient, err = oss.New(ossConnectInfo.Endpoint, ossConnectInfo.AccessKeyId, ossConnectInfo.AccessKeySecret, oss.UseCname(true))
 	if err != nil {
-		log.GlobalLogger.Error("无法创建阿里云client:", err)
+		c_log.GlobalLogger.Error("无法创建阿里云client:", err)
 		os.Exit(-1)
 	}
 	OssBucket, err = OssClient.Bucket(ossConnectInfo.BucketName)
 	if err != nil {
-		log.GlobalLogger.Error("无法创建阿里云bucket:", err)
+		c_log.GlobalLogger.Error("无法创建阿里云bucket:", err)
 		os.Exit(-1)
 	}
-	log.GlobalLogger.Info("初始化OSS客户端对象 - 成功。")
+	c_log.GlobalLogger.Info("初始化OSS客户端对象 - 成功。")
 }

pji/common/cfg/platform_cfg.go

@@ -1,8 +1,8 @@
 package cfg
 
 import (
+	"cicv-data-closedloop/common/config/c_log"
 	"cicv-data-closedloop/pji/common/cutil"
-	"cicv-data-closedloop/pji/common/log"
 	"encoding/json"
 	"time"
 )
@@ -38,30 +38,30 @@ var PlatformConfig platformConfig
 
 // InitPlatformConfig 初始化数据闭环平台的配置
 func InitPlatformConfig() {
-	log.GlobalLogger.Info("获取数据闭环平台配置 - 开始")
+	c_log.GlobalLogger.Info("获取数据闭环平台配置 - 开始")
 	// 1 如果车辆没有配置任务，则阻塞在这里，不启动任务
 	for {
 		time.Sleep(time.Duration(1))
-		log.GlobalLogger.Info("获取数据闭环平台配置 - 进行中")
+		c_log.GlobalLogger.Info("获取数据闭环平台配置 - 进行中")
 		status, err := GetStatus("")
 		if err != nil {
-			log.GlobalLogger.Error("获取配置status失败：", err)
+			c_log.GlobalLogger.Error("获取配置status失败：", err)
 			continue
 		}
 		// 判断是否有配置，第一次访问状态应该为：CHANGE（一共三种状态 CHANGE|UNCHANGE|NONE）
 		if status == "CHANGE" {
 			PlatformConfig, err = getConfig()
 			if err != nil {
-				log.GlobalLogger.Error("获取配置status失败：", err)
+				c_log.GlobalLogger.Error("获取配置status失败：", err)
 				continue
 			} else {
 				break
 			}
 		} else {
-			log.GlobalLogger.Error("车辆没有配置采集任务，等待平台配置。status=", status)
+			c_log.GlobalLogger.Error("车辆没有配置采集任务，等待平台配置。status=", status)
 		}
 	}
-	log.GlobalLogger.Info("获取数据闭环平台配置 - 成功。")
+	c_log.GlobalLogger.Info("获取数据闭环平台配置 - 成功。")
 }
 
 /*
@@ -91,13 +91,13 @@ func GetAccessToken() (string, error) {
 	}
 	respMap, err := cutil.JsonStringToMap(respJson)
 	if err != nil {
-		log.GlobalLogger.Error("解析返回结果", respJson, "失败：", err)
+		c_log.GlobalLogger.Error("解析返回结果", respJson, "失败：", err)
 		return "", nil
 	}
 
 	dataMap := respMap["data"].(map[string]interface{})
 	if err != nil {
-		log.GlobalLogger.Error("解析返回结果.data", dataMap, "失败：", err)
+		c_log.GlobalLogger.Error("解析返回结果.data", dataMap, "失败：", err)
 		return "", nil
 	}
 	return dataMap["accessToken"].(string), nil
@@ -133,17 +133,17 @@ func GetStatus(taskConfigId string) (string, error) {
 	)
 
 	if err != nil {
-		log.GlobalLogger.Error("访问接口", CloudConfig.Platform.UrlTask, "失败：", err)
+		c_log.GlobalLogger.Error("访问接口", CloudConfig.Platform.UrlTask, "失败：", err)
 		return "", err
 	}
 	respMap, err := cutil.JsonStringToMap(resp)
 	if err != nil {
-		log.GlobalLogger.Error("解析【返回结果1】", resp, "失败：", err)
+		c_log.GlobalLogger.Error("解析【返回结果1】", resp, "失败：", err)
 		return "", err
 	}
 	dataMap := respMap["data"].(map[string]interface{})
 	if err != nil {
-		log.GlobalLogger.Error("解析【返回结果.data】", dataMap, "失败：", err)
+		c_log.GlobalLogger.Error("解析【返回结果.data】", dataMap, "失败：", err)
 		return "", err
 	}
 	return dataMap["status"].(string), nil
@@ -166,13 +166,13 @@ func getConfig() (platformConfig, error) {
 		},
 	)
 	if err != nil {
-		log.GlobalLogger.Error("访问接口", CloudConfig.Platform.UrlTask, "失败：", err)
+		c_log.GlobalLogger.Error("访问接口", CloudConfig.Platform.UrlTask, "失败：", err)
 		return platformConfig{}, err
 	}
 	var result response
 	err = json.Unmarshal([]byte(resp), &result)
 	if err != nil {
-		log.GlobalLogger.Error("解析【返回结果】", resp, "失败：", err)
+		c_log.GlobalLogger.Error("解析【返回结果】", resp, "失败：", err)
 		return platformConfig{}, err
 	}
 	return result.Data, nil

pji/common/cfg/ros_cfg.go

@@ -1,8 +1,8 @@
 package cfg
 
 import (
+	"cicv-data-closedloop/common/config/c_log"
 	"cicv-data-closedloop/pji/common/cutil"
-	"cicv-data-closedloop/pji/common/log"
 	"github.com/bluenviron/goroslib/v2"
 	"os"
 )
@@ -10,15 +10,15 @@ import (
 var RosNode *goroslib.Node
 
 func InitRosConfig() {
-	log.GlobalLogger.Info("初始化RosNode - 开始")
+	c_log.GlobalLogger.Info("初始化RosNode - 开始")
 	var err error
 	RosNode, err = goroslib.NewNode(goroslib.NodeConf{
 		Name:          "node" + cutil.GetNowTimeCustom(),
 		MasterAddress: CloudConfig.Ros.MasterAddress,
 	})
 	if err != nil {
-		log.GlobalLogger.Error("初始化RosNode - 失败：", err)
+		c_log.GlobalLogger.Error("初始化RosNode - 失败：", err)
 		os.Exit(-1)
 	}
-	log.GlobalLogger.Info("初始化RosNode - 成功：", CloudConfig.Ros.MasterAddress)
+	c_log.GlobalLogger.Info("初始化RosNode - 成功：", CloudConfig.Ros.MasterAddress)
 }