58 lines
1.3 KiB
Go
58 lines
1.3 KiB
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
"github.com/go-kratos/kratos/v2/log"
|
|
"github.com/robfig/cron"
|
|
v1 "voucher/api/v1"
|
|
"voucher/internal/biz"
|
|
"voucher/internal/biz/bo"
|
|
"voucher/internal/biz/mixrepos"
|
|
"voucher/internal/biz/vo"
|
|
"voucher/internal/biz/wechatrepo"
|
|
"voucher/internal/conf"
|
|
)
|
|
|
|
var _ v1.CmbHTTPServer = (*CmbService)(nil)
|
|
|
|
type CmbService struct {
|
|
bc *conf.Bootstrap
|
|
cron *cron.Cron
|
|
VoucherBiz *biz.VoucherBiz
|
|
CmbMixRepo mixrepos.CmbMixRepo
|
|
WechatCpnRepo wechatrepo.WechatCpnRepo
|
|
}
|
|
|
|
func NewCmbService(
|
|
bc *conf.Bootstrap,
|
|
cron *cron.Cron,
|
|
VoucherBiz *biz.VoucherBiz,
|
|
CmbMixRepo mixrepos.CmbMixRepo,
|
|
WechatCpnRepo wechatrepo.WechatCpnRepo,
|
|
) *CmbService {
|
|
return &CmbService{
|
|
bc: bc,
|
|
cron: cron,
|
|
VoucherBiz: VoucherBiz,
|
|
CmbMixRepo: CmbMixRepo,
|
|
WechatCpnRepo: WechatCpnRepo,
|
|
}
|
|
}
|
|
|
|
func (c *CmbService) GetResponse(ctx context.Context, replyBizContent []byte) (*v1.CmbReply, error) {
|
|
|
|
req := &bo.CmbResponseBo{
|
|
RespCode: vo.CmbResponseStatusSuccess.GetValue(),
|
|
RespMsg: "成功",
|
|
BizContent: string(replyBizContent),
|
|
}
|
|
|
|
reply, err := c.CmbMixRepo.GetResponse(ctx, req)
|
|
if err != nil {
|
|
log.Errorf("build cmb response fail: %v", err)
|
|
return nil, err
|
|
}
|
|
|
|
return reply, nil
|
|
}
|