package com.doumee.service.business.impl; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.LoginUserInfo; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; import com.doumee.dao.business.YwDeviceMapper; import com.doumee.dao.business.YwDeviceRecordMapper; import com.doumee.dao.business.model.Category; import com.doumee.dao.business.model.Company; import com.doumee.dao.business.model.YwDevice; import com.doumee.dao.business.model.YwDeviceRecord; import com.doumee.dao.business.vo.YwDeviceDataVO; import com.doumee.dao.system.MultifileMapper; import com.doumee.dao.system.model.Multifile; import com.doumee.dao.system.model.SystemUser; import com.doumee.service.business.YwDeviceRecordService; import com.doumee.service.business.YwDeviceService; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.github.yulichang.wrapper.MPJLambdaWrapper; import lombok.extern.java.Log; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import java.util.Date; import java.util.List; import java.util.Objects; import java.util.stream.Collectors; /** * 运维设备信息表Service实现 * @author 江蹄蹄 * @date 2024/11/19 16:07 */ @Service public class YwDeviceServiceImpl implements YwDeviceService { @Autowired private YwDeviceMapper ywDeviceMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private MultifileMapper multifileMapper; @Autowired private YwDeviceRecordMapper ywDeviceRecordMapper; @Autowired private RedisTemplate redisTemplate; @Override public Integer create(YwDevice ywDevice) { if(Objects.isNull(ywDevice) || StringUtils.isBlank(ywDevice.getName()) || StringUtils.isBlank(ywDevice.getCode()) || Objects.isNull(ywDevice.getStatus()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } LoginUserInfo loginUserInfo = ywDevice.getLoginUserInfo(); if(ywDeviceMapper.selectCount(new QueryWrapper().lambda().eq(YwDevice::getIsdeleted,Constants.ZERO).eq(YwDevice::getCode,ywDevice.getCode()))>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"设备编号重复!"); } ywDevice.setCreateDate(new Date()); ywDevice.setCreator(loginUserInfo.getId()); ywDevice.setIsdeleted(Constants.ZERO); ywDeviceMapper.insert(ywDevice); if(Objects.nonNull(ywDevice.getFileUrl())){ Multifile multifile = new Multifile(); multifile.setCreator(loginUserInfo.getId()); multifile.setCreateDate(new Date()); multifile.setIsdeleted(Constants.ZERO); multifile.setObjType(Constants.MultiFile.FN_DEVICE_FILE.getKey()); multifile.setObjId(ywDevice.getId()); multifile.setFileurl(ywDevice.getFileUrl()); multifileMapper.insert(multifile); } return ywDevice.getId(); } @Override public void deleteById(Integer id, LoginUserInfo user) { //查询设备是否存在运维记录 if(ywDeviceRecordMapper.selectCount(new QueryWrapper().lambda().eq(YwDeviceRecord::getDeviceId,id).eq(YwDeviceRecord::getIsdeleted,Constants.ZERO))>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"当前设备存在运维记录，无法删除"); }; ywDeviceMapper.update(new UpdateWrapper() .lambda().set(YwDevice::getIsdeleted,Constants.ONE) .set(YwDevice::getEditDate, DateUtil.getCurrDateTime()) .set(YwDevice::getEditor,user.getId()) .eq(YwDevice::getId,id) ); } @Override public void delete(YwDevice ywDevice) { UpdateWrapper deleteWrapper = new UpdateWrapper<>(ywDevice); ywDeviceMapper.delete(deleteWrapper); } @Override public void deleteByIdInBatch(List ids, LoginUserInfo user) { if (CollectionUtils.isEmpty(ids)) { return; } ywDeviceMapper.deleteBatchIds(ids); } @Override public void updateById(YwDevice ywDevice) { if(Objects.isNull(ywDevice) || StringUtils.isBlank(ywDevice.getName()) || StringUtils.isBlank(ywDevice.getCode()) || Objects.isNull(ywDevice.getStatus()) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } LoginUserInfo loginUserInfo = ywDevice.getLoginUserInfo(); if(ywDeviceMapper.selectCount(new QueryWrapper().lambda().eq(YwDevice::getIsdeleted,Constants.ZERO) .eq(YwDevice::getCode,ywDevice.getCode()) .ne(YwDevice::getId,ywDevice.getId()))>Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"设备编号重复!"); } ywDevice.setEditDate(new Date()); ywDevice.setEditor(loginUserInfo.getId()); ywDeviceMapper.updateById(ywDevice); multifileMapper.delete(new QueryWrapper().lambda() .eq(Multifile::getObjId,ywDevice.getId()) .eq(Multifile::getObjType,Constants.MultiFile.FN_DEVICE_FILE.getKey()) ); if(Objects.nonNull(ywDevice.getFileUrl())){ Multifile multifile = new Multifile(); multifile.setCreator(loginUserInfo.getId()); multifile.setCreateDate(new Date()); multifile.setIsdeleted(Constants.ZERO); multifile.setObjType(Constants.MultiFile.FN_DEVICE_FILE.getKey()); multifile.setObjId(ywDevice.getId()); multifile.setFileurl(ywDevice.getFileUrl()); multifileMapper.insert(multifile); } } @Override public void updateByIdInBatch(List ywDevices) { if (CollectionUtils.isEmpty(ywDevices)) { return; } for (YwDevice ywDevice: ywDevices) { this.updateById(ywDevice); } } @Override public YwDevice findById(Integer id) { return ywDeviceMapper.selectById(id); } @Override public YwDevice getDetail(Integer id) { YwDevice ywDevice = ywDeviceMapper.selectById(id); Multifile multifile = multifileMapper.selectOne(new QueryWrapper().lambda() .eq(Multifile::getObjId,id).eq(Multifile::getObjType,Constants.MultiFile.FN_DEVICE_FILE.getKey()).last(" limit 1")); if(Objects.nonNull(multifile)){ String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() +systemDictDataBiz.queryByCode(Constants.FTP,Constants.YW_DEVICE).getCode(); ywDevice.setFileFullUrl(path + multifile.getFileurl()); } return ywDevice; } /** * 根据编码查询 * @param deviceCode * @return */ @Override public YwDevice findByCode(String deviceCode) { YwDevice ywDevice = ywDeviceMapper.selectOne( new QueryWrapper() .lambda() .eq(YwDevice::getIsdeleted,Constants.ZERO) .eq(YwDevice::getCode,deviceCode) .last(" limit 1 ") ); if(Objects.isNull(ywDevice)){ throw new BusinessException(ResponseStatus.DATA_EMPTY); } return ywDevice; } @Override public YwDevice findOne(YwDevice ywDevice) { QueryWrapper wrapper = new QueryWrapper<>(ywDevice); return ywDeviceMapper.selectOne(wrapper); } @Override public List findList(YwDevice ywDevice) { QueryWrapper wrapper = new QueryWrapper<>(ywDevice); return ywDeviceMapper.selectList(wrapper); } @Override public PageData findPage(PageWrap pageWrap) { IPage page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper queryWrapper = new MPJLambdaWrapper(); Utils.MP.blankToNull(pageWrap.getModel()); YwDevice model = pageWrap.getModel(); queryWrapper.selectAll(YwDevice.class) .selectAs(Category::getName,YwDevice::getCategoryName) .selectAs(SystemUser::getRealname,YwDevice::getRealName) .leftJoin(Category.class,Category::getId,YwDevice::getCateId) .leftJoin(SystemUser.class,SystemUser::getId,YwDevice::getUserId) .and(Objects.nonNull(model)&&StringUtils.isNotBlank(model.getName()),i->i.like(YwDevice::getName,model.getName()).or().like(YwDevice::getCode,model.getName())) .eq(Objects.nonNull(model.getStatus()),YwDevice::getStatus,model.getStatus()) .eq(YwDevice::getIsdeleted,Constants.ZERO) .orderByDesc(YwDevice::getCreateDate) ; IPage iPage = ywDeviceMapper.selectJoinPage(page,YwDevice.class,queryWrapper); return PageData.from(iPage); } @Override public long count(YwDevice ywDevice) { QueryWrapper wrapper = new QueryWrapper<>(ywDevice); return ywDeviceMapper.selectCount(wrapper); } @Override public YwDeviceDataVO getYwDeviceData(){ YwDeviceDataVO ywDeviceDataVO = new YwDeviceDataVO(); List ywDeviceList = ywDeviceMapper.selectList(new QueryWrapper().lambda().eq(YwDevice::getIsdeleted,Constants.ZERO)); if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywDeviceList)){ ywDeviceDataVO.setQualityNum(ywDeviceList.size()); ywDeviceDataVO.setTotalNum(ywDeviceList.size()); ywDeviceDataVO.setNormalNum(ywDeviceList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ZERO)).collect(Collectors.toList()).size()); ywDeviceDataVO.setAbnormalNum(ywDeviceList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ONE)).collect(Collectors.toList()).size()); ywDeviceDataVO.setScrapNum(ywDeviceList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.TWO)).collect(Collectors.toList()).size()); } return ywDeviceDataVO; } }