diff --git a/internal/web/actions/default/clusters/cluster/init.go b/internal/web/actions/default/clusters/cluster/init.go index c200e82f..4d60c5b9 100644 --- a/internal/web/actions/default/clusters/cluster/init.go +++ b/internal/web/actions/default/clusters/cluster/init.go @@ -45,6 +45,7 @@ func init() { Get("/thresholds", new(thresholds.IndexAction)). Get("/detail", new(node.DetailAction)). GetPost("/updateDNSPopup", new(node.UpdateDNSPopupAction)). + Post("/syncDomain", new(node.SyncDomainAction)). // 分组相关 Prefix("/clusters/cluster/groups"). diff --git a/internal/web/actions/default/clusters/cluster/node/syncDomain.go b/internal/web/actions/default/clusters/cluster/node/syncDomain.go new file mode 100644 index 00000000..769d1962 --- /dev/null +++ b/internal/web/actions/default/clusters/cluster/node/syncDomain.go @@ -0,0 +1,33 @@ +package node + +import ( + "github.com/TeaOSLab/EdgeAdmin/internal/oplogs" + "github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils" + "github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb" +) + +type SyncDomainAction struct { + actionutils.ParentAction +} + +func (this *SyncDomainAction) RunPost(params struct { + DomainId int64 +}) { + // 记录日志 + defer this.CreateLog(oplogs.LevelInfo, "同步DNS域名数据 %d", params.DomainId) + + // 执行同步 + resp, err := this.RPC().DNSDomainRPC().SyncDNSDomainData(this.AdminContext(), &pb.SyncDNSDomainDataRequest{DnsDomainId: params.DomainId}) + if err != nil { + this.ErrorPage(err) + return + } + if resp.IsOk { + this.Success() + } else { + this.Data["shouldFix"] = resp.ShouldFix + this.Fail(resp.Error) + } + + this.Success() +} diff --git a/internal/web/actions/default/dns/init.go b/internal/web/actions/default/dns/init.go index a3e9e294..ef631d41 100644 --- a/internal/web/actions/default/dns/init.go +++ b/internal/web/actions/default/dns/init.go @@ -56,6 +56,7 @@ func init() { Data("teaSubMenu", "issue"). GetPost("", new(issues.IndexAction)). GetPost("/updateNodePopup", new(issues.UpdateNodePopupAction)). + Post("/syncDomain", new(issues.SyncDomainAction)). EndData(). EndAll() }) diff --git a/internal/web/actions/default/dns/issues/syncDomain.go b/internal/web/actions/default/dns/issues/syncDomain.go new file mode 100644 index 00000000..80095f55 --- /dev/null +++ b/internal/web/actions/default/dns/issues/syncDomain.go @@ -0,0 +1,33 @@ +package issues + +import ( + "github.com/TeaOSLab/EdgeAdmin/internal/oplogs" + "github.com/TeaOSLab/EdgeAdmin/internal/web/actions/actionutils" + "github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb" +) + +type SyncDomainAction struct { + actionutils.ParentAction +} + +func (this *SyncDomainAction) RunPost(params struct { + DomainId int64 +}) { + // 记录日志 + defer this.CreateLog(oplogs.LevelInfo, "同步DNS域名数据 %d", params.DomainId) + + // 执行同步 + resp, err := this.RPC().DNSDomainRPC().SyncDNSDomainData(this.AdminContext(), &pb.SyncDNSDomainDataRequest{DnsDomainId: params.DomainId}) + if err != nil { + this.ErrorPage(err) + return + } + if resp.IsOk { + this.Success() + } else { + this.Data["shouldFix"] = resp.ShouldFix + this.Fail(resp.Error) + } + + this.Success() +} diff --git a/web/views/@default/clusters/cluster/node/updateDNSPopup.html b/web/views/@default/clusters/cluster/node/updateDNSPopup.html index 3f41ed3b..7cf669fa 100644 --- a/web/views/@default/clusters/cluster/node/updateDNSPopup.html +++ b/web/views/@default/clusters/cluster/node/updateDNSPopup.html @@ -24,10 +24,10 @@
没有可选的线路。
+没有可选的线路。[获取线路]
没有可选的线路。
+没有可选的线路。[获取线路]