feiyu02
2023-11-23 e2392116cd6f875cdc2f46bc04b04d5305f21b56
src/main/java/com/flightfeather/monitor/analysis/dust/exception/ExceptionDataMissing.kt
@@ -2,35 +2,68 @@
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.Duration
import java.time.LocalDateTime
import java.time.ZoneId
import java.util.*
/**
 * 数据缺失异常分析
 */
class ExceptionDataMissing(config: DustExceptionSetting) : BaseDustExceptionAnalysis(config) {
    private var lastData: DustSiteData? = null
    override fun init() {
        super.init()
        lastData = null
    }
class ExceptionDataMissing(config: DustExceptionSetting) : BaseExceptionContinuous(config) {
    override fun getExceptionType(): ExceptionType = ExceptionType.TYPE0
    override fun onNextData(data: DustSiteData) {
        lastData?.let {
            val t1 = it.lst
            val t2 = data.lst
            if (Duration.between(t1?.toInstant(), t2.toInstant()).toMinutes() > config.missDataMinutes) {
                resultList.add(newResult(it, data))
//    override fun onNextData(data: DustSiteData) {
//        lastData?.let {
//            val t1 = it.lst
//            val t2 = data.lst
//            val b1 = Duration.between(t1?.toInstant(), t2.toInstant()).toMinutes() >= config.missDataMinutes
//            if (b1) {
//                resultList.add(newResult(it, data))
//            }
//        }
//        lastData = data
//    }
    override fun judgeException(p: DustSiteData?, n: DustSiteData): Boolean {
        // 数据缺失异常不同于其他异常的点在于当日首个数据如果不存在,需要做一次判断
        var pData: DustSiteData? = null
        if (p == null) {
            //当首个数据进入时,需要判断是否为当日的第一个数据
            val time = LocalDateTime.ofInstant(n.lst.toInstant(), ZoneId.systemDefault())
            if (time.hour == 0 && time.minute == 0) {
                return false
            }
            // 如果缺失当日首个数据,则需要将当前数据n和当日0点进行比较,记录数据缺失异常
            else {
                startData = DustSiteData().apply {
                    mnCode = n.mnCode
                    lst = Date.from(time.withHour(0).withMinute(0).withSecond(0).atZone(ZoneId.systemDefault())
                        .toInstant())
                    flag = DataStatus.A.value
                }
                pData = startData
            }
        }
        lastData = data
        if (pData == null) return false
        val t1 = pData.lst
        val t2 = n.lst
        val b1 = Duration.between(t1?.toInstant(), t2.toInstant()).toMinutes() >= config.missDataMinutes
        val b2 = n.flag == DataStatus.A.value || n.flag == DataStatus.D.value
        return b1 || b2
    }
    override fun onDone() {
        //do noting
    override fun judgeDuration(sIndex: Int, eIndex: Int): Boolean {
        return true
    }
    /**
     * 针对数据缺失异常, 对数据的连续性不做判断
     */
    override fun isContinuous(d1: DustSiteData?, d2: DustSiteData): Boolean {
        return true
    }
}