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