From 01b4d80adb9592397b84943c344ce737248b6e1d Mon Sep 17 00:00:00 2001 From: lg Date: Sun, 28 Sep 2025 17:23:10 +0800 Subject: [PATCH] =?UTF-8?q?ys=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../monitoring/config/SnowFlakeUtil.java | 43 +++ .../org/dromara/monitoring/config/YsDto.java | 16 ++ .../controller/MonDevicePresetController.java | 116 ++++++++ .../controller/MonitoriingYsColltroller.java | 69 +++++ .../monitoring/domain/MonDevicePreset.java | 59 ++++ .../domain/MonEquipmentHistroy.java | 43 +++ .../monitoring/domain/MonEquipmentList.java | 60 ++++ .../domain/bo/MonDevicePresetBo.java | 52 ++++ .../domain/bo/MonEquipmentListBo.java | 92 ++++++ .../dromara/monitoring/domain/dto/DelYzd.java | 26 ++ .../domain/dto/MonitoringListDto.java | 31 ++ .../domain/vo/MonDevicePresetVo.java | 62 ++++ .../domain/vo/MonEquipmentListVo.java | 96 +++++++ .../dromara/monitoring/domain/vo/MonList.java | 11 + .../dromara/monitoring/domain/vo/MonYsVo.java | 23 ++ .../mapper/MonDevicePresetMapper.java | 17 ++ .../mapper/MonEquipmentListMapper.java | 16 ++ .../monitoring/mapper/MonitoringYsMapper.java | 27 ++ .../monitoring/monEnum/ListConstant.java | 18 ++ .../monitoring/monEnum/QualityEnum.java | 26 ++ .../dromara/monitoring/monEnum/YsPort.java | 36 +++ .../service/IMonDevicePresetService.java | 70 +++++ .../service/IMonEquipmentListService.java | 69 +++++ .../service/MonitoringYsService.java | 20 ++ .../impl/MonDevicePresetServiceImpl.java | 206 ++++++++++++++ .../impl/MonEquipmentListServiceImpl.java | 141 +++++++++ .../service/impl/MonitoringYsServiceImpl.java | 267 ++++++++++++++++++ .../mapper/monitoring/MonitoringYsMapper.xml | 33 +++ 28 files changed, 1745 insertions(+) create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/SnowFlakeUtil.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/YsDto.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonDevicePresetController.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonitoriingYsColltroller.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonDevicePreset.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentHistroy.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentList.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonDevicePresetBo.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonEquipmentListBo.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/DelYzd.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/MonitoringListDto.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonDevicePresetVo.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonEquipmentListVo.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonList.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonYsVo.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonDevicePresetMapper.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonEquipmentListMapper.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonitoringYsMapper.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/ListConstant.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/QualityEnum.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/YsPort.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonDevicePresetService.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonEquipmentListService.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/MonitoringYsService.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonDevicePresetServiceImpl.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonEquipmentListServiceImpl.java create mode 100644 ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonitoringYsServiceImpl.java create mode 100644 ruoyi-modules/xny-ops/src/main/resources/mapper/monitoring/MonitoringYsMapper.xml diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/SnowFlakeUtil.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/SnowFlakeUtil.java new file mode 100644 index 0000000..2c6458d --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/SnowFlakeUtil.java @@ -0,0 +1,43 @@ +package org.dromara.monitoring.config; + +public class SnowFlakeUtil { + // 起始时间戳 + private static final long startTimeStamp = 1577808000000L; + // 机器ID + private static final long workID = 1L; + // 数据中心ID + private static final long dataCenterID = 1L; + // 序列号 + private static long sequence = 0L; + // 数据中心ID移动位数 + private static final long dataCenterIndex = 12L; + // 机器ID移动位数 + private static final long workIDIndex = 17L; + // 时间戳移动位数 + private static final long timeStampIndex = 22L; + // 记录上一次时间戳 + private static long lastTimeStamp = -1L; + // 序列号掩码 + private static final long sequenceMask = -1L ^ (-1L << 12); + public synchronized static long getID() { + long now = System.currentTimeMillis(); + if (now < lastTimeStamp) { + throw new RuntimeException("时钟回拨异常"); + } + if (now == lastTimeStamp) { + sequence = (sequence + 1) & sequenceMask; + if (sequence == 0L) { + try { + Thread.sleep(1L); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + now = System.currentTimeMillis(); + } + } else { + sequence = 0L; + } + lastTimeStamp = now; + return ((now - startTimeStamp) << timeStampIndex) | (dataCenterID << dataCenterIndex) | (workID << workIDIndex) | sequence; + } +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/YsDto.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/YsDto.java new file mode 100644 index 0000000..3747637 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/config/YsDto.java @@ -0,0 +1,16 @@ +package org.dromara.monitoring.config; + + +import lombok.Data; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.stereotype.Component; + +@Data +@Component +@ConfigurationProperties(prefix = "ys7") +public class YsDto { + private String appKey; + private String appSecret; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonDevicePresetController.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonDevicePresetController.java new file mode 100644 index 0000000..64a8742 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonDevicePresetController.java @@ -0,0 +1,116 @@ +package org.dromara.monitoring.controller; + +import cn.dev33.satoken.annotation.SaCheckPermission; +import jakarta.servlet.http.HttpServletResponse; +import jakarta.validation.constraints.NotNull; +import lombok.RequiredArgsConstructor; +import org.dromara.common.core.domain.R; +import org.dromara.common.core.validate.AddGroup; +import org.dromara.common.core.validate.EditGroup; +import org.dromara.common.excel.utils.ExcelUtil; +import org.dromara.common.idempotent.annotation.RepeatSubmit; +import org.dromara.common.log.annotation.Log; +import org.dromara.common.log.enums.BusinessType; +import org.dromara.common.mybatis.core.page.PageQuery; +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.common.web.core.BaseController; +import org.dromara.monitoring.domain.bo.MonDevicePresetBo; +import org.dromara.monitoring.domain.dto.DelYzd; +import org.dromara.monitoring.domain.vo.MonDevicePresetVo; +import org.dromara.monitoring.service.IMonDevicePresetService; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; + +import java.util.List; + +/** + * 摄像头预置位 + * 前端访问路由地址为:/camera/devicePreset + * + * @author LionLi + * @date 2025-09-23 + */ +@Validated +@RequiredArgsConstructor +@RestController +@RequestMapping("/devicePreset") +public class MonDevicePresetController extends BaseController { + + private final IMonDevicePresetService monDevicePresetService; + + /** + * 查询摄像头预置位列表 + */ + @SaCheckPermission("camera:devicePreset:list") + @GetMapping("/list") + public TableDataInfo list(MonDevicePresetBo bo, PageQuery pageQuery) { + return monDevicePresetService.queryPageList(bo, pageQuery); + } + + /** + * 导出摄像头预置位列表 + */ + @SaCheckPermission("camera:devicePreset:export") + @Log(title = "摄像头预置位", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(MonDevicePresetBo bo, HttpServletResponse response) { + List list = monDevicePresetService.queryList(bo); + ExcelUtil.exportExcel(list, "摄像头预置位", MonDevicePresetVo.class, response); + } + + /** + * 获取摄像头预置位详细信息 + * + * @param id 主键 + */ + @SaCheckPermission("camera:devicePreset:query") + @GetMapping("/{id}") + public R getInfo(@NotNull(message = "主键不能为空") + @PathVariable("id") Long id) { + return R.ok(monDevicePresetService.queryById(id)); + } + + /** + * 新增摄像头预置位 + */ + @SaCheckPermission("camera:devicePreset:add") + @Log(title = "摄像头预置位", businessType = BusinessType.INSERT) + @RepeatSubmit() + @PostMapping() + public R add(@Validated(AddGroup.class) @RequestBody MonDevicePresetBo bo) { + return toAjax(monDevicePresetService.insertByBo(bo)); + } + + /** + * 修改摄像头预置位 + */ + @SaCheckPermission("camera:devicePreset:edit") + @Log(title = "摄像头预置位", businessType = BusinessType.UPDATE) + @RepeatSubmit() + @PutMapping() + public R edit(@Validated(EditGroup.class) @RequestBody MonDevicePresetBo bo) { + return toAjax(monDevicePresetService.updateByBo(bo)); + } + + /** + * 删除摄像头预置位 + * + * @param + */ + @SaCheckPermission("camera:devicePreset:remove") + @Log(title = "摄像头预置位", businessType = BusinessType.DELETE) + @DeleteMapping("/delYzd") + public R remove(@RequestBody List yzd) { + return toAjax(monDevicePresetService.deleteWithValidByIds(yzd, true)); + } + + @Log(title = "调用摄像头预置位", businessType = BusinessType.DELETE) + @PostMapping("/callYzd") + public R invoking(@RequestBody List yzd) { + return toAjax(monDevicePresetService.invoking(yzd)); + } + + + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonitoriingYsColltroller.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonitoriingYsColltroller.java new file mode 100644 index 0000000..77af1e4 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/controller/MonitoriingYsColltroller.java @@ -0,0 +1,69 @@ +package org.dromara.monitoring.controller; + +import lombok.RequiredArgsConstructor; +import org.dromara.common.core.domain.R; +import org.dromara.common.log.annotation.Log; +import org.dromara.common.log.enums.BusinessType; +import org.dromara.monitoring.domain.dto.DelYzd; +import org.dromara.monitoring.domain.dto.MonitoringListDto; +import org.dromara.monitoring.domain.vo.MonList; +import org.dromara.monitoring.domain.vo.MonYsVo; +import org.dromara.monitoring.service.MonitoringYsService; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; + +@Validated +@RequiredArgsConstructor +@RestController +@RequestMapping("/monitoriing") +/** + * 监控管理 + */ +public class MonitoriingYsColltroller { + + private final MonitoringYsService monitoringYsService; + + /** + * 获取token + */ + @GetMapping("/getToken") + @Log(title = "获取莹石云token", businessType = BusinessType.INSERT) + public R getysTokenColltroller(){ + return R.ok("ok",monitoringYsService.getYsTokenService()); + } + + /** + * 获取监控列表 + */ + @PostMapping("/getMonitoringList") + @Log(title = "获取监控列表", businessType = BusinessType.INSERT) + public R getMonitoringList(@RequestBody MonitoringListDto dto){ + return R.ok("请求成功",monitoringYsService.getMonitoringList(dto)); + } + + /** + * 获取大屏项目 + */ + @GetMapping("/getMonitoringDp") + @Log(title = "数据组装", businessType = BusinessType.INSERT) + public R getMonitoringDp(){ + return R.ok("请求成功",monitoringYsService.getMonitoringDp()); + } + + /** + * 抓拍 + */ + @GetMapping("/capturePho") + @Log(title = "抓拍接口：未用", businessType = BusinessType.INSERT) + public R capturePho(@RequestBody DelYzd dto){ + return R.ok("请求成功",monitoringYsService.capturePho(dto)); + } + + + @GetMapping("/test") + public R test(){ + return R.ok("请求成功",monitoringYsService.test()); + } + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonDevicePreset.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonDevicePreset.java new file mode 100644 index 0000000..02475fe --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonDevicePreset.java @@ -0,0 +1,59 @@ +package org.dromara.monitoring.domain; + + +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import org.checkerframework.checker.i18nformatter.qual.I18nFormat; + +import java.time.LocalDateTime; + + +/** + * 设备预置点记录 mon_device_preset + */ +@TableName("mon_device_preset") +@Data +public class MonDevicePreset { + + private static final long serialVersionUID = 1L; + + /** 预置点ID */ + @TableId(value = "id", type = com.baomidou.mybatisplus.annotation.IdType.AUTO) + private Long id; + + + /** 设备序列号 */ + private String deviceSerial; + + + /** 通道号 */ + private Integer channelNo; + + + /** 预置点序号 */ + private Integer PresetIndex; + + + /** 预置点名称 */ + private String presetName; + + + /**创建时间 */ + private LocalDateTime createTime; + + /**更新时间 */ + private LocalDateTime updateTime; + + + + + + + + + + + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentHistroy.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentHistroy.java new file mode 100644 index 0000000..8b57138 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentHistroy.java @@ -0,0 +1,43 @@ +package org.dromara.monitoring.domain; + + +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.time.LocalDateTime; + +@Data +@TableName("mon_equipment_histroy") +/** + * 设备点击历史记录表 mon_equipment_histroy + */ +public class MonEquipmentHistroy { + /** 历史id */ + @TableId(value = "id") + private Long id; + + /** 设备序列号 */ + private String deviceSerial; + + /** 设备名称 */ + private String deviceName; + + /** 设备型号 */ + private String deviceType; + + + /** 用户id */ + private Long userId; + + /** 部门id */ + private Long deptId; + + /** 项目id */ + private Long projectId; + + /** 点击时间 */ + private LocalDateTime createTime; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentList.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentList.java new file mode 100644 index 0000000..de5cc23 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/MonEquipmentList.java @@ -0,0 +1,60 @@ +package org.dromara.monitoring.domain; + +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.time.LocalDateTime; + +/** + * 设备列表表 mon_equipment_list + * + * @author LionLi + * @date 2023-08-09 + */ +@TableName("mon_equipment_list") +@Data +public class MonEquipmentList { + + private Long id; + + + + /** 设备序列号 */ + private String deviceSerial; + + /**设备名称 */ + private String deviceName; + + /**设备型号 */ + private String deviceType; + + /**设备在线状态，1-在线；0-离线 */ + private Integer status; + + /**布撤防状态 */ + private Integer defence; + + /**固件版本号 */ + private String deviceVersion; + + /**用户添加时间 */ + private LocalDateTime addTime; + + /**设备最后更新时间 */ + private LocalDateTime updateTime; + + /**设备二级类目名称 */ + private String parentCategory; + + /**设备风险安全等级，0-安全；大于0，有风险，风险越高，值越大 */ + private Integer riskLevel; + + /**设备IP地址 */ + private String netAddress; + + + private Integer total; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonDevicePresetBo.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonDevicePresetBo.java new file mode 100644 index 0000000..4f061a1 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonDevicePresetBo.java @@ -0,0 +1,52 @@ +package org.dromara.monitoring.domain.bo; + +import org.dromara.common.mybatis.core.domain.BaseEntity; +import org.dromara.common.core.validate.AddGroup; +import org.dromara.common.core.validate.EditGroup; +import io.github.linpeilie.annotations.AutoMapper; +import lombok.Data; +import lombok.EqualsAndHashCode; +import jakarta.validation.constraints.*; +import org.dromara.monitoring.domain.MonDevicePreset; + +/** + * 摄像头预置位业务对象 mon_device_preset + * + * @author LionLi + * @date 2025-09-23 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@AutoMapper(target = MonDevicePreset.class, reverseConvertGenerate = false) +public class MonDevicePresetBo extends BaseEntity { + + /** + * 主键id + */ + private Long id; + + /** + * 设备序列号 + */ + @NotBlank(message = "设备序列号不能为空", groups = { AddGroup.class, EditGroup.class }) + private String deviceSerial; + + /** + * 通道号 + */ + @NotNull(message = "通道号不能为空", groups = { AddGroup.class, EditGroup.class }) + private Long channelNo; + + /** + * 预置点序号 + */ + private Long presetIndex; + + /** + * 预置点 + */ + @NotBlank(message = "预置点不能为空", groups = { AddGroup.class, EditGroup.class }) + private String presetName; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonEquipmentListBo.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonEquipmentListBo.java new file mode 100644 index 0000000..e8063d9 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/bo/MonEquipmentListBo.java @@ -0,0 +1,92 @@ +package org.dromara.monitoring.domain.bo; + +import io.github.linpeilie.annotations.AutoMapper; +import jakarta.validation.constraints.NotBlank; +import jakarta.validation.constraints.NotNull; +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.dromara.common.core.validate.AddGroup; +import org.dromara.common.core.validate.EditGroup; +import org.dromara.common.mybatis.core.domain.BaseEntity; +import org.dromara.monitoring.domain.MonEquipmentList; + +import java.util.Date; + +/** + * 设备列业务对象 mon_equipment_list + * + * @author LionLi + * @date 2025-09-25 + */ +@Data +@EqualsAndHashCode(callSuper = true) +@AutoMapper(target = MonEquipmentList.class, reverseConvertGenerate = false) +public class MonEquipmentListBo extends BaseEntity { + + /** + * 主键 + */ + private Long id; + + /** + * 设备序列号 + */ + @NotBlank(message = "设备序列号不能为空", groups = { AddGroup.class, EditGroup.class }) + private String deviceSerial; + + /** + * 设备名称 + */ + @NotBlank(message = "设备名称不能为空", groups = { AddGroup.class, EditGroup.class }) + private String deviceName; + + /** + * 设备型号 + */ + @NotBlank(message = "设备型号 不能为空", groups = { AddGroup.class, EditGroup.class }) + private String deviceType; + + /** + * 设备在线状态，1-在线；0-离线 + */ + @NotNull(message = "设备在线状态，1-在线；0-离线不能为空", groups = { AddGroup.class, EditGroup.class }) + private Long status; + + /** + * 布撤防状态 + */ + @NotNull(message = "布撤防状态不能为空", groups = { AddGroup.class, EditGroup.class }) + private Long defence; + + /** + * 固件版本号 + */ + @NotBlank(message = "固件版本号 不能为空", groups = { AddGroup.class, EditGroup.class }) + private String deviceVersion; + + /** + * 用户添加时间 + */ + @NotNull(message = "用户添加时间不能为空", groups = { AddGroup.class, EditGroup.class }) + private Date addTime; + + /** + * 设备二级类目名称 + */ + @NotBlank(message = "设备二级类目名称不能为空", groups = { AddGroup.class, EditGroup.class }) + private String parentCategory; + + /** + * 设备风险安全等级，0-安全；大于0，有风险，风险越高，值越大 + */ + @NotNull(message = "设备风险安全等级，0-安全；大于0，有风险，风险越高，值越大不能为空", groups = { AddGroup.class, EditGroup.class }) + private Long riskLevel; + + /** + * 设备IP地址 + */ + @NotBlank(message = "设备IP地址不能为空", groups = { AddGroup.class, EditGroup.class }) + private String netAddress; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/DelYzd.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/DelYzd.java new file mode 100644 index 0000000..3613446 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/DelYzd.java @@ -0,0 +1,26 @@ +package org.dromara.monitoring.domain.dto; + + +import lombok.Data; + +@Data +/** + * 删除预置点 + */ +public class DelYzd { + + private Long id; + /** + * 设备序列号 + */ + private String deviceSerial; + /** + * 通道号 + */ + private Integer channelNo = 1; + /** + * 预置点序号 + */ + private Integer presetIndex ; + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/MonitoringListDto.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/MonitoringListDto.java new file mode 100644 index 0000000..1ddb182 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/dto/MonitoringListDto.java @@ -0,0 +1,31 @@ +package org.dromara.monitoring.domain.dto; + + +import jakarta.validation.constraints.NotNull; +import lombok.Data; +import lombok.NonNull; + +@Data +public class MonitoringListDto { + + + /** + * 分页页码，起始页从0开始，不超过400页 + */ + private Integer pageStart; + + + /** + * 分页大小，默认为10，不超过50 + */ + private Integer pageSize; + +// 部门id + @NotNull(message = "部门id不能为空") + private Long projectId; + + @NotNull(message = "是否为历史数据") + private Boolean isflow; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonDevicePresetVo.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonDevicePresetVo.java new file mode 100644 index 0000000..bb76178 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonDevicePresetVo.java @@ -0,0 +1,62 @@ +package org.dromara.monitoring.domain.vo; + +import cn.idev.excel.annotation.ExcelIgnoreUnannotated; +import cn.idev.excel.annotation.ExcelProperty; +import org.dromara.common.excel.annotation.ExcelDictFormat; +import org.dromara.common.excel.convert.ExcelDictConvert; +import io.github.linpeilie.annotations.AutoMapper; +import lombok.Data; +import org.dromara.monitoring.domain.MonDevicePreset; + +import java.io.Serial; +import java.io.Serializable; +import java.util.Date; + + + +/** + * 摄像头预置位视图对象 mon_device_preset + * + * @author LionLi + * @date 2025-09-23 + */ +@Data +@ExcelIgnoreUnannotated +@AutoMapper(target = MonDevicePreset.class) +public class MonDevicePresetVo implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + /** + * 主键id + */ + @ExcelProperty(value = "主键id") + private Long id; + + /** + * 设备序列号 + */ + @ExcelProperty(value = "设备序列号") + private String deviceSerial; + + /** + * 通道号 + */ + @ExcelProperty(value = "通道号") + private Long channelNo; + + /** + * 预置点序号 + */ + @ExcelProperty(value = "预置点序号") + private Long presetIndex; + + /** + * 预置点 + */ + @ExcelProperty(value = "预置点") + private String presetName; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonEquipmentListVo.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonEquipmentListVo.java new file mode 100644 index 0000000..31446d0 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonEquipmentListVo.java @@ -0,0 +1,96 @@ +package org.dromara.monitoring.domain.vo; + +import cn.idev.excel.annotation.ExcelIgnoreUnannotated; +import cn.idev.excel.annotation.ExcelProperty; +import io.github.linpeilie.annotations.AutoMapper; +import lombok.Data; +import org.dromara.monitoring.domain.MonEquipmentList; + +import java.io.Serial; +import java.io.Serializable; +import java.util.Date; + + + +/** + * 设备列视图对象 mon_equipment_list + * + * @author LionLi + * @date 2025-09-25 + */ +@Data +@ExcelIgnoreUnannotated +@AutoMapper(target = MonEquipmentList.class) +public class MonEquipmentListVo implements Serializable { + + @Serial + private static final long serialVersionUID = 1L; + + /** + * 主键 + */ + @ExcelProperty(value = "主键") + private Long id; + + /** + * 设备序列号 + */ + @ExcelProperty(value = "设备序列号") + private String deviceSerial; + + /** + * 设备名称 + */ + @ExcelProperty(value = "设备名称 ") + private String deviceName; + + /** + * 设备型号 + */ + @ExcelProperty(value = "设备型号 ") + private String deviceType; + + /** + * 设备在线状态，1-在线；0-离线 + */ + @ExcelProperty(value = "设备在线状态，1-在线；0-离线") + private Long status; + + /** + * 布撤防状态 + */ + @ExcelProperty(value = "布撤防状态") + private Long defence; + + /** + * 固件版本号 + */ + @ExcelProperty(value = "固件版本号 ") + private String deviceVersion; + + /** + * 用户添加时间 + */ + @ExcelProperty(value = "用户添加时间") + private Date addTime; + + /** + * 设备二级类目名称 + */ + @ExcelProperty(value = "设备二级类目名称") + private String parentCategory; + + /** + * 设备风险安全等级，0-安全；大于0，有风险，风险越高，值越大 + */ + @ExcelProperty(value = "设备风险安全等级，0-安全；大于0，有风险，风险越高，值越大") + private Long riskLevel; + + /** + * 设备IP地址 + */ + @ExcelProperty(value = "设备IP地址") + private String netAddress; + + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonList.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonList.java new file mode 100644 index 0000000..ff5c51a --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonList.java @@ -0,0 +1,11 @@ +package org.dromara.monitoring.domain.vo; + + +import lombok.Data; + +@Data +public class MonList { + + private Object object; + private Integer sum; +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonYsVo.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonYsVo.java new file mode 100644 index 0000000..f5a9977 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/domain/vo/MonYsVo.java @@ -0,0 +1,23 @@ +package org.dromara.monitoring.domain.vo; + + +import lombok.Data; + +@Data +public class MonYsVo { + + /** + * 监控总数 + */ + private Integer sumMon; + + /** + * 在线总数 + */ + private Long sumOnLine; + + /** + * 离线总数 + */ + private Long sumOffLine; +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonDevicePresetMapper.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonDevicePresetMapper.java new file mode 100644 index 0000000..e0e7665 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonDevicePresetMapper.java @@ -0,0 +1,17 @@ +package org.dromara.monitoring.mapper; + +import org.apache.ibatis.annotations.Mapper; +import org.dromara.common.mybatis.core.mapper.BaseMapperPlus; +import org.dromara.monitoring.domain.MonDevicePreset; +import org.dromara.monitoring.domain.vo.MonDevicePresetVo; + +/** + * 摄像头预置位Mapper接口 + * + * @author LionLi + * @date 2025-09-23 + */ +@Mapper +public interface MonDevicePresetMapper extends BaseMapperPlus { + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonEquipmentListMapper.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonEquipmentListMapper.java new file mode 100644 index 0000000..6f14095 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonEquipmentListMapper.java @@ -0,0 +1,16 @@ +package org.dromara.monitoring.mapper; + + +import org.dromara.common.mybatis.core.mapper.BaseMapperPlus; +import org.dromara.monitoring.domain.MonEquipmentList; +import org.dromara.monitoring.domain.vo.MonEquipmentListVo; + +/** + * 设备列Mapper接口 + * + * @author LionLi + * @date 2025-09-25 + */ +public interface MonEquipmentListMapper extends BaseMapperPlus { + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonitoringYsMapper.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonitoringYsMapper.java new file mode 100644 index 0000000..d6860c8 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/mapper/MonitoringYsMapper.java @@ -0,0 +1,27 @@ +package org.dromara.monitoring.mapper; + + +import org.apache.ibatis.annotations.Delete; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; +import org.dromara.monitoring.domain.MonEquipmentHistroy; +import org.dromara.monitoring.domain.MonEquipmentList; + +import java.util.List; + +@Mapper + public interface MonitoringYsMapper { + + + Integer setSunList(); + + void insettList(@Param("list") List tempList); + + void insertHistroy(@Param("data") List data); + + @Delete("TRUNCATE TABLE mon_equipment_list") + void delList(); + + List selDpList(); + +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/ListConstant.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/ListConstant.java new file mode 100644 index 0000000..51b78be --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/ListConstant.java @@ -0,0 +1,18 @@ +package org.dromara.monitoring.monEnum; + + + +public enum ListConstant { + PAGESTART(0), + pageSize(300); + + private Integer constant; + + ListConstant(Integer constant) { + this.constant = constant; + } + + public Integer getConstant() { + return constant; + } +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/QualityEnum.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/QualityEnum.java new file mode 100644 index 0000000..5ce5f63 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/QualityEnum.java @@ -0,0 +1,26 @@ +package org.dromara.monitoring.monEnum; + +public enum QualityEnum { + + FLUENCY("流畅", "0"), + HIGHDEFINITION("高清", "1"), + CIF("4CIF", "2"), + CIFG("1080P", "3"); + + + + private String name; + + private String value; + + private QualityEnum(String name, String value) { + this.name = name; + this.value = value; + } + public String getName() { + return name; + } + public String getValue() { + return value; + } +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/YsPort.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/YsPort.java new file mode 100644 index 0000000..f4ce791 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/monEnum/YsPort.java @@ -0,0 +1,36 @@ +package org.dromara.monitoring.monEnum; + + +public enum YsPort { + ON_OFF_LINE_TOPIC_TYP("设备在线状态类型","ys.onoffline"), + GETTOKENURLBYPOST("获取token的url","https://open.ys7.com/api/lapp/token/get"), + GETDEVICELISTURL("获取设备列表的url","https://open.ys7.com/api/lapp/device/list"), + UPDATEDEVICENAMEURLBYPOST("修改设备名称的url","https://open.ys7.com/api/lapp/device/name/update"), + ADDDEVICEPRESETURLBYPOST("添加设备预置点请求地址","https://open.ys7.com/api/lapp/device/preset/add"), + MOVEDEVICEPRESETURLBYPOST("调用设备预置点请求地址","https://open.ys7.com/api/lapp/device/preset/move"), + DELETEDEVICEPRESETURLBYPOST("删除设备预置点请求地址","https://open.ys7.com/api/lapp/device/preset/clear"), + CAPTUREDEVICEURLBYPOST("设备拍照请求地址","https://open.ys7.com/api/lapp/device/capture"), + DEVICESTORAGEMEDIUM ("设备存储介质格式化接口","https://open.ys7.com/api/v3/device/format/disk"), + STORAGEMEDIUMSTATUS ("设备存储介质状态查询接口","https://open.ys7.com/api/v3/device/format/status"); + + + + // 成员变量 + private final String sitename; // 中文名称 + private final String site; + + public String getSiteName() { + return sitename; + } + + public String getSite() { + return site; + } + + + YsPort(String sitename, String site) { + this.sitename = sitename; + this.site = site; + } +} + diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonDevicePresetService.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonDevicePresetService.java new file mode 100644 index 0000000..e2e6e6b --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonDevicePresetService.java @@ -0,0 +1,70 @@ +package org.dromara.monitoring.service; + +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.common.mybatis.core.page.PageQuery; +import org.dromara.monitoring.domain.bo.MonDevicePresetBo; +import org.dromara.monitoring.domain.dto.DelYzd; +import org.dromara.monitoring.domain.vo.MonDevicePresetVo; + +import java.util.List; + +/** + * 摄像头预置位Service接口 + * + * @author LionLi + * @date 2025-09-23 + */ +public interface IMonDevicePresetService { + + /** + * 查询摄像头预置位 + * + * @param id 主键 + * @return 摄像头预置位 + */ + MonDevicePresetVo queryById(Long id); + + /** + * 分页查询摄像头预置位列表 + * + * @param bo 查询条件 + * @param pageQuery 分页参数 + * @return 摄像头预置位分页列表 + */ + TableDataInfo queryPageList(MonDevicePresetBo bo, PageQuery pageQuery); + + /** + * 查询符合条件的摄像头预置位列表 + * + * @param bo 查询条件 + * @return 摄像头预置位列表 + */ + List queryList(MonDevicePresetBo bo); + + /** + * 新增摄像头预置位 + * + * @param bo 摄像头预置位 + * @return 是否新增成功 + */ + Boolean insertByBo(MonDevicePresetBo bo); + + /** + * 修改摄像头预置位 + * + * @param bo 摄像头预置位 + * @return 是否修改成功 + */ + Boolean updateByBo(MonDevicePresetBo bo); + + /** + * 校验并批量删除摄像头预置位信息 + * + * @param + * @param isValid 是否进行有效性校验 + * @return 是否删除成功 + */ + Boolean deleteWithValidByIds(List yzd, Boolean isValid); + + boolean invoking(List yzd); +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonEquipmentListService.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonEquipmentListService.java new file mode 100644 index 0000000..1ab9ffa --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/IMonEquipmentListService.java @@ -0,0 +1,69 @@ +package org.dromara.monitoring.service; + + +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.common.mybatis.core.page.PageQuery; +import org.dromara.monitoring.domain.bo.MonEquipmentListBo; +import org.dromara.monitoring.domain.vo.MonEquipmentListVo; + +import java.util.Collection; +import java.util.List; + +/** + * 设备列Service接口 + * + * @author LionLi + * @date 2025-09-25 + */ +public interface IMonEquipmentListService { + + /** + * 查询设备列 + * + * @param id 主键 + * @return 设备列 + */ + MonEquipmentListVo queryById(Long id); + + /** + * 分页查询设备列列表 + * + * @param bo 查询条件 + * @param pageQuery 分页参数 + * @return 设备列分页列表 + */ + TableDataInfo queryPageList(MonEquipmentListBo bo, PageQuery pageQuery); + + /** + * 查询符合条件的设备列列表 + * + * @param bo 查询条件 + * @return 设备列列表 + */ + List queryList(MonEquipmentListBo bo); + + /** + * 新增设备列 + * + * @param bo 设备列 + * @return 是否新增成功 + */ + Boolean insertByBo(MonEquipmentListBo bo); + + /** + * 修改设备列 + * + * @param bo 设备列 + * @return 是否修改成功 + */ + Boolean updateByBo(MonEquipmentListBo bo); + + /** + * 校验并批量删除设备列信息 + * + * @param ids 待删除的主键集合 + * @param isValid 是否进行有效性校验 + * @return 是否删除成功 + */ + Boolean deleteWithValidByIds(Collection ids, Boolean isValid); +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/MonitoringYsService.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/MonitoringYsService.java new file mode 100644 index 0000000..dbe5466 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/MonitoringYsService.java @@ -0,0 +1,20 @@ +package org.dromara.monitoring.service; + +import org.dromara.monitoring.domain.dto.DelYzd; +import org.dromara.monitoring.domain.dto.MonitoringListDto; +import org.dromara.monitoring.domain.vo.MonList; +import org.dromara.monitoring.domain.vo.MonYsVo; + +public interface MonitoringYsService { + + + String getYsTokenService(); + + MonList getMonitoringList(MonitoringListDto dto); + + MonYsVo getMonitoringDp(); + + String capturePho(DelYzd dto); + + Void test(); +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonDevicePresetServiceImpl.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonDevicePresetServiceImpl.java new file mode 100644 index 0000000..80ef2b8 --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonDevicePresetServiceImpl.java @@ -0,0 +1,206 @@ +package org.dromara.monitoring.service.impl; + +import cn.hutool.http.HttpRequest; +import cn.hutool.json.JSONObject; +import cn.hutool.json.JSONUtil; +import org.dromara.common.core.utils.MapstructUtils; +import org.dromara.common.core.utils.StringUtils; +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.common.mybatis.core.page.PageQuery; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.dromara.monitoring.config.SnowFlakeUtil; +import org.dromara.monitoring.domain.MonDevicePreset; +import org.dromara.monitoring.domain.bo.MonDevicePresetBo; +import org.dromara.monitoring.domain.dto.DelYzd; +import org.dromara.monitoring.domain.vo.MonDevicePresetVo; +import org.dromara.monitoring.mapper.MonDevicePresetMapper; +import org.dromara.monitoring.monEnum.YsPort; +import org.dromara.monitoring.service.IMonDevicePresetService; +import org.dromara.monitoring.service.MonitoringYsService; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.Map; +import java.util.Collection; +import java.util.stream.Collectors; + +/** + * 摄像头预置位Service业务层处理 + * + * @author LionLi + * @date 2025-09-23 + */ +@Slf4j +@RequiredArgsConstructor +@Service +public class MonDevicePresetServiceImpl implements IMonDevicePresetService { + + private final MonDevicePresetMapper baseMapper; + + private final MonitoringYsService monitoringYsService; + + /** + * 查询摄像头预置位 + * + * @param id 主键 + * @return 摄像头预置位 + */ + @Override + public MonDevicePresetVo queryById(Long id){ + return baseMapper.selectVoById(id); + } + + /** + * 分页查询摄像头预置位列表 + * + * @param bo 查询条件 + * @param pageQuery 分页参数 + * @return 摄像头预置位分页列表 + */ + @Override + public TableDataInfo queryPageList(MonDevicePresetBo bo, PageQuery pageQuery) { + LambdaQueryWrapper lqw = buildQueryWrapper(bo); + Page result = baseMapper.selectVoPage(pageQuery.build(), lqw); + return TableDataInfo.build(result); + } + + /** + * 查询符合条件的摄像头预置位列表 + * + * @param bo 查询条件 + * @return 摄像头预置位列表 + */ + @Override + public List queryList(MonDevicePresetBo bo) { + LambdaQueryWrapper lqw = buildQueryWrapper(bo); + return baseMapper.selectVoList(lqw); + } + + private LambdaQueryWrapper buildQueryWrapper(MonDevicePresetBo bo) { + Map params = bo.getParams(); + LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); + lqw.orderByAsc(MonDevicePreset::getId); + lqw.eq(StringUtils.isNotBlank(bo.getDeviceSerial()), MonDevicePreset::getDeviceSerial, bo.getDeviceSerial()); + lqw.eq(bo.getChannelNo() != null, MonDevicePreset::getChannelNo, bo.getChannelNo()); + lqw.eq(bo.getPresetIndex() != null, MonDevicePreset::getPresetIndex, bo.getPresetIndex()); + lqw.like(StringUtils.isNotBlank(bo.getPresetName()), MonDevicePreset::getPresetName, bo.getPresetName()); + return lqw; + } + + /** + * 新增摄像头预置位 + * + * @param bo 摄像头预置位 + * @return 是否新增成功 + */ + @Override + public Boolean insertByBo(MonDevicePresetBo bo) { + MonDevicePreset add = MapstructUtils.convert(bo, MonDevicePreset.class); + validEntityBeforeSave(add); + String jsonStr = HttpRequest + .post(YsPort.ADDDEVICEPRESETURLBYPOST.getSite()). + form("accessToken",monitoringYsService.getYsTokenService()) + .form("deviceSerial", add.getDeviceSerial()) + .form("channelNo", add.getChannelNo()) + .execute().body(); + JSONObject jsonObject = JSONUtil.parseObj(jsonStr.trim()); + + Map page1 = JSONUtil.parseObj(jsonObject.get("data")).toBean(Map.class); + + + add.setPresetIndex(Integer.parseInt(page1.get("index").toString())); + add.setId(SnowFlakeUtil.getID()); + + boolean flag = baseMapper.insert(add) > 0; + if (flag) { + bo.setId(add.getId()); + } + return flag; + } + + /** + * 修改摄像头预置位 + * + * @param bo 摄像头预置位 + * @return 是否修改成功 + */ + @Override + public Boolean updateByBo(MonDevicePresetBo bo) { + MonDevicePreset update = MapstructUtils.convert(bo, MonDevicePreset.class); + String jsonStr = HttpRequest + .post(YsPort.ADDDEVICEPRESETURLBYPOST.getSite()). + form("accessToken",monitoringYsService.getYsTokenService()) + .form("deviceSerial", update.getDeviceSerial()) + .form("channelNo", update.getChannelNo()) + .execute().body(); + JSONObject jsonObject = JSONUtil.parseObj(jsonStr.trim()); + + Map page1 = JSONUtil.parseObj(jsonObject.get("data")).toBean(Map.class); + + + update.setPresetIndex(Integer.parseInt(page1.get("index").toString())); + + + + validEntityBeforeSave(update); + return baseMapper.updateById(update) > 0; + } + + /** + * 保存前的数据校验 + */ + private void validEntityBeforeSave(MonDevicePreset entity){ + //TODO 做一些数据校验,如唯一约束 + } + + /** + * 校验并批量删除摄像头预置位信息 + * + * @param + * @param isValid 是否进行有效性校验 + * @return 是否删除成功 + */ + @Override + public Boolean deleteWithValidByIds(List yzd, Boolean isValid) { + if(isValid){ + if (yzd.size() >0){ + yzd.stream().forEach(temp ->{ + HttpRequest + .post(YsPort.DELETEDEVICEPRESETURLBYPOST.getSite()). + form("accessToken",monitoringYsService.getYsTokenService()) + .form("deviceSerial", temp.getDeviceSerial()) + .form("channelNo", temp.getChannelNo()) + .form("index", temp.getPresetIndex()) + .execute().body(); + }); + } + } + Collection collect = yzd.stream().map(temp -> { + return temp.getId(); + }).collect(Collectors.toList()); + return baseMapper.deleteByIds(collect) > 0; + } + + @Override + public boolean invoking(List yzd) { + try { + yzd.stream().forEach(temp ->{{ + HttpRequest + .post(YsPort.MOVEDEVICEPRESETURLBYPOST.getSite()). + form("accessToken",monitoringYsService.getYsTokenService()) + .form("deviceSerial", temp.getDeviceSerial()) + .form("channelNo", temp.getChannelNo()) + .form("index", temp.getPresetIndex()) + .execute().body(); + }}); + }catch (Exception e) { + return false; + } + + return true; + } +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonEquipmentListServiceImpl.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonEquipmentListServiceImpl.java new file mode 100644 index 0000000..132969a --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonEquipmentListServiceImpl.java @@ -0,0 +1,141 @@ +package org.dromara.monitoring.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.dromara.common.core.utils.MapstructUtils; +import org.dromara.common.core.utils.StringUtils; +import org.dromara.common.mybatis.core.page.PageQuery; +import org.dromara.common.mybatis.core.page.TableDataInfo; +import org.dromara.monitoring.domain.MonEquipmentList; +import org.dromara.monitoring.domain.bo.MonEquipmentListBo; +import org.dromara.monitoring.domain.vo.MonEquipmentListVo; +import org.dromara.monitoring.mapper.MonEquipmentListMapper; +import org.dromara.monitoring.service.IMonEquipmentListService; +import org.springframework.stereotype.Service; + +import java.util.Collection; +import java.util.List; +import java.util.Map; + +/** + * 设备列Service业务层处理 + * + * @author LionLi + * @date 2025-09-25 + */ +@Slf4j +@RequiredArgsConstructor +@Service +public class MonEquipmentListServiceImpl implements IMonEquipmentListService { + + private final MonEquipmentListMapper baseMapper; + + /** + * 查询设备列 + * + * @param id 主键 + * @return 设备列 + */ + @Override + public MonEquipmentListVo queryById(Long id){ + return baseMapper.selectVoById(id); + } + + /** + * 分页查询设备列列表 + * + * @param bo 查询条件 + * @param pageQuery 分页参数 + * @return 设备列分页列表 + */ + @Override + public TableDataInfo queryPageList(MonEquipmentListBo bo, PageQuery pageQuery) { + LambdaQueryWrapper lqw = buildQueryWrapper(bo); + Page result = baseMapper.selectVoPage(pageQuery.build(), lqw); + return TableDataInfo.build(result); + } + + /** + * 查询符合条件的设备列列表 + * + * @param bo 查询条件 + * @return 设备列列表 + */ + @Override + public List queryList(MonEquipmentListBo bo) { + LambdaQueryWrapper lqw = buildQueryWrapper(bo); + return baseMapper.selectVoList(lqw); + } + + private LambdaQueryWrapper buildQueryWrapper(MonEquipmentListBo bo) { + Map params = bo.getParams(); + LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); + lqw.orderByAsc(MonEquipmentList::getId); + lqw.eq(StringUtils.isNotBlank(bo.getDeviceSerial()), MonEquipmentList::getDeviceSerial, bo.getDeviceSerial()); + lqw.like(StringUtils.isNotBlank(bo.getDeviceName()), MonEquipmentList::getDeviceName, bo.getDeviceName()); + lqw.eq(StringUtils.isNotBlank(bo.getDeviceType()), MonEquipmentList::getDeviceType, bo.getDeviceType()); + lqw.eq(bo.getStatus() != null, MonEquipmentList::getStatus, bo.getStatus()); + lqw.eq(bo.getDefence() != null, MonEquipmentList::getDefence, bo.getDefence()); + lqw.eq(StringUtils.isNotBlank(bo.getDeviceVersion()), MonEquipmentList::getDeviceVersion, bo.getDeviceVersion()); + lqw.eq(bo.getAddTime() != null, MonEquipmentList::getAddTime, bo.getAddTime()); + lqw.eq(StringUtils.isNotBlank(bo.getParentCategory()), MonEquipmentList::getParentCategory, bo.getParentCategory()); + lqw.eq(bo.getRiskLevel() != null, MonEquipmentList::getRiskLevel, bo.getRiskLevel()); + lqw.eq(StringUtils.isNotBlank(bo.getNetAddress()), MonEquipmentList::getNetAddress, bo.getNetAddress()); + return lqw; + } + + /** + * 新增设备列 + * + * @param bo 设备列 + * @return 是否新增成功 + */ + @Override + public Boolean insertByBo(MonEquipmentListBo bo) { + MonEquipmentList add = MapstructUtils.convert(bo, MonEquipmentList.class); + validEntityBeforeSave(add); + boolean flag = baseMapper.insert(add) > 0; + if (flag) { + bo.setId(add.getId()); + } + return flag; + } + + /** + * 修改设备列 + * + * @param bo 设备列 + * @return 是否修改成功 + */ + @Override + public Boolean updateByBo(MonEquipmentListBo bo) { + MonEquipmentList update = MapstructUtils.convert(bo, MonEquipmentList.class); + validEntityBeforeSave(update); + return baseMapper.updateById(update) > 0; + } + + /** + * 保存前的数据校验 + */ + private void validEntityBeforeSave(MonEquipmentList entity){ + //TODO 做一些数据校验,如唯一约束 + } + + /** + * 校验并批量删除设备列信息 + * + * @param ids 待删除的主键集合 + * @param isValid 是否进行有效性校验 + * @return 是否删除成功 + */ + @Override + public Boolean deleteWithValidByIds(Collection ids, Boolean isValid) { + if(isValid){ + //TODO 做一些业务上的校验,判断是否需要校验 + } + return baseMapper.deleteByIds(ids) > 0; + } +} diff --git a/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonitoringYsServiceImpl.java b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonitoringYsServiceImpl.java new file mode 100644 index 0000000..046ac1a --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/java/org/dromara/monitoring/service/impl/MonitoringYsServiceImpl.java @@ -0,0 +1,267 @@ +package org.dromara.monitoring.service.impl; + + +import cn.hutool.http.HttpRequest; +import cn.hutool.json.JSONArray; +import cn.hutool.json.JSONObject; +import cn.hutool.json.JSONUtil; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.dromara.common.core.utils.StringUtils; +import org.dromara.common.satoken.utils.LoginHelper; +import org.dromara.monitoring.config.SnowFlakeUtil; +import org.dromara.monitoring.config.YsDto; +import org.dromara.monitoring.domain.MonEquipmentHistroy; +import org.dromara.monitoring.domain.MonEquipmentList; +import org.dromara.monitoring.domain.dto.DelYzd; +import org.dromara.monitoring.domain.dto.MonitoringListDto; +import org.dromara.monitoring.domain.vo.MonList; +import org.dromara.monitoring.domain.vo.MonYsVo; +import org.dromara.monitoring.mapper.MonitoringYsMapper; +import org.dromara.monitoring.monEnum.ListConstant; +import org.dromara.monitoring.monEnum.QualityEnum; +import org.dromara.monitoring.monEnum.YsPort; +import org.dromara.monitoring.service.MonitoringYsService; +import org.springframework.cache.annotation.Cacheable; +import org.springframework.stereotype.Service; + +import java.time.LocalDateTime; +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +import java.util.stream.Collectors; + +@Slf4j +@RequiredArgsConstructor +@Service +public class MonitoringYsServiceImpl implements MonitoringYsService { + + + private final YsDto ysDto; + + private final MonitoringYsMapper monitoringYsMapper; + + private final String GETDEVICELISTURL = "https://open.ys7.com/api/lapp/device/list"; + + + + @Override + @Cacheable(cacheNames = "opsMonToken#432000s") + public String getYsTokenService() { + + String jsonStr = HttpRequest.post(YsPort.GETTOKENURLBYPOST.getSite()). + form("appKey", ysDto.getAppKey()) + .form("appSecret", ysDto.getAppSecret()) + .execute().body(); + + + JSONObject jsonObject = JSONUtil.parseObj(jsonStr.trim()); + String accessToken = jsonObject.getJSONObject("data").getStr("accessToken"); + return accessToken; + } + + @Override + public MonList getMonitoringList(MonitoringListDto dto) { + + MonList monList = new MonList(); + + if (StringUtils.isEmpty(dto.getPageSize().toString())){ + dto.setPageSize(ListConstant.pageSize.getConstant()); + dto.setPageStart(ListConstant.PAGESTART.getConstant()); + } + +// 分页查询 + String jsonStr = HttpRequest + .post(YsPort.GETDEVICELISTURL.getSite()). + form("accessToken",getYsTokenService()) + .form("pageStart",dto.getPageStart() - 1) + .form("pageSize",dto.getPageSize()) + .execute().body(); + + JSONObject jsonObject = JSONUtil.parseObj(jsonStr.trim()); + List data = (List)jsonObject.get("data"); + + + Map page1 = JSONUtil.parseObj(jsonObject.get("page")).toBean(Map.class); + monList.setSum(Integer.parseInt(page1.get("total").toString())); + + + if(dto.getPageSize() != ListConstant.pageSize.getConstant()&& dto.getIsflow()) { + + List monEquipmentHistroys = new ArrayList(); + data = JSONUtil.toList(data.toString(), MonEquipmentList.class); + + data.stream().forEach(item -> { + MonEquipmentHistroy monEquipmentHistroy = new MonEquipmentHistroy(); + monEquipmentHistroy.setId(SnowFlakeUtil.getID()); + monEquipmentHistroy.setDeviceSerial(item.getDeviceSerial()); + monEquipmentHistroy.setDeviceName(item.getDeviceName()); + monEquipmentHistroy.setDeviceType(item.getDeviceType()); + monEquipmentHistroy.setUserId(LoginHelper.getUserId()); + monEquipmentHistroy.setDeptId(LoginHelper.getDeptId()); + monEquipmentHistroy.setProjectId(dto.getProjectId()); + monEquipmentHistroy.setCreateTime(LocalDateTime.now()); + monEquipmentHistroys.add(monEquipmentHistroy); + }); + +// 将返回的数据列为点击数据 + if (monEquipmentHistroys.size() > 0) { + monitoringYsMapper.insertHistroy(monEquipmentHistroys); + } + } + monList.setObject(data); + +// 查询所有并将数据存入数据库 :先判断数据库里是否有数据 + Integer sum = monitoringYsMapper.setSunList(); + + + + + if(sum != Integer.parseInt(page1.get("total").toString())){ + monitoringYsMapper.delList(); + insertMonitoring(Integer.parseInt(page1.get("total").toString()),1); + } + return monList; + } + + @Override + public MonYsVo getMonitoringDp() { + List list = monitoringYsMapper.selDpList(); + MonYsVo monYsVo = new MonYsVo(); + if (list.size() > 0){ + monYsVo.setSumMon(list.size()); + long count = list.stream().filter(item -> item.getStatus() == 1).count(); + monYsVo.setSumOnLine(count); + monYsVo.setSumOffLine(list.size() - count); + } + + return monYsVo; + } + + @Override + public String capturePho(DelYzd dto) { + String temp = HttpRequest + .post(YsPort.CAPTUREDEVICEURLBYPOST.getSite()). + form("accessToken",getYsTokenService()) + .form("deviceSerial",dto.getDeviceSerial()) + .form("channelNo",dto.getChannelNo()) + .form("quality", QualityEnum.HIGHDEFINITION.getValue()) + .execute().body(); + JSONObject jsonObject = JSONUtil.parseObj(temp.trim()); + Map bean = JSONUtil.parseObj(jsonObject.get("data")).toBean(Map.class); + /**Todo 后期照片需要对接ai识别 */ + return bean.get("picUrl").toString(); + } + + @Override + public Void test() { +// 查询所有的设备 + List monEquipmentList = monitoringYsMapper.selDpList(); + + monEquipmentList.forEach(item -> { + serialNumber(item); + }); + return null; + } + + + //格式化存储 + public void serialNumber(MonEquipmentList equipmentList){ + + ArrayList temp = selSTORAGEMEDIUMSTATUS(equipmentList.getDeviceSerial()); + if (temp.size() == 0)return; + + temp.forEach(s -> { + HttpRequest + .put(YsPort.DEVICESTORAGEMEDIUM.getSite()) + .header("accessToken",getYsTokenService()) + .form("deviceSerial",equipmentList.getDeviceSerial()) + .form("diskIndex",s) + .execute().body(); + }); + + } + + /** + * 查询存储状态 + * @param deviceSerial + * @return + */ + public ArrayList selSTORAGEMEDIUMSTATUS(String deviceSerial){ + + ArrayList res = new ArrayList<>(); + String body = HttpRequest + .get(YsPort.STORAGEMEDIUMSTATUS.getSite()) + .header("accessToken", getYsTokenService()) + .form("deviceSerial", deviceSerial) + .execute().body(); + + JSONObject jsonObject = JSONUtil.parseObj(body.trim()); + + + + + Map bean = JSONUtil.parseObj(jsonObject.get("data")).toBean(Map.class); + + if (bean.get("storageStatus") == null){return res;} + + JSONArray objects = JSONUtil.parseArray( bean.get("storageStatus").toString()); + + if (objects != null && objects.size() > 0){ + objects.stream().forEach(temp ->{ + Map temoMap = JSONUtil.parseObj(temp.toString()).toBean(Map.class); + res.add(temoMap.get("index").toString()); + }); + } + + return res; + + } + + + + public void insertMonitoring(Integer sum,Integer start){ + if (sum > 50){ + String temp = HttpRequest + .post(YsPort.GETDEVICELISTURL.getSite()). + form("accessToken",getYsTokenService()) + .form("pageStart",start - 1) + .form("pageSize",50) + .execute().body(); + + JSONObject jsonTemp = JSONUtil.parseObj(temp.trim()); + List tempList = (List)jsonTemp.get("data"); + tempList = JSONUtil.toList(tempList.toString(), MonEquipmentList.class); + List collect = tempList.stream().map(monEquipmentList -> { + + monEquipmentList.setId(SnowFlakeUtil.getID()); + return monEquipmentList; + }).collect(Collectors.toList()); + + monitoringYsMapper.insettList(collect); + start++; + sum = sum - 50; + insertMonitoring(sum,start); + }else { + String temp = HttpRequest + .post(YsPort.GETDEVICELISTURL.getSite()). + form("accessToken",getYsTokenService()) + .form("pageStart",start - 1) + .form("pageSize",sum) + .execute().body(); + + JSONObject jsonTemp = JSONUtil.parseObj(temp.trim()); + List tempList = (List)jsonTemp.get("data"); + tempList = JSONUtil.toList(tempList.toString(), MonEquipmentList.class); + List collect = tempList.stream().map(monEquipmentList -> { + + monEquipmentList.setId(SnowFlakeUtil.getID()); + return monEquipmentList; + }).collect(Collectors.toList()); + + monitoringYsMapper.insettList(collect); + } + } + + +} diff --git a/ruoyi-modules/xny-ops/src/main/resources/mapper/monitoring/MonitoringYsMapper.xml b/ruoyi-modules/xny-ops/src/main/resources/mapper/monitoring/MonitoringYsMapper.xml new file mode 100644 index 0000000..999ea5f --- /dev/null +++ b/ruoyi-modules/xny-ops/src/main/resources/mapper/monitoring/MonitoringYsMapper.xml @@ -0,0 +1,33 @@ + + + + +insert into mon_equipment_list (id, device_serial, device_name, device_type, status,defence,device_version,add_time,update_time,parent_category,risk_level,net_address) +values + + (#{item.id}, #{item.deviceSerial}, #{item.deviceName}, #{item.deviceType}, #{item.status}, #{item.defence}, #{item.deviceVersion}, #{item.addTime}, #{item.updateTime}, #{item.parentCategory}, #{item.riskLevel}, #{item.netAddress}) + + + + + insert into mon_equipment_histroy (id, device_serial, device_name, device_type, user_id,dept_id,project_id,create_time) + values + + (#{item.id}, #{item.deviceSerial}, #{item.deviceName}, #{item.deviceType}, #{item.userId}, #{item.deptId}, #{item.projectId}, #{item.createTime}) + + + + + + + + + +