liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

切换主体

This commit is contained in:
ziming 2026-03-25 17:29:00 +08:00
parent 5ba27d7f7b
commit 7c851ddb1b
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/biz/wechat_notify.go
View File

@ -9,9 +9,9 @@ import (
"voucher/internal/pkg/lock" "voucher/internal/pkg/lock"
) )
func (this *VoucherBiz) WechatNotifyConsumer(ctx context.Context, ip, tag string, req *bo.WechatVoucherNotifyBo) error { func (this *VoucherBiz) WechatNotifyConsumer(ctx context.Context, ip string, req *bo.WechatVoucherNotifyBo) error {
c := vo.WechatNotifyConsumeLockKey.BuildCache([]string{tag, req.PlainText.StockID, req.PlainText.CouponID}) c := vo.WechatNotifyConsumeLockKey.BuildCache([]string{req.PlainText.StockCreatorMchid, req.PlainText.StockID, req.PlainText.CouponID})
return lock.NewMutex(this.rdb.Rdb, c.TTL).Lock(ctx, c.Key, func(ctx context.Context) error { return lock.NewMutex(this.rdb.Rdb, c.TTL).Lock(ctx, c.Key, func(ctx context.Context) error {
@ -21,7 +21,7 @@ func (this *VoucherBiz) WechatNotifyConsumer(ctx context.Context, ip, tag string
} }
if order.ActivityId != "" { if order.ActivityId != "" {
return this.MultiBiz.Run(ctx, ip, "lsxd_"+req.PlainText.StockCreatorMchid, req, order) return this.MultiBiz.Run(ctx, ip, req.PlainText.StockCreatorMchid, req, order)
} }
if req.PlainText.Status.IsSended() { if req.PlainText.Status.IsSended() {

2
internal/service/notify.go
View File

@ -66,7 +66,7 @@ func (srv *NotifyService) Notify(ctx http.Context) error {
ip := helper.GetClientIP(ctx) ip := helper.GetClientIP(ctx)
if err = srv.VoucherBiz.WechatNotifyConsumer(ctx, ip, "WECHAT_NOTIFY", response); err != nil { if err = srv.VoucherBiz.WechatNotifyConsumer(ctx, ip, response); err != nil {
log.Errorf("微信回调通知[%s],处理失败,headers:%+v,body:%s,err:%s", mchId, headers, string(bodyBytes), err.Error()) log.Errorf("微信回调通知[%s],处理失败,headers:%+v,body:%s,err:%s", mchId, headers, string(bodyBytes), err.Error())
return ctx.JSON(http2.StatusBadRequest, map[string]string{ return ctx.JSON(http2.StatusBadRequest, map[string]string{

2
internal/service/voucher.go
View File

@ -133,5 +133,5 @@ func (v *VoucherService) WechatUseNotifyConsumer(ctx context.Context, tag, msg s
return err return err
} }
return v.VoucherBiz.WechatNotifyConsumer(ctx, "127.0.0.1", tag, req) return v.VoucherBiz.WechatNotifyConsumer(ctx, "127.0.0.1", req)
} }