package cn.besteam.modules.medical.service.impl;
|
|
import cn.besteam.common.constant.CacheKey;
|
import cn.besteam.common.constant.CommonConstant;
|
import cn.besteam.common.constant.ErrorCode;
|
import cn.besteam.common.exception.BusinessException;
|
import cn.besteam.common.util.RedisUtil;
|
import cn.besteam.modules.medical.entity.MwDeviceAgentDevice;
|
import cn.besteam.modules.medical.mapper.MwDeviceAgentDeviceMapper;
|
import cn.besteam.modules.medical.service.IMwDeviceAgentDeviceService;
|
import cn.besteam.modules.medical.vo.MwDeviceAgentDeviceAddBatchVO;
|
import cn.besteam.modules.medical.vo.MwDeviceAgentDeviceExcelVO;
|
import cn.besteam.modules.medical.vo.MwDeviceAgentDeviceVO;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
/**
|
* @Description: 设备代理商-设备
|
* @author： besteam
|
* @date： 2020-04-25
|
* @version： V1.0
|
*/
|
@Service
|
public class MwDeviceAgentDeviceServiceImpl extends ServiceImpl<MwDeviceAgentDeviceMapper, MwDeviceAgentDevice> implements IMwDeviceAgentDeviceService {
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Override
|
public IPage getDeviceList(String name, Integer pageNo, Integer pageSize) {
|
|
Page<MwDeviceAgentDeviceVO> page = new Page<>(pageNo, pageSize);
|
List<MwDeviceAgentDeviceVO> deviceList = baseMapper.getDeviceList(page, name);
|
page.setRecords(deviceList);
|
return page;
|
}
|
|
@Override
|
public boolean move(Integer id, Integer deviceAgentId) {
|
|
MwDeviceAgentDevice mwDeviceAgentDevice = getById(id);
|
if (mwDeviceAgentDevice == null) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_NOT_FOUND);
|
}
|
mwDeviceAgentDevice.setDeviceAgentId(deviceAgentId);
|
return updateById(mwDeviceAgentDevice);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public boolean moveBatch(String ids, Integer deviceAgentId) {
|
|
String[] idArray = ids.split(",");
|
for (String id : idArray) {
|
MwDeviceAgentDevice mwDeviceAgentDevice = getById(Integer.parseInt(id));
|
if (mwDeviceAgentDevice == null) {
|
continue;
|
}
|
mwDeviceAgentDevice.setDeviceAgentId(deviceAgentId);
|
updateById(mwDeviceAgentDevice);
|
}
|
return true;
|
}
|
|
@Override
|
public boolean updateStatus(Integer id, Integer status) {
|
|
if (status == null || status < 1 || status > 2) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_STATUS_INVALID);
|
}
|
MwDeviceAgentDevice mwDeviceAgentDevice = getById(id);
|
if (mwDeviceAgentDevice == null) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_NOT_FOUND);
|
}
|
mwDeviceAgentDevice.setStatus(status);
|
return updateById(mwDeviceAgentDevice);
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public boolean updateStatusBatch(String ids, Integer status) {
|
|
if (status == null || status < 1 || status > 2) {
|
throw new BusinessException(ErrorCode.MW_DEVICE_STATUS_INVALID);
|
}
|
String[] idArray = ids.split(",");
|
for (String id : idArray) {
|
MwDeviceAgentDevice mwDeviceAgentDevice = getById(Integer.parseInt(id));
|
if (mwDeviceAgentDevice == null) {
|
continue;
|
}
|
mwDeviceAgentDevice.setStatus(status);
|
updateById(mwDeviceAgentDevice);
|
}
|
return true;
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public MwDeviceAgentDeviceAddBatchVO addBatch(Integer deviceAgentId, String sns) {
|
|
MwDeviceAgentDeviceAddBatchVO vo = new MwDeviceAgentDeviceAddBatchVO();
|
List<String> saveList = new ArrayList<>();
|
List<String> replicateList = new ArrayList<>();
|
String[] snArray = sns.split("\\n");
|
for (String sn : snArray) {
|
MwDeviceAgentDevice device = getOne(new QueryWrapper<MwDeviceAgentDevice>().lambda().eq(MwDeviceAgentDevice::getSn, sn));
|
if (device != null) {
|
replicateList.add(sn);
|
continue;
|
}
|
if (saveList.contains(sn)) {
|
replicateList.add(sn);
|
continue;
|
}
|
device = new MwDeviceAgentDevice();
|
device.setStatus(CommonConstant.STATUS_NORMAL);
|
device.setDeviceAgentId(deviceAgentId);
|
device.setSn(sn);
|
save(device);
|
//
|
saveList.add(sn);
|
}
|
vo.setSaveList(saveList);
|
vo.setReplicateList(replicateList);
|
return vo;
|
}
|
|
@Override
|
public List<MwDeviceAgentDeviceExcelVO> getDeviceExcelList(Integer deviceAgentId) {
|
|
return baseMapper.getDeviceExcelList(deviceAgentId);
|
}
|
|
@Override
|
public Integer getDeviceValidateStatus() {
|
|
Integer status = 1;
|
if (!redisUtil.hasKey(CacheKey.getGlobalDeviceValidateStatusKey())) {
|
redisUtil.set(CacheKey.getGlobalDeviceValidateStatusKey(), status, -1);
|
} else {
|
status = redisUtil.get(CacheKey.getGlobalDeviceValidateStatusKey());
|
}
|
return status;
|
}
|
|
@Override
|
public boolean setDeviceValidateStatus(Integer status) {
|
|
return redisUtil.set(CacheKey.getGlobalDeviceValidateStatusKey(), status, -1);
|
}
|
|
}
|
