package com.flightfeather.uav.biz.report
|
|
import com.flightfeather.uav.biz.sourcetrace.model.PollutedClue
|
import com.flightfeather.uav.common.utils.MapUtil
|
import com.flightfeather.uav.domain.entity.SceneInfo
|
import com.flightfeather.uav.domain.entity.avg
|
import com.flightfeather.uav.socket.eunm.AggregatedFactorType
|
|
/**
|
* 走航典型隐患区域
|
* @date 2025/8/25 14:18
|
* @author feiyu
|
*/
|
class MissionRiskArea {
|
|
class ClueByArea {
|
var sceneInfo: SceneInfo? = null
|
var address: String? = null
|
var clueByFactorList: MutableList<ClueByFactor>? = null
|
}
|
|
class ClueByFactor {
|
var factor: String? = null
|
var clues: MutableList<PollutedClue>? = null
|
}
|
|
/**
|
* 生成走航典型隐患区域，根据关键场景列表进行分组
|
* @param keyScenes 关键场景列表
|
* @param pollutedClues 污染线索列表
|
* @return 按区域和因子分组的污染线索
|
*/
|
fun generateClueByKeyRiskScene(keyScenes: List<SceneInfo?>, pollutedClues: List<PollutedClue?>): List<ClueByArea> {
|
val result = mutableListOf<ClueByArea>()
|
|
pollutedClues.forEach { pollutedClue ->
|
if (pollutedClue == null) return@forEach
|
val dataList = pollutedClue.pollutedData?.dataList ?: emptyList()
|
if (dataList.isEmpty()) return@forEach
|
|
// 计算单个PollutedClue的均值经纬度
|
val avgData = dataList.avg()
|
val wgs84Lng = avgData.longitude?.toDouble() ?: return@forEach
|
val wgs84Lat = avgData.latitude?.toDouble() ?: return@forEach
|
|
// 坐标转换
|
val gcj02Point = MapUtil.wgs84ToGcj02(wgs84Lng to wgs84Lat)
|
|
// 查找最近场景
|
var minDistance = Double.MAX_VALUE
|
var closestScene: SceneInfo? = null
|
keyScenes.forEach { scene ->
|
scene?.let { s ->
|
val sceneLng = s.longitude?.toDouble() ?: return@let
|
val sceneLat = s.latitude?.toDouble() ?: return@let
|
val distance = MapUtil.getDistance(gcj02Point.first, gcj02Point.second, sceneLng, sceneLat)
|
if (distance < minDistance) {
|
minDistance = distance
|
closestScene = s
|
}
|
}
|
}
|
|
// 按场景和因子分组线索
|
closestScene?.let { scene ->
|
var clueByArea = result.find { it.sceneInfo?.guid == scene.guid }
|
if (clueByArea == null) {
|
clueByArea = ClueByArea().apply {
|
this.sceneInfo = scene
|
this.clueByFactorList = mutableListOf()
|
}
|
result.add(clueByArea)
|
}
|
|
val firstFactorType = pollutedClue.pollutedData?.statisticMap?.keys?.first()
|
val afType = AggregatedFactorType.getAFType(firstFactorType)
|
val factorName = afType?.des ?: firstFactorType?.des
|
var clueByFactor = clueByArea.clueByFactorList?.find { it.factor == factorName }
|
if (clueByFactor == null) {
|
clueByFactor = ClueByFactor().apply {
|
this.factor = factorName
|
this.clues = mutableListOf()
|
}
|
clueByArea.clueByFactorList?.add(clueByFactor)
|
}
|
|
clueByFactor.clues?.add(pollutedClue)
|
}
|
}
|
|
return result
|
}
|
|
/**
|
* 生成走航典型隐患区域，根据污染线索溯源地址进行分组
|
* @param pollutedClues 污染线索列表
|
* @return 按区域和因子分组的污染线索
|
*/
|
fun generateClueByRiskArea(pollutedClues: List<PollutedClue?>): List<ClueByArea> {
|
val result = mutableListOf<ClueByArea>()
|
|
pollutedClues.forEach { pollutedClue ->
|
if (pollutedClue == null) return@forEach
|
val dataList = pollutedClue.pollutedData?.dataList ?: emptyList()
|
if (dataList.isEmpty()) return@forEach
|
|
// 按污染溯源地址和因子分组线索
|
pollutedClue.pollutedArea?.address?.let { address ->
|
var clueByArea = result.find { it.address == address }
|
if (clueByArea == null) {
|
clueByArea = ClueByArea().apply {
|
this.address = address
|
this.clueByFactorList = mutableListOf()
|
}
|
result.add(clueByArea)
|
}
|
|
val firstFactorType = pollutedClue.pollutedData?.statisticMap?.keys?.first()
|
val afType = AggregatedFactorType.getAFType(firstFactorType)
|
val factorName = afType?.des ?: firstFactorType?.des
|
var clueByFactor = clueByArea.clueByFactorList?.find { it.factor == factorName }
|
if (clueByFactor == null) {
|
clueByFactor = ClueByFactor().apply {
|
this.factor = factorName
|
this.clues = mutableListOf()
|
}
|
clueByArea.clueByFactorList?.add(clueByFactor)
|
}
|
|
clueByFactor.clues?.add(pollutedClue)
|
}
|
}
|
|
return result
|
}
|
}
|
