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

IP名单添加新IP时删除老的IP内容

Browse Source
This commit is contained in:
刘祥超
2021-12-10 11:12:34 +08:00
parent 91378b26dd
commit 01ea13d283
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
internal/db/models/ip_item_dao.go
View File

@@ -123,14 +123,15 @@ func (this *IPItemDAO) FindEnabledIPItem(tx *dbs.Tx, id int64) (*IPItem, error)
return result.(*IPItem), err return result.(*IPItem), err
} }
// DisableOldIPItem 根据IP删除以前的旧记录 // DeleteOldItem 根据IP删除以前的旧记录
func (this *IPItemDAO) DisableOldIPItem(tx *dbs.Tx, listId int64, ipFrom string, ipTo string) error { func (this *IPItemDAO) DeleteOldItem(tx *dbs.Tx, listId int64, ipFrom string, ipTo string) error {
return this.Query(tx). _, err := this.Query(tx).
UseIndex("ipFrom").
Attr("listId", listId). Attr("listId", listId).
Attr("ipFrom", ipFrom). Attr("ipFrom", ipFrom).
Attr("ipTo", ipTo). Attr("ipTo", ipTo).
Set("state", IPItemStateDisabled). Delete()
UpdateQuickly() return err
} }
// CreateIPItem 创建IP // CreateIPItem 创建IP

2
internal/rpc/services/service_ip_item.go
View File

@@ -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 { if err != nil {
return nil, err return nil, err
} }