检测设备实时数据查询

huimv-farm-environ/src/main/java/com/huimv/environ/eco/controller/EcoDeviceFlowController.java

@@ -1,10 +1,18 @@
 package com.huimv.environ.eco.controller;
 
 
+import com.huimv.common.utils.Result;
+import com.huimv.environ.eco.service.EcoDeviceFlowService;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
 /**
  * <p>
  *  前端控制器
@@ -17,5 +25,13 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/eco-device-flow")
 public class EcoDeviceFlowController {
 
+    @Resource
+    private EcoDeviceFlowService ecoDeviceFlowService;
+
+    @PostMapping("/getLastFlow")
+    public Result getLastFlow(HttpServletRequest request){
+        return ecoDeviceFlowService.getLastFlow(request);
+    }
+
 }
 

huimv-farm-environ/src/main/java/com/huimv/environ/eco/entity/dto/LastFlowDto.java

@@ -0,0 +1,11 @@
+package com.huimv.environ.eco.entity.dto;
+
+import lombok.Data;
+
+@Data
+public class LastFlowDto {
+    private String tem;
+    private String hum;
+    private String room;
+
+}

huimv-farm-environ/src/main/java/com/huimv/environ/eco/mapper/EcoDeviceFlowMapper.java

@@ -2,6 +2,11 @@ package com.huimv.environ.eco.mapper;
 
 import com.huimv.environ.eco.entity.EcoDeviceFlow;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huimv.environ.eco.entity.dto.LastFlowDto;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
 
 /**
  * <p>
@@ -11,6 +16,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  * @author zn
  * @since 2022-11-09
  */
+@Repository
 public interface EcoDeviceFlowMapper extends BaseMapper<EcoDeviceFlow> {
 
+    List<LastFlowDto> getLastFlow(@Param("farmId") String farmId);
 }

huimv-farm-environ/src/main/java/com/huimv/environ/eco/service/EcoDeviceFlowService.java

@@ -1,8 +1,12 @@
 package com.huimv.environ.eco.service;
 
+import com.huimv.common.utils.Result;
 import com.huimv.environ.eco.entity.EcoDeviceFlow;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
 /**
  * <p>
  *  服务类
@@ -13,4 +17,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface EcoDeviceFlowService extends IService<EcoDeviceFlow> {
 
+    Result getLastFlow(HttpServletRequest request);
 }

huimv-farm-environ/src/main/java/com/huimv/environ/eco/service/impl/EcoDeviceFlowServiceImpl.java

@@ -1,11 +1,20 @@
 package com.huimv.environ.eco.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huimv.common.utils.Result;
+import com.huimv.common.utils.ResultCode;
 import com.huimv.environ.eco.entity.EcoDeviceFlow;
+import com.huimv.environ.eco.entity.dto.LastFlowDto;
 import com.huimv.environ.eco.mapper.EcoDeviceFlowMapper;
+import com.huimv.environ.eco.mapper.EcoDeviceMapper;
 import com.huimv.environ.eco.service.EcoDeviceFlowService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import javax.servlet.http.HttpServletRequest;
+
+
 /**
  * <p>
  *  服务实现类
@@ -17,4 +26,12 @@ import org.springframework.stereotype.Service;
 @Service
 public class EcoDeviceFlowServiceImpl extends ServiceImpl<EcoDeviceFlowMapper, EcoDeviceFlow> implements EcoDeviceFlowService {
 
+    @Autowired
+    private EcoDeviceFlowMapper ecoDeviceFlowMapper;
+
+    @Override
+    public Result getLastFlow(HttpServletRequest request) {
+        String farmId = request.getHeader("farmId");
+        return new Result(ResultCode.SUCCESS,ecoDeviceFlowMapper.getLastFlow(farmId));
+    }
 }

huimv-farm-environ/src/main/java/com/huimv/environ/eco/mapper/xml/EcoDeviceFlowMapper.xml

@@ -24,4 +24,13 @@
         id, device_code, device_name, device_status, device_open, id1_name, id1_value, id1_alarm_status, id1_alarm_msg, id2_name, id2_value, id2_alarm_status, id2_alarm_msg
     </sql>
 
+
+    <select id="getLastFlow" resultType="com.huimv.environ.eco.entity.dto.LastFlowDto">
+       SELECT CONCAT(b.pigpen_name,a.pigpen_name) room,d.device_code,df.id1_value 'tem',df.id2_value 'hum'
+        FROM `base_pigpen` a INNER JOIN `base_pigpen` b ON a.parent_id =b.id
+        LEFT JOIN `eco_device` d ON d.unit_id = a.id
+        LEFT JOIN `eco_device_flow` df ON d.device_code = df.device_code
+        AND df.id IN (SELECT MAX(df.id) FROM `eco_device_flow` df GROUP BY device_code) AND df.farm_id=#{farmId}
+        ORDER BY a.id DESC,a.parent_id DESC
+    </select>
 </mapper>