From f6b34bccf9da812c4870d8af387a7c5d9a381556 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sun, 29 Aug 2021 16:57:50 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BD=93=E4=BF=AE=E6=94=B9=E8=8A=82=E7=82=B9?= =?UTF-8?q?=E5=9C=A8=E7=BA=BF=E7=8A=B6=E6=80=81=E6=97=B6=E9=87=8D=E7=BD=AE?= =?UTF-8?q?=E4=B8=8A=E7=BA=BF=E6=A3=80=E6=9F=A5=E6=AC=A1=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/db/models/node_dao.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/db/models/node_dao.go b/internal/db/models/node_dao.go index 9df9f8bc..0bc44041 100644 --- a/internal/db/models/node_dao.go +++ b/internal/db/models/node_dao.go @@ -1154,15 +1154,19 @@ func (this *NodeDAO) UpdateNodeUp(tx *dbs.Tx, nodeId int64, isUp bool) error { if nodeId <= 0 { return errors.New("invalid nodeId") } + op := NewNodeOperator() op.Id = nodeId op.IsUp = isUp - op.CountDown = 0 + op.CountUp = 0 op.CountDown = 0 err := this.Save(tx, op) if err != nil { return err } + + // TODO 只有前后状态不一致的时候才需要更新DNS + return this.NotifyDNSUpdate(tx, nodeId) }