diff --git a/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/controller/DklMonitoringPointsControllerTest .java b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/controller/DklMonitoringPointsControllerTest .java
new file mode 100644
index 0000000..9cafa42
--- /dev/null
+++ b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/controller/DklMonitoringPointsControllerTest .java	
@@ -0,0 +1,352 @@
+package com.dkl.large.controller;
+
+import com.dkl.common.core.domain.AjaxResult;
+import com.dkl.common.core.page.TableDataInfo;
+import com.dkl.large.domain.DklMonitoringPoints;
+import com.dkl.large.service.IDklMonitoringPointsService;
+import com.koal.kms.sdk.ed.KmsSdkException;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.mock.web.MockHttpServletResponse;
+import org.springframework.mock.web.MockMultipartFile;
+import org.springframework.security.test.context.support.WithMockUser;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.ByteArrayInputStream;
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+/**
+ * 监控点信息Controller单元测试
+ *
+ * @author Dkl
+ * @date 2025-06-10
+ */
+@ExtendWith(MockitoExtension.class)
+@WithMockUser(roles = "ADMIN") // 模拟登录用户，满足权限校验
+public class DklMonitoringPointsControllerTest {
+
+    // 注入被测试的Controller（自动注入Mock的依赖）
+    @InjectMocks
+    private DklMonitoringPointsController monitoringPointsController;
+
+    // 模拟Controller依赖的Service层
+    @Mock
+    private IDklMonitoringPointsService monitoringPointsService;
+
+    // 测试用例基础数据
+    private DklMonitoringPoints testPoint;
+    private List<DklMonitoringPoints> testPointList;
+
+    /**
+     * 每个测试方法执行前初始化测试数据
+     */
+    @BeforeEach
+    void setUp() {
+        // 初始化单个监控点数据
+        testPoint = new DklMonitoringPoints();
+        testPoint.setId(1L);
+        testPoint.setPointName("测试监控点");
+        testPoint.setDelFlag("0");
+
+        // 初始化监控点列表
+        testPointList = new ArrayList<>();
+        testPointList.add(testPoint);
+    }
+
+    /**
+     * 测试查询监控点列表（list接口）
+     */
+    @Test
+    void testList() throws KmsSdkException {
+        // 1. 模拟Service层返回数据
+        when(monitoringPointsService.selectDklMonitoringPointsList(any(DklMonitoringPoints.class)))
+                .thenReturn(testPointList);
+
+        // 2. 调用Controller接口
+        TableDataInfo result = monitoringPointsController.list(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertEquals(testPointList.size(), result.getRows().size());
+        assertEquals(testPointList.get(0).getId(), ((DklMonitoringPoints) result.getRows().get(0)).getId());
+
+        // 4. 验证Service方法被调用
+        verify(monitoringPointsService, times(1)).selectDklMonitoringPointsList(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试查询监控点消息（listMessage接口）
+     */
+    @Test
+    void testListMessage() throws KmsSdkException {
+        // 1. 模拟Service返回消息
+        String mockMessage = "查询成功";
+        when(monitoringPointsService.selectDklMonitoringPointsListMeaasge(any(DklMonitoringPoints.class)))
+                .thenReturn(mockMessage);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.listMessage(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertTrue(result.isSuccess());
+        assertEquals(mockMessage, result.getData());
+
+        // 4. 验证Service调用
+        verify(monitoringPointsService, times(1)).selectDklMonitoringPointsListMeaasge(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试查询所有有效监控点（listAll接口）
+     */
+    @Test
+    void testListAll() throws KmsSdkException {
+        // 1. 模拟Service返回数据
+        when(monitoringPointsService.selectDklMonitoringPointsList(any(DklMonitoringPoints.class)))
+                .thenReturn(testPointList);
+
+        // 2. 调用接口
+        TableDataInfo result = monitoringPointsController.listAll(testPoint);
+
+        // 3. 验证delFlag被设置为0
+        assertEquals("0", testPoint.getDelFlag());
+
+        // 4. 验证返回结果
+        assertNotNull(result);
+        assertEquals(testPointList.size(), result.getRows().size());
+
+        // 5. 验证Service调用
+        verify(monitoringPointsService, times(1)).selectDklMonitoringPointsList(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试外部查询所有监控点（listOutAll接口）
+     */
+    @Test
+    void testListOutAll() throws KmsSdkException {
+        // 1. 模拟Service返回数据
+        when(monitoringPointsService.selectDklMonitoringPointsList(any(DklMonitoringPoints.class)))
+                .thenReturn(testPointList);
+
+        // 2. 调用接口
+        TableDataInfo result = monitoringPointsController.listOutAll(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertEquals(testPointList.size(), result.getRows().size());
+
+        // 4. 验证Service调用
+        verify(monitoringPointsService, times(1)).selectDklMonitoringPointsList(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试导出监控点列表（export接口）
+     */
+    @Test
+    void testExport() throws KmsSdkException {
+        // 1. 模拟Service返回数据
+        when(monitoringPointsService.selectDklMonitoringPointsList(any(DklMonitoringPoints.class)))
+                .thenReturn(testPointList);
+
+        // 2. 构建Mock响应对象
+        MockHttpServletResponse response = new MockHttpServletResponse();
+
+        // 3. 调用导出接口
+        monitoringPointsController.export(response, testPoint);
+
+        // 4. 验证Service调用
+        verify(monitoringPointsService, times(1)).selectDklMonitoringPointsList(any(DklMonitoringPoints.class));
+
+        // 5. 验证响应状态（非空即可，Excel导出核心逻辑在ExcelUtil，此处仅验证流程）
+        assertEquals(200, response.getStatus());
+    }
+
+    /**
+     * 测试获取监控点详情（getInfo接口）
+     */
+    @Test
+    void testGetInfo() throws KmsSdkException {
+        // 1. 模拟Service返回单个监控点
+        when(monitoringPointsService.selectDklMonitoringPointsById(anyLong())).thenReturn(testPoint);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.getInfo(1L);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertTrue(result.isSuccess());
+        assertEquals(testPoint.getId(), ((DklMonitoringPoints) result.getData()).getId());
+
+        // 4. 验证Service调用
+        verify(monitoringPointsService, times(1)).selectDklMonitoringPointsById(1L);
+    }
+
+    /**
+     * 测试新增监控点（add接口）- 名称唯一，新增成功
+     */
+    @Test
+    void testAdd_Success() throws KmsSdkException {
+        // 1. 模拟Service校验名称唯一、新增成功
+        when(monitoringPointsService.checkPointsNameUnique(any(DklMonitoringPoints.class))).thenReturn(true);
+        when(monitoringPointsService.insertDklMonitoringPoints(any(DklMonitoringPoints.class))).thenReturn(1);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.add(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertTrue(result.isSuccess());
+        assertEquals(1, result.getData()); // toAjax(1) 返回成功
+
+        // 4. 验证监控点的系统字段被设置
+        assertNotNull(testPoint.getCreateTime());
+        assertNotNull(testPoint.getUpdateTime());
+        assertNotNull(testPoint.getCreateBy());
+        assertNotNull(testPoint.getUpdateBy());
+        assertEquals("0", testPoint.getDelFlag());
+
+        // 5. 验证Service调用
+        verify(monitoringPointsService, times(1)).checkPointsNameUnique(any(DklMonitoringPoints.class));
+        verify(monitoringPointsService, times(1)).insertDklMonitoringPoints(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试新增监控点（add接口）- 名称重复，新增失败
+     */
+    @Test
+    void testAdd_Fail_NameDuplicate() throws KmsSdkException {
+        // 1. 模拟Service校验名称重复
+        when(monitoringPointsService.checkPointsNameUnique(any(DklMonitoringPoints.class))).thenReturn(false);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.add(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertFalse(result.isSuccess());
+        assertEquals("新增监控点信息'测试监控点'失败，名称已存在", result.getMsg());
+
+        // 4. 验证新增方法未被调用
+        verify(monitoringPointsService, never()).insertDklMonitoringPoints(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试修改监控点（edit接口）- 名称唯一，修改成功
+     */
+    @Test
+    void testEdit_Success() throws KmsSdkException {
+        // 1. 模拟Service校验名称唯一、修改成功
+        when(monitoringPointsService.checkPointsNameUnique(any(DklMonitoringPoints.class))).thenReturn(true);
+        when(monitoringPointsService.updateDklMonitoringPoints(any(DklMonitoringPoints.class))).thenReturn(1);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.edit(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertTrue(result.isSuccess());
+        assertEquals(1, result.getData());
+
+        // 4. 验证系统字段被设置
+        assertNotNull(testPoint.getUpdateTime());
+        assertNotNull(testPoint.getUpdateBy());
+
+        // 5. 验证Service调用
+        verify(monitoringPointsService, times(1)).checkPointsNameUnique(any(DklMonitoringPoints.class));
+        verify(monitoringPointsService, times(1)).updateDklMonitoringPoints(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试修改监控点（edit接口）- 名称重复，修改失败
+     */
+    @Test
+    void testEdit_Fail_NameDuplicate() throws KmsSdkException {
+        // 1. 模拟Service校验名称重复
+        when(monitoringPointsService.checkPointsNameUnique(any(DklMonitoringPoints.class))).thenReturn(false);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.edit(testPoint);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertFalse(result.isSuccess());
+        assertEquals("修改监控点信息'测试监控点'失败，名称已存在", result.getMsg());
+
+        // 4. 验证修改方法未被调用
+        verify(monitoringPointsService, never()).updateDklMonitoringPoints(any(DklMonitoringPoints.class));
+    }
+
+    /**
+     * 测试删除监控点（remove接口）
+     */
+    @Test
+    void testRemove() {
+        // 1. 模拟Service删除成功
+        int[] ids = {1, 2};
+        when(monitoringPointsService.deleteDklMonitoringPointsByIds(any(int[].class))).thenReturn(2);
+
+        // 2. 调用接口
+        AjaxResult result = monitoringPointsController.remove(ids);
+
+        // 3. 验证结果
+        assertNotNull(result);
+        assertTrue(result.isSuccess());
+        assertEquals(2, result.getData());
+
+        // 4. 验证Service调用
+        verify(monitoringPointsService, times(1)).deleteDklMonitoringPointsByIds(any(int[].class));
+    }
+
+    /**
+     * 测试导入模板下载（importTemplate接口）
+     */
+    @Test
+    void testImportTemplate() {
+        // 1. 构建Mock响应
+        MockHttpServletResponse response = new MockHttpServletResponse();
+
+        // 2. 调用接口（无返回值，仅验证无异常）
+        assertDoesNotThrow(() -> monitoringPointsController.importTemplate(response));
+
+        // 3. 验证响应状态
+        assertEquals(200, response.getStatus());
+    }
+
+    /**
+     * 测试导入监控点数据（importData接口）
+     */
+    @Test
+    void testImportData() throws Exception {
+        // 1. 模拟上传文件
+        MockMultipartFile file = new MockMultipartFile(
+                "file",
+                "monitoring_points.xlsx",
+                "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
+                new ByteArrayInputStream("test data".getBytes())
+        );
+
+        // 2. 模拟Service返回导入结果
+        String mockMessage = "导入成功，共导入1条数据";
+        when(monitoringPointsService.importDate(anyList(), anyString())).thenReturn(mockMessage);
+
+        // 3. 调用接口
+        AjaxResult result = monitoringPointsController.importData(file);
+
+        // 4. 验证结果
+        assertNotNull(result);
+        assertTrue(result.isSuccess());
+        assertEquals(mockMessage, result.getData());
+
+        // 5. 验证Service调用
+        verify(monitoringPointsService, times(1)).importDate(anyList(), anyString());
+    }
+}
\ No newline at end of file
diff --git a/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/domain/DklMonitoringPoints.java b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/domain/DklMonitoringPoints.java
new file mode 100644
index 0000000..c8b3dcc
--- /dev/null
+++ b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/domain/DklMonitoringPoints.java
@@ -0,0 +1,90 @@
+package com.dkl.large.domain;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+import com.dkl.common.annotation.Excel;
+import com.dkl.common.core.domain.BaseEntity;
+
+import java.util.Date;
+
+/**
+ * 监控点信息对象 dkl_monitoring_points
+ *
+ * @author Dkl
+ * @date 2025-06-10
+ */
+@Data
+public class DklMonitoringPoints extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** id */
+    private int id;
+
+    /** 监控点类型 */
+//    @Excel(name = "监控点类型")
+    private String monitoringType;
+    @Excel(name = "监控点类型")
+    private String monitoringTypeName;
+    /** 名称 */
+    @Excel(name = "名称")
+    private String pointName;
+
+    /** 区域 */
+//    @Excel(name = "区域")
+    private String pointRegion;
+    /** 区域名称 */
+    @Excel(name = "区域")
+    @TableField(exist = false)
+    private String regionname;
+    /** 值班人员 */
+    @Excel(name = "值班人员")
+    private String dutyPeople;
+
+    /** 值班联系方式 */
+    @Excel(name = "值班联系方式")
+    private String dutyPhone;
+
+    /** 地址 */
+    @Excel(name = "地址")
+    private String pointAddress;
+
+    /** 经度 */
+    @Excel(name = "经度")
+    private String lng;
+
+    /** 纬度 */
+    @Excel(name = "纬度")
+    private String lat;
+
+    /** 删除标志（0代表存在 2代表删除） */
+    private String delFlag;
+
+    /** 最大承载量 */
+    @Excel(name = "最大承载量")
+    private Long loadBearingMax;
+
+    /** 部门id*/
+    private Long deptId;
+
+    /** 开始时间 */
+    @TableField(exist = false)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date startTime;
+
+    /** 结束时间 */
+    @TableField(exist = false)
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date endTime;
+
+    /** 是否为风险点 */
+    @Excel(name = "风险点", readConverterExp = "Y=是,N=否")
+    private String isRisk;
+
+    private String sigenCode;
+
+
+}
diff --git a/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/mapper/DklMonitoringPointsMapper.java b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/mapper/DklMonitoringPointsMapper.java
new file mode 100644
index 0000000..c433e44
--- /dev/null
+++ b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/mapper/DklMonitoringPointsMapper.java
@@ -0,0 +1,127 @@
+package com.dkl.large.mapper;
+
+import java.util.List;
+
+import com.dkl.large.domain.DklMonitoringCameraData;
+import com.dkl.large.domain.DklMonitoringPoints;
+import com.dkl.large.domain.vo.DklMonitoringCameraDataVo;
+import com.dkl.large.domain.vo.HeatVo;
+import com.dkl.large.domain.vo.RegionalVo;
+import com.dkl.large.domain.vo.RiskVo;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * 监控点信息Mapper接口
+ *
+ * @author Dkl
+ * @date 2025-06-10
+ */
+public interface DklMonitoringPointsMapper
+{
+    /**
+     * 查询监控点信息
+     *
+     * @param id 监控点信息主键
+     * @return 监控点信息
+     */
+    public DklMonitoringPoints selectDklMonitoringPointsById(Long id);
+
+    /**
+     * 查询监控点信息列表
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 监控点信息集合
+     */
+    public List<DklMonitoringPoints> selectDklMonitoringPointsList(DklMonitoringPoints dklMonitoringPoints);
+
+    /**
+     * 新增监控点信息
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 结果
+     */
+    public int insertDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints);
+
+    /**
+     * 修改监控点信息
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 结果
+     */
+    public int updateDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints);
+
+    /**
+     * 删除监控点信息
+     *
+     * @param id 监控点信息主键
+     * @return 结果
+     */
+    public int deleteDklMonitoringPointsById(Long id);
+
+    /**
+     * 批量删除监控点信息
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteDklMonitoringPointsByIds(int[] ids);
+
+    /***
+     * @Author :rq
+     * @Description :获取监测点数量
+     * @Date :2025/06/12 11:00
+     * @Param :[]
+     * @return :int
+     **/
+    public String getDklMonitoringPointsCount();
+
+    /**
+     * 监控点热力图
+     *
+     * @param dataVo
+     * @return 结果
+     */
+    public List<HeatVo>  heatMap(@Param("dataVo") HeatVo dataVo);
+
+    /**
+     * 大客流总数区域展示图
+     *
+     * @param regionalVo
+     * @return 结果
+     */
+    public List<RegionalVo>  regionalStatistics(@Param("regionalVo")RegionalVo regionalVo);
+
+    /**
+     * 大客流总数区域数据
+     *
+     * @param regionalVo
+     * @return 结果
+     */
+    public List<DklMonitoringPoints>  regionalDataList(@Param("regionalVo")RegionalVo regionalVo);
+
+    /**
+     * 大客流总数区域数据
+     *
+     * @param riskVo
+     * @return 结果
+     */
+    public List<RiskVo>  riskDataList(@Param("riskVo")RiskVo riskVo);
+
+
+    /**
+     * @Author :rq
+     * @Description :大客流基础信息统计首页
+     * @Date :2025/07/11 10:42
+     **/
+    public List<RiskVo>  homePointsStatistics(RiskVo riskVo);
+
+    /**
+     * @Author :rq
+     * @Description :大客流基础信息统计首页
+     * @Date :2025/07/11 10:42
+     **/
+    public List<RiskVo>  homePointsStatisticsPeople(RiskVo riskVo);
+
+
+    public DklMonitoringPoints checkPointsNameUnique(@Param("pointName") String pointName);
+}
diff --git a/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/service/IDklMonitoringPointsService.java b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/service/IDklMonitoringPointsService.java
new file mode 100644
index 0000000..4162a4c
--- /dev/null
+++ b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/service/IDklMonitoringPointsService.java
@@ -0,0 +1,127 @@
+package com.dkl.large.service;
+
+import java.util.List;
+
+import com.koal.kms.sdk.ed.KmsSdkException;
+import com.dkl.large.domain.DklActivity;
+import com.dkl.large.domain.DklMonitoringCameraData;
+import com.dkl.large.domain.DklMonitoringPoints;
+import com.dkl.large.domain.vo.DklMonitoringCameraDataVo;
+import com.dkl.large.domain.vo.HeatVo;
+import com.dkl.large.domain.vo.RegionalVo;
+import com.dkl.large.domain.vo.RiskVo;
+
+/**
+ * 监控点信息Service接口
+ *
+ * @author Dkl
+ * @date 2025-06-10
+ */
+public interface IDklMonitoringPointsService
+{
+    /**
+     * 查询监控点信息
+     *
+     * @param id 监控点信息主键
+     * @return 监控点信息
+     */
+    public DklMonitoringPoints selectDklMonitoringPointsById(Long id) throws KmsSdkException;
+
+    /**
+     * 查询监控点信息列表
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 监控点信息集合
+     */
+
+    public List<DklMonitoringPoints> selectDklMonitoringPointsList(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException;
+    public String selectDklMonitoringPointsListMeaasge(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException;
+    /**
+     * 新增监控点信息
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 结果
+     */
+    public int insertDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException;
+
+    /**
+     * 修改监控点信息
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 结果
+     */
+    public int updateDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException;
+
+    /**
+     * 批量删除监控点信息
+     *
+     * @param ids 需要删除的监控点信息主键集合
+     * @return 结果
+     */
+    public int deleteDklMonitoringPointsByIds(int[] ids);
+
+    /**
+     * 删除监控点信息信息
+     *
+     * @param id 监控点信息主键
+     * @return 结果
+     */
+    public int deleteDklMonitoringPointsById(Long id);
+
+    /**
+     * 监控点热力图
+     *
+     * @param dataVo
+     * @return 结果
+     */
+    public List<HeatVo>  heatMap(HeatVo dataVo);
+
+    /**
+     * 大客流总数区域展示图
+     *
+     * @param regionalVo
+     * @return 结果
+     */
+    public List<RegionalVo>  regionalStatistics(RegionalVo regionalVo);
+
+    /**
+     * 大客流总数区域数据
+     *
+     * @param regionalVo
+     * @return 结果
+     */
+    public List<DklMonitoringPoints>  regionalDataList(RegionalVo regionalVo) throws KmsSdkException;
+
+    /**
+     * 大客流风险预警信息
+     *
+     * @param riskVo
+     * @return 结果
+     */
+    public List<RiskVo>  riskDataList(RiskVo riskVo);
+    /**
+     * @Author :rq
+     * @Description :
+     * @Date :2025/07/11 10:42
+     **/
+    public List<RiskVo>  homePointsStatistics(RiskVo riskVo);
+
+    /**
+     * @Author :rq
+     * @Description :大客流基础信息统计首页
+     * @Date :2025/07/11 10:42
+     **/
+    public List<RiskVo>  homePointsStatisticsPeople(RiskVo riskVo);
+
+    /**
+     * 导入数据
+     *
+     * @param dklMonitoringPointsList 数据列表
+     * @param operName 操作用户
+     * @return 结果
+     */
+    public String importDate(List<DklMonitoringPoints> dklMonitoringPointsList, String operName) throws KmsSdkException;
+
+    public boolean checkPointsNameUnique(DklMonitoringPoints dklMonitoringPoints);
+}
+
diff --git a/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java
new file mode 100644
index 0000000..bee6457
--- /dev/null
+++ b/Dkl-Vue-master/dkl-large/src/test/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java
@@ -0,0 +1,505 @@
+package com.dkl.large.service.impl;
+
+import java.util.Collection;
+import java.util.Collections;
+import java.util.Date;
+import java.util.List;
+import java.util.regex.Pattern;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import com.koal.kms.sdk.ed.KmsSdkException;
+import com.dkl.common.constant.UserConstants;
+import com.dkl.common.core.domain.entity.SysDept;
+import com.dkl.common.core.domain.entity.SysDictData;
+import com.dkl.common.exception.ServiceException;
+import com.dkl.common.utils.DateUtils;
+import com.dkl.common.utils.StringUtils;
+import com.dkl.large.domain.DklActivity;
+import com.dkl.large.domain.DklMonitoringCameraData;
+import com.dkl.large.domain.vo.DklMonitoringCameraDataVo;
+import com.dkl.large.domain.vo.HeatVo;
+import com.dkl.large.domain.vo.RegionalVo;
+import com.dkl.large.domain.vo.RiskVo;
+import com.dkl.large.utli.EnciphermentUtil;
+import com.dkl.system.mapper.SysDictDataMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.dkl.large.mapper.DklMonitoringPointsMapper;
+import com.dkl.large.domain.DklMonitoringPoints;
+import com.dkl.large.service.IDklMonitoringPointsService;
+
+import static com.dkl.common.utils.SecurityUtils.getDeptId;
+import static com.dkl.common.utils.SecurityUtils.getUsername;
+import static org.springframework.util.SerializationUtils.serialize;
+
+/**
+ * 监控点信息Service业务层处理
+ *
+ * @author Dkl
+ * @date 2025-06-10
+ */
+@Service
+public class DklMonitoringPointsServiceImpl implements IDklMonitoringPointsService
+{
+    @Autowired
+    private DklMonitoringPointsMapper dklMonitoringPointsMapper;
+    @Autowired
+    private SysDictDataMapper sysDictDataMapper;
+    //手机号正则
+    private static final String PHONE_REGEX = "^((0\\d{2,3}-\\d{7,8})|(1[3456789]\\d{9}))$";
+    //经度
+    private static final String LNG_REGEX = "^-?\\d{1,3}(\\.\\d+)?$";
+    //维度
+    private static final String LAT_REGEX = "^-?\\d{1,2}(\\.\\d+)?$";
+    /**
+     * 查询监控点信息
+     *
+     * @param id 监控点信息主键
+     * @return 监控点信息
+     */
+    @Override
+    public DklMonitoringPoints selectDklMonitoringPointsById(Long id) throws KmsSdkException {
+        DklMonitoringPoints dklMonitoringPoints =  dklMonitoringPointsMapper.selectDklMonitoringPointsById(id);
+        if (StringUtils.isNotEmpty(dklMonitoringPoints.getDutyPeople())&&StringUtils.isNotEmpty(dklMonitoringPoints.getDutyPhone())) {
+            String dutyPeople = dklMonitoringPoints.getDutyPeople();
+            String dutyPhone = dklMonitoringPoints.getDutyPhone();
+            dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople));
+            dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone));
+        }
+        return dklMonitoringPoints;
+    }
+
+    /**
+     * 查询监控点信息列表
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 监控点信息
+     */
+    @Override
+    public List<DklMonitoringPoints> selectDklMonitoringPointsList(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException {
+        List<DklMonitoringPoints>  list = dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoints);
+
+
+
+        for (DklMonitoringPoints dklMonitoringPointsInfo : list) {
+            if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPeople())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) {
+            String dutyPeople = dklMonitoringPointsInfo.getDutyPeople();
+            dklMonitoringPointsInfo.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople));
+            }
+            if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPhone())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) {
+                String dutyPhone = dklMonitoringPointsInfo.getDutyPhone();
+                dklMonitoringPointsInfo.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone));
+            }
+        }
+        return list;
+    }
+
+    @Override
+    public String selectDklMonitoringPointsListMeaasge(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException {
+        StringBuilder successMsg = new StringBuilder();
+        
+        List<DklMonitoringPoints>  list = dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoints);
+        for (DklMonitoringPoints dklMonitoringPointsInfo : list) {
+            if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPeople())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) {
+                String dutyPeople = dklMonitoringPointsInfo.getDutyPeople();
+                dklMonitoringPointsInfo.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople));
+            }
+            if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPhone())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) {
+                String dutyPhone = dklMonitoringPointsInfo.getDutyPhone();
+                dklMonitoringPointsInfo.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone));
+            }
+            byte[] bytes = serialize(dklMonitoringPointsInfo.getDutyPeople()+","+dklMonitoringPointsInfo.getDutyPhone());
+            String isor = EnciphermentUtil.kmsSign(bytes);
+            if (!isor.equals(dklMonitoringPointsInfo.getSigenCode())) {
+                successMsg.append("名称为"+dklMonitoringPointsInfo.getPointName()+"的数据被篡改");
+            }
+        }
+
+      //  List<DklMonitoringPoints>  list = dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoints);
+
+
+
+//        for (DklMonitoringPoints dklMonitoringPointsInfo : list) {
+//            String dutyPeople = null;
+//            String dutyPhone = null;
+//            if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPeople())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) {
+//                 dutyPeople = EnciphermentUtil.kmsDencrypt(dklMonitoringPointsInfo.getDutyPeople());
+//            }
+//            if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPhone())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) {
+//                 dutyPhone = EnciphermentUtil.kmsDencrypt(dklMonitoringPointsInfo.getDutyPhone());
+//            }
+//            // （序列化）
+//            byte[] bytes = serialize(dutyPeople+","+dutyPhone);
+//            String sigenCode = EnciphermentUtil.kmsSign(bytes);
+//            dklMonitoringPointsInfo.setSigenCode(sigenCode);
+//             dklMonitoringPointsMapper.updateDklMonitoringPoints(dklMonitoringPointsInfo);
+//        }
+
+        return successMsg.toString();
+}
+
+    /**
+     * 新增监控点信息
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 结果
+     */
+    @Override
+    public int insertDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException {
+        dklMonitoringPoints.setCreateTime(DateUtils.getNowDate());
+        String dutyPeople = dklMonitoringPoints.getDutyPeople();
+        String dutyPhone = dklMonitoringPoints.getDutyPhone();
+        dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsEncrypt(dutyPeople));
+        dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsEncrypt(dutyPhone));
+        // （序列化）
+        byte[] bytes = serialize(dutyPeople+","+dutyPhone);
+        String sigenCode = EnciphermentUtil.kmsSign(bytes);
+        dklMonitoringPoints.setSigenCode(sigenCode);
+        return dklMonitoringPointsMapper.insertDklMonitoringPoints(dklMonitoringPoints);
+    }
+
+    /**
+     * 修改监控点信息
+     *
+     * @param dklMonitoringPoints 监控点信息
+     * @return 结果
+     */
+    @Override
+    public int updateDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException {
+        dklMonitoringPoints.setUpdateTime(DateUtils.getNowDate());
+        String dutyPeople = dklMonitoringPoints.getDutyPeople();
+        String dutyPhone = dklMonitoringPoints.getDutyPhone();
+        dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsEncrypt(dutyPeople));
+        dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsEncrypt(dutyPhone));
+        // （序列化）
+        byte[] bytes = serialize(dutyPeople+","+dutyPhone);
+        String sigenCode = EnciphermentUtil.kmsSign(bytes);
+        dklMonitoringPoints.setSigenCode(sigenCode);
+        return dklMonitoringPointsMapper.updateDklMonitoringPoints(dklMonitoringPoints);
+    }
+
+    /**
+     * 批量删除监控点信息
+     *
+     * @param ids 需要删除的监控点信息主键
+     * @return 结果
+     */
+    @Override
+    public int deleteDklMonitoringPointsByIds(int[] ids)
+    {
+        return dklMonitoringPointsMapper.deleteDklMonitoringPointsByIds(ids);
+    }
+
+    /**
+     * 删除监控点信息信息
+     *
+     * @param id 监控点信息主键
+     * @return 结果
+     */
+    @Override
+    public int deleteDklMonitoringPointsById(Long id)
+    {
+        return dklMonitoringPointsMapper.deleteDklMonitoringPointsById(id);
+    }
+
+
+    /**
+     * 监控点热力图
+     *
+     * @param dataVo
+     * @return 结果
+     */
+    @Override
+    public List<HeatVo> heatMap(HeatVo dataVo) {
+        return dklMonitoringPointsMapper.heatMap(dataVo);
+    }
+
+    /**
+     * 大客流总数区域展示图
+     *
+     * @param regionalVo
+     * @return 结果
+     */
+    @Override
+    public List<RegionalVo> regionalStatistics(RegionalVo regionalVo) {
+        return dklMonitoringPointsMapper.regionalStatistics(regionalVo);
+    }
+
+    /**
+     * 大客流总数区域数据
+     *
+     * @param regionalVo
+     * @return 结果
+     */
+    @Override
+    public List<DklMonitoringPoints> regionalDataList(RegionalVo regionalVo) throws KmsSdkException {
+        List<DklMonitoringPoints>  list = dklMonitoringPointsMapper.regionalDataList(regionalVo);
+        for (DklMonitoringPoints dklMonitoringPointsInfo : list) {
+            String dutyPeople = dklMonitoringPointsInfo.getDutyPeople();
+            String dutyPhone = dklMonitoringPointsInfo.getDutyPhone();
+            dklMonitoringPointsInfo.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople));
+            dklMonitoringPointsInfo.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone));
+        }
+        return list;
+    }
+
+    /**
+     * 大客流风险预警信息
+     *
+     * @param riskVo
+     * @return 结果
+     */
+    @Override
+    public List<RiskVo> riskDataList(RiskVo riskVo) {
+        return dklMonitoringPointsMapper.riskDataList(riskVo);
+    }
+
+    @Override
+    public List<RiskVo> homePointsStatistics(RiskVo riskVo) {
+        return dklMonitoringPointsMapper.homePointsStatistics(riskVo);
+    }
+
+    @Override
+    public List<RiskVo> homePointsStatisticsPeople(RiskVo riskVo) {
+        return dklMonitoringPointsMapper.homePointsStatisticsPeople(riskVo);
+    }
+
+    @Override
+    public String importDate(List<DklMonitoringPoints> dklMonitoringPointsList, String operName) throws KmsSdkException {
+        //区域集合
+        List<SysDictData> areaDict=sysDictDataMapper.selectDictDataByType("activity_area");
+        //区监控点类型
+        List<SysDictData> pointType=sysDictDataMapper.selectDictDataByType("monitoring_point_type");
+        //所有大客流活动
+        DklMonitoringPoints dklMonitoringPoint = new DklMonitoringPoints();
+        dklMonitoringPoint.setDelFlag("0");
+        List<DklMonitoringPoints> dklMonitoringPointAll= dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoint);
+        if (StringUtils.isNull(dklMonitoringPointsList) || dklMonitoringPointsList.size() == 0) {
+            throw new ServiceException("导入数据不能为空！");
+        }
+        int successNum = 0;
+        int failureNum = 0;
+        StringBuilder successMsg = new StringBuilder();
+        StringBuilder failureMsg = new StringBuilder();
+        for (int i = 0; i < dklMonitoringPointsList.size(); i++) {
+            try
+            {
+                //名称
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getPointName())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据名称为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getPointName().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据名称长度过长");
+                    }
+                }
+
+
+                //地址
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getPointAddress())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1)+ "条数据地址为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getPointAddress().length()>=50){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据地址长度过长");
+                    }
+                }
+
+                //区域
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getRegionname())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1)+ "条数据区域为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getRegionname().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" +(i+1) + "条数据区域长度过长");
+                    }else{
+                        for (SysDictData sysDictData : areaDict) {
+                            if (sysDictData.getDictLabel().equals(dklMonitoringPointsList.get(i).getRegionname())) {
+                                dklMonitoringPointsList.get(i).setPointRegion(sysDictData.getDictValue());
+                                break;
+                            }
+
+                        }
+                        if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getPointRegion())){
+                            failureNum++;
+                            failureMsg.append("<br/> 第" +(i+1) + "条数据区域未找到");
+                        }
+                    }
+                }
+
+                //监控点类型
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getMonitoringTypeName())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1)+ "条数据监控点类型为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getMonitoringTypeName().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" +(i+1) + "条数据监控点类型长度过长");
+                    }else{
+                        for (SysDictData sysDictData : pointType) {
+                            if (sysDictData.getDictLabel().equals(dklMonitoringPointsList.get(i).getMonitoringTypeName())) {
+                                dklMonitoringPointsList.get(i).setMonitoringType(sysDictData.getDictValue());
+                                break;
+                            }
+                        }
+                        if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getMonitoringType())){
+                            failureNum++;
+                            failureMsg.append("<br/> 第" +(i+1) + "条数据监控点类型未找到");
+                        }
+                    }
+                }
+
+                //值班人员
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getDutyPeople())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据值班人员为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getDutyPeople().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据值班人员长度过长");
+                    }
+                }
+
+                //值班联系方式
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getDutyPhone())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据值班联系方式为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getDutyPhone().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据值班联系方式长度过长");
+                    }else if (!Pattern.matches(PHONE_REGEX, dklMonitoringPointsList.get(i).getDutyPhone())){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据值班联系方式有误");
+                    }
+                }
+
+
+                //经度
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getLng())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据经度为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getLng().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据经度长度过长");
+                    }else if (!Pattern.matches(LNG_REGEX, dklMonitoringPointsList.get(i).getLng())){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据值经度有误");
+                    }
+                }
+
+                //纬度
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getLat())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据纬度为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getLat().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据纬度长度过长");
+                    }else if (!Pattern.matches(LAT_REGEX, dklMonitoringPointsList.get(i).getLat())){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据值纬度有误");
+                    }
+                }
+
+                //最大承载量
+                if (dklMonitoringPointsList.get(i).getLoadBearingMax()<=0){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据最大承载量为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getLoadBearingMax()>=999999999){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" + (i+1) + "条数据最大承载量长度过长");
+                    }
+                }
+
+
+                //风险点
+                if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getIsRisk())){
+                    failureNum++;
+                    failureMsg.append("<br/> 第" + (i+1) + "条数据是否风险点为空");
+                }else{
+                    if (dklMonitoringPointsList.get(i).getIsRisk().length()>=30){
+                        failureNum++;
+                        failureMsg.append("<br/> 第" +(i+1)+ "条数据是否风险点长度过长");
+                    }else{
+                        if (!("Y").equals(dklMonitoringPointsList.get(i).getIsRisk())&&!("N").equals(dklMonitoringPointsList.get(i).getIsRisk())) {
+                            failureNum++;
+                            failureMsg.append("<br/> 第" + (i+1) + "条数据是否风险点长有误");
+                        }
+                    }
+                }
+
+
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + failureNum + "导入失败：";
+                failureMsg.append(msg + e.getMessage());
+            }
+
+        }
+        if (failureNum > 0)
+        {
+            failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下：");
+            throw new ServiceException(failureMsg.toString());
+        }
+        else {
+
+            List<DklMonitoringPoints> lists = Stream.of(dklMonitoringPointAll, dklMonitoringPointsList)
+                    .flatMap(Collection::stream)
+                    .collect(Collectors.toList());
+
+            boolean hasDuplicates = lists.stream()
+                    .map(DklMonitoringPoints::getPointName)
+                    .distinct()
+                    .count() != lists.size();
+            if (hasDuplicates) {
+                failureMsg.insert(0, "很抱歉，导入失败！共导入数据中有和系统原数据名称相同的数据");
+                throw new ServiceException(failureMsg.toString());
+
+            } else {
+                for (DklMonitoringPoints dklMonitoringPoints : dklMonitoringPointsList) {
+                    //添加系统信息
+                    dklMonitoringPoints.setDelFlag("0");
+                    dklMonitoringPoints.setCreateTime(new Date());
+                    dklMonitoringPoints.setCreateBy(getUsername());
+                    dklMonitoringPoints.setDeptId(getDeptId());
+                    dklMonitoringPoints.setUpdateTime(new Date());
+                    dklMonitoringPoints.setUpdateBy(getUsername());
+                    String dutyPeople = dklMonitoringPoints.getDutyPeople();
+                    String dutyPhone = dklMonitoringPoints.getDutyPhone();
+                    dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsEncrypt(dutyPeople));
+                    dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsEncrypt(dutyPhone));
+                    // （序列化）
+                    byte[] bytes = serialize(dutyPeople+","+dutyPhone);
+                    String sigenCode = EnciphermentUtil.kmsSign(bytes);
+                    dklMonitoringPoints.setSigenCode(sigenCode);
+                    dklMonitoringPointsMapper.insertDklMonitoringPoints(dklMonitoringPoints);
+                }
+                successMsg.insert(0, "恭喜您，数据已全部导入成功！");
+            }
+        }
+
+        return successMsg.toString();
+    }
+
+    @Override
+    public boolean checkPointsNameUnique(DklMonitoringPoints dklMonitoringPoints) {
+        Long deptId = StringUtils.isNull(dklMonitoringPoints.getId()) ? -1L : dklMonitoringPoints.getId();
+        DklMonitoringPoints info = dklMonitoringPointsMapper.checkPointsNameUnique(dklMonitoringPoints.getPointName());
+        if (StringUtils.isNotNull(info) && info.getId() != deptId.longValue())
+        {
+            return UserConstants.NOT_UNIQUE;
+        }
+        return UserConstants.UNIQUE;
+    }
+
+
+}
diff --git a/Dkl-Vue-master/dkl-large/src/test/resources/mapper/large/DklMonitoringPointsMapper.xml b/Dkl-Vue-master/dkl-large/src/test/resources/mapper/large/DklMonitoringPointsMapper.xml
new file mode 100644
index 0000000..3677961
--- /dev/null
+++ b/Dkl-Vue-master/dkl-large/src/test/resources/mapper/large/DklMonitoringPointsMapper.xml
@@ -0,0 +1,357 @@
+<?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.dkl.large.mapper.DklMonitoringPointsMapper">
+
+    <resultMap type="DklMonitoringPoints" id="DklMonitoringPointsResult">
+        <result property="id"    column="id"    />
+        <result property="monitoringType"    column="monitoring_type"    />
+        <result property="pointName"    column="point_name"    />
+        <result property="pointRegion"    column="point_region"    />
+        <result property="dutyPeople"    column="duty_people"    />
+        <result property="dutyPhone"    column="duty_phone"    />
+        <result property="pointAddress"    column="point_address"    />
+        <result property="lng"    column="lng"    />
+        <result property="lat"    column="lat"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateBy"    column="update_by"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="delFlag"    column="del_flag"    />
+        <result property="loadBearingMax"    column="load_bearing_max"    />
+        <result property="deptId"    column="dept_id"    />
+        <result property="isRisk"    column="is_risk"    />
+        <result property="sigenCode"    column="sigen_code"    />
+
+    </resultMap>
+
+    <sql id="selectDklMonitoringPointsVo">
+        select dmp.id, dmp.sigen_code , dmp.monitoring_type, dmp.point_name, dmp.point_region, dmp.duty_people, dmp.duty_phone, dmp.point_address, dmp.lng, dmp.lat, dmp.create_by, dmp.create_time,
+               dmp.update_by, dmp.update_time,dmp.is_risk, dmp.del_flag, dmp.load_bearing_max, dmp.dept_id,sdd.dict_label as regionname ,sdd1.dict_label as monitoringTypeName from dkl_monitoring_points AS dmp
+         left join sys_dept d on dmp.dept_id = d.dept_id
+         LEFT JOIN sys_dict_data sdd ON sdd.dict_value = dmp.point_region
+            AND sdd.dict_type = 'activity_area'
+         LEFT JOIN sys_dict_data sdd1 ON sdd1.dict_value = dmp.monitoring_type
+            AND sdd1.dict_type = 'monitoring_point_type'
+    </sql>
+
+    <select id="selectDklMonitoringPointsList" parameterType="DklMonitoringPoints" resultMap="DklMonitoringPointsResult">
+        <include refid="selectDklMonitoringPointsVo"/>
+        <where>
+            <if test="monitoringType != null  and monitoringType != ''"> and dmp.monitoring_type = #{monitoringType}</if>
+            <if test="pointName != null  and pointName != ''"> and dmp.point_name like concat('%', #{pointName}, '%')</if>
+            <if test="pointRegion != null  and pointRegion != ''"> and dmp.point_region = #{pointRegion}</if>
+            <if test="dutyPeople != null  and dutyPeople != ''"> and dmp.duty_people like concat('%', #{dutyPeople}, '%')</if>
+            <if test="dutyPhone != null  and dutyPhone != ''"> and dmp.duty_phone = #{dutyPhone}</if>
+            <if test="pointAddress != null  and pointAddress != ''"> and dmp.point_address = #{pointAddress}</if>
+            <if test="lng != null  and lng != ''"> and dmp.lng = #{lng}</if>
+            <if test="lat != null  and lat != ''"> and dmp.lat = #{lat}</if>
+            <if test="loadBearingMax != null "> and dmp.load_bearing_max = #{loadBearingMax}</if>
+            <if test="deptId != null "> and dmp.dept_id = #{deptId}</if>
+            <if test="delFlag != null  and delFlag != ''"> and dmp.del_flag = #{delFlag}</if>
+            <if test="isRisk != null  and isRisk != ''"> and dmp.is_risk = #{isRisk}</if>
+            <if test="startTime != null   and endTime != null">
+                AND dmp.create_time BETWEEN #{startTime} and #{endTime}
+            </if>
+        </where>
+        <!-- 数据范围过滤 -->
+        ${params.dataScope}
+        order by dmp.create_time desc
+    </select>
+
+    <select id="selectDklMonitoringPointsById" parameterType="Long" resultMap="DklMonitoringPointsResult">
+        <include refid="selectDklMonitoringPointsVo"/>
+        where dmp.id = #{id}
+    </select>
+
+    <insert id="insertDklMonitoringPoints" parameterType="DklMonitoringPoints">
+        insert into dkl_monitoring_points
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="monitoringType != null">monitoring_type,</if>
+            <if test="pointName != null">point_name,</if>
+            <if test="pointRegion != null">point_region,</if>
+            <if test="dutyPeople != null">duty_people,</if>
+            <if test="dutyPhone != null">duty_phone,</if>
+            <if test="pointAddress != null">point_address,</if>
+            <if test="lng != null">lng,</if>
+            <if test="lat != null">lat,</if>
+            <if test="createBy != null">create_by,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateBy != null">update_by,</if>
+            <if test="updateTime != null">update_time,</if>
+            <if test="delFlag != null">del_flag,</if>
+            <if test="loadBearingMax != null">load_bearing_max,</if>
+            <if test="deptId != null">dept_id,</if>
+            <if test="isRisk != null">is_risk,</if>
+            <if test="sigenCode != null">sigen_code,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="monitoringType != null">#{monitoringType},</if>
+            <if test="pointName != null">#{pointName},</if>
+            <if test="pointRegion != null">#{pointRegion},</if>
+            <if test="dutyPeople != null">#{dutyPeople},</if>
+            <if test="dutyPhone != null">#{dutyPhone},</if>
+            <if test="pointAddress != null">#{pointAddress},</if>
+            <if test="lng != null">#{lng},</if>
+            <if test="lat != null">#{lat},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateBy != null">#{updateBy},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+            <if test="delFlag != null">#{delFlag},</if>
+            <if test="loadBearingMax != null">#{loadBearingMax},</if>
+            <if test="deptId != null">#{deptId},</if>
+            <if test="isRisk != null">#{isRisk},</if>
+            <if test="sigenCode != null">#{sigenCode},</if>
+         </trim>
+    </insert>
+
+    <update id="updateDklMonitoringPoints" parameterType="DklMonitoringPoints">
+        update dkl_monitoring_points
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="monitoringType != null">monitoring_type = #{monitoringType},</if>
+            <if test="pointName != null">point_name = #{pointName},</if>
+            <if test="pointRegion != null">point_region = #{pointRegion},</if>
+            <if test="dutyPeople != null">duty_people = #{dutyPeople},</if>
+            <if test="dutyPhone != null">duty_phone = #{dutyPhone},</if>
+            <if test="pointAddress != null">point_address = #{pointAddress},</if>
+            <if test="lng != null">lng = #{lng},</if>
+            <if test="lat != null">lat = #{lat},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="delFlag != null">del_flag = #{delFlag},</if>
+            <if test="loadBearingMax != null">load_bearing_max = #{loadBearingMax},</if>
+            <if test="deptId != null">dept_id = #{deptId},</if>
+            <if test="isRisk != null">is_risk = #{isRisk},</if>
+            <if test="sigenCode != null">sigen_code = #{sigenCode},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <update id="deleteDklMonitoringPointsById" parameterType="int">
+        update dkl_monitoring_points set  del_flag = 2  where id = #{id}
+    </update>
+
+    <update id="deleteDklMonitoringPointsByIds" parameterType="int">
+        update dkl_monitoring_points set  del_flag = 2  where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </update>
+
+    <select id="getDklMonitoringPointsCount" parameterType="string">
+      SELECT COUNT(*) FROM  dkl_monitoring_points WHERE   del_flag = '0'
+    </select>
+
+
+    <select id="heatMap" parameterType="HeatVo" resultType="HeatVo">
+        SELECT
+            mp.id,
+            mp.monitoring_type,
+            mp.point_name,
+            mp.point_address,
+            mp.lng,
+            mp.lat,
+            CONCAT(a.dayTime, ' ', a.hTime) as dayTime,
+            a.numberPeople,
+            CAST( a.numberPeople  / mp.load_bearing_max AS DECIMAL( 10, 3 ) )*100 AS capacityFactor
+        FROM(
+            SELECT
+                mcd.camera_id,
+                SUM( mcd.number_people ) AS numberPeople,
+                to_char( mcd.acquisition_time, 'YYYY-MM-DD' ) AS dayTime,
+                to_char( mcd.acquisition_time, 'HH24:MI' ) AS hTime
+            FROM
+                dkl_monitoring_camera_data mcd
+            WHERE
+                mcd.del_flag = '0'
+                <if test="dataVo.startTime != null">
+                    AND mcd.acquisition_time >= DATE_TRUNC( 'day', #{dataVo.startTime} :: DATE)
+                </if>
+                <if test="dataVo.endTime != null">
+                    AND mcd.acquisition_time  <![CDATA[ <= ]]>  DATE_TRUNC( 'day', #{dataVo.endTime} :: DATE + INTERVAL '1 day' )
+                </if>
+            GROUP BY
+                mcd.camera_id,
+                dayTime,
+                hTime
+        ) a
+        LEFT JOIN dkl_monitoring_camera  AS mc ON mc."id" = a.camera_id
+        LEFT JOIN dkl_monitoring_points AS mp ON mp."id" = mc.points_id
+        WHERE
+            mc.del_flag = '0'
+            AND mp.del_flag = '0'
+            <if test="dataVo.monitoringType != null  and dataVo.monitoringType != ''">
+                AND mp.monitoring_type = #{dataVo.monitoringType}
+            </if>
+    </select>
+
+    <select id="regionalStatistics" parameterType="RegionalVo" resultType="RegionalVo">
+<!--        SELECT-->
+<!--            sdd.dict_label as regionname,-->
+<!--            COALESCE(A.numberPeople,0) AS loadBearingMax-->
+<!--        FROM-->
+<!--        sys_dict_data sdd-->
+<!--        LEFT JOIN (-->
+<!--            SELECT-->
+<!--                mp.point_region,-->
+<!--                SUM ( mcd.number_people ) AS numberPeople-->
+<!--            FROM-->
+<!--                dkl_monitoring_camera_data mcd-->
+<!--            LEFT JOIN dkl_monitoring_camera AS mc ON mc."id" = mcd.camera_id-->
+<!--            LEFT JOIN dkl_monitoring_points AS mp ON mp."id" = mc.points_id-->
+<!--            WHERE-->
+<!--                mcd.del_flag = '0'-->
+<!--                AND mc.del_flag = '0'-->
+<!--                AND mp.del_flag = '0'-->
+<!--            <if test="regionalVo.startTime != null">-->
+<!--                AND mcd.acquisition_time >= DATE_TRUNC( 'day', #{regionalVo.startTime} :: DATE )-->
+<!--            </if>-->
+<!--            <if test="regionalVo.endTime != null">-->
+<!--                AND mcd.acquisition_time  <![CDATA[ <= ]]>  DATE_TRUNC( 'day', #{regionalVo.endTime} :: DATE + INTERVAL '1 day' )-->
+<!--            </if>-->
+<!--            GROUP BY-->
+<!--            mp.point_region-->
+<!--        ) A ON A.point_region = sdd.dict_value-->
+<!--        WHERE-->
+<!--            sdd.status = '0'-->
+<!--            AND sdd.dict_type = 'activity_area'-->
+        SELECT
+            sdd.dict_label AS regionname,
+            sdd.dict_value AS regioninfo,
+            A.typename AS typename,
+            A.monitoring_type AS typeinfo,
+            COALESCE ( A.numberPeople, 0 ) AS loadBearingMax
+        FROM
+            sys_dict_data sdd
+        LEFT JOIN (
+        SELECT
+            dmp.point_region,
+            dmp.monitoring_type,
+            sdd.dict_label AS typename,
+            COUNT ( * ) AS numberPeople
+        FROM
+            dkl_monitoring_points AS dmp
+        LEFT JOIN sys_dict_data AS sdd ON dmp.monitoring_type = sdd.dict_value
+        AND sdd.dict_type = 'monitoring_point_type'
+        WHERE
+            dmp.del_flag = '0'
+        GROUP BY
+            point_region,
+            monitoring_type,
+            sdd.dict_label
+        ) A ON A.point_region = sdd.dict_value
+        WHERE
+            sdd.status = '0'
+        AND sdd.dict_type = 'activity_area'
+    </select>
+
+    <select id="regionalDataList" parameterType="RegionalVo" resultType="DklMonitoringPoints">
+        select dmp.id, dmp.monitoring_type, dmp.point_name as pointName, dmp.point_region , dmp.duty_people as dutyPeople, dmp.duty_phone as dutyPhone, dmp.point_address as pointAddress , dmp.lng, dmp.lat, dmp.create_by, dmp.create_time,
+               dmp.update_by, dmp.update_time, dmp.del_flag, dmp.load_bearing_max as loadBearingMax from dkl_monitoring_points AS dmp
+       LEFT JOIN sys_dict_data AS sdd ON dmp.monitoring_type = sdd.dict_value AND sdd.dict_type = 'monitoring_point_type'
+       LEFT JOIN sys_dict_data AS sdd1 ON dmp.point_region = sdd1.dict_value  AND sdd1.dict_type = 'activity_area'
+        WHERE
+        dmp.del_flag = '0'
+        <if test="regionalVo.typename != null">
+           AND sdd.dict_label = #{regionalVo.typename}
+        </if>
+        <if test="regionalVo.regionname != null">
+            AND sdd1.dict_label = #{regionalVo.regionname}
+        </if>
+
+    </select>
+
+    <select id="riskDataList" parameterType="RiskVo" resultType="RiskVo">
+        SELECT
+            mp.id,
+            mp.point_name AS pointName,
+            mp.load_bearing_max  AS loadBearingMax,
+            SUM( a.numberPeopleSum ) AS numberPeople,
+            CAST( numberPeople  / mp.load_bearing_max AS DECIMAL( 10, 3 ) )*100 AS capacityFactor,
+            mp.monitoring_type AS monitoringType,
+            mp.point_address AS pointAddress,
+            (
+                SELECT
+                    icon
+                FROM
+                    dkl_warning_threshold
+                WHERE
+                    CAST ( SUM ( a.numberPeopleSum ) / mp.load_bearing_max AS DECIMAL ( 10, 3 ) ) >= max_capacity
+                    AND CAST ( SUM ( a.numberPeopleSum ) / mp.load_bearing_max AS DECIMAL ( 10, 3 ) ) &lt;= min_capacity
+                    AND del_flag = '0'
+            )  as icon
+        FROM(
+                SELECT
+                    mcd.camera_id,
+                    SUM( mcd.number_people ) AS numberPeopleSum
+                FROM
+                    dkl_monitoring_camera_data mcd
+                WHERE
+                    mcd.del_flag = '0'
+                    <if test="riskVo.startTime != null">
+                        AND mcd.acquisition_time >= DATE_TRUNC( 'day', #{riskVo.startTime} :: DATE )
+                    </if>
+                    <if test="riskVo.endTime != null">
+                        AND mcd.acquisition_time  <![CDATA[ <= ]]>  DATE_TRUNC( 'day', #{riskVo.endTime} :: DATE + INTERVAL '1 day' )
+                    </if>
+                GROUP BY
+                    mcd.camera_id
+            ) a
+        LEFT JOIN dkl_monitoring_camera  AS mc ON mc."id" = a.camera_id
+        LEFT JOIN dkl_monitoring_points AS mp ON mp."id" = mc.points_id
+        WHERE
+            mc.del_flag = '0'
+            AND mp.del_flag = '0'
+        GROUP BY    mp.id
+    </select>
+
+    <select id="homePointsStatistics" parameterType="RiskVo" resultType="RiskVo">
+        SELECT
+            dmp.point_region  as pointRegion,
+            sdd.dict_label AS regionname,
+            count ( dmp.point_region ) AS numberPeople
+        FROM
+            dkl_monitoring_points AS dmp
+                LEFT JOIN sys_dict_data sdd ON sdd.dict_value = dmp.point_region
+                AND sdd.dict_type = 'activity_area'
+        WHERE
+            dmp.del_flag = '0'
+        <if test="startTime != null and endTime != null ">
+            AND dmp.create_time >= #{startTime}
+            AND dmp.create_time &lt;= #{endTime}
+        </if>
+
+        GROUP BY
+            dmp.point_region,
+            sdd.dict_label
+    </select>
+
+    <select id="homePointsStatisticsPeople" parameterType="RiskVo" resultType="RiskVo">
+        SELECT
+            dmp.point_region  as pointRegion,
+            sdd.dict_label as regionname,
+            SUM ( dmp.load_bearing_max ) AS numberPeople
+        FROM
+            dkl_monitoring_points AS dmp
+                LEFT JOIN sys_dict_data sdd ON sdd.dict_value = dmp.point_region
+                AND sdd.dict_type = 'activity_area'
+        WHERE
+            dmp.del_flag = '0'
+        <if test="startTime != null   and endTime != null ">
+            AND dmp.create_time >= #{startTime}
+            AND dmp.create_time &lt;= #{endTime}
+        </if>
+        GROUP BY
+            dmp.point_region,
+            sdd.dict_label
+    </select>
+
+    <select id="checkPointsNameUnique" resultMap="DklMonitoringPointsResult">
+        <include refid="selectDklMonitoringPointsVo"/>
+        where dmp.point_name=#{pointName}  and dmp.del_flag = '0' limit 1
+    </select>
+</mapper>