|
@@ -4,11 +4,11 @@ import (
|
|
"context"
|
|
"context"
|
|
"encoding/json"
|
|
"encoding/json"
|
|
"fmt"
|
|
"fmt"
|
|
|
|
+ "github.com/davecgh/go-spew/spew"
|
|
"github.com/go-nunu/nunu-layout-advanced/internal/service"
|
|
"github.com/go-nunu/nunu-layout-advanced/internal/service"
|
|
"github.com/google/uuid"
|
|
"github.com/google/uuid"
|
|
"github.com/rabbitmq/amqp091-go"
|
|
"github.com/rabbitmq/amqp091-go"
|
|
"go.uber.org/zap"
|
|
"go.uber.org/zap"
|
|
- "strconv"
|
|
|
|
"strings"
|
|
"strings"
|
|
"sync"
|
|
"sync"
|
|
)
|
|
)
|
|
@@ -222,9 +222,10 @@ func (j *whitelistJob) handleIpMessage(ctx context.Context, logger *zap.Logger,
|
|
errChan <- fmt.Errorf("获取IP '%s' (isSmall: %t) ID失败: %w", ip, isSmall, err)
|
|
errChan <- fmt.Errorf("获取IP '%s' (isSmall: %t) ID失败: %w", ip, isSmall, err)
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- if err := j.aoDunService.DelWhiteStaticList(ctx, isSmall, strconv.Itoa(id)); err != nil {
|
|
|
|
- errChan <- fmt.Errorf("删除IP '%s' (isSmall: %t, id: %d) 失败: %w", ip, isSmall, id, err)
|
|
|
|
- }
|
|
|
|
|
|
+ spew.Dump(id,"----------------------------")
|
|
|
|
+ //if err := j.aoDunService.DelWhiteStaticList(ctx, isSmall, strconv.Itoa(id)); err != nil {
|
|
|
|
+ // errChan <- fmt.Errorf("删除IP '%s' (isSmall: %t, id: %d) 失败: %w", ip, isSmall, id, err)
|
|
|
|
+ //}
|
|
}
|
|
}
|
|
|
|
|
|
for _, ip := range payload.Ips {
|
|
for _, ip := range payload.Ips {
|