diff --git a/src/main/java/com/zhgd/xmgl/modules/electrical/mapper/xml/ElectricalDevMapper.xml b/src/main/java/com/zhgd/xmgl/modules/electrical/mapper/xml/ElectricalDevMapper.xml index efc59c369..9dff4ca15 100644 --- a/src/main/java/com/zhgd/xmgl/modules/electrical/mapper/xml/ElectricalDevMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/electrical/mapper/xml/ElectricalDevMapper.xml @@ -1,9 +1,8 @@ - SELECT COUNT(1) devNum, - IFNULL(SUM((case when round((UNIX_TIMESTAMP(now())-UNIX_TIMESTAMP(real_time))/60)<=10 then 1 else 0 end)),0) devOnline + IFNULL(SUM((case when round((UNIX_TIMESTAMP(now())-UNIX_TIMESTAMP(real_time))/86400)<=7 then 1 else 0 + end)),0) devOnline FROM electrical_dev de INNER JOIN project a ON de.project_sn=a.project_sn INNER JOIN company cp ON a.company_sn=cp.company_sn INNER JOIN company b ON cp.parent_id=b.company_id diff --git a/src/main/java/com/zhgd/xmgl/modules/environment/mapper/EnvironmentDevMapper.java b/src/main/java/com/zhgd/xmgl/modules/environment/mapper/EnvironmentDevMapper.java index ad8f2c2e9..e2266cac0 100644 --- a/src/main/java/com/zhgd/xmgl/modules/environment/mapper/EnvironmentDevMapper.java +++ b/src/main/java/com/zhgd/xmgl/modules/environment/mapper/EnvironmentDevMapper.java @@ -20,8 +20,6 @@ public interface EnvironmentDevMapper extends BaseMapper { List selectEnvironmentDevList(Map map); - List selectProjectEnvironmentDevList(Map map); - List> selectAllDevCount(); List> selectCompanyDevCountStatistics(Map map); diff --git a/src/main/java/com/zhgd/xmgl/modules/environment/mapper/xml/EnvironmentDevMapper.xml b/src/main/java/com/zhgd/xmgl/modules/environment/mapper/xml/EnvironmentDevMapper.xml index da7dc073e..f28fa9a39 100644 --- a/src/main/java/com/zhgd/xmgl/modules/environment/mapper/xml/EnvironmentDevMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/environment/mapper/xml/EnvironmentDevMapper.xml @@ -1,62 +1,75 @@ + + (case + when round((UNIX_TIMESTAMP(now()) - UNIX_TIMESTAMP( + ${real_time} + )) / 86400) <= 7 then 1 + else 0 end) + - UPDATE environment_dev SET real_time=now() - WHERE id=#{id} + UPDATE environment_dev + SET real_time=now() + WHERE id = #{id} - + - diff --git a/src/main/java/com/zhgd/xmgl/modules/environment/service/impl/EnvironmentDevServiceImpl.java b/src/main/java/com/zhgd/xmgl/modules/environment/service/impl/EnvironmentDevServiceImpl.java index e16cbd4f0..c7090e774 100644 --- a/src/main/java/com/zhgd/xmgl/modules/environment/service/impl/EnvironmentDevServiceImpl.java +++ b/src/main/java/com/zhgd/xmgl/modules/environment/service/impl/EnvironmentDevServiceImpl.java @@ -204,7 +204,7 @@ public class EnvironmentDevServiceImpl extends ServiceImpl map) { - List devList = environmentDevMapper.selectProjectEnvironmentDevList(map); + List devList = environmentDevMapper.selectEnvironmentDevList(map); int totalDevOnlineNum = 0; int totalAlarmNum = 0; if (devList != null && devList.size() > 0) { diff --git a/src/main/java/com/zhgd/xmgl/modules/frontier/mapper/xml/FrontierProtectionDevMapper.xml b/src/main/java/com/zhgd/xmgl/modules/frontier/mapper/xml/FrontierProtectionDevMapper.xml index c506025cd..88f1d442c 100644 --- a/src/main/java/com/zhgd/xmgl/modules/frontier/mapper/xml/FrontierProtectionDevMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/frontier/mapper/xml/FrontierProtectionDevMapper.xml @@ -30,9 +30,7 @@ diff --git a/src/main/java/com/zhgd/xmgl/modules/poisonous/mapper/xml/PoisonousGasDevMapper.xml b/src/main/java/com/zhgd/xmgl/modules/poisonous/mapper/xml/PoisonousGasDevMapper.xml index b4da579db..5ac36c8a9 100644 --- a/src/main/java/com/zhgd/xmgl/modules/poisonous/mapper/xml/PoisonousGasDevMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/poisonous/mapper/xml/PoisonousGasDevMapper.xml @@ -2,9 +2,9 @@ - select sd.*,ti.team_name dutyTeamInfoName,IFNULL(((case when - round((UNIX_TIMESTAMP(now())-UNIX_TIMESTAMP(sd.upload_date))/60)<=30 then 1 else 0 end)),0) - online + select sd.*,ti.team_name dutyTeamInfoName,1 online from smoke_dev sd inner join team_info ti on ti.id=sd.duty_team_info_id ${ew.customSqlSegment} diff --git a/src/main/java/com/zhgd/xmgl/util/AqiUtil.java b/src/main/java/com/zhgd/xmgl/util/AqiUtil.java index e34498d44..e07350f8e 100644 --- a/src/main/java/com/zhgd/xmgl/util/AqiUtil.java +++ b/src/main/java/com/zhgd/xmgl/util/AqiUtil.java @@ -1,5 +1,6 @@ package com.zhgd.xmgl.util; +import cn.hutool.http.HttpException; import cn.hutool.http.HttpUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; @@ -33,6 +34,10 @@ public class AqiUtil { private static RedisRepository redisRepository; public static String SYSTEM_CITIES_KEY = "SYSTEM_CITIES"; public static String WEATHER_DATA = "WEATHER_DATA:"; + /** + * 天气质量 + */ + public static String WEATHER_QUALITY = "WEATHER_QUALITY:"; @Autowired public void setSystemCitiesMapper(SystemCitiesMapper systemCitiesMapper) { @@ -162,6 +167,11 @@ public class AqiUtil { */ public static Double getWeatherInfo(String cityCode) { List systemCities = redisRepository.getOrSet(SYSTEM_CITIES_KEY, () -> systemCitiesMapper.selectList(null), 60 * 60L); + String key = WEATHER_QUALITY + cityCode; + Object ro = redisRepository.get(key); + if (ro != null) { + return (Double) ro; + } Map cityIdMap = systemCities.stream().collect(Collectors.toMap(e -> e.getCityid(), Function.identity(), (o, o2) -> o)); //空气指数 Double air = null; @@ -173,7 +183,7 @@ public class AqiUtil { if (StringUtils.isNotBlank(cityId)) { param.put("cityid", cityId); } - String result = HttpUtil.get("https://v0.yiketianqi.com/free/day", param); + String result = HttpUtil.get("https://v0.yiketianqi.com/free/day", param, 5000); if (result != null && result.length() > 0) { JSONObject obj = JSONObject.parseObject(result); if (obj != null && obj.getString("air") != null) { @@ -186,6 +196,7 @@ public class AqiUtil { if (air == null) { air = 80d; } + redisRepository.set(key, air, 60 * 60L); return air; } @@ -235,8 +246,15 @@ public class AqiUtil { log.info(getDegree(getPollutionDegree(temp)));*/ //log.info(getWeatherInfo("110100")); //log.info(getWeatherData("110100")); - System.out.println(getWeatherInfo("11")); + //System.out.println(getWeatherInfo("11")); //log.info(getDegree(getPollutionDegree(39d))); + try { + + String result = HttpUtil.get("https://v0.yiketianqi.com/free/day", 1000); + } catch (HttpException e) { + e.printStackTrace(); + } + System.out.println(123); } }