mengff
/
jihe-dc
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

收费站枚举

develop
王兴琳 9 months ago
parent
39fbc79c58
commit
ee4fd54751
2 changed files with 312 additions and 246 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 55
      zc-business/src/main/java/com/zc/business/enums/LocationEnum.java
  2. 503
      zc-business/src/main/java/com/zc/business/service/impl/DcTrafficStatisticsServiceImpl.java

55
zc-business/src/main/java/com/zc/business/enums/LocationEnum.java
View File

@ -0,0 +1,55 @@
package com.zc.business.enums;
import java.util.Optional;
/**
*
*/
public enum LocationEnum {
CHANGQING_UNIVERSITY_CITY(1, "长清大学城"),
CHANGQING(2, "长清"),
XIAOLI(3, "孝里"),
PINGYIN_NORTH(4, "平阴北"),
PINGYIN(5, "平阴"),
PINGYIN_SOUTH(6, "平阴南"),
DONGPING(7, "东平"),
LIANGSHAN_EAST(8, "梁山东"),
LIANGSHAN(9, "梁山"),
JIAXIANG_WEST(10, "嘉祥西");
private final int order;
private final String name;
LocationEnum(int order, String name) {
this.order = order;
this.name = name;
}
public int getOrder() {
return order;
}
public String getName() {
return name;
}
// 通过序号查找枚举值，未找到时返回null
public static String findByOrder(int order) {
for (LocationEnum location : LocationEnum.values()) {
if (location.getOrder() == order) {
return location.getName();
}
}
return " "; // 未找到匹配的枚举值
}
// 查找序号，通过地点名称
public static int findOrderByName(String name) {
for (LocationEnum location : LocationEnum.values()) {
if (location.getName().equals(name)) {
return location.getOrder();
}
}
return -1; // 未找到匹配的名称
}
}

503
zc-business/src/main/java/com/zc/business/service/impl/DcTrafficStatisticsServiceImpl.java
View File

@ -1,4 +1,5 @@
package com.zc.business.service.impl;
import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
@ -12,6 +13,7 @@ import com.zc.business.domain.DcCongestionSection;
import com.zc.business.domain.DcFacility;
import com.zc.business.domain.DcRoadSection;
import com.zc.business.domain.DcRoadSectionCongestion;
import com.zc.business.enums.LocationEnum;
import com.zc.business.enums.StakeMarkRange;
import com.zc.business.enums.UniversalEnum;
import com.zc.business.service.IDcFacilityService;
@ -39,6 +41,7 @@ import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
@Service
public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsService {
@ -194,24 +197,24 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.GETS_THE_VEHICLE_TRAFFIC_URI_IN_TRANSIT.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.GETS_THE_VEHICLE_TRAFFIC_URI_IN_TRANSIT.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
}
}
}
return new JSONArray();
return new JSONArray();
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -234,73 +237,73 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.AVERAGE_SPEED_URI_OF_GANTRY_IN_TRANSIT.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.AVERAGE_SPEED_URI_OF_GANTRY_IN_TRANSIT.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
ResponseBody body = response.body();
JSONArray jsonArray = null;
JSONArray jsonArray = null;
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
jsonArray = JSON.parseArray(jsonString);
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
jsonArray = JSON.parseArray(jsonString);
}
}
}
Map<String, Integer> map = new HashMap<>();
Map<String, Integer> map = new HashMap<>();
if (jsonArray != null) {
jsonArray.forEach(jsonObject -> {
if (jsonObject instanceof JSONObject) {
String gantryId = ((JSONObject) jsonObject).getString("gantry_id");
map.put(gantryId, ((JSONObject) jsonObject).getInteger("avg_speed"));
}
});
}
if (jsonArray != null) {
jsonArray.forEach(jsonObject -> {
if (jsonObject instanceof JSONObject) {
String gantryId = ((JSONObject) jsonObject).getString("gantry_id");
map.put(gantryId, ((JSONObject) jsonObject).getInteger("avg_speed"));
}
});
}
if (map.isEmpty()) {
return new JSONArray();
}
if (map.isEmpty()) {
return new JSONArray();
}
LambdaQueryWrapper<DcFacility> queryWrapper = new LambdaQueryWrapper<>();
LambdaQueryWrapper<DcFacility> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.in(DcFacility::getFacilityCode, map.keySet());
queryWrapper.in(DcFacility::getFacilityCode, map.keySet());
List<DcFacility> facilities = facilityService.list(queryWrapper);
List<DcFacility> facilities = facilityService.list(queryWrapper);
if (facilities == null || facilities.isEmpty()) {
return new JSONArray();
}
if (facilities == null || facilities.isEmpty()) {
return new JSONArray();
}
List<DcRoadSection> roadSections = roadSectionService.selectDcRoadSectionListAll(null);
List<DcRoadSection> roadSections = roadSectionService.selectDcRoadSectionListAll(null);
JSONArray jsonArray1 = new JSONArray();
JSONArray jsonArray1 = new JSONArray();
roadSections.forEach(item -> {
Integer startStakeMark = StakeMarkUtils.stakeMarkToInt(item.getStartStakeMark());
Integer endStakeMark = StakeMarkUtils.stakeMarkToInt(item.getEndStakeMark());
roadSections.forEach(item -> {
Integer startStakeMark = StakeMarkUtils.stakeMarkToInt(item.getStartStakeMark());
Integer endStakeMark = StakeMarkUtils.stakeMarkToInt(item.getEndStakeMark());
for (DcFacility facility : facilities) {
Integer stakeMark = StakeMarkUtils.stakeMarkToInt(facility.getStakeMark());
for (DcFacility facility : facilities) {
Integer stakeMark = StakeMarkUtils.stakeMarkToInt(facility.getStakeMark());
if (stakeMark >= startStakeMark && stakeMark <= endStakeMark) {
JSONObject jsonObject = new JSONObject();
jsonObject.put("sectionId", item.getId());
jsonObject.put("sectionName", item.getSectionName());
jsonObject.put("avgSpeed", map.get(facility.getFacilityCode()));
jsonObject.put("facilityCode", facility.getFacilityCode());
jsonArray1.add(jsonObject);
break;
if (stakeMark >= startStakeMark && stakeMark <= endStakeMark) {
JSONObject jsonObject = new JSONObject();
jsonObject.put("sectionId", item.getId());
jsonObject.put("sectionName", item.getSectionName());
jsonObject.put("avgSpeed", map.get(facility.getFacilityCode()));
jsonObject.put("facilityCode", facility.getFacilityCode());
jsonArray1.add(jsonObject);
break;
}
}
}
});
});
return jsonArray1;
return jsonArray1;
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -322,23 +325,23 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.GETS_THE_URI_OF_THE_CURRENT_CONGESTION_EVENT.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.GETS_THE_URI_OF_THE_CURRENT_CONGESTION_EVENT.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
}
}
}
return new JSONArray();
return new JSONArray();
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -577,24 +580,24 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.GETS_THE_LANE_OCCUPANCY_URI.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.GETS_THE_LANE_OCCUPANCY_URI.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
}
}
}
return new JSONArray();
return new JSONArray();
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -628,25 +631,25 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.OBTAIN_THE_SHELF_INDICATOR_DATA.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.OBTAIN_THE_SHELF_INDICATOR_DATA.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
}
}
}
return new JSONArray();
return new JSONArray();
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -790,33 +793,42 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
JSONArray jsonArray = JSON.parseArray(jsonString);
Map<String, Integer> sumByName = new LinkedHashMap<>();
List<Map<String, String>> list = new ArrayList();
for (Object item : jsonArray) { // 这里做了微调，直接遍历jsonArray的Object
JSONObject jsonObject = (JSONObject) item;
if (!JSON.isValidArray(jsonString)) return Collections.emptyList();
// 获取当前时间
LocalTime now = LocalTime.now();
// 获取当前小时数（24小时制）
int currentHour = now.getHour();
if (jsonObject.getInteger("data_hour") == currentHour) {
String name = jsonObject.getString("ts_name"); // 更安全的取值方式
int totalFlow = jsonObject.getInteger("total_flow"); // 专门针对Integer类型
JSONArray jsonArray = JSON.parseArray(jsonString);
sumByName.put(name, totalFlow);
}
}
// 正确创建新的映射对象并添加到list中
for (Map.Entry<String, Integer> entry : sumByName.entrySet()) {
Map<String, String> singleResult = new LinkedHashMap<>(); // 每次循环都创建一个新的映射
singleResult.put("name", entry.getKey());
singleResult.put("value", entry.getValue().toString());
list.add(singleResult);
}
return list;
}
// 从JSON数据创建原始数据映射，构造为String类型值
Map<String, Map<String, String>> originalDataMap = jsonArray.stream()
.filter(item -> ((JSONObject) item).getInteger("data_hour") == LocalTime.now().getHour())
.collect(Collectors.toMap(
item -> ((JSONObject) item).getString("ts_name"),
item -> {
JSONObject jsonObject = (JSONObject) item;
return new HashMap<String, String>() {{
put("value", String.valueOf(jsonObject.getInteger("total_flow")));
put("orderId", jsonObject.getString("order_id"));
}};
},
(oldVal, newVal) -> oldVal, // 保留旧值以解决键冲突
LinkedHashMap::new // 保持插入顺序
));
// 直接基于原始数据映射和LocationEnum构建最终结果列表
List<Map<String, String>> resultList = Arrays.stream(LocationEnum.values())
.map(location -> {
Map<String, String> defaultData = new HashMap<String, String>() {{
put("value", "0");
put("orderId", String.valueOf(LocationEnum.findOrderByName(location.getName())));
}};
return new HashMap<String, String>() {{
put("name", location.getName());
put("value", originalDataMap.getOrDefault(location.getName(), defaultData).get("value"));
put("orderId", originalDataMap.getOrDefault(location.getName(), defaultData).get("orderId"));
}};
})
.collect(Collectors.toList());
return resultList;
}
return new ArrayList();
} catch (IOException e) {
@ -848,24 +860,24 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.THE_ENTRANCE_OF_EACH_TOLL_STATION_IS_DIVIDED_INTO_VEHICLE_FLOW.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
}else {
return new JSONArray();
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.THE_ENTRANCE_OF_EACH_TOLL_STATION_IS_DIVIDED_INTO_VEHICLE_FLOW.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
return JSON.parseArray(jsonString);
} else {
return new JSONArray();
}
}
}
return new JSONArray();
return new JSONArray();
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -995,7 +1007,7 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
} else {
return new JSONArray();
}
}else {
} else {
return new JSONArray();
}
} catch (IOException e) {
@ -1059,36 +1071,36 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Map<String, String> headers = new HashMap<>();
headers.put("Authorization", getAccessToken());
try {
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.THE_WHOLE_SECTION_TWO_WAY_REAL_TIME_TRAFFIC_FLOW_URL.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
JSONArray jsonArray = JSON.parseArray(jsonString);
for (Object item : jsonArray) {
JSONObject jsonObject = (JSONObject) item;
if (jsonObject.getString("gantry_id").equals(nearestFacility.getFacilityCode())) {
Map<String, Object> map = new HashMap<>();
int totalFlow = jsonObject.getInteger("total_flow");
int data_hour = jsonObject.getInteger("data_hour");
map.put("hour", data_hour);
map.put("totalFlow", totalFlow);
mapList.add(map);
Response response // 请求响应
= okHttp
.headers(headers)
.url(baseUrl + UniversalEnum.THE_WHOLE_SECTION_TWO_WAY_REAL_TIME_TRAFFIC_FLOW_URL.getValue()) // 请求地址
.data(requestParams) // 请求参数
.post(); // 请求方法
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
JSONArray jsonArray = JSON.parseArray(jsonString);
for (Object item : jsonArray) {
JSONObject jsonObject = (JSONObject) item;
if (jsonObject.getString("gantry_id").equals(nearestFacility.getFacilityCode())) {
Map<String, Object> map = new HashMap<>();
int totalFlow = jsonObject.getInteger("total_flow");
int data_hour = jsonObject.getInteger("data_hour");
map.put("hour", data_hour);
map.put("totalFlow", totalFlow);
mapList.add(map);
}
}
}
}
}
// 输出结果
return mapList;
}
return mapList;
}
return null;
return null;
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -1129,67 +1141,67 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
.post(RequestBody.create(MediaType.parse("application/json; charset=utf-8"), requestParamsJson))
.build();
Response response = okHttpClient.newCall(request).execute();
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
JSONArray jsonArray = JSON.parseArray(jsonString);
for (Object object : jsonArray) {
JSONObject jsonObject = (JSONObject) object;
Integer asOneRoad = jsonObject.getInteger("as_one_road");
if (jsonObject.getDouble("end_pile_no") != null) {
double endPileNo = jsonObject.getDouble("end_pile_no");
String endMark = formatNumber(endPileNo);
jsonObject.put("endMark", endMark);//结束桩号
}
double startPileNo = jsonObject.getDouble("start_pile_no");
String stakeMark = formatNumber(startPileNo);
jsonObject.put("stakeMark", stakeMark);//
//as_one_road
//是否为同一条路，1-是，0-否
if (asOneRoad == UniversalEnum.ZERO.getNumber()) {
String string = jsonObject.getString("list_link_info");
JSONArray jsonlist = JSON.parseArray(string);
JSONObject o = (JSONObject) jsonlist.get(UniversalEnum.ZERO.getNumber());
String string1 = o.getString("firstPoint");
String string2 = o.getString("lastPoint");
String lngLats = o.getString("lngLats");
String[] lngLatsString = lngLats.split(";");
double s = Double.parseDouble(lngLatsString[UniversalEnum.ZERO.getNumber()].split(",")[UniversalEnum.ZERO.getNumber()]);
double s2 = Double.parseDouble(lngLatsString[UniversalEnum.ZERO.getNumber()].split(",")[UniversalEnum.ONE.getNumber()]);
double s3 = Double.parseDouble(lngLatsString[lngLatsString.length - UniversalEnum.ONE.getNumber()].split(",")[UniversalEnum.ZERO.getNumber()]);
double s4 = Double.parseDouble(lngLatsString[lngLatsString.length - UniversalEnum.ONE.getNumber()].split(",")[UniversalEnum.ONE.getNumber()]);
double distanceM = calculateDistance(s2, s, s4, s3);
// System.out.printf("最大距离为: %.2f 米%n", distanceM);
jsonObject.put("max_jam_dist", distanceM);//最大拥堵距离
double endMake = startPileNo + Double.parseDouble(String.format("%.3f", distanceM));
String endmark = formatNumber(endMake);
jsonObject.put("endMark", endmark);//结束桩号
String[] split = string1.split(",");
double firstLon = Double.parseDouble(split[UniversalEnum.ZERO.getNumber()]);
double firstLat = Double.parseDouble(split[UniversalEnum.ONE.getNumber()]);
String[] split2 = string2.split(",");
double lastLon = Double.parseDouble(split2[UniversalEnum.ZERO.getNumber()]);
double lastLat = Double.parseDouble(split2[UniversalEnum.ONE.getNumber()]);
//double firstLat = 35.38524527319016;
// double firstLon = 118.39808642864227;
//double lastLat = 35.386351346969604;
// double lastLon = 118.4038907289505;
double distanceKm = calculateDistance(firstLat, firstLon, lastLat, lastLon);
double distanceMeters = distanceKm * UniversalEnum.THOUSAND.getNumber(); // 将距离转换为米
//System.out.printf("两点之间的距离为: %.2f 米%n", distanceMeters);
jsonObject.put("jam_dist", distanceMeters);//当前拥堵距离
ResponseBody body = response.body();
if (body != null) {
String jsonString = body.string();
if (JSON.isValidArray(jsonString)) {
JSONArray jsonArray = JSON.parseArray(jsonString);
for (Object object : jsonArray) {
JSONObject jsonObject = (JSONObject) object;
Integer asOneRoad = jsonObject.getInteger("as_one_road");
if (jsonObject.getDouble("end_pile_no") != null) {
double endPileNo = jsonObject.getDouble("end_pile_no");
String endMark = formatNumber(endPileNo);
jsonObject.put("endMark", endMark);//结束桩号
}
double startPileNo = jsonObject.getDouble("start_pile_no");
String stakeMark = formatNumber(startPileNo);
jsonObject.put("stakeMark", stakeMark);//
//as_one_road
//是否为同一条路，1-是，0-否
if (asOneRoad == UniversalEnum.ZERO.getNumber()) {
String string = jsonObject.getString("list_link_info");
JSONArray jsonlist = JSON.parseArray(string);
JSONObject o = (JSONObject) jsonlist.get(UniversalEnum.ZERO.getNumber());
String string1 = o.getString("firstPoint");
String string2 = o.getString("lastPoint");
String lngLats = o.getString("lngLats");
String[] lngLatsString = lngLats.split(";");
double s = Double.parseDouble(lngLatsString[UniversalEnum.ZERO.getNumber()].split(",")[UniversalEnum.ZERO.getNumber()]);
double s2 = Double.parseDouble(lngLatsString[UniversalEnum.ZERO.getNumber()].split(",")[UniversalEnum.ONE.getNumber()]);
double s3 = Double.parseDouble(lngLatsString[lngLatsString.length - UniversalEnum.ONE.getNumber()].split(",")[UniversalEnum.ZERO.getNumber()]);
double s4 = Double.parseDouble(lngLatsString[lngLatsString.length - UniversalEnum.ONE.getNumber()].split(",")[UniversalEnum.ONE.getNumber()]);
double distanceM = calculateDistance(s2, s, s4, s3);
// System.out.printf("最大距离为: %.2f 米%n", distanceM);
jsonObject.put("max_jam_dist", distanceM);//最大拥堵距离
double endMake = startPileNo + Double.parseDouble(String.format("%.3f", distanceM));
String endmark = formatNumber(endMake);
jsonObject.put("endMark", endmark);//结束桩号
String[] split = string1.split(",");
double firstLon = Double.parseDouble(split[UniversalEnum.ZERO.getNumber()]);
double firstLat = Double.parseDouble(split[UniversalEnum.ONE.getNumber()]);
String[] split2 = string2.split(",");
double lastLon = Double.parseDouble(split2[UniversalEnum.ZERO.getNumber()]);
double lastLat = Double.parseDouble(split2[UniversalEnum.ONE.getNumber()]);
//double firstLat = 35.38524527319016;
// double firstLon = 118.39808642864227;
//double lastLat = 35.386351346969604;
// double lastLon = 118.4038907289505;
double distanceKm = calculateDistance(firstLat, firstLon, lastLat, lastLon);
double distanceMeters = distanceKm * UniversalEnum.THOUSAND.getNumber(); // 将距离转换为米
//System.out.printf("两点之间的距离为: %.2f 米%n", distanceMeters);
jsonObject.put("jam_dist", distanceMeters);//当前拥堵距离
}
}
}
return jsonArray;
return jsonArray;
}
}
}
return new JSONArray();
return new JSONArray();
} catch (IOException e) {
// 处理异常
e.printStackTrace();
@ -1236,8 +1248,7 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
}
return totalFlow1 + totalFlow2;
}
catch (IOException e) {
} catch (IOException e) {
// 处理异常
e.printStackTrace();
return UniversalEnum.ZERO.getNumber();
@ -1270,12 +1281,12 @@ public class DcTrafficStatisticsServiceImpl implements IDcTrafficStatisticsServi
Gson gson = new Gson();
String requestParamsJson = gson.toJson(requestParams);
Request request = new Request.Builder()
.url(baseUrl + UniversalEnum.EACH_TOLL_STATION_ENTRANCE_BY_TYPE_OF_HOURLY_TRAFFIC_FLOW.getValue())
.headers(Headers.of(headers))
.post(RequestBody.create(MediaType.parse("application/json; charset=utf-8"), requestParamsJson))
.build();
Response response = okHttpClient.newCall(request).execute();
Request request = new Request.Builder()
.url(baseUrl + UniversalEnum.EACH_TOLL_STATION_ENTRANCE_BY_TYPE_OF_HOURLY_TRAFFIC_FLOW.getValue())
.headers(Headers.of(headers))
.post(RequestBody.create(MediaType.parse("application/json; charset=utf-8"), requestParamsJson))
.build();
Response response = okHttpClient.newCall(request).execute();
return response;
}

Write Preview
Loading…
Cancel
Save