| | |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.moral.api.entity.HistoryHourly; |
|---|
| | | import com.moral.api.config.mybatis.MybatisPlusConfig; |
|---|
| | | import com.moral.api.entity.*; |
|---|
| | | import com.moral.api.mapper.DeviceMapper; |
|---|
| | | import com.moral.api.mapper.HistoryHourlyMapper; |
|---|
| | | import com.moral.api.service.HistoryHourlyService; |
|---|
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|---|
| | | import com.moral.api.service.OrganizationService; |
|---|
| | | import com.moral.api.utils.GetCenterPointFromListOfCoordinates; |
|---|
| | | import com.moral.constant.Constants; |
|---|
| | | import com.moral.constant.SeparateTableType; |
|---|
| | | import com.moral.pojo.AQI; |
|---|
| | | import com.moral.util.AQIUtils; |
|---|
| | | import com.moral.util.DateUtils; |
|---|
| | | |
|---|
| | | import com.moral.util.MybatisPLUSUtils; |
|---|
| | | import com.moral.util.PollutantUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.util.ObjectUtils; |
|---|
| | | |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * <p> |
|---|
| | |
|---|
| | | * @since 2021-07-14 |
|---|
| | | */ |
|---|
| | | @Service |
|---|
| | | public class HistoryHourlyServiceImpl extends ServiceImpl<HistoryHourlyMapper, HistoryHourly> implements HistoryHourlyService { |
|---|
| | | public class HistoryHourlyServiceImpl implements HistoryHourlyService { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private HistoryHourlyMapper historyHourlyMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private DeviceMapper deviceMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private OrganizationService organizationService; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Map<String, Object> getHourlyAqiByMac(String mac) { |
|---|
| | | QueryWrapper<HistoryHourly> queryWrapper = new QueryWrapper<>(); |
|---|
| | | String time = DateUtils.dateToDateString(new Date(), DateUtils.yyyy_MM_dd_HH_EN) + ":00:00"; |
|---|
| | | queryWrapper.eq("time", time).eq("mac", mac); |
|---|
| | | Date now = new Date(); |
|---|
| | | String time = DateUtils.dateToDateString(now, DateUtils.yyyy_MM_dd_HH_EN) + ":00:00"; |
|---|
| | | //获取小时数据 |
|---|
| | | HistoryHourly historyHourly = historyHourlyMapper.selectOne(queryWrapper); |
|---|
| | | Map<String, Object> params = new HashMap<>(); |
|---|
| | | params.put("timeUnits", DateUtils.dateToDateString(now, DateUtils.yyyyMM_EN)); |
|---|
| | | params.put("mac", mac); |
|---|
| | | params.put("time", time); |
|---|
| | | String value = historyHourlyMapper.selectHourlyData(params); |
|---|
| | | Map<String, Object> result = new HashMap<>(); |
|---|
| | | if (historyHourly == null) { |
|---|
| | | if (ObjectUtils.isEmpty(value)) { |
|---|
| | | result.put("AQI", Constants.NULL_VALUE); |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | Map<String, Object> data = JSONObject.parseObject(historyHourly.getValue(), Map.class); |
|---|
| | | result.put("AQI", AQIUtils.hourlyAqi(data)); |
|---|
| | | Map<String, Object> data = JSONObject.parseObject(value, Map.class); |
|---|
| | | AQI aqi = AQIUtils.hourlyAQI(data); |
|---|
| | | result.put("AQI", aqi.getAQIValue()); |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | *@Description: 通过组织id和因子编码获取上一个小时数据 |
|---|
| | | *@Param: [map] |
|---|
| | | *@return: java.util.Map<java.lang.String,java.lang.Object> |
|---|
| | | *@Author: lizijie |
|---|
| | | *@Date: 2021/12/7 10:07 |
|---|
| | | **/ |
|---|
| | | @Override |
|---|
| | | public Map<String, Object> getLastHourDataByOrgIdAndSensorCode(Map parameters) { |
|---|
| | | Map<String, Object> resultMap = new HashMap<>(); |
|---|
| | | int orgId = Integer.parseInt(parameters.get("organization_id").toString()); |
|---|
| | | //定义一个集合，存放所有id |
|---|
| | | List<Integer> allOrgId = new ArrayList<>(); |
|---|
| | | allOrgId.add(orgId); |
|---|
| | | //循环集合 |
|---|
| | | //所有子组织 |
|---|
| | | List<Organization> allChildrenOrganization = organizationService.getChildrenOrganizationsById(orgId); |
|---|
| | | if (!ObjectUtils.isEmpty(allChildrenOrganization) || allChildrenOrganization.size() < 1){ |
|---|
| | | for (Organization organization:allChildrenOrganization) { |
|---|
| | | allOrgId.add(organization.getId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //集合去重 |
|---|
| | | List<Integer> allOrgIdWithoutDuplicates = allOrgId.stream().distinct().collect(Collectors.toList()); |
|---|
| | | //声明一个list，存放设备mac |
|---|
| | | List<String> deviceMacList = new ArrayList<>(); |
|---|
| | | //声明一个map，Mac作为key，device作为value |
|---|
| | | Map<String,Device> deviceMap = new HashMap<>(); |
|---|
| | | for (Integer orgIdWithoutDuplicates:allOrgIdWithoutDuplicates) { |
|---|
| | | //根据id查询所属设备 |
|---|
| | | QueryWrapper<Device> wrapper_device = new QueryWrapper<>(); |
|---|
| | | wrapper_device.eq("is_delete",Constants.NOT_DELETE).eq("organization_id",orgIdWithoutDuplicates); |
|---|
| | | List<Device> devices = new ArrayList<>(); |
|---|
| | | devices = deviceMapper.selectList(wrapper_device); |
|---|
| | | if (devices.size()>0){ |
|---|
| | | for (Device device:devices) { |
|---|
| | | String mac = device.getMac(); |
|---|
| | | deviceMacList.add(mac); |
|---|
| | | deviceMap.put(mac,device); |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //获取时间 |
|---|
| | | SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH"); |
|---|
| | | Calendar calendar = Calendar.getInstance(); |
|---|
| | | calendar.set(Calendar.HOUR_OF_DAY,calendar.get(Calendar.HOUR_OF_DAY)-1); |
|---|
| | | String time = df.format(calendar.getTime())+":00:00"; |
|---|
| | | resultMap.put("time",time); |
|---|
| | | String timeUnits = DateUtils.dateToDateString(calendar.getTime(), DateUtils.yyyyMM_EN); |
|---|
| | | List<Map<String,Object>> historyHourlyDatas = new ArrayList<>(); |
|---|
| | | historyHourlyDatas = historyHourlyMapper.selectDataByMacsAndTime(timeUnits, deviceMacList, time); |
|---|
| | | List<Object> list = new ArrayList<>(); |
|---|
| | | List<Double> longitudeList = new ArrayList<>(); |
|---|
| | | List<Double> latitudeList = new ArrayList<>(); |
|---|
| | | for (Map historyHourlyData:historyHourlyDatas) { |
|---|
| | | List<Object> list1 = new ArrayList<>(); |
|---|
| | | String mac = historyHourlyData.get("mac").toString(); |
|---|
| | | Device device = deviceMap.get(mac); |
|---|
| | | double longitude = device.getLongitude(); |
|---|
| | | double latitude = device.getLatitude(); |
|---|
| | | longitudeList.add(longitude); |
|---|
| | | latitudeList.add(latitude); |
|---|
| | | JSONObject value = JSONObject.parseObject(historyHourlyData.get("value").toString()); |
|---|
| | | double num = Double.parseDouble(value.get(parameters.get("sensor_code")).toString()); |
|---|
| | | int level = PollutantUtils.pollutantLevel(num, (parameters.get("sensor_code")).toString()); |
|---|
| | | list1.add(longitude); |
|---|
| | | list1.add(latitude); |
|---|
| | | list1.add(level); |
|---|
| | | list.add(list1); |
|---|
| | | } |
|---|
| | | resultMap.put("list",list); |
|---|
| | | double latitudeMin = Collections.min(latitudeList)-0.0018; |
|---|
| | | double latitudeMax = Collections.max(latitudeList)+0.0018; |
|---|
| | | double longitudeMin = Collections.min(longitudeList)-0.2/(111*Math.cos(latitudeMin)); |
|---|
| | | double longitudeMax = Collections.max(longitudeList)+0.2/(111*Math.cos(latitudeMin)); |
|---|
| | | List<Double> bound = new ArrayList<>(); |
|---|
| | | bound.add(longitudeMin); |
|---|
| | | bound.add(latitudeMax); |
|---|
| | | bound.add(longitudeMax); |
|---|
| | | bound.add(latitudeMin); |
|---|
| | | resultMap.put("bound",bound); |
|---|
| | | List<List> bound1 = new ArrayList<>(); |
|---|
| | | List<Double> left_up = new ArrayList<>(); |
|---|
| | | left_up.add(latitudeMax); |
|---|
| | | left_up.add(longitudeMin); |
|---|
| | | List<Double> right_up = new ArrayList<>(); |
|---|
| | | right_up.add(latitudeMax); |
|---|
| | | right_up.add(longitudeMax); |
|---|
| | | List<Double> left_down = new ArrayList<>(); |
|---|
| | | left_down.add(latitudeMin); |
|---|
| | | left_down.add(longitudeMin); |
|---|
| | | List<Double> right_down = new ArrayList<>(); |
|---|
| | | right_down.add(latitudeMin); |
|---|
| | | right_down.add(longitudeMax); |
|---|
| | | bound1.add(left_up); |
|---|
| | | bound1.add(right_up); |
|---|
| | | bound1.add(right_down); |
|---|
| | | bound1.add(left_down); |
|---|
| | | List<GeoCoordinate> geoCoordinates = new ArrayList<>(); |
|---|
| | | for (List bo:bound1) { |
|---|
| | | GeoCoordinate g = new GeoCoordinate(); |
|---|
| | | g.setLatitude(Double.parseDouble(bo.get(0).toString())); |
|---|
| | | g.setLongitude(Double.parseDouble(bo.get(1).toString())); |
|---|
| | | geoCoordinates.add(g); |
|---|
| | | } |
|---|
| | | GeoCoordinate centerPoint400 = GetCenterPointFromListOfCoordinates.getCenterPoint400(geoCoordinates); |
|---|
| | | List centerPoint = new ArrayList(); |
|---|
| | | centerPoint.add(centerPoint400.getLongitude()); |
|---|
| | | centerPoint.add(centerPoint400.getLatitude()); |
|---|
| | | resultMap.put("centerPoint",centerPoint); |
|---|
| | | return resultMap; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Map<String, Object> getLastTwelveHourDataByOrgIdAndSensorCode(Map parameters) { |
|---|
| | | Map<String, Object> resultMap = new HashMap<>(); |
|---|
| | | int orgId = Integer.parseInt(parameters.get("organization_id").toString()); |
|---|
| | | //定义一个集合，存放所有id |
|---|
| | | List<Integer> allOrgId = new ArrayList<>(); |
|---|
| | | allOrgId.add(orgId); |
|---|
| | | //循环集合 |
|---|
| | | //所有子组织 |
|---|
| | | List<Organization> allChildrenOrganization = organizationService.getChildrenOrganizationsById(orgId); |
|---|
| | | if (!ObjectUtils.isEmpty(allChildrenOrganization) || allChildrenOrganization.size() < 1){ |
|---|
| | | for (Organization organization:allChildrenOrganization) { |
|---|
| | | allOrgId.add(organization.getId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | //集合去重 |
|---|
| | | List<Integer> allOrgIdWithoutDuplicates = allOrgId.stream().distinct().collect(Collectors.toList()); |
|---|
| | | //声明一个list，存放设备mac |
|---|
| | | List<String> deviceMacList = new ArrayList<>(); |
|---|
| | | //声明一个map，Mac作为key，device作为value |
|---|
| | | Map<String,Device> deviceMap = new HashMap<>(); |
|---|
| | | List<Double> longitudeList = new ArrayList<>(); |
|---|
| | | List<Double> latitudeList = new ArrayList<>(); |
|---|
| | | for (Integer orgIdWithoutDuplicates:allOrgIdWithoutDuplicates) { |
|---|
| | | //根据id查询所属设备 |
|---|
| | | QueryWrapper<Device> wrapper_device = new QueryWrapper<>(); |
|---|
| | | wrapper_device.eq("is_delete",Constants.NOT_DELETE).eq("organization_id",orgIdWithoutDuplicates); |
|---|
| | | List<Device> devices = new ArrayList<>(); |
|---|
| | | devices = deviceMapper.selectList(wrapper_device); |
|---|
| | | if (devices.size()>0){ |
|---|
| | | for (Device device:devices) { |
|---|
| | | String mac = device.getMac(); |
|---|
| | | deviceMacList.add(mac); |
|---|
| | | deviceMap.put(mac,device); |
|---|
| | | double longitude = device.getLongitude(); |
|---|
| | | double latitude = device.getLatitude(); |
|---|
| | | longitudeList.add(longitude); |
|---|
| | | latitudeList.add(latitude); |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | List<Object> list = new ArrayList<>(); |
|---|
| | | //获取时间 |
|---|
| | | SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH"); |
|---|
| | | for (int i=12;i>0;i--){ |
|---|
| | | Calendar calendar = Calendar.getInstance(); |
|---|
| | | calendar.set(Calendar.HOUR_OF_DAY,calendar.get(Calendar.HOUR_OF_DAY)-i); |
|---|
| | | String time = df.format(calendar.getTime())+":00:00"; |
|---|
| | | String timeUnits = DateUtils.dateToDateString(calendar.getTime(), DateUtils.yyyyMM_EN); |
|---|
| | | List<Map<String,Object>> historyHourlyDatas = new ArrayList<>(); |
|---|
| | | historyHourlyDatas = historyHourlyMapper.selectDataByMacsAndTime(timeUnits, deviceMacList, time); |
|---|
| | | List<Object> oneHourlyList = new ArrayList<>(); |
|---|
| | | for (Map historyHourlyData:historyHourlyDatas) { |
|---|
| | | List<Object> list1 = new ArrayList<>(); |
|---|
| | | String mac = historyHourlyData.get("mac").toString(); |
|---|
| | | Device device = deviceMap.get(mac); |
|---|
| | | double longitude = device.getLongitude(); |
|---|
| | | double latitude = device.getLatitude(); |
|---|
| | | JSONObject value = JSONObject.parseObject(historyHourlyData.get("value").toString()); |
|---|
| | | double num = Double.parseDouble(value.get(parameters.get("sensor_code")).toString()); |
|---|
| | | int level = PollutantUtils.pollutantLevel(num, (parameters.get("sensor_code")).toString()); |
|---|
| | | list1.add(longitude); |
|---|
| | | list1.add(latitude); |
|---|
| | | list1.add(level); |
|---|
| | | oneHourlyList.add(list1); |
|---|
| | | } |
|---|
| | | list.add(oneHourlyList); |
|---|
| | | } |
|---|
| | | resultMap.put("list",list); |
|---|
| | | double latitudeMin = Collections.min(latitudeList)-0.0018; |
|---|
| | | double latitudeMax = Collections.max(latitudeList)+0.0018; |
|---|
| | | double longitudeMin = Collections.min(longitudeList)-0.2/(111*Math.cos(latitudeMin)); |
|---|
| | | double longitudeMax = Collections.max(longitudeList)+0.2/(111*Math.cos(latitudeMin)); |
|---|
| | | List<Double> bound = new ArrayList<>(); |
|---|
| | | bound.add(latitudeMax); |
|---|
| | | bound.add(longitudeMax); |
|---|
| | | bound.add(latitudeMin); |
|---|
| | | bound.add(longitudeMin); |
|---|
| | | resultMap.put("bound",bound); |
|---|
| | | List<List> bound1 = new ArrayList<>(); |
|---|
| | | List<Double> left_up = new ArrayList<>(); |
|---|
| | | left_up.add(latitudeMax); |
|---|
| | | left_up.add(longitudeMin); |
|---|
| | | List<Double> right_up = new ArrayList<>(); |
|---|
| | | right_up.add(latitudeMax); |
|---|
| | | right_up.add(longitudeMax); |
|---|
| | | List<Double> left_down = new ArrayList<>(); |
|---|
| | | left_down.add(latitudeMin); |
|---|
| | | left_down.add(longitudeMin); |
|---|
| | | List<Double> right_down = new ArrayList<>(); |
|---|
| | | right_down.add(latitudeMin); |
|---|
| | | right_down.add(longitudeMax); |
|---|
| | | bound1.add(left_up); |
|---|
| | | bound1.add(right_up); |
|---|
| | | bound1.add(right_down); |
|---|
| | | bound1.add(left_down); |
|---|
| | | List<GeoCoordinate> geoCoordinates = new ArrayList<>(); |
|---|
| | | for (List bo:bound1) { |
|---|
| | | GeoCoordinate g = new GeoCoordinate(); |
|---|
| | | g.setLatitude(Double.parseDouble(bo.get(0).toString())); |
|---|
| | | g.setLongitude(Double.parseDouble(bo.get(1).toString())); |
|---|
| | | geoCoordinates.add(g); |
|---|
| | | } |
|---|
| | | GeoCoordinate centerPoint400 = GetCenterPointFromListOfCoordinates.getCenterPoint400(geoCoordinates); |
|---|
| | | List centerPoint = new ArrayList(); |
|---|
| | | centerPoint.add(centerPoint400.getLongitude()); |
|---|
| | | centerPoint.add(centerPoint400.getLatitude()); |
|---|
| | | resultMap.put("centerPoint",centerPoint); |
|---|
| | | return resultMap; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Description: 查询一段时间内某一mac的数据 |
|---|
| | | * @Param: [mac, startDate, endDate] |
|---|
| | | * @return: java.util.List<com.moral.api.entity.HistoryHourly> |
|---|
| | | * @Author: 陈凯裕 |
|---|
| | | * @Date: 2021/9/23 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public List<HistoryHourly> getValueByMacAndTime(String mac,Date startDate,Date endDate){ |
|---|
| | | QueryWrapper<HistoryHourly> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.eq("mac",mac); |
|---|
| | | wrapper.between("time",startDate,endDate); |
|---|
| | | List<String> tableNames = MybatisPLUSUtils.getTableNamesByWrapper(startDate, endDate, SeparateTableType.MONTH); |
|---|
| | | List<HistoryHourly> datas = multiTableQuery(wrapper, tableNames); |
|---|
| | | return datas; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Description: 多表查询，传入表名集合，以及条件wrapper，返回数据 |
|---|
| | | * @Param: [wrapper, tableNames] |
|---|
| | | * @return: java.util.List<com.moral.api.entity.HistoryHourly> |
|---|
| | | * @Author: 陈凯裕 |
|---|
| | | * @Date: 2021/9/23 |
|---|
| | | */ |
|---|
| | | private List<HistoryHourly> multiTableQuery(QueryWrapper<HistoryHourly> wrapper,List<String> tableNames){ |
|---|
| | | List<HistoryHourly> result = new ArrayList<>(); |
|---|
| | | for (String tableName : tableNames) { |
|---|
| | | MybatisPlusConfig.tableName.set(tableName); |
|---|
| | | List<HistoryHourly> datas = historyHourlyMapper.selectList(wrapper); |
|---|
| | | result.addAll(datas); |
|---|
| | | } |
|---|
| | | MybatisPlusConfig.tableName.remove(); |
|---|
| | | return result; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
