基于Java的cutebyte-end室内异常行为监测报警系统设计源码

package com.cutebytec.base.controller; import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.ArrayUtil; import cn.hutool.core.collection.CollUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.cutebytec.base.api.entity.BaseCustomerDeviceEntity; import com.cutebytec.base.api.entity.BaseDeviceEntity; import com.cutebytec.base.api.vo.BaseCustomerDeviceVo; import com.cutebytec.base.constant.DeviceManageTypeConstant; import com.cutebytec.base.service.BaseCustomerDeviceService; import com.cutebytec.cutebyte.common.core.util.R; import com.cutebytec.cutebyte.common.log.annotation.SysLog; import com.cutebytec.base.service.BaseDeviceService; import com.cutebytec.cutebyte.common.security.util.SecurityUtils; import com.cutebytec.ys.api.feign.RemoteYsAccountService; import com.cutebytec.ys.api.feign.RemoteYsDeviceService; import com.cutebytec.ys.api.properties.YsProperty; import org.springframework.security.access.prepost.PreAuthorize; import com.pig4cloud.plugin.excel.annotation.ResponseExcel; import io.swagger.v3.oas.annotations.security.SecurityRequirement; import org.springdoc.core.annotations.ParameterObject; import org.springframework.http.HttpHeaders; import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.Operation; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import java.util.ArrayList; import java.util.List; import java.util.Objects; import java.util.Set; /** * 设备管理 * * @author lty * @date 2024-03-11 08:25:21 */ @RestController @RequiredArgsConstructor //这一个保证了构造函数注入 所以可以不用 变量注入 @RequestMapping("/baseDevice" ) @Tag(description = "baseDevice" , name = "设备管理管理" ) @SecurityRequirement(name = HttpHeaders.AUTHORIZATION) public class BaseDeviceController { private final BaseDeviceService baseDeviceService; private final YsProperty ysProperty; private final RemoteYsAccountService remoteYsAccountService; private final RemoteYsDeviceService remoteYsDeviceService; private final BaseCustomerDeviceService baseCustomerDeviceService; /** * 分页查询客户具备权限的所有设备不包括 * @param page 分页对象 * @return */ @Operation(summary = "分页查询客户设备" , description = "分页查询客户设备" ) @GetMapping("/customer/allDev/page" ) public R getJustDeviceCustomerPage(@ParameterObject Page page) { //条件查询系统中所有设备 //todo 应该先查出设备所有具备权限的ID列表，再去查询过来 LambdaQueryWrapper<BaseDeviceEntity> dwrapper = Wrappers.lambdaQuery(); dwrapper.eq(BaseDeviceEntity::getType, DeviceManageTypeConstant.DEVICE); IPage res=baseDeviceService.page(page,dwrapper); return R.ok(res); } /** * 分页查询客户设备 只可以查询出分配给了 该客户都得设备 * @param page 分页对象 * @param baseDevice 设备管理 * @return */ @Operation(summary = "分页查询客户设备" , description = "分页查询客户设备" ) @GetMapping("/customer/page" ) public R getDeviceCustomerPage(@ParameterObject Page page, @ParameterObject BaseDeviceEntity baseDevice) { System.out.println("ggggg"); IPage res=null; Long id = SecurityUtils.getUser().getId(); if(Objects.isNull(id)){ throw new RuntimeException("身份认证失败"); } //查询条件查询用户具备管理权限得devId LambdaQueryWrapper<BaseCustomerDeviceEntity> wrapper = Wrappers.lambdaQuery(); wrapper.select(BaseCustomerDeviceEntity::getDeviceId); wrapper.eq(BaseCustomerDeviceEntity::getCustomerId,id); //条件查询设备 LambdaQueryWrapper<BaseDeviceEntity> dwrapper = Wrappers.lambdaQuery(); dwrapper.eq(StrUtil.isNotBlank(baseDevice.getDeviceSerial()),BaseDeviceEntity::getDeviceSerial,baseDevice.getDeviceSerial()); dwrapper.like(StrUtil.isNotBlank(baseDevice.getName()),BaseDeviceEntity::getName,baseDevice.getName()); dwrapper.eq(Objects.nonNull(baseDevice.getParentId()),BaseDeviceEntity::getParentId,baseDevice.getParentId()); dwrapper.eq(StrUtil.isNotBlank(baseDevice.getYsStatus()),BaseDeviceEntity::getYsStatus,baseDevice.getYsStatus()); dwrapper.eq(StrUtil.isNotBlank(baseDevice.getType()),BaseDeviceEntity::getType,baseDevice.getType()); //todo 如果前端传入了parentId则要判断当前用户是否具备parentId得这个权限 // (因为这个时候是用户在前台点击了一个用户具备权限得设备文件夹然后查看文件夹里面得设备，不过前提先判断权限） // （从数据库查询出所有得pId递归到最上级得pid作为列表） // 然后看是否可以从数据库设备权限表中查找树上面对应id得设备即可 能找多说明具备权限 不能找到说明不具备 Long parentId = baseDevice.getParentId(); if(Objects.nonNull(parentId)){ Set<Long> idByIdUpRecursive = baseDeviceService.getIdByIdUpRecursive(parentId); if(Objects.isNull(idByIdUpRecursive) || idByIdUpRecursive.size()<=0){ throw new RuntimeException("设备不存在未知异常！"); } wrapper.in(BaseCustomerDeviceEntity::getDeviceId,idByIdUpRecursive); //判断用户是否具备当前访问设备目录的数据权限 List<BaseCustomerDeviceEntity> list = baseCustomerDeviceService.list(wrapper); if(Objects.isNull(list) || list.size()<=0){ throw new RuntimeException("不具备访问权限"); } res=baseDeviceService.page(page,dwrapper); }else{ wrapper.eq(BaseCustomerDeviceEntity::getCustomerId,id); // List<Long> devIdList = baseCustomerDeviceService.listObjs(page,wrapper); //分页写在下面最后baseDeviceService.page 也可以 不再这里分页也可以 都可以这里暂时用这种 (区别和上一个分页的地方不同0 IPage iPage = baseCustomerDeviceService.selfPageGetDevId(page, wrapper); List<Long> devIdList = iPage.getRecords(); //devIdLis为空应该直接返回空(改用还没有任何具备权限的设备） if(Objects.isNull(devIdList) || devIdList.size()<=0){ return R.ok(new Page<>()); } //其它情况查询得就是用户的根目录下具备权限的所有设备 dwrapper.in(BaseDeviceEntity::getId, devIdList); iPage.setRecords(baseDeviceService.list(dwrapper)); res=iPage; } return R.ok(res); } /** * (缺少堆该用户是否具备该设备的访问权限再次去获取) * @param baseDevice * @return */ @Operation(summary = "获取设备访问token" , description = "获取设备访问token" ) @PostMapping("/device/token" ) public R getDeviceCustomerPage(@RequestBody BaseDeviceEntity baseDevice) { return R.ok(baseDeviceService.getDeviceAccessToken(baseDevice)); } //todo 或许为了统一之后其实或许（这里可以用设备serial代替id来查询单个设备信息或者其它操作等） /** * 通过id查询设备信息 * @return R */ @Operation(summary = "customer查询设备信息" , description = "通过id查询" ) @PostMapping("/getDevInfo" ) public R getDevInfo(@RequestBody BaseDeviceEntity baseDevice) { LambdaQueryWrapper<BaseDeviceEntity> dwrapper = Wrappers.lambdaQuery(); // dwrapper.eq(Objects.nonNull(baseDevice.getDeviceSerial()),BaseDeviceEntity::getDeviceSerial,baseDevice.getDeviceSerial()); if(Objects.isNull(baseDevice.getId()) && Objects.isNull(baseDevice.getDeviceSerial())){ throw new RuntimeException("设备id或者序列号不可以为空"); } dwrapper.eq(BaseDeviceEntity::getId,baseDevice.getId()); dwrapper.or(); dwrapper.eq(Objects.nonNull(baseDevice.getDeviceSerial()),BaseDeviceEntity::getDeviceSerial,baseDevice.getDeviceSerial()); BaseDeviceEntity one = baseDeviceService.getOne(dwrapper); return R.ok(one); } /********************* 下面是sys管理端用的居多 上面则