Update bundleOrder.go
This commit is contained in:
parent
0802c372b0
commit
a0ad992ab1
@ -7,6 +7,7 @@ import (
|
|||||||
"fonchain-fiee/api/accountFiee"
|
"fonchain-fiee/api/accountFiee"
|
||||||
"fonchain-fiee/api/bundle"
|
"fonchain-fiee/api/bundle"
|
||||||
"fonchain-fiee/api/order"
|
"fonchain-fiee/api/order"
|
||||||
|
"fonchain-fiee/pkg/cache"
|
||||||
"fonchain-fiee/pkg/model/login"
|
"fonchain-fiee/pkg/model/login"
|
||||||
"fonchain-fiee/pkg/service"
|
"fonchain-fiee/pkg/service"
|
||||||
"fonchain-fiee/pkg/service/bundle/common"
|
"fonchain-fiee/pkg/service/bundle/common"
|
||||||
@ -213,6 +214,14 @@ func CreateBundleOrderSignature(c *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Redis 防重复提交:同一用户5秒内只能提交一次订单
|
||||||
|
lockKey := fmt.Sprintf("create_bundle_order_%d", userInfo.ID)
|
||||||
|
reply := cache.RedisClient.SetNX(lockKey, 1, 5*time.Second)
|
||||||
|
if !reply.Val() {
|
||||||
|
service.Error(c, errors.New("请勿重复提交订单,请稍后再试"))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
// 校验套餐是否已购买
|
// 校验套餐是否已购买
|
||||||
if err := logic.CheckUserOrder(userInfo.ID); err != nil {
|
if err := logic.CheckUserOrder(userInfo.ID); err != nil {
|
||||||
service.Error(c, err)
|
service.Error(c, err)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user