diff --git a/internal/db/models/node_cluster_dao.go b/internal/db/models/node_cluster_dao.go index 246186b6..4f04b21f 100644 --- a/internal/db/models/node_cluster_dao.go +++ b/internal/db/models/node_cluster_dao.go @@ -176,7 +176,7 @@ func (this *NodeClusterDAO) CreateCluster(tx *dbs.Tx, adminId int64, name string // 全局服务配置 if globalServerConfig == nil { - globalServerConfig = serverconfigs.DefaultGlobalServerConfig() + globalServerConfig = serverconfigs.NewGlobalServerConfig() } globalServerConfigJSON, err := json.Marshal(globalServerConfig) if err != nil { @@ -1396,7 +1396,7 @@ func (this *NodeClusterDAO) FindClusterGlobalServerConfig(tx *dbs.Tx, clusterId return nil, err } - var config = serverconfigs.DefaultGlobalServerConfig() + var config = serverconfigs.NewGlobalServerConfig() if IsNull(configJSON) { return config, nil } @@ -1412,7 +1412,7 @@ func (this *NodeClusterDAO) FindClusterGlobalServerConfig(tx *dbs.Tx, clusterId // UpdateClusterGlobalServerConfig 修改全局服务配置 func (this *NodeClusterDAO) UpdateClusterGlobalServerConfig(tx *dbs.Tx, clusterId int64, config *serverconfigs.GlobalServerConfig) error { if config == nil { - config = serverconfigs.DefaultGlobalServerConfig() + config = serverconfigs.NewGlobalServerConfig() } configJSON, err := json.Marshal(config) if err != nil { diff --git a/internal/db/models/node_cluster_model_ext.go b/internal/db/models/node_cluster_model_ext.go index 25b7ad58..2b24a304 100644 --- a/internal/db/models/node_cluster_model_ext.go +++ b/internal/db/models/node_cluster_model_ext.go @@ -60,7 +60,7 @@ func (this *NodeCluster) DecodeClock() *nodeconfigs.ClockConfig { // DecodeGlobalServerConfig 解析全局服务配置 func (this *NodeCluster) DecodeGlobalServerConfig() *serverconfigs.GlobalServerConfig { - var config = serverconfigs.DefaultGlobalServerConfig() + var config = serverconfigs.NewGlobalServerConfig() if IsNotNull(this.GlobalServerConfig) { err := json.Unmarshal(this.GlobalServerConfig, config) if err != nil { diff --git a/internal/rpc/services/service_node.go b/internal/rpc/services/service_node.go index c47deee1..97104f18 100644 --- a/internal/rpc/services/service_node.go +++ b/internal/rpc/services/service_node.go @@ -2016,7 +2016,7 @@ func (this *NodeService) FindNodeGlobalServerConfig(ctx context.Context, req *pb } } if config == nil { - config = serverconfigs.DefaultGlobalServerConfig() + config = serverconfigs.NewGlobalServerConfig() } configJSON, err := json.Marshal(config) diff --git a/internal/rpc/services/service_node_cluster.go b/internal/rpc/services/service_node_cluster.go index 413edd04..1ace02e3 100644 --- a/internal/rpc/services/service_node_cluster.go +++ b/internal/rpc/services/service_node_cluster.go @@ -34,7 +34,7 @@ func (this *NodeClusterService) CreateNodeCluster(ctx context.Context, req *pb.C } // 全局服务配置 - var serverGlobalConfig = serverconfigs.DefaultGlobalServerConfig() + var serverGlobalConfig = serverconfigs.NewGlobalServerConfig() if len(req.GlobalServerConfigJSON) > 0 { err = json.Unmarshal(req.GlobalServerConfigJSON, serverGlobalConfig) if err != nil { @@ -1444,7 +1444,7 @@ func (this *NodeClusterService) UpdateNodeClusterGlobalServerConfig(ctx context. return nil, err } - var config = serverconfigs.DefaultGlobalServerConfig() + var config = serverconfigs.NewGlobalServerConfig() err = json.Unmarshal(req.GlobalServerConfigJSON, config) if err != nil { return nil, err