feat: 发布etcd配置添加MySQL记录

internal/pkg/service/confgov2/config.go

@@ -756,6 +756,8 @@ func PublishAllConfig() (err error) {
 	if query.Error != nil {
 		return
 	}
+	settings, err := system.System.Setting.GetAll()
+	clusterList := view.ClusterList{}
 	for _, item := range configuration {
 		var confHistory db.ConfigurationHistory
 		query = mysql.Where("configuration_id= ?", item.ID).Order("id desc").First(&confHistory)
@@ -782,6 +784,32 @@ func PublishAllConfig() (err error) {
 		}); err != nil {
 			continue
 		}
+		var cp db.ConfigurationPublish
+		cp.ConfigurationID = item.ID
+		cp.ConfigurationHistoryID = confHistory.ID
+		if err = mysql.Save(&cp).Error; err != nil {
+			continue
+		}
+		_, cp.FilePath = genConfigurePath(appInfo.AppName, item.FileName())
+		if _, ok := settings["k8s_cluster"]; ok {
+			if err = json.Unmarshal([]byte(settings["k8s_cluster"]), &clusterList); err == nil {
+				for _, instance := range clusterList.List {
+					var cs db.ConfigurationClusterStatus
+					cs.ConfigurationID = item.ID
+					cs.ConfigurationPublishID = cp.ID
+					cs.ClusterName = instance.Name
+					cs.Used = 0
+					cs.Synced = 0
+					cs.TakeEffect = 0
+					cs.CreatedAt = time.Now()
+					cs.UpdateAt = time.Now()
+					if sErr := mysql.Save(&cs).Error; sErr != nil {
+						continue
+					}
+				}
+
+			}
+		}
 	}
 	return
 }