GpsRealData.java
6.31 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
package com.bsth.data.gpsdata_v2;
import com.bsth.data.BasicData;
import com.bsth.data.forecast.ForecastRealServer;
import com.bsth.data.gpsdata_v2.entity.GpsEntity;
import com.bsth.data.schedule.DayOfSchedule;
import com.bsth.entity.realcontrol.ScheduleRealInfo;
import com.bsth.message.buffer.CarEnergyBuffer;
import com.bsth.service.realcontrol.impl.ScheduleRealInfoServiceImpl;
import com.google.common.collect.TreeMultimap;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
/**
* @author PanZhao
* @ClassName: GpsRealData
* @Description: TODO(实时GPS数据集合)
* @date 2016年8月12日 下午2:04:41
*/
@Component
public class GpsRealData {
static Logger logger = LoggerFactory.getLogger(GpsRealData.class);
private static ConcurrentMap<String, GpsEntity> gpsMap;
//按线路分组设备号
private static TreeMultimap<String, String> lineCode2Devices;
@Autowired
DayOfSchedule dayOfSchedule;
@Autowired
ForecastRealServer forecastRealServer;
/**
* 构造函数
*/
public GpsRealData() {
gpsMap = new ConcurrentHashMap<>();
lineCode2Devices = TreeMultimap.create();
}
public void put(GpsEntity gps) {
String device = gps.getDeviceId();
GpsEntity old = gpsMap.get(device);
try {
if (!StringUtils.isEmpty(gps.getStopNo())) {
//站点编码改变
if (null == old || !gps.getStopNo().equals(old.getStopNo())) {
gps.setArrTime(gps.getTimestamp());
//预测到达终点时间
forecastRealServer.forecast(gps.getNbbm(), gps);
} else {
gps.setArrTime(old.getArrTime());
//不预测， 重新计算终点时间
gps.setExpectStopTime(forecastRealServer.expectStopTime(gps.getNbbm()));
}
}
//刷新对照
gpsMap.put(device, gps);
if (StringUtils.isNotBlank(gps.getLineId())) {
//站点名称
gps.setStationName(getStationName(gps));
lineCode2Devices.put(gps.getLineId(), device);
if(old != null && !gps.getLineId().equals(old.getLineId()))
lineCode2Devices.remove(old.getLineId(), device);
}
//车辆换设备了
String nbbm = gps.getNbbm();
if(old != null && StringUtils.isNotEmpty(nbbm) && !nbbm.equals(old.getNbbm())){
List<GpsEntity> list = findByNbbm(nbbm);
for(GpsEntity g : list){
if(!g.getDeviceId().equals(device))
gpsMap.remove(g.getDeviceId());
}
}
// 设置车辆的电量
gps.setEnergy(CarEnergyBuffer.getCarEnergy(gps.getNbbm()));
} catch (Exception e) {
logger.error("", e);
}
}
public String getStationName(GpsEntity gps) {
return BasicData.getStationNameByCode(gps.getStopNo(), gps.getLineId() + "_" + gps.getUpDown() + "_");
}
/**
* @Title: get @Description: TODO(设备号获取GPS)
*/
public static GpsEntity get(String deviceId) {
return gpsMap.get(deviceId);
}
public List<GpsEntity> findByNbbm(String nbbm){
Collection<GpsEntity> arr = gpsMap.values();
List<GpsEntity> rs = new ArrayList<>();
for(GpsEntity g : arr){
if(nbbm.equals(g.getNbbm()))
rs.add(g);
}
return rs;
}
public GpsEntity getByNbbm(String nbbm){
String device = BasicData.deviceId2NbbmMap.inverse().get(nbbm);
if(StringUtils.isNotBlank(device))
return get(device);
else
return null;
}
/**
* @Title: get @Description: TODO(线路编码获取GPS集合) @throws
*/
public List<GpsEntity> getByLine(String lineCode) {
NavigableSet<String> set = lineCode2Devices.get(lineCode);//实际车载
if(null == set)
set = new TreeSet();
Set<String> nbbmSet = dayOfSchedule.findCarByLineCode(lineCode);//计划用车
Map<String, String> nbbm2deviceMap = BasicData.deviceId2NbbmMap.inverse();
String deviceId;
for(String nbbm : nbbmSet){
deviceId = nbbm2deviceMap.get(nbbm);
if(StringUtils.isNotEmpty(deviceId))
set.add(deviceId);
}
List<GpsEntity> rs = new ArrayList<>();
GpsEntity gps;
ScheduleRealInfo sch;
for (String device : set) {
gps = gpsMap.get(device);
//过滤异常GPS数据
if (gps == null || StringUtils.isBlank(gps.getNbbm()))
continue;
sch = dayOfSchedule.execPlanMap().get(gps.getNbbm());
if (null != sch){
gps.setSchId(sch.getId());
if(!sch.getXlBm().equals(lineCode)){
//车辆在其他线路营运
gps.setRemark("执行 " + sch.getXlName() + " " + sch.getDfsj() + " 班次");
gps.setPlanCode(sch.getXlBm());
}
}else
gps.setRemark(null);
gps.setDvrcode(ScheduleRealInfoServiceImpl.DIRMAP.get(BasicData.deviceId2NbbmMap.get(gps.getDeviceId())));;
rs.add(gps);
}
return rs;
}
public static Set<String> findDevices(String lineCode){
return lineCode2Devices.get(lineCode);
}
public List<GpsEntity> get(List<String> pArray) {
List<GpsEntity> list = new ArrayList<>();
for (String code : pArray)
list.addAll(getByLine(code));
return list;
}
public Set<String> allDevices() {
return gpsMap.keySet();
}
public Collection<GpsEntity> all() {
return gpsMap.values();
}
public void remove(String device) {
gpsMap.remove(device);
}
}