新增 获取病害设备上报数据接口

src/main/java/com/yunfeiyun/agmp/iotm/web/controller/IotScreenController.java

@@ -10,6 +10,7 @@ import com.yunfeiyun.agmp.common.exception.BizException;
 import com.yunfeiyun.agmp.common.service.LocationService;
 import com.yunfeiyun.agmp.common.service.WeatherService;
 import com.yunfeiyun.agmp.common.service.modal.LocationAddressModel;
+import com.yunfeiyun.agmp.iot.common.domain.reqvo.IotYbqdataReqVo;
 import com.yunfeiyun.agmp.iotm.device.monitor.domin.IotMonitorAddressGetReqVo;
 import com.yunfeiyun.agmp.iotm.web.domain.reqvo.IotDeviceListReqVo;
 import com.yunfeiyun.agmp.iotm.web.domain.reqvo.IotHomeDeviceListReqVo;
@@ -175,4 +176,14 @@ public class IotScreenController extends BaseController {
         return success(iIotScreenService.ybqList(reqVo));
     }
 
+    /**
+     * 获取病害设备数据接口
+     * @param
+     * @return
+     */
+    @GetMapping("/device/ybq/env/info")
+    public AjaxResult ybqEnvInfo(IotYbqdataReqVo reqVo) {
+        return success(iIotScreenService.ybqEnvInfo(reqVo));
+    }
+
 }

src/main/java/com/yunfeiyun/agmp/iotm/web/service/IIotScreenService.java

@@ -1,6 +1,8 @@
 package com.yunfeiyun.agmp.iotm.web.service;
 
 import com.yunfeiyun.agmp.iot.common.domain.IotDevicelasteddata;
+import com.yunfeiyun.agmp.iot.common.domain.IotYbqEnvData;
+import com.yunfeiyun.agmp.iot.common.domain.reqvo.IotYbqdataReqVo;
 import com.yunfeiyun.agmp.iotm.device.monitor.domin.IotMonitorAddressGetReqVo;
 import com.yunfeiyun.agmp.iotm.web.domain.reqvo.IotDeviceListReqVo;
 import com.yunfeiyun.agmp.iotm.web.domain.reqvo.IotHomeDeviceListReqVo;
@@ -38,4 +40,6 @@ public interface IIotScreenService {
     public List<IotCbdRecogChartResVo> cbdRecogChartStat(IotScreenStatReqVo reqVo);
 
     public List<IotDeviceListResVo> ybqList(IotDeviceListReqVo reqVo);
+
+    public IotYbqEnvData ybqEnvInfo(IotYbqdataReqVo reqVo);
 }

src/main/java/com/yunfeiyun/agmp/iotm/web/service/impl/IotScreenServiceImpl.java

@@ -1,10 +1,13 @@
 package com.yunfeiyun.agmp.iotm.web.service.impl;
 
+import cn.hutool.core.bean.BeanUtil;
 import com.yunfeiyun.agmp.common.constant.ErrorCode;
 import com.yunfeiyun.agmp.common.utils.DateUtils;
 import com.yunfeiyun.agmp.common.utils.SecurityUtils;
 import com.yunfeiyun.agmp.common.utils.StringUtils;
+import com.yunfeiyun.agmp.iot.common.constant.IotErrorCode;
 import com.yunfeiyun.agmp.iot.common.domain.*;
+import com.yunfeiyun.agmp.iot.common.domain.reqvo.IotYbqdataReqVo;
 import com.yunfeiyun.agmp.iot.common.enums.EnumCbdMarkType;
 import com.yunfeiyun.agmp.iot.common.exception.IotBizException;
 import com.yunfeiyun.agmp.iot.common.service.MongoService;
@@ -351,4 +354,18 @@ public class IotScreenServiceImpl implements IIotScreenService {
         return devList;
     }
 
+    @Override
+    public IotYbqEnvData ybqEnvInfo(IotYbqdataReqVo reqVo) {
+        String devBid = reqVo.getDevBid();
+        if (StringUtils.isEmpty(devBid)) {
+            throw new IotBizException(IotErrorCode.FAILURE.getCode(), "设备id不可为空");
+        }
+        String ybqType = reqVo.getDateDevType();
+        if (StringUtils.isEmpty(ybqType)) {
+            throw new IotBizException(IotErrorCode.FAILURE.getCode(), "数据类型不可为空");
+        }
+        Map<String, Object> map = BeanUtil.beanToMap(reqVo);
+        return (IotYbqEnvData) mongoService.findOne(IotYbqEnvData.class, map, "ybqdataCreatedDate", "desc");
+    }
+
 }