package com.flightfeather.uav.lightshare.web
|
|
import com.fasterxml.jackson.annotation.JsonFormat
|
import com.flightfeather.uav.common.exception.BizException
|
import com.flightfeather.uav.lightshare.bean.AnalysisOption
|
import com.flightfeather.uav.lightshare.bean.AreaVo
|
import com.flightfeather.uav.lightshare.service.DataAnalysisService
|
import com.flightfeather.uav.socket.eunm.FactorType
|
import io.swagger.annotations.Api
|
import io.swagger.annotations.ApiOperation
|
import io.swagger.annotations.ApiParam
|
import org.springframework.format.annotation.DateTimeFormat
|
import org.springframework.web.bind.annotation.*
|
import java.time.LocalDateTime
|
import java.time.ZoneId
|
import java.util.*
|
|
/**
|
* 走航数据分析
|
* @date 2025/5/8
|
* @author feiyu02
|
*/
|
@Api(tags = ["走航数据分析API接口"])
|
@RestController
|
@RequestMapping("air/analysis")
|
class DataAnalysisController(private val dataAnalysisService: DataAnalysisService) {
|
|
@Deprecated("该接口已废弃，使用/report/missionSummary/one接口")
|
@ApiOperation(value = "污染溯源分析")
|
@GetMapping("/pollution/trace")
|
fun pollutionTrace(
|
@ApiParam("走航任务编号") @RequestParam missionCode: String,
|
) = resPack { dataAnalysisService.pollutionTrace(missionCode) }
|
|
@ApiOperation(value = "获取历史污染溯源结果")
|
@GetMapping("/pollution/trace/history")
|
fun fetchHistory(
|
@ApiParam("走航任务编号") @RequestParam missionCode: String,
|
) = resPack { dataAnalysisService.fetchHistory(missionCode) }
|
|
@ApiOperation(value = "生成走航任务汇总统计")
|
@PostMapping("/report/missionSummary")
|
fun generateMissionSummary(
|
@ApiParam("分析选项") @RequestBody analysisOption: AnalysisOption,
|
) = resPack {
|
if (analysisOption.startTime == null || analysisOption.endTime == null || analysisOption.area == null)
|
throw BizException("参数错误, startTime, endTime, area不能为空")
|
val startTime = analysisOption.startTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val endTime = analysisOption.endTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val areaVo = analysisOption.area!!
|
|
dataAnalysisService.generateMissionSummary(
|
Date.from(startTime.atZone(ZoneId.systemDefault()).toInstant()),
|
Date.from(endTime.atZone(ZoneId.systemDefault()).toInstant()),
|
areaVo
|
)
|
}
|
|
@ApiOperation(value = "生成走航任务汇总统计")
|
@GetMapping("/report/missionSummary/one")
|
fun generateOneMissionSummary(
|
@ApiParam("任务编号") @RequestParam missionCode: String,
|
) = resPack { dataAnalysisService.generateMissionSummary(missionCode) }
|
|
@ApiOperation(value = "生成走航任务清单")
|
@PostMapping("/report/missionList")
|
fun generateMissionList(
|
@ApiParam("分析选项") @RequestBody analysisOption: AnalysisOption,
|
) = resPack {
|
if (analysisOption.startTime == null || analysisOption.endTime == null || analysisOption.area == null)
|
throw BizException("参数错误, startTime, endTime, area不能为空")
|
val startTime = analysisOption.startTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val endTime = analysisOption.endTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val areaVo = analysisOption.area!!
|
|
dataAnalysisService.generateMissionList(
|
Date.from(startTime.atZone(ZoneId.systemDefault()).toInstant()),
|
Date.from(endTime.atZone(ZoneId.systemDefault()).toInstant()),
|
areaVo
|
)
|
}
|
|
@ApiOperation(value = "生成走航任务详情")
|
@PostMapping("/report/missionDetail")
|
fun generateMissionDetail(
|
@ApiParam("分析选项") @RequestBody analysisOption: AnalysisOption,
|
) = resPack {
|
if (analysisOption.startTime == null || analysisOption.endTime == null || analysisOption.area == null)
|
throw BizException("参数错误, startTime, endTime, area不能为空")
|
val startTime = analysisOption.startTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val endTime = analysisOption.endTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val areaVo = analysisOption.area!!
|
val granularity = analysisOption.granularity
|
|
dataAnalysisService.generateMissionDetail(
|
Date.from(startTime.atZone(ZoneId.systemDefault()).toInstant()),
|
Date.from(endTime.atZone(ZoneId.systemDefault()).toInstant()),
|
areaVo,granularity
|
)
|
}
|
|
@ApiOperation(value = "生成走航任务详情")
|
@GetMapping("/report/missionDetail/one")
|
fun generateOneMissionDetail(
|
@ApiParam("任务编号") @RequestParam missionCode: String,
|
@ApiParam("数据颗粒度", allowableValues = "SECOND, MINUTE, HOUR") @RequestParam(required = false)
|
granularity: String?,
|
) = resPack { dataAnalysisService.generateMissionDetail(missionCode, granularity) }
|
|
@ApiOperation(value = "走航典型隐患区域统计")
|
@PostMapping("/report/clueByRiskArea")
|
fun generateClueByRiskArea(
|
@ApiParam("分析选项") @RequestBody analysisOption: AnalysisOption,
|
) = resPack {
|
if (analysisOption.startTime == null || analysisOption.endTime == null || analysisOption.area == null)
|
throw BizException("参数错误, startTime, endTime, area不能为空")
|
val startTime = analysisOption.startTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val endTime = analysisOption.endTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val areaVo = analysisOption.area!!
|
dataAnalysisService.generateClueByRiskArea(
|
Date.from(startTime.atZone(ZoneId.systemDefault()).toInstant()),
|
Date.from(endTime.atZone(ZoneId.systemDefault()).toInstant()),
|
areaVo,
|
analysisOption.removeOtherDistrict,
|
analysisOption.removeNoPollutedSource
|
)
|
}
|
|
@ApiOperation(value = "走航典型隐患区域统计")
|
@GetMapping("/report/clueByRiskArea/one")
|
fun generateOneClueByRiskArea(
|
@ApiParam("任务编号") @RequestParam missionCode: String,
|
) = resPack { dataAnalysisService.generateClueByRiskArea(missionCode) }
|
|
@ApiOperation(value = "叠加融合分析")
|
@PostMapping("/report/gridFusion")
|
fun generateGridFusion(
|
@ApiParam("分析选项") @RequestBody analysisOption: AnalysisOption,
|
) = resPack {
|
if (analysisOption.startTime == null || analysisOption.endTime == null || analysisOption.area == null || analysisOption.factorTypes == null)
|
throw BizException("参数错误, startTime, endTime, area, factorTypes不能为空")
|
val startTime = analysisOption.startTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val endTime = analysisOption.endTime!!.atZone(ZoneId.systemDefault()).toInstant()
|
val areaVo = analysisOption.area!!
|
val factorTypes = analysisOption.factorTypes!!.map { FactorType.valueOf(it) }
|
|
dataAnalysisService.generateGridFusion(
|
factorTypes,
|
Date.from(startTime.atZone(ZoneId.systemDefault()).toInstant()),
|
Date.from(endTime.atZone(ZoneId.systemDefault()).toInstant()),
|
areaVo
|
)
|
}
|
}
|
