diff --git a/src/main/java/org/springnewfiber/dataadapter/xf/controller/MonitorDataController.java b/src/main/java/org/springnewfiber/dataadapter/xf/controller/MonitorDataController.java index a7febf4..c3a3e2f 100644 --- a/src/main/java/org/springnewfiber/dataadapter/xf/controller/MonitorDataController.java +++ b/src/main/java/org/springnewfiber/dataadapter/xf/controller/MonitorDataController.java @@ -306,6 +306,12 @@ } else if(xfDataEnum == XfDataEnum.WhjkSzqData){ WhjkSzqDto szqDto = JSONObject.parseObject(data, WhjkSzqDto.class); model = RealTimeSerializer.xfObjectToRealMap(WhjkSzqDto.dataToDto(szqDto)); + }else if(xfDataEnum == XfDataEnum.InwamntData){ + WrInwamntRDataDto surgeTankData = JSONObject.parseObject(data, WrInwamntRDataDto.class); + model = RealTimeSerializer.xfObjectToRealMap(WrInwamntRData.dtoToDto(surgeTankData)); + }else if(xfDataEnum == XfDataEnum.OutwamntData){ + WrOutwamntRDataDto surgeTankData = JSONObject.parseObject(data, WrOutwamntRDataDto.class); + model = RealTimeSerializer.xfObjectToRealMap(WrOutwamntRData.dtoToDto(surgeTankData)); }else { throw new RuntimeException("暂未开发"); }