diff --git a/internal/cron/supply.go b/internal/cron/supply.go index 9a89637..53c64bf 100644 --- a/internal/cron/supply.go +++ b/internal/cron/supply.go @@ -88,8 +88,8 @@ func (s *supplyTask) data() { time.Sleep(time.Second * 3) s.data() }() - pool, _ := ants.NewPool(5) - if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 5, func(message skuMessage, delivery amqp.Delivery) { + pool, _ := ants.NewPool(30) + if err := (skuMessage{}.Consume(supply.Api.Mq.SkuChangeQueue(), false, 30, func(message skuMessage, delivery amqp.Delivery) { pool.Submit(func() { defer delivery.Ack(false) if err := third.SupplyLogic.SyncData([]uint{message.SkuId}); err != nil { diff --git a/internal/v2/controller/app/vip/vip.go b/internal/v2/controller/app/vip/vip.go index a3ce006..369251a 100644 --- a/internal/v2/controller/app/vip/vip.go +++ b/internal/v2/controller/app/vip/vip.go @@ -147,7 +147,7 @@ func (o Proxy) VipIsUsed(c *gin.Context) { // InviteCheck @Title 邀请码验证 func (o *Proxy) InviteCheck(c *gin.Context) { args := argsGoodsInvite{} - err := tools.Params(&args, c) + err := tools.ParseParams(&args, c) if err != nil { back.Fail(c, err.Error()) return @@ -184,7 +184,7 @@ type argsGoodsInvite struct { // Invite @Title 邀请码 func (o *Proxy) Invite(c *gin.Context) { args := argsGoodsInvite{} - err := tools.Params(&args, c) + err := tools.ParseParams(&args, c) if err != nil { back.Fail(c, err.Error()) return