|
...
|
...
|
@@ -127,7 +127,6 @@ func (repo *NodeTaskRepository) Find(queryOptions map[string]interface{}) ([]*do |
|
|
|
query := tx.Model(&m).Where("deleted_at isnull")
|
|
|
|
|
|
|
|
if v, ok := queryOptions["now"].(time.Time); ok {
|
|
|
|
query.Where("next_sent_at isnull")
|
|
|
|
query.Where("next_sent_at <= ?", v)
|
|
|
|
}
|
|
|
|
|
...
|
...
|
|
