From 9b8823cc29ee43d25e9cb851496194f861ddbc5c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Wed, 5 Mar 2025 18:23:24 +0800 Subject: [PATCH] cmb --- internal/biz/cmb/consume.go | 2 +- internal/biz/mixrepos/cmb.go | 2 +- internal/data/mixrepoimpl/cmb.go | 12 +++++++++++- internal/service/cmb_mock.go | 4 ++-- 4 files changed, 15 insertions(+), 5 deletions(-) diff --git a/internal/biz/cmb/consume.go b/internal/biz/cmb/consume.go index f7ec6a5..43a5de4 100644 --- a/internal/biz/cmb/consume.go +++ b/internal/biz/cmb/consume.go @@ -109,7 +109,7 @@ func (v *Cmb) NotifyConsume(ctx context.Context, order *bo.OrderBo, orderOutRequ bizJsonStr := string(bizJsonBytes) - request, err := v.CmbMixRepo.BuildRequest(ctx, "updateCodeStatus.json", bizJsonStr) + request, err := v.CmbMixRepo.GetRequestData(ctx, "updateCodeStatus.json", bizJsonStr) if err != nil { return err } diff --git a/internal/biz/mixrepos/cmb.go b/internal/biz/mixrepos/cmb.go index 934f220..6925a27 100644 --- a/internal/biz/mixrepos/cmb.go +++ b/internal/biz/mixrepos/cmb.go @@ -6,5 +6,5 @@ import ( ) type CmbMixRepo interface { - BuildRequest(ctx context.Context, funcName, bizJsonStr string) (*v1.CmbRequest, error) + GetRequestData(ctx context.Context, funcName, bizJsonStr string) (*v1.CmbRequest, error) } diff --git a/internal/data/mixrepoimpl/cmb.go b/internal/data/mixrepoimpl/cmb.go index e8bc3ea..a0af044 100644 --- a/internal/data/mixrepoimpl/cmb.go +++ b/internal/data/mixrepoimpl/cmb.go @@ -20,7 +20,7 @@ func NewCmbMixRepoImpl(bc *conf.Bootstrap) mixrepos.CmbMixRepo { return &CmbMixRepoImpl{bc: bc} } -func (s *CmbMixRepoImpl) BuildRequest(_ context.Context, funcName, bizJsonStr string) (*v1.CmbRequest, error) { +func (s *CmbMixRepoImpl) GetRequestData(_ context.Context, funcName, bizJsonStr string) (*v1.CmbRequest, error) { // 我们的sm2 公钥加密 // 请求到我们这边 使用 我们的私钥解密 encryptBody, err := cmb.Encrypt(s.bc.Cmb.Sm2Puk, bizJsonStr) @@ -64,3 +64,13 @@ func (s *CmbMixRepoImpl) BuildRequest(_ context.Context, funcName, bizJsonStr st return reply, nil } + +func (s *CmbMixRepoImpl) Request(ctx context.Context, funcName, bizJsonStr string) (*v1.CmbRequest, error) { + data, err := s.GetRequestData(ctx, funcName, bizJsonStr) + if err != nil { + return nil, err + } + fmt.Print(data) + + return nil, nil +} diff --git a/internal/service/cmb_mock.go b/internal/service/cmb_mock.go index d5082e1..6cf935a 100644 --- a/internal/service/cmb_mock.go +++ b/internal/service/cmb_mock.go @@ -20,7 +20,7 @@ func (s *VoucherService) CmbOrderMock(ctx http.Context) error { bizJsonStr := string(bizJsonBytes) - reply, err := s.CmbMixRepo.BuildRequest(ctx, "/voucher/cmb/v1/order", bizJsonStr) + reply, err := s.CmbMixRepo.GetRequestData(ctx, "/voucher/cmb/v1/order", bizJsonStr) if err != nil { return err } @@ -42,7 +42,7 @@ func (s *VoucherService) CmbProductQueryMock(ctx http.Context) error { bizJsonStr := string(bizJsonBytes) - reply, err := s.CmbMixRepo.BuildRequest(ctx, "/voucher/cmb/v1/productQuery", bizJsonStr) + reply, err := s.CmbMixRepo.GetRequestData(ctx, "/voucher/cmb/v1/productQuery", bizJsonStr) if err != nil { return err }