package com.flightfeather.monitor.analysis.dust
|
|
import com.flightfeather.monitor.analysis.DataAnalysisInterface
|
import com.flightfeather.monitor.domain.ds1.entity.DustExceptionSetting
|
import com.flightfeather.monitor.domain.ds1.entity.DustSiteData
|
import java.util.*
|
import kotlin.properties.Delegates
|
|
/**
|
* 量级突变异常分析
|
*/
|
class ExceptionValueMutation(config: DustExceptionSetting) : DataAnalysisInterface<DustSiteData,
|
DustExceptionSetting>(config) {
|
|
private var mutationNum by Delegates.notNull<Int>()
|
|
private var mutationRate by Delegates.notNull<Double>()
|
|
private var lastDataTime: Date? = null
|
|
override fun initConfig(config: DustExceptionSetting) {
|
mutationNum = config.mutationNum
|
mutationRate = config.mutationRate
|
}
|
|
override fun onNextData(data: DustSiteData) {
|
if (lastDataTime != null) {
|
// 相邻数据时间小于或等于30分钟分为一组
|
}
|
|
lastDataTime = data.lst
|
}
|
|
override fun toDb() {
|
TODO("Not yet implemented")
|
}
|
|
|
}
|
