package com.ruoyi.quartz.task;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.ruoyi.system.domain.GpsLastPosition;
|
import com.ruoyi.system.domain.GpsLastPositionRequest;
|
import com.ruoyi.system.domain.GpsLastPositionResponse;
|
import com.ruoyi.system.domain.VehicleGps;
|
import com.ruoyi.system.domain.VehicleInfo;
|
import com.ruoyi.system.service.IGpsCollectService;
|
import com.ruoyi.system.service.IVehicleGpsService;
|
import com.ruoyi.system.service.IVehicleInfoService;
|
|
/**
|
* GPS同步定时任务
|
*/
|
@Component("gpsSyncTask")
|
public class GpsSyncTask {
|
|
private static final Logger log = LoggerFactory.getLogger(GpsSyncTask.class);
|
|
@Autowired
|
private IGpsCollectService gpsCollectService;
|
|
@Autowired
|
private IVehicleInfoService vehicleInfoService;
|
|
@Autowired
|
private IVehicleGpsService vehicleGpsService;
|
|
/**
|
* 同步GPS位置
|
*/
|
public void syncGpsData() {
|
try {
|
// log.info("开始同步GPS数据...");
|
|
// 1. 获取所有车辆信息
|
List<VehicleInfo> vehicleList = vehicleInfoService.selectVehicleInfoList(new VehicleInfo());
|
|
List<String> deviceIds = vehicleList.stream().map(VehicleInfo::getDeviceId).collect(Collectors.toList());
|
// 2. 获取所有车辆的GPS最后位置
|
GpsLastPositionRequest request = new GpsLastPositionRequest();
|
// request.setDeviceids(deviceIds);
|
GpsLastPositionResponse gpsLastPositionResponse = gpsCollectService.getLastPosition(request);
|
|
// 3. 遍历车辆列表，获取每个车辆的GPS位置
|
for (VehicleInfo vehicle : vehicleList) {
|
if (vehicle.getDeviceId() != null && !vehicle.getDeviceId().isEmpty()) {
|
try {
|
// 获取车辆的最后位置
|
gpsLastPositionResponse.getRecords().stream()
|
.filter(e -> e.getDeviceid().equals(vehicle.getDeviceId()))
|
.forEach(record -> {
|
updateVehicleGpsPositions(vehicle, record);
|
});
|
} catch (Exception e) {
|
log.error("获取车辆[{}]GPS位置失败: {}", vehicle.getVehicleNo(), e.getMessage());
|
}
|
}
|
}
|
|
// log.info("GPS数据同步完成");
|
} catch (Exception e) {
|
log.error("GPS数据同步失败: {}", e.getMessage());
|
}
|
}
|
|
/**
|
* 更新车辆GPS位置信息
|
*/
|
private void updateVehicleGpsPositions(VehicleInfo vehicle, GpsLastPosition position) {
|
try {
|
VehicleGps gps = new VehicleGps();
|
gps.setVehicleId(vehicle.getVehicleId());
|
gps.setDeviceId(vehicle.getDeviceId());
|
gps.setLongitude(position.getCallon());
|
gps.setLatitude(position.getCallat());
|
gps.setAltitude(position.getAltitude());
|
gps.setSpeed(position.getSpeed());
|
gps.setDirection(Double.valueOf(position.getCourse()));
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
// 处理到达时间
|
long arrivedTime = position.getArrivedtime();
|
Date arrivedDate;
|
if (arrivedTime > 0) {
|
arrivedDate = new Date(arrivedTime);
|
arrivedDate.setTime(arrivedDate.getTime() - 8 * 60 * 60 * 1000);
|
} else {
|
arrivedDate = new Date();
|
}
|
gps.setPlatformProcessTime(sdf.format(arrivedDate));
|
|
// 设备上报时间
|
long deviceTime = position.getDevicetime();
|
Date date;
|
if (deviceTime > 0) {
|
date = new Date(deviceTime);
|
date.setTime(date.getTime() - 8 * 60 * 60 * 1000);
|
} else {
|
date = arrivedDate;
|
}
|
gps.setDeviceReportTime(sdf.format(date));
|
|
// 采集时间（使用设备上报时间）
|
gps.setCollectTime(sdf.format(new Date()));
|
|
// 保存GPS位置信息
|
vehicleGpsService.insertVehicleGps(gps);
|
|
// log.info("车辆[{}]GPS位置已更新: 经度={}, 纬度={}, 设备时间={}, 处理时间={}",
|
// vehicle.getVehicleNo(), position.getCallon(), position.getCallat(),
|
// gps.getDeviceReportTime(), gps.getPlatformProcessTime());
|
} catch (Exception e) {
|
log.error("更新车辆[{}]GPS位置失败: {}", vehicle.getVehicleNo(), e.getMessage());
|
}
|
}
|
}
|
