From 407630ea62e90deddb62f1a8df4fb2135a9908e5 Mon Sep 17 00:00:00 2001 From: TsMask <340112800@qq.com> Date: Wed, 26 Feb 2025 17:56:23 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E7=BD=91=E5=85=83=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E5=8F=98=E6=9B=B4=E8=AE=B0=E5=BD=95=E6=9B=B4=E6=96=B0=E6=97=B6?= =?UTF-8?q?=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/modules/network_element/repository/ne_info.go | 4 +++- src/modules/network_element/service/ne_info.go | 3 +++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/src/modules/network_element/repository/ne_info.go b/src/modules/network_element/repository/ne_info.go index 0e707a6b..5381f3d0 100644 --- a/src/modules/network_element/repository/ne_info.go +++ b/src/modules/network_element/repository/ne_info.go @@ -221,8 +221,10 @@ func (r NeInfo) UpdateState(id int64, status int64) int64 { tx := db.DB("").Model(&model.NeInfo{}) // 构建查询条件 tx = tx.Where("id = ?", id) + tx.UpdateColumn("status", status) + tx.UpdateColumn("update_time", time.Now().UnixMilli()) // 执行更新 - if err := tx.UpdateColumn("status", status).Error; err != nil { + if err := tx.Error; err != nil { logger.Errorf("update err => %v", err.Error()) return 0 } diff --git a/src/modules/network_element/service/ne_info.go b/src/modules/network_element/service/ne_info.go index 3313aaec..4cc00721 100644 --- a/src/modules/network_element/service/ne_info.go +++ b/src/modules/network_element/service/ne_info.go @@ -7,6 +7,7 @@ import ( "path/filepath" "runtime" "strings" + "time" "be.ems/src/framework/constants" "be.ems/src/framework/database/redis" @@ -181,6 +182,7 @@ func (r NeInfo) bandNeStatus(arr *[]model.NeInfo) { if v.Status != 0 { v.Status = 0 (*arr)[i].Status = v.Status + (*arr)[i].UpdateTime = time.Now().UnixMilli() r.neInfoRepository.UpdateState(v.ID, v.Status) } continue @@ -198,6 +200,7 @@ func (r NeInfo) bandNeStatus(arr *[]model.NeInfo) { } (*arr)[i].Status = status if v.Status != status { + (*arr)[i].UpdateTime = time.Now().UnixMilli() r.neInfoRepository.UpdateState(v.ID, status) } }