|
@@ -554,7 +554,7 @@ func DealUserCoinForGreen(session *xorm.Session, req md.DealUserCoinReq) (err er |
|
|
req.Amount = 0 |
|
|
req.Amount = 0 |
|
|
} |
|
|
} |
|
|
//1、分布式锁阻拦 |
|
|
//1、分布式锁阻拦 |
|
|
requestIdPrefix := fmt.Sprintf(md.DealUserCoinRequestIdPrefix, req.Mid, req.CoinId, req.Uid) |
|
|
|
|
|
|
|
|
requestIdPrefix := fmt.Sprintf(md.DealUserCoinForGreenRequestIdPrefix, req.Mid, req.CoinId, req.Uid) |
|
|
cb, err := svc.HandleDistributedLock(req.Mid, strconv.Itoa(req.Uid), requestIdPrefix) |
|
|
cb, err := svc.HandleDistributedLock(req.Mid, strconv.Itoa(req.Uid), requestIdPrefix) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return err |
|
|
return err |
|
|