|
...
|
...
|
@@ -3,12 +3,13 @@ package repository |
|
|
|
import (
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
"github.com/go-pg/pg/v10"
|
|
|
|
pgTransaction "github.com/linmadan/egglib-go/transaction/pg"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/pg/models"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/utils"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
|
|
|
type NodeTaskRepository struct {
|
|
...
|
...
|
@@ -127,7 +128,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)
|
|
|
|
}
|
|
|
|
|
...
|
...
|
|
