大屏墒情设备实时数据接口

fastbee-open-api/src/main/java/com/fastbee/data/controller/deviceData/DeviceRealtimedataMeteorologyController.java

@@ -13,6 +13,11 @@ public class DeviceRealtimedataMeteorologyController {
 
     @Autowired
     private DeviceRealtimedataMeteorologyServiceImpl deviceRealtimedataMeteorologyService;
+
+    /**
+     * 获取最新的一条气象数据
+     * @return
+     */
         @GetMapping(value = "/weather/realtimedata")
     public AjaxResult getLatestWeatherRealtimedata() {
         return AjaxResult.success(deviceRealtimedataMeteorologyService.getLatestWeatherRealtimedata());

fastbee-open-api/src/main/java/com/fastbee/data/controller/deviceData/DeviceRealtimedataMoistureController.java

@@ -0,0 +1,24 @@
+package com.fastbee.data.controller.deviceData;
+
+import com.fastbee.common.core.domain.AjaxResult;
+import com.fastbee.deviceData.service.impl.DeviceRealtimedataMoistureServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController()
+@RequestMapping("/moisture")
+public class DeviceRealtimedataMoistureController {
+    @Autowired
+    private DeviceRealtimedataMoistureServiceImpl deviceRealtimedataMoistureServiceImpl;
+
+    /**
+     * 获取最新一条墒情数据
+     * @return
+     */
+    @GetMapping("/weather/realtimedata")
+    public AjaxResult getLatestWeatherRealtimedata() {
+        return AjaxResult.success(deviceRealtimedataMoistureServiceImpl.getLatestWeatherRealtimedata());
+    }
+}

fastbee-service/fastbee-device-service/src/main/java/com/fastbee/deviceData/domain/DeviceRealtimedataMoisture.java

@@ -23,9 +23,8 @@ import com.fastbee.common.core.domain.BaseEntity;
 @Builder
 @AllArgsConstructor
 @NoArgsConstructor
-@EqualsAndHashCode(callSuper = true)
 @TableName("iot_device_realtimedata_moisture")
-public class DeviceRealtimedataMoisture extends BaseEntity
+public class DeviceRealtimedataMoisture
         {
 private static final long serialVersionUID = 1L;
 

fastbee-service/fastbee-device-service/src/main/java/com/fastbee/deviceData/service/IDeviceRealtimedataMoistureService.java

@@ -58,4 +58,10 @@ public interface IDeviceRealtimedataMoistureService
      * @return 结果
      */
     public int deleteDeviceRealtimedataMoistureById(Long id);
+
+    /**
+     * 获取最新一条墒情数据
+     * @return
+     */
+    public DeviceRealtimedataMoisture getLatestWeatherRealtimedata();
 }

fastbee-service/fastbee-device-service/src/main/java/com/fastbee/deviceData/service/impl/DeviceRealtimedataMoistureServiceImpl.java

@@ -1,6 +1,8 @@
 package com.fastbee.deviceData.service.impl;
 
 import java.util.List;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.fastbee.deviceData.mapper.DeviceRealtimedataMoistureMapper;
@@ -90,4 +92,14 @@ public class DeviceRealtimedataMoistureServiceImpl implements IDeviceRealtimedat
     {
         return deviceRealtimedataMoistureMapper.deleteDeviceRealtimedataMoistureById(id);
     }
+    /**
+     * 获取最新一条墒情数据
+     * @return
+     */
+    public DeviceRealtimedataMoisture getLatestWeatherRealtimedata(){
+        QueryWrapper queryWrapper = new QueryWrapper();
+        queryWrapper.orderByDesc("real_time");
+        queryWrapper.last("limit 1");
+        return deviceRealtimedataMoistureMapper.selectOne(queryWrapper);
+    }
 }