| | |
| | | dataTransform(vo, d) |
| | | /**************************************************************************/ |
| | | // FIXME: 2021/11/8 针对历史网格化原始数据,进行临时校准处理 |
| | | val dTime = LocalDateTime.ofInstant(d.dataTime?.toInstant(), ZoneId.systemDefault()) |
| | | // CO: 2021.8.28 17:27起 *0.25 |
| | | val coTime = LocalDateTime.of(2021, 8, 28, 17, 27, 0) |
| | | if (dTime.isAfter(coTime)) { |
| | | d.co = d.co?.times(0.25f) |
| | | } |
| | | |
| | | // NO2 |
| | | d.no2 = d.no2?.times(0.6f) |
| | | |
| | | // O3 |
| | | d.o3 = abs(d.o3?.minus(d.no2?.div(2) ?: 0f) ?: 0f) * 1.5f |
| | | |
| | | // SO2: *0.2, 2021.8.29 6:00起 *0.08 |
| | | val so2Time = LocalDateTime.of(2021, 8, 29, 6, 0, 0) |
| | | d.so2 = if (dTime.isAfter(so2Time)) { |
| | | d.so2?.times(0.08f) |
| | | } else { |
| | | d.so2?.times(0.2f) |
| | | } |
| | | |
| | | // H2S |
| | | d.h2s = d.h2s?.let { sqrt(it) * 2 } |
| | | // val dTime = LocalDateTime.ofInstant(d.dataTime?.toInstant(), ZoneId.systemDefault()) |
| | | // // CO: 2021.8.28 17:27起 *0.25 |
| | | // val coTime = LocalDateTime.of(2021, 8, 28, 17, 27, 0) |
| | | // if (dTime.isAfter(coTime)) { |
| | | // d.co = d.co?.times(0.25f) |
| | | // } |
| | | // |
| | | // // NO2 |
| | | // d.no2 = d.no2?.times(0.6f) |
| | | // |
| | | // // O3 |
| | | // d.o3 = abs(d.o3?.minus(d.no2?.div(2) ?: 0f) ?: 0f) * 1.5f |
| | | // |
| | | // // SO2: *0.2, 2021.8.29 6:00起 *0.08 |
| | | // val so2Time = LocalDateTime.of(2021, 8, 29, 6, 0, 0) |
| | | // d.so2 = if (dTime.isAfter(so2Time)) { |
| | | // d.so2?.times(0.08f) |
| | | // } else { |
| | | // d.so2?.times(0.2f) |
| | | // } |
| | | // |
| | | // // H2S |
| | | // d.h2s = d.h2s?.let { sqrt(it) * 2 } |
| | | /**************************************************************************/ |
| | | realTimeDataGridMapper.insert(d) |
| | | count++ |