新增数据分析模块

feiyu02

2023-10-20 3371ed856d8712732b3f46e30e41e652ff5d7781

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
package com.flightfeather.monitor.analysis.dust
 
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.ExceptionType
import java.time.LocalDateTime
import java.time.ZoneId
import java.util.*
 
/**
 * 单日超标次数临近处罚标准异常分析
 */
class ExceptionExceedingTimes(config: DustExceptionSetting) : BaseDustExceptionAnalysis(config) {
 
    private var exceedingCount = 0
    private var startData: DustSiteData? = null
 
    override fun getExceptionType(): ExceptionType = ExceptionType.TYPE6
 
    override fun onNextData(data: DustSiteData) {
        if (startData == null) startData = data
 
        if (data.dustValue >= config.exceedingStandard) {
            exceedingCount++
        }
    }
 
    override fun onDone() {
        if (exceedingCount >= config.dayExceedBorderlineLowNum && exceedingCount < config.dayExceedBorderlineHighNum) {
            startData?.let {
                val eType = getExceptionType()
                val t = LocalDateTime.ofInstant(it.lst.toInstant(), ZoneId.systemDefault())
                t.withHour(0)
                val sT =
                resultList.add(DustExceptionData().apply {
                    mnCode = it.mnCode
                    exception = eType.des
                    exceptionType = eType.value
                    region = config.region
//                    beginTime = if (p == null) n.lst else p.lst
//                    endTime = n.lst
                })
            }
        }
    }
}