提交设备接入代码

unis-plugin/unis-plugin-biz/src/main/java/com/unis/basic.info/modular/orgInfo/mapper/OrgInfoMapper.java

@@ -19,6 +19,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Constants;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.unis.basic.info.modular.orgInfo.entity.OrgInfo;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisPageVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisVO;
 import com.unis.reserveLayout.modular.dataSystemInfo.param.DataPageParam;
 import org.apache.ibatis.annotations.Mapper;
 import com.unis.basic.info.modular.orgInfo.param.OrgInfoPageParam;
@@ -71,4 +73,16 @@ public interface OrgInfoMapper extends BaseMapper<OrgInfo> {
     List<Map<String, Object>> selectKcYearRepot(@Param("dataPageParam")DataPageParam dataPageParam);
 
     Map<String, Object> selectByOrgInfo(@Param("dataPageParam")DataPageParam dataPageParam);
+
+    /**
+     * 在线统计分析-分页
+     *
+     * @author hjc
+     * @date  2024/06/21 10:07
+     */
+    Page<StatisticalAnalysisPageVO> statisticalAnalysisPage(@Param("page") Page<StatisticalAnalysisPageVO> page,
+                                                            @Param("zcdzCityName") String zcdzCityName);
+
+    List<StatisticalAnalysisVO> statisticalAnalysis();
+
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/basic.info/modular/orgInfo/mapper/mapping/OrgInfoMapper.xml

@@ -261,4 +261,111 @@
 
 
     </select>
+
+
+
+    <select id="statisticalAnalysisPage"
+            resultType="com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisPageVO">
+
+        SELECT DISTINCT
+        oi.org_id,
+        oi.org_name,
+        bui.zcdz_city zcdzCityId,
+        dd.DICT_LABEL zcdzCityName,
+        t1.nvrNum,
+        t2.cameraNum,
+        t3.cameraAbnormalNum
+        FROM
+        depot_qh.org_info oi
+        LEFT JOIN province_all.biz_unit_info bui ON oi.unit_info_id = bui.id
+        LEFT JOIN province_all.dev_dict dd ON bui.zcdz_city = dd.ID
+        LEFT JOIN (
+        SELECT
+        oi.org_id,
+        count( mn.id ) nvrNum
+        FROM
+        depot_qh.org_info oi
+        LEFT JOIN depot_qh.monitor_nvr mn ON oi.org_id = mn.org_id
+        GROUP BY
+        oi.org_id
+        ) t1 ON oi.org_id = t1.org_id
+        LEFT JOIN (
+        SELECT
+        oi.org_id,
+        count( mc.id ) cameraNum
+        FROM
+        depot_qh.org_info oi
+        LEFT JOIN depot_qh.monitor_camera mc ON oi.org_id = mc.org_id
+        GROUP BY
+        oi.org_id
+        ) t2 ON oi.org_id = t2.org_id
+        LEFT JOIN (
+        SELECT
+        oi.org_id,
+        count( mc.id ) cameraAbnormalNum
+        FROM
+        depot_qh.org_info oi
+        LEFT JOIN depot_qh.monitor_camera mc ON oi.org_id = mc.org_id
+        WHERE
+        mc.`status` != '1'
+        GROUP BY
+        oi.org_id
+        ) t3 ON oi.org_id = t3.org_id
+
+        <where>
+            <if test="zcdzCityName!=null and zcdzCityName!=null">
+               and dd.DICT_LABEL =#{zcdzCityName}
+            </if>
+        </where>
+
+    </select>
+
+
+    <select id="statisticalAnalysis"
+            resultType="com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisVO">
+        SELECT DISTINCT
+            oi.org_id,
+            oi.org_name,
+            bui.zcdz_city zcdzCityId,
+            dd.DICT_LABEL zcdzCityName,
+            t1.nvrNum,
+            t2.cameraNum,
+            t3.cameraAbnormalNum
+        FROM
+            depot_qh.org_info oi
+                LEFT JOIN province_all.biz_unit_info bui ON oi.unit_info_id = bui.id
+                LEFT JOIN province_all.dev_dict dd ON bui.zcdz_city = dd.ID
+                LEFT JOIN (
+                SELECT
+                    oi.org_id,
+                    count( mn.id ) nvrNum
+                FROM
+                    depot_qh.org_info oi
+                        LEFT JOIN depot_qh.monitor_nvr mn ON oi.org_id = mn.org_id
+                GROUP BY
+                    oi.org_id
+            ) t1 ON oi.org_id = t1.org_id
+                LEFT JOIN (
+                SELECT
+                    oi.org_id,
+                    count( mc.id ) cameraNum
+                FROM
+                    depot_qh.org_info oi
+                        LEFT JOIN depot_qh.monitor_camera mc ON oi.org_id = mc.org_id
+                GROUP BY
+                    oi.org_id
+            ) t2 ON oi.org_id = t2.org_id
+                LEFT JOIN (
+                SELECT
+                    oi.org_id,
+                    count( mc.id ) cameraAbnormalNum
+                FROM
+                    depot_qh.org_info oi
+                        LEFT JOIN depot_qh.monitor_camera mc ON oi.org_id = mc.org_id
+                WHERE
+                    mc.`status` != '1'
+                GROUP BY
+                    oi.org_id
+            ) t3 ON oi.org_id = t3.org_id
+    </select>
 </mapper>

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/controller/MonitorCameraController.java

@@ -12,30 +12,25 @@
  */
 package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.controller;
 
-import cn.dev33.satoken.annotation.SaCheckPermission;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.github.xiaoymin.knife4j.annotations.ApiSupport;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.*;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrDetailVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisPageVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
-import com.unis.common.annotation.CommonLog;
 import com.unis.common.pojo.CommonResult;
-import com.unis.common.pojo.CommonValidList;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.entity.MonitorCamera;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraAddParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraEditParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraIdParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraPageParam;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.service.MonitorCameraService;
 
 import javax.annotation.Resource;
 import javax.validation.Valid;
-import javax.validation.constraints.NotEmpty;
 
 /**
  * 摄像头基本信息表控制器
@@ -53,25 +48,25 @@ public class MonitorCameraController {
     private MonitorCameraService monitorCameraService;
 
     /**
-     * 获取摄像头基本信息表分页
+     * 设备接入管理-分页
      *
      * @author hjc
      * @date  2024/06/21 10:07
      */
     @ApiOperationSupport(order = 1)
-    @ApiOperation("获取摄像头基本信息表分页")
+    @ApiOperation("设备接入管理-分页")
     //@SaCheckPermission("/equipmentOnlineRateAssessment/monitorCamera/page")
     @GetMapping("/equipmentOnlineRateAssessment/monitorCamera/page")
-    public CommonResult<Page<MonitorCamera>> page(MonitorCameraPageParam monitorCameraPageParam) {
+    public CommonResult<Page<CameraAndNvrVO>> page(MonitorCameraPageParam monitorCameraPageParam) {
         return CommonResult.data(monitorCameraService.page(monitorCameraPageParam));
     }
 
-    /**
+   /* *//**
      * 添加摄像头基本信息表
      *
      * @author hjc
      * @date  2024/06/21 10:07
-     */
+     *//*
     @ApiOperationSupport(order = 2)
     @ApiOperation("添加摄像头基本信息表")
     @CommonLog("添加摄像头基本信息表")
@@ -82,12 +77,12 @@ public class MonitorCameraController {
         return CommonResult.ok();
     }
 
-    /**
+    *//**
      * 编辑摄像头基本信息表
      *
      * @author hjc
      * @date  2024/06/21 10:07
-     */
+     *//*
     @ApiOperationSupport(order = 3)
     @ApiOperation("编辑摄像头基本信息表")
     @CommonLog("编辑摄像头基本信息表")
@@ -98,12 +93,12 @@ public class MonitorCameraController {
         return CommonResult.ok();
     }
 
-    /**
+    *//**
      * 删除摄像头基本信息表
      *
      * @author hjc
      * @date  2024/06/21 10:07
-     */
+     *//*
     @ApiOperationSupport(order = 4)
     @ApiOperation("删除摄像头基本信息表")
     @CommonLog("删除摄像头基本信息表")
@@ -113,19 +108,48 @@ public class MonitorCameraController {
                                                    CommonValidList<MonitorCameraIdParam> monitorCameraIdParamList) {
         monitorCameraService.delete(monitorCameraIdParamList);
         return CommonResult.ok();
-    }
+    }*/
 
     /**
-     * 获取摄像头基本信息表详情
+     * 设备接入管理-详情
      *
      * @author hjc
      * @date  2024/06/21 10:07
      */
-    @ApiOperationSupport(order = 5)
-    @ApiOperation("获取摄像头基本信息表详情")
+    @ApiOperationSupport(order = 2)
+    @ApiOperation("设备接入管理-详情")
     //@SaCheckPermission("/equipmentOnlineRateAssessment/monitorCamera/detail")
     @GetMapping("/equipmentOnlineRateAssessment/monitorCamera/detail")
-    public CommonResult<MonitorCamera> detail(@Valid MonitorCameraIdParam monitorCameraIdParam) {
-        return CommonResult.data(monitorCameraService.detail(monitorCameraIdParam));
+    public CommonResult<CameraAndNvrDetailVO> detail(@Valid MonitorCameraDetailParam monitorCameraDetailParam) {
+        return CommonResult.data(monitorCameraService.detail(monitorCameraDetailParam));
+    }
+
+    /**
+     * 在线统计分析-分页
+     *
+     * @author hjc
+     * @date  2024/06/21 10:07
+     */
+    @ApiOperationSupport(order = 3)
+    @ApiOperation("在线统计分析-分页")
+    //@SaCheckPermission("/equipmentOnlineRateAssessment/monitorCamera/page")
+    @GetMapping("/equipmentOnlineRateAssessment/monitorCamera/statisticalAnalysisPage")
+    public CommonResult<Page<StatisticalAnalysisPageVO>> statisticalAnalysisPage(StatisticalAnalysisPageParam pageParam) {
+        return CommonResult.data(monitorCameraService.statisticalAnalysisPage(pageParam));
+    }
+
+    /**
+     * 在线统计分析-导出
+     *
+     * @author hjc
+     * @date  2024/06/21 10:07
+     */
+    @ApiOperationSupport(order = 4)
+    @ApiOperation("在线统计分析-导出")
+    //@SaCheckPermission("/equipmentOnlineRateAssessment/monitorCamera/page")
+    @GetMapping("/equipmentOnlineRateAssessment/monitorCamera/statisticalAnalysisExport")
+    public CommonResult<String> statisticalAnalysisExport() {
+        monitorCameraService.statisticalAnalysisExport();
+        return CommonResult.ok();
     }
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/mapper/MonitorCameraMapper.java

@@ -14,8 +14,10 @@ package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.mapper;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.unis.common.constant.DBConstant;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.entity.MonitorCamera;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO;
 import org.apache.ibatis.annotations.Mapper;
 
 /**
@@ -27,4 +29,5 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 @DS(DBConstant.DS_DEPOT)
 public interface MonitorCameraMapper extends BaseMapper<MonitorCamera> {
+    Page<CameraAndNvrVO> findcamera(Page<CameraAndNvrVO> page ,  String name);
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/mapper/mapping/MonitorCameraMapper.xml

@@ -2,4 +2,13 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.mapper.MonitorCameraMapper">
 
+    <select id="findcamera"
+            resultType="com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO">
+        select * from monitor_camera
+        <where>
+            <if test="name != null and name != ''">
+                name like concat('%',#{name},'%')
+            </if>
+        </where>
+    </select>
 </mapper>

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/param/MonitorCameraDetailParam.java

@@ -0,0 +1,41 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+
+/**
+ * 摄像头基本信息表Id参数
+ *
+ * @author hjc
+ * @date  2024/06/21 10:07
+ **/
+@Getter
+@Setter
+public class MonitorCameraDetailParam {
+
+    /** 主键 */
+    @ApiModelProperty(value = "主键", required = true)
+    @NotNull(message = "id不能为空")
+    private Integer id;
+
+    /** 设备类型（1 摄像头，2 NVR) */
+    @ApiModelProperty(value = "设备类型（1 摄像头，2 NVR)", required = true)
+    @NotNull(message = "设备类型不能为空")
+    private Integer variety;
+}

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/param/MonitorCameraPageParam.java

@@ -44,8 +44,12 @@ public class MonitorCameraPageParam {
     @ApiModelProperty(value = "排序方式，升序：ASCEND；降序：DESCEND")
     private String sortOrder;
 
-    /** 关键词 */
-    @ApiModelProperty(value = "关键词")
-    private String searchKey;
+    /** 设备类型（1 摄像头，2 NVR) */
+    @ApiModelProperty(value = "设备类型（1 摄像头，2 NVR)", position = 27)
+    private Integer variety;
+
+    /** 设备出厂名称（海康高清红外球机） */
+    @ApiModelProperty(value = "设备出厂名称（海康高清红外球机）", position = 4)
+    private String name;
 
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/param/StatisticalAnalysisPageParam.java

@@ -0,0 +1,35 @@
+package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author hjc
+ * @version 1.0
+ * @Description
+ * @date 2024/6/21 15:19
+ */
+@Data
+public class StatisticalAnalysisPageParam {
+
+    /** 当前页 */
+    @ApiModelProperty(value = "当前页码")
+    private Integer current;
+
+    /** 每页条数 */
+    @ApiModelProperty(value = "每页条数")
+    private Integer size;
+
+    /** 排序字段 */
+    @ApiModelProperty(value = "排序字段，字段驼峰名称，如：userName")
+    private String sortField;
+
+    /** 排序方式 */
+    @ApiModelProperty(value = "排序方式，升序：ASCEND；降序：DESCEND")
+    private String sortOrder;
+
+    /** 所属市州名称 */
+    @ApiModelProperty(value = "所属市州名称",position = 4)
+    private String zcdzCityName;
+
+}

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/service/MonitorCameraService.java

@@ -15,10 +15,10 @@ package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.entity.MonitorCamera;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraAddParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraEditParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraIdParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraPageParam;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.*;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrDetailVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisPageVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO;
 
 import java.util.List;
 
@@ -36,7 +36,7 @@ public interface MonitorCameraService extends IService<MonitorCamera> {
      * @author hjc
      * @date  2024/06/21 10:07
      */
-    Page<MonitorCamera> page(MonitorCameraPageParam monitorCameraPageParam);
+    Page<CameraAndNvrVO> page(MonitorCameraPageParam monitorCameraPageParam);
 
     /**
      * 添加摄像头基本信息表
@@ -68,7 +68,7 @@ public interface MonitorCameraService extends IService<MonitorCamera> {
      * @author hjc
      * @date  2024/06/21 10:07
      */
-    MonitorCamera detail(MonitorCameraIdParam monitorCameraIdParam);
+    CameraAndNvrDetailVO detail(MonitorCameraDetailParam monitorCameraDetailParam);
 
     /**
      * 获取摄像头基本信息表详情
@@ -77,4 +77,22 @@ public interface MonitorCameraService extends IService<MonitorCamera> {
      * @date  2024/06/21 10:07
      **/
     MonitorCamera queryEntity(Integer id);
+
+    /**
+     * 在线统计分析-分页
+     *
+     * @author hjc
+     * @date  2024/06/21 10:07
+     */
+    Page<StatisticalAnalysisPageVO> statisticalAnalysisPage(StatisticalAnalysisPageParam pageParam);
+
+    /**
+     * 在线统计分析-导出
+     *
+     * @author hjc
+     * @date  2024/06/21 10:07
+     */
+    void statisticalAnalysisExport();
+
+
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/service/impl/MonitorCameraServiceImpl.java

@@ -14,46 +14,123 @@ package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.service.imp
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollStreamUtil;
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.ObjectUtil;
-import cn.hutool.core.util.StrUtil;
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.write.style.column.SimpleColumnWidthStyleStrategy;
+import com.alibaba.excel.write.style.row.SimpleRowHeightStyleStrategy;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.unis.basic.info.modular.orgInfo.mapper.OrgInfoMapper;
+import com.unis.common.page.CommonPageRequest;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.*;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrDetailVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisPageVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.StatisticalAnalysisVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorNvr.entity.MonitorNvr;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorNvr.mapper.MonitorNvrMapper;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import com.unis.common.enums.CommonSortOrderEnum;
 import com.unis.common.exception.CommonException;
-import com.unis.common.page.CommonPageRequest;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.entity.MonitorCamera;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.mapper.MonitorCameraMapper;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraAddParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraEditParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraIdParam;
-import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.param.MonitorCameraPageParam;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.service.MonitorCameraService;
 
+import javax.xml.crypto.Data;
+import java.io.File;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 摄像头基本信息表Service接口实现类
  *
  * @author hjc
- * @date  2024/06/21 10:07
+ * @date 2024/06/21 10:07
  **/
 @Service
 public class MonitorCameraServiceImpl extends ServiceImpl<MonitorCameraMapper, MonitorCamera> implements MonitorCameraService {
 
+    @Autowired
+    private OrgInfoMapper orgInfoMapper;
+
+    @Autowired
+    private MonitorCameraMapper monitorCameraMapper;
+
+    @Autowired
+    private MonitorNvrMapper monitorNvrMapper;
+
     @Override
-    public Page<MonitorCamera> page(MonitorCameraPageParam monitorCameraPageParam) {
-        QueryWrapper<MonitorCamera> queryWrapper = new QueryWrapper<>();
-        if(ObjectUtil.isAllNotEmpty(monitorCameraPageParam.getSortField(), monitorCameraPageParam.getSortOrder())) {
-            CommonSortOrderEnum.validate(monitorCameraPageParam.getSortOrder());
-            queryWrapper.orderBy(true, monitorCameraPageParam.getSortOrder().equals(CommonSortOrderEnum.ASC.getValue()),
-                    StrUtil.toUnderlineCase(monitorCameraPageParam.getSortField()));
-        } else {
-            queryWrapper.lambda().orderByAsc(MonitorCamera::getId);
+    public Page<CameraAndNvrVO> page(MonitorCameraPageParam pageParam) {
+
+        Page<CameraAndNvrVO> page = new Page<>(pageParam.getCurrent(), pageParam.getSize());
+
+        switch (pageParam.getVariety() == null ? 3 : pageParam.getVariety()) {
+            case 1:
+                page = findCamera(page, pageParam);
+                break;
+            case 2:
+                page = findNvr(pageParam, page);
+                break;
+            default:
+                page = findAll(pageParam, page);
+
         }
-        return this.page(CommonPageRequest.defaultPage(), queryWrapper);
+        return page;
+
+    }
+
+    private Page<CameraAndNvrVO> findAll(MonitorCameraPageParam pageParam, Page<CameraAndNvrVO> page) {
+        List<MonitorCamera> monitorCameras = monitorCameraMapper.selectList(null);
+        List<MonitorNvr> monitorNvrs = monitorNvrMapper.selectList(null);
+        List<CameraAndNvrVO> cameraAndNvrVOS = new ArrayList<>();
+
+        for (MonitorCamera monitorCamera : monitorCameras) {
+            CameraAndNvrVO vo = new CameraAndNvrVO();
+            BeanUtil.copyProperties(monitorCamera, vo);
+            vo.setVariety(1);
+            cameraAndNvrVOS.add(vo);
+        }
+        for (MonitorNvr monitorNvr : monitorNvrs) {
+            CameraAndNvrVO vo = new CameraAndNvrVO();
+            BeanUtil.copyProperties(monitorNvr, vo);
+            vo.setVariety(2);
+            cameraAndNvrVOS.add(vo);
+        }
+        page.setRecords(cameraAndNvrVOS.subList(Math.min((pageParam.getCurrent() - 1) * pageParam.getSize(), cameraAndNvrVOS.size())
+                , Math.min(pageParam.getCurrent() * pageParam.getSize(), cameraAndNvrVOS.size())));
+        page.setTotal(cameraAndNvrVOS.size());
+        return page;
+    }
+
+    private Page<CameraAndNvrVO> findNvr(MonitorCameraPageParam pageParam, Page<CameraAndNvrVO> list) {
+        list = monitorNvrMapper.findNvr(list, pageParam.getName());
+        List<CameraAndNvrVO> records = list.getRecords();
+        if (CollectionUtil.isNotEmpty(records)) {
+            for (CameraAndNvrVO CameraAndNvrVO : records) {
+                CameraAndNvrVO.setVariety(2);
+            }
+        }
+
+        return list;
+    }
+
+
+    private Page<CameraAndNvrVO> findCamera(Page<CameraAndNvrVO> list, MonitorCameraPageParam pageParam) {
+        list = monitorCameraMapper.findcamera(list, pageParam.getName());
+        List<CameraAndNvrVO> records = list.getRecords();
+        if (CollectionUtil.isNotEmpty(records)) {
+            for (CameraAndNvrVO monitorCamera : records) {
+                monitorCamera.setVariety(1);
+            }
+        }
+        return list;
     }
 
     @Transactional(rollbackFor = Exception.class)
@@ -79,16 +156,75 @@ public class MonitorCameraServiceImpl extends ServiceImpl<MonitorCameraMapper, M
     }
 
     @Override
-    public MonitorCamera detail(MonitorCameraIdParam monitorCameraIdParam) {
-        return this.queryEntity(monitorCameraIdParam.getId());
+    public CameraAndNvrDetailVO detail(MonitorCameraDetailParam detailParam) {
+
+        CameraAndNvrDetailVO vo = new CameraAndNvrDetailVO();
+        if (detailParam.getVariety() == 1) {
+            //摄像头
+            MonitorCamera monitorCamera = this.queryEntity(detailParam.getId());
+            BeanUtil.copyProperties(monitorCamera, vo);
+            vo.setVariety(1);
+
+        } else if (detailParam.getVariety() == 2) {
+            //NVR
+            MonitorNvr monitorNvr = monitorNvrMapper.selectById(detailParam.getId());
+            BeanUtil.copyProperties(monitorNvr, vo);
+            vo.setModelNumber(monitorNvr.getModelNum());
+            vo.setSubnetmask(monitorNvr.getSubnetMask());
+            vo.setVariety(2);
+        }
+
+        return vo;
     }
 
     @Override
     public MonitorCamera queryEntity(Integer id) {
         MonitorCamera monitorCamera = this.getById(id);
-        if(ObjectUtil.isEmpty(monitorCamera)) {
+        if (ObjectUtil.isEmpty(monitorCamera)) {
             throw new CommonException("摄像头基本信息表不存在，id值为：{}", id);
         }
         return monitorCamera;
     }
+
+
+    /**
+     * 在线统计分析-分页
+     *
+     * @author hjc
+     * @date 2024/06/21 10:07
+     */
+    @Override
+    public Page<StatisticalAnalysisPageVO> statisticalAnalysisPage(StatisticalAnalysisPageParam pageParam) {
+
+        Page<StatisticalAnalysisPageVO> page = new Page<>(pageParam.getCurrent(), pageParam.getSize());
+        return orgInfoMapper.statisticalAnalysisPage(page, pageParam.getZcdzCityName());
+
+    }
+
+
+    /**
+     * 在线统计分析-导出
+     *
+     * @author hjc
+     * @date 2024/06/21 10:07
+     */
+    @Override
+    public void statisticalAnalysisExport() {
+        //TODO 路径改变
+        String path = "D://";
+        File folder = new File(path);
+        if (!folder.isDirectory()) {
+            folder.mkdirs();
+        }
+
+        SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
+        String dateStr = format.format(new Date());
+        String fileName = path + dateStr + "设备在线率考核统计分析" + ".xlsx";
+
+        EasyExcel.write(fileName, StatisticalAnalysisVO.class)
+                .sheet("设备在线率考核统计分析表")
+                .doWrite(orgInfoMapper.statisticalAnalysis());
+
+    }
+
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/vo/CameraAndNvrDetailVO.java

@@ -0,0 +1,45 @@
+package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @author hjc
+ * @version 1.0
+ * @Description
+ * @date 2024/6/22 10:10
+ */
+@Data
+public class CameraAndNvrDetailVO {
+
+    /** 设备出厂名称（海康高清红外球机） */
+    @ApiModelProperty(value = "设备出厂名称（海康高清红外球机）", position = 4)
+    private String name;
+
+    /** ip地址 */
+    @ApiModelProperty(value = "ip地址", position = 8)
+    private String ip;
+
+    /** 子网掩码 */
+    @ApiModelProperty(value = "子网掩码", position = 9)
+    private String subnetmask;
+
+    /** 端口 */
+    @ApiModelProperty(value = "端口", position = 12)
+    private String port;
+
+    /** 设备型号 */
+    @ApiModelProperty(value = "设备型号", position = 15)
+    private String modelNumber;
+
+
+    /** 设备类型（1 摄像头，2 NVR) */
+    @ApiModelProperty(value = "设备类型（1 摄像头，2 NVR)", position = 27)
+    private Integer variety;
+
+}

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/vo/CameraAndNvrVO.java

@@ -0,0 +1,44 @@
+package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author hjc
+ * @version 1.0
+ * @Description
+ * @date 2024/6/21 20:54
+ */
+@Data
+public class CameraAndNvrVO {
+
+    /** 主键 */
+    @ApiModelProperty(value = "主键", required = true, position = 1)
+    private Integer id;
+
+    /** 组织机构代码 */
+    @ApiModelProperty(value = "库区id", position = 2)
+    private String orgId;
+
+    /** 组织机构代码 */
+    @ApiModelProperty(value = "库区名称", position = 3)
+    private String orgName;
+
+    /** 设备出厂名称（海康高清红外球机） */
+    @ApiModelProperty(value = "设备出厂名称（海康高清红外球机）", position = 4)
+    private String name;
+
+    /** ip地址 */
+    @ApiModelProperty(value = "ip地址", position = 8)
+    private String ip;
+
+    /** 所属厂商 1-200海康 2-300大华 3其他 */
+    @ApiModelProperty(value = "所属厂商 1-200海康 2-300大华 3其他", position = 13)
+    private String factory;
+
+    /** 设备类型（1 摄像头，2 NVR) */
+    @ApiModelProperty(value = "设备类型（1 摄像头，2 NVR)", position = 27)
+    private Integer variety;
+
+
+}

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/vo/StatisticalAnalysisPageVO.java

@@ -0,0 +1,35 @@
+package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author hjc
+ * @version 1.0
+ * @Description
+ * @date 2024/6/21 15:09
+ */
+@Data
+public class StatisticalAnalysisPageVO {
+
+    @ApiModelProperty(value = "库区id",position = 1)
+    private Integer orgId;
+
+    @ApiModelProperty(value = "库区名称",position = 2)
+    private String orgName;
+
+    @ApiModelProperty(value = "所属市州Id",position = 3)
+    private String zcdzCityId;
+
+    @ApiModelProperty(value = "所属市州名称",position = 4)
+    private String zcdzCityName;
+
+    @ApiModelProperty(value = "NVR数量",position = 5)
+    private Integer nvrNum;
+
+    @ApiModelProperty(value = "摄像头数量",position = 6)
+    private Integer cameraNum;
+
+    @ApiModelProperty(value = "摄像头异常数量",position = 7)
+    private Integer cameraAbnormalNum;
+}

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorCamera/vo/StatisticalAnalysisVO.java

@@ -0,0 +1,37 @@
+package com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.write.style.ColumnWidth;
+import com.alibaba.excel.annotation.write.style.ContentRowHeight;
+import com.alibaba.excel.annotation.write.style.HeadRowHeight;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author hjc
+ * @version 1.0
+ * @Description
+ * @date 2024/6/21 15:09
+ */
+@Data
+@ContentRowHeight(20) // 文本行高度
+@HeadRowHeight(15) // 标题高度
+@ColumnWidth(20) // 默认列宽度
+public class StatisticalAnalysisVO {
+
+    @ExcelProperty("库区名称")
+    @ColumnWidth(40)
+    private String orgName;
+
+    @ExcelProperty("所属市州")
+    private String zcdzCityName;
+
+    @ExcelProperty("NVR数量")
+    private Integer nvrNum;
+
+    @ExcelProperty("摄像头数量")
+    private Integer cameraNum;
+
+    @ExcelProperty("摄像头异常数量")
+    private Integer cameraAbnormalNum;
+}

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorNvr/mapper/MonitorNvrMapper.java

@@ -14,9 +14,13 @@ package com.unis.equipmentOnlineRateAssessment.modular.monitorNvr.mapper;
 
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.unis.common.constant.DBConstant;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO;
 import com.unis.equipmentOnlineRateAssessment.modular.monitorNvr.entity.MonitorNvr;
+import com.unis.equipmentOnlineRateAssessment.modular.monitorNvr.param.MonitorNvrAddParam;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * 硬盘录像机表Mapper接口
@@ -27,4 +31,5 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 @DS(DBConstant.DS_DEPOT)
 public interface MonitorNvrMapper extends BaseMapper<MonitorNvr> {
+    Page<CameraAndNvrVO> findNvr( Page<CameraAndNvrVO> page ,@Param("name") String name);
 }

unis-plugin/unis-plugin-biz/src/main/java/com/unis/equipmentOnlineRateAssessment/modular/monitorNvr/mapper/mapping/MonitorNvrMapper.xml

@@ -2,4 +2,14 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.unis.equipmentOnlineRateAssessment.modular.monitorNvr.mapper.MonitorNvrMapper">
 
+
+    <select id="findNvr"
+            resultType="com.unis.equipmentOnlineRateAssessment.modular.monitorCamera.vo.CameraAndNvrVO">
+        select * from monitor_nvr
+        <where>
+            <if test="name != null and name != ''">
+                name like concat('%',#{name},'%')
+            </if>
+        </where>
+    </select>
 </mapper>