1

app-admin/src/main/java/com/ruoyi/web/controller/system/DrowningWarningController.java

@@ -0,0 +1,115 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.warning.drowningWarning.DrowningWarningAddRequest;
+import com.ruoyi.web.domain.dto.warning.drowningWarning.DrowningWarningEditRequest;
+import com.ruoyi.web.domain.dto.warning.drowningWarning.DrowningWarningQueryRequest;
+import com.ruoyi.web.domain.vo.DrowningWarningVO;
+import com.ruoyi.web.service.DrowningWarningService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "防溺水预警")
+@RestController
+@RequestMapping("/system/drowning/warning")
+public class DrowningWarningController {
+
+    @Autowired
+    private DrowningWarningService drowningWarningService;
+
+    /**
+     * 添加防溺水预警
+     *
+     * @param drowningWarningAddRequest
+     * @return
+     */
+    @ApiOperation("添加防溺水预警")
+    @PostMapping("/add")
+    public AjaxResult addDrowningWarning(@RequestBody DrowningWarningAddRequest drowningWarningAddRequest) {
+        if (drowningWarningAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = drowningWarningService.addDrowningWarning(drowningWarningAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除防溺水预警
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除防溺水预警")
+    @PostMapping("/delete")
+    public AjaxResult deleteDrowningWarning(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = drowningWarningService.deleteDrowningWarning(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑防溺水预警
+     *
+     * @param drowningWarningEditRequest
+     * @return
+     */
+    @ApiOperation("编辑防溺水预警")
+    @PostMapping("/edit")
+    public AjaxResult editFacility(@RequestBody DrowningWarningEditRequest drowningWarningEditRequest) {
+        if (drowningWarningEditRequest == null) {
+            return error("请求参数为空");
+        }
+        drowningWarningService.editDrowningWarning(drowningWarningEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取防溺水预警
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取防溺水预警")
+    @GetMapping("/get")
+    public AjaxResult getDrowningWarningById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        DrowningWarningVO drowningWarningVO = drowningWarningService.getDrowningWarningById(id);
+        return success(drowningWarningVO);
+    }
+
+    /**
+     * 分页获取防溺水预警列表
+     *
+     * @param drowningWarningQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取防溺水预警列表")
+    @PostMapping("/list/page")
+    public AjaxResult listDrowningWarningByPage(@RequestBody DrowningWarningQueryRequest drowningWarningQueryRequest) {
+        if (drowningWarningQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<DrowningWarningVO> listDrowningWarningVOByPage = drowningWarningService.getListDrowningWarningByPage(drowningWarningQueryRequest);
+        return success(listDrowningWarningVOByPage);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EarthquakeWarningController.java

@@ -0,0 +1,115 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.warning.earthquakeWarning.EarthquakeWarningAddRequest;
+import com.ruoyi.web.domain.dto.warning.earthquakeWarning.EarthquakeWarningEditRequest;
+import com.ruoyi.web.domain.dto.warning.earthquakeWarning.EarthquakeWarningQueryRequest;
+import com.ruoyi.web.domain.vo.EarthquakeWarningVO;
+import com.ruoyi.web.service.EarthquakeWarningService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "地震监测预警")
+@RestController
+@RequestMapping("/system/earthquake/warning")
+public class EarthquakeWarningController {
+
+    @Autowired
+    private EarthquakeWarningService earthquakeWarningService;
+
+    /**
+     * 添加地震监测预警
+     *
+     * @param earthquakeWarningAddRequest
+     * @return
+     */
+    @ApiOperation("添加地震监测预警")
+    @PostMapping("/add")
+    public AjaxResult addEarthquakeWarning(@RequestBody EarthquakeWarningAddRequest earthquakeWarningAddRequest) {
+        if (earthquakeWarningAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = earthquakeWarningService.addEarthquakeWarning(earthquakeWarningAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除地震监测预警
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除地震监测预警")
+    @PostMapping("/delete")
+    public AjaxResult deleteEarthquakeWarning(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = earthquakeWarningService.deleteEarthquakeWarning(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑地震监测预警
+     *
+     * @param earthquakeWarningEditRequest
+     * @return
+     */
+    @ApiOperation("编辑地震监测预警")
+    @PostMapping("/edit")
+    public AjaxResult editEarthquakeWarning(@RequestBody EarthquakeWarningEditRequest earthquakeWarningEditRequest) {
+        if (earthquakeWarningEditRequest == null) {
+            return error("请求参数为空");
+        }
+        earthquakeWarningService.editEarthquakeWarning(earthquakeWarningEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取地震监测预警
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取地震监测预警")
+    @GetMapping("/get")
+    public AjaxResult getEarthquakeWarningById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        EarthquakeWarningVO earthquakeWarningVO = earthquakeWarningService.getEarthquakeWarningById(id);
+        return success(earthquakeWarningVO);
+    }
+
+    /**
+     * 分页获取地震监测预警列表
+     *
+     * @param earthquakeWarningQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取地震监测预警列表")
+    @PostMapping("/list/page")
+    public AjaxResult listEarthquakeWarningByPage(@RequestBody EarthquakeWarningQueryRequest earthquakeWarningQueryRequest) {
+        if (earthquakeWarningQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<EarthquakeWarningVO> listEarthquakeWarningVOByPage = earthquakeWarningService.getListEarthquakeWarningByPage(earthquakeWarningQueryRequest);
+        return success(listEarthquakeWarningVOByPage);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EmergencyController.java

@@ -0,0 +1,147 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.emergency.EmergencyAddRequest;
+import com.ruoyi.web.domain.dto.emergency.EmergencyEditRequest;
+import com.ruoyi.web.domain.dto.emergency.EmergencyQueryRequest;
+import com.ruoyi.web.domain.dto.emergency.EmergencyRevokeRequest;
+import com.ruoyi.web.domain.vo.EmergencyVO;
+import com.ruoyi.web.service.EmergencyService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "应急指令下达管理")
+@RestController
+@RequestMapping("/system/emergency")
+public class EmergencyController {
+
+    @Autowired
+    private EmergencyService emergencyService;
+
+
+    /**
+     * 添加应急指令下达
+     *
+     * @param emergencyAddRequest
+     * @return
+     */
+    @ApiOperation("添加应急指令下达")
+    @PostMapping("/add")
+    public AjaxResult addEmergency(@RequestBody EmergencyAddRequest emergencyAddRequest) {
+        if (emergencyAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = emergencyService.addEmergency(emergencyAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除应急指令下达
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除应急指令下达")
+    @PostMapping("/delete")
+    public AjaxResult deleteEmergency(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = emergencyService.deleteEmergency(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+    /**
+     * 编辑应急指令下达
+     *
+     * @param emergencyEditRequest
+     * @return
+     */
+    @ApiOperation("编辑应急指令下达")
+    @PostMapping("/edit")
+    public AjaxResult editEmergency(@RequestBody EmergencyEditRequest emergencyEditRequest) {
+        if (emergencyEditRequest == null) {
+            return error("请求参数为空");
+        }
+        emergencyService.editEmergency(emergencyEditRequest);
+        return AjaxResult.success();
+    }
+
+    /**
+     * 撤回应急指令下达
+     *
+     * @param emergencyRevokeRequest
+     * @return
+     */
+    @ApiOperation("撤回应急指令下达")
+    @PostMapping("/revoke")
+    public AjaxResult revokeEmergency(@RequestBody EmergencyRevokeRequest emergencyRevokeRequest) {
+        if (emergencyRevokeRequest == null) {
+            return error("请求参数为空");
+        }
+        emergencyService.revokeEmergency(emergencyRevokeRequest);
+        return AjaxResult.success();
+    }
+
+    /**
+     * 下达应急指令
+     *
+     * @param emergencyRevokeRequest
+     * @return
+     */
+    @ApiOperation("下达应急指令")
+    @PostMapping("/down")
+    public AjaxResult downEmergency(@RequestBody EmergencyRevokeRequest emergencyRevokeRequest) {
+        if (emergencyRevokeRequest == null) {
+            return error("请求参数为空");
+        }
+        emergencyService.downEmergency(emergencyRevokeRequest);
+        return AjaxResult.success();
+    }
+
+    /**
+     * 根据id获取应急指令下达
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取应急指令下达")
+    @GetMapping("/get")
+    public AjaxResult getEmergencyById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        EmergencyVO emergencyById = emergencyService.getEmergencyById(id);
+        return success(emergencyById);
+    }
+
+    /**
+     * 分页获取应急指令下达列表
+     *
+     * @param emergencyQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取应急指令下达列表")
+    @PostMapping("/list/page")
+    public AjaxResult listEmergencyByPage(@RequestBody EmergencyQueryRequest emergencyQueryRequest) {
+        if (emergencyQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<EmergencyVO> listEmergencyVOByPage = emergencyService.getListEmergencyVOByPage(emergencyQueryRequest);
+        return success(listEmergencyVOByPage);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EmergencyUserController.java

@@ -0,0 +1,170 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.system.mapper.SysUserMapper;
+import com.ruoyi.web.domain.dto.emergencyUser.EmergencyUserAddRequest;
+import com.ruoyi.web.domain.entity.EmergencyUser;
+import com.ruoyi.web.domain.entity.PersonInfo;
+import com.ruoyi.web.domain.vo.EmergencyUserVO;
+import com.ruoyi.web.service.EmergencyUserService;
+import com.ruoyi.web.service.PersonInfoService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "应急指令下达负责人管理")
+@RestController
+@RequestMapping("/system/emergency/user")
+public class EmergencyUserController {
+
+    @Autowired
+    private EmergencyUserService emergencyUserService;
+
+    @Autowired
+    private PersonInfoService personInfoService;
+
+    @Autowired
+    private SysUserMapper sysUserMapper;
+
+    /**
+     * 添加指令下达负责人
+     *
+     * @param emergencyUserAddRequest
+     * @return
+     */
+    @ApiOperation("添加指令下达负责人")
+    @PostMapping("/add")
+    public AjaxResult addEmergencyUser(@RequestBody EmergencyUserAddRequest emergencyUserAddRequest) {
+        if (emergencyUserAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer personId = emergencyUserAddRequest.getPersonId();
+        QueryWrapper<PersonInfo> wrapper = new QueryWrapper<>();
+        wrapper.select("user_id")
+                .eq("id", personId);
+        PersonInfo personInfo = personInfoService.getOne(wrapper);
+        if (personInfo == null) {
+            throw new ServiceException("未找到负责人");
+        }
+        EmergencyUser emergencyUser = new EmergencyUser();
+        Integer userId = personInfo.getUserId();
+
+        QueryWrapper<EmergencyUser> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("user_id", userId);
+        long count = emergencyUserService.count(queryWrapper);
+        if (count == 0) {
+            // 不存在才添加
+            emergencyUser.setUserId(userId);
+            boolean save = emergencyUserService.save(emergencyUser);
+            if (save) {
+                return success("添加成功");
+            } else {
+                return error("添加失败");
+            }
+        } else {
+            return error("添加失败,该用户已成为指令下达负责人");
+        }
+    }
+
+    /**
+     * 删除指令下达负责人
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除指令下达负责人")
+    @PostMapping("/delete")
+    public AjaxResult deleteEmergencyUser(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+
+        // 2. 分割ID字符串为List<Integer>
+        List<Long> idList = Arrays.stream(ids.split(","))
+                .map(String::trim)
+                .filter(StrUtil::isNotBlank)
+                .map(Long::parseLong)
+                .collect(Collectors.toList());
+
+        if (idList.isEmpty()) {
+            throw new ServiceException("ID格式异常");
+        }
+
+        // 3. 构建删除条件
+        QueryWrapper<EmergencyUser> queryWrapper = new QueryWrapper<>();
+        queryWrapper.in("id", idList);
+
+        // 4. 执行删除（返回是否删除成功）
+        boolean b = emergencyUserService.remove(queryWrapper);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 获取指令下达负责人列表
+     *
+     * @return
+     */
+    @ApiOperation("获取指令下达负责人列表")
+    @PostMapping("/list")
+    public AjaxResult listEmergencyUserByPage() {
+        List<EmergencyUser> list = emergencyUserService.list();
+        // 收集所有用户ID
+        List<Long> userIds = list.stream()
+                .map(emergencyUser -> Long.valueOf(emergencyUser.getUserId()))
+                .collect(Collectors.toList());
+        // 批量查询用户信息
+        List<SysUser> sysUsers = sysUserMapper.selectUsersByIds(userIds);
+
+        // 创建用户ID->昵称的映射
+        Map<Long, String> userNickNameMap = sysUsers.stream()
+                .collect(Collectors.toMap(SysUser::getUserId, SysUser::getNickName));
+
+        List<EmergencyUserVO> emergencyUserVOList = list.stream().map(emergencyUser -> {
+            Integer userId = emergencyUser.getUserId();
+            EmergencyUserVO emergencyUserVO = new EmergencyUserVO();
+            // 从映射中获取昵称
+            String nickName = userNickNameMap.getOrDefault(Long.valueOf(userId), "");
+            emergencyUserVO.setNickName(nickName);
+            emergencyUserVO.setId(emergencyUser.getId());
+            return emergencyUserVO;
+        }).collect(Collectors.toList());
+        return success(emergencyUserVOList);
+
+
+//        List<EmergencyUserVO> emergencyUserVOList = list.stream().map(emergencyUser -> {
+//            Integer userId = emergencyUser.getUserId();
+//            EmergencyUserVO emergencyUserVO = new EmergencyUserVO();
+//            QueryWrapper<SysUser> wrapper = new QueryWrapper<>();
+//            wrapper.select("nick_name")
+//                    .eq("user_id", userId);
+//            SysUser sysUser = sysUserMapper.selectUserById(Long.valueOf(userId));
+//            String nickName = sysUser.getNickName();
+//            emergencyUserVO.setNickName(nickName);
+//            emergencyUserVO.setId(emergencyUser.getId());
+//            return emergencyUserVO;
+//        }).collect(Collectors.toList());
+//        return success(emergencyUserVOList);
+
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EmploymentController.java

@@ -72,7 +72,7 @@ public class EmploymentController {
      */
     @ApiOperation("编辑就业数据")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody EmploymentDataEditRequest employmentDataEditRequest) {
+    public AjaxResult editEmploymentData(@RequestBody EmploymentDataEditRequest employmentDataEditRequest) {
         if (employmentDataEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/EnvironmentWarningController.java

@@ -0,0 +1,116 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.warning.environmentWarning.EnvironmentWarningAddRequest;
+import com.ruoyi.web.domain.dto.warning.environmentWarning.EnvironmentWarningEditRequest;
+import com.ruoyi.web.domain.dto.warning.environmentWarning.EnvironmentWarningQueryRequest;
+import com.ruoyi.web.domain.vo.EnvironmentWarningVO;
+import com.ruoyi.web.service.EnvironmentWarningService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "人居环境预警")
+@RestController
+@RequestMapping("/system/environment/warning")
+public class EnvironmentWarningController {
+
+    @Autowired
+    private EnvironmentWarningService environmentWarningService;
+
+    /**
+     * 添加人居环境预警
+     *
+     * @param environmentWarningAddRequest
+     * @return
+     */
+    @ApiOperation("添加人居环境预警")
+    @PostMapping("/add")
+    public AjaxResult addEnvironmentWarning(@RequestBody EnvironmentWarningAddRequest environmentWarningAddRequest) {
+        if (environmentWarningAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = environmentWarningService.addEnvironmentWarning(environmentWarningAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除人居环境预警
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除人居环境预警")
+    @PostMapping("/delete")
+    public AjaxResult deleteEnvironmentWarning(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = environmentWarningService.deleteEnvironmentWarning(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑人居环境预警
+     *
+     * @param environmentWarningEditRequest
+     * @return
+     */
+    @ApiOperation("编辑人居环境预警")
+    @PostMapping("/edit")
+    public AjaxResult editEnvironmentWarning(@RequestBody EnvironmentWarningEditRequest environmentWarningEditRequest) {
+        if (environmentWarningEditRequest == null) {
+            return error("请求参数为空");
+        }
+        environmentWarningService.editEnvironmentWarning(environmentWarningEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取人居环境预警
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取人居环境预警")
+    @GetMapping("/get")
+    public AjaxResult getEnvironmentWarningById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        EnvironmentWarningVO environmentWarningVO = environmentWarningService.getEnvironmentWarningById(id);
+        return success(environmentWarningVO);
+    }
+
+    /**
+     * 分页获取人居环境预警列表
+     *
+     * @param environmentWarningQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取人居环境预警列表")
+    @PostMapping("/list/page")
+    public AjaxResult listEnvironmentWarningByPage(@RequestBody EnvironmentWarningQueryRequest environmentWarningQueryRequest) {
+        if (environmentWarningQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<EnvironmentWarningVO> listEnvironmentWarningVOByPage = environmentWarningService.getListEnvironmentWarningByPage(environmentWarningQueryRequest);
+        return success(listEnvironmentWarningVOByPage);
+    }
+
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EnvironmentWarningThresholdController.java

@@ -0,0 +1,116 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.environmentWarningThreshold.EnvironmentWarningThresholdAddRequest;
+import com.ruoyi.web.domain.dto.environmentWarningThreshold.EnvironmentWarningThresholdEditRequest;
+import com.ruoyi.web.domain.dto.environmentWarningThreshold.EnvironmentWarningThresholdQueryRequest;
+import com.ruoyi.web.domain.vo.EnvironmentWarningThresholdVO;
+import com.ruoyi.web.service.EnvironmentWarningThresholdService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "人居环境预警阈值设置")
+@RestController
+@RequestMapping("/system/environment/warning/threshold")
+public class EnvironmentWarningThresholdController {
+
+    @Autowired
+    private EnvironmentWarningThresholdService environmentWarningThresholdService;
+
+    /**
+     * 添加人居环境预警阈值
+     *
+     * @param environmentWarningThresholdAddRequest
+     * @return
+     */
+    @ApiOperation("添加人居环境预警阈值")
+    @PostMapping("/add")
+    public AjaxResult addEnvironmentWarningThreshold(@RequestBody EnvironmentWarningThresholdAddRequest environmentWarningThresholdAddRequest) {
+        if (environmentWarningThresholdAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = environmentWarningThresholdService.addEnvironmentWarningThreshold(environmentWarningThresholdAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除人居环境预警阈值
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除人居环境预警阈值")
+    @PostMapping("/delete")
+    public AjaxResult deleteEnvironmentWarningThreshold(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = environmentWarningThresholdService.deleteEnvironmentWarningThreshold(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑人居环境预警阈值
+     *
+     * @param environmentWarningThresholdEditRequest
+     * @return
+     */
+    @ApiOperation("编辑人居环境预警阈值")
+    @PostMapping("/edit")
+    public AjaxResult editEnvironmentWarningThreshold(@RequestBody EnvironmentWarningThresholdEditRequest environmentWarningThresholdEditRequest) {
+        if (environmentWarningThresholdEditRequest == null) {
+            return error("请求参数为空");
+        }
+        environmentWarningThresholdService.editEnvironmentWarningThreshold(environmentWarningThresholdEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取人居环境预警阈值
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取人居环境预警阈值")
+    @GetMapping("/get")
+    public AjaxResult getEnvironmentWarningThresholdById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        EnvironmentWarningThresholdVO environmentWarningThresholdVO = environmentWarningThresholdService.getEnvironmentWarningThresholdById(id);
+        return success(environmentWarningThresholdVO);
+    }
+
+    /**
+     * 获取人居环境预警阈值列表
+     *
+     * @param environmentWarningThresholdQueryRequest
+     * @return
+     */
+    @ApiOperation("获取人居环境预警阈值列表")
+    @PostMapping("/list")
+    public AjaxResult listEnvironmentWarningThresholdByPage(@RequestBody EnvironmentWarningThresholdQueryRequest environmentWarningThresholdQueryRequest) {
+        if (environmentWarningThresholdQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        List<EnvironmentWarningThresholdVO> listEnvironmentWarningThreshold = environmentWarningThresholdService.getListEnvironmentWarningThreshold(environmentWarningThresholdQueryRequest);
+        return success(listEnvironmentWarningThreshold);
+    }
+
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EnvironmentWarningThresholdRoleController.java

@@ -0,0 +1,115 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.web.domain.dto.environmentWarningThresholdRole.EnvironmentWarningThresholdRoleAddRequest;
+import com.ruoyi.web.domain.dto.environmentWarningThresholdRole.EnvironmentWarningThresholdRoleEditRequest;
+import com.ruoyi.web.domain.dto.environmentWarningThresholdRole.EnvironmentWarningThresholdRoleQueryRequest;
+import com.ruoyi.web.domain.entity.EnvironmentWarningThresholdRole;
+import com.ruoyi.web.service.EnvironmentWarningThresholdRoleService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "人居环境负责人类型管理")
+@RestController
+@RequestMapping("/system/environmentWarning/warning/threshold/role")
+public class EnvironmentWarningThresholdRoleController {
+
+    @Autowired
+    private EnvironmentWarningThresholdRoleService environmentWarningThresholdRoleService;
+
+    /**
+     * 添加人居环境负责人类型
+     *
+     * @param environmentWarningThresholdRoleAddRequest
+     * @return
+     */
+    @ApiOperation("添加人居环境负责人类型")
+    @PostMapping("/add")
+    public AjaxResult addEnvironmentWarningThresholdRole(@RequestBody EnvironmentWarningThresholdRoleAddRequest environmentWarningThresholdRoleAddRequest) {
+        if (environmentWarningThresholdRoleAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = environmentWarningThresholdRoleService.addEnvironmentWarningThresholdRole(environmentWarningThresholdRoleAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除人居环境负责人类型
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除人居环境负责人类型")
+    @PostMapping("/delete")
+    public AjaxResult deleteEnvironmentWarningThresholdRole(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = environmentWarningThresholdRoleService.deleteEnvironmentWarningThresholdRole(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+    /**
+     * 编辑人居环境负责人类型
+     *
+     * @param environmentWarningThresholdRoleEditRequest
+     * @return
+     */
+    @ApiOperation("编辑人居环境负责人类型")
+    @PostMapping("/edit")
+    public AjaxResult editEnvironmentWarningThresholdRole(@RequestBody EnvironmentWarningThresholdRoleEditRequest environmentWarningThresholdRoleEditRequest) {
+        if (environmentWarningThresholdRoleEditRequest == null) {
+            return error("请求参数为空");
+        }
+        environmentWarningThresholdRoleService.editEnvironmentWarningThresholdRole(environmentWarningThresholdRoleEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取人居环境负责人类型
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取人居环境负责人类型")
+    @GetMapping("/get")
+    public AjaxResult getEnvironmentWarningThresholdRoleById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        EnvironmentWarningThresholdRole environmentWarningThresholdRoleById = environmentWarningThresholdRoleService.getEnvironmentWarningThresholdRoleById(id);
+        return success(environmentWarningThresholdRoleById);
+    }
+
+
+    /**
+     * 获取人居环境负责人类型列表
+     *
+     * @return
+     */
+    @ApiOperation("获取人居环境负责人类型列表")
+    @PostMapping("/list")
+    public AjaxResult listEnvironmentWarningThresholdRoleByPage(@RequestBody EnvironmentWarningThresholdRoleQueryRequest environmentWarningThresholdRoleQueryRequest) {
+        if (environmentWarningThresholdRoleQueryRequest == null) {
+            throw new ServiceException("请求参数未空");
+        }
+        List<EnvironmentWarningThresholdRole> list = environmentWarningThresholdRoleService.getListEnvironmentWarningThresholdRole(environmentWarningThresholdRoleQueryRequest);
+        return success(list);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EnvironmentWarningThresholdUserController.java

@@ -0,0 +1,116 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.environmentWarningThresholdRole.EnvironmentWarningThresholdUserAddRequest;
+import com.ruoyi.web.domain.dto.environmentWarningThresholdRole.EnvironmentWarningThresholdUserEditRequest;
+import com.ruoyi.web.domain.dto.environmentWarningThresholdRole.EnvironmentWarningThresholdUserQueryRequest;
+import com.ruoyi.web.domain.vo.EnvironmentWarningThresholdUserVO;
+import com.ruoyi.web.service.EnvironmentWarningThresholdUserService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "人居环境负责人管理")
+@RestController
+@RequestMapping("/system/environmentWarning/warning/threshold/user")
+public class EnvironmentWarningThresholdUserController {
+
+    @Autowired
+    private EnvironmentWarningThresholdUserService environmentWarningThresholdUserService;
+
+    /**
+     * 添加人居环境负责人
+     *
+     * @param environmentWarningThresholdUserAddRequest
+     * @return
+     */
+    @ApiOperation("添加人居环境负责人")
+    @PostMapping("/add")
+    public AjaxResult addEnvironmentWarningThresholdUser(@RequestBody EnvironmentWarningThresholdUserAddRequest environmentWarningThresholdUserAddRequest) {
+        if (environmentWarningThresholdUserAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = environmentWarningThresholdUserService.addEnvironmentWarningThresholdUser(environmentWarningThresholdUserAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除人居环境负责人
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除人居环境负责人")
+    @PostMapping("/delete")
+    public AjaxResult deleteEnvironmentWarningThresholdUser(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = environmentWarningThresholdUserService.deleteEnvironmentWarningThresholdUser(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑人居环境负责人
+     *
+     * @param environmentWarningThresholdUserEditRequest
+     * @return
+     */
+    @ApiOperation("编辑人居环境负责人")
+    @PostMapping("/edit")
+    public AjaxResult editEnvironmentWarningThresholdUser(@RequestBody EnvironmentWarningThresholdUserEditRequest environmentWarningThresholdUserEditRequest) {
+        if (environmentWarningThresholdUserEditRequest == null) {
+            return error("请求参数为空");
+        }
+        environmentWarningThresholdUserService.editEnvironmentWarningThresholdUser(environmentWarningThresholdUserEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取人居环境负责人
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取人居环境负责人")
+    @GetMapping("/get")
+    public AjaxResult getEnvironmentWarningThresholdUserById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        EnvironmentWarningThresholdUserVO environmentWarningThresholdUserVO = environmentWarningThresholdUserService.getEnvironmentWarningThresholdUserVOById(id);
+        return success(environmentWarningThresholdUserVO);
+    }
+
+    /**
+     * 获取人居环境负责人列表
+     *
+     * @param environmentWarningThresholdUserQueryRequest
+     * @return
+     */
+    @ApiOperation("获取人居环境负责人列表")
+    @PostMapping("/list")
+    public AjaxResult getListEnvironmentWarningThresholdUser(@RequestBody EnvironmentWarningThresholdUserQueryRequest environmentWarningThresholdUserQueryRequest) {
+        if (environmentWarningThresholdUserQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        List<EnvironmentWarningThresholdUserVO> listEnvironmentWarningThresholdUserVO = environmentWarningThresholdUserService.getListEnvironmentWarningThresholdUserVO(environmentWarningThresholdUserQueryRequest);
+        return success(listEnvironmentWarningThresholdUserVO);
+    }
+
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/EthnicActivitiesController.java

@@ -70,7 +70,7 @@ public class EthnicActivitiesController {
      */
     @ApiOperation("编辑民族团结活动数据")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody EthnicActivitiesEditRequest ethnicActivitiesEditRequest) {
+    public AjaxResult editEthnicActivities(@RequestBody EthnicActivitiesEditRequest ethnicActivitiesEditRequest) {
         if (ethnicActivitiesEditRequest == null) {
             throw new ServiceException("参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/HouseInfoController.java

@@ -72,7 +72,7 @@ public class HouseInfoController {
      */
     @ApiOperation("编辑房屋")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody HouseInfoEditRequest houseInfoEditRequest) {
+    public AjaxResult editHouseInfo(@RequestBody HouseInfoEditRequest houseInfoEditRequest) {
         if (houseInfoEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/IndustryController.java

@@ -72,7 +72,7 @@ public class IndustryController {
      */
     @ApiOperation("编辑产业数据")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody IndustryDataEditRequest industryDataEditRequest) {
+    public AjaxResult editIndustryData(@RequestBody IndustryDataEditRequest industryDataEditRequest) {
         if (industryDataEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/LocalPolicyController.java

@@ -76,7 +76,7 @@ public class LocalPolicyController {
      */
     @ApiOperation("编辑当地政策")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody LocalPolicyEditRequest localPolicyEditRequest) {
+    public AjaxResult editLocalPolicy(@RequestBody LocalPolicyEditRequest localPolicyEditRequest) {
         if (localPolicyEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/LotEnvironmentController.java

@@ -0,0 +1,115 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.lotEnvironment.LotEnvironmentAddRequest;
+import com.ruoyi.web.domain.dto.lotEnvironment.LotEnvironmentEditRequest;
+import com.ruoyi.web.domain.dto.lotEnvironment.LotEnvironmentQueryRequest;
+import com.ruoyi.web.domain.vo.LotEnvironmentVO;
+import com.ruoyi.web.service.LotEnvironmentService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "物联网实时数据人居环境监测")
+@RestController
+@RequestMapping("/system/lot/environment")
+public class LotEnvironmentController {
+
+    @Autowired
+    private LotEnvironmentService lotEnvironmentService;
+
+    /**
+     * 添加物联网实时数据人居环境监测
+     *
+     * @param lotEnvironmentAddRequest
+     * @return
+     */
+    @ApiOperation("添加物联网实时数据人居环境监测")
+    @PostMapping("/add")
+    public AjaxResult addLotEnvironment(@RequestBody LotEnvironmentAddRequest lotEnvironmentAddRequest) {
+        if (lotEnvironmentAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = lotEnvironmentService.addLotEnvironment(lotEnvironmentAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除物联网实时数据人居环境监测
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除物联网实时数据人居环境监测")
+    @PostMapping("/delete")
+    public AjaxResult deleteLotEnvironment(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = lotEnvironmentService.deleteLotEnvironment(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑物联网实时数据人居环境监测
+     *
+     * @param lotEnvironmentEditRequest
+     * @return
+     */
+    @ApiOperation("编辑物联网实时数据人居环境监测")
+    @PostMapping("/edit")
+    public AjaxResult editLotEnvironment(@RequestBody LotEnvironmentEditRequest lotEnvironmentEditRequest) {
+        if (lotEnvironmentEditRequest == null) {
+            return error("请求参数为空");
+        }
+        lotEnvironmentService.editLotEnvironment(lotEnvironmentEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取物联网实时数据人居环境监测
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取物联网实时数据人居环境监测")
+    @GetMapping("/get")
+    public AjaxResult getLotEnvironmentById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        LotEnvironmentVO lotEnvironmentVO = lotEnvironmentService.getLotEnvironmentById(id);
+        return success(lotEnvironmentVO);
+    }
+
+    /**
+     * 分页获取物联网实时数据人居环境监测列表
+     *
+     * @param lotEnvironmentQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取物联网实时数据人居环境监测列表")
+    @PostMapping("/list/page")
+    public AjaxResult listLotEnvironmentByPage(@RequestBody LotEnvironmentQueryRequest lotEnvironmentQueryRequest) {
+        if (lotEnvironmentQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<LotEnvironmentVO> listLotEnvironmentVOByPage = lotEnvironmentService.getListLotEnvironmentByPage(lotEnvironmentQueryRequest);
+        return success(listLotEnvironmentVOByPage);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/LotPlatformDeviceController.java

@@ -0,0 +1,116 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.lotPlatFormDevice.LotPlatformDeviceAddRequest;
+import com.ruoyi.web.domain.dto.lotPlatFormDevice.LotPlatformDeviceEditRequest;
+import com.ruoyi.web.domain.dto.lotPlatFormDevice.LotPlatformDeviceQueryRequest;
+import com.ruoyi.web.domain.vo.LotPlatformDeviceVO;
+import com.ruoyi.web.service.LotPlatformDeviceService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "物联网平台设备")
+@RestController
+@RequestMapping("/system/lot/platform/device")
+public class LotPlatformDeviceController {
+
+    @Autowired
+    private LotPlatformDeviceService lotPlatformDeviceService;
+
+    /**
+     * 添加物联网平台设备
+     *
+     * @param lotPlatformDeviceAddRequest
+     * @return
+     */
+    @ApiOperation("添加物联网平台设备")
+    @PostMapping("/add")
+    public AjaxResult addLotPlatformDevice(@RequestBody LotPlatformDeviceAddRequest lotPlatformDeviceAddRequest) {
+        if (lotPlatformDeviceAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = lotPlatformDeviceService.addLotPlatformDevice(lotPlatformDeviceAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除物联网平台设备
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除物联网平台设备")
+    @PostMapping("/delete")
+    public AjaxResult deleteLotPlatformDevice(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = lotPlatformDeviceService.deleteLotPlatformDevice(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑物联网平台设备
+     *
+     * @param lotPlatformDeviceEditRequest
+     * @return
+     */
+    @ApiOperation("编辑物联网平台设备")
+    @PostMapping("/edit")
+    public AjaxResult editLotPlatformDevice(@RequestBody LotPlatformDeviceEditRequest lotPlatformDeviceEditRequest) {
+        if (lotPlatformDeviceEditRequest == null) {
+            return error("请求参数为空");
+        }
+        lotPlatformDeviceService.editLotPlatformDevice(lotPlatformDeviceEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取物联网平台设备
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取物联网平台设备")
+    @GetMapping("/get")
+    public AjaxResult getLotPlatformDeviceById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        LotPlatformDeviceVO lotPlatformDeviceVO = lotPlatformDeviceService.getLotPlatformDeviceById(id);
+        return success(lotPlatformDeviceVO);
+    }
+
+    /**
+     * 分页获取物联网平台设备列表
+     *
+     * @param lotPlatformDeviceQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取物联网平台设备列表")
+    @PostMapping("/list/page")
+    public AjaxResult listLotPlatformDeviceByPage(@RequestBody LotPlatformDeviceQueryRequest lotPlatformDeviceQueryRequest) {
+        if (lotPlatformDeviceQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<LotPlatformDeviceVO> listLotPlatformDeviceVOByPage = lotPlatformDeviceService.getListLotPlatformDeviceByPage(lotPlatformDeviceQueryRequest);
+        return success(listLotPlatformDeviceVOByPage);
+    }
+
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/LotPlatformProductsController.java

@@ -0,0 +1,116 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.lotPlatformProducts.LotPlatformProductsAddRequest;
+import com.ruoyi.web.domain.dto.lotPlatformProducts.LotPlatformProductsEditRequest;
+import com.ruoyi.web.domain.dto.lotPlatformProducts.LotPlatformProductsQueryRequest;
+import com.ruoyi.web.domain.vo.LotPlatformProductsVO;
+import com.ruoyi.web.service.LotPlatformProductsService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "物联网平台产品")
+@RestController
+@RequestMapping("/system/lot/platform/products")
+public class LotPlatformProductsController {
+
+    @Autowired
+    private LotPlatformProductsService lotPlatformProductsService;
+
+    /**
+     * 添加物联网平台产品
+     *
+     * @param lotPlatformProductsAddRequest
+     * @return
+     */
+    @ApiOperation("添加物联网平台产品")
+    @PostMapping("/add")
+    public AjaxResult addLotPlatformProducts(@RequestBody LotPlatformProductsAddRequest lotPlatformProductsAddRequest) {
+        if (lotPlatformProductsAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = lotPlatformProductsService.addLotPlatformProducts(lotPlatformProductsAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除物联网平台产品
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除物联网平台产品")
+    @PostMapping("/delete")
+    public AjaxResult deleteLotPlatformProducts(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = lotPlatformProductsService.deleteLotPlatformProducts(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑物联网平台产品
+     *
+     * @param lotPlatformProductsEditRequest
+     * @return
+     */
+    @ApiOperation("编辑物联网平台产品")
+    @PostMapping("/edit")
+    public AjaxResult editLotPlatformProducts(@RequestBody LotPlatformProductsEditRequest lotPlatformProductsEditRequest) {
+        if (lotPlatformProductsEditRequest == null) {
+            return error("请求参数为空");
+        }
+        lotPlatformProductsService.editLotPlatformProducts(lotPlatformProductsEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取物联网平台产品
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取物联网平台产品")
+    @GetMapping("/get")
+    public AjaxResult getLotPlatformProductsById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        LotPlatformProductsVO lotPlatformProductsVO = lotPlatformProductsService.getLotPlatformProductsById(id);
+        return success(lotPlatformProductsVO);
+    }
+
+    /**
+     * 分页获取物联网平台产品列表
+     *
+     * @param lotPlatformProductsQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取物联网平台产品列表")
+    @PostMapping("/list/page")
+    public AjaxResult listLotPlatformProductsByPage(@RequestBody LotPlatformProductsQueryRequest lotPlatformProductsQueryRequest) {
+        if (lotPlatformProductsQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<LotPlatformProductsVO> listLotPlatformProductsVOByPage = lotPlatformProductsService.getListLotPlatformProductsByPage(lotPlatformProductsQueryRequest);
+        return success(listLotPlatformProductsVOByPage);
+    }
+
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/LotVideoController.java

@@ -0,0 +1,115 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.lotVideo.LotVideoAddRequest;
+import com.ruoyi.web.domain.dto.lotVideo.LotVideoEditRequest;
+import com.ruoyi.web.domain.dto.lotVideo.LotVideoQueryRequest;
+import com.ruoyi.web.domain.vo.LotVideoVO;
+import com.ruoyi.web.service.LotVideoService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "物联网实时数据视频监控")
+@RestController
+@RequestMapping("/system/lot/video")
+public class LotVideoController {
+
+    @Autowired
+    private LotVideoService lotVideoService;
+
+    /**
+     * 添加物联网实时数据视频监控
+     *
+     * @param lotVideoAddRequest
+     * @return
+     */
+    @ApiOperation("添加物联网实时数据视频监控")
+    @PostMapping("/add")
+    public AjaxResult addLotVideo(@RequestBody LotVideoAddRequest lotVideoAddRequest) {
+        if (lotVideoAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = lotVideoService.addLotVideo(lotVideoAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除物联网实时数据视频监控
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除物联网实时数据视频监控")
+    @PostMapping("/delete")
+    public AjaxResult deleteLotVideo(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = lotVideoService.deleteLotVideo(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑物联网实时数据视频监控
+     *
+     * @param lotVideoEditRequest
+     * @return
+     */
+    @ApiOperation("编辑物联网实时数据视频监控")
+    @PostMapping("/edit")
+    public AjaxResult editLotVideo(@RequestBody LotVideoEditRequest lotVideoEditRequest) {
+        if (lotVideoEditRequest == null) {
+            return error("请求参数为空");
+        }
+        lotVideoService.editLotVideo(lotVideoEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取物联网实时数据视频监控
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取物联网实时数据视频监控")
+    @GetMapping("/get")
+    public AjaxResult getLotVideoById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        LotVideoVO lotVideoVO = lotVideoService.getLotVideoById(id);
+        return success(lotVideoVO);
+    }
+
+    /**
+     * 分页获取物联网实时数据视频监控列表
+     *
+     * @param lotVideoQueryRequest
+     * @return
+     */
+    @ApiOperation("分页获取物联网实时数据视频监控列表")
+    @PostMapping("/list/page")
+    public AjaxResult listLotVideoByPage(@RequestBody LotVideoQueryRequest lotVideoQueryRequest) {
+        if (lotVideoQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        Page<LotVideoVO> listLotVideoVOByPage = lotVideoService.getListLotVideoByPage(lotVideoQueryRequest);
+        return success(listLotVideoVOByPage);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/ProjectsController.java

@@ -74,7 +74,7 @@ public class ProjectsController {
      */
     @ApiOperation("编辑项目")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody ProjectsEditRequest projectsEditRequest) {
+    public AjaxResult editProjects(@RequestBody ProjectsEditRequest projectsEditRequest) {
         if (projectsEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/SubsidyProjectsController.java

@@ -72,7 +72,7 @@ public class SubsidyProjectsController {
      */
     @ApiOperation("编辑惠农补贴项目")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody SubsidyProjectsEditRequest subsidyProjectsEditRequest) {
+    public AjaxResult editSubsidyProjects(@RequestBody SubsidyProjectsEditRequest subsidyProjectsEditRequest) {
         if (subsidyProjectsEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/VillageCommitteeRoleController.java

@@ -0,0 +1,115 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.web.domain.dto.villageCommitteeRole.VillageCommitteeRoleAddRequest;
+import com.ruoyi.web.domain.dto.villageCommitteeRole.VillageCommitteeRoleEditRequest;
+import com.ruoyi.web.domain.dto.villageCommitteeRole.VillageCommitteeRoleQueryRequest;
+import com.ruoyi.web.domain.entity.VillageCommitteeRole;
+import com.ruoyi.web.service.VillageCommitteeRoleService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "村委类型管理")
+@RestController
+@RequestMapping("/system/village/committee/role")
+public class VillageCommitteeRoleController {
+
+    @Autowired
+    private VillageCommitteeRoleService villageCommitteeRoleService;
+
+    /**
+     * 添加村委类型
+     *
+     * @param villageCommitteeRoleAddRequest
+     * @return
+     */
+    @ApiOperation("添加村委类型")
+    @PostMapping("/add")
+    public AjaxResult addVillageCommitteeRole(@RequestBody VillageCommitteeRoleAddRequest villageCommitteeRoleAddRequest) {
+        if (villageCommitteeRoleAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = villageCommitteeRoleService.addVillageCommitteeRole(villageCommitteeRoleAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除村委类型
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除村委类型")
+    @PostMapping("/delete")
+    public AjaxResult deleteVillageCommitteeRole(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = villageCommitteeRoleService.deleteVillageCommitteeRole(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+    /**
+     * 编辑村委类型
+     *
+     * @param villageCommitteeRoleEditRequest
+     * @return
+     */
+    @ApiOperation("编辑村委类型")
+    @PostMapping("/edit")
+    public AjaxResult editVillageCommitteeRole(@RequestBody VillageCommitteeRoleEditRequest villageCommitteeRoleEditRequest) {
+        if (villageCommitteeRoleEditRequest == null) {
+            return error("请求参数为空");
+        }
+        villageCommitteeRoleService.editVillageCommitteeRole(villageCommitteeRoleEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取村委类型
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取村委类型")
+    @GetMapping("/get")
+    public AjaxResult getVillageCommitteeRoleById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        VillageCommitteeRole villageCommitteeRoleById = villageCommitteeRoleService.getVillageCommitteeRoleById(id);
+        return success(villageCommitteeRoleById);
+    }
+
+
+    /**
+     * 获取村委类型列表
+     *
+     * @return
+     */
+    @ApiOperation("获取村委类型列表")
+    @PostMapping("/list")
+    public AjaxResult listVillageCommitteeRoleByPage(@RequestBody VillageCommitteeRoleQueryRequest villageCommitteeRoleQueryRequest) {
+        if (villageCommitteeRoleQueryRequest == null) {
+            throw new ServiceException("请求参数未空");
+        }
+        List<VillageCommitteeRole> list = villageCommitteeRoleService.getListVillageCommitteeRole(villageCommitteeRoleQueryRequest);
+        return success(list);
+    }
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/VillageCommitteeRoleUserController.java

@@ -0,0 +1,116 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.villageCommitteeRole.VillageCommitteeRoleUserAddRequest;
+import com.ruoyi.web.domain.dto.villageCommitteeRole.VillageCommitteeRoleUserEditRequest;
+import com.ruoyi.web.domain.dto.villageCommitteeRole.VillageCommitteeRoleUserQueryRequest;
+import com.ruoyi.web.domain.vo.VillageCommitteeRoleUserVO;
+import com.ruoyi.web.service.VillageCommitteeRoleUserService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.Map;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "村委管理")
+@RestController
+@RequestMapping("/system/village/committee/role/user")
+public class VillageCommitteeRoleUserController {
+
+    @Autowired
+    private VillageCommitteeRoleUserService villageCommitteeRoleUserService;
+
+    /**
+     * 添加村委
+     *
+     * @param villageCommitteeRoleUserAddRequest
+     * @return
+     */
+    @ApiOperation("添加村委")
+    @PostMapping("/add")
+    public AjaxResult addVillageCommitteeRoleUser(@RequestBody VillageCommitteeRoleUserAddRequest villageCommitteeRoleUserAddRequest) {
+        if (villageCommitteeRoleUserAddRequest == null) {
+            return error("请求参数为空");
+        }
+        Integer id = villageCommitteeRoleUserService.addVillageCommitteeRoleUser(villageCommitteeRoleUserAddRequest);
+        return success(id);
+    }
+
+    /**
+     * 删除村委
+     *
+     * @param paramsMap
+     * @return
+     */
+    @ApiOperation("删除村委")
+    @PostMapping("/delete")
+    public AjaxResult deleteVillageCommitteeRoleUser(@RequestBody Map<String, String> paramsMap) {
+        String ids = paramsMap.get("ids");
+        if (StrUtil.isBlank(ids)) {
+            return error("请求参数为空");
+        }
+        boolean b = villageCommitteeRoleUserService.deleteVillageCommitteeRoleUser(ids);
+        if (b) {
+            return success("删除成功");
+        }
+        return error("删除失败");
+    }
+
+
+    /**
+     * 编辑村委
+     *
+     * @param villageCommitteeRoleUserEditRequest
+     * @return
+     */
+    @ApiOperation("编辑村委")
+    @PostMapping("/edit")
+    public AjaxResult editVillageCommitteeRoleUser(@RequestBody VillageCommitteeRoleUserEditRequest villageCommitteeRoleUserEditRequest) {
+        if (villageCommitteeRoleUserEditRequest == null) {
+            return error("请求参数为空");
+        }
+        villageCommitteeRoleUserService.editVillageCommitteeRoleUser(villageCommitteeRoleUserEditRequest);
+        return AjaxResult.success();
+    }
+
+
+    /**
+     * 根据id获取村委
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation("根据id获取村委")
+    @GetMapping("/get")
+    public AjaxResult getVillageCommitteeRoleUserById(@RequestParam int id) {
+        if (ObjectUtil.isEmpty(id)) {
+            return error("请求参数为空");
+        }
+        VillageCommitteeRoleUserVO villageCommitteeRoleUserVO = villageCommitteeRoleUserService.getVillageCommitteeRoleUserVOById(id);
+        return success(villageCommitteeRoleUserVO);
+    }
+
+    /**
+     * 获取村委列表
+     *
+     * @param villageCommitteeRoleUserQueryRequest
+     * @return
+     */
+    @ApiOperation("获取村委列表")
+    @PostMapping("/list")
+    public AjaxResult getListVillageCommitteeRoleUser(@RequestBody VillageCommitteeRoleUserQueryRequest villageCommitteeRoleUserQueryRequest) {
+        if (villageCommitteeRoleUserQueryRequest == null) {
+            return error("请求参数为空");
+        }
+        List<VillageCommitteeRoleUserVO> listVillageCommitteeRoleUserVO = villageCommitteeRoleUserService.getListVillageCommitteeRoleUserVO(villageCommitteeRoleUserQueryRequest);
+        return success(listVillageCommitteeRoleUserVO);
+    }
+
+}

app-admin/src/main/java/com/ruoyi/web/controller/system/VillageProfileController.java

@@ -73,7 +73,7 @@ public class VillageProfileController extends BaseController {
      */
     @ApiOperation("编辑村庄")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody VillageProfileEditRequest villageProfileEditRequest) {
+    public AjaxResult editVillageProfile(@RequestBody VillageProfileEditRequest villageProfileEditRequest) {
         if (villageProfileEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/VillageSpecialController.java

@@ -74,7 +74,7 @@ public class VillageSpecialController {
      */
     @ApiOperation("编辑特色产业")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody VillageSpecialEditRequest villageSpecialEditRequest) {
+    public AjaxResult editVillageSpecial(@RequestBody VillageSpecialEditRequest villageSpecialEditRequest) {
         if (villageSpecialEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/VillageTraditionController.java

@@ -72,7 +72,7 @@ public class VillageTraditionController {
      */
     @ApiOperation("编辑传统产业")
     @PostMapping("/edit")
-    public AjaxResult editFacility(@RequestBody VillageTraditionEditRequest villageTraditionEditRequest) {
+    public AjaxResult editVillageTradition(@RequestBody VillageTraditionEditRequest villageTraditionEditRequest) {
         if (villageTraditionEditRequest == null) {
             return error("请求参数为空");
         }

app-admin/src/main/java/com/ruoyi/web/controller/system/WarningController.java

@@ -0,0 +1,75 @@
+package com.ruoyi.web.controller.system;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.web.domain.dto.warning.WarningReleaseRequest;
+import com.ruoyi.web.domain.dto.warning.drowningWarning.DrowningWarningAddRequest;
+import com.ruoyi.web.domain.dto.warning.earthquakeWarning.EarthquakeWarningAddRequest;
+import com.ruoyi.web.domain.dto.warning.environmentWarning.EnvironmentWarningAddRequest;
+import com.ruoyi.web.service.DrowningWarningService;
+import com.ruoyi.web.service.EarthquakeWarningService;
+import com.ruoyi.web.service.EnvironmentWarningService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import static com.ruoyi.common.core.domain.AjaxResult.error;
+import static com.ruoyi.common.core.domain.AjaxResult.success;
+
+@Api(tags = "预警信息发布")
+@RestController
+@RequestMapping("/system/warning")
+public class WarningController {
+
+    @Autowired
+    private EarthquakeWarningService earthquakeWarningService;
+
+    @Autowired
+    private EnvironmentWarningService environmentWarningService;
+
+    @Autowired
+    private DrowningWarningService drowningWarningService;
+
+    /**
+     * 发布预警信息
+     *
+     * @param warningReleaseRequest
+     * @return
+     */
+    @ApiOperation("发布预警信息")
+    @PostMapping("/release")
+    public AjaxResult addDrowningWarning(@RequestBody WarningReleaseRequest warningReleaseRequest) {
+        if (warningReleaseRequest == null) {
+            return error("请求参数为空");
+        }
+        String type = warningReleaseRequest.getType();
+        if (type == null) {
+            return error("类别为空");
+        }
+        //类别 0-地震预警、1-人居环境预警、2-防溺水预警
+        switch (type) {
+            case "0":
+                EarthquakeWarningAddRequest earthquakeWarningAddRequest = new EarthquakeWarningAddRequest();
+                BeanUtil.copyProperties(warningReleaseRequest, earthquakeWarningAddRequest);
+                earthquakeWarningService.addEarthquakeWarning(earthquakeWarningAddRequest);
+                break;
+            case "1":
+                EnvironmentWarningAddRequest environmentWarningAddRequest = new EnvironmentWarningAddRequest();
+                BeanUtil.copyProperties(warningReleaseRequest, environmentWarningAddRequest);
+                environmentWarningService.addEnvironmentWarning(environmentWarningAddRequest);
+                break;
+            case "2":
+                DrowningWarningAddRequest drowningWarningAddRequest = new DrowningWarningAddRequest();
+                BeanUtil.copyProperties(warningReleaseRequest, drowningWarningAddRequest);
+                drowningWarningService.addDrowningWarning(drowningWarningAddRequest);
+                break;
+            default:
+                return error("发布失败");
+        }
+        return success("发布成功");
+    }
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/cloudBroadcasting/CloudBroadcastingQueryRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.cloudBroadcasting;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 联动云广播查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "CloudBroadcastingQueryRequest", description = "联动云广播查询请求")
+public class CloudBroadcastingQueryRequest extends PageRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 呼叫开始日期
+     */
+    private Date startTime;
+
+    /**
+     * 呼叫结束日期
+     */
+    private Date endTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/emergency/EmergencyAddRequest.java

@@ -0,0 +1,54 @@
+package com.ruoyi.web.domain.dto.emergency;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 应急指令下达添加请求
+ *
+ * @TableName
+ */
+@Data
+@ApiModel(value = "EmergencyAddRequest", description = "应急指令下达添加请求")
+public class EmergencyAddRequest implements Serializable {
+
+    /**
+     * 事发时间
+     */
+    private Date occurTime;
+
+    /**
+     * 事件名称
+     */
+    private String name;
+
+    /**
+     * 事发地点
+     */
+    private String location;
+
+    /**
+     * 调度要求
+     */
+    private String requirement;
+
+    /**
+     * 接收对象person_ids
+     */
+    private String receivePersonIds;
+
+    /**
+     * 负责人ID(默认本用户)
+     */
+    private Integer userId;
+
+    /**
+     * 发布状态 0-未下达 1-已下达
+     */
+    private Integer status;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/emergency/EmergencyEditRequest.java

@@ -0,0 +1,56 @@
+package com.ruoyi.web.domain.dto.emergency;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 应急指令下达编辑请求
+ *
+ * @TableName
+ */
+@Data
+@ApiModel(value = "EmergencyEditRequest", description = "应急指令下达编辑请求")
+public class EmergencyEditRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 事发时间
+     */
+    private Date occurTime;
+
+    /**
+     * 事件名称
+     */
+    private String name;
+
+    /**
+     * 事发地点
+     */
+    private String location;
+
+    /**
+     * 调度要求
+     */
+    private String requirement;
+
+    /**
+     * 接收对象person_ids
+     */
+    private String receivePersonIds;
+
+    /**
+     * 负责人ID(默认本用户)
+     */
+    private Integer userId;
+
+    /**
+     * 发布状态 0-未下达 1-已下达
+     */
+    private Integer status;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/emergency/EmergencyQueryRequest.java

@@ -0,0 +1,32 @@
+package com.ruoyi.web.domain.dto.emergency;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 应急指令下达查询请求
+ */
+@ApiModel(value = "EmergencyQueryRequest", description = "应急指令下达查询请求")
+@EqualsAndHashCode(callSuper = true)
+@Data
+public class EmergencyQueryRequest extends PageRequest implements Serializable {
+    /**
+     * 事发开始时间
+     */
+    private Date startTime;
+
+    /**
+     * 事发结束时间
+     */
+    private Date endTime;
+
+    /**
+     * 事发地点
+     */
+    private String location;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/emergency/EmergencyRevokeRequest.java

@@ -0,0 +1,20 @@
+package com.ruoyi.web.domain.dto.emergency;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 应急指令下达撤回请求
+ *
+ * @TableName
+ */
+@Data
+@ApiModel(value = "EmergencyRevokeRequest", description = "应急指令下达撤回请求")
+public class EmergencyRevokeRequest implements Serializable {
+
+    private Integer id;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/emergencyUser/EmergencyUserAddRequest.java

@@ -0,0 +1,19 @@
+package com.ruoyi.web.domain.dto.emergencyUser;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+/**
+ * 指令下达负责人添加请求
+ *
+ * @TableName
+ */
+@Data
+@ApiModel(value = "EmergencyUserAddRequest", description = "指令下达负责人添加请求")
+public class EmergencyUserAddRequest {
+
+    /**
+     * 负责人id (人口表id)
+     */
+    private Integer personId;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThreshold/EnvironmentWarningThresholdAddRequest.java

@@ -0,0 +1,36 @@
+package com.ruoyi.web.domain.dto.environmentWarningThreshold;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值添加请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdAddRequest", description = "人居环境预警阈值添加请求")
+public class EnvironmentWarningThresholdAddRequest implements Serializable {
+
+    /**
+     * 环境类型id
+     */
+    private String typeId;
+
+    /**
+     * 预警等级：1-一级/2-二级/3-三级/4-四级
+     */
+    private Integer level;
+
+    /**
+     * 下限
+     */
+    private String low;
+
+    /**
+     * 上限
+     */
+    private String high;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThreshold/EnvironmentWarningThresholdEditRequest.java

@@ -0,0 +1,40 @@
+package com.ruoyi.web.domain.dto.environmentWarningThreshold;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值编辑请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdEditRequest", description = "人居环境预警阈值编辑请求")
+public class EnvironmentWarningThresholdEditRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 环境类型id
+     */
+    private String typeId;
+
+    /**
+     * 预警等级：1-一级/2-二级/3-三级/4-四级
+     */
+    private Integer level;
+
+    /**
+     * 下限
+     */
+    private String low;
+
+    /**
+     * 上限
+     */
+    private String high;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThreshold/EnvironmentWarningThresholdQueryRequest.java

@@ -0,0 +1,40 @@
+package com.ruoyi.web.domain.dto.environmentWarningThreshold;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值查询请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdQueryRequest", description = "人居环境预警阈值查询请求")
+public class EnvironmentWarningThresholdQueryRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 环境类型id
+     */
+    private String typeId;
+
+//    /**
+//     * 预警等级：1-一级/2-二级/3-三级/4-四级
+//     */
+//    private Integer level;
+
+//    /**
+//     * 下限
+//     */
+//    private String low;
+//
+//    /**
+//     * 上限
+//     */
+//    private String high;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThresholdRole/EnvironmentWarningThresholdRoleAddRequest.java

@@ -0,0 +1,23 @@
+package com.ruoyi.web.domain.dto.environmentWarningThresholdRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人角色添加请求
+ *
+ * @TableName environment_warning_threshold_role
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdRoleAddRequest", description = "人居环境预警阈值负责人角色添加请求")
+public class EnvironmentWarningThresholdRoleAddRequest implements Serializable {
+
+    /**
+     * 环境类型名称
+     */
+    private String type;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThresholdRole/EnvironmentWarningThresholdRoleEditRequest.java

@@ -0,0 +1,23 @@
+package com.ruoyi.web.domain.dto.environmentWarningThresholdRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人角色编辑请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdRoleEditRequest", description = "人居环境预警阈值负责人角色编辑请求")
+public class EnvironmentWarningThresholdRoleEditRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 环境类型名称
+     */
+    private String type;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThresholdRole/EnvironmentWarningThresholdRoleQueryRequest.java

@@ -0,0 +1,23 @@
+package com.ruoyi.web.domain.dto.environmentWarningThresholdRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人角色查询请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdRoleQueryRequest", description = "人居环境预警阈值负责人角色查询请求")
+public class EnvironmentWarningThresholdRoleQueryRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 环境类型名称
+     */
+    private String type;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThresholdRole/EnvironmentWarningThresholdUserAddRequest.java

@@ -0,0 +1,26 @@
+package com.ruoyi.web.domain.dto.environmentWarningThresholdRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人添加请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdUserAddRequest", description = "人居环境预警阈值负责人添加请求")
+public class EnvironmentWarningThresholdUserAddRequest implements Serializable {
+
+    /**
+     * 环境类型
+     */
+    private String typeId;
+
+    /**
+     * 负责人ID
+     */
+    private Integer personId;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThresholdRole/EnvironmentWarningThresholdUserEditRequest.java

@@ -0,0 +1,30 @@
+package com.ruoyi.web.domain.dto.environmentWarningThresholdRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人编辑请求
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdUserEditRequest", description = "人居环境预警阈值负责人编辑请求")
+public class EnvironmentWarningThresholdUserEditRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 环境类型
+     */
+    private String typeId;
+
+    /**
+     * 负责人ID
+     */
+    private Integer personId;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/environmentWarningThresholdRole/EnvironmentWarningThresholdUserQueryRequest.java

@@ -0,0 +1,27 @@
+package com.ruoyi.web.domain.dto.environmentWarningThresholdRole;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人关联表
+ *
+ * @TableName environment_warning_threshold_user
+ */
+@TableName(value = "environment_warning_threshold_user")
+@Data
+public class EnvironmentWarningThresholdUserQueryRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 环境类型
+     */
+    private String typeId;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotEnvironment/LotEnvironmentAddRequest.java

@@ -0,0 +1,54 @@
+package com.ruoyi.web.domain.dto.lotEnvironment;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据人居环境监测添加请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "LotEnvironmentAddRequest", description = "物联网实时数据人居环境监测添加请求")
+public class LotEnvironmentAddRequest implements Serializable {
+
+    /**
+     * 水位
+     */
+    private String waterLevel;
+
+    /**
+     * 温度
+     */
+    private String temperature;
+
+    /**
+     * 湿度
+     */
+    private String humidity;
+
+    /**
+     * 降雨量
+     */
+    private String rainfall;
+
+    /**
+     * 风速
+     */
+    private String windSpeed;
+
+    /**
+     * 风向
+     */
+    private String windDirection;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotEnvironment/LotEnvironmentEditRequest.java

@@ -0,0 +1,56 @@
+package com.ruoyi.web.domain.dto.lotEnvironment;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据人居环境监测编辑请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "LotEnvironmentEditRequest", description = "物联网实时数据人居环境监测编辑请求")
+public class LotEnvironmentEditRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 水位
+     */
+    private String waterLevel;
+
+    /**
+     * 温度
+     */
+    private String temperature;
+
+    /**
+     * 湿度
+     */
+    private String humidity;
+
+    /**
+     * 降雨量
+     */
+    private String rainfall;
+
+    /**
+     * 风速
+     */
+    private String windSpeed;
+
+    /**
+     * 风向
+     */
+    private String windDirection;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotEnvironment/LotEnvironmentQueryRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.lotEnvironment;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据人居环境监测查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "LotEnvironmentQueryRequest", description = "物联网实时数据人居环境监测查询请求")
+public class LotEnvironmentQueryRequest extends PageRequest implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 预警开始日期
+     */
+    private Date startTime;
+
+    /**
+     * 预警结束日期
+     */
+    private Date endTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotPlatFormDevice/LotPlatformDeviceAddRequest.java

@@ -0,0 +1,36 @@
+package com.ruoyi.web.domain.dto.lotPlatFormDevice;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 物联网平台设备添加请求
+ */
+@Data
+@ApiModel(value = "LotPlatformDeviceAddRequest", description = "物联网平台设备添加请求")
+public class LotPlatformDeviceAddRequest implements Serializable {
+
+    /**
+     * 设备编号
+     */
+    private String code;
+
+    /**
+     * 设备名称
+     */
+    private String name;
+
+    /**
+     * 设备类别
+     */
+    private String category;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotPlatFormDevice/LotPlatformDeviceEditRequest.java

@@ -0,0 +1,60 @@
+package com.ruoyi.web.domain.dto.lotPlatFormDevice;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 物联网平台设备修改请求
+ */
+@Data
+@ApiModel(value = "LotPlatformDeviceEditRequest", description = "物联网平台设备修改请求")
+public class LotPlatformDeviceEditRequest implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 设备编号
+     */
+    private String code;
+
+    /**
+     * 设备名称
+     */
+    private String name;
+
+    /**
+     * 设备类别
+     */
+    private String category;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * 上报信息
+     */
+    private String information;
+
+    /**
+     * 状态信息
+     */
+    private String status;
+
+    /**
+     * 日志记录信息
+     */
+    private String logInformation;
+
+    /**
+     * 操作信息
+     */
+    private String operationalInformation;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotPlatFormDevice/LotPlatformDeviceQueryRequest.java

@@ -0,0 +1,43 @@
+package com.ruoyi.web.domain.dto.lotPlatFormDevice;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * 物联网平台设备查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "LotPlatformDeviceQueryRequest", description = "物联网平台设备查询请求")
+public class LotPlatformDeviceQueryRequest extends PageRequest implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 设备编号
+     */
+    private String code;
+
+    /**
+     * 设备名称
+     */
+    private String name;
+
+    /**
+     * 设备类别
+     */
+    private String category;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotPlatformProducts/LotPlatformProductsAddRequest.java

@@ -0,0 +1,25 @@
+package com.ruoyi.web.domain.dto.lotPlatformProducts;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 物联网平台产品添加请求
+ */
+@Data
+@ApiModel(value = "LotPlatFormProductsAddRequest", description = "物联网平台产品添加请求")
+public class LotPlatformProductsAddRequest implements Serializable {
+    /**
+     * 类别
+     */
+    private String category;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotPlatformProducts/LotPlatformProductsEditRequest.java

@@ -0,0 +1,28 @@
+package com.ruoyi.web.domain.dto.lotPlatformProducts;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 物联网平台产品修改请求
+ */
+@Data
+@ApiModel(value = "LotPlatFormProductsEditRequest", description = "物联网平台产品修改请求参数")
+public class LotPlatformProductsEditRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 类别
+     */
+    private String category;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotPlatformProducts/LotPlatformProductsQueryRequest.java

@@ -0,0 +1,31 @@
+package com.ruoyi.web.domain.dto.lotPlatformProducts;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * 物联网平台产品查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "LotPlatFormProductsQueryRequest", description = "物联网平台产品查询请求")
+public class LotPlatformProductsQueryRequest extends PageRequest implements Serializable {
+    /**
+     * ID
+     */
+    @ApiModelProperty(value = "ID")
+    private Integer id;
+
+    /**
+     * 项目名称
+     */
+    @ApiModelProperty(value = "类别")
+    private String category;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotVideo/LotVideoAddRequest.java

@@ -0,0 +1,43 @@
+package com.ruoyi.web.domain.dto.lotVideo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 物联网实时数据视频监控添加请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "LotDataCollectionAddRequest", description = "物联网实时数据视频监控添加请求")
+public class LotVideoAddRequest implements Serializable {
+
+    /**
+     * 监控名称
+     */
+    private String name;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * IP
+     */
+    private String ip;
+
+    /**
+     * 监控范围
+     */
+    private String monitoringRange;
+
+    /**
+     * 应用场景 0-安防监控/1-交通监控/2-防溺水监控/3-其他
+     */
+    private String scenarios;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotVideo/LotVideoEditRequest.java

@@ -0,0 +1,45 @@
+package com.ruoyi.web.domain.dto.lotVideo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 物联网实时数据视频监控编辑请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "LotDataCollectionEditRequest", description = "物联网实时数据视频监控编辑请求")
+public class LotVideoEditRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 监控名称
+     */
+    private String name;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * IP
+     */
+    private String ip;
+
+    /**
+     * 监控范围
+     */
+    private String monitoringRange;
+
+    /**
+     * 应用场景 0-安防监控/1-交通监控/2-防溺水监控/3-其他
+     */
+    private String scenarios;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/lotVideo/LotVideoQueryRequest.java

@@ -0,0 +1,38 @@
+package com.ruoyi.web.domain.dto.lotVideo;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * 物联网实时数据视频监控查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "LotDataCollectionQueryRequest", description = "物联网实时数据视频监控查询请求")
+public class LotVideoQueryRequest extends PageRequest implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 监控名称
+     */
+    private String name;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * 应用场景 0-安防监控/1-交通监控/2-防溺水监控/3-其他
+     */
+    private String scenarios;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/villageCommitteeRole/VillageCommitteeRoleAddRequest.java

@@ -0,0 +1,20 @@
+package com.ruoyi.web.domain.dto.villageCommitteeRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 村委类型添加请求
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleAddRequest", description = "村委类型添加请求")
+public class VillageCommitteeRoleAddRequest implements Serializable {
+    /**
+     * 村委类型
+     */
+    private String type;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/villageCommitteeRole/VillageCommitteeRoleEditRequest.java

@@ -0,0 +1,22 @@
+package com.ruoyi.web.domain.dto.villageCommitteeRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 村委类型编辑请求
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleEditRequest", description = "村委类型编辑请求")
+public class VillageCommitteeRoleEditRequest implements Serializable {
+
+    private Integer id;
+    /**
+     * 村委类型
+     */
+    private String type;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/villageCommitteeRole/VillageCommitteeRoleQueryRequest.java

@@ -0,0 +1,23 @@
+package com.ruoyi.web.domain.dto.villageCommitteeRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 村委类型查询请求
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleQueryRequest", description = "村委类型查询请求")
+public class VillageCommitteeRoleQueryRequest implements Serializable {
+
+    private Integer id;
+
+    /**
+     * 类型名称
+     */
+    private String type;
+
+    private static final long serialVersionUID = 1L;
+} 

app-admin/src/main/java/com/ruoyi/web/domain/dto/villageCommitteeRole/VillageCommitteeRoleUserAddRequest.java

@@ -0,0 +1,26 @@
+package com.ruoyi.web.domain.dto.villageCommitteeRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 村委添加请求
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleUserAddRequest", description = "村委添加请求")
+public class VillageCommitteeRoleUserAddRequest implements Serializable {
+
+    /**
+     * 村委类型id
+     */
+    private Integer roleId;
+
+    /**
+     * 用户id
+     */
+    private Integer personId;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/villageCommitteeRole/VillageCommitteeRoleUserEditRequest.java

@@ -0,0 +1,30 @@
+package com.ruoyi.web.domain.dto.villageCommitteeRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 村委编辑请求
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleUserEditRequest", description = "村委编辑请求")
+public class VillageCommitteeRoleUserEditRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 村委类型id
+     */
+    private Integer roleId;
+
+    /**
+     * 用户id
+     */
+    private Integer personId;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/villageCommitteeRole/VillageCommitteeRoleUserQueryRequest.java

@@ -0,0 +1,25 @@
+package com.ruoyi.web.domain.dto.villageCommitteeRole;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 人居环境预警阈值负责人查询请求
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleUserQueryRequest", description = "人居环境预警阈值负责人查询请求")
+public class VillageCommitteeRoleUserQueryRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 村委类型id
+     */
+    private Integer roleId;
+
+    private static final long serialVersionUID = 1L;
+} 

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/WarningReleaseRequest.java

@@ -0,0 +1,38 @@
+package com.ruoyi.web.domain.dto.warning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 预警信息发布请求
+ */
+@Data
+@ApiModel(value = "WarningReleaseRequest", description = "预警信息发布请求")
+public class WarningReleaseRequest implements Serializable {
+
+    /**
+     * 类别 0-地震预警、1-人居环境预警、2-防溺水预警
+     */
+    private String type;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/drowningWarning/DrowningWarningAddRequest.java

@@ -0,0 +1,32 @@
+package com.ruoyi.web.domain.dto.warning.drowningWarning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 防溺水预警添加请求
+ */
+@Data
+@ApiModel(value = "DrowningWarningAddRequest", description = "防溺水预警添加请求")
+public class DrowningWarningAddRequest implements Serializable {
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/drowningWarning/DrowningWarningEditRequest.java

@@ -0,0 +1,33 @@
+package com.ruoyi.web.domain.dto.warning.drowningWarning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 防溺水预警编辑请求
+ */
+@Data
+@ApiModel(value = "DrowningWarningEditRequest", description = "防溺水预警编辑请求")
+public class DrowningWarningEditRequest implements Serializable {
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/drowningWarning/DrowningWarningQueryRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.warning.drowningWarning;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 防溺水预警查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "DrowningWarningQueryRequest", description = "防溺水预警查询请求")
+public class DrowningWarningQueryRequest extends PageRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 预警开始日期
+     */
+    private Date startTime;
+
+    /**
+     * 预警结束日期
+     */
+    private Date endTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/earthquakeWarning/EarthquakeWarningAddRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.warning.earthquakeWarning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 地震监测预警添加请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "EarthquakeWarningAddRequest", description = "地震监测预警添加请求")
+public class EarthquakeWarningAddRequest implements Serializable {
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/earthquakeWarning/EarthquakeWarningEditRequest.java

@@ -0,0 +1,38 @@
+package com.ruoyi.web.domain.dto.warning.earthquakeWarning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 地震监测预警编辑请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "EarthquakeWarningEditRequest", description = "地震监测预警编辑请求")
+public class EarthquakeWarningEditRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/earthquakeWarning/EarthquakeWarningQueryRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.warning.earthquakeWarning;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 地震监测预警查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "EarthquakeWarningQueryRequest", description = "地震监测预警查询请求")
+public class EarthquakeWarningQueryRequest extends PageRequest implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 预警开始日期
+     */
+    private Date startTime;
+
+    /**
+     * 预警结束日期
+     */
+    private Date endTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/environmentWarning/EnvironmentWarningAddRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.warning.environmentWarning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警添加请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningAddRequest", description = "人居环境预警添加请求")
+public class EnvironmentWarningAddRequest implements Serializable {
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/environmentWarning/EnvironmentWarningEditRequest.java

@@ -0,0 +1,38 @@
+package com.ruoyi.web.domain.dto.warning.environmentWarning;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警编辑请求
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningEditRequest", description = "人居环境预警编辑请求")
+public class EnvironmentWarningEditRequest implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/dto/warning/environmentWarning/EnvironmentWarningQueryRequest.java

@@ -0,0 +1,34 @@
+package com.ruoyi.web.domain.dto.warning.environmentWarning;
+
+import com.ruoyi.web.common.PageRequest;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警查询请求
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@ApiModel(value = "EnvironmentWarningQueryRequest", description = "人居环境预警查询请求")
+public class EnvironmentWarningQueryRequest extends PageRequest implements Serializable {
+    /**
+     * ID
+     */
+    private Integer id;
+
+    /**
+     * 预警开始日期
+     */
+    private Date startTime;
+
+    /**
+     * 预警结束日期
+     */
+    private Date endTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/CloudBroadcasting.java

@@ -0,0 +1,53 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 联动云广播管理表
+ *
+ * @TableName cloud_broadcasting
+ */
+@TableName(value = "cloud_broadcasting")
+@Data
+public class CloudBroadcasting implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 主题
+     */
+    private String theme;
+
+    /**
+     * 呼叫日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/DrowningWarning.java

@@ -0,0 +1,58 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 防溺水预警管理表
+ *
+ * @TableName drowning_warning
+ */
+@TableName(value = "drowning_warning")
+@Data
+public class DrowningWarning implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警时间
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/EarthquakeWarning.java

@@ -0,0 +1,58 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 地震监测预警管理表
+ *
+ * @TableName earthquake_warning
+ */
+@TableName(value = "earthquake_warning")
+@Data
+public class EarthquakeWarning implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/Emergency.java

@@ -0,0 +1,88 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 应急指令下达表
+ *
+ * @TableName emergency
+ */
+@TableName(value = "emergency")
+@Data
+public class Emergency implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 事发时间
+     */
+    private Date occurTime;
+
+    /**
+     * 事件名称
+     */
+    private String name;
+
+    /**
+     * 事发地点
+     */
+    private String location;
+
+    /**
+     * 调度要求
+     */
+    private String requirement;
+
+    /**
+     * 接收对象user_id
+     */
+    private String receiveUserIds;
+
+    /**
+     * 负责人ID(默认本用户)
+     */
+    private Integer userId;
+
+    /**
+     * 发布状态 0-未下达 1-已下达
+     */
+    private Integer status;
+
+    /**
+     * 下达日期
+     */
+    private Date date;
+
+    /**
+     * 下达人id
+     */
+    private Integer issuerId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/EmergencyUser.java

@@ -0,0 +1,48 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 应急指令负责人表
+ *
+ * @TableName emergency_user
+ */
+@TableName(value = "emergency_user")
+@Data
+public class EmergencyUser implements Serializable {
+    /**
+     * ID
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 负责人ID
+     */
+    private Integer userId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/EnvironmentWarning.java

@@ -0,0 +1,58 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警管理表
+ *
+ * @TableName environment_warning
+ */
+@TableName(value = "environment_warning")
+@Data
+public class EnvironmentWarning implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/EnvironmentWarningThreshold.java

@@ -0,0 +1,64 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警阈值管理表
+ *
+ * @TableName environment_warning_threshold
+ */
+@TableName(value = "environment_warning_threshold")
+@Data
+public class EnvironmentWarningThreshold implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 环境类型id
+     */
+    private String typeId;
+
+
+    /**
+     * 预警等级：1-一级/2-二级/3-三级/4-四级
+     */
+    private Integer level;
+
+    /**
+     * 下限
+     */
+    private String low;
+
+    /**
+     * 上限
+     */
+    private String high;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/EnvironmentWarningThresholdRole.java

@@ -0,0 +1,48 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警阈值负责人角色表
+ *
+ * @TableName environment_warning_threshold_role
+ */
+@TableName(value = "environment_warning_threshold_role")
+@Data
+public class EnvironmentWarningThresholdRole implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 环境类型名称
+     */
+    private String type;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/EnvironmentWarningThresholdUser.java

@@ -0,0 +1,53 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警阈值负责人关联表
+ *
+ * @TableName environment_warning_threshold_user
+ */
+@TableName(value = "environment_warning_threshold_user")
+@Data
+public class EnvironmentWarningThresholdUser implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 环境类型
+     */
+    private String typeId;
+
+    /**
+     * 负责人ID
+     */
+    private Integer userId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/LotEnvironment.java

@@ -0,0 +1,78 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据环境监测管理表
+ *
+ * @TableName lot_environment
+ */
+@TableName(value = "lot_environment")
+@Data
+public class LotEnvironment implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 水位
+     */
+    private String waterLevel;
+
+    /**
+     * 温度
+     */
+    private String temperature;
+
+    /**
+     * 湿度
+     */
+    private String humidity;
+
+    /**
+     * 降雨量
+     */
+    private String rainfall;
+
+    /**
+     * 风速
+     */
+    private String windSpeed;
+
+    /**
+     * 风向
+     */
+    private String windDirection;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/LotPlatformDevice.java

@@ -0,0 +1,83 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网平台设备联动管理表
+ *
+ * @TableName lot_platform_device
+ */
+@TableName(value = "lot_platform_device")
+@Data
+public class LotPlatformDevice implements Serializable {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 设备编号
+     */
+    private String code;
+
+    /**
+     * 设备名称
+     */
+    private String name;
+
+    /**
+     * 设备类别
+     */
+    private String category;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * 上报信息
+     */
+    private String information;
+
+    /**
+     * 状态信息
+     */
+    private String status;
+
+    /**
+     * 日志记录信息
+     */
+    private String logInformation;
+
+    /**
+     * 操作信息
+     */
+    private String operationalInformation;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/LotPlatformProducts.java

@@ -0,0 +1,53 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网平台产品管理表
+ *
+ * @TableName lot_platform_products
+ */
+@TableName(value = "lot_platform_products")
+@Data
+public class LotPlatformProducts implements Serializable {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 类别
+     */
+    private String category;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/LotVideo.java

@@ -0,0 +1,68 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据采集管理表
+ *
+ * @TableName lot_data_collection
+ */
+@TableName(value = "lot_data_collection")
+@Data
+public class LotVideo implements Serializable {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 监控名称
+     */
+    private String name;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * IP
+     */
+    private String ip;
+
+    /**
+     * 监控范围
+     */
+    private String monitoringRange;
+
+    /**
+     * 应用场景 0-安防监控/1-交通监控/2-防溺水监控/3-其他
+     */
+    private String scenarios;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/VillageCommitteeRole.java

@@ -0,0 +1,48 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 村委角色表
+ *
+ * @TableName village_committee_role
+ */
+@TableName(value = "village_committee_role")
+@Data
+public class VillageCommitteeRole implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 村委类型
+     */
+    private String type;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/entity/VillageCommitteeRoleUser.java

@@ -0,0 +1,53 @@
+package com.ruoyi.web.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 村委用户关联表
+ *
+ * @TableName village_committee_role_user
+ */
+@TableName(value = "village_committee_role_user")
+@Data
+public class VillageCommitteeRoleUser implements Serializable {
+    /**
+     * id
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 村委类型id
+     */
+    private Integer roleId;
+
+    /**
+     * 用户id
+     */
+    private Integer userId;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
+     * 删除标志
+     */
+    @TableLogic
+    @JsonIgnore
+    private String delFlag;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/CloudBroadcastingVO.java

@@ -0,0 +1,41 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 联动云广播
+ */
+@ApiModel(value = "CloudBroadcastingVO", description = "联动云广播")
+@Data
+public class CloudBroadcastingVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 主题
+     */
+    private String theme;
+
+    /**
+     * 呼叫日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/DrowningWarningVO.java

@@ -0,0 +1,46 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 防溺水预警
+ */
+@Data
+@ApiModel(value = "DrowningWarningVO", description = "防溺水预警")
+public class DrowningWarningVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警时间
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/EarthquakeWarningVO.java

@@ -0,0 +1,46 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 地震监测预警管理表
+ */
+@Data
+@ApiModel(value = "EarthquakeWarningVO", description = "地震监测预警")
+public class EarthquakeWarningVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/EmergencyUserVO.java

@@ -0,0 +1,25 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 应急下达负责人vo
+ */
+@ApiModel(value = "EmergencyUserVO", description = "应急下达负责人vo")
+@Data
+public class EmergencyUserVO implements Serializable {
+    /**
+     * ID
+     */
+    private Integer id;
+
+    /**
+     * 负责人名称
+     */
+    private String nickName;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/EmergencyVO.java

@@ -0,0 +1,70 @@
+package com.ruoyi.web.domain.vo;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 应急指令下达vo
+ */
+@ApiModel(value = "EmergencyVO", description = "应急指令下达vo")
+@Data
+public class EmergencyVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 事发时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private Date occurTime;
+
+    /**
+     * 事件名称
+     */
+    private String name;
+
+    /**
+     * 事发地点
+     */
+    private String location;
+
+    /**
+     * 调度要求
+     */
+    private String requirement;
+
+    /**
+     * 接收对象列表
+     */
+    private List<PersonInfoVO> receivePersonInfo;
+
+    /**
+     * 负责人
+     */
+    private PersonInfoVO leaderInfo;
+
+    /**
+     * 发布状态 0-未下达 1-已下达
+     */
+    private Integer status;
+
+    /**
+     * 下达日期
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date date;
+
+    /**
+     * 下达人
+     */
+    private PersonInfoVO issuerInfo;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/EnvironmentWarningThresholdUserVO.java

@@ -0,0 +1,41 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警阈值负责人vo
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdUserVO", description = "人居环境预警阈值负责人vo")
+public class EnvironmentWarningThresholdUserVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 环境类型
+     */
+    private String type;
+
+    /**
+     * 负责人
+     */
+    private PersonInfoVO personInfo;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/EnvironmentWarningThresholdVO.java

@@ -0,0 +1,53 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警阈值vo
+ *
+ * @TableName environment_warning_threshold
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningThresholdVO", description = "人居环境预警阈值vo")
+public class EnvironmentWarningThresholdVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 环境类型
+     */
+    private String type;
+
+    /**
+     * 预警等级：1-一级/2-二级/3-三级/4-四级
+     */
+    private Integer level;
+
+    /**
+     * 下限
+     */
+    private String low;
+
+    /**
+     * 上限
+     */
+    private String high;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/EnvironmentWarningVO.java

@@ -0,0 +1,46 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 人居环境预警
+ */
+@Data
+@ApiModel(value = "EnvironmentWarningVO", description = "人居环境预警")
+public class EnvironmentWarningVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 位置
+     */
+    private String location;
+
+    /**
+     * 具体内容
+     */
+    private String content;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/LotEnvironmentVO.java

@@ -0,0 +1,66 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据环境监测管理表
+ */
+@Data
+@ApiModel(value = "LotEnvironmentVO", description = "物联网实时数据环境监测")
+public class LotEnvironmentVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 水位
+     */
+    private String waterLevel;
+
+    /**
+     * 温度
+     */
+    private String temperature;
+
+    /**
+     * 湿度
+     */
+    private String humidity;
+
+    /**
+     * 降雨量
+     */
+    private String rainfall;
+
+    /**
+     * 风速
+     */
+    private String windSpeed;
+
+    /**
+     * 风向
+     */
+    private String windDirection;
+
+    /**
+     * 预警日期
+     */
+    private Date date;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/LotPlatformDeviceVO.java

@@ -0,0 +1,71 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网平台设备联动
+ */
+@Data
+@ApiModel(value = "LotPlatformDeviceVO", description = "物联网平台设备联动")
+public class LotPlatformDeviceVO implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 设备编号
+     */
+    private String code;
+
+    /**
+     * 设备名称
+     */
+    private String name;
+
+    /**
+     * 设备类别
+     */
+    private String category;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * 上报信息
+     */
+    private String information;
+
+    /**
+     * 状态信息
+     */
+    private String status;
+
+    /**
+     * 日志记录信息
+     */
+    private String logInformation;
+
+    /**
+     * 操作信息
+     */
+    private String operationalInformation;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/LotPlatformProductsVO.java

@@ -0,0 +1,43 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网平台产品管理表
+ *
+ * @TableName lot_platform_products
+ */
+@Data
+@ApiModel(value = "LotPlatformProductsVO", description = "物联网平台产品")
+public class LotPlatformProductsVO implements Serializable {
+    /**
+     *
+     */
+    private Integer id;
+
+    /**
+     * 类别
+     */
+    private String category;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/LotVideoVO.java

@@ -0,0 +1,58 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 物联网实时数据视频监控
+ *
+ * @TableName lot_data_collection
+ */
+@Data
+@ApiModel(value = "LotVideoVO", description = "物联网实时数据视频监控")
+public class LotVideoVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 监控名称
+     */
+    private String name;
+
+    /**
+     * 安装位置
+     */
+    private String location;
+
+    /**
+     * IP
+     */
+    private String ip;
+
+    /**
+     * 监控范围
+     */
+    private String monitoringRange;
+
+    /**
+     * 应用场景 0-安防监控/1-交通监控/2-防溺水监控/3-其他
+     */
+    private String scenarios;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/domain/vo/VillageCommitteeRoleUserVO.java

@@ -0,0 +1,41 @@
+package com.ruoyi.web.domain.vo;
+
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 村委用户VO
+ */
+@Data
+@ApiModel(value = "VillageCommitteeRoleUserVO", description = "村委用户VO")
+public class VillageCommitteeRoleUserVO implements Serializable {
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * 村委类型
+     */
+    private String role;
+
+    /**
+     * 村委信息
+     */
+    private PersonInfoVO personInfo;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    private static final long serialVersionUID = 1L;
+}

app-admin/src/main/java/com/ruoyi/web/mapper/CloudBroadcastingMapper.java

@@ -0,0 +1,16 @@
+package com.ruoyi.web.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.web.domain.entity.CloudBroadcasting;
+
+
+/**
+ * @Entity generator.domain.CloudBroadcasting
+ */
+public interface CloudBroadcastingMapper extends BaseMapper<CloudBroadcasting> {
+
+}
+
+
+
+

app-admin/src/main/java/com/ruoyi/web/mapper/DrowningWarningMapper.java

@@ -0,0 +1,15 @@
+package com.ruoyi.web.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.web.domain.entity.DrowningWarning;
+
+/**
+ * @Entity generator.domain.DrowningWarning
+ */
+public interface DrowningWarningMapper extends BaseMapper<DrowningWarning> {
+
+}
+
+
+
+

app-admin/src/main/java/com/ruoyi/web/mapper/EarthquakeWarningMapper.java

@@ -0,0 +1,16 @@
+package com.ruoyi.web.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ruoyi.web.domain.entity.EarthquakeWarning;
+
+
+/**
+ * @Entity generator.domain.EarthquakeWarning
+ */
+public interface EarthquakeWarningMapper extends BaseMapper<EarthquakeWarning> {
+
+}
+
+
+
+