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 }