feat: PollingBase 新增 verboseLog 支持,Worker 传入配置

polling_base.go: PollingBase.verboseLog bool 字段,NewPollingBase 新增参数
main.go: cfg.Polling.VerboseLog 作为第6个参数传入 NewPollingBase

Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-openagent)

Co-authored-by: Sisyphus <clio-agent@sisyphuslabs.ai>
This commit is contained in:
2026-04-15 12:22:16 +08:00
parent 97c196b7c6
commit 6292443f69
2 changed files with 5 additions and 2 deletions

View File

@@ -151,7 +151,7 @@ func main() {
pollingQueueMgr := polling.NewPollingQueueManager(redisClient, constants.PollingShardCount, appLogger) pollingQueueMgr := polling.NewPollingQueueManager(redisClient, constants.PollingShardCount, appLogger)
pollingIotCardStore := postgres.NewIotCardStore(db, redisClient) pollingIotCardStore := postgres.NewIotCardStore(db, redisClient)
pollingBase := task.NewPollingBase(redisClient, pollingQueueMgr, pollingConfigMgr, pollingIotCardStore, appLogger) pollingBase := task.NewPollingBase(redisClient, pollingQueueMgr, pollingConfigMgr, pollingIotCardStore, appLogger, cfg.Polling.VerboseLog)
// 后台渐进式初始化(将全量卡数据写入分片 Sorted Set // 后台渐进式初始化(将全量卡数据写入分片 Sorted Set
pollingInitializer := polling.NewPollingInitializer(pollingIotCardStore, redisClient, pollingConfigMgr, pollingQueueMgr, appLogger) pollingInitializer := polling.NewPollingInitializer(pollingIotCardStore, redisClient, pollingConfigMgr, pollingQueueMgr, appLogger)

View File

@@ -29,13 +29,14 @@ var acquireConcurrencyScript = redis.NewScript(`
`) `)
// PollingBase 轮询共享基类 // PollingBase 轮询共享基类
// 封装并发控制、卡缓存、重入队、配置间隔查询等公共方法,4 个 Handler 共享 // 封装并发控制、卡缓存、重入队、配置间隔查询等公共方法,所有 Handler 共享
type PollingBase struct { type PollingBase struct {
redis *redis.Client redis *redis.Client
queueMgr *polling.PollingQueueManager queueMgr *polling.PollingQueueManager
configMgr *polling.PollingConfigManager configMgr *polling.PollingConfigManager
iotCardStore *postgres.IotCardStore iotCardStore *postgres.IotCardStore
logger *zap.Logger logger *zap.Logger
verboseLog bool
} }
// NewPollingBase 创建轮询共享基类 // NewPollingBase 创建轮询共享基类
@@ -45,6 +46,7 @@ func NewPollingBase(
configMgr *polling.PollingConfigManager, configMgr *polling.PollingConfigManager,
iotCardStore *postgres.IotCardStore, iotCardStore *postgres.IotCardStore,
logger *zap.Logger, logger *zap.Logger,
verboseLog bool,
) *PollingBase { ) *PollingBase {
return &PollingBase{ return &PollingBase{
redis: redisClient, redis: redisClient,
@@ -52,6 +54,7 @@ func NewPollingBase(
configMgr: configMgr, configMgr: configMgr,
iotCardStore: iotCardStore, iotCardStore: iotCardStore,
logger: logger, logger: logger,
verboseLog: verboseLog,
} }
} }