diff --git a/internal/biz/cmb/cmb.go b/internal/biz/cmb/cmb.go index fbb54dd..a9f2f13 100644 --- a/internal/biz/cmb/cmb.go +++ b/internal/biz/cmb/cmb.go @@ -14,6 +14,7 @@ type Cmb struct { ProductRepo repo.ProductRepo WechatCpnRepo wechatrepo.WechatCpnRepo GenerateMixRepo mixrepos.GenerateMixRepo + CmbMixRepo mixrepos.CmbMixRepo } func NewCmb( @@ -23,6 +24,7 @@ func NewCmb( ProductRepo repo.ProductRepo, WechatCpnRepo wechatrepo.WechatCpnRepo, GenerateMixRepo mixrepos.GenerateMixRepo, + CmbMixRepo mixrepos.CmbMixRepo, ) *Cmb { return &Cmb{ bc: bc, @@ -31,5 +33,6 @@ func NewCmb( ProductRepo: ProductRepo, WechatCpnRepo: WechatCpnRepo, GenerateMixRepo: GenerateMixRepo, + CmbMixRepo: CmbMixRepo, } } diff --git a/internal/biz/cmb/consume.go b/internal/biz/cmb/consume.go index e8f7b03..f7ec6a5 100644 --- a/internal/biz/cmb/consume.go +++ b/internal/biz/cmb/consume.go @@ -2,6 +2,7 @@ package cmb import ( "context" + "encoding/json" "fmt" v1 "voucher/api/v1" "voucher/internal/biz/bo" @@ -94,14 +95,26 @@ func (v *Cmb) NotifyConsume(ctx context.Context, order *bo.OrderBo, orderOutRequ return fmt.Errorf("微信订单状态错误,不能通知:%s", order.Status.GetText()) } - request := &v1.CmbNotifyRequest{ + req := &v1.CmbNotifyRequest{ Ticket: orderWechat.OrderNo, Status: "", TransDate: "", OrgNo: "", Ext: "", } - fmt.Printf("request:%+v", request) + bizJsonBytes, err := json.Marshal(req) + if err != nil { + return err + } + bizJsonStr := string(bizJsonBytes) + + request, err := v.CmbMixRepo.BuildRequest(ctx, "updateCodeStatus.json", bizJsonStr) + if err != nil { + return err + } + + // todo + fmt.Print(request) return nil }