package Mqttmessage.Util;
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.DeserializationFeature;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import Mqttmessage.Entity.GPSData;
|
import Mqttmessage.Entity.ResponseData;
|
|
/**
|
* 设备消息解析工具类 - 支持GPS数据、状态数据和响应数据的解析
|
*/
|
public class DeviceMessageParser {
|
|
private static final ObjectMapper objectMapper = new ObjectMapper();
|
|
static {
|
// 配置ObjectMapper
|
objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
|
}
|
|
|
/**
|
* 解析为GPS数据对象（支持新协议格式，包含GPS、IMU和状态数据）
|
* @param jsonStr JSON字符串
|
* @return GPSData对象
|
* @throws JsonProcessingException 解析异常
|
*/
|
public static GPSData parseGPSData(String jsonStr) throws JsonProcessingException {
|
GPSData gpsData = objectMapper.readValue(jsonStr, GPSData.class);
|
|
// 可选：解析GGA数据
|
/* if (gpsData.getGps_raw() != null && gpsData.getGps_raw().startsWith("$GNGGA")) {
|
GPSData.GGAData ggaData = parseGGA(gpsData.getGps_raw());
|
gpsData.setGgaData(ggaData);
|
}*/
|
|
return gpsData;
|
}
|
|
|
|
/**
|
* 解析为响应数据对象
|
* @param jsonStr JSON字符串
|
* @return ResponseData对象
|
* @throws JsonProcessingException 解析异常
|
*/
|
public static ResponseData parseResponseData(String jsonStr) throws JsonProcessingException {
|
return objectMapper.readValue(jsonStr, ResponseData.class);
|
}
|
|
/**
|
* 解析GGA格式的GPS数据（可选功能）
|
* @param ggaString GGA格式字符串
|
* @return GGAData对象
|
*/
|
/*public static GPSData.GGAData parseGGA(String ggaString) {
|
// 移除可能的校验和部分
|
String cleanString = ggaString.split("\\*")[0];
|
String[] fields = cleanString.split(",");
|
|
if (fields.length < 15) {
|
return null;
|
}
|
|
GPSData.GGAData ggaData = new GPSData.GGAData();
|
|
try {
|
ggaData.setUtcTime(fields[1]);
|
ggaData.setLatitude(fields[2]);
|
ggaData.setLatitudeDir(fields[3]);
|
ggaData.setLongitude(fields[4]);
|
ggaData.setLongitudeDir(fields[5]);
|
|
if (!fields[6].isEmpty()) {
|
ggaData.setGpsQuality(Integer.parseInt(fields[6]));
|
}
|
|
if (!fields[7].isEmpty()) {
|
ggaData.setSatellites(Integer.parseInt(fields[7]));
|
}
|
|
if (!fields[8].isEmpty()) {
|
ggaData.setHdop(Double.parseDouble(fields[8]));
|
}
|
|
if (!fields[9].isEmpty()) {
|
ggaData.setAltitude(Double.parseDouble(fields[9]));
|
}
|
|
ggaData.setAltitudeUnit(fields[10]);
|
|
if (!fields[11].isEmpty()) {
|
ggaData.setGeoidSep(Double.parseDouble(fields[11]));
|
}
|
|
ggaData.setGeoidSepUnit(fields[12]);
|
|
if (fields.length > 13) {
|
ggaData.setAge(fields[13]);
|
}
|
|
if (fields.length > 14) {
|
ggaData.setStationId(fields[14]);
|
}
|
|
} catch (Exception e) {
|
// 解析异常，返回部分解析的数据或null
|
System.err.println("解析GGA数据时出错: " + e.getMessage());
|
}
|
|
return ggaData;
|
}*/
|
|
/**
|
* 将消息对象转换为JSON字符串
|
* @param message 消息对象（GPSData、StatusData或ResponseData）
|
* @return JSON字符串
|
* @throws JsonProcessingException 转换异常
|
*/
|
public static String toJson(Object message) throws JsonProcessingException {
|
return objectMapper.writeValueAsString(message);
|
}
|
|
/**
|
* 获取ObjectMapper实例（用于高级操作）
|
* @return ObjectMapper实例
|
*/
|
public static ObjectMapper getObjectMapper() {
|
return objectMapper;
|
}
|
|
/**
|
* 消息类型枚举
|
*/
|
public enum MessageType {
|
GPS("gps"),
|
STATUS("status"),
|
RESPONSE("response");
|
|
private final String type;
|
|
MessageType(String type) {
|
this.type = type;
|
}
|
|
public String getType() {
|
return type;
|
}
|
|
public static MessageType fromString(String type) {
|
for (MessageType mt : MessageType.values()) {
|
if (mt.type.equalsIgnoreCase(type)) {
|
return mt;
|
}
|
}
|
throw new IllegalArgumentException("未知的消息类型: " + type);
|
}
|
}
|
}
|
