package com.moral.api.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.conditions.query.QueryChainWrapper;
|
import com.moral.api.entity.Device;
|
import com.moral.api.entity.MonitorPoint;
|
import com.moral.api.entity.ServicesScopeDevice;
|
import com.moral.api.mapper.DeviceMapper;
|
import com.moral.api.mapper.MonitorPointMapper;
|
import com.moral.api.mapper.ServicesScopeDeviceMapper;
|
import com.moral.api.service.ServicesScopeDeviceService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.moral.constant.Constants;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author moral
|
* @since 2022-01-17
|
*/
|
@Service
|
public class ServicesScopeDeviceServiceImpl extends ServiceImpl<ServicesScopeDeviceMapper, ServicesScopeDevice> implements ServicesScopeDeviceService {
|
|
@Autowired
|
private ServicesScopeDeviceMapper servicesScopeDeviceMapper;
|
|
@Autowired
|
private DeviceMapper deviceMapper;
|
|
@Autowired
|
private MonitorPointMapper monitorPointMapper;
|
|
@Override
|
public List<Map<String, Object>> getDevicesAndMonitorPoint(Map<String, Object> map) {
|
int servicesScopeId = Integer.parseInt(map.get("servicesScopeId").toString());
|
QueryWrapper<ServicesScopeDevice> servicesScopeDeviceQueryWrapper = new QueryWrapper<>();
|
servicesScopeDeviceQueryWrapper.eq("is_delete",Constants.NOT_DELETE);
|
servicesScopeDeviceQueryWrapper.eq("services_scope_id",servicesScopeId);
|
List<ServicesScopeDevice> servicesScopeDevices = servicesScopeDeviceMapper.selectList(servicesScopeDeviceQueryWrapper);
|
if (servicesScopeDevices.size() == 0){
|
return null;
|
}
|
List<Integer> deviceIds = servicesScopeDevices.stream().map(p -> p.getDeviceId()).collect(Collectors.toList());
|
QueryWrapper<Device> deviceQueryWrapper = new QueryWrapper<>();
|
deviceQueryWrapper.eq("is_delete",Constants.NOT_DELETE);
|
deviceQueryWrapper.in("id",deviceIds);
|
List<Device> devices = deviceMapper.selectList(deviceQueryWrapper);
|
if (devices.size() == 0){
|
return null;
|
}
|
List<Integer> monitorPointIds = devices.stream().map(p -> p.getMonitorPointId()).collect(Collectors.toList());
|
QueryWrapper<MonitorPoint> monitorPointQueryWrapper = new QueryWrapper<>();
|
monitorPointQueryWrapper.eq("is_delete",Constants.NOT_DELETE);
|
monitorPointQueryWrapper.in("id",monitorPointIds);
|
List<MonitorPoint> monitorPointList = monitorPointMapper.selectList(monitorPointQueryWrapper);
|
if (monitorPointList.size() == 0){
|
return null;
|
}
|
List resultList = new ArrayList();
|
for (MonitorPoint monitorPoint:monitorPointList) {
|
Map monitorPointMap = JSON.parseObject(JSON.toJSONString(monitorPoint), Map.class);
|
List deviceList = new ArrayList();
|
for (Device device:devices) {
|
if (device.getMonitorPointId().equals(monitorPoint.getId())){
|
deviceList.add(device);
|
}
|
}
|
monitorPointMap.put("devices",deviceList);
|
resultList.add(monitorPointMap);
|
}
|
return resultList;
|
}
|
}
|
