package com.moral.service.impl;
|
|
import com.moral.entity.Device;
|
import com.moral.entity.DeviceRoad;
|
import com.moral.entity.MonitorPoint;
|
import com.moral.mapper.DeviceRoadMapper;
|
import com.moral.mapper.MonitorPointMapper;
|
import com.moral.service.DeviceRoadService;
|
import com.moral.util.MyLatLng;
|
import com.moral.util.mapUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.socket.sockjs.transport.handler.JsonpPollingTransportHandler;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class DeviceRoadServiceImpl implements DeviceRoadService {
|
@Resource
|
private MonitorPointMapper monitorPointMapper;
|
@Resource
|
private DeviceRoadMapper deviceRoadMapper;
|
|
@Override
|
public List<DeviceRoad> getAlarmData(String windData, String code, String mac, String speedLevel) {
|
int len = code.length();
|
Map params = new HashMap();
|
String townCode = null;
|
String areaCode = null;
|
String cityCode = null;
|
if (len == 12) {
|
townCode = code;
|
} else if (code.substring(4, 6).equals("00")) {
|
cityCode = code;
|
} else {
|
areaCode = code;
|
}
|
params.put("townCode", townCode);
|
params.put("areaCode", areaCode);
|
params.put("cityCode", cityCode);
|
List<MonitorPoint> monitorPointList = monitorPointMapper.byCodeGetMonitor(params);
|
List<MonitorPoint> monitorPoints = new ArrayList();
|
List<Device> allDeviceList = new ArrayList();
|
//找出所有国控站站点放到一个集合中；将几台国控站的所有设备放到一个集合中
|
for (MonitorPoint monitorPoint : monitorPointList) {
|
String description = monitorPoint.getDescription();
|
if (description != null) {
|
if (monitorPoint.getDescription().equals("国控站")) {
|
int monitorId = monitorPoint.getId();
|
MonitorPoint monitorPointG = monitorPointMapper.getMonitorPointById(monitorId);
|
monitorPoints.add(monitorPointG);
|
List<Device> deviceList = monitorPointMapper.getDeviceList(monitorId);
|
for (Device device : deviceList) {
|
String state = device.getState();
|
if (state.equals("1") || state.equals("2") || state.equals("0")) {
|
allDeviceList.add(device);
|
}
|
}
|
}
|
}
|
}
|
List drlist = null;
|
if (allDeviceList.size() > 0) {
|
for (int i = 0; i < allDeviceList.size(); i++) {
|
if (/*allDeviceList.get(i).getMac()*/("p5dnd7a0392210").equals(mac)) {
|
|
Double lng = allDeviceList.get(i).getLongitude();
|
Double lat = allDeviceList.get(i).getLatitude();
|
List<Integer> iList = new ArrayList<Integer>();
|
//求出每台设备和每台国控站的距离,距离大于5000米的舍弃
|
for (int j = 0; j < monitorPoints.size(); j++) {
|
Double distance = 0.0;
|
Double mLat = monitorPoints.get(j).getLatitude();
|
Double mLng = monitorPoints.get(j).getLongitude();
|
distance = mapUtils.getDistance(lng, lat, mLng, mLat);
|
if (distance < 5000) {
|
iList.add(j);
|
} else {
|
continue;
|
}
|
}
|
List<Integer> indexList = new ArrayList<Integer>();
|
if (iList.size() > 0) {
|
for (int q = 0; q < iList.size(); q++) {
|
int index = iList.get(q);
|
Double latitude = monitorPoints.get(index).getLatitude();
|
Double longitude = monitorPoints.get(index).getLongitude();
|
Double angle = mapUtils.getAngle(new MyLatLng(lng, lat), new MyLatLng(longitude, latitude));
|
Double angleDiff = angle - Double.parseDouble(windData);
|
if (Math.abs(angleDiff) < 30.0) {
|
indexList.add(index);
|
} else {
|
continue;
|
}
|
}
|
}
|
List<MonitorPoint> monitorPoints1 = new ArrayList<MonitorPoint>();
|
if (indexList.size() > 0) {
|
for (int k = 0; k < indexList.size(); k++) {
|
MonitorPoint monitorPoint1 = monitorPoints.get(indexList.get(k));
|
monitorPoints1.add(monitorPoint1);
|
}
|
}
|
|
|
//System.out.println(monitorPoints1.size());
|
if (monitorPoints1.size() > 0) {
|
drlist = new ArrayList();
|
for (MonitorPoint point : monitorPoints1) {
|
List<DeviceRoad> list = deviceRoadMapper.getData(mac, point.getId());
|
drlist.add(list);
|
}
|
|
}
|
|
|
//System.out.println("==========" + drlist);
|
}
|
}
|
|
}
|
|
return drlist;
|
}
|
}
|
