|
|
|
@ -42,6 +42,7 @@ import com.alibaba.fastjson.JSON;
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
|
@ -63,6 +64,7 @@ import java.text.SimpleDateFormat;
|
|
|
|
import java.time.LocalDateTime;
|
|
|
|
import java.time.LocalDateTime;
|
|
|
|
import java.time.format.DateTimeFormatter;
|
|
|
|
import java.time.format.DateTimeFormatter;
|
|
|
|
import java.util.*;
|
|
|
|
import java.util.*;
|
|
|
|
|
|
|
|
import java.util.function.Function;
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
|
|
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
|
@ -1184,91 +1186,110 @@ public class DeviceServiceImpl implements DeviceService {
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public List<Map<String, Object>> getMultiDeviceAttributes(Long goviewId) {
|
|
|
|
public List<Map<String, Object>> getMultiDeviceAttributes(Long goviewId) {
|
|
|
|
|
|
|
|
|
|
|
|
List<Map<String, Object>> result = new ArrayList<>();
|
|
|
|
List<Map<String, Object>> result = new ArrayList<>();
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
// 直接从数据库查询deviceIds JSON字符串
|
|
|
|
|
|
|
|
String deviceIdsJson = deviceMapper.selectDeviceIdsByGoviewId(goviewId);
|
|
|
|
String deviceIdsJson = deviceMapper.selectDeviceIdsByGoviewId(goviewId);
|
|
|
|
if (StringUtils.isBlank(deviceIdsJson)) {
|
|
|
|
if (StringUtils.isBlank(deviceIdsJson)) {
|
|
|
|
log.info("No deviceIds found for goviewId: {}", goviewId);
|
|
|
|
|
|
|
|
return result;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 解析JSON格式的deviceIds
|
|
|
|
// 1. 解析（允许重复 device）
|
|
|
|
Map<Long, Set<Long>> deviceAttributeMap = parseDeviceIdsJson(deviceIdsJson);
|
|
|
|
List<Map.Entry<Long, Set<Long>>> deviceAttributeList =
|
|
|
|
if (deviceAttributeMap.isEmpty()) {
|
|
|
|
parseDeviceIdsJson(deviceIdsJson);
|
|
|
|
log.warn("No valid device-attribute mapping found for goviewId: {}", goviewId);
|
|
|
|
|
|
|
|
|
|
|
|
if (CollectionUtils.isEmpty(deviceAttributeList)) {
|
|
|
|
return result;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 批量获取所有设备的最新运行记录，减少数据库查询次数
|
|
|
|
// 2. 收集所有 deviceId / attributeId（用于批量查询）
|
|
|
|
Map<Long, DeviceOperationRecordDO> latestRecordMap = getLatestDeviceOperationRecords(deviceAttributeMap.keySet());
|
|
|
|
Set<Long> allDeviceIds = deviceAttributeList.stream()
|
|
|
|
|
|
|
|
.map(Map.Entry::getKey)
|
|
|
|
|
|
|
|
.collect(Collectors.toSet());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Set<Long> allAttributeIds = deviceAttributeList.stream()
|
|
|
|
|
|
|
|
.flatMap(e -> e.getValue().stream())
|
|
|
|
|
|
|
|
.collect(Collectors.toSet());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 3. 批量查设备
|
|
|
|
|
|
|
|
Map<Long, DeviceDO> deviceMap = deviceMapper
|
|
|
|
|
|
|
|
.selectBatchIds(allDeviceIds)
|
|
|
|
|
|
|
|
.stream()
|
|
|
|
|
|
|
|
.collect(Collectors.toMap(DeviceDO::getId, Function.identity()));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 4. 批量查属性
|
|
|
|
|
|
|
|
Map<Long, DeviceContactModelDO> attributeMap =
|
|
|
|
|
|
|
|
deviceContactModelMapper.selectList(
|
|
|
|
|
|
|
|
Wrappers.<DeviceContactModelDO>lambdaQuery()
|
|
|
|
|
|
|
|
.in(DeviceContactModelDO::getId, allAttributeIds)
|
|
|
|
|
|
|
|
).stream().collect(Collectors.toMap(
|
|
|
|
|
|
|
|
DeviceContactModelDO::getId,
|
|
|
|
|
|
|
|
Function.identity()
|
|
|
|
|
|
|
|
));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 5. 批量查运行状态
|
|
|
|
|
|
|
|
Map<Long, DeviceOperationRecordDO> latestRecordMap =
|
|
|
|
|
|
|
|
getLatestDeviceOperationRecords(allDeviceIds);
|
|
|
|
|
|
|
|
|
|
|
|
log.info("Found {} devices with attribute mappings for goviewId {}: {}",
|
|
|
|
// 6. 批量查最新采集数据（需为批量方法）
|
|
|
|
deviceAttributeMap.size(), goviewId, deviceAttributeMap);
|
|
|
|
Map<Long, Map<Long, Map<String, Object>>> deviceDataMap =
|
|
|
|
|
|
|
|
createDeviceDataMapBatch(allDeviceIds, attributeMap);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 7. 按原始结构组装（不合并重复设备）
|
|
|
|
|
|
|
|
for (Map.Entry<Long, Set<Long>> entry : deviceAttributeList) {
|
|
|
|
|
|
|
|
|
|
|
|
// 遍历每个设备ID，获取设备属性数据
|
|
|
|
|
|
|
|
for (Map.Entry<Long, Set<Long>> entry : deviceAttributeMap.entrySet()) {
|
|
|
|
|
|
|
|
Long deviceId = entry.getKey();
|
|
|
|
Long deviceId = entry.getKey();
|
|
|
|
Set<Long> attributeIds = entry.getValue();
|
|
|
|
Set<Long> attributeIds = entry.getValue();
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
DeviceDO device = deviceMap.get(deviceId);
|
|
|
|
// 获取设备信息
|
|
|
|
|
|
|
|
DeviceDO device = deviceMapper.selectById(deviceId);
|
|
|
|
|
|
|
|
if (device == null) {
|
|
|
|
if (device == null) {
|
|
|
|
log.warn("Device not found for ID: {}", deviceId);
|
|
|
|
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 创建设备层级的Map
|
|
|
|
Map<String, Object> deviceResult = new HashMap<>();
|
|
|
|
Map<String, Object> deviceMap = new HashMap<>();
|
|
|
|
deviceResult.put("deviceId", deviceId);
|
|
|
|
deviceMap.put("deviceId", deviceId);
|
|
|
|
deviceResult.put("deviceName", device.getDeviceName());
|
|
|
|
deviceMap.put("deviceName", device.getDeviceName());
|
|
|
|
deviceResult.put("deviceCode", device.getDeviceCode());
|
|
|
|
deviceMap.put("deviceCode", device.getDeviceCode());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 添加设备运行状态
|
|
|
|
String operatingStatus =
|
|
|
|
String operatingStatus = getDeviceOperatingStatus(deviceId, latestRecordMap);
|
|
|
|
getDeviceOperatingStatus(deviceId, latestRecordMap);
|
|
|
|
deviceMap.put("operatingStatus", operatingStatus);
|
|
|
|
deviceResult.put("operatingStatus", operatingStatus);
|
|
|
|
|
|
|
|
|
|
|
|
// 获取设备属性列表，只查询指定的属性ID
|
|
|
|
List<Map<String, Object>> attributeList = new ArrayList<>();
|
|
|
|
List<DeviceContactModelDO> attributes = deviceContactModelMapper.selectList(
|
|
|
|
|
|
|
|
Wrappers.<DeviceContactModelDO>lambdaQuery()
|
|
|
|
|
|
|
|
.eq(DeviceContactModelDO::getDeviceId, deviceId)
|
|
|
|
|
|
|
|
.in(DeviceContactModelDO::getId, attributeIds));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 获取设备最新数据
|
|
|
|
Map<Long, Map<String, Object>> deviceAttrData =
|
|
|
|
Map<Long, Map<String, Object>> deviceDataMap = createDeviceDataMap(deviceId);
|
|
|
|
deviceDataMap.getOrDefault(deviceId, Collections.emptyMap());
|
|
|
|
|
|
|
|
|
|
|
|
// 创建属性集合
|
|
|
|
for (Long attributeId : attributeIds) {
|
|
|
|
List<Map<String, Object>> attributeList = new ArrayList<>();
|
|
|
|
|
|
|
|
for (DeviceContactModelDO attribute : attributes) {
|
|
|
|
|
|
|
|
Map<String, Object> attributeData = new HashMap<>();
|
|
|
|
|
|
|
|
attributeData.put("attributeId", attribute.getId());
|
|
|
|
|
|
|
|
attributeData.put("attributeName", attribute.getAttributeName());
|
|
|
|
|
|
|
|
attributeData.put("attributeCode", attribute.getAttributeCode());
|
|
|
|
|
|
|
|
attributeData.put("dataType", attribute.getDataType());
|
|
|
|
|
|
|
|
attributeData.put("dataUnit", attribute.getDataUnit());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 获取最新数据
|
|
|
|
|
|
|
|
Map<String, Object> latestData = deviceDataMap.get(attribute.getId());
|
|
|
|
|
|
|
|
if (latestData != null) {
|
|
|
|
|
|
|
|
attributeData.put("addressValue", adjustByRatio(latestData.get("addressValue"), attribute.getRatio()));
|
|
|
|
|
|
|
|
attributeData.put("latestCollectionTime", latestData.get("timestamp"));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
attributeList.add(attributeData);
|
|
|
|
DeviceContactModelDO attribute = attributeMap.get(attributeId);
|
|
|
|
|
|
|
|
if (attribute == null) {
|
|
|
|
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 将属性集合添加到设备层级
|
|
|
|
Map<String, Object> attrResult = new HashMap<>();
|
|
|
|
deviceMap.put("attributes", attributeList);
|
|
|
|
attrResult.put("attributeId", attribute.getId());
|
|
|
|
|
|
|
|
attrResult.put("attributeName", attribute.getAttributeName());
|
|
|
|
|
|
|
|
attrResult.put("attributeCode", attribute.getAttributeCode());
|
|
|
|
|
|
|
|
attrResult.put("dataType", attribute.getDataType());
|
|
|
|
|
|
|
|
attrResult.put("dataUnit", attribute.getDataUnit());
|
|
|
|
|
|
|
|
|
|
|
|
// 添加到结果列表
|
|
|
|
Map<String, Object> latestData = deviceAttrData.get(attributeId);
|
|
|
|
result.add(deviceMap);
|
|
|
|
if (latestData != null) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
attrResult.put("addressValue",
|
|
|
|
log.error("Error processing device ID: {} with attributes: {}", deviceId, attributeIds, e);
|
|
|
|
adjustByRatio(latestData.get("addressValue"), attribute.getRatio()));
|
|
|
|
// 继续处理其他设备，不中断整体流程
|
|
|
|
attrResult.put("latestCollectionTime", latestData.get("timestamp"));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
attributeList.add(attrResult);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
deviceResult.put("attributes", attributeList);
|
|
|
|
|
|
|
|
result.add(deviceResult);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
log.error("Failed to get multi-device attributes by goviewId: {}", goviewId, e);
|
|
|
|
log.error("Failed to get multi-device attributes by goviewId: {}", goviewId, e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@ -1276,6 +1297,11 @@ public class DeviceServiceImpl implements DeviceService {
|
|
|
|
return result;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private Map<Long, Map<Long, Map<String, Object>>> createDeviceDataMapBatch(Set<Long> allDeviceIds, Map<Long, DeviceContactModelDO> deviceContactModelDOMap) {
|
|
|
|
|
|
|
|
return tdengineService.createDeviceDataMapBatch(allDeviceIds,deviceContactModelDOMap);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 获取设备运行状态
|
|
|
|
* 获取设备运行状态
|
|
|
|
* @param deviceId 设备ID
|
|
|
|
* @param deviceId 设备ID
|
|
|
|
@ -1327,74 +1353,60 @@ public class DeviceServiceImpl implements DeviceService {
|
|
|
|
* @param deviceIdsJson JSON格式的设备和属性映射字符串
|
|
|
|
* @param deviceIdsJson JSON格式的设备和属性映射字符串
|
|
|
|
* @return 设备ID到属性ID集合的映射（已去重）
|
|
|
|
* @return 设备ID到属性ID集合的映射（已去重）
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
private Map<Long, Set<Long>> parseDeviceIdsJson(String deviceIdsJson) {
|
|
|
|
private List<Map.Entry<Long, Set<Long>>> parseDeviceIdsJson(String deviceIdsJson) {
|
|
|
|
Map<Long, Set<Long>> deviceAttributeMap = new HashMap<>();
|
|
|
|
|
|
|
|
|
|
|
|
List<Map.Entry<Long, Set<Long>>> result = new ArrayList<>();
|
|
|
|
|
|
|
|
|
|
|
|
if (StringUtils.isBlank(deviceIdsJson)) {
|
|
|
|
if (StringUtils.isBlank(deviceIdsJson)) {
|
|
|
|
return deviceAttributeMap;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
// 使用Jackson解析JSON字符串
|
|
|
|
|
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
|
|
List<Map<String, Object>> deviceAttributeList = objectMapper.readValue(
|
|
|
|
|
|
|
|
deviceIdsJson, new TypeReference<List<Map<String, Object>>>() {});
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// 遍历解析结果，构建设备-属性映射并去重
|
|
|
|
List<Map<String, Object>> deviceAttributeList =
|
|
|
|
|
|
|
|
objectMapper.readValue(deviceIdsJson,
|
|
|
|
|
|
|
|
new TypeReference<List<Map<String, Object>>>() {});
|
|
|
|
|
|
|
|
|
|
|
|
for (Map<String, Object> item : deviceAttributeList) {
|
|
|
|
for (Map<String, Object> item : deviceAttributeList) {
|
|
|
|
try {
|
|
|
|
|
|
|
|
// 提取设备ID
|
|
|
|
|
|
|
|
Object deviceIdObj = item.get("deviceId");
|
|
|
|
Object deviceIdObj = item.get("deviceId");
|
|
|
|
if (deviceIdObj == null) {
|
|
|
|
if (deviceIdObj == null) {
|
|
|
|
log.warn("Device ID is null in item: {}", item);
|
|
|
|
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
Long deviceId = null;
|
|
|
|
|
|
|
|
|
|
|
|
Long deviceId;
|
|
|
|
if (deviceIdObj instanceof Number) {
|
|
|
|
if (deviceIdObj instanceof Number) {
|
|
|
|
deviceId = ((Number) deviceIdObj).longValue();
|
|
|
|
deviceId = ((Number) deviceIdObj).longValue();
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
deviceId = Long.parseLong(deviceIdObj.toString());
|
|
|
|
deviceId = Long.parseLong(deviceIdObj.toString());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 提取属性ID数组
|
|
|
|
Set<Long> attributeIds = new HashSet<>();
|
|
|
|
List<Long> attributeIds = new ArrayList<>();
|
|
|
|
|
|
|
|
Object attributesIdsObj = item.get("attributesIds");
|
|
|
|
Object attributesIdsObj = item.get("attributesIds");
|
|
|
|
if (attributesIdsObj instanceof List) {
|
|
|
|
if (attributesIdsObj instanceof List) {
|
|
|
|
List<?> attributesList = (List<?>) attributesIdsObj;
|
|
|
|
for (Object attrIdObj : (List<?>) attributesIdsObj) {
|
|
|
|
for (Object attrIdObj : attributesList) {
|
|
|
|
|
|
|
|
if (attrIdObj instanceof Number) {
|
|
|
|
if (attrIdObj instanceof Number) {
|
|
|
|
attributeIds.add(((Number) attrIdObj).longValue());
|
|
|
|
attributeIds.add(((Number) attrIdObj).longValue());
|
|
|
|
} else if (attrIdObj != null) {
|
|
|
|
} else if (attrIdObj != null) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
attributeIds.add(Long.parseLong(attrIdObj.toString()));
|
|
|
|
attributeIds.add(Long.parseLong(attrIdObj.toString()));
|
|
|
|
} catch (NumberFormatException e) {
|
|
|
|
} catch (Exception ignore) {
|
|
|
|
log.warn("Invalid attribute ID: {}", attrIdObj);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 合并属性ID到现有设备映射中（避免Lambda变量捕获问题）
|
|
|
|
// 每条记录单独保存，不合并
|
|
|
|
Set<Long> existingAttributes = deviceAttributeMap.get(deviceId);
|
|
|
|
result.add(new AbstractMap.SimpleEntry<>(deviceId, attributeIds));
|
|
|
|
if (existingAttributes == null) {
|
|
|
|
|
|
|
|
// 如果设备不存在，创建新的属性集合
|
|
|
|
|
|
|
|
Set<Long> newAttributesSet = new HashSet<>(attributeIds);
|
|
|
|
|
|
|
|
deviceAttributeMap.put(deviceId, newAttributesSet);
|
|
|
|
|
|
|
|
} else {
|
|
|
|
|
|
|
|
// 如果设备已存在，将新的属性ID添加到现有集合中
|
|
|
|
|
|
|
|
for (Long attrId : attributeIds) {
|
|
|
|
|
|
|
|
existingAttributes.add(attrId);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
|
|
|
log.warn("Error parsing device-attribute item: {}", item, e);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
log.error("Error parsing deviceIds JSON: {}", deviceIdsJson, e);
|
|
|
|
log.error("Error parsing deviceIds JSON: {}", deviceIdsJson, e);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return deviceAttributeMap;
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
|
HuangHuiKang
3 weeks ago