满足压测处理
This commit is contained in:
parent
45233650d7
commit
bab72020ad
|
|
@ -20,7 +20,9 @@ func (v *VoucherBiz) CmbOrder(ctx context.Context, req *bo.OrderCreateReqBo) (or
|
||||||
|
|
||||||
err = lock.NewMutex(v.rdb.Rdb, c.TTL).Lock(bizCtx, c.Key, func(bizCtx context.Context) error {
|
err = lock.NewMutex(v.rdb.Rdb, c.TTL).Lock(bizCtx, c.Key, func(bizCtx context.Context) error {
|
||||||
|
|
||||||
|
// 压测商品直接过
|
||||||
if req.ProductNo != "001" {
|
if req.ProductNo != "001" {
|
||||||
|
|
||||||
order, err := v.OrderRepo.GetByOutBizNo(bizCtx, vo.OrderTypeCmb, req.OutBizNo)
|
order, err := v.OrderRepo.GetByOutBizNo(bizCtx, vo.OrderTypeCmb, req.OutBizNo)
|
||||||
|
|
||||||
if err != nil && !err2.IsDbNotFound(err) {
|
if err != nil && !err2.IsDbNotFound(err) {
|
||||||
|
|
@ -46,10 +48,6 @@ func (v *VoucherBiz) CmbOrder(ctx context.Context, req *bo.OrderCreateReqBo) (or
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if !product.Channel.IsWeChat() {
|
|
||||||
return err2.ErrorCmbProductNotSupported("只支持微信")
|
|
||||||
}
|
|
||||||
|
|
||||||
order, err := v.order(bizCtx, req, product)
|
order, err := v.order(bizCtx, req, product)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue