From 01ea13d283f5cfa88d9941417daab1a21c714ad4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Fri, 10 Dec 2021 11:12:34 +0800 Subject: [PATCH] =?UTF-8?q?IP=E5=90=8D=E5=8D=95=E6=B7=BB=E5=8A=A0=E6=96=B0?= =?UTF-8?q?IP=E6=97=B6=E5=88=A0=E9=99=A4=E8=80=81=E7=9A=84IP=E5=86=85?= =?UTF-8?q?=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/db/models/ip_item_dao.go | 11 ++++++----- internal/rpc/services/service_ip_item.go | 2 +- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/internal/db/models/ip_item_dao.go b/internal/db/models/ip_item_dao.go index 527a074c..aa058a74 100644 --- a/internal/db/models/ip_item_dao.go +++ b/internal/db/models/ip_item_dao.go @@ -123,14 +123,15 @@ func (this *IPItemDAO) FindEnabledIPItem(tx *dbs.Tx, id int64) (*IPItem, error) return result.(*IPItem), err } -// DisableOldIPItem 根据IP删除以前的旧记录 -func (this *IPItemDAO) DisableOldIPItem(tx *dbs.Tx, listId int64, ipFrom string, ipTo string) error { - return this.Query(tx). +// DeleteOldItem 根据IP删除以前的旧记录 +func (this *IPItemDAO) DeleteOldItem(tx *dbs.Tx, listId int64, ipFrom string, ipTo string) error { + _, err := this.Query(tx). + UseIndex("ipFrom"). Attr("listId", listId). Attr("ipFrom", ipFrom). Attr("ipTo", ipTo). - Set("state", IPItemStateDisabled). - UpdateQuickly() + Delete() + return err } // CreateIPItem 创建IP diff --git a/internal/rpc/services/service_ip_item.go b/internal/rpc/services/service_ip_item.go index 2170e37d..2b661f66 100644 --- a/internal/rpc/services/service_ip_item.go +++ b/internal/rpc/services/service_ip_item.go @@ -59,7 +59,7 @@ func (this *IPItemService) CreateIPItem(ctx context.Context, req *pb.CreateIPIte } // 删除以前的 - err = models.SharedIPItemDAO.DisableOldIPItem(tx, req.IpListId, req.IpFrom, req.IpTo) + err = models.SharedIPItemDAO.DeleteOldItem(tx, req.IpListId, req.IpFrom, req.IpTo) if err != nil { return nil, err }