c_cloud.go 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155
  1. package config
  2. import (
  3. "cicv-data-closedloop/common/config/c_log"
  4. "cicv-data-closedloop/common/util"
  5. "gopkg.in/yaml.v3"
  6. "os"
  7. "sync"
  8. "time"
  9. )
  10. type Platform struct {
  11. UrlDeviceAuth string `yaml:"url-device-auth"`
  12. UrlTaskPoll string `yaml:"url-task-poll"`
  13. UrlTask string `yaml:"url-task"`
  14. }
  15. type Host struct {
  16. Name string `yaml:"name"`
  17. Ip string `yaml:"ip"`
  18. Topics []string `yaml:"topics"`
  19. }
  20. type Ros struct {
  21. MasterAddress string `yaml:"master-address"`
  22. Nodes []string `yaml:"nodes"`
  23. }
  24. type cloudConfig struct {
  25. FullCollect bool `yaml:"full-collect"`
  26. ConfigRefreshInterval int `yaml:"config-refresh-interval"` // 配置刷新时间间隔
  27. BagNumber int `yaml:"bag-number"`
  28. TimeWindowSendGap int `yaml:"time-window-send-gap"` // 主节点向从节点发送窗口的最小时间间隔
  29. DiskUsage float64 `yaml:"disk-usage"`
  30. TimeToLabelJsonPath string `yaml:"time-to-label-json-path"`
  31. BagDataDir string `yaml:"bag-data-dir"`
  32. BagCopyDir string `yaml:"bag-copy-dir"`
  33. TriggersDir string `yaml:"triggers-dir"`
  34. TcpPort string `yaml:"tcp-port"`
  35. RpcPort string `yaml:"rpc-port"`
  36. Triggers []Trigger `yaml:"triggers"`
  37. Hosts []Host `yaml:"hosts"`
  38. Ros Ros `yaml:"ros"`
  39. Platform Platform `yaml:"platform"`
  40. }
  41. type Trigger struct {
  42. Label string `yaml:"label"`
  43. Topics []string `yaml:"topics"`
  44. }
  45. var (
  46. CloudConfig cloudConfig
  47. CloudConfigMutex sync.RWMutex
  48. )
  49. // InitCloudConfig 初始化业务配置
  50. func InitCloudConfig() {
  51. c_log.GlobalLogger.Info("初始化OSS配置文件 - 开始。")
  52. // 获取文件的目录
  53. _ = util.CreateParentDir(LocalConfig.CloudConfigLocalPath)
  54. // 3 ------- 获取 yaml 字符串 -------
  55. var content []byte
  56. cloudConfigObjectKey := LocalConfig.OssBasePrefix + LocalConfig.EquipmentNo + "/" + LocalConfig.CloudConfigFilename
  57. err := OssBucket.GetObjectToFile(cloudConfigObjectKey, LocalConfig.CloudConfigLocalPath)
  58. if err != nil {
  59. c_log.GlobalLogger.Error("下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
  60. os.Exit(-1)
  61. }
  62. content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
  63. if err != nil {
  64. c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
  65. os.Exit(-1)
  66. }
  67. // 4 ------- 解析YAML内容 -------
  68. var newCloudConfig cloudConfig
  69. err = yaml.Unmarshal(content, &newCloudConfig)
  70. if err != nil {
  71. c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
  72. os.Exit(-1)
  73. }
  74. // 5 ------- 校验 yaml -------
  75. if checkConfig(newCloudConfig) {
  76. CloudConfigMutex.RLock()
  77. CloudConfig = newCloudConfig
  78. CloudConfigMutex.RUnlock()
  79. } else {
  80. c_log.GlobalLogger.Error("配置文件格式错误:", newCloudConfig)
  81. os.Exit(-1)
  82. }
  83. c_log.GlobalLogger.Info("初始化OSS配置文件 - 成功。")
  84. _ = util.CreateDir(CloudConfig.BagDataDir)
  85. _ = util.CreateDir(CloudConfig.BagCopyDir)
  86. timeToLabelJson, _ := util.MapToJsonString(map[string]interface{}{"time": "label"})
  87. _ = util.WriteFile(timeToLabelJson, CloudConfig.TimeToLabelJsonPath)
  88. }
  89. // RefreshCloudConfig 初始化业务配置
  90. func refreshCloudConfig() {
  91. // 获取文件的目录
  92. _ = util.CreateParentDir(LocalConfig.CloudConfigLocalPath)
  93. // 3 ------- 获取 yaml 字符串 -------
  94. var content []byte
  95. cloudConfigObjectKey := LocalConfig.OssBasePrefix + LocalConfig.EquipmentNo + "/" + LocalConfig.CloudConfigFilename
  96. err := OssBucket.GetObjectToFile(cloudConfigObjectKey, LocalConfig.CloudConfigLocalPath)
  97. if err != nil {
  98. c_log.GlobalLogger.Error("下载oss上的配置文件"+cloudConfigObjectKey+"失败。", err)
  99. return
  100. }
  101. content, err = os.ReadFile(LocalConfig.CloudConfigLocalPath)
  102. if err != nil {
  103. c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 读取失败:", err)
  104. return
  105. }
  106. // 4 ------- 解析YAML内容 -------
  107. var newCloudConfig cloudConfig
  108. err = yaml.Unmarshal(content, &newCloudConfig)
  109. if err != nil {
  110. c_log.GlobalLogger.Error("配置文件 ", LocalConfig.CloudConfigLocalPath, " 解析失败:", err)
  111. return
  112. }
  113. // 5 ------- 校验 yaml -------
  114. if checkConfig(newCloudConfig) {
  115. CloudConfigMutex.RLock()
  116. CloudConfig = newCloudConfig
  117. CloudConfigMutex.RUnlock()
  118. } else {
  119. c_log.GlobalLogger.Error("配置文件格式错误:", newCloudConfig)
  120. return
  121. }
  122. _ = util.CreateDir(CloudConfig.BagDataDir)
  123. _ = util.CreateDir(CloudConfig.BagCopyDir)
  124. }
  125. // RefreshCloudConfig 轮询oss上的配置文件更新到本地
  126. func RefreshCloudConfig() {
  127. for {
  128. time.Sleep(time.Duration(CloudConfig.ConfigRefreshInterval) * time.Second)
  129. refreshCloudConfig()
  130. }
  131. }
  132. // CheckConfig 校验 cfg.yaml 文件
  133. func checkConfig(check cloudConfig) bool {
  134. if len(check.Hosts) != 2 {
  135. c_log.GlobalLogger.Error("cloud-config.yaml中配置的hosts必须为2。")
  136. os.Exit(-1)
  137. }
  138. return true
  139. }