package com.gkhy.safePlatform.account.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gkhy.safePlatform.account.entity.device.Camera;
|
import com.gkhy.safePlatform.account.enums.DepartmentLevelEnum;
|
import com.gkhy.safePlatform.account.model.dto.req.AddAndUpdateCameraDTO;
|
import com.gkhy.safePlatform.account.model.dto.req.CameraQuery;
|
import com.gkhy.safePlatform.account.model.dto.resp.CameraRespDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.DepRespDTO;
|
import com.gkhy.safePlatform.account.model.dto.resp.UserInfoRespDTO;
|
import com.gkhy.safePlatform.account.service.AccountService;
|
import com.gkhy.safePlatform.account.service.CameraManageService;
|
import com.gkhy.safePlatform.account.service.DepartmentService;
|
import com.gkhy.safePlatform.account.service.baseService.CameraService;
|
import com.gkhy.safePlatform.commons.enums.ResultCodes;
|
import com.gkhy.safePlatform.commons.exception.BusinessException;
|
import com.gkhy.safePlatform.commons.vo.ResultVO;
|
import com.gkhy.safePlatform.commons.vo.SearchResultVO;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.transaction.Transactional;
|
import java.util.ArrayList;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
|
@Service
|
public class CameraManageServiceImpl implements CameraManageService {
|
|
@Autowired
|
private CameraService cameraService;
|
|
@Autowired
|
private DepartmentService departmentService;
|
|
@Autowired
|
private AccountService accountService;
|
|
@Override
|
@Transactional
|
public ResultVO saveNewCamera(AddAndUpdateCameraDTO dto) {
|
ResultVO resultVO = new ResultVO<>();
|
if(dto == null){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_NULL.getCode());
|
resultVO.setMsg("参数不能为空");
|
return resultVO;
|
}
|
if(dto.getDeviceNo() == null || dto.getDeviceNo().isEmpty()){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_NULL.getCode());
|
resultVO.setMsg("摄像机编号不能为空");
|
return resultVO;
|
}
|
if(dto.getName() == null || dto.getName().isEmpty()){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_NULL.getCode());
|
resultVO.setMsg("摄像机名称不能为空");
|
return resultVO;
|
}
|
if(dto.getShortName() == null || dto.getShortName().isEmpty()){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_NULL.getCode());
|
resultVO.setMsg("摄像机别名不能为空");
|
return resultVO;
|
}
|
if(dto.getBizDepId() == null || dto.getBizDepId() < 0){
|
resultVO.setCode(ResultCodes.CLIENT_PARAM_NULL.getCode());
|
resultVO.setMsg("摄像机所属事业部不能为空");
|
return resultVO;
|
}
|
if(cameraService.findByDeviceNo(dto.getDeviceNo()) != null){
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("摄像机编号已被使用");
|
return resultVO;
|
}
|
//判断是否为事业部
|
//判断部门是否存在
|
DepRespDTO dep = departmentService.getDepartmentInfoByDepId(dto.getBizDepId());
|
if(dep == null){
|
resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"部门不存在");
|
return resultVO;
|
}
|
if(!dep.getDepLevel().equals(DepartmentLevelEnum.BUSINESS.code)){
|
resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"部门必须为事业部");
|
return resultVO;
|
}
|
//检测名称和别名是否重复
|
List<Camera> cameraListByName = cameraService.listCamerasByName(dto.getName());
|
if(cameraListByName != null && !cameraListByName.isEmpty()){
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("摄像机名称不能重复");
|
return resultVO;
|
}
|
List<Camera> cameraListByShortName = cameraService.listCamerasByShortName(dto.getShortName());
|
if(cameraListByShortName != null && !cameraListByShortName.isEmpty()){
|
resultVO.setCode(ResultCodes.BUSINESS_ERROR.getCode());
|
resultVO.setMsg("摄像机简称不能重复");
|
return resultVO;
|
}
|
|
Camera camera = new Camera();
|
camera.setBizDepId(dto.getBizDepId());
|
camera.setDeviceNo(dto.getDeviceNo());
|
camera.setName(dto.getName());
|
camera.setShortName(dto.getShortName());
|
if(cameraService.saveNewCamera(camera) != 1){
|
throw new BusinessException(ResultCodes.SERVER_ADD_ERROR);
|
}
|
resultVO.setCode(ResultCodes.OK);
|
return resultVO;
|
}
|
|
@Override
|
@Transactional
|
public ResultVO updateCameraInfo(AddAndUpdateCameraDTO dto) {
|
if(dto == null || dto.getId() == null){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.CLIENT_PARAM_NULL.getCode(),"参数不能为空");
|
return resultVO;
|
}
|
if(dto.getDeviceNo() == null || dto.getDeviceNo().isEmpty()){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.CLIENT_PARAM_NULL.getCode(),"摄像机编号不能为空");
|
return resultVO;
|
}
|
if(dto.getName() == null || dto.getName().isEmpty()){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.CLIENT_PARAM_NULL.getCode(),"摄像机名称不能为空");
|
return resultVO;
|
}
|
if(dto.getShortName() == null || dto.getShortName().isEmpty()){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.CLIENT_PARAM_NULL.getCode(),"摄像机别名不能为空");
|
return resultVO;
|
}
|
if(dto.getBizDepId() == null || dto.getBizDepId() < 0){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.CLIENT_PARAM_NULL.getCode(),"摄像机所属事业部不能为空");
|
return resultVO;
|
}
|
//检查目标设备是否存在
|
Camera camera = cameraService.findByDeviceId(dto.getId());
|
if(camera == null){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"摄像机不存在");
|
return resultVO;
|
}
|
//判断设备号是否被使用
|
Camera cameraByNo = cameraService.findByDeviceNo(dto.getDeviceNo());
|
if(cameraByNo != null && !cameraByNo.getId().equals(camera.getId())){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"摄像机编号已经被使用");
|
return resultVO;
|
}
|
if(!camera.getBizDepId().equals(dto.getBizDepId())){
|
//判断部门是否存在
|
DepRespDTO dep = departmentService.getDepartmentInfoByDepId(dto.getBizDepId());
|
if(dep == null){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"部门不存在");
|
return resultVO;
|
}
|
if(!dep.getDepLevel().equals(DepartmentLevelEnum.BUSINESS.code)){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"部门必须为事业部");
|
return resultVO;
|
}
|
}
|
if(!camera.getName().equals(dto.getName())){
|
//检测名称和别名是否重复
|
List<Camera> cameraListByName = cameraService.listCamerasByName(dto.getName());
|
if(cameraListByName != null && !cameraListByName.isEmpty()){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"摄像机名称不能重复");
|
return resultVO;
|
}
|
}
|
if(!camera.getShortName().equals(dto.getShortName())){
|
List<Camera> cameraListByShortName = cameraService.listCamerasByShortName(dto.getShortName());
|
if(cameraListByShortName != null && !cameraListByShortName.isEmpty()){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"摄像机简称不能重复");
|
return resultVO;
|
}
|
}
|
//更新数据库
|
camera.setName(dto.getName());
|
camera.setShortName(dto.getShortName());
|
camera.setBizDepId(dto.getBizDepId());
|
camera.setDeviceNo(dto.getDeviceNo());
|
if(cameraService.updateCameraInfo(camera) <= 0){
|
throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
|
}
|
return new ResultVO<>(ResultCodes.OK);
|
}
|
|
@Override
|
@Transactional
|
public ResultVO deleteCameraById(Long cameraId) {
|
if(cameraId == null || cameraId < 0){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.CLIENT_PARAM_NULL.getCode(),"参数不能为空");
|
return resultVO;
|
}
|
//检查目标设备是否存在
|
Camera camera = cameraService.findByDeviceId(cameraId);
|
if(camera == null){
|
ResultVO resultVO = new ResultVO<>(ResultCodes.BUSINESS_ERROR.getCode(),"摄像机不存在");
|
return resultVO;
|
}
|
if(cameraService.deleteCamera(cameraId) != 1){
|
throw new BusinessException(ResultCodes.SERVER_DEL_ERROR);
|
}
|
return new ResultVO<>(ResultCodes.OK);
|
}
|
|
@Override
|
public SearchResultVO<CameraRespDTO> findByCameraId(Long id) {
|
SearchResultVO<CameraRespDTO> resultVO = new SearchResultVO<>(ResultCodes.OK);
|
resultVO.setUsePage(false);
|
if(id == null || id < 1)
|
return resultVO;
|
Camera camera = cameraService.findByDeviceId(id);
|
if(camera != null){
|
DepRespDTO depInfo = departmentService.getDepartmentInfoByDepId(camera.getBizDepId());
|
resultVO.setData(convertToRespDTO(camera,depInfo));
|
resultVO.setCount(1);
|
resultVO.setTotal(1L);
|
}
|
return resultVO;
|
}
|
|
@Override
|
public SearchResultVO<List<CameraRespDTO>> listCamerasByDepId(CameraQuery query) {
|
SearchResultVO<List<CameraRespDTO>> resultVO = new SearchResultVO<>(ResultCodes.OK);
|
resultVO.setUsePage(true);
|
resultVO.setPageSize(query.getPageSize());
|
resultVO.setPageIndex(query.getPageIndex());
|
Page page = new Page<>();
|
if(query.getPageSize() == null){
|
query.setPageSize(10L);
|
}
|
if(query.getPageIndex() == null){
|
query.setPageIndex(1L);
|
}
|
page.setSize(query.getPageSize());
|
page.setCurrent(query.getPageIndex());
|
if(query == null || query.getBizDepId() == null || query.getBizDepId() < 1){
|
return resultVO;
|
}
|
IPage<Camera> cameraPages = cameraService.listCamerasByBizDepId(page, query.getBizDepId());
|
if(cameraPages != null){
|
resultVO.setTotal(cameraPages.getTotal());
|
List<Camera> cameraList = cameraPages.getRecords();
|
List<CameraRespDTO> dtoList = convertToRespDTOList(cameraList);
|
resultVO.setData(dtoList);
|
if(dtoList != null)
|
resultVO.setCount(dtoList.size());
|
else
|
resultVO.setCount(0);
|
}
|
return resultVO;
|
}
|
|
@Override
|
public SearchResultVO<List<CameraRespDTO>> listCamerasByDepId(Long depId) {
|
SearchResultVO<List<CameraRespDTO>> resultVO = new SearchResultVO<>(ResultCodes.OK);
|
resultVO.setUsePage(false);
|
List<Camera> cameraList = cameraService.listCamerasByBizDepId(depId);
|
if(cameraList != null){
|
resultVO.setData(convertToRespDTOList(cameraList));
|
resultVO.setCount(cameraList.size());
|
}
|
return resultVO;
|
}
|
|
@Override
|
public SearchResultVO<List<CameraRespDTO>> listCamerasByCondition(CameraQuery query) {
|
SearchResultVO<List<CameraRespDTO>> resultVO = new SearchResultVO<>(ResultCodes.OK);
|
resultVO.setUsePage(true);
|
if(query.getPageSize() == null){
|
query.setPageSize(10L);
|
}
|
if(query.getPageIndex() == null){
|
query.setPageIndex(1L);
|
}
|
resultVO.setPageSize(query.getPageSize());
|
resultVO.setPageIndex(query.getPageIndex());
|
Page page = new Page<>(query.getPageIndex(), query.getPageSize());
|
if(query == null || (query.getBizDepId() != null && query.getBizDepId() < 1)){
|
return resultVO;
|
}
|
List<Camera> cameraList = cameraService.listCamerasByCondition(page, query.getBizDepId(), query.getName(), query.getShortName());
|
if(cameraList != null){
|
resultVO.setTotal(page.getTotal());
|
List<CameraRespDTO> dtoList = convertToRespDTOList(cameraList);
|
resultVO.setData(dtoList);
|
if(dtoList != null)
|
resultVO.setCount(dtoList.size());
|
else
|
resultVO.setCount(0);
|
}
|
return resultVO;
|
}
|
|
@Override
|
public SearchResultVO<List<CameraRespDTO>> listAccessCamerasByUserId(Long userId) {
|
SearchResultVO<List<CameraRespDTO>> resultVO = new SearchResultVO<>(ResultCodes.OK);
|
resultVO.setUsePage(false);
|
if(userId == null || userId < 1)
|
return resultVO;
|
//1、查询用户信息
|
UserInfoRespDTO userInfo = accountService.getUserInfoByUid(userId);
|
if(userInfo == null)
|
return resultVO;
|
DepRespDTO depInfo = departmentService.getDepartmentInfoByDepId(userInfo.getDepId());
|
if(depInfo == null)
|
return resultVO;
|
List<Camera> cameraList = null;
|
if(depInfo.getDepLevel().equals(DepartmentLevelEnum.COMPANY.code)){
|
//公司级用户，返回全部摄像头
|
cameraList = cameraService.listAllCameras();
|
}else if(depInfo.getDepLevel().equals(DepartmentLevelEnum.BUSINESS.code)){
|
//事业部级用户，查询本事业部
|
cameraList = cameraService.listCamerasByBizDepId(depInfo.getDepId());
|
}else {
|
//解析至事业部级部门
|
DepRespDTO busDep = praseBusinessDepId(depInfo);
|
if(busDep == null) {
|
return resultVO;
|
}
|
cameraList = cameraService.listCamerasByBizDepId(busDep.getDepId());
|
}
|
if(cameraList != null){
|
resultVO.setData(convertToRespDTOList(cameraList));
|
resultVO.setCount(cameraList.size());
|
}
|
return resultVO;
|
}
|
|
@Override
|
public SearchResultVO<List<CameraRespDTO>> listAllCameras() {
|
SearchResultVO<List<CameraRespDTO>> resultVO = new SearchResultVO<>(ResultCodes.OK);
|
resultVO.setUsePage(false);
|
List<Camera> cameraList = cameraService.listAllCameras();
|
if(cameraList != null){
|
resultVO.setData(convertToRespDTOList(cameraList));
|
resultVO.setCount(cameraList.size());
|
}
|
return resultVO;
|
}
|
|
@Override
|
public List<CameraRespDTO> listByCameraIdList(List<Long> cameraIdList) {
|
if(cameraIdList == null || cameraIdList.isEmpty()){
|
return null;
|
}
|
List<Camera> cameraList = cameraService.listByCameraIdList(cameraIdList);
|
return convertToRespDTOList(cameraList);
|
}
|
|
private List<CameraRespDTO> convertToRespDTOList(List<Camera> cameraList){
|
if(cameraList == null || cameraList.isEmpty()){
|
return null;
|
}
|
//获取部门信息
|
Set<Long> depIdSet = new HashSet<>();
|
cameraList.forEach(c -> {
|
depIdSet.add(c.getBizDepId());
|
});
|
List<Long> depIdList = new ArrayList<>();
|
depIdSet.forEach(id -> {
|
depIdList.add(id);
|
});
|
List<DepRespDTO> depList = departmentService.listDepByDepIds(depIdList);
|
List<CameraRespDTO> dtoList = new ArrayList<>();
|
for(int i = 0;i < cameraList.size();i++){
|
CameraRespDTO dto = convertToRespDTO(cameraList.get(i));
|
//读取部门名称
|
for(int j = 0; j < depList.size(); j++){
|
if(depList.get(j).getDepId().equals(dto.getBizDepId())){
|
dto.setDepName(depList.get(j).getDepName());
|
}
|
}
|
dtoList.add(dto);
|
}
|
return dtoList;
|
}
|
|
private CameraRespDTO convertToRespDTO(Camera camera){
|
if(camera == null)
|
return null;
|
CameraRespDTO dto = new CameraRespDTO();
|
BeanUtils.copyProperties(camera,dto);
|
return dto;
|
}
|
|
private CameraRespDTO convertToRespDTO(Camera camera,DepRespDTO depInfo){
|
if(camera == null)
|
return null;
|
CameraRespDTO dto = new CameraRespDTO();
|
BeanUtils.copyProperties(camera,dto);
|
if(depInfo != null)
|
dto.setDepName(depInfo.getDepName());
|
return dto;
|
}
|
|
private DepRespDTO praseBusinessDepId(DepRespDTO depRespDTO){
|
if(depRespDTO == null)
|
return null;
|
if(depRespDTO.getDepLevel().equals(DepartmentLevelEnum.COMPANY.code))
|
return depRespDTO;
|
if(depRespDTO.getDepLevel().equals(DepartmentLevelEnum.BUSINESS.code))
|
return depRespDTO;
|
//
|
if(depRespDTO.getParentDepId() == null){
|
return null;
|
}
|
depRespDTO = departmentService.getDepartmentInfoByDepId(depRespDTO.getParentDepId());
|
depRespDTO = praseBusinessDepId(depRespDTO);
|
return depRespDTO;
|
}
|
}
|
