@@ -162,10 +162,8 @@ func (im *InvoiceManager) RunJob(ctx context.Context) {
case im.RunPool <- true:
case <-time.After(time.Minute * 5):
g.Log().Infof(ctx, "RunJob-等待回调完成超时")
- return
}
<-im.RunPool
-
g.Log().Infof(ctx, "RunJob-multipleOrdersMakeRedInvoice任务完成 共%d个 完成%d个", total, okNum)