package com.ruoyi.system.service.impl;
|
|
import com.ruoyi.common.basic.PageInfo;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.system.domain.SysDoorDevice;
|
import com.ruoyi.system.domain.SysVisitArea;
|
import com.ruoyi.system.dto.SysDoorDeviceAddRequest;
|
import com.ruoyi.system.dto.SysDoorDeviceDeleteRequest;
|
import com.ruoyi.system.dto.SysDoorDeviceDetailRequest;
|
import com.ruoyi.system.dto.SysDoorDeviceEditRequest;
|
import com.ruoyi.system.dto.SysDoorDeviceLogoutRequest;
|
import com.ruoyi.system.dto.SysDoorDevicePageRequest;
|
import com.ruoyi.system.dto.SysDoorDeviceStatusRequest;
|
import com.ruoyi.system.mapper.SysDoorDeviceMapper;
|
import com.ruoyi.system.mapper.SysVisitAreaMapper;
|
import com.ruoyi.system.service.ISysDoorDeviceService;
|
import com.ruoyi.system.vo.SysDoorDeviceVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 门禁设备服务实现
|
*
|
* @author ruoyi
|
*/
|
@Service
|
public class SysDoorDeviceServiceImpl implements ISysDoorDeviceService
|
{
|
private static final String ONLINE_STATUS_UNACTIVATED = "UNACTIVATED";
|
|
@Autowired
|
private SysDoorDeviceMapper doorDeviceMapper;
|
|
@Autowired
|
private SysVisitAreaMapper visitAreaMapper;
|
|
@Override
|
public PageInfo<SysDoorDeviceVO> pageList(SysDoorDevicePageRequest request)
|
{
|
SysDoorDevicePageRequest query = request == null ? new SysDoorDevicePageRequest() : request;
|
query.setDeviceName(StringUtils.trim(query.getDeviceName()));
|
query.setDeviceId(StringUtils.trim(query.getDeviceId()));
|
query.setOnlineStatus(StringUtils.trim(query.getOnlineStatus()));
|
PageInfo<SysDoorDeviceVO> pageInfo = new PageInfo<SysDoorDeviceVO>(query.getPageNum(), query.getPageSize());
|
List<SysDoorDeviceVO> list = doorDeviceMapper.pageList(query, pageInfo);
|
pageInfo.setRecords(list);
|
return pageInfo;
|
}
|
|
@Override
|
public SysDoorDeviceVO detail(SysDoorDeviceDetailRequest request)
|
{
|
Long doorId = getRequiredDoorId(request == null ? null : request.getDoorId());
|
SysDoorDeviceVO detail = doorDeviceMapper.selectVoById(doorId);
|
if (detail == null)
|
{
|
throw new ServiceException("门禁设备不存在");
|
}
|
return detail;
|
}
|
|
@Override
|
public int add(SysDoorDeviceAddRequest request, String username)
|
{
|
if (request == null)
|
{
|
throw new ServiceException("门禁设备内容不能为空");
|
}
|
SysDoorDevice doorDevice = buildDoorDevice(request.getAreaId(), request.getDeviceName(), request.getBrand(),
|
request.getDeviceId(), request.getRemark(), request.getEnabled(), null);
|
doorDevice.setOnlineStatus(ONLINE_STATUS_UNACTIVATED);
|
doorDevice.setCreateBy(username);
|
return doorDeviceMapper.insertDoorDevice(doorDevice);
|
}
|
|
@Override
|
public int edit(SysDoorDeviceEditRequest request, String username)
|
{
|
if (request == null)
|
{
|
throw new ServiceException("门禁设备内容不能为空");
|
}
|
Long doorId = getRequiredDoorId(request.getDoorId());
|
if (doorDeviceMapper.selectById(doorId) == null)
|
{
|
throw new ServiceException("门禁设备不存在");
|
}
|
SysDoorDevice doorDevice = buildDoorDevice(request.getAreaId(), request.getDeviceName(), request.getBrand(),
|
request.getDeviceId(), request.getRemark(), request.getEnabled(), doorId);
|
doorDevice.setDoorId(doorId);
|
doorDevice.setUpdateBy(username);
|
return doorDeviceMapper.updateDoorDevice(doorDevice);
|
}
|
|
@Override
|
public int changeStatus(SysDoorDeviceStatusRequest request, String username)
|
{
|
List<Long> doorIds = getRequiredDoorIds(request == null ? null : request.getDoorIds());
|
if (request.getEnabled() == null)
|
{
|
throw new ServiceException("启用状态不能为空");
|
}
|
return doorDeviceMapper.updateEnabled(doorIds, request.getEnabled(), username);
|
}
|
|
@Override
|
public int logout(SysDoorDeviceLogoutRequest request, String username)
|
{
|
List<Long> doorIds = getRequiredDoorIds(request == null ? null : request.getDoorIds());
|
return doorDeviceMapper.updateOnlineStatus(doorIds, ONLINE_STATUS_UNACTIVATED, username);
|
}
|
|
@Override
|
public int delete(SysDoorDeviceDeleteRequest request, String username)
|
{
|
List<Long> doorIds = getRequiredDoorIds(request == null ? null : request.getDoorIds());
|
return doorDeviceMapper.deleteByIds(doorIds, username);
|
}
|
|
private SysDoorDevice buildDoorDevice(Long areaId, String deviceName, String brand, String deviceId, String remark,
|
Boolean enabled, Long excludeDoorId)
|
{
|
Long requiredAreaId = getRequiredAreaId(areaId);
|
SysVisitArea area = visitAreaMapper.selectById(requiredAreaId);
|
if (area == null)
|
{
|
throw new ServiceException("所属区域不存在");
|
}
|
String requiredDeviceName = getRequiredText(deviceName, "设备名称不能为空");
|
String requiredBrand = getRequiredText(brand, "品牌不能为空");
|
String requiredDeviceId = getRequiredText(deviceId, "设备ID不能为空");
|
if (doorDeviceMapper.checkDeviceIdUnique(requiredDeviceId, excludeDoorId) != null)
|
{
|
throw new ServiceException("设备ID已存在");
|
}
|
|
SysDoorDevice doorDevice = new SysDoorDevice();
|
doorDevice.setAreaId(requiredAreaId);
|
doorDevice.setDeviceName(requiredDeviceName);
|
doorDevice.setBrand(requiredBrand);
|
doorDevice.setDeviceId(requiredDeviceId);
|
doorDevice.setRemark(StringUtils.trim(remark));
|
doorDevice.setEnabled(enabled == null ? Boolean.TRUE : enabled);
|
return doorDevice;
|
}
|
|
private Long getRequiredAreaId(Long areaId)
|
{
|
if (areaId == null || areaId <= 0)
|
{
|
throw new ServiceException("所属区域不能为空");
|
}
|
return areaId;
|
}
|
|
private Long getRequiredDoorId(Long doorId)
|
{
|
if (doorId == null || doorId <= 0)
|
{
|
throw new ServiceException("门禁设备主键不能为空");
|
}
|
return doorId;
|
}
|
|
private List<Long> getRequiredDoorIds(List<Long> doorIds)
|
{
|
if (CollectionUtils.isEmpty(doorIds))
|
{
|
throw new ServiceException("门禁设备主键集合不能为空");
|
}
|
for (Long doorId : doorIds)
|
{
|
getRequiredDoorId(doorId);
|
}
|
return doorIds;
|
}
|
|
private String getRequiredText(String value, String message)
|
{
|
String result = StringUtils.trim(value);
|
if (StringUtils.isEmpty(result))
|
{
|
throw new ServiceException(message);
|
}
|
return result;
|
}
|
}
|
