|
|
@ -59,11 +59,13 @@ func (env *Env) BackgroundJobRunner() { |
|
|
|
err = tx.Model(&jobToDo). |
|
|
|
Where("user_id NOT IN (?)", userIDArr). |
|
|
|
Where("status = ?", "pending"). |
|
|
|
Order("created_at asc"). |
|
|
|
Preload("User"). |
|
|
|
First(&jobToDo).Error |
|
|
|
} else { |
|
|
|
err = tx.Model(&jobToDo). |
|
|
|
Where("status = ?", "pending"). |
|
|
|
Order("created_at asc"). |
|
|
|
Preload("User"). |
|
|
|
First(&jobToDo).Error |
|
|
|
} |
|
|
|