liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

查询

This commit is contained in:
李子铭 2025-03-20 19:50:41 +08:00
parent a1750d6959
commit aa2d5a5069
3 changed files with 8 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/biz/cmb.go
View File

@ -144,11 +144,13 @@ func (v *VoucherBiz) CmbProductQuery(ctx context.Context, productNo string) (rep
} }
if wechatResp.StartTime != nil { if wechatResp.StartTime != nil {
// 批次激活开启时间
s, _ := time.Parse(inputFormat, *wechatResp.StartTime) s, _ := time.Parse(inputFormat, *wechatResp.StartTime)
reps.SaleStartTime = s.Format(time.DateTime) reps.SaleStartTime = s.Format(time.DateTime)
} }
if wechatResp.StopTime != nil { if wechatResp.StopTime != nil {
// 批次永久停止时间
e, _ := time.Parse(inputFormat, *wechatResp.StopTime) e, _ := time.Parse(inputFormat, *wechatResp.StopTime)
reps.SaleEndTime = e.Format(time.DateTime) reps.SaleEndTime = e.Format(time.DateTime)
} }

8
internal/data/mixrepoimpl/generate.go
View File

@ -6,19 +6,15 @@ import (
"github.com/bwmarrin/snowflake" "github.com/bwmarrin/snowflake"
"os" "os"
"voucher/internal/biz/mixrepos" "voucher/internal/biz/mixrepos"
"voucher/internal/data"
"voucher/internal/pkg/helper" "voucher/internal/pkg/helper"
) )
type GenerateRepoImpl struct { type GenerateRepoImpl struct {
rdb *data.Rdb
node *snowflake.Node node *snowflake.Node
} }
func NewGenerateMixRepoImpl(rdb *data.Rdb) (mixrepos.GenerateMixRepo, error) { func NewGenerateMixRepoImpl() (mixrepos.GenerateMixRepo, error) {
g := &GenerateRepoImpl{}
g := &GenerateRepoImpl{rdb: rdb}
name, err := os.Hostname() name, err := os.Hostname()
if err != nil { if err != nil {

8
internal/service/cmb.go
View File

@ -12,7 +12,7 @@ import (
"voucher/internal/biz/vo" "voucher/internal/biz/vo"
) )
func (s *VoucherService) readBody(bodyBytes []byte) (*v1.CmbRequest, error) { func (s *VoucherService) buildCmbRequest(bodyBytes []byte) (*v1.CmbRequest, error) {
var req *v1.CmbRequest var req *v1.CmbRequest
if err := json.Unmarshal(bodyBytes, &req); err != nil { if err := json.Unmarshal(bodyBytes, &req); err != nil {
@ -82,7 +82,7 @@ func (v *VoucherService) cmbOrder(ctx http.Context) (string, error) {
return "", err2.ErrorCmbParamFail(err.Error()) return "", err2.ErrorCmbParamFail(err.Error())
} }
req, err := v.readBody(bodyBytes) req, err := v.buildCmbRequest(bodyBytes)
if err != nil { if err != nil {
return "", err return "", err
} }
@ -160,7 +160,7 @@ func (v *VoucherService) cmbProductQuery(ctx http.Context) (*v1.CmbQueryProductR
return nil, err2.ErrorCmbParamFail(err.Error()) return nil, err2.ErrorCmbParamFail(err.Error())
} }
req, err := v.readBody(bodyBytes) req, err := v.buildCmbRequest(bodyBytes)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -219,7 +219,7 @@ func (v *VoucherService) cmbQuery(ctx http.Context) (*v1.CmbQueryReply, error) {
return nil, err2.ErrorCmbParamFail(err.Error()) return nil, err2.ErrorCmbParamFail(err.Error())
} }
req, err := v.readBody(bodyBytes) req, err := v.buildCmbRequest(bodyBytes)
if err != nil { if err != nil {
return nil, err return nil, err
} }