作者 tangxvhui

调试定时任务

... ... @@ -15,7 +15,7 @@ import (
func main() {
startNodeTask()
// startSummaryEvaluation()
//startSummaryEvaluation()
go consumer.Run()
web.Run()
}
... ...
... ... @@ -72,8 +72,7 @@ func (repo *EvaluationItemUsedRepository) BatchInsert(items []*domain.Evaluation
func (repo *EvaluationItemUsedRepository) Find(queryOptions map[string]interface{}) (int, []*domain.EvaluationItemUsed, error) {
tx := repo.transactionContext.PgTx
var m []*models.EvaluationItemUsed
query := tx.Model(&m).
Where("deleted_at isnull")
query := tx.Model(&m)
if v, ok := queryOptions["limit"].(int); ok {
query.Limit(v)
}
... ...