diff --git a/internal/biz/order_notice.go b/internal/biz/order_notice.go index 3b23f41..e7b3956 100644 --- a/internal/biz/order_notice.go +++ b/internal/biz/order_notice.go @@ -54,6 +54,8 @@ func (v *VoucherBiz) ExecuteNotice(ctx context.Context) error { } + time.Sleep(1 * time.Second) + return nil }) diff --git a/internal/data/repoimpl/order.go b/internal/data/repoimpl/order.go index 5008c73..009bf47 100644 --- a/internal/data/repoimpl/order.go +++ b/internal/data/repoimpl/order.go @@ -33,9 +33,9 @@ func (p *OrderRepoImpl) FindInBatches(ctx context.Context, w *bo.FindInBatchesUs var results = make([]*model.Order, 0) result := p.db.DB(ctx). - Where("receive_success_time BETWEEN ? AND ?", w.StartTime, w.EndTime). Where("type = ?", w.Type). Where("status IN (?)", []uint8{vo.OrderStatusSuccess.GetValue(), vo.OrderStatusUse.GetValue()}). + Where("receive_success_time BETWEEN ? AND ?", w.StartTime, w.EndTime). FindInBatches(&results, 100, func(tx *gorm.DB, batch int) error { // tx.RowsAffected 提供当前批处理中记录的计数(the count of records in the current batch) // 'batch' 变量表示当前批号(the current batch number)