| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void insertHistoryMonthly() { |
|---|
| | | |
|---|
| | | Date now = new Date(); |
|---|
| | | //开始时间，上月1号 |
|---|
| | | Date start = DateUtils.getFirstDayOfLastMonth(); |
|---|
| | | //结束时间，本月1号 |
|---|
| | | Date end = DateUtils.addMonths(start, 1); |
|---|
| | | //因子 |
|---|
| | | QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>(); |
|---|
| | | sensorQueryWrapper.select("code").eq("is_delete", Constants.NOT_DELETE); |
|---|
| | |
|---|
| | | |
|---|
| | | //获取所有设备日数据 |
|---|
| | | QueryWrapper<HistoryDaily> historyDailyQueryWrapper = new QueryWrapper<>(); |
|---|
| | | historyDailyQueryWrapper.ge("time", DateUtils.dateToDateString(start)).lt("time", DateUtils.dateToDateString(now)); |
|---|
| | | historyDailyQueryWrapper.ge("time", DateUtils.dateToDateString(start)).lt("time", DateUtils.dateToDateString(end)); |
|---|
| | | List<Map<String, Object>> weeklyData = historyDailyService.listMaps(historyDailyQueryWrapper); |
|---|
| | | if (weeklyData.size() == 0) { |
|---|
| | | return; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //CO 95百分位计算并修约 |
|---|
| | | Object coAvg = AmendUtils.getCOAvgOfWeek(value); |
|---|
| | | Object coAvg = AmendUtils.getCOAvgOfWeekOrMonth(value); |
|---|
| | | if (coAvg != null) { |
|---|
| | | jsonMap.put(Constants.SENSOR_CODE_CO, coAvg); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //O3 90百分位计算并修约 |
|---|
| | | Object o3Avg = AmendUtils.getO3AvgOfWeek(value); |
|---|
| | | Object o3Avg = AmendUtils.getO3AvgOfWeekOrMonth(value); |
|---|
| | | if (o3Avg != null) { |
|---|
| | | jsonMap.put(Constants.SENSOR_CODE_O3, o3Avg); |
|---|
| | | } |
|---|
| | |
|---|
| | | |
|---|
| | | //存入数据库 |
|---|
| | | historyMonthlyMapper.insertHistoryMonthly(insertData); |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
