From ba1e219d97e123b91657dc424f13a2fdeaa85d21 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: Mon, 21 Aug 2023 13:37:01 +0800
Subject: [PATCH] 修改兴趣点列表井号模糊查询
---
ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java | 779 +++++++++++++++++++++++++++++++++++++++++++++--------------
1 files changed, 597 insertions(+), 182 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
index a706028..bf19a74 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
@@ -1,20 +1,28 @@
package com.ruoyi.sy.service.impl;
+import java.io.IOException;
import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
import java.util.function.Predicate;
import java.util.stream.Collectors;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.core.redis.RedisCache;
+import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
+import com.ruoyi.scheduling.domian.SchedulingParam;
+import com.ruoyi.sy.domain.ArdSyCarDay;
+import com.ruoyi.sy.mapper.ArdSyCarDayMapper;
+import com.ruoyi.utils.tools.GisTool;
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import com.ruoyi.device.hiksdk.config.MinioClientSingleton;
-import com.ruoyi.device.hiksdk.util.minio.MinioUtils;
+import com.ruoyi.storage.minio.utils.MinioUtils;
import com.ruoyi.sy.domain.ArdSyUser;
import com.ruoyi.sy.gps31.PositionContainer;
import com.ruoyi.sy.mapper.ArdSyUserMapper;
@@ -29,6 +37,11 @@
import io.minio.Result;
import io.minio.http.Method;
import io.minio.messages.Item;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.stereotype.Service;
import com.ruoyi.sy.mapper.ArdSyCarMapper;
@@ -47,6 +60,7 @@
* @date 2023-06-26
*/
@Service
+@Slf4j(topic = "sy")
public class ArdSyCarServiceImpl implements IArdSyCarService {
@Resource
private ArdSyCarMapper ardSyCarMapper;
@@ -62,8 +76,14 @@
@Resource
private SYClient sYClient;
+ @Resource
+ RedisCache redisCache;
+ @Resource
+ private ArdSyCarDayMapper ardSyCarDayMapper;
- private Map<Integer,Map<String,String>> logInMap = new HashMap();
+ private Map<Integer, Map<String, String>> logInMap = new HashMap();
+
+ private Map<String, Timer> userCarTimerMap = new HashMap();
/**
* 查询三一车辆
@@ -95,7 +115,7 @@
*/
@Override
public int insertArdSyCar(ArdSyCar ardSyCar) {
- return ardSyCarMapper.insertArdSyCar(ardSyCar);
+ return ardSyCarMapper.insertArdSyCar(ardSyCar);
}
/**
@@ -119,8 +139,8 @@
public int deleteArdSyCarByIds(String[] ids) {
List<ArdSyCar> result = ardSyCarMapper.selectArdSyCarByIds(ids);
List<String> objectNames = new ArrayList();
- for(ArdSyCar ardSyCar : result){
- if(ardSyCar.getCarPicture() != null && !ardSyCar.getCarPicture().equals("")){
+ for (ArdSyCar ardSyCar : result) {
+ if (ardSyCar.getCarPicture() != null && !ardSyCar.getCarPicture().equals("")) {
objectNames.add(ardSyCar.getCarPicture().split("/sycar/")[1]);
}
}
@@ -143,54 +163,54 @@
* 获取未挂接权限的三一车辆
*/
@Override
- public Map<String,Object> getArdSyCarNoRight(String userId) {
+ public Map<String, Object> getArdSyCarNoRight(String userId) {
SysConfig config = new SysConfig();
config.setConfigKey("syCarPT");
List<SysConfig> sysConfigResult = sysConfigMapper.selectConfigList(config);
String syURL = "";
- Map<String,Object> result = new HashMap();
- if(sysConfigResult.size() == 0){
- result.put("data","三一车辆url没有录入");
- result.put("code","500");
+ Map<String, Object> result = new HashMap();
+ if (sysConfigResult.size() == 0) {
+ result.put("data", "三一车辆url没有录入");
+ result.put("code", "500");
return result;
- }else{
+ } else {
syURL = sysConfigResult.get(0).getConfigValue();
ArdSyUser ardSyUserPara = new ArdSyUser();
ardSyUserPara.setSysUserId(userId);
List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(ardSyUserPara);
- if(ardSyUserList.size() == 0){
- result.put("data","用户未挂接三一车辆");
- result.put("code","500");
+ if (ardSyUserList.size() == 0) {
+ result.put("data", "用户未挂接三一车辆");
+ result.put("code", "500");
return result;
- }else{
+ } else {
ArdSyUser ardSyUser = ardSyUserList.get(0);
//Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
- Map<String,Object> LogInResult = sYClient.logIn(syURL,passwordMd5,ardSyUser.getUserId());
+ Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, ardSyUser.getUserId());
String sessionId = (String) LogInResult.get("sessionId");
//Map<String,Object> carListMap = SYCarClient.getCarList(syURL,sessionId);
- Map<String,Object> carListMap = sYClient.getCarList(syURL,sessionId);
- if(((String)carListMap.get("rspCode")).equals("1")){
- List<Map<String,Object>> list = (List<Map<String,Object>>) carListMap.get("list");
+ Map<String, Object> carListMap = sYClient.getCarList(syURL, sessionId);
+ if (((String) carListMap.get("rspCode")).equals("1")) {
+ List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
ArdSyCar ardSyCar = new ArdSyCar();
List<ArdSyCar> ardSyCarList = ardSyCarMapper.selectArdSyCarList(ardSyCar);
List<String> carIdList = new ArrayList();
- for(ArdSyCar innerArdSyCar : ardSyCarList){
+ for (ArdSyCar innerArdSyCar : ardSyCarList) {
carIdList.add(innerArdSyCar.getCarId());
}
- List<Map<String,Object>> carList = list.stream().filter(new Predicate<Map<String,Object>>(){
+ List<Map<String, Object>> carList = list.stream().filter(new Predicate<Map<String, Object>>() {
@Override
- public boolean test(Map<String,Object> map) {
- return !carIdList.contains((String)map.get("carId"));
+ public boolean test(Map<String, Object> map) {
+ return !carIdList.contains((String) map.get("carId"));
}
}).collect(Collectors.toList());
- result.put("data",carList);
- result.put("code","200");
+ result.put("data", carList);
+ result.put("code", "200");
return result;
- }else{
- result.put("data","三一车辆平台出错");
- result.put("code","500");
+ } else {
+ result.put("data", "三一车辆平台出错");
+ result.put("code", "500");
return result;
}
}
@@ -203,36 +223,36 @@
config.setConfigKey("syCarPT");
List<SysConfig> sysConfigResult = sysConfigMapper.selectConfigList(config);
String syURL = "";
- Map<String,Object> result = new HashMap();
- if(sysConfigResult.size() == 0){
- result.put("data","三一车辆url没有录入");
- result.put("code","500");
+ Map<String, Object> result = new HashMap();
+ if (sysConfigResult.size() == 0) {
+ result.put("data", "三一车辆url没有录入");
+ result.put("code", "500");
return result;
- }else{
+ } else {
syURL = sysConfigResult.get(0).getConfigValue();
ArdSyUser ardSyUserPara = new ArdSyUser();
ardSyUserPara.setSysUserId(userId);
List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(ardSyUserPara);
- if(ardSyUserList.size() == 0){
- result.put("data","用户未挂接三一车辆");
- result.put("code","500");
+ if (ardSyUserList.size() == 0) {
+ result.put("data", "用户未挂接三一车辆");
+ result.put("code", "500");
return result;
- }else{
+ } else {
ArdSyUser ardSyUser = ardSyUserList.get(0);
//Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
- Map<String,Object> LogInResult = sYClient.logIn(syURL,passwordMd5,ardSyUser.getUserId());
+ Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, ardSyUser.getUserId());
String sessionId = (String) LogInResult.get("sessionId");
//Map<String,Object> carListMap = SYCarClient.getCarList(syURL,sessionId);
- Map<String,Object> carListMap = sYClient.getCarList(syURL,sessionId);
- if(((String)carListMap.get("rspCode")).equals("1")){
- List<Map<String,Object>> list = (List<Map<String,Object>>) carListMap.get("list");
- result.put("data",list);
- result.put("code","200");
+ Map<String, Object> carListMap = sYClient.getCarList(syURL, sessionId);
+ if (((String) carListMap.get("rspCode")).equals("1")) {
+ List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
+ result.put("data", list);
+ result.put("code", "200");
return result;
- }else{
- result.put("data","三一车辆平台出错");
- result.put("code","500");
+ } else {
+ result.put("data", "三一车辆平台出错");
+ result.put("code", "500");
return result;
}
}
@@ -240,30 +260,54 @@
}
@Override
- public List<Map<String,String>> getAllCarModel() {
+ public List<Map<String, String>> getAllCarModel() {
boolean exsit = MinioUtils.exitsBucket("sycar");
if (exsit) {
- List<Map<String,String>> listObjetcName = new ArrayList<>();
+ List<Map<String, String>> listObjetcName = new ArrayList<>();
try {
ListObjectsArgs listObjectsArgs = ListObjectsArgs.builder().prefix("carmodel/").bucket("sycar").build();
Iterable<Result<Item>> myObjects = MinioClientSingleton.getMinioClient().listObjects(listObjectsArgs);
for (Result<Item> result : myObjects) {
Item item = result.get();
- Map<String,String> map = new HashMap();
- map.put("carModel","sycar/" + item.objectName());
- switch(item.objectName()){
- case "carmodel/aodi.glb":map.put("carType","奥迪");break;
- case "carmodel/baolai.glb":map.put("carType","宝来");break;
- case "carmodel/bieke.glb":map.put("carType","别克");break;
- case "carmodel/bus1.glb":map.put("carType","大客车");break;
- case "carmodel/car.glb":map.put("carType","小型车");break;
- case "carmodel/fire(1).glb":map.put("carType","消防车");break;
- case "carmodel/fute.glb":map.put("carType","福特");break;
- case "carmodel/jingche_a.glb":map.put("carType","警车");break;
- case "carmodel/jiuhu.glb":map.put("carType","救护车");break;
- case "carmodel/oil.glb":map.put("carType","油罐车");break;
- case "carmodel/truck.glb":map.put("carType","工程用车");break;
- case "carmodel/van1.glb":map.put("carType","大货车");break;
+ Map<String, String> map = new HashMap();
+ map.put("carModel", "sycar/" + item.objectName());
+ switch (item.objectName()) {
+ case "carmodel/aodi.glb":
+ map.put("carType", "奥迪");
+ break;
+ case "carmodel/baolai.glb":
+ map.put("carType", "宝来");
+ break;
+ case "carmodel/bieke.glb":
+ map.put("carType", "别克");
+ break;
+ case "carmodel/bus1.glb":
+ map.put("carType", "大客车");
+ break;
+ case "carmodel/car.glb":
+ map.put("carType", "小型车");
+ break;
+ case "carmodel/fire(1).glb":
+ map.put("carType", "消防车");
+ break;
+ case "carmodel/fute.glb":
+ map.put("carType", "福特");
+ break;
+ case "carmodel/jingche_a.glb":
+ map.put("carType", "警车");
+ break;
+ case "carmodel/jiuhu.glb":
+ map.put("carType", "救护车");
+ break;
+ case "carmodel/oil.glb":
+ map.put("carType", "油罐车");
+ break;
+ case "carmodel/truck.glb":
+ map.put("carType", "工程用车");
+ break;
+ case "carmodel/van1.glb":
+ map.put("carType", "大货车");
+ break;
default:
break;
}
@@ -279,10 +323,10 @@
@Override
public String uploadCarPicture(String id, MultipartFile carPicture) {
- if(id != null && !id.equals("")){//id为非必要
+ if (id != null && !id.equals("")) {//id为非必要
ArdSyCar ardSyCarr = ardSyCarMapper.selectArdSyCarById(id);
List<String> objectNames = new ArrayList();
- if(ardSyCarr.getCarPicture() != null || !ardSyCarr.getCarPicture().equals("")){
+ if (ardSyCarr.getCarPicture() != null || !ardSyCarr.getCarPicture().equals("")) {
String objectName = ardSyCarr.getCarPicture().split("/sycar/")[1];
objectNames.add(objectName);
MinioUtils.removeObjects("sycar", objectNames);
@@ -299,7 +343,7 @@
//文件名
String originalFilename = carPicture.getOriginalFilename();
//新的文件名
- String fileName = "carpicture/" + IdUtils.fastSimpleUUID()+"_"+ originalFilename;
+ String fileName = "carpicture/" + IdUtils.fastSimpleUUID() + "_" + originalFilename;
try {
InputStream inputStream = carPicture.getInputStream();
/*上传对象*/
@@ -320,8 +364,8 @@
.method(Method.GET)
.build();
String presignedObjectUrl = MinioClientSingleton.getMinioClient().getPresignedObjectUrl(getPresignedObjectUrlArgs);
- String ObjectUrl = presignedObjectUrl.substring(0, presignedObjectUrl.indexOf("?"));
- if(id != null && !id.equals("")){//id为非必要
+ String ObjectUrl = presignedObjectUrl.substring(0, presignedObjectUrl.indexOf("?"));
+ if (id != null && !id.equals("")) {//id为非必要
ArdSyCar ardSyCar = new ArdSyCar();
ardSyCar.setId(id);
ardSyCar.setCarPicture(ObjectUrl);
@@ -344,10 +388,10 @@
public Results carListById(String id) {
try {
List<ArdSyCar> list = ardSyCarMapper.carListById(id);
- if(list.size()>0){
+ if (list.size() > 0) {
ArdSyCar ardSyCar = list.get(0);
return Results.succeed(ardSyCar);
- }else {
+ } else {
return Results.succeed();
}
} catch (Exception e) {
@@ -358,146 +402,196 @@
@Override
public Map<String, Object> getArdSyCarAndDeptByCarId(String carId) {
Map<String, Object> result = ardSyCarMapper.getArdSyCarAndDeptByCarId(carId);
+ if (result != null) {
+ if (result.get("carPicture") != null) {
+ if (!((String) result.get("carPicture")).equals("")) {
+ String url = ((String) result.get("carPicture")).split("sycar")[0];
+ String carModel = url + (String) result.get("carModel");
+ result.put("carModel", carModel);
+ }
+ }
+ }
return result;
}
@Override
public void sendArdSyCarPosition() {
- for(String key : ONLINE_USER_SESSIONS.keySet()){
- SysUser sysUser = userMapper.selectUserById(key);
- if(sysUser == null){
- return;
+ for (String key : ONLINE_USER_SESSIONS.keySet()) {
+ if (PositionContainer.getUserPositionMap().keySet().contains(key)) {//当追踪的车辆容器包含此用户Id，则实时位置推送需要剔除该车辆
+ SysUser sysUser = userMapper.selectUserById(key);
+ if (sysUser == null) {
+ //return;
+ continue;
+ }
+ String deptId = String.valueOf(sysUser.getDeptId());
+ Map<String, Map<String, Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
+ List<String> carIdList = new ArrayList();
+ carIdList.addAll(PositionContainer.getUserPositionMap().get(key).keySet());
+ String carId = carIdList.get(0);
+ map.remove(carId);
+ if (map != null) {
+ Map<String, Object> data = new HashMap();
+ data.put("30000", map.values());
+ WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+ }
+ } else {
+ SysUser sysUser = userMapper.selectUserById(key);
+ if (sysUser == null) {
+ //return;
+ continue;
+ }
+ String deptId = String.valueOf(sysUser.getDeptId());
+ Map<String, Map<String, Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
+ if (map != null) {
+ Map<String, Object> data = new HashMap();
+ data.put("30000", map.values());
+ WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+ }
}
- String deptId = String.valueOf(sysUser.getDeptId());
- Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
- if(map != null){
- Map<String,Object> data = new HashMap();
- data.put("30000", map.values());
- WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
+ }
+ for (String userId : userCarTimerMap.keySet()) {//用户离线后将车辆追踪资源释放
+ if (!ONLINE_USER_SESSIONS.keySet().contains(userId)) {
+ userCarTimerMap.get(userId).cancel();
+ userCarTimerMap.remove(userId);
+ PositionContainer.getUserPositionMap().remove(userId);
}
}
}
@Override
- public void sendArdSyCarAlarmByCarId(String carId, Map<String,Object> data) {
+ public void sendArdSyCarAlarmByCarId(String carId, Map<String, Object> data) {
List<SysUser> result = userMapper.getSysUserByCarId(carId);
- for(SysUser sysUser : result){
+ for (SysUser sysUser : result) {
WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sysUser.getUserId()), JSON.toJSONString(data));
}
}
/**
* 根据用户获取三一列表
+ *
* @return
*/
@Override
- public Map<String,Object> allListByUser(ArdSyUser ardSyUser,String syURL,String usersId){
- Map<String,Object> result0 = new HashMap();
+ public Map<String, Object> allListByUser(ArdSyUser ardSyUser, String syURL, String usersId) {
+ Map<String, Object> result0 = new HashMap();
//判断关联表是否有数据
- if(ardSyUser!=null){
+ if (ardSyUser != null) {
Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
//31用户名密码
String username31 = ardSyUser.getUserId();
String password31 = ardSyUser.getPassword();
String passwordMd5 = DigestUtils.md5Hex(password31);
- Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
+ Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
result = new HashMap();
result.put("userId", username31);
result.put("sessionId", (String) result1.get("sessionId"));
try {
- result0 = sYClient.getTeamList(syURL,result.get("userId"),result.get("sessionId"));
+ result0 = sYClient.getTeamList(syURL, result.get("userId"), result.get("sessionId"));
} catch (Exception e) {
- Map<String,Object> map = new HashMap();
+ Map<String, Object> map = new HashMap();
map.put("rspCode", 0);
map.put("list", new ArrayList());
return map;
}
int online = 0;
- for(Map<String,Object> map : (List<Map<String,Object>>) result0.get("list")){
- Map<String,Object> resultMap = sYClient.getTeamCarList(syURL,(String)map.get("teamId"),result.get("sessionId"));
- List<Map<String,Object>> carList = (List<Map<String, Object>>) resultMap.get("carList");
- for(Map<String,Object> m : carList){
- if(((String) m.get("stateCn")).contains("在线")){
+ for (Map<String, Object> map : (List<Map<String, Object>>) result0.get("list")) {
+ Map<String, Object> resultMap = sYClient.getTeamCarList(syURL, (String) map.get("teamId"), result.get("sessionId"));
+ List<Map<String, Object>> carList = (List<Map<String, Object>>) resultMap.get("carList");
+ for (Map<String, Object> m : carList) {
+ if (((String) m.get("stateCn")).contains("在线")) {
online = online + 1;
- }else{
+ } else {
continue;
}
}
- for(Map<String,Object> m : (List<Map<String,Object>>) result0.get("list")){
- if(((String) m.get("teamId")).equals(((String) map.get("teamId")))){
+ for (Map<String, Object> m : (List<Map<String, Object>>) result0.get("list")) {
+ if (((String) m.get("teamId")).equals(((String) map.get("teamId")))) {
map.put("count", Integer.parseInt((String) m.get("carNum")));
}
}
map.put("online", online);
online = 0;
}
- }else {
- result0.put("列表为空！","无关联账号！");
+ } else {
+ result0.put("列表为空！", "无关联账号！");
}
return result0;
}
@Override
- public List<Map<String,String>> getCarList(ArdSyUser ardSyUser, String syURL, String usersId,String teamId){
- List<Map<String,String>> list = new ArrayList<>();
+ public List<Map<String, String>> getCarList(ArdSyUser ardSyUser, String syURL, String usersId, String teamId) {
+ List<Map<String, String>> list = new ArrayList<>();
Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
//31用户名密码
String username31 = ardSyUser.getUserId();
String password31 = ardSyUser.getPassword();
String passwordMd5 = DigestUtils.md5Hex(password31);
- Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
+ Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
result = new HashMap();
result.put("userId", username31);
result.put("sessionId", (String) result1.get("sessionId"));
//查询该teamId下的车辆数据
- Map<String,Object> carList31 = new HashMap();
- carList31 = sYClient.getCarList1(syURL,teamId, result.get("userId"),result.get("sessionId"));
+ Map<String, Object> carList31 = new HashMap();
+ carList31 = sYClient.getCarList1(syURL, teamId, result.get("userId"), result.get("sessionId"));
//拿到车辆数据
- list= (List) carList31.get("list");
- if(list.isEmpty()){
+ list = (List) carList31.get("list");
+ if (list.isEmpty()) {
return list;
- }else {
+ } else {
List<String> carIdList = new ArrayList();
//所有carId
- for(Map<String,String> m : list){
+ for (Map<String, String> m : list) {
carIdList.add(m.get("carId"));
}
- if(carIdList.size() == 0){
- Map<String,String> map0 = new HashMap();
+ if (carIdList.size() == 0) {
+ Map<String, String> map0 = new HashMap();
map0.put("list", "{}");
map0.put("rspCode", "1");
list.add(map0);
return list;
}
//添加车辆属性
- for(Map<String,String> m : list){
+ for (Map<String, String> m : list) {
switch (m.get("state")) {
case "1":
- m.put("carState", "离线-从未报定位");break;
+ m.put("carState", "离线-从未报定位");
+ break;
case "2":
- m.put("carState", "离线-欠费");break;
+ m.put("carState", "离线-欠费");
+ break;
case "3":
- m.put("carState", "离线");break;
+ m.put("carState", "离线");
+ break;
case "4":
- m.put("carState", "离线-报警");break;
+ m.put("carState", "离线-报警");
+ break;
case "5":
- m.put("carState", "在线-从未报定位");break;
+ m.put("carState", "在线-从未报定位");
+ break;
case "6":
- m.put("carState", "在线-欠费");break;
+ m.put("carState", "在线-欠费");
+ break;
case "7":
- m.put("carState", "在线-行驶");break;
+ m.put("carState", "在线-行驶");
+ break;
case "8":
- m.put("carState", "在线-行驶-报警");break;
+ m.put("carState", "在线-行驶-报警");
+ break;
case "9":
- m.put("carState", "在线-停车-ACC关");break;
+ m.put("carState", "在线-停车-ACC关");
+ break;
case "10":
- m.put("carState", "在线-停车-ACC开");break;
+ m.put("carState", "在线-停车-ACC开");
+ break;
case "11":
- m.put("carState", "在线-停车-ACC关-报警");break;
+ m.put("carState", "在线-停车-ACC关-报警");
+ break;
case "12":
- m.put("carState", "在线-停车-ACC开-报警");break;
+ m.put("carState", "在线-停车-ACC开-报警");
+ break;
case "13":
- m.put("carState", "在线-无效定位");break;
+ m.put("carState", "在线-无效定位");
+ break;
default:
break;
}
@@ -508,24 +602,32 @@
/**
* 根据dept集合查询出所有对应的carId
+ *
* @param deptList
* @return
*/
@Override
- public List<Map<String,String>> carIdByDeptList(List<Long> deptList,List<Map<String,String>> list){
+ public List<Map<String, String>> carIdByDeptList(List<Long> deptList, List<Map<String, String>> list) {
QueryWrapper<ArdSyCar> queryWrapper = new QueryWrapper<>();
- queryWrapper.in("dept_id",deptList);
+ queryWrapper.in("dept_id", deptList);
List<ArdSyCar> carList = ardSyCarMapper.selectList(queryWrapper);
//对比把匹配到的数据添加到list中
- for(Map<String,String> m : list){
+ for (Map<String, String> m : list) {
String carId = m.get("carId");
for (int i = 0; i < carList.size(); i++) {
ArdSyCar ardSyCar = carList.get(i);
- if(carId.equals(ardSyCar.getCarId())){
- m.put("carModel",ardSyCar.getCarModel());
- m.put("carTypeArd",ardSyCar.getCarType());
- m.put("carBrand",ardSyCar.getCarBrand());
- m.put("carPicture",ardSyCar.getCarPicture());
+ if (carId.equals(ardSyCar.getCarId())) {
+ String url = "";
+ if (ardSyCar.getCarPicture() != null) {
+ if (!ardSyCar.getCarPicture().equals("")) {
+ url = ardSyCar.getCarPicture().split("sycar")[0];
+ }
+ }
+ m.put("carModel", url + ardSyCar.getCarModel());//zns
+ //m.put("carModel",ardSyCar.getCarModel());
+ m.put("carTypeArd", ardSyCar.getCarType());
+ m.put("carBrand", ardSyCar.getCarBrand());
+ m.put("carPicture", ardSyCar.getCarPicture());
}
}
}
@@ -533,23 +635,27 @@
}
@Override
- public Results getCarGPSTrack(Map<String,String> map,String syURL, ArdSyUser ardSyUser){
+ public Results getCarGPSTrack(Map<String, String> map, String syURL, ArdSyUser ardSyUser) {
String carId = map.get("carId");
- String startTime = map.get("startTime").replace(" ", "").replace("-", "").replace(":", "");
- String endTime = map.get("endTime").replace(" ", "").replace("-", "").replace(":", "");
+ //String startTime = map.get("startTime").replace(" ", "").replace("-", "").replace(":", "");
+ //String endTime = map.get("endTime").replace(" ", "").replace("-", "").replace(":", "");
+ String time = map.get("time");
+ time = time.replace("-", "");
+ String startTime = time + "000000";
+ String endTime = time + "235959";
String maxSpeed = map.get("maxSpeed");
//31用户名密码
String username31 = ardSyUser.getUserId();
String password31 = ardSyUser.getPassword();
String passwordMd5 = DigestUtils.md5Hex(password31);
- Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
- Map<String,Object> result0 = new HashMap();
- result0 = sYClient.getCarGPSTrack(syURL,carId,startTime,endTime,maxSpeed,(String) result1.get("sessionId"));
- List<Map<String,Object>> list = (List<Map<String, Object>>) result0.get("list");
- if(list.isEmpty()){
+ Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
+ Map<String, Object> result0 = new HashMap();
+ result0 = sYClient.getCarGPSTrack(syURL, carId, startTime, endTime, maxSpeed, (String) result1.get("sessionId"));
+ List<Map<String, Object>> list = (List<Map<String, Object>>) result0.get("list");
+ if (list.isEmpty()) {
return Results.succeed();
- }else {
- for(Map<String,Object> m : list) {
+ } else {
+ for (Map<String, Object> m : list) {
String alarmStts = (String) m.get("alarmStts");
Map<String, List<String>> alarmMap = getInfo("alarm", alarmStts);
m.putAll(alarmMap);
@@ -565,28 +671,30 @@
}
- public Map<String,List<String>> getInfo(String type,String stts){
- if(stts.isEmpty()){
+ public Map<String, List<String>> getInfo(String type, String stts) {
+ if (stts.isEmpty()) {
return new HashMap<>();
}
- String[] alarmTypes = {"紧急报警","超速报警","疲劳驾驶","危险预警","GNSS 模块发生故障","GNSS 天线未接或被剪断","GNSS 天线短路",
- "终端主电源欠压","终端主电源掉电","终端LCD 或显示器故障","TTS 模块故障","摄像头故障","道路运输证IC 卡模块故障","超速预警",
- "疲劳驾驶预警","违规行驶报警","胎压预警","右转盲区异常报警","当天累计驾驶超时","超时停车","进出区域","进出路线","路段行驶时间不足/过长",
- "路线偏离报警","车辆VSS 故障","车辆油量异常","车辆被盗","车辆非法点火","车辆非法位移","碰撞预警","侧翻预警","非法开门报警"};
+ String[] alarmTypes = {"紧急报警", "超速报警", "疲劳驾驶", "危险预警", "GNSS 模块发生故障", "GNSS 天线未接或被剪断", "GNSS 天线短路",
+ "终端主电源欠压", "终端主电源掉电", "终端LCD 或显示器故障", "TTS 模块故障", "摄像头故障", "道路运输证IC 卡模块故障", "超速预警",
+ "疲劳驾驶预警", "违规行驶报警", "胎压预警", "右转盲区异常报警", "当天累计驾驶超时", "超时停车", "进出区域", "进出路线", "路段行驶时间不足/过长",
+ "路线偏离报警", "车辆VSS 故障", "车辆油量异常", "车辆被盗", "车辆非法点火", "车辆非法位移", "碰撞预警", "侧翻预警", "非法开门报警"};
- String[] carTypes89 = {"空车","半载","保留","满载"};
+ String[] carTypes89 = {"空车", "半载", "保留", "满载"};
- Object[] carTypes = {"ACC开","定位","南纬","西经","停运状态","经纬度已经保密插件加密","保留","保留",carTypes89,"车辆油路断开","车门加锁",
- "车辆电路断开","门1开（前门）","门2开（中门）","门3开（后门","门4开（驾驶席门","门5开","使用GPS 卫星进行定位","使用北斗卫星进行定位",
- "使用GLONASS卫星进行定位","使用Galileo卫星进行定位","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留"};
+ Object[] carTypes = {"ACC开", "定位", "南纬", "西经", "停运状态", "经纬度已经保密插件加密", "保留", "保留", carTypes89, "车辆油路断开", "车门加锁",
+ "车辆电路断开", "门1开（前门）", "门2开（中门）", "门3开（后门", "门4开（驾驶席门", "门5开", "使用GPS 卫星进行定位", "使用北斗卫星进行定位",
+ "使用GLONASS卫星进行定位", "使用Galileo卫星进行定位", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留"};
- String[] sgnTypes = {"近光灯信号","远光灯信号","右转向灯信号","左转向灯信号","制动信号","倒档信号","雾灯信号","示廓灯","喇叭信号","空调状态",
- "空挡信号","缓速器工作","ABS 工作","加热器工作","离合器状态","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留",
- "保留","保留","保留","保留","保留","保留"};
- Integer sttsHex = Integer.parseInt(stts, 16);
- String sttsBin = Integer.toBinaryString(sttsHex);
- if(sttsBin.length() < 32){
- while(sttsBin.length() < 32){
+ String[] sgnTypes = {"近光灯信号", "远光灯信号", "右转向灯信号", "左转向灯信号", "制动信号", "倒档信号", "雾灯信号", "示廓灯", "喇叭信号", "空调状态",
+ "空挡信号", "缓速器工作", "ABS 工作", "加热器工作", "离合器状态", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留",
+ "保留", "保留", "保留", "保留", "保留", "保留"};
+ //Integer sttsHex = Integer.parseInt(stts, 16);
+ Long sttsHex = Long.parseLong(stts, 16);
+ //String sttsBin = Integer.toBinaryString(sttsHex);
+ String sttsBin = Long.toBinaryString(sttsHex);
+ if (sttsBin.length() < 32) {
+ while (sttsBin.length() < 32) {
sttsBin = "0" + sttsBin;
}
}
@@ -595,22 +703,22 @@
case "alarm":
List<String> alarmTypeArray = new ArrayList();
for (int i = 0; i < sttsBinArray.length; i++) {
- if(sttsBinArray[i].equals("1")){
+ if (sttsBinArray[i].equals("1")) {
alarmTypeArray.add(alarmTypes[i]);
}
}
- Map<String,List<String>> alarmMap = new HashMap();
+ Map<String, List<String>> alarmMap = new HashMap();
alarmMap.put(type, alarmTypeArray);
return alarmMap;
case "car":
List<String> carTypeArray = new ArrayList();
for (int i = 0; i < sttsBinArray.length; i++) {
- if(i <= 7 || i >= 10){
- if(sttsBinArray[i].equals("1")){
+ if (i <= 7 || i >= 10) {
+ if (sttsBinArray[i].equals("1")) {
carTypeArray.add(alarmTypes[i]);
}
- }else if(i == 8){
- switch (sttsBinArray[8]+sttsBinArray[9]) {
+ } else if (i == 8) {
+ switch (sttsBinArray[8] + sttsBinArray[9]) {
case "00":
carTypeArray.add(carTypes89[0]);
break;
@@ -626,16 +734,16 @@
default:
break;
}
- }else if(i == 9){
+ } else if (i == 9) {
continue;
- }else{
+ } else {
break;
}
}
- Map<String,List<String>> carMap = new HashMap();
+ Map<String, List<String>> carMap = new HashMap();
List<String> carTypeArray0 = new ArrayList();
- for(String str : carTypeArray){
- if(!str.equals("保留")){
+ for (String str : carTypeArray) {
+ if (!str.equals("保留")) {
carTypeArray0.add(str);
}
}
@@ -644,37 +752,344 @@
case "sgn":
List<String> sgnTypeArray = new ArrayList();
for (int i = 0; i < sttsBinArray.length; i++) {
- if(sttsBinArray[i].equals("1")){
+ if (sttsBinArray[i].equals("1")) {
sgnTypeArray.add(alarmTypes[i]);
}
}
- Map<String,List<String>> sgnMap = new HashMap();
+ Map<String, List<String>> sgnMap = new HashMap();
List<String> sgnTypeArray0 = new ArrayList();
- for(String str : sgnTypeArray){
- if(!str.equals("保留")){
+ for (String str : sgnTypeArray) {
+ if (!str.equals("保留")) {
sgnTypeArray0.add(str);
}
}
sgnMap.put(type, sgnTypeArray0);
return sgnMap;
default:
- return new HashMap<String,List<String>>();
+ return new HashMap<String, List<String>>();
}
}
@Override
- public Results getCarGPSBycarId(String usersId,String carId,String syURL,ArdSyUser ardSyUser){
+ public Results getCarGPSBycarId(String usersId, String carId, String syURL, ArdSyUser ardSyUser) {
Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
//31用户名密码
String username31 = ardSyUser.getUserId();
String password31 = ardSyUser.getPassword();
String passwordMd5 = DigestUtils.md5Hex(password31);
- Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
+ Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
result = new HashMap();
result.put("userId", username31);
result.put("sessionId", (String) result1.get("sessionId"));
- Map<String,Object> result0 = new HashMap();
- result0 = sYClient.getCarNearPositionByCarId(syURL,carId,result.get("userId"),result.get("sessionId"));
+ Map<String, Object> result0 = new HashMap();
+ result0 = sYClient.getCarNearPositionByCarId(syURL, carId, result.get("userId"), result.get("sessionId"));
return Results.succeed(result0);
}
+
+ @Override
+ public Results chaseCarByCarId(String usersId, String carId, String cycle) {
+ try {
+ /*Map<String,Map<String,Object>> map = new HashMap();
+ map.put(carId,new HashMap());
+ PositionContainer.getUserPositionMap().put(usersId,map);*/
+ if (cycle.equals("0")) {
+ if (userCarTimerMap.get(usersId) != null) {
+ userCarTimerMap.get(usersId).cancel();
+ userCarTimerMap.remove(usersId);
+ PositionContainer.getUserPositionMap().remove(usersId);
+ }
+ return Results.succeed("停止追踪");
+ } else {
+ if (userCarTimerMap.get(usersId) != null) {
+ userCarTimerMap.get(usersId).cancel();
+ userCarTimerMap.remove(usersId);
+ PositionContainer.getUserPositionMap().remove(usersId);
+ Map<String, Map<String, Object>> map = new HashMap();
+ map.put(carId, new HashMap());
+ PositionContainer.getUserPositionMap().put(usersId, map);
+ Date date = new Date();
+ Timer carPositionTimer = new Timer();//定时推送实时位置
+ TimerTask carPositionTask = new TimerTask() {
+ @Override
+ public void run() {
+ Map<String, Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
+ if (position != null) {
+ if (position.size() != 0) {
+ Map<String, Map<String, Object>> data = new HashMap();
+ data.put("31000", position);
+ WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
+ }
+ }
+ }
+ };
+ carPositionTimer.scheduleAtFixedRate(carPositionTask, date, Integer.parseInt(cycle));//启用
+ this.userCarTimerMap.put(usersId, carPositionTimer);
+ return Results.succeed("开始追踪");
+ } else {
+ Map<String, Map<String, Object>> map = new HashMap();
+ map.put(carId, new HashMap());
+ PositionContainer.getUserPositionMap().put(usersId, map);
+ Date date = new Date();
+ Timer carPositionTimer = new Timer();//定时推送实时位置
+ TimerTask carPositionTask = new TimerTask() {
+ @Override
+ public void run() {
+ Map<String, Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
+ if (position != null) {
+ if (position.size() != 0) {
+ Map<String, Map<String, Object>> data = new HashMap();
+ data.put("31000", position);
+ WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
+ }
+ }
+ }
+ };
+ carPositionTimer.scheduleAtFixedRate(carPositionTask, date, Integer.parseInt(cycle));//启用
+ this.userCarTimerMap.put(usersId, carPositionTimer);
+ return Results.succeed("开始追踪");
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ return Results.error("追踪失败");
+ }
+ }
+
+ /*@Override
+ public Results getExistTraceByCarIdAndMonth(String userId, String carId, String time) {
+ SysConfig config = new SysConfig();
+ config.setConfigKey("syCarPT");
+ List<SysConfig> sysConfigResult = sysConfigMapper.selectConfigList(config);
+ String syURL = "";
+ if(sysConfigResult.size() == 0){
+ return Results.succeed("三一车辆url没有录入");
+ }else{
+ syURL = sysConfigResult.get(0).getConfigValue();
+ ArdSyUser ardSyUserPara = new ArdSyUser();
+ ardSyUserPara.setSysUserId(userId);
+ List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(ardSyUserPara);
+ if(ardSyUserList.size() == 0){
+ return Results.succeed("用户未挂接三一车辆");
+ }else{
+ ArdSyUser ardSyUser = ardSyUserList.get(0);
+ String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
+ Map<String,Integer> existTraceMap = getExistTraceByCarIdAndMonth(syURL,ardSyUser.getUserId(),passwordMd5,carId,time);
+ return Results.succeed(existTraceMap);
+ }
+ }
+ }*/
+
+ @Override
+ public Results getExistTraceByCarIdAndMonth(String userId, String carId, String time) {
+ List<ArdSyCarDay> result = ardSyCarDayMapper.selectArdSyCarDayByCarIdAndDay(carId, time + "%");
+ List<String> list = new ArrayList();
+ for (ArdSyCarDay ardSyCarDay : result) {
+// list.add(ardSyCarDay.getDay().split("-")[2]);
+ list.add(ardSyCarDay.getDay());
+ }
+ return Results.succeed(list);
+ }
+
+ public Map<String, Integer> getExistTraceByCarIdAndMonth(String url, String usersId, String password, String carId, String time) {
+ Map<String, Object> LogInResult = sYClient.logIn(url, password, usersId);
+ String sessionId = (String) LogInResult.get("sessionId");
+
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
+ Date date = null;
+ try {
+ date = sdf.parse(time);
+ } catch (ParseException e) {
+ e.printStackTrace();
+ }
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(date);
+ int maxDay = calendar.getActualMaximum(Calendar.DAY_OF_MONTH);//获取该月天数
+ Map<String, Integer> existTraceMap = new HashMap();
+ ExecutorService newCachedThreadPoll = Executors.newCachedThreadPool();
+ for (int i = 1; i <= maxDay; i = i + 7) {
+ int temp = i;
+ String finalTime = time.replace("-", "");
+ String finalsyURL = url;
+ newCachedThreadPoll.execute(new Runnable() {
+ @Override
+ public void run() {
+ int temp0 = temp + 6;
+ if (temp0 > maxDay) {
+ temp0 = maxDay;
+ }
+ for (int j = temp; j <= temp0; j++) {
+ if (j <= 9) {
+ existTraceMap.put("0" + String.valueOf(j), -1);
+ } else {
+ existTraceMap.put(String.valueOf(j), -1);
+ }
+ }
+ if (temp <= 9) {
+ if (temp0 <= 9) {
+ String startTime = finalTime + "0" + temp + "000000";
+ String endTime = finalTime + "0" + temp0 + "235959";
+ Map<String, Object> result = getCarGPSTrack(finalsyURL, carId, startTime, endTime, sessionId);
+ String rspCode = (String) result.get("rspCode");
+ if (rspCode.equals("1")) {
+ List<Map<String, Object>> list = (List<Map<String, Object>>) result.get("list");
+ for (Map<String, Object> m : list) {
+ String time = (String) m.get("time");
+ time = time.split(" ")[0];
+ time = time.split("-")[2];
+ existTraceMap.put(time, 1);
+ }
+ }
+ } else {
+ String startTime = finalTime + "0" + temp + "000000";
+ String endTime = finalTime + temp0 + "235959";
+ Map<String, Object> result = getCarGPSTrack(finalsyURL, carId, startTime, endTime, sessionId);
+ String rspCode = (String) result.get("rspCode");
+ if (rspCode.equals("1")) {
+ List<Map<String, Object>> list = (List<Map<String, Object>>) result.get("list");
+ for (Map<String, Object> m : list) {
+ String time = (String) m.get("time");
+ time = time.split(" ")[0];
+ time = time.split("-")[2];
+ existTraceMap.put(time, 1);
+ }
+ }
+ }
+ } else {
+ String startTime = finalTime + temp + "000000";
+ String endTime = finalTime + temp0 + "235959";
+ Map<String, Object> result = getCarGPSTrack(finalsyURL, carId, startTime, endTime, sessionId);
+ String rspCode = (String) result.get("rspCode");
+ if (rspCode.equals("1")) {
+ List<Map<String, Object>> list = (List<Map<String, Object>>) result.get("list");
+ for (Map<String, Object> m : list) {
+ String time = (String) m.get("time");
+ time = time.split(" ")[0];
+ time = time.split("-")[2];
+ existTraceMap.put(time, 1);
+ }
+ }
+ }
+ for (int j = temp; j <= temp0; j++) {
+ String key = "";
+ if (j <= 9) {
+ key = "0" + j;
+ } else {
+ key = String.valueOf(j);
+ }
+ if (existTraceMap.get(key) == -1) {
+ existTraceMap.put(key, 0);
+ }
+
+ }
+ }
+ });
+ }
+ while (true) {
+ if (!existTraceMap.values().contains(-1)) {
+ if (existTraceMap.size() == maxDay) {
+ break;
+ }
+ }
+ }
+ try {
+ return existTraceMap;
+ } finally {
+ newCachedThreadPoll.shutdown();
+ }
+ }
+
+ public static Map<String, Object> getCarGPSTrack(String syURL, String carId, String startTime, String endTime, String sessionId) {
+ OkHttpClient okHttpClient = new OkHttpClient();
+
+ Request request = new Request.Builder()
+ .url(syURL + "/gps-web/api/get_gps_h.jsp?carId=" + carId + "&startTime=" + startTime + "&endTime=" + endTime + "&filter0=true&maxSpeed=&stopLong=5&queryAlarm=false&userId=yanshi&loginType=user&loginWay=android&loginLang=zh_CN&appDevId=&sessionId=" + sessionId)
+ .build();
+
+ Response response = null;
+ try {
+ response = okHttpClient.newCall(request).execute();
+ } catch (IOException e1) {
+ // TODO Auto-generated catch block
+ e1.printStackTrace();
+ }
+
+ response.headers(); //响应头
+
+ ResponseBody responseBody = response.body();
+
+ try {
+ String message = responseBody.string();// 响应体
+ Map<String, Object> map = (Map<String, Object>) JSON.parse(message);
+ //System.out.println(message);
+ return map;
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ return new HashMap();
+ }
+ }
+
+ /**
+ * 获取附近范围内的车辆信息
+ */
+
+ @Override
+ public List<Map<String, Object>> getNearCar(SchedulingParam param) {
+ Double longitude = param.getLongitude();
+ Double latitude = param.getLatitude();
+ Integer radius = param.getSealingRadius();
+ if (longitude == null && latitude == null) {
+ log.debug("原点坐标为空");
+ return null;
+ }
+ if (radius == null) {
+ log.debug("半径距离为空");
+ return null;
+ }
+ String userId = SecurityUtils.getUserId();
+ ArdSyUser syUser = new ArdSyUser();
+ syUser.setSysUserId(userId);
+ List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(syUser);
+ if (ardSyUserList.size() == 0) {
+ log.debug("用户未挂接三一车辆");
+ return null;
+ }
+ ArdSyUser ardSyUser = ardSyUserList.get(0);
+ String syUrl = redisCache.getCacheObject("sys_config:syCarPT");
+ String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
+ Map<String, Object> LogInResult = sYClient.logIn(syUrl, passwordMd5, ardSyUser.getUserId());
+ String sessionId = (String) LogInResult.get("sessionId");
+
+ Map<String, Object> teamList = sYClient.getTeamList(syUrl, ardSyUser.getUserId(), sessionId);
+ List<Map<String, Object>> listMap = (List<Map<String, Object>>) teamList.get("list");
+ List<Map<String, Object>> allList = new ArrayList<>();
+ for (Map<String, Object> team : listMap) {
+ String teamId = (String) team.get("teamId");
+ Map<String, Object> carListMap = sYClient.getCarList1(syUrl, teamId, ardSyUser.getUserId(), sessionId);
+ if (((String) carListMap.get("rspCode")).equals("1")) {
+ List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
+ allList.addAll(list);
+ }
+ }
+ //过滤在线车辆
+ List<Map<String, Object>> onlineList = allList.stream()
+ .filter(map -> !"离线".equals(map.get("stateCn")))
+ .collect(Collectors.toList());
+ List<Map<String, Object>> filteredList = new ArrayList<>();
+ //过滤半径
+ for (Map<String, Object> carMap : onlineList) {
+ String carId = (String) carMap.get("carId");
+ Map<String, Object> carGPSTrack = sYClient.getCarNearPositionByCarId(syUrl, carId, ardSyUser.getUserId(), sessionId);
+ List<Map<String, Object>> carGPSMap = (List<Map<String, Object>>) carGPSTrack.get("list");
+ Double lng = Double.valueOf((String) carGPSMap.get(0).get("lng"));
+ Double lat = Double.valueOf((String) carGPSMap.get(0).get("lat"));
+ double distance = GisTool.getDistance( new double[]{longitude,latitude}, new double[]{lng, lat});
+ if (distance <= radius) {
+ carMap.put("longitude",lng);
+ carMap.put("latitude",lat);
+ filteredList.add(carMap); // 将满足条件的车辆添加到筛选列表中
+ }
+ }
+ return filteredList;
+ }
}
--
Gitblit v1.9.3