From c35090abedcfd1c9a8d53794570e836f2b0bb866 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Thu, 17 Feb 2022 15:25:43 +0800
Subject: [PATCH] 督办单编号唯一性
---
screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java | 36 ++++++++++++++++++++++++++++--------
1 files changed, 28 insertions(+), 8 deletions(-)
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
index 141b779..88b5cff 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java
@@ -23,11 +23,13 @@
import org.springframework.util.ObjectUtils;
import org.springframework.web.client.RestTemplate;
+import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.OptionalDouble;
+import java.util.stream.Collectors;
import java.util.stream.DoubleStream;
/**
@@ -70,8 +72,28 @@
wrapper.select("city_code", "city_id").eq("is_delete", Constants.NOT_DELETE);
List<CityConfigAqi> list = cityConfigAqiService.list(wrapper);
- CityAqi cityAqi = new CityAqi();
+ //������������������������������������������������
+ Map<Integer, List<Map<String, Object>>> cityData = null;
+ if (start != null) {
+ QueryWrapper<CityAqi> queryWrapper = new QueryWrapper<>();
+ List<Integer> cityCodes = list.stream().map(CityConfigAqi::getCityCode)
+ .collect(Collectors.toList());
+
+ queryWrapper.select("city_code", "time", "value")
+ .ge("time", DateUtils.dateToDateString(start))
+ .in("city_code", cityCodes);
+ List<Map<String, Object>> selectMaps = cityAqiMapper.selectMaps(queryWrapper);
+
+ //���city_code������
+ cityData = selectMaps.stream()
+ .collect(Collectors.groupingBy(o -> Integer.parseInt(o.get("city_code").toString())));
+ }
+
+
+ List<CityAqi> cityAqiList = new ArrayList<>();
+
for (CityConfigAqi cityConfigAqi : list) {
+ CityAqi cityAqi = new CityAqi();
Integer cityCode = cityConfigAqi.getCityCode();
Map<String, Object> data;
try {
@@ -102,12 +124,9 @@
aqi.put("AQI", aqi.remove("value"));
//o3���������������
- if (start != null) {
- QueryWrapper<CityAqi> queryWrapper = new QueryWrapper<>();
- queryWrapper.select("time", "value")
- .eq("city_code", cityCode)
- .ge("time", DateUtils.dateToDateString(start));
- List<Map<String, Object>> cityAqis = cityAqiMapper.selectMaps(queryWrapper);
+ if (cityData != null) {
+ List<Map<String, Object>> cityAqis = cityData.get(cityCode);
+
Map<String, Object> params = new HashMap<>();
params.put("time", DateUtils.dateToDateString(dataTime, DateUtils.yyyy_MM_dd_HH_mm_ss_S_EN));
params.put("value", JSONObject.toJSONString(aqi));
@@ -146,10 +165,11 @@
cityAqi.setCityCode(cityCode);
cityAqi.setTime(dataTime);
cityAqi.setValue(JSONObject.toJSONString(aqi));
- cityAqiMapper.insert(cityAqi);
+ cityAqiList.add(cityAqi);
//������redis
redisTemplate.opsForHash().put(RedisConstants.CITY_AQI, cityCode.toString(), aqi);
}
+ cityAqiMapper.insertCityAqi(cityAqiList);
}
@Override
--
Gitblit v1.8.0