|
...
|
...
|
@@ -31,9 +31,9 @@ func (rs *NodeTaskService) SendEvaluationNode() error { |
|
|
|
defer func() {
|
|
|
|
transactionContext.RollbackTransaction()
|
|
|
|
|
|
|
|
// 异常捕获
|
|
|
|
recError := recover()
|
|
|
|
log.Logger.Error(application.ThrowError(application.BUSINESS_ERROR, fmt.Sprintf("定时发送评估任务异常：%s", recError)).Error())
|
|
|
|
if err := recover(); err != nil {
|
|
|
|
log.Logger.Error(application.ThrowError(application.BUSINESS_ERROR, fmt.Sprintf("定时发送评估任务异常：%s", err)).Error())
|
|
|
|
}
|
|
|
|
}()
|
|
|
|
taskRepository := factory.CreateNodeTaskRepository(map[string]interface{}{"transactionContext": transactionContext})
|
|
|
|
tasks, err := taskRepository.Find(map[string]interface{}{"now": time.Now().Local()})
|
...
|
...
|
|
