|
|
@ -54,11 +54,19 @@ func (env *Env) BackgroundJobRunner() { |
|
|
|
} |
|
|
|
|
|
|
|
var jobToDo Booking |
|
|
|
err := tx.Model(&jobToDo). |
|
|
|
Where("user_id NOT IN (?)", userIDArr). |
|
|
|
Where("status = ?", "pending"). |
|
|
|
Preload("User"). |
|
|
|
First(&jobToDo).Error |
|
|
|
var err error |
|
|
|
if len(userIDArr) > 0 { |
|
|
|
err = tx.Model(&jobToDo). |
|
|
|
Where("user_id NOT IN (?)", userIDArr). |
|
|
|
Where("status = ?", "pending"). |
|
|
|
Preload("User"). |
|
|
|
First(&jobToDo).Error |
|
|
|
} else { |
|
|
|
err = tx.Model(&jobToDo). |
|
|
|
Where("status = ?", "pending"). |
|
|
|
Preload("User"). |
|
|
|
First(&jobToDo).Error |
|
|
|
} |
|
|
|
|
|
|
|
// if no jobs pending found
|
|
|
|
if err != nil { |
|
|
|