xx

cmd/server/wire.go

@@ -10,6 +10,7 @@ import (
 	"github.com/go-kratos/kratos/v2/log"
 	"github.com/google/wire"
 	"voucher/internal/biz"
+	"voucher/internal/biz/cmb"
 	"voucher/internal/conf"
 	"voucher/internal/data"
 	"voucher/internal/data/mixrepoimpl"
@@ -26,6 +27,7 @@ func wireApp(*conf.Bootstrap, log.Logger, *log2.AccessLogger) (*kratos.App, func
 	panic(wire.Build(
 		server.ProviderSetServer,
 		service.ProviderSetService,
+		cmb.ProviderSetCmb,
 		biz.ProviderSetBiz,
 		data.ProviderDataSet,
 		repoimpl.ProviderRepoImplSet,

cmd/server/wire_gen.go

@@ -9,7 +9,7 @@ package main
 import (
 	"github.com/go-kratos/kratos/v2"
 	"github.com/go-kratos/kratos/v2/log"
-	"voucher/internal/biz"
+	"voucher/internal/biz/cmb"
 	"voucher/internal/conf"
 	"voucher/internal/data"
 	"voucher/internal/data/mixrepoimpl"
@@ -48,7 +48,7 @@ func wireApp(bootstrap *conf.Bootstrap, logger log.Logger, accessLogger *log2.Ac
 		return nil, nil, err
 	}
 	generateMixRepo := mixrepoimpl.NewGenerateMixRepoImpl(rdb)
-	voucherBiz := biz.NewVoucherBiz(rdb, orderRepo, thirdMQSend, wechatCpnRepo, generateMixRepo)
+	voucherBiz := cmb.NewCmb(rdb, orderRepo, thirdMQSend, wechatCpnRepo, generateMixRepo)
 	voucherService := service.NewVoucherService(bootstrap, voucherBiz)
 	httpServer := server.NewHTTPServer(bootstrap, helper, accessLogger, voucherService)
 	consumer := server.NewConsumer(helper, bootstrap, voucherService)

internal/biz/cmb/cmb.go

@@ -1 +1,36 @@
 package cmb
+
+import (
+	"voucher/internal/biz/mixrepos"
+	"voucher/internal/biz/repo"
+	"voucher/internal/biz/thirdrepo"
+	"voucher/internal/biz/wechatrepo"
+	"voucher/internal/data"
+)
+
+type Cmb struct {
+	rdb             *data.Rdb
+	OrderRepo       repo.OrderRepo
+	ProductRepo     repo.ProductRepo
+	ThirdMQSend     thirdrepo.ThirdMQSend
+	WechatCpnRepo   wechatrepo.WechatCpnRepo
+	GenerateMixRepo mixrepos.GenerateMixRepo
+}
+
+func NewCmb(
+	rdb *data.Rdb,
+	orderRepo repo.OrderRepo,
+	ProductRepo repo.ProductRepo,
+	thirdMQSend thirdrepo.ThirdMQSend,
+	WechatCpnRepo wechatrepo.WechatCpnRepo,
+	GenerateMixRepo mixrepos.GenerateMixRepo,
+) *Cmb {
+	return &Cmb{
+		rdb:             rdb,
+		OrderRepo:       orderRepo,
+		ProductRepo:     ProductRepo,
+		ThirdMQSend:     thirdMQSend,
+		WechatCpnRepo:   WechatCpnRepo,
+		GenerateMixRepo: GenerateMixRepo,
+	}
+}

internal/biz/cmb/consume.go

@@ -0,0 +1,17 @@
+package cmb
+
+import (
+	"context"
+)
+
+func (v *Cmb) OrderConsume(ctx context.Context, orderNo string) (err error) {
+	return
+}
+
+func (v *Cmb) QueryConsume(ctx context.Context, orderNo string) (err error) {
+	return
+}
+
+func (v *Cmb) NotifyConsume(ctx context.Context, orderNo string) (err error) {
+	return
+}

internal/biz/cmb/provider_set.go

@@ -0,0 +1,8 @@
+package cmb
+
+import (
+	"github.com/google/wire"
+)
+
+// ProviderSetCmb is biz providers.
+var ProviderSetCmb = wire.NewSet(NewCmb)

internal/biz/cmb/voucher.go

@@ -1,4 +1,4 @@
-package biz
+package cmb
 
 import (
 	"context"
@@ -12,7 +12,7 @@ import (
 	"voucher/internal/pkg/uid"
 )
 
-func (v *VoucherBiz) CmbOrder(ctx context.Context, req *bo.OrderCreateReqBo) (reps *bo.OrderCreateRepBo, err error) {
+func (v *Cmb) CmbOrder(ctx context.Context, req *bo.OrderCreateReqBo) (reps *bo.OrderCreateRepBo, err error) {
 
 	err = lock.NewMutex(v.rdb.Rdb, time.Second*30).Lock(ctx, fmt.Sprintf("cmb_order_%s", req.OutBizNo), func(ctx context.Context) error {
 
@@ -63,7 +63,7 @@ func (v *VoucherBiz) CmbOrder(ctx context.Context, req *bo.OrderCreateReqBo) (re
 	return
 }
 
-func (v *VoucherBiz) CmbQuery(ctx context.Context, req *bo.OrderCreateReqBo) (reps *bo.OrderCreateRepBo, err error) {
+func (v *Cmb) CmbQuery(ctx context.Context, req *bo.OrderCreateReqBo) (reps *bo.OrderCreateRepBo, err error) {
 
 	err = lock.NewMutex(v.rdb.Rdb, time.Second*30).Lock(ctx, fmt.Sprintf("cmb_order_%s", req.OutBizNo), func(ctx context.Context) error {
 
@@ -73,6 +73,6 @@ func (v *VoucherBiz) CmbQuery(ctx context.Context, req *bo.OrderCreateReqBo) (re
 	return
 }
 
-func (v *VoucherBiz) CmbNotify(ctx context.Context, order *bo.OrderBo) (err error) {
+func (v *Cmb) CmbNotify(ctx context.Context, order *bo.OrderBo) (err error) {
 	return
 }

internal/biz/consume/consume.go

@@ -1 +0,0 @@
-package consume

internal/biz/consume/notify.go

@@ -1 +0,0 @@
-package consume

internal/biz/consume/order.go

@@ -1 +0,0 @@
-package consume

internal/biz/consume/query.go

@@ -1 +0,0 @@
-package consume

internal/biz/voucher.go

@@ -1,36 +1,21 @@
 package biz
 
 import (
-	"voucher/internal/biz/mixrepos"
+	"voucher/internal/biz/cmb"
-	"voucher/internal/biz/repo"
-	"voucher/internal/biz/thirdrepo"
-	"voucher/internal/biz/wechatrepo"
 	"voucher/internal/data"
 )
 
 type VoucherBiz struct {
-	rdb             *data.Rdb
+	rdb *data.Rdb
-	OrderRepo       repo.OrderRepo
+	Cmb *cmb.Cmb
-	ProductRepo     repo.ProductRepo
-	ThirdMQSend     thirdrepo.ThirdMQSend
-	WechatCpnRepo   wechatrepo.WechatCpnRepo
-	GenerateMixRepo mixrepos.GenerateMixRepo
 }
 
 func NewVoucherBiz(
 	rdb *data.Rdb,
-	orderRepo repo.OrderRepo,
+	Cmb *cmb.Cmb,
-	ProductRepo repo.ProductRepo,
-	thirdMQSend thirdrepo.ThirdMQSend,
-	WechatCpnRepo wechatrepo.WechatCpnRepo,
-	GenerateMixRepo mixrepos.GenerateMixRepo,
 ) *VoucherBiz {
 	return &VoucherBiz{
-		rdb:             rdb,
+		rdb: rdb,
-		OrderRepo:       orderRepo,
+		Cmb: Cmb,
-		ProductRepo:     ProductRepo,
-		ThirdMQSend:     thirdMQSend,
-		WechatCpnRepo:   WechatCpnRepo,
-		GenerateMixRepo: GenerateMixRepo,
 	}
 }