From a3cc1d220f8a1de11874bebceba0130d32157ff1 Mon Sep 17 00:00:00 2001 From: feiyu02 <risaku@163.com> Date: 星期二, 30 九月 2025 09:26:32 +0800 Subject: [PATCH] 2025.9.30 1. 联合前端调试数据产品接口(待完成) --- src/main/kotlin/cn/flightfeather/supervision/lightshare/service/impl/DataProdBaseServiceImpl.kt | 18 ++++++++++-------- 1 files changed, 10 insertions(+), 8 deletions(-) diff --git a/src/main/kotlin/cn/flightfeather/supervision/lightshare/service/impl/DataProdBaseServiceImpl.kt b/src/main/kotlin/cn/flightfeather/supervision/lightshare/service/impl/DataProdBaseServiceImpl.kt index 0cd663b..d13bfe1 100644 --- a/src/main/kotlin/cn/flightfeather/supervision/lightshare/service/impl/DataProdBaseServiceImpl.kt +++ b/src/main/kotlin/cn/flightfeather/supervision/lightshare/service/impl/DataProdBaseServiceImpl.kt @@ -105,8 +105,7 @@ } } return@queryCache res - }, - save = { } + } ) } @@ -151,7 +150,6 @@ res.sortBy { it.index } return@queryCache res }, - save = { } ) } @@ -202,7 +200,6 @@ res.sortBy { it.index } return@queryCache res }, - save = { } ) } @@ -211,23 +208,28 @@ cache = { return@queryCache null }, calculate = { val res = mutableListOf<DPMonitorDataInfo>() - val objList = aopDbMapper.monitorobjectversionMapper.selectByExample(Example(Monitorobjectversion::class.java).apply { + val sceneIdList = aopDbMapper.monitorobjectversionMapper.selectByExample(Example(Monitorobjectversion::class.java).apply { createCriteria().andEqualTo("tid", queryOpt.topTaskId) + }).map { it.sguid } + if (sceneIdList.isEmpty()) return@queryCache res + + val sceneList = aopDbMapper.scenseMapper.selectByExample(Example(Scense::class.java).apply { + createCriteria().andIn("guid", sceneIdList) + .andEqualTo("typeid", queryOpt.sceneTypeId) }) - if (objList.isEmpty()) return@queryCache res aopDbMapper.dustDataResultMapper.selectByExample(Example(DustDataResult::class.java).apply { createCriteria().andBetween("drTime", queryOpt.startTime, queryOpt.endTime) - .andIn("objectId", objList.map { it.sguid }) + .andIn("drSceneId", sceneList.map { it.guid }) }).forEach { res.add(DPMonitorDataInfo().apply { + scene = sceneList.find { scene -> scene.guid == it?.drSceneId } data = it }) } return@queryCache res }, - save = { } ) } } \ No newline at end of file -- Gitblit v1.9.3