This commit is contained in:
李子铭 2025-03-21 08:57:23 +08:00
parent aa2d5a5069
commit 609fe56f75
1 changed files with 1 additions and 1 deletions

View File

@ -39,7 +39,7 @@ func (p *OrderRepoImpl) FindInBatches(ctx context.Context, w *bo.FindInBatchesUs
Where("type = ?", w.Type). Where("type = ?", w.Type).
Where("status IN (?)", []uint8{vo.OrderStatusSuccess.GetValue(), vo.OrderStatusUse.GetValue()}). Where("status IN (?)", []uint8{vo.OrderStatusSuccess.GetValue(), vo.OrderStatusUse.GetValue()}).
Where("receive_success_time BETWEEN ? AND ?", w.StartTime, w.EndTime). Where("receive_success_time BETWEEN ? AND ?", w.StartTime, w.EndTime).
Where("product_no <>", "001"). // 跳过压测的订单数据 Where("product_no <> ?", "001"). // 跳过压测的订单数据
FindInBatches(&results, 100, func(tx *gorm.DB, batch int) error { FindInBatches(&results, 100, func(tx *gorm.DB, batch int) error {
// tx.RowsAffected 提供当前批处理中记录的计数the count of records in the current batch // tx.RowsAffected 提供当前批处理中记录的计数the count of records in the current batch
// 'batch' 变量表示当前批号the current batch number // 'batch' 变量表示当前批号the current batch number