| | |
|---|
| | | 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 |
|---|
| | | }) |
|---|
| | | } |
|---|
