From ab8873f2eab7f9edba7c2b8a217a5406fbf34d9e Mon Sep 17 00:00:00 2001 From: luorijun Date: Fri, 28 Nov 2025 18:35:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E7=99=BD=E5=90=8D=E5=8D=95?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E7=B1=BB=E5=9E=8B=E6=98=A0=E5=B0=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 6 +++++- web/globals/orm/inet.go | 6 +++--- web/handlers/resource.go | 2 +- web/handlers/whitelist.go | 4 ++++ 4 files changed, 13 insertions(+), 5 deletions(-) diff --git a/README.md b/README.md index ad8f1c7..e17f21b 100644 --- a/README.md +++ b/README.md @@ -14,6 +14,10 @@ trade/create 性能问题,缩短事务时间,考虑其他方式实现可靠 需要确认以下 ID.GenSerial 的分布式并发安全性 +实现 sse 检查订单,减少请求次数 + +网关缩扩容太慢 + ### 长期 分离 task 的客户端,支持多进程(prefork 必要!) @@ -79,7 +83,7 @@ proxy 网关更新接口可以传输更结构化的数据,直接区分不同 缩扩容: - 通过调度任务实现缩扩容 -- 每 n 秒检查一次全部配置,按代理分组 +- 每分钟检查一次全部配置,按代理分组 - 获取所有代理后备配置 - 后备配置/当前配置 - 当比例 < 1.5 或 > 3 时,重新更新为 2 倍 diff --git a/web/globals/orm/inet.go b/web/globals/orm/inet.go index 8bba19b..d5eae33 100644 --- a/web/globals/orm/inet.go +++ b/web/globals/orm/inet.go @@ -11,13 +11,13 @@ type Inet struct { } func (inet Inet) Value() (driver.Value, error) { - return inet.MarshalBinary() + return inet.MarshalText() } func (inet *Inet) Scan(value any) (err error) { switch value := value.(type) { - case []byte: - return inet.UnmarshalBinary(value) + case string: + return inet.UnmarshalText([]byte(value)) default: return fmt.Errorf("不支持的类型: %T", value) } diff --git a/web/handlers/resource.go b/web/handlers/resource.go index 8e28f4d..ea7452c 100644 --- a/web/handlers/resource.go +++ b/web/handlers/resource.go @@ -66,7 +66,7 @@ func ListResourceShort(c *fiber.Ctx) error { do.Where(q.ResourceShort.As(q.Resource.Short.Name()).Expire.Lte(*req.ExpireBefore)) } - resource, err := q.Resource.Debug().Where(do). + resource, err := q.Resource.Where(do). Joins(q.Resource.Short). Order(q.Resource.CreatedAt.Desc()). Offset(req.GetOffset()). diff --git a/web/handlers/whitelist.go b/web/handlers/whitelist.go index 4630c88..fc89771 100644 --- a/web/handlers/whitelist.go +++ b/web/handlers/whitelist.go @@ -101,6 +101,10 @@ func CreateWhitelist(c *fiber.Ctx) error { IP: u.Z(ip), Remark: &req.Remark, }) + if err != nil { + return core.NewServErr("添加白名单失败", err) + } + return nil }