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);
|
}
|
|
|
|
/**
|
* 将消息对象转换为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);
|
}
|
}
|
}
|
