This commit is contained in:
李子铭 2025-03-05 14:31:08 +08:00
parent d34f77853f
commit 110fdd5221
1 changed files with 2 additions and 2 deletions

View File

@ -43,14 +43,14 @@ func wireApp(bootstrap *conf.Bootstrap, logger log.Logger, accessLogger *log2.Ac
return nil, nil, err
}
generateMixRepo := mixrepoimpl.NewGenerateMixRepoImpl(rdb)
cmbCmb := cmb.NewCmb(rdb, orderRepo, orderWechatRepo, productRepo, wechatCpnRepo, generateMixRepo)
cmbCmb := cmb.NewCmb(bootstrap, orderRepo, orderWechatRepo, productRepo, wechatCpnRepo, generateMixRepo)
rocketMQ, cleanup2, err := data.NewRocketMQ(bootstrap)
if err != nil {
cleanup()
return nil, nil, err
}
mqSendMixRepo := mixrepoimpl.NewMQSendMixRepoImpl(rocketMQ)
voucherBiz := biz.NewVoucherBiz(bootstrap, rdb, cmbCmb, orderRepo, mqSendMixRepo)
voucherBiz := biz.NewVoucherBiz(bootstrap, rdb, cmbCmb, productRepo, orderRepo, mqSendMixRepo, wechatCpnRepo)
voucherService := service.NewVoucherService(bootstrap, voucherBiz)
httpServer := server.NewHTTPServer(bootstrap, helper, accessLogger, voucherService)
consumer := server.NewConsumer(helper, bootstrap, voucherService)