From 9992e82a3cb49ed5cf8090ed66eb0dad0eaaeefd Mon Sep 17 00:00:00 2001 From: huang Date: Wed, 15 Apr 2026 12:21:43 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=96=B0=E5=A2=9E=E5=8D=A1=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E8=BD=AE=E8=AF=A2=E4=BB=BB=E5=8A=A1=E7=B1=BB=E5=9E=8B?= =?UTF-8?q?=E5=B8=B8=E9=87=8F=E5=8F=8A=20verbose=5Flog=20=E9=85=8D?= =?UTF-8?q?=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit constants.go: 新增 TaskTypePollingCardStatus = "polling:card_status" config.go: 新增 PollingConfig struct 含 VerboseLog bool config.yaml: polling.verbose_log 默认 false Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-openagent) Co-authored-by: Sisyphus --- pkg/config/config.go | 8 ++++++++ pkg/config/defaults/config.yaml | 4 ++++ pkg/constants/constants.go | 9 +++++---- 3 files changed, 17 insertions(+), 4 deletions(-) diff --git a/pkg/config/config.go b/pkg/config/config.go index 86b5637..af3d375 100644 --- a/pkg/config/config.go +++ b/pkg/config/config.go @@ -25,6 +25,7 @@ type Config struct { Storage StorageConfig `mapstructure:"storage"` Gateway GatewayConfig `mapstructure:"gateway"` PollingAutoTrigger PollingAutoTriggerConfig `mapstructure:"polling_auto_trigger"` + Polling PollingConfig `mapstructure:"polling"` } // ServerConfig HTTP 服务器配置 @@ -140,6 +141,13 @@ type GatewayConfig struct { Timeout int `mapstructure:"timeout"` // 超时时间（秒） } +// PollingConfig 轮询通用配置 +type PollingConfig struct { + // VerboseLog 开启后，所有轮询 handler 在成功获取上游数据时以 Info 级别输出详细日志 + // 环境变量：JUNHONG_POLLING_VERBOSE_LOG + VerboseLog bool `mapstructure:"verbose_log"` +} + // PollingAutoTriggerConfig 轮询自动触发配置 type PollingAutoTriggerConfig struct { // EnableAutoTrigger 是否启用C端实名自动触发 diff --git a/pkg/config/defaults/config.yaml b/pkg/config/defaults/config.yaml index 0895fe5..935d33a 100644 --- a/pkg/config/defaults/config.yaml +++ b/pkg/config/defaults/config.yaml @@ -116,6 +116,10 @@ gateway: app_secret: "BZeQttaZQt0i73moF" timeout: 30 +# 轮询配置 +polling: + verbose_log: false # 是否开启详细日志（环境变量：JUNHONG_POLLING_VERBOSE_LOG） + # 轮询自动触发配置 polling_auto_trigger: enable_auto_trigger: true diff --git a/pkg/constants/constants.go b/pkg/constants/constants.go index 1e31d7b..b76225b 100644 --- a/pkg/constants/constants.go +++ b/pkg/constants/constants.go @@ -51,10 +51,11 @@ const ( TaskTypeCommissionStatsArchive = "commission:stats:archive" // 佣金统计归档 // 轮询任务类型 - TaskTypePollingRealname = "polling:realname" // 实名状态检查 - TaskTypePollingCarddata = "polling:carddata" // 卡流量检查 - TaskTypePollingPackage = "polling:package" // 套餐流量检查 - TaskTypePollingProtect = "polling:protect" // 保护期一致性检查 + TaskTypePollingRealname = "polling:realname" // 实名状态检查 + TaskTypePollingCarddata = "polling:carddata" // 卡流量检查 + TaskTypePollingPackage = "polling:package" // 套餐流量检查 + TaskTypePollingProtect = "polling:protect" // 保护期一致性检查 + TaskTypePollingCardStatus = "polling:card_status" // 卡开停机状态检查 // 套餐激活任务类型 TaskTypePackageFirstActivation = "package:first:activation" // 首次实名激活