|
|
|
|
@ -3,9 +3,6 @@ package cn.iocoder.yudao.module.iot.service.devicemodelattribute;
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
|
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
|
|
|
|
import cn.iocoder.yudao.framework.common.util.validation.ValidationUtils;
|
|
|
|
|
import cn.iocoder.yudao.framework.common.util.collection.MapUtils;
|
|
|
|
|
import cn.iocoder.yudao.module.erp.dal.dataobject.product.ErpProductUnitDO;
|
|
|
|
|
import cn.iocoder.yudao.module.erp.service.product.ErpProductUnitService;
|
|
|
|
|
import cn.iocoder.yudao.module.iot.dal.dataobject.deviceattributetype.DeviceAttributeTypeDO;
|
|
|
|
|
import cn.iocoder.yudao.module.iot.dal.mysql.deviceattributetype.DeviceAttributeTypeMapper;
|
|
|
|
|
import cn.iocoder.yudao.module.iot.enums.ErrorCodeConstants;
|
|
|
|
|
@ -35,7 +32,6 @@ import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
|
|
|
|
import cn.iocoder.yudao.module.iot.dal.mysql.devicemodelattribute.DeviceModelAttributeMapper;
|
|
|
|
|
|
|
|
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
|
|
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
|
|
|
|
|
import static cn.iocoder.yudao.module.iot.enums.ErrorCodeConstants.*;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
@ -57,9 +53,6 @@ import static cn.iocoder.yudao.module.iot.enums.ErrorCodeConstants.*;
|
|
|
|
|
@Resource
|
|
|
|
|
private DeviceAttributeTypeMapper deviceAttributeTypeMapper;
|
|
|
|
|
|
|
|
|
|
@Resource
|
|
|
|
|
private ErpProductUnitService productUnitService;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public Long createDeviceModelAttribute(DeviceModelAttributeSaveReqVO createReqVO) {
|
|
|
|
|
@ -122,33 +115,9 @@ import static cn.iocoder.yudao.module.iot.enums.ErrorCodeConstants.*;
|
|
|
|
|
// List<DeviceAttributeTypeDO> attributeTypes = deviceAttributeTypeMapper.selectList();
|
|
|
|
|
// Map<Long, String> typeNameMap = attributeTypes.stream()
|
|
|
|
|
// .collect(Collectors.toMap(DeviceAttributeTypeDO::getId, DeviceAttributeTypeDO::getName));
|
|
|
|
|
Map<Long, ErpProductUnitDO> unitMap = productUnitService.getProductUnitMap(
|
|
|
|
|
pageResult.getList().stream()
|
|
|
|
|
.map(DeviceModelAttributeDO::getDataUnit)
|
|
|
|
|
.filter(StringUtils::isNotEmpty)
|
|
|
|
|
.map(str -> {
|
|
|
|
|
try {
|
|
|
|
|
return Long.valueOf(str.trim());
|
|
|
|
|
} catch (NumberFormatException e) {
|
|
|
|
|
return null;
|
|
|
|
|
}
|
|
|
|
|
})
|
|
|
|
|
.filter(Objects::nonNull)
|
|
|
|
|
.collect(Collectors.toSet())
|
|
|
|
|
);
|
|
|
|
|
// 转换并设置类型名称
|
|
|
|
|
PageResult<DeviceModelAttributeRespVO> respPageResult = BeanUtils.toBean(pageResult, DeviceModelAttributeRespVO.class, deviceModelAttribute -> {
|
|
|
|
|
String dataUnitStr = deviceModelAttribute.getDataUnit();
|
|
|
|
|
if (StringUtils.isNotBlank(dataUnitStr)) {
|
|
|
|
|
try {
|
|
|
|
|
Long dataUnitId = Long.valueOf(dataUnitStr.trim());
|
|
|
|
|
MapUtils.findAndThen(unitMap, dataUnitId,
|
|
|
|
|
unit -> deviceModelAttribute.setDataUnitName(unit.getName()));
|
|
|
|
|
} catch (NumberFormatException e) {
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
// 转换并设置类型名称
|
|
|
|
|
PageResult<DeviceModelAttributeRespVO> respPageResult = BeanUtils.toBean(pageResult, DeviceModelAttributeRespVO.class);
|
|
|
|
|
|
|
|
|
|
// respPageResult.getList().forEach(item -> {
|
|
|
|
|
// String typeName = typeNameMap.get(item.getAttributeType());
|
|
|
|
|
|