Browse Source

fix(waf): 修复删除带宽限制功能并优化日志信息

- 修复 DelBandwidth 方法中 Name 字段的赋值错误,应使用 ServerIPStart 替代
- 优化内部服务器任务中的日志信息,将"续费失败"和"续费注册任务失败"更改为"清理过期记录失败"和"清理过期记录注册任务失败"
fusu 1 tuần trước cách đây
mục cha
commit
0f0b0ecbca
2 tập tin đã thay đổi với 4 bổ sung4 xóa
  1. 2 2
      internal/server/task.go
  2. 2 2
      internal/service/api/waf/buildaudun.go

+ 2 - 2
internal/server/task.go

@@ -111,11 +111,11 @@ func (t *TaskServer) Start(ctx context.Context) error {
 	_, err = t.scheduler.Cron("0 * * * *").Do(func() {
 		err := t.wafTask.CleanUpStaleRecords(ctx)
 		if err != nil {
-			t.log.Error("续费失败", zap.Error(err))
+			t.log.Error("清理过期记录失败", zap.Error(err))
 		}
 	})
 	if err != nil {
-		t.log.Error("续费注册任务失败", zap.Error(err))
+		t.log.Error("清理过期记录注册任务失败", zap.Error(err))
 	}
 
 

+ 2 - 2
internal/service/api/waf/buildaudun.go

@@ -62,7 +62,7 @@ func (s *buildAudunService) AddBandwidth(ctx context.Context, req v1.Bandwidth)
 
 func (s *buildAudunService) DelBandwidth(ctx context.Context, req v1.Bandwidth) error {
 	err := s.audun.DelBandwidthLimit(ctx, v1.Bandwidth{
-		Name: s.BuildName(req.ServerIPStart, req.ServerIPStart, "KFW-API-RESTAPI-"),
+		Name: s.BuildName(req.ServerIPStart, strconv.FormatInt(req.SpeedlimitOut, 10), "KFW-API-RESTAPI-"),
 	})
 	if err != nil {
 		return err
@@ -103,7 +103,7 @@ func (s *buildAudunService) Bandwidth(ctx context.Context,hostId int64, action s
 				})
 			case "del":
 				e = s.DelBandwidth(ctx,v1.Bandwidth{
-					Name:          ip,
+				    ServerIPStart: ip,
 					SpeedlimitOut: int64(bpsInt),
 				})
 			default: