GpsRealData.java
4.36 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
package com.bsth.data.gpsdata;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.NavigableSet;
import java.util.concurrent.TimeUnit;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.bsth.Application;
import com.bsth.data.BasicData;
import com.bsth.util.ConfigUtil;
import com.google.common.collect.TreeMultimap;
/**
*
* @ClassName: GpsRealEntityBuffer
* @Description: TODO(实时GPS数据集合)
* @author PanZhao
* @date 2016年8月12日 下午2:04:41
*
*/
@Component
public class GpsRealData implements CommandLineRunner{
static Logger logger = LoggerFactory.getLogger(GpsRealData.class);
private static Map<String, GpsEntity> gpsMap;
//按线路分组设备号
private static TreeMultimap<Integer, String> lineCode2Devices;
// 网关数据接口地址
private static String url;
@Autowired
GpsDataLoader gpsDataLoader;
/**
* 构造函数
*/
public GpsRealData(){
gpsMap = new HashMap<>();
lineCode2Devices = TreeMultimap.create();
url = ConfigUtil.get("http.gps.real.url");
}
@Override
public void run(String... arg0) throws Exception {
logger.info("gpsDataLoader,20,8");
Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 20, 8, TimeUnit.SECONDS);
}
public static GpsEntity add(GpsEntity gps) {
String device = gps.getDeviceId();
gpsMap.put(device, gps);
lineCode2Devices.put(gps.getLineId(), device);
return gps;
}
/**
*
* @Title: get @Description: TODO(设备号获取GPS)
*/
public GpsEntity get(String deviceId) {
return gpsMap.get(deviceId);
}
/**
*
* @Title: get @Description: TODO(线路编码获取GPS集合) @throws
*/
public List<GpsEntity> get(Integer lineCode) {
NavigableSet<String> set = lineCode2Devices.get(lineCode);
List<GpsEntity> rs = new ArrayList<>();
for(String device : set){
rs.add(gpsMap.get(device));
}
return rs;
}
public List<GpsEntity> get(List<String> pArray){
List<GpsEntity> list = new ArrayList<>();
for(String code : pArray)
list.addAll(get(Integer.parseInt(code)));
return list;
}
public GpsEntity findByDeviceId(String deviceId) {
return gpsMap.get(deviceId);
}
@Component
public static class GpsDataLoader extends Thread{
Logger logger = LoggerFactory.getLogger(GpsDataLoader.class);
@Override
public void run() {
try{
load();
}catch(Exception e){
logger.error("", e);
}
}
public void load() throws Exception {
List<GpsEntity> list = new ArrayList<>();
CloseableHttpClient httpClient = null;
CloseableHttpResponse response = null;
try {
httpClient = HttpClients.createDefault();
HttpGet get = new HttpGet(url);
response = httpClient.execute(get);
HttpEntity entity = response.getEntity();
if (null != entity) {
// 返回数据量比较大，建议以流的形式读取
BufferedReader br = new BufferedReader(new InputStreamReader(entity.getContent()));
StringBuffer stringBuffer = new StringBuffer();
String str = "";
while ((str = br.readLine()) != null)
stringBuffer.append(str);
JSONObject jsonObj = JSON.parseObject(stringBuffer.toString());
if (jsonObj != null)
list = JSON.parseArray(jsonObj.getString("data"), GpsEntity.class);
//附加车辆内部编码
for(GpsEntity gps : list){
gps.setNbbm(BasicData.deviceId2NbbmMap.get(gps.getDeviceId()));
gps.setStationName(BasicData.stationCode2NameMap.get(gps.getStopNo()));
add(gps);
}
} else
logger.error("result is null");
} finally {
if (null != httpClient)
httpClient.close();
if(null != response)
response.close();
}
}
}
}