parent
f66794f3d8
commit
adcac54754
@ -0,0 +1,24 @@
|
||||
package com.ykMap.base.config;
|
||||
|
||||
/**
|
||||
* mybatis-plus分页查询
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/19 16:55
|
||||
*/
|
||||
|
||||
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
|
||||
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
@Configuration
|
||||
public class MyBatisPlusConfig {
|
||||
|
||||
@Bean
|
||||
public MybatisPlusInterceptor mybatisPlusInterceptor() {
|
||||
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
|
||||
interceptor.addInnerInterceptor(new PaginationInnerInterceptor());
|
||||
return interceptor;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,42 @@
|
||||
package com.ykMap.controller;
|
||||
|
||||
import com.ykMap.base.controller.BaseController;
|
||||
import com.ykMap.base.domain.AjaxResult;
|
||||
import com.ykMap.entity.request.CarPageRequest;
|
||||
import com.ykMap.entity.response.CarPageResponse;
|
||||
import com.ykMap.service.CarService;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import jakarta.validation.Valid;
|
||||
import org.springframework.web.bind.annotation.GetMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
/**
|
||||
* 车辆实时定位
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/12 10:22
|
||||
*/
|
||||
@RestController
|
||||
@RequestMapping("/ykmap/car")
|
||||
@Api(tags = "车辆实时定位接口")
|
||||
public class CarController extends BaseController {
|
||||
|
||||
@Resource
|
||||
private CarService carService;
|
||||
|
||||
/**
|
||||
* 分页查询单位内外的车辆任务
|
||||
*
|
||||
* @param req 请求类
|
||||
* @return 响应类
|
||||
*/
|
||||
@GetMapping("page")
|
||||
@ApiOperation(value = "分页查询单位内外的车辆任务", response = CarPageResponse.class)
|
||||
public AjaxResult page( @Valid CarPageRequest req) {
|
||||
return success(carService.page(req));
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
package com.ykMap.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* @author wu
|
||||
* @since 2025/3/19 17:04
|
||||
*/
|
||||
@Data
|
||||
public class ColDTO implements Serializable {
|
||||
private static final long serialVersionUID = -8045055883099483791L;
|
||||
|
||||
private String value;
|
||||
|
||||
private String label;
|
||||
|
||||
}
|
||||
@ -0,0 +1,44 @@
|
||||
package com.ykMap.entity.request;
|
||||
|
||||
import io.swagger.annotations.ApiModel;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import jakarta.validation.constraints.NotNull;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 分页查询单位内外的车辆任务请求类
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/14 14:22
|
||||
*/
|
||||
@Data
|
||||
@ApiModel("分页查询单位内外的车辆任务请求类")
|
||||
public class CarPageRequest implements Serializable {
|
||||
private static final long serialVersionUID = 1031466955513130671L;
|
||||
/**
|
||||
* 当前页
|
||||
*/
|
||||
@ApiModelProperty(value = "当前页 默认1")
|
||||
public Integer pageNo = 1;
|
||||
|
||||
/**
|
||||
* 每页显示条数
|
||||
*/
|
||||
@ApiModelProperty(value = "每页显示条数 默认10")
|
||||
public Integer pageSize = 10;
|
||||
|
||||
/**
|
||||
* 距离单位距离
|
||||
*/
|
||||
@ApiModelProperty(value = "距离单位距离(米) 默认200米")
|
||||
public double distance = 200;
|
||||
|
||||
/**
|
||||
* 单位内外 1单位外 2单位内
|
||||
*/
|
||||
@ApiModelProperty(value = "单位内外 1单位外 2单位内", required = true)
|
||||
@NotNull(message = "单位内外不能为空")
|
||||
private Integer type;
|
||||
}
|
||||
@ -0,0 +1,31 @@
|
||||
package com.ykMap.entity.response;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 车辆实时数据
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/14 15:02
|
||||
*/
|
||||
@Data
|
||||
public class CarGPSResponse implements Serializable {
|
||||
private static final long serialVersionUID = 6524106295010311569L;
|
||||
|
||||
/**
|
||||
* 车牌号
|
||||
*/
|
||||
public String carPlate;
|
||||
|
||||
/**
|
||||
* 84坐标系经度
|
||||
*/
|
||||
public String lat;
|
||||
|
||||
/**
|
||||
* 84坐标系纬度
|
||||
*/
|
||||
public String lng;
|
||||
}
|
||||
@ -0,0 +1,30 @@
|
||||
package com.ykMap.entity.response;
|
||||
|
||||
import io.swagger.annotations.ApiModel;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 分页查询单位内外的车辆任务响应类
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/14 14:32
|
||||
*/
|
||||
@Data
|
||||
@ApiModel("分页查询单位内外的车辆任务响应类")
|
||||
public class CarPageResponse implements Serializable {
|
||||
|
||||
/**
|
||||
* 车牌号
|
||||
*/
|
||||
@ApiModelProperty(value = "车牌号")
|
||||
public String carNumber;
|
||||
|
||||
/**
|
||||
* 车辆关联任务
|
||||
*/
|
||||
@ApiModelProperty(value = "车辆关联任务")
|
||||
public String taskTitle;
|
||||
}
|
||||
@ -0,0 +1,30 @@
|
||||
package com.ykMap.entity.response;
|
||||
|
||||
import io.swagger.annotations.ApiModel;
|
||||
import io.swagger.annotations.ApiModelProperty;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 分页查询单位内外的车辆任务响应类
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/14 14:32
|
||||
*/
|
||||
@Data
|
||||
@ApiModel("分页查询单位内外的车辆任务响应类")
|
||||
public class CarResponse implements Serializable {
|
||||
|
||||
/**
|
||||
* 车牌号
|
||||
*/
|
||||
@ApiModelProperty(value = "车牌号")
|
||||
public String carNumber;
|
||||
|
||||
/**
|
||||
* 车辆关联任务
|
||||
*/
|
||||
@ApiModelProperty(value = "车辆关联任务")
|
||||
public String taskTitle;
|
||||
}
|
||||
@ -0,0 +1,24 @@
|
||||
package com.ykMap.entity.response;
|
||||
|
||||
import com.ykMap.entity.ColDTO;
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @author wu
|
||||
* @since 2025/3/19 17:02
|
||||
*/
|
||||
@Data
|
||||
public class ContentResponse implements Serializable {
|
||||
private static final long serialVersionUID = -8078281805074879229L;
|
||||
|
||||
private List<ColDTO> col;
|
||||
|
||||
private List<CarPageResponse> data;
|
||||
|
||||
private Long totalCount = 0L;
|
||||
private Long pageNum = 1L;
|
||||
private Long pageSize = 10L;
|
||||
}
|
||||
@ -0,0 +1,110 @@
|
||||
package com.ykMap.exception;
|
||||
|
||||
import com.ykMap.base.domain.AjaxResult;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.validation.BindException;
|
||||
import org.springframework.web.HttpRequestMethodNotSupportedException;
|
||||
import org.springframework.web.bind.MethodArgumentNotValidException;
|
||||
import org.springframework.web.bind.MissingPathVariableException;
|
||||
import org.springframework.web.bind.annotation.ExceptionHandler;
|
||||
import org.springframework.web.bind.annotation.RestControllerAdvice;
|
||||
import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
|
||||
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import java.util.Objects;
|
||||
|
||||
/**
|
||||
* 全局异常处理器
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/13 17:28
|
||||
*/
|
||||
@RestControllerAdvice
|
||||
public class GlobalExceptionHandler {
|
||||
private static final Logger log = LoggerFactory.getLogger(GlobalExceptionHandler.class);
|
||||
|
||||
|
||||
/**
|
||||
* 请求方式不支持
|
||||
*/
|
||||
@ExceptionHandler(HttpRequestMethodNotSupportedException.class)
|
||||
public AjaxResult handleHttpRequestMethodNotSupported(HttpRequestMethodNotSupportedException e,
|
||||
HttpServletRequest request) {
|
||||
String requestURI = request.getRequestURI();
|
||||
log.error("请求地址'{}',不支持'{}'请求", requestURI, e.getMethod());
|
||||
return AjaxResult.error(e.getMessage());
|
||||
}
|
||||
|
||||
/**
|
||||
* 业务异常
|
||||
*/
|
||||
@ExceptionHandler(ServiceException.class)
|
||||
public AjaxResult handleServiceException(ServiceException e) {
|
||||
log.error(e.getMessage(), e);
|
||||
Integer code = e.getCode();
|
||||
return code != null ? AjaxResult.error(code, e.getMessage()) : AjaxResult.error(e.getMessage());
|
||||
}
|
||||
|
||||
/**
|
||||
* 请求路径中缺少必需的路径变量
|
||||
*/
|
||||
@ExceptionHandler(MissingPathVariableException.class)
|
||||
public AjaxResult handleMissingPathVariableException(MissingPathVariableException e, HttpServletRequest request) {
|
||||
String requestURI = request.getRequestURI();
|
||||
log.error("请求路径中缺少必需的路径变量'{}',发生系统异常.", requestURI, e);
|
||||
return AjaxResult.error(String.format("请求路径中缺少必需的路径变量[%s]", e.getVariableName()));
|
||||
}
|
||||
|
||||
/**
|
||||
* 请求参数类型不匹配
|
||||
*/
|
||||
@ExceptionHandler(MethodArgumentTypeMismatchException.class)
|
||||
public AjaxResult handleMethodArgumentTypeMismatchException(MethodArgumentTypeMismatchException e, HttpServletRequest request) {
|
||||
String requestURI = request.getRequestURI();
|
||||
log.error("请求参数类型不匹配'{}',发生系统异常.", requestURI, e);
|
||||
return AjaxResult.error(String.format("请求参数类型不匹配，参数[%s]要求类型为：'%s'，但输入值为：'%s'",
|
||||
e.getName(), Objects.requireNonNull(e.getRequiredType()).getName(), e.getValue()));
|
||||
}
|
||||
|
||||
/**
|
||||
* 拦截未知的运行时异常
|
||||
*/
|
||||
@ExceptionHandler(RuntimeException.class)
|
||||
public AjaxResult handleRuntimeException(RuntimeException e, HttpServletRequest request) {
|
||||
String requestURI = request.getRequestURI();
|
||||
log.error("请求地址'{}',发生未知异常.", requestURI, e);
|
||||
return AjaxResult.error(e.getMessage());
|
||||
}
|
||||
|
||||
/**
|
||||
* 系统异常
|
||||
*/
|
||||
@ExceptionHandler(Exception.class)
|
||||
public AjaxResult handleException(Exception e, HttpServletRequest request) {
|
||||
String requestURI = request.getRequestURI();
|
||||
log.error("请求地址'{}',发生系统异常.", requestURI, e);
|
||||
return AjaxResult.error(e.getMessage());
|
||||
}
|
||||
|
||||
/**
|
||||
* 自定义验证异常
|
||||
*/
|
||||
@ExceptionHandler(BindException.class)
|
||||
public AjaxResult handleBindException(BindException e) {
|
||||
log.error(e.getMessage(), e);
|
||||
String message = e.getAllErrors().get(0).getDefaultMessage();
|
||||
return AjaxResult.error(message);
|
||||
}
|
||||
|
||||
/**
|
||||
* 自定义验证异常
|
||||
*/
|
||||
@ExceptionHandler(MethodArgumentNotValidException.class)
|
||||
public Object handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
|
||||
log.error(e.getMessage(), e);
|
||||
String message = Objects.requireNonNull(e.getBindingResult().getFieldError()).getDefaultMessage();
|
||||
return AjaxResult.error(message);
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,21 @@
|
||||
package com.ykMap.service;
|
||||
|
||||
import com.ykMap.entity.request.CarPageRequest;
|
||||
import com.ykMap.entity.response.ContentResponse;
|
||||
|
||||
/**
|
||||
* 车辆实时定位业务层
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/13 17:28
|
||||
*/
|
||||
public interface CarService {
|
||||
|
||||
/**
|
||||
* 分页查询单位内外的车辆任务
|
||||
*
|
||||
* @param req 请求类
|
||||
* @return 响应类
|
||||
*/
|
||||
ContentResponse page(CarPageRequest req);
|
||||
}
|
||||
@ -0,0 +1,155 @@
|
||||
package com.ykMap.service.impl;
|
||||
|
||||
import cn.hutool.core.collection.CollectionUtil;
|
||||
import cn.hutool.core.util.NumberUtil;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import cn.hutool.http.HttpRequest;
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import com.alibaba.fastjson2.JSONObject;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.ykMap.entity.ColDTO;
|
||||
import com.ykMap.entity.request.CarPageRequest;
|
||||
import com.ykMap.entity.response.CarGPSResponse;
|
||||
import com.ykMap.entity.response.CarPageResponse;
|
||||
import com.ykMap.entity.response.ContentResponse;
|
||||
import com.ykMap.exception.ServiceException;
|
||||
import com.ykMap.service.CarService;
|
||||
import com.ykMap.service.TaskMissionService;
|
||||
import com.ykMap.utils.SpaceUtils;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.gavaghan.geodesy.GlobalCoordinates;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
/**
|
||||
* 车辆实时定位实现层
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/13 17:28
|
||||
*/
|
||||
@Service("CarService")
|
||||
@Slf4j
|
||||
public class CarServiceImpl implements CarService {
|
||||
|
||||
@Resource
|
||||
private TaskMissionService taskMissionService;
|
||||
|
||||
|
||||
/**
|
||||
* 分页查询单位内外的车辆任务
|
||||
*
|
||||
* @param req 请求类
|
||||
* @return 响应类
|
||||
*/
|
||||
@Override
|
||||
public ContentResponse page(CarPageRequest req) {
|
||||
// 查询sessionId
|
||||
String sessionId = findSessionId();
|
||||
// 获取车辆实时定位
|
||||
List<CarGPSResponse> carGPSList = findCarGPS(sessionId);
|
||||
GlobalCoordinates companyLocation = new GlobalCoordinates(31.226963,120.634355);
|
||||
// 过滤后的车辆
|
||||
List<CarGPSResponse> list = new ArrayList<>();
|
||||
if (CollectionUtil.isEmpty(carGPSList)) {
|
||||
return null;
|
||||
}
|
||||
for (CarGPSResponse res : carGPSList) {
|
||||
GlobalCoordinates carLocation = new GlobalCoordinates(Double.parseDouble(res.getLat()), Double.parseDouble(res.getLng()));
|
||||
double distanceMeter = SpaceUtils.getDistanceMeter(companyLocation, carLocation);
|
||||
if (req.getType() == 1) {
|
||||
if (NumberUtil.compare(req.getDistance(), distanceMeter) != 1) {
|
||||
// 单位外
|
||||
list.add(res);
|
||||
}
|
||||
} else {
|
||||
if (NumberUtil.compare(req.getDistance(), distanceMeter) == 1) {
|
||||
// 单位内
|
||||
list.add(res);
|
||||
}
|
||||
}
|
||||
}
|
||||
if (CollectionUtil.isEmpty(list)) {
|
||||
return null;
|
||||
}
|
||||
List<String> plateNums = list.stream().map(CarGPSResponse::getCarPlate).collect(Collectors.toList());
|
||||
Page<CarPageResponse> page = new Page<>();
|
||||
page.setCurrent(req.getPageNo());
|
||||
page.setSize(req.getPageSize());
|
||||
Page<CarPageResponse> carPageResponsePage = taskMissionService.pageByPlateNums(page, plateNums);
|
||||
ContentResponse contentResponse = new ContentResponse();
|
||||
contentResponse.setTotalCount(carPageResponsePage.getTotal());
|
||||
contentResponse.setPageNum(carPageResponsePage.getCurrent());
|
||||
contentResponse.setPageSize(carPageResponsePage.getSize());
|
||||
ArrayList<ColDTO> colDTOS = new ArrayList<>();
|
||||
ColDTO colDTO = new ColDTO();
|
||||
colDTO.setValue("carNumber");
|
||||
colDTO.setLabel("车辆号码");
|
||||
ColDTO colDTO2 = new ColDTO();
|
||||
colDTO2.setValue("Title");
|
||||
colDTO2.setLabel("任务名称");
|
||||
colDTOS.add(colDTO);
|
||||
colDTOS.add(colDTO2);
|
||||
contentResponse.setCol(colDTOS);
|
||||
contentResponse.setData(carPageResponsePage.getRecords());
|
||||
return contentResponse;
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取sessionId
|
||||
*
|
||||
* @return sessionId
|
||||
*/
|
||||
private String findSessionId() {
|
||||
String body = HttpRequest.get("http://192.168.0.91/gps-web/api/login.jsp")
|
||||
.form("userId", 99999)
|
||||
.form("password", "6d0fd76ab81325588d8065ec1036fdd3")
|
||||
.form("loginType", "user")
|
||||
.execute().body();
|
||||
JSONObject json;
|
||||
log.info("================获取sessionId数据=================");
|
||||
log.info(body);
|
||||
try {
|
||||
json = JSONObject.parse(body);
|
||||
} catch (Exception e) {
|
||||
log.error(e.getMessage());
|
||||
throw new ServiceException("未获取到sessionId");
|
||||
}
|
||||
return json.get("sessionId").toString();
|
||||
}
|
||||
|
||||
/**
|
||||
* 获取车辆实时定位
|
||||
*
|
||||
* @return 车辆实时数据
|
||||
*/
|
||||
private List<CarGPSResponse> findCarGPS(String sessionId) {
|
||||
String body = HttpRequest.get("http://192.168.0.91/gps-web/api/get_gps_r.jsp")
|
||||
.form("teamId", 2)
|
||||
.form("sessionId", sessionId)
|
||||
.execute().body();
|
||||
JSONObject json;
|
||||
log.info("================获取车辆实时定位数据=================");
|
||||
log.info(body);
|
||||
try {
|
||||
json = JSONObject.parse(body);
|
||||
} catch (Exception e) {
|
||||
log.error(e.getMessage());
|
||||
throw new ServiceException("获取车辆实时定位失败");
|
||||
}
|
||||
List<CarGPSResponse> list = Collections.emptyList();
|
||||
Object listStr = json.get("list");
|
||||
String recordsStr = JSONUtil.toJsonStr(listStr);
|
||||
if (StrUtil.isNotEmpty(recordsStr)) {
|
||||
// 获取所有车辆经纬度
|
||||
list = JSONUtil.toList(recordsStr, CarGPSResponse.class);
|
||||
|
||||
}
|
||||
return list;
|
||||
}
|
||||
|
||||
}
|
||||
@ -0,0 +1,30 @@
|
||||
package com.ykMap.utils;
|
||||
|
||||
import org.gavaghan.geodesy.Ellipsoid;
|
||||
import org.gavaghan.geodesy.GeodeticCalculator;
|
||||
import org.gavaghan.geodesy.GeodeticCurve;
|
||||
import org.gavaghan.geodesy.GlobalCoordinates;
|
||||
|
||||
/**
|
||||
* 空间坐标计算工具类
|
||||
*
|
||||
* @author wu
|
||||
* @since 2025/3/14 15:12
|
||||
*/
|
||||
public class SpaceUtils {
|
||||
|
||||
/**
|
||||
* 根据两个经纬度计算距离(米)
|
||||
*
|
||||
* @param point1 经纬度1
|
||||
* @param point2 经纬度2
|
||||
* @return 距离(米)
|
||||
*/
|
||||
public static double getDistanceMeter(GlobalCoordinates point1, GlobalCoordinates point2) {
|
||||
GeodeticCalculator calc = new GeodeticCalculator();
|
||||
Ellipsoid ellipsoid = Ellipsoid.WGS84; // 使用 WGS84 椭球模型
|
||||
GeodeticCurve geoCurve = calc.calculateGeodeticCurve(ellipsoid, point1, point2);
|
||||
return geoCurve.getEllipsoidalDistance();
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in new issue