moral.git - Gitblit

			@@ -21,6 +21,7 @@
			import org.springframework.stereotype.Service;
			import org.springframework.util.ObjectUtils;

			import java.text.ParseException;
			import java.text.SimpleDateFormat;
			import java.util.*;
			import java.util.stream.Collectors;
			@@ -294,6 +295,238 @@
			return resultMap;
			}

			@Override
			public Map<String, Object> getThermodynamicDiagramDataByOrgIdSensorCodeTime(Map<String, Object> 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;
			}
			}
			//获取时间
			String time = parameters.get("time").toString().substring(0,13)+":00:00";
			resultMap.put("time",time);
			String timeUnits = DateUtils.stringToDateString(time, DateUtils.yyyy_MM_dd_HH_mm_ss_EN, DateUtils.yyyyMM_EN);
			List<Map<String,Object>> historyHourlyDatas = new ArrayList<>();
			historyHourlyDatas = historyHourlyMapper.selectDataByMacsAndTime(timeUnits, deviceMacList, time);
			List<Object> list = 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);
			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(latitudeMin);
			bound.add(longitudeMax);
			bound.add(latitudeMax);
			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 List<Map<String, Object>> getThermodynamicDiagramDataByOrgIdSensorCodeTimeslot(Map<String, Object> parameters) {
			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;
			}
			}
			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(latitudeMin);
			bound.add(longitudeMax);
			bound.add(latitudeMax);
			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());
			List<Map<String, Object>> list = new ArrayList<>();
			//获取时间
			SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH");
			String endTime = parameters.get("endTime").toString();
			int hour = Integer.parseInt(parameters.get("hour").toString());
			Date newEndTime = new Date();
			for (int i=hour;i>=0;i--){
			Map<String, Object> resultMap = new HashMap<>();
			//先存放中心点和边界点
			resultMap.put("centerPoint",centerPoint);
			resultMap.put("bound",bound);
			Calendar calendar = Calendar.getInstance();
			try {
			newEndTime = df.parse(endTime);
			} catch (ParseException e) {
			e.printStackTrace();
			}
			calendar.setTime(newEndTime);
			calendar.set(Calendar.HOUR_OF_DAY,calendar.get(Calendar.HOUR_OF_DAY)-i);
			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> 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);
			}
			resultMap.put("list",oneHourlyList);
			list.add(resultMap);
			}
			return list;
			}

			/**
			* @Description: 查询一段时间内某一mac的数据
			* @Param: [mac, startDate, endDate]