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

pro order use notify

This commit is contained in:
ziming 2025-06-09 15:01:52 +08:00
parent 0bd9444026
commit a1271d1fc8
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/data/repoimpl/order.go
View File

@ -66,7 +66,7 @@ func (p *OrderRepoImpl) FinFailByStockIdInBatches(ctx context.Context, batchNo s
Where("batch_no = ?", batchNo). Where("batch_no = ?", batchNo).
Where("status = ?", vo.OrderStatusFail.GetValue()). Where("status = ?", vo.OrderStatusFail.GetValue()).
//Where("remark <> ?", "error: code = 500 reason = WechatFAIL message = 微信返回错误:该用户账号异常，无法领券。商家可联系微信支付或让用户联系微信支付客服处理。 metadat"). //Where("remark <> ?", "error: code = 500 reason = WechatFAIL message = 微信返回错误:该用户账号异常，无法领券。商家可联系微信支付或让用户联系微信支付客服处理。 metadat").
FindInBatches(&results, 50, func(tx *gorm.DB, batch int) error { FindInBatches(&results, 100, func(tx *gorm.DB, batch int) error {
return fun(ctx, p.ToBos(results)) return fun(ctx, p.ToBos(results))
}) })
@ -83,8 +83,8 @@ func (p *OrderRepoImpl) FindIngInBatches(ctx context.Context, fun func(ctx conte
result := p.DB(ctx). result := p.DB(ctx).
Where("status = ?", vo.OrderStatusIng.GetValue()). Where("status = ?", vo.OrderStatusIng.GetValue()).
Limit(100). Limit(20).
FindInBatches(&results, 20, func(tx *gorm.DB, batch int) error { FindInBatches(&results, 10, func(tx *gorm.DB, batch int) error {
return fun(ctx, p.ToBos(results)) return fun(ctx, p.ToBos(results))
}) })