package com.moral.service.impl; import java.text.DecimalFormat; import java.util.ArrayList; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.apache.commons.collections.MapUtils; import org.springframework.stereotype.Service; import com.moral.entity.Device; import com.moral.entity.Point; import com.moral.entity.Sensor; import com.moral.mapper.HistoryHourlyMapper; import com.moral.mapper.SensorMapper; import com.moral.service.DeviceService; import com.moral.service.HistoryHourlyService; @Service public class HistoryHourlyServiceImpl implements HistoryHourlyService { @Resource private HistoryHourlyMapper historyHourlyMapper; @Resource private DeviceService deviceService; @Resource private SensorMapper sensorMapper; @Override public Map getPollutionSourceData(Map parameters) throws Exception { List sensors = sensorMapper.getSensorsByMac(parameters); List sensorKeys = new ArrayList<>(); for (Sensor sensor : sensors) { sensorKeys.add(sensor.getSensorKey()); } parameters.put("sensorKeys", sensorKeys); /* if(pollutionSourceData.get("e6")!=null&&pollutionSourceData.get("e18")!=null){ pollutionSourceData=historyHourlyMapper.getPollutionSourceData(parameters); } return pollutionSourceData;*/ System.out.println("----"+historyHourlyMapper.getPollutionSourceData(parameters)); return historyHourlyMapper.getPollutionSourceData(parameters); } @Override public Point getDirPoint(Map parameters) throws Exception{ Map pollutionSourceData=getPollutionSourceData(parameters); String mac = parameters.get("mac").toString(); Device device = deviceService.getDeviceByMac(mac, false); Point pointEnd=new Point(); if(MapUtils.isNotEmpty(pollutionSourceData)){ System.out.println("pollutionSourceData"+pollutionSourceData); if(pollutionSourceData.get("e18")!=null&&pollutionSourceData.get("e23")!=null&&pollutionSourceData.get("e6")!=null){ double windSpeed=Double.valueOf(pollutionSourceData.get("e18").toString()); double winDir=Double.valueOf(pollutionSourceData.get("e23").toString()); double distance=windSpeed*3600; double long1=device.getLongitude(); double lat1=device.getLatitude(); System.out.println("windSpeed:"+windSpeed+"---winDir:"+winDir+"---distance:"+distance+"--long1:"+long1+"--lat1:"+lat1); String[] result=calLocationByDistanceAndLocationAndDirection(winDir,long1,lat1,distance); System.out.println("result1:"+Double.valueOf(result[0])+"result2:"+Double.valueOf(result[1])); pointEnd.setLng(Double.valueOf(result[0])); pointEnd.setLat(Double.valueOf(result[1])); } } return pointEnd; } /** * 根据一点的坐标与距离,以及方向,计算另外一点的位置 * @param angle 角度,从正北顺时针方向开始计算 * @param startLong 起始点经度 * @param startLat 起始点纬度 * @param distance 距离,单位m * @return */ private String[] calLocationByDistanceAndLocationAndDirection(double angle, double startLong,double startLat, double distance){ /** 地球半径 **/ final double R = 6371e3; /** 180° **/ final DecimalFormat df = new DecimalFormat("0.000000"); String[] result = new String[2]; //将距离转换成经度的计算公式 double δ = distance/R; // 转换为radian,否则结果会不正确 angle = Math.toRadians(angle); startLong = Math.toRadians(startLong); startLat = Math.toRadians(startLat); double lat = Math.asin(Math.sin(startLat)*Math.cos(δ)+Math.cos(startLat)*Math.sin(δ)*Math.cos(angle)); double lng = startLong + Math.atan2(Math.sin(angle)*Math.sin(δ)*Math.cos(startLat),Math.cos(δ)-Math.sin(startLat)*Math.sin(lat)); // 转为正常的10进制经纬度 lng = Math.toDegrees(lng); lat = Math.toDegrees(lat); result[0] = df.format(lng); result[1] = df.format(lat); return result; } }