'数据中心-门禁系统统计进出设备配置保存、数据中心-门禁系统统计进出设备配置查询和数据中心-环境系统楼宇健康监测查询三个接口'

service-park/service-park-biz/src/main/java/com/usky/park/controller/web/DataEvHistoryController.java

@@ -1,9 +1,11 @@
 package com.usky.park.controller.web;
 
 
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RestController;
 
 /**
  * <p>
@@ -13,9 +15,8 @@ import org.springframework.stereotype.Controller;
  * @author zyj
  * @since 2023-04-03
  */
-@Controller
+@RestController
 @RequestMapping("/dataEvHistory")
 public class DataEvHistoryController {
-
 }
 

service-park/service-park-biz/src/main/java/com/usky/park/controller/web/DataRealTimeController.java

@@ -1,9 +1,17 @@
 package com.usky.park.controller.web;
 
 
+import com.usky.common.core.bean.ApiResult;
+import com.usky.park.domain.DataRealTime;
+import com.usky.park.service.DataRealTimeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 
 import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
 
 /**
  * <p>
@@ -13,7 +21,7 @@ import org.springframework.stereotype.Controller;
  * @author zyj
  * @since 2023-03-30
  */
-@Controller
+@RestController
 @RequestMapping("/dataRealTime")
 public class DataRealTimeController {
 

service-park/service-park-biz/src/main/java/com/usky/park/controller/web/DmpDeviceController.java

@@ -3,6 +3,8 @@ package com.usky.park.controller.web;
 
 import com.usky.common.core.bean.ApiResult;
 import com.usky.common.core.bean.CommonPage;
+import com.usky.park.domain.DataRealTime;
+import com.usky.park.service.DataRealTimeService;
 import com.usky.park.service.DmpDeviceService;
 import com.usky.park.service.vo.DmpDeviceVO;
 import com.usky.park.service.vo.HistoryAttributeVO;
@@ -16,6 +18,7 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -100,6 +103,16 @@ public class DmpDeviceController {
         return ApiResult.success(deviceService.deviceHistoryDataList(deviceId,deviceType,deviceAttribute,startDate,endDate));
     }
 
+    /**
+     * 数据中心-环境系统楼宇健康监测查询
+     *
+     * @return
+     */
+    @GetMapping("evBuildHealth")
+    public ApiResult<Map<String,Object>> evBuildHealth(){
+        return ApiResult.success(deviceService.evBuildHealth());
+    }
+
 
 }
 

service-park/service-park-biz/src/main/java/com/usky/park/controller/web/EgConfigController.java

@@ -0,0 +1,51 @@
+package com.usky.park.controller.web;
+
+
+import com.usky.common.core.bean.ApiResult;
+import com.usky.park.domain.EgConfig;
+import com.usky.park.service.EgConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import retrofit2.http.PUT;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 门禁进出统计配置设备表 前端控制器
+ * </p>
+ *
+ * @author zyj
+ * @since 2023-04-26
+ */
+@RestController
+@RequestMapping("/egConfig")
+public class EgConfigController {
+    @Autowired
+    private EgConfigService egConfigService;
+
+    /**
+     * 数据中心-门禁系统统计进出设备配置保存接口
+     *
+     * @param egConfig
+     * @return
+     */
+    @PutMapping("updateEgConfig")
+    public ApiResult<Void> updateEgConfig(@RequestBody EgConfig egConfig){
+        egConfigService.updateEgConfig(egConfig);
+        return ApiResult.success();
+    }
+
+    /**
+     * 数据中心-门禁系统统计进出设备配置查询接口
+     *
+     * @return
+     */
+    @GetMapping("getEgConfig")
+    public ApiResult<List<EgConfig>> getEgConfig(){
+        return ApiResult.success(egConfigService.getEgConfig());
+    }
+
+
+}
+

service-park/service-park-biz/src/main/java/com/usky/park/domain/EgConfig.java

@@ -0,0 +1,46 @@
+package com.usky.park.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 门禁进出统计配置设备表
+ * </p>
+ *
+ * @author zyj
+ * @since 2023-04-26
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class EgConfig implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键ID
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 进入统计设备ID汇总
+     */
+    private String inDeviceids;
+
+    /**
+     * 出去统计设备ID汇总
+     */
+    private String outDeviceids;
+
+    /**
+     * 配置时间
+     */
+    private LocalDateTime configTime;
+
+
+}

service-park/service-park-biz/src/main/java/com/usky/park/mapper/EgConfigMapper.java

@@ -0,0 +1,16 @@
+package com.usky.park.mapper;
+
+import com.usky.park.domain.EgConfig;
+import com.usky.common.mybatis.core.CrudMapper;
+
+/**
+ * <p>
+ * 门禁进出统计配置设备表 Mapper 接口
+ * </p>
+ *
+ * @author zyj
+ * @since 2023-04-26
+ */
+public interface EgConfigMapper extends CrudMapper<EgConfig> {
+
+}

service-park/service-park-biz/src/main/java/com/usky/park/service/DataRealTimeService.java

@@ -1,8 +1,11 @@
 package com.usky.park.service;
 
+import com.usky.common.core.bean.ApiResult;
 import com.usky.park.domain.DataRealTime;
 import com.usky.common.mybatis.core.CrudService;
 
+import java.util.Map;
+
 /**
  * <p>
  * 实时数据表 服务类

service-park/service-park-biz/src/main/java/com/usky/park/service/DmpDeviceService.java

@@ -7,6 +7,7 @@ import com.usky.park.service.vo.DmpDeviceVO;
 import com.usky.park.service.vo.HistoryAttributeVO;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -56,4 +57,13 @@ public interface DmpDeviceService extends CrudService<DmpDevice> {
      * @return
      */
     List<HistoryAttributeVO> deviceHistoryDataList(String deviceId, Integer deviceType, List<String> deviceAttribute, String startDate, String endDate);
+
+    /**
+     * 数据中心-环境系统楼宇健康监测查询
+     *
+     * @return
+     */
+    Map<String,Object> evBuildHealth();
+
+    float attributeStatistic(Integer deviceType,String attribute_name);
 }

service-park/service-park-biz/src/main/java/com/usky/park/service/EgConfigService.java

@@ -0,0 +1,34 @@
+package com.usky.park.service;
+
+import com.usky.park.domain.EgConfig;
+import com.usky.common.mybatis.core.CrudService;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 门禁进出统计配置设备表 服务类
+ * </p>
+ *
+ * @author zyj
+ * @since 2023-04-26
+ */
+public interface EgConfigService extends CrudService<EgConfig> {
+
+    /**
+     * 数据中心-门禁系统统计进出设备配置保存接口
+     *
+     * @param egConfig
+     * @return
+     */
+    void updateEgConfig(EgConfig egConfig);
+
+    /**
+     * 数据中心-门禁系统统计进出设备配置查询接口
+     *
+     * @return
+     */
+    List<EgConfig> getEgConfig();
+
+}

service-park/service-park-biz/src/main/java/com/usky/park/service/impl/DataRealTimeServiceImpl.java

@@ -1,11 +1,17 @@
 package com.usky.park.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.usky.park.domain.DataRealTime;
+import com.usky.park.domain.DmpDevice;
 import com.usky.park.mapper.DataRealTimeMapper;
 import com.usky.park.service.DataRealTimeService;
 import com.usky.common.mybatis.core.AbstractCrudService;
 import org.springframework.stereotype.Service;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * <p>
  * 实时数据表 服务实现类
@@ -17,4 +23,5 @@ import org.springframework.stereotype.Service;
 @Service
 public class DataRealTimeServiceImpl extends AbstractCrudService<DataRealTimeMapper, DataRealTime> implements DataRealTimeService {
 
+
 }

service-park/service-park-biz/src/main/java/com/usky/park/service/impl/DmpDeviceServiceImpl.java

@@ -250,7 +250,8 @@ public class DmpDeviceServiceImpl extends AbstractCrudService<DmpDeviceMapper, D
                     queryWrapper1.select(DataGrHistory::getAttributeData,DataGrHistory::getDataTime)
                             .eq(DataGrHistory::getDeviceId,deviceId)
                             .eq(DataGrHistory::getAttributeName,deviceAttribute.get(i))
-                            .between(DataGrHistory::getDataTime,startDate,endDate);
+                            .between(DataGrHistory::getDataTime,startDate,endDate)
+                            .orderByDesc(DataGrHistory::getId);
                     List<DataGrHistory> grList = dataGrHistoryService.list(queryWrapper1);
                     if(CollectionUtils.isNotEmpty(grList)){
                         for(int j=0;j< grList.size();j++){
@@ -276,7 +277,8 @@ public class DmpDeviceServiceImpl extends AbstractCrudService<DmpDeviceMapper, D
                     queryWrapper1.select(DataEvHistory::getAttributeData,DataEvHistory::getDataTime)
                             .eq(DataEvHistory::getDeviceId,deviceId)
                             .eq(DataEvHistory::getAttributeName,deviceAttribute.get(i))
-                            .between(DataEvHistory::getDataTime,startDate,endDate);
+                            .between(DataEvHistory::getDataTime,startDate,endDate)
+                            .orderByDesc(DataEvHistory::getId);
                     List<DataEvHistory> evList = dataEvHistoryService.list(queryWrapper1);
                     if(CollectionUtils.isNotEmpty(evList)){
                         for(int j=0;j< evList.size();j++){
@@ -301,7 +303,8 @@ public class DmpDeviceServiceImpl extends AbstractCrudService<DmpDeviceMapper, D
                     queryWrapper1.select(DataLgHistory::getAttributeData,DataLgHistory::getDataTime)
                             .eq(DataLgHistory::getDeviceId,deviceId)
                             .eq(DataLgHistory::getAttributeName,deviceAttribute.get(i))
-                            .between(DataLgHistory::getDataTime,startDate,endDate);
+                            .between(DataLgHistory::getDataTime,startDate,endDate)
+                            .orderByDesc(DataLgHistory::getId);
                     List<DataLgHistory> lgList = dataLgHistoryService.list(queryWrapper1);
                     if(CollectionUtils.isNotEmpty(lgList)){
                         for(int j=0;j< lgList.size();j++){
@@ -321,4 +324,48 @@ public class DmpDeviceServiceImpl extends AbstractCrudService<DmpDeviceMapper, D
 
     }
 
+
+    @Override
+    public Map<String,Object> evBuildHealth(){
+        Map<String,Object> map = new HashMap<>();
+        float co2 = attributeStatistic(509,"co2");
+        map.put("co2",co2);
+        float jq = attributeStatistic(509,"jq");
+        map.put("jq",jq);
+        float pm2_5 = attributeStatistic(509,"pm2.5");
+        map.put("pm2.5",pm2_5);
+        float pm1_0 = attributeStatistic(509,"pm1.0");
+        map.put("pm1.0",pm1_0);
+        float pm10 = attributeStatistic(509,"pm10");
+        map.put("pm10",pm10);
+        float tvoc = attributeStatistic(509,"tvoc");
+        map.put("tvoc",tvoc);
+        float wd = attributeStatistic(509,"wd");
+        map.put("wd",wd);
+        float sd = attributeStatistic(509,"sd");
+        map.put("sd",sd);
+
+        return map;
+    }
+
+    public float attributeStatistic(Integer deviceType,String attribute_name){
+        float f = 0;
+        int deviceCount = 0;
+        LambdaQueryWrapper<DmpDevice> queryWrapper = Wrappers.lambdaQuery();
+        queryWrapper.eq(DmpDevice::getDeviceType,deviceType);
+        deviceCount = this.count(queryWrapper);
+        LambdaQueryWrapper<DataRealTime> queryWrapper1 = Wrappers.lambdaQuery();
+        queryWrapper1.select(DataRealTime::getAttributeData)
+                .eq(DataRealTime::getDeviceType,deviceType)
+                .eq(DataRealTime::getAttributeName,attribute_name);
+        List<DataRealTime> list = dataRealTimeService.list(queryWrapper1);
+        if(list.size() > 0){
+            for(int i=0;i<list.size();i++){
+                f += Float.parseFloat(list.get(i).getAttributeData());
+            }
+        }
+        float data = f/deviceCount;
+        return data;
+    }
+
 }

service-park/service-park-biz/src/main/java/com/usky/park/service/impl/EgConfigServiceImpl.java

@@ -0,0 +1,39 @@
+package com.usky.park.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.usky.park.domain.EgConfig;
+import com.usky.park.mapper.EgConfigMapper;
+import com.usky.park.service.EgConfigService;
+import com.usky.common.mybatis.core.AbstractCrudService;
+import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ * 门禁进出统计配置设备表 服务实现类
+ * </p>
+ *
+ * @author zyj
+ * @since 2023-04-26
+ */
+@Service
+public class EgConfigServiceImpl extends AbstractCrudService<EgConfigMapper, EgConfig> implements EgConfigService {
+    @Override
+    public void updateEgConfig(EgConfig egConfig){
+        egConfig.setConfigTime(LocalDateTime.now());
+        this.updateById(egConfig);
+    }
+
+    @Override
+    public List<EgConfig> getEgConfig(){
+        LambdaQueryWrapper<EgConfig> queryWrapper = Wrappers.lambdaQuery();
+        List<EgConfig> list = this.list(queryWrapper);
+        return list;
+    }
+
+}

service-park/service-park-biz/src/main/java/com/usky/park/service/impl/EventEgServiceImpl.java

@@ -6,16 +6,20 @@ import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.usky.common.core.bean.CommonPage;
+import com.usky.park.domain.DmpDevice;
 import com.usky.park.domain.EventEg;
 import com.usky.park.mapper.EventEgMapper;
+import com.usky.park.service.DmpDeviceService;
 import com.usky.park.service.EventEgService;
 import com.usky.common.mybatis.core.AbstractCrudService;
 import com.usky.park.service.vo.EventEgStatisticVO;
 import org.bouncycastle.util.StringList;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -27,22 +31,66 @@ import java.util.List;
  */
 @Service
 public class EventEgServiceImpl extends AbstractCrudService<EventEgMapper, EventEg> implements EventEgService {
+    @Autowired
+    private DmpDeviceService deviceService;
 
     @Override
     public CommonPage<EventEg> eventEgList(String deviceName,String installAddress,String cardNo,String orgName,Integer eventType,Integer pageNum,Integer pageSize){
         IPage<EventEg> page = new Page<>(pageNum,pageSize);
         List<EventEg> list = new ArrayList<>();
-        LambdaQueryWrapper<EventEg> queryWrapper = Wrappers.lambdaQuery();
-        queryWrapper.like(StringUtils.isNotBlank(deviceName),EventEg::getDeviceName,deviceName)
-                    .like(StringUtils.isNotBlank(installAddress),EventEg::getInstallAddress,installAddress)
-                    .like(StringUtils.isNotBlank(cardNo),EventEg::getCardNo,cardNo)
-                    .like(StringUtils.isNotBlank(orgName),EventEg::getOrgName,orgName)
-                    .eq(eventType  != null,EventEg::getEventType,eventType)
-                    .orderByDesc(EventEg::getId);
-        page = this.page(page,queryWrapper);
-        list = page.getRecords();
+        List<EventEg> list2 = new ArrayList<>();
+
+        LambdaQueryWrapper<DmpDevice> queryWrapper1 = Wrappers.lambdaQuery();
+        queryWrapper1.select(DmpDevice::getDeviceId)
+                .eq(DmpDevice::getDeviceType,502);
+        List<DmpDevice> deviceList = deviceService.list(queryWrapper1);
+        if(deviceList.size() > 0){
+            for(int i=0;i<deviceList.size();i++){
+                LambdaQueryWrapper<EventEg> queryWrapper = Wrappers.lambdaQuery();
+                queryWrapper.eq(EventEg::getDeviceId,deviceList.get(i).getDeviceId())
+                        .orderByDesc(EventEg::getEventTime);
+                List<EventEg> list1 = this.list(queryWrapper);
+                if(list1.size()>0){
+                    list2.add(list1.get(0));
+
+                }
+            }
+
+        }
+
+        if(StringUtils.isNotBlank(deviceName)){
+            list = list2.stream().filter(e->deviceName.equals(e.getDeviceName())).collect(Collectors.toList());
+        }
+        if(StringUtils.isNotBlank(installAddress)){
+            list = list2.stream().filter(e->installAddress.equals(e.getInstallAddress())).collect(Collectors.toList());
+        }
+        if(StringUtils.isNotBlank(cardNo)){
+            list = list2.stream().filter(e->cardNo.equals(e.getCardNo())).collect(Collectors.toList());
+        }
+        if(StringUtils.isNotBlank(orgName)){
+            list = list2.stream().filter(e->orgName.equals(e.getOrgName())).collect(Collectors.toList());
+        }
+        if(eventType != null){
+            list = list2.stream().filter(e->eventType.equals(e.getEventType())).collect(Collectors.toList());
+        }
+        if(list.size()==0){
+            list = list2;
+        }
+
+        List<EventEg> objectList = new ArrayList<>();
+        int total = 0;
+        if(list.size() > 0){
+            total = list.size();
+        }
+        int current = 0;
+        if(pageNum != 0 && pageSize > 0){
+            current = (pageNum - 1)*pageSize;
+        }
+
+        objectList = list.stream().skip(current).limit(pageSize).collect(Collectors.toList());
+
 
-        return new CommonPage<>(list,page.getTotal(),pageNum,pageSize);
+        return new CommonPage<>(objectList,total,pageNum,pageSize);
 
     }
 

service-park/service-park-biz/src/main/resources/mapper/park/EgConfigMapper.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.usky.park.mapper.EgConfigMapper">
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.usky.park.domain.EgConfig">
+        <id column="id" property="id" />
+        <result column="in_deviceids" property="inDeviceids" />
+        <result column="out_deviceids" property="outDeviceids" />
+        <result column="config_time" property="configTime" />
+    </resultMap>
+
+</mapper>