package cn.besteam.modules.medical.service.impl;
|
|
import cn.besteam.common.constant.DepartmentEnum;
|
import cn.besteam.modules.medical.biz.MonitorDeviceApiNewService;
|
import cn.besteam.modules.medical.entity.MwMonitorDevice;
|
import cn.besteam.modules.medical.mapper.MwMonitorDeviceMapper;
|
import cn.besteam.modules.medical.service.IMwMonitorDeviceService;
|
import cn.besteam.modules.medical.vo.MwMonitorDeviceVO;
|
import cn.besteam.modules.shiro.authc.util.EnvUtils;
|
import cn.besteam.modules.system.entity.SysDepartment;
|
import cn.besteam.modules.system.service.ISysDepartmentService;
|
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.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Description: 监控设备
|
* @author： besteam
|
* @date： 2020-07-14
|
* @version： V1.0
|
*/
|
@Service
|
public class MwMonitorDeviceServiceImpl extends ServiceImpl<MwMonitorDeviceMapper, MwMonitorDevice> implements IMwMonitorDeviceService {
|
|
@Autowired
|
private ISysDepartmentService sysDepartmentService;
|
@Autowired
|
private MonitorDeviceApiNewService monitorDeviceApiNewService;
|
|
@Override
|
public IPage<MwMonitorDeviceVO> queryPageList(Integer pageNo, Integer pageSize, Integer departmentId, String devIdno) {
|
|
Page<MwMonitorDeviceVO> pageParam = new Page<>(pageNo, pageSize);
|
//
|
SysDepartment myDepartment = sysDepartmentService.getMyDepartment(EnvUtils.getUser().getId());
|
if (myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.OFFICE.getType()) || myDepartment.getOrgType().equals(DepartmentEnum.OrgTypeEnum.DEPARTMENT.getType())) {
|
return pageParam;
|
}
|
if (departmentId != null) {
|
SysDepartment sysDepartment = sysDepartmentService.getById(departmentId);
|
if (sysDepartment == null) {
|
return pageParam;
|
}
|
myDepartment = sysDepartment;
|
}
|
//获取视频服务器中的在线设备列表
|
List<String> deviceList=monitorDeviceApiNewService.getDeviceList();
|
List<SysDepartment> sysDepartmentList = sysDepartmentService.list(new QueryWrapper<SysDepartment>().lambda().likeRight(SysDepartment::getTreeCode, myDepartment.getTreeCode()));
|
if (CollectionUtils.isNotEmpty(sysDepartmentList)) {
|
IPage<MwMonitorDeviceVO> resultPage = baseMapper.queryPageList(pageParam, sysDepartmentList.stream().map(SysDepartment::getId).collect(Collectors.toList()), devIdno);
|
for (MwMonitorDeviceVO vo : resultPage.getRecords()) {
|
//设置每个设备状态
|
vo.setStateName("离线");
|
for(String deviceID:deviceList){
|
if(deviceID.equals(vo.getDevIdno())){
|
vo.setStateName("在线");
|
break;
|
}
|
}
|
vo.setDepartmentIdList(sysDepartmentService.getParentIdList(vo.getHospitalId()));
|
}
|
return resultPage;
|
}
|
return pageParam;
|
}
|
|
}
|
