网关 端口

huimv-env-admin/src/main/java/com/huimv/env/admin/controller/PortWarningInfoController.java

@@ -6,12 +6,22 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huimv.env.admin.common.utils.Result;
 import com.huimv.env.admin.common.utils.ResultCode;
+import com.huimv.env.admin.entity.BasePigpen;
 import com.huimv.env.admin.entity.PortWarningInfo;
+import com.huimv.env.admin.entity.Terminal;
 import com.huimv.env.admin.entity.vo.WarningPageParam;
+import com.huimv.env.admin.entity.vo.WarningTotalByLocationIdParam;
+import com.huimv.env.admin.entity.vo.WarningTotalResult;
+import com.huimv.env.admin.mapper.TerminalMapper;
+import com.huimv.env.admin.mapper.TerminalPortMapper;
+import com.huimv.env.admin.service.IBasePigpenService;
 import com.huimv.env.admin.service.IPortWarningInfoService;
+import com.huimv.env.admin.service.ITerminalService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 /**
  * <p>
  *  前端控制器
@@ -27,6 +37,10 @@ public class PortWarningInfoController {
 
     @Autowired
     private IPortWarningInfoService portWarningInfoService;
+    @Autowired
+    private ITerminalService terminalService;
+    @Autowired
+    private TerminalMapper terminalMapper;
 
     @PostMapping("/page")
     public Result page(@RequestBody WarningPageParam warningPageParam){
@@ -43,4 +57,11 @@ public class PortWarningInfoController {
         return new Result(ResultCode.SUCCESS,warningInfoPage);
     }
 
+    @PostMapping("/total")
+    public Result total(@RequestBody WarningTotalByLocationIdParam warningTotalByLocationIdParam){
+        List<Terminal> terminalList = terminalService.list(new QueryWrapper<Terminal>().lambda().eq(Terminal::getBuildId,warningTotalByLocationIdParam.getLocationId()));
+        WarningTotalResult warningTotalResult = terminalMapper.getTotal(terminalList);
+        return new Result(ResultCode.SUCCESS,warningTotalResult);
+    }
+
 }

huimv-env-admin/src/main/java/com/huimv/env/admin/entity/vo/WarningTotalByLocationIdParam.java

@@ -0,0 +1,11 @@
+package com.huimv.env.admin.entity.vo;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+
+@Data
+public class WarningTotalByLocationIdParam {
+    @NotNull(message = "locationId不能为空")
+    private Integer locationId;
+}

huimv-env-admin/src/main/java/com/huimv/env/admin/entity/vo/WarningTotalResult.java

@@ -0,0 +1,11 @@
+package com.huimv.env.admin.entity.vo;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import lombok.Data;
+
+@Data
+public class WarningTotalResult {
+    private Integer heightTempWarning;
+    private Integer chargingWarning;
+    private Integer leakageWarning;
+}

huimv-env-admin/src/main/java/com/huimv/env/admin/mapper/TerminalMapper.java

@@ -4,6 +4,9 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huimv.env.admin.entity.Terminal;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.huimv.env.admin.entity.vo.TerminalPageResult;
+import com.huimv.env.admin.entity.vo.WarningTotalResult;
+
+import java.util.List;
 
 /**
  * <p>
@@ -18,4 +21,6 @@ public interface TerminalMapper extends BaseMapper<Terminal> {
     Page<TerminalPageResult> listByLocationId(Page<TerminalPageResult> page, Integer locationId);
 
     Integer getMaxOrder(Integer gatewayId);
+
+    WarningTotalResult getTotal(List<Terminal> terminalList);
 }

huimv-env-admin/src/main/java/com/huimv/env/admin/mapper/TerminalPortMapper.java

@@ -1,7 +1,11 @@
 package com.huimv.env.admin.mapper;
 
+import com.huimv.env.admin.entity.Terminal;
 import com.huimv.env.admin.entity.TerminalPort;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huimv.env.admin.entity.vo.WarningTotalResult;
+
+import java.util.List;
 
 /**
  * <p>
@@ -13,4 +17,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface TerminalPortMapper extends BaseMapper<TerminalPort> {
 
+
 }

huimv-env-admin/src/main/resources/mapper/TerminalMapper.xml

@@ -18,4 +18,13 @@
         SELECT COALESCE(MAX(orders),0) AS 'maxOrder' FROM `terminal` WHERE gateway_id = #{gatewayId}
     </select>
 
+    <select id="getTotal" resultType="com.huimv.env.admin.entity.vo.WarningTotalResult">
+        SELECT SUM(height_temp_warning) AS 'heightTempWarning',SUM(charging_warning) AS 'chargingWarning',SUM(leakage_warning) AS 'leakageWarning'
+        FROM `terminal_port`
+        WHERE terminal_id IN
+        <foreach item="terminalList" index="index" collection="list" open="(" separator="," close=")">
+            #{terminalList}
+        </foreach>
+    </select>
+
 </mapper>