TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-06 18:10:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

如果服务变更集群前后域名ID一致，则不执行删除操作

Browse Source
This commit is contained in:
刘祥超
2022-04-18 18:35:57 +08:00
parent ea09ef3d91
commit 26fe3558f4
1 changed files with 27 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
internal/tasks/dns_task_executor.go
View File

@@ -132,12 +132,21 @@ func (this *DNSTaskExecutor) doServer(taskId int64, oldClusterId int64, serverId
var recordName = serverDNS.DnsName var recordName = serverDNS.DnsName
var recordType = dnstypes.RecordTypeCNAME var recordType = dnstypes.RecordTypeCNAME
// 新的DNS设置
manager, newDomainId, domain, clusterDNSName, dnsConfig, err := this.findDNSManager(tx, int64(serverDNS.ClusterId))
if err != nil {
return err
}
// 如果集群发生了变化，则从老的集群中删除 // 如果集群发生了变化，则从老的集群中删除
if oldClusterId > 0 && int64(serverDNS.ClusterId) != oldClusterId { if oldClusterId > 0 && int64(serverDNS.ClusterId) != oldClusterId {
oldManager, oldDomainId, oldDomain, _, _, err := this.findDNSManager(tx, oldClusterId) oldManager, oldDomainId, oldDomain, _, _, err := this.findDNSManager(tx, oldClusterId)
if err != nil { if err != nil {
return err return err
} }
// 如果域名发生了变化
if oldDomainId != newDomainId {
if oldManager != nil { if oldManager != nil {
oldRecord, err := oldManager.QueryRecord(oldDomain, recordName, recordType) oldRecord, err := oldManager.QueryRecord(oldDomain, recordName, recordType)
if err != nil { if err != nil {
@@ -158,16 +167,13 @@ func (this *DNSTaskExecutor) doServer(taskId int64, oldClusterId int64, serverId
} }
} }
} }
}
isOk = true isOk = true
return nil return nil
} }
// 处理新的集群 // 处理新的集群
manager, domainId, domain, clusterDNSName, dnsConfig, err := this.findDNSManager(tx, int64(serverDNS.ClusterId))
if err != nil {
return err
}
if manager == nil { if manager == nil {
isOk = true isOk = true
return nil return nil
@@ -191,7 +197,7 @@ func (this *DNSTaskExecutor) doServer(taskId int64, oldClusterId int64, serverId
if err != nil { if err != nil {
return err return err
} }
err = dnsmodels.SharedDNSTaskDAO.CreateDomainTask(tx, domainId, dnsmodels.DNSTaskTypeDomainChange) err = dnsmodels.SharedDNSTaskDAO.CreateDomainTask(tx, newDomainId, dnsmodels.DNSTaskTypeDomainChange)
if err != nil { if err != nil {
return err return err
} }
@@ -200,7 +206,7 @@ func (this *DNSTaskExecutor) doServer(taskId int64, oldClusterId int64, serverId
isOk = true isOk = true
} else { } else {
// 是否已存在 // 是否已存在
exist, err := dnsmodels.SharedDNSDomainDAO.ExistDomainRecord(tx, domainId, recordName, recordType, recordRoute, recordValue) exist, err := dnsmodels.SharedDNSDomainDAO.ExistDomainRecord(tx, newDomainId, recordName, recordType, recordRoute, recordValue)
if err != nil { if err != nil {
return err return err
} }
@@ -225,7 +231,7 @@ func (this *DNSTaskExecutor) doServer(taskId int64, oldClusterId int64, serverId
if err != nil { if err != nil {
return err return err
} }
err = dnsmodels.SharedDNSTaskDAO.CreateDomainTask(tx, domainId, dnsmodels.DNSTaskTypeDomainChange) err = dnsmodels.SharedDNSTaskDAO.CreateDomainTask(tx, newDomainId, dnsmodels.DNSTaskTypeDomainChange)
if err != nil { if err != nil {
return err return err
} }
@@ -243,7 +249,7 @@ func (this *DNSTaskExecutor) doServer(taskId int64, oldClusterId int64, serverId
return err return err
} }
err = dnsmodels.SharedDNSTaskDAO.CreateDomainTask(tx, domainId, dnsmodels.DNSTaskTypeDomainChange) err = dnsmodels.SharedDNSTaskDAO.CreateDomainTask(tx, newDomainId, dnsmodels.DNSTaskTypeDomainChange)
if err != nil { if err != nil {
return err return err
} }