From 32c3f94da2a2c2fd26bb44e34837fa84fa029728 Mon Sep 17 00:00:00 2001 From: kanade Date: Tue, 22 Nov 2022 09:42:03 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=8E=B7=E5=8F=96?= =?UTF-8?q?=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/v2/controller/app/vip/vip.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 From 11809442cb728947125f28dd844b3218cf0ba11e Mon Sep 17 00:00:00 2001 From: kanade Date: Wed, 23 Nov 2022 10:25:53 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=B9=B6=E5=8F=91?= =?UTF-8?q?=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/cron/supply.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 {