package com.flightfeather.monitor.analysis.dust.exception
|
|
import com.flightfeather.monitor.domain.ds1.entity.DustExceptionData
|
import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting
|
import com.flightfeather.monitor.domain.ds1.entity.DustSiteData
|
import com.flightfeather.monitor.enumration.dust.DataStatus
|
import com.flightfeather.monitor.enumration.dust.ExceptionType
|
import java.time.LocalDateTime
|
import java.time.ZoneId
|
import java.util.*
|
|
/**
|
* 数据有效率异常
|
*/
|
class ExceptionValidRate(config: DustExceptionSetting) : BaseDustExceptionAnalysis(config) {
|
|
private var count = 0
|
private val total = 96
|
private var startData: DustSiteData? = null
|
|
override fun init() {
|
super.init()
|
count = 0
|
startData = null
|
}
|
|
override fun getExceptionType(): ExceptionType = ExceptionType.TYPE8
|
|
override fun onNextData(data: DustSiteData) {
|
if (startData == null) startData = data
|
|
if (data.flag == DataStatus.N.value) {
|
count++
|
}
|
}
|
|
override fun onDone() {
|
val rate = count.toDouble() / total
|
if (rate < 0.9) {
|
startData?.let {
|
val eType = getExceptionType()
|
val t = LocalDateTime.ofInstant(it.lst.toInstant(), ZoneId.systemDefault())
|
.withHour(0).withMinute(0).withSecond(0)
|
val sT = Date.from(t.atZone(ZoneId.systemDefault()).toInstant())
|
val n = t.plusDays(1).minusSeconds(1)
|
val eT = Date.from(n.atZone(ZoneId.systemDefault()).toInstant())
|
resultList.add(DustExceptionData().apply {
|
mnCode = it.mnCode
|
exception = eType.des
|
exceptionType = eType.value
|
region = config.region
|
beginTime = sT
|
endTime = eT
|
})
|
}
|
}
|
}
|
}
|
