package com.ruoyi.jt.service.impl;
|
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDateTime;
|
import java.time.ZoneId;
|
import java.time.format.DateTimeFormatter;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.ruoyi.jt.common.DateUtils;
|
import com.ruoyi.jt.domain.JtDevice;
|
import com.ruoyi.jt.mapper.JtDeviceMapper;
|
import com.ruoyi.jt.uuid.IdUtils;
|
import io.github.yezhihao.netmc.session.Session;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.jt.mapper.JtDeviceLocationMapper;
|
import com.ruoyi.jt.domain.JtDeviceLocation;
|
import com.ruoyi.jt.service.IJtDeviceLocationService;
|
import org.yzh.protocol.commons.transform.AttributeKey;
|
import org.yzh.protocol.t808.T0200;
|
import org.yzh.web.model.entity.DeviceDO;
|
import org.yzh.web.model.enums.SessionKey;
|
|
/**
|
* 设备位置Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2025-06-26
|
*/
|
@Service
|
public class JtDeviceLocationServiceImpl implements IJtDeviceLocationService {
|
private static DateTimeFormatter dataFormater = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
@Autowired
|
private JtDeviceLocationMapper jtDeviceLocationMapper;
|
@Autowired
|
private JtDeviceMapper jtDeviceMapper;
|
|
|
/**
|
* 查询设备位置
|
*
|
* @param id 设备位置主键
|
* @return 设备位置
|
*/
|
@Override
|
public JtDeviceLocation selectJtDeviceLocationById(String id) {
|
return jtDeviceLocationMapper.selectJtDeviceLocationById(id);
|
}
|
|
/**
|
* 查询设备位置列表
|
*
|
* @param jtDeviceLocation 设备位置
|
* @return 设备位置
|
*/
|
@Override
|
public List<JtDeviceLocation> selectJtDeviceLocationList(JtDeviceLocation jtDeviceLocation) {
|
return jtDeviceLocationMapper.selectJtDeviceLocationList(jtDeviceLocation);
|
}
|
|
/**
|
* 新增设备位置
|
*
|
* @param jtDeviceLocation 设备位置
|
* @return 结果
|
*/
|
@Override
|
public int insertJtDeviceLocation(JtDeviceLocation jtDeviceLocation) {
|
jtDeviceLocation.setId(IdUtils.simpleUUID());
|
jtDeviceLocation.setCreateTime(DateUtils.getNowDate());
|
return jtDeviceLocationMapper.insertJtDeviceLocation(jtDeviceLocation);
|
}
|
|
/**
|
* 修改设备位置
|
*
|
* @param jtDeviceLocation 设备位置
|
* @return 结果
|
*/
|
@Override
|
public int updateJtDeviceLocation(JtDeviceLocation jtDeviceLocation) {
|
return jtDeviceLocationMapper.updateJtDeviceLocation(jtDeviceLocation);
|
}
|
|
/**
|
* 批量删除设备位置
|
*
|
* @param ids 需要删除的设备位置主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteJtDeviceLocationByIds(String[] ids) {
|
return jtDeviceLocationMapper.deleteJtDeviceLocationByIds(ids);
|
}
|
|
/**
|
* 删除设备位置信息
|
*
|
* @param id 设备位置主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteJtDeviceLocationById(String id) {
|
return jtDeviceLocationMapper.deleteJtDeviceLocationById(id);
|
}
|
|
@Override
|
public int saveT0200s(List<T0200> list, boolean isUpdateDevicePosition) {
|
T0200 latestT0200 = null;
|
for (T0200 t0200 : list) {
|
if (t0200.getWarnBit() != 0) {
|
//TODO 处理报警
|
System.out.println("!!!T0200报警:" + t0200);
|
|
}
|
|
this.saveJtDeviceLocation(t0200);
|
//获得最新的设备时间
|
if (latestT0200 == null || t0200.getDeviceTime().isAfter(latestT0200.getDeviceTime())) {
|
latestT0200 = t0200;
|
}
|
// }
|
}
|
if (isUpdateDevicePosition && latestT0200 != null) {
|
|
this.updateLatestDeviceLocation(latestT0200);
|
}
|
return 0;
|
}
|
|
private void updateLatestDeviceLocation(T0200 t0200) {
|
//按clientId 获取设备
|
JtDevice jtDevice = jtDeviceMapper.selectJtDeviceByClientId(t0200.getClientId());
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
//如果设备时间大于更新时间,则更新位置和更新时间
|
if (jtDevice != null) {
|
LocalDateTime jtDeviceLocalDateTime = null;
|
// Date 转 LocalDateTime
|
if (jtDevice.getUpdateTime() != null) {
|
jtDeviceLocalDateTime = jtDevice.getUpdateTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
|
}
|
if (jtDeviceLocalDateTime == null || t0200.getDeviceTime().isAfter(jtDeviceLocalDateTime)) {
|
jtDevice.setLongitude(t0200.getLng() + "");
|
jtDevice.setLatitude(t0200.getLat() + "");
|
jtDevice.setAltitude(t0200.getAltitude() + "");
|
jtDevice.setSpeed(Double.valueOf(t0200.getSpeed())/10+"");
|
jtDevice.setDirection(t0200.getDirection() + "");
|
jtDevice.setUpdateTime(Date.from(t0200.getDeviceTime().atZone(ZoneId.systemDefault()).toInstant()));
|
|
//处理附加信息
|
Map<Integer, Object> attributes = t0200.getAttributes();
|
|
if (attributes!=null) {
|
System.out.println("!!!!附加信息!!!! = " + attributes);
|
Object mileage = attributes.get(AttributeKey.Mileage);
|
if (mileage != null) {
|
double mileageInt = Double.parseDouble(mileage.toString()) / 10;
|
jtDevice.setMileage(mileageInt + "");
|
}
|
jtDevice.setFuel(attributes.get(AttributeKey.Fuel) + "");
|
jtDevice.setTirePressure(attributes.get(AttributeKey.TirePressure) + "");
|
jtDevice.setCarriageTemperature(attributes.get(AttributeKey.CarriageTemperature) + "");
|
jtDevice.setExtendSignalStatus(attributes.get(AttributeKey.Signal)+"");
|
jtDevice.setSignalStrength(attributes.get(AttributeKey.SignalStrength)+"");
|
jtDevice.setGnssCount(attributes.get(AttributeKey.GnssCount)+"");
|
}
|
|
|
jtDeviceMapper.updateJtDevice(jtDevice);
|
}
|
|
}
|
|
}
|
|
public int saveJtDeviceLocation(T0200 t0200) {
|
Session session = t0200.getSession();
|
if (session != null) {
|
JtDeviceLocation location = new JtDeviceLocation();
|
location.setId(IdUtils.simpleUUID());
|
location.setAltitude(t0200.getAltitude() + "");
|
location.setLatitude(t0200.getLat() + "");
|
location.setLongitude(t0200.getLng() + "");
|
location.setClientId(t0200.getClientId());
|
location.setCreateTime(DateUtils.getNowDate());
|
location.setDeviceTime(t0200.getDeviceTime().format(dataFormater));
|
location.setDirection(t0200.getDirection() + "");
|
location.setSpeed(t0200.getSpeed() * 0.1 + "");
|
location.setProtocolVersion(t0200.getProtocolVersion() + "");
|
location.setStatusBit(t0200.getStatusBit() + "");
|
location.setWarnBit(t0200.getWarnBit() + "");
|
|
//处理附加信息
|
Map<Integer, Object> attributes = t0200.getAttributes();
|
|
if (attributes!=null) {
|
System.out.println(">>>>>>>附加信息:" + attributes);
|
Object mileage = attributes.get(AttributeKey.Mileage);
|
if (mileage != null) {
|
double mileageInt = Double.parseDouble(mileage.toString()) / 10;
|
location.setMileage(mileageInt + "");
|
}
|
location.setFuel(attributes.get(AttributeKey.Fuel) + "");
|
location.setTirePressure(attributes.get(AttributeKey.TirePressure) + "");
|
location.setCarriageTemperature(attributes.get(AttributeKey.CarriageTemperature) + "");
|
location.setExtendSignalStatus(attributes.get(AttributeKey.Signal)+"");
|
location.setSignalStrength(attributes.get(AttributeKey.SignalStrength)+"");
|
location.setGnssCount(attributes.get(AttributeKey.GnssCount)+"");
|
}
|
|
|
|
DeviceDO deviceDO = session.getAttribute(SessionKey.Device);
|
if (deviceDO != null) {
|
location.setPlateNo(deviceDO.getPlateNo());
|
;
|
}
|
return jtDeviceLocationMapper.insertJtDeviceLocation(location);
|
}
|
return 0;
|
}
|
|
|
}
|
