diff --git a/internal/db/models/node_dao.go b/internal/db/models/node_dao.go index 099304e9..b332bced 100644 --- a/internal/db/models/node_dao.go +++ b/internal/db/models/node_dao.go @@ -18,7 +18,6 @@ import ( "github.com/TeaOSLab/EdgeCommon/pkg/serverconfigs" "github.com/TeaOSLab/EdgeCommon/pkg/serverconfigs/ddosconfigs" "github.com/TeaOSLab/EdgeCommon/pkg/serverconfigs/shared" - "github.com/TeaOSLab/EdgeCommon/pkg/systemconfigs" _ "github.com/go-sql-driver/mysql" "github.com/iwind/TeaGo/Tea" "github.com/iwind/TeaGo/dbs" @@ -1057,30 +1056,6 @@ func (this *NodeDAO) ComposeNodeConfig(tx *dbs.Tx, nodeId int64, dataMap *shared } } - // 全局设置 - // TODO 根据用户的不同读取不同的全局设置 - var settingCacheKey = "SharedSysSettingDAO:" + systemconfigs.SettingCodeServerGlobalConfig - settingJSONCache, ok := cacheMap.Get(settingCacheKey) - var settingJSON []byte - if ok { - settingJSON = settingJSONCache.([]byte) - } else { - settingJSON, err = SharedSysSettingDAO.ReadSetting(tx, systemconfigs.SettingCodeServerGlobalConfig) - if err != nil { - return nil, err - } - cacheMap.Put(settingCacheKey, settingJSON) - } - - if len(settingJSON) > 0 { - globalConfig := &serverconfigs.GlobalConfig{} - err = json.Unmarshal(settingJSON, globalConfig) - if err != nil { - return nil, err - } - config.GlobalConfig = globalConfig - } - var clusterIndex = 0 config.WebPImagePolicies = map[int64]*nodeconfigs.WebPImagePolicy{} config.UAMPolicies = map[int64]*nodeconfigs.UAMPolicy{} diff --git a/internal/db/models/sys_setting_dao.go b/internal/db/models/sys_setting_dao.go index ac34cb50..ae3b1277 100644 --- a/internal/db/models/sys_setting_dao.go +++ b/internal/db/models/sys_setting_dao.go @@ -7,7 +7,6 @@ import ( "github.com/TeaOSLab/EdgeAPI/internal/utils" "github.com/TeaOSLab/EdgeAPI/internal/zero" "github.com/TeaOSLab/EdgeCommon/pkg/nodeconfigs" - "github.com/TeaOSLab/EdgeCommon/pkg/serverconfigs" "github.com/TeaOSLab/EdgeCommon/pkg/systemconfigs" "github.com/TeaOSLab/EdgeCommon/pkg/userconfigs" _ "github.com/go-sql-driver/mysql" @@ -126,23 +125,6 @@ func (this *SysSettingDAO) CompareInt64Setting(tx *dbs.Tx, code string, anotherV return 0, nil } -// ReadGlobalConfig 读取全局配置 -func (this *SysSettingDAO) ReadGlobalConfig(tx *dbs.Tx) (*serverconfigs.GlobalConfig, error) { - globalConfigData, err := this.ReadSetting(tx, systemconfigs.SettingCodeServerGlobalConfig) - if err != nil { - return nil, err - } - if len(globalConfigData) == 0 { - return &serverconfigs.GlobalConfig{}, nil - } - config := &serverconfigs.GlobalConfig{} - err = json.Unmarshal(globalConfigData, config) - if err != nil { - return nil, err - } - return config, nil -} - // ReadAdminUIConfig 读取管理员界面配置 func (this *SysSettingDAO) ReadAdminUIConfig(tx *dbs.Tx, cacheMap *utils.CacheMap) (*systemconfigs.AdminUIConfig, error) { var cacheKey = this.Table + ":ReadAdminUIConfig" diff --git a/internal/rpc/services/service_node_cluster.go b/internal/rpc/services/service_node_cluster.go index d27ab499..d648fff1 100644 --- a/internal/rpc/services/service_node_cluster.go +++ b/internal/rpc/services/service_node_cluster.go @@ -963,15 +963,21 @@ func (this *NodeClusterService) FindFreePortInNodeCluster(ctx context.Context, r } var tx = this.NullTx() - globalConfig, err := models.SharedSysSettingDAO.ReadGlobalConfig(tx) + + // 检查端口 + globalServerConfig, err := models.SharedNodeClusterDAO.FindClusterGlobalServerConfig(tx, req.NodeClusterId) if err != nil { return nil, err } - // 检查端口 - portMin := globalConfig.TCPAll.PortRangeMin - portMax := globalConfig.TCPAll.PortRangeMax - denyPorts := globalConfig.TCPAll.DenyPorts + var portMin, portMax int + var denyPorts []int + + if globalServerConfig != nil { + portMin = globalServerConfig.TCPAll.PortRangeMin + portMax = globalServerConfig.TCPAll.PortRangeMax + denyPorts = globalServerConfig.TCPAll.DenyPorts + } if portMin == 0 && portMax == 0 { portMin = 10_000 diff --git a/internal/setup/sql_upgrade.go b/internal/setup/sql_upgrade.go index e4ae516a..f03681a0 100644 --- a/internal/setup/sql_upgrade.go +++ b/internal/setup/sql_upgrade.go @@ -792,8 +792,14 @@ func upgradeV1_2_10(db *dbs.DB) error { if err != nil { return err } + globalServerConfig.HTTPAll.DomainAuditingIsOn = oldGlobalConfig.HTTPAll.DomainAuditingIsOn globalServerConfig.HTTPAll.DomainAuditingPrompt = oldGlobalConfig.HTTPAll.DomainAuditingPrompt + + globalServerConfig.TCPAll.DenyPorts = oldGlobalConfig.TCPAll.DenyPorts + globalServerConfig.TCPAll.PortRangeMin = oldGlobalConfig.TCPAll.PortRangeMin + globalServerConfig.TCPAll.PortRangeMax = oldGlobalConfig.TCPAll.PortRangeMax + globalServerConfigJSON, err := json.Marshal(globalServerConfig) if err != nil { return err