diff --git a/internal/data/repoimpl/product.go b/internal/data/repoimpl/product.go
index 5f92646..220b49c 100644
--- a/internal/data/repoimpl/product.go
+++ b/internal/data/repoimpl/product.go
@@ -42,6 +42,7 @@ func (r *ProductRepoImpl) FindWarningBudget(ctx context.Context, fun func(ctx co
 		Where("end_time > ?", nowTime).
 		Where("warning_budget > 0").
 		Where("warning_person IS NOT NULL").
+		Group("batch_no").
 		FindInBatches(&results, 5, func(tx *gorm.DB, batch int) error {
 			return fun(ctx, r.ToBos(results))
 		})