|
|
@@ -38,10 +38,7 @@ import com.usky.iot.domain.*;
|
|
|
import com.usky.common.security.utils.SecurityUtils;
|
|
|
import com.usky.iot.mapper.DmpDeviceInfoMapper;
|
|
|
import com.usky.iot.mapper.DmpProductAttributeMapper;
|
|
|
-import com.usky.iot.service.BaseFacilityDeviceService;
|
|
|
-import com.usky.iot.service.DmpDeviceInfoService;
|
|
|
-import com.usky.iot.service.DmpDeviceStatusService;
|
|
|
-import com.usky.iot.service.DmpProductAttributeService;
|
|
|
+import com.usky.iot.service.*;
|
|
|
import com.usky.iot.service.config.DeviceOperate;
|
|
|
import com.usky.iot.service.enums.TopicInfo;
|
|
|
import com.usky.iot.service.vo.*;
|
|
|
@@ -103,6 +100,9 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
@Autowired
|
|
|
private DmpProductAttributeMapper dmpProductAttributeMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private BaseSpaceGatewayService baseSpaceGatewayService;
|
|
|
+
|
|
|
@Autowired
|
|
|
private DeviceOperate deviceOperate;
|
|
|
|
|
|
@@ -647,6 +647,13 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
Integer pageSize = diRequest.getSize();
|
|
|
IPage<DmpDeviceInfo> page = new Page<>(pageCurrent, pageSize);
|
|
|
|
|
|
+ List<String> gatewayUuidList = new ArrayList<>();
|
|
|
+ if (diRequest.getSpaceId() != null) {
|
|
|
+ LambdaQueryWrapper<BaseSpaceGateway> spaceGatewayLambdaQueryWrapper = Wrappers.lambdaQuery();
|
|
|
+ spaceGatewayLambdaQueryWrapper.eq(BaseSpaceGateway::getSpaceId, diRequest.getSpaceId());
|
|
|
+ gatewayUuidList = baseSpaceGatewayService.list(spaceGatewayLambdaQueryWrapper).stream().map(BaseSpaceGateway::getGatewayUuid).collect(Collectors.toList());
|
|
|
+ }
|
|
|
+
|
|
|
if (diRequest.getDeviceStatus() != null) {
|
|
|
if (StringUtils.isNotBlank(diRequest.getDeviceId()) || StringUtils.isNotBlank(diRequest.getDeviceUuid()) || StringUtils.isNotBlank(diRequest.getDeviceName()) || diRequest.getProductId() != null || StringUtils.isNotBlank(diRequest.getProductCode()) || diRequest.getServiceStatus() != null || diRequest.getCategoryType() != null) {
|
|
|
LambdaQueryWrapper<DmpDeviceInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
|
@@ -657,6 +664,7 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
.like(StringUtils.isNotBlank(diRequest.getProductCode()), DmpDeviceInfo::getProductCode, diRequest.getProductCode())
|
|
|
.eq(diRequest.getServiceStatus() != null, DmpDeviceInfo::getServiceStatus, diRequest.getServiceStatus())
|
|
|
.eq(diRequest.getCategoryType() != null, DmpDeviceInfo::getCategoryType, diRequest.getCategoryType())
|
|
|
+ .in(CollectionUtils.isNotEmpty(gatewayUuidList), DmpDeviceInfo::getGatewayUuid, gatewayUuidList)
|
|
|
.eq(DmpDeviceInfo::getDeleteFlag, 0)
|
|
|
.eq(DmpDeviceInfo::getTenantId, SecurityUtils.getTenantId())
|
|
|
.orderByDesc(DmpDeviceInfo::getId);
|
|
|
@@ -768,6 +776,7 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
.like(StringUtils.isNotBlank(diRequest.getProductCode()), DmpDeviceInfo::getProductCode, diRequest.getProductCode())
|
|
|
.eq(diRequest.getServiceStatus() != null, DmpDeviceInfo::getServiceStatus, diRequest.getServiceStatus())
|
|
|
.eq(diRequest.getCategoryType() != null, DmpDeviceInfo::getCategoryType, diRequest.getCategoryType())
|
|
|
+ .in(CollectionUtils.isNotEmpty(gatewayUuidList), DmpDeviceInfo::getGatewayUuid, gatewayUuidList)
|
|
|
.eq(DmpDeviceInfo::getDeleteFlag, 0)
|
|
|
.eq(DmpDeviceInfo::getTenantId, SecurityUtils.getTenantId());
|
|
|
|
|
|
@@ -844,6 +853,13 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
tenantId = baseMapper.sysTenantId(domain);
|
|
|
}
|
|
|
|
|
|
+ List<String> gatewayUuidList = new ArrayList<>();
|
|
|
+ if (diRequest.getSpaceId() != null) {
|
|
|
+ LambdaQueryWrapper<BaseSpaceGateway> spaceGatewayLambdaQueryWrapper = Wrappers.lambdaQuery();
|
|
|
+ spaceGatewayLambdaQueryWrapper.eq(BaseSpaceGateway::getSpaceId, diRequest.getSpaceId());
|
|
|
+ gatewayUuidList = baseSpaceGatewayService.list(spaceGatewayLambdaQueryWrapper).stream().map(BaseSpaceGateway::getGatewayUuid).collect(Collectors.toList());
|
|
|
+ }
|
|
|
+
|
|
|
if (diRequest.getDeviceStatus() != null) {
|
|
|
if (StringUtils.isNotBlank(diRequest.getDeviceId()) || StringUtils.isNotBlank(diRequest.getDeviceName()) || diRequest.getProductId() != null || StringUtils.isNotBlank(diRequest.getProductCode()) || diRequest.getServiceStatus() != null || diRequest.getCategoryType() != null) {
|
|
|
LambdaQueryWrapper<DmpDeviceInfo> queryWrapper = Wrappers.lambdaQuery();
|
|
|
@@ -853,6 +869,7 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
.like(StringUtils.isNotBlank(diRequest.getProductCode()), DmpDeviceInfo::getProductCode, diRequest.getProductCode())
|
|
|
.eq(diRequest.getServiceStatus() != null, DmpDeviceInfo::getServiceStatus, diRequest.getServiceStatus())
|
|
|
.eq(diRequest.getCategoryType() != null, DmpDeviceInfo::getCategoryType, diRequest.getCategoryType())
|
|
|
+ .in(CollectionUtils.isNotEmpty(gatewayUuidList), DmpDeviceInfo::getGatewayUuid, gatewayUuidList)
|
|
|
.eq(DmpDeviceInfo::getDeleteFlag, 0)
|
|
|
.eq(DmpDeviceInfo::getTenantId, tenantId)
|
|
|
.orderByDesc(DmpDeviceInfo::getId);
|
|
|
@@ -963,6 +980,7 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
|
|
|
.like(StringUtils.isNotBlank(diRequest.getProductCode()), DmpDeviceInfo::getProductCode, diRequest.getProductCode())
|
|
|
.eq(diRequest.getServiceStatus() != null, DmpDeviceInfo::getServiceStatus, diRequest.getServiceStatus())
|
|
|
.eq(diRequest.getCategoryType() != null, DmpDeviceInfo::getCategoryType, diRequest.getCategoryType())
|
|
|
+ .in(CollectionUtils.isNotEmpty(gatewayUuidList), DmpDeviceInfo::getGatewayUuid, gatewayUuidList)
|
|
|
.eq(DmpDeviceInfo::getDeleteFlag, 0)
|
|
|
.eq(DmpDeviceInfo::getTenantId, tenantId)
|
|
|
.orderByDesc(DmpDeviceInfo::getId);
|