From 89bd70819f1c01da8dd51fb22709fb20af78921b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Wed, 15 Sep 2021 17:53:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=9F=A5=E6=89=BE=E5=8C=BA?= =?UTF-8?q?=E5=9F=9F=E7=9B=91=E6=8E=A7=E5=AF=B9=E8=B1=A1=E7=9B=B8=E5=85=B3?= =?UTF-8?q?=E7=BB=93=E6=9E=9CAPI?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/db/models/report_result_dao.go | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/internal/db/models/report_result_dao.go b/internal/db/models/report_result_dao.go index b415625b..1cbdb02d 100644 --- a/internal/db/models/report_result_dao.go +++ b/internal/db/models/report_result_dao.go @@ -99,7 +99,6 @@ func (this *ReportResultDAO) ListResults(tx *dbs.Tx, reportNodeId int64, okState query.Attr("level", level) } _, err = query. - Attr("reportNodeId", reportNodeId). Gt("updatedAt", time.Now().Unix()-600). Offset(offset). Limit(size). @@ -109,6 +108,19 @@ func (this *ReportResultDAO) ListResults(tx *dbs.Tx, reportNodeId int64, okState return } +// FindAllResults 列出所有结果 +func (this *ReportResultDAO) FindAllResults(tx *dbs.Tx, taskType string, targetId int64) (result []*ReportResult, err error) { + _, err = this.Query(tx). + Attr("type", taskType). + Attr("targetId", targetId). + Gt("updatedAt", time.Now().Unix()-600). + Desc("isOk"). + Asc("costMs"). + Slice(&result). + FindAll() + return +} + // FindAvgCostMsWithTarget 获取某个对象的平均耗时 func (this *ReportResultDAO) FindAvgCostMsWithTarget(tx *dbs.Tx, taskType reporterconfigs.TaskType, targetId int64) (float64, error) { return this.Query(tx).