From b70eda503b8a2178b34af30ab8e23876a9e9f038 Mon Sep 17 00:00:00 2001 From: ziming Date: Fri, 6 Jun 2025 09:16:50 +0800 Subject: [PATCH] WechatQuery --- internal/biz/repo/order.go | 2 +- internal/biz/wechat_query.go | 2 +- internal/data/repoimpl/order.go | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/biz/repo/order.go b/internal/biz/repo/order.go index 2cb954f..e3520d8 100644 --- a/internal/biz/repo/order.go +++ b/internal/biz/repo/order.go @@ -7,7 +7,7 @@ import ( ) type OrderRepo interface { - FinByStockIdInBatches(ctx context.Context, batchNo string, fun func(ctx context.Context, rows []*bo.OrderBo) error) error + FinSucByStockIdInBatches(ctx context.Context, batchNo string, fun func(ctx context.Context, rows []*bo.OrderBo) error) error FinFailByStockIdInBatches(ctx context.Context, batchNo string, fun func(ctx context.Context, rows []*bo.OrderBo) error) error FindIngInBatches(ctx context.Context, fun func(ctx context.Context, rows []*bo.OrderBo) error) error FindInBatches(ctx context.Context, w *bo.FindInBatchesUseBo, fun func(ctx context.Context, rows []*bo.OrderBo) error) error diff --git a/internal/biz/wechat_query.go b/internal/biz/wechat_query.go index 4ab32b2..b725138 100644 --- a/internal/biz/wechat_query.go +++ b/internal/biz/wechat_query.go @@ -35,7 +35,7 @@ func (v *VoucherBiz) WechatQuery(ctx context.Context, batchNo string) error { fmt.Printf("微信券查询处理开始:%s,batchNo:%s", start.String(), batchNo) num := 0 - err := v.OrderRepo.FinByStockIdInBatches(ctx, batchNo, func(ctx context.Context, rows []*bo.OrderBo) error { + err := v.OrderRepo.FinSucByStockIdInBatches(ctx, batchNo, func(ctx context.Context, rows []*bo.OrderBo) error { for _, order := range rows { diff --git a/internal/data/repoimpl/order.go b/internal/data/repoimpl/order.go index 0be4e8b..d00826f 100644 --- a/internal/data/repoimpl/order.go +++ b/internal/data/repoimpl/order.go @@ -30,7 +30,7 @@ func (p *OrderRepoImpl) DB(ctx context.Context) *gorm.DB { return p.db.DB(ctx).Model(model.Order{}) } -func (p *OrderRepoImpl) FinByStockIdInBatches(ctx context.Context, batchNo string, fun func(ctx context.Context, rows []*bo.OrderBo) error) error { +func (p *OrderRepoImpl) FinSucByStockIdInBatches(ctx context.Context, batchNo string, fun func(ctx context.Context, rows []*bo.OrderBo) error) error { var results = make([]*model.Order, 0)