package com.ruoyi.oa.service.impl;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.http.HttpStatus;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.common.utils.DataFormatUtils;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.PageUtils;
|
import com.ruoyi.common.core.page.PagePlus;
|
import com.ruoyi.common.core.page.TableDataInfo;
|
import com.ruoyi.oa.domain.BsSchool;
|
import com.ruoyi.oa.domain.DevEquipmentCode;
|
import com.ruoyi.oa.mapper.DevEquipmentCodeMapper;
|
import com.ruoyi.oa.service.IBsSchoolService;
|
import com.ruoyi.oa.service.IDevEquipmentCodeService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.common.core.mybatisplus.core.ServicePlusImpl;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.ruoyi.oa.domain.bo.DevEquipmentBo;
|
import com.ruoyi.oa.domain.vo.DevEquipmentVo;
|
import com.ruoyi.oa.domain.DevEquipment;
|
import com.ruoyi.oa.mapper.DevEquipmentMapper;
|
import com.ruoyi.oa.service.IDevEquipmentService;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Collection;
|
|
/**
|
* 智控设备Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2021-12-05
|
*/
|
@Service
|
public class DevEquipmentServiceImpl extends ServicePlusImpl<DevEquipmentMapper, DevEquipment, DevEquipmentVo> implements IDevEquipmentService {
|
|
@Autowired
|
private IDevEquipmentCodeService devEquipmentCodeService;
|
|
@Autowired
|
private IBsSchoolService iBsSchoolService;
|
|
@Override
|
public DevEquipmentVo queryById(Long id) {
|
return getVoById(id);
|
}
|
|
@Override
|
public TableDataInfo<DevEquipmentVo> queryPageList(DevEquipmentBo bo) {
|
PagePlus<DevEquipment, DevEquipmentVo> result = pageVo(PageUtils.buildPagePlus(), buildQueryWrapper(bo));
|
return PageUtils.buildDataInfo(result);
|
}
|
|
@Override
|
public List<DevEquipmentVo> queryList(DevEquipmentBo bo) {
|
return listVo(buildQueryWrapper(bo));
|
}
|
|
private LambdaQueryWrapper<DevEquipment> buildQueryWrapper(DevEquipmentBo bo) {
|
Map<String, Object> params = bo.getParams();
|
LambdaQueryWrapper<DevEquipment> lqw = Wrappers.lambdaQuery();
|
lqw.like(bo.getSerialNumber() != null, DevEquipment::getSerialNumber, bo.getSerialNumber());
|
lqw.eq(bo.getType() != null, DevEquipment::getType, bo.getType());
|
lqw.like(bo.getSequenceCode() != null, DevEquipment::getSequenceCode, bo.getSequenceCode());
|
lqw.like(bo.getEdition() != null, DevEquipment::getEdition, bo.getEdition());
|
lqw.eq(bo.getSchoolId() != null, DevEquipment::getSchoolId, bo.getSchoolId());
|
lqw.like(bo.getHostId() != null, DevEquipment::getHostId, bo.getHostId());
|
lqw.like(bo.getNetworkId() != null, DevEquipment::getNetworkId, bo.getNetworkId());
|
lqw.eq(bo.getFrequencyBand() != null, DevEquipment::getFrequencyBand, bo.getFrequencyBand());
|
lqw.eq(bo.getUseStatus() != null, DevEquipment::getUseStatus, bo.getUseStatus());
|
lqw.orderByDesc(DevEquipment::getUpdateTime);
|
return lqw;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Boolean insertByBo(DevEquipmentBo bo) {
|
List<DevEquipment> list = baseMapper.selectList(new QueryWrapper<DevEquipment>().lambda()
|
.eq(DevEquipment::getSequenceCode, bo.getSequenceCode()));
|
if (list.size() > 0) {
|
throw new ServiceException("硬件序列码重复", HttpStatus.HTTP_PARTIAL);
|
}
|
DevEquipment add = BeanUtil.toBean(bo, DevEquipment.class);
|
validEntityBeforeSave(add);
|
boolean flag = save(add);
|
if (flag) {
|
bo.setId(add.getId());
|
}
|
return flag;
|
}
|
|
@Override
|
public Boolean updateByBo(DevEquipmentBo bo) {
|
List<DevEquipment> list = baseMapper.selectList(new QueryWrapper<DevEquipment>().lambda()
|
.eq(DevEquipment::getSequenceCode, bo.getSequenceCode())
|
.ne(DevEquipment::getId, bo.getId()));
|
if (list.size() > 0) {
|
throw new ServiceException("硬件序列码重复", HttpStatus.HTTP_PARTIAL);
|
}
|
DevEquipment update = BeanUtil.toBean(bo, DevEquipment.class);
|
validEntityBeforeSave(update);
|
return updateById(update);
|
}
|
|
/**
|
* 保存前的数据校验
|
*
|
* @param entity 实体类数据
|
*/
|
private void validEntityBeforeSave(DevEquipment entity) {
|
//TODO 做一些数据校验,如唯一约束
|
}
|
|
@Override
|
public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
|
if (isValid) {
|
//TODO 做一些业务上的校验,判断是否需要校验
|
}
|
return removeByIds(ids);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public DevEquipment externalAdd(DevEquipmentBo bo) {
|
DevEquipment po = baseMapper.selectOne(new QueryWrapper<DevEquipment>().lambda()
|
.eq(DevEquipment::getSequenceCode, bo.getSequenceCode()));
|
// 设备存在，直接返回设备信息
|
if (StringUtils.isNotEmpty(po)) {
|
return po;
|
}
|
// 设备不存在则新建
|
else {
|
if(bo.isRegister()) {
|
BsSchool bsSchool = iBsSchoolService.getById(5);
|
if(bsSchool == null){
|
throw new ServiceException("学校编号不存在，请先到线上维护", HttpStatus.HTTP_PARTIAL);
|
}
|
// 先根据序列码生成序列号
|
List<DevEquipmentCode> devEquipmentCodeList = devEquipmentCodeService.list();
|
DevEquipmentCode c = new DevEquipmentCode();
|
if(devEquipmentCodeList != null && devEquipmentCodeList.size() > 0){
|
c = devEquipmentCodeList.get(0);
|
}else{
|
c.setCreateTime(DateUtils.getNowDate());
|
c.setCode(Long.parseLong("1"));
|
c.setVersion(1);
|
devEquipmentCodeService.save(c);
|
}
|
int i = baseMapper.updateCode(c.getId(), c.getVersion());
|
if(i <= 0){
|
throw new ServiceException("设备编号表被占用，请稍后在校验", HttpStatus.HTTP_PARTIAL);
|
}
|
// 添加设备
|
DevEquipment add = BeanUtil.toBean(bo, DevEquipment.class);
|
String schoolCodeHex16 = "0".equals(Integer.toHexString(Integer.parseInt(bsSchool.getCode()))) ? "0000" : Integer.toHexString(Integer.parseInt(bsSchool.getCode()));//DataFormatUtils.strTo16(bsSchool.getCode());
|
String codeHex16 =DataFormatUtils.padLeft(Integer.toHexString(Integer.parseInt(c.getCode().toString())), 4);
|
String hostId = (schoolCodeHex16 + codeHex16).toUpperCase();
|
add.setHostId(hostId);
|
add.setSerialNumber(c.getCode());
|
add.setUseStatus("1");
|
baseMapper.insert(add);
|
return add;
|
}else{
|
return po;
|
}
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public DevEquipment equipmentEdit(DevEquipmentBo bo) {
|
DevEquipment po = baseMapper.selectById(bo.getId());
|
if (po == null) {
|
throw new ServiceException("没有设备信息", HttpStatus.HTTP_PARTIAL);
|
}
|
if (null != bo.getSchoolId()) {
|
po.setSchoolId(bo.getSchoolId());
|
}
|
if (StringUtils.isNotBlank(bo.getHostId())) {
|
po.setHostId(bo.getHostId());
|
}
|
if(StringUtils.isNotBlank(bo.getEdition())){
|
po.setEdition(bo.getEdition());
|
}
|
// if (StringUtils.isEmpty(bo.getNetworkId())) {
|
// po.setNetworkId(bo.getNetworkId());
|
// }
|
// if (StringUtils.isEmpty(bo.getFrequencyBand())) {
|
// po.setFrequencyBand(bo.getFrequencyBand());
|
// }
|
if (null != bo.getBatchId()) {
|
po.setBatchId(bo.getBatchId());
|
}
|
if (StringUtils.isNotBlank(bo.getRemarks())) {
|
po.setRemarks(bo.getRemarks());
|
}
|
baseMapper.updateById(po);
|
return po;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void submitComment(DevEquipmentBo bo) {
|
DevEquipment po = baseMapper.selectById(bo.getId());
|
if (po == null) {
|
throw new ServiceException("没有设备信息", HttpStatus.HTTP_PARTIAL);
|
}
|
if (null != bo.getBatchId()) {
|
po.setBatchId(bo.getBatchId());
|
}
|
if (StringUtils.isNotBlank(bo.getRemarks())) {
|
po.setRemarks(bo.getRemarks());
|
}
|
baseMapper.updateById(po);
|
}
|
}
|
