Removed device's methods for edge
This commit is contained in:
parent
525ae47347
commit
4b08103857
@ -701,8 +701,6 @@ public class DeviceController extends BaseController {
|
|||||||
@PathVariable(EDGE_ID) String strEdgeId,
|
@PathVariable(EDGE_ID) String strEdgeId,
|
||||||
@RequestParam int pageSize,
|
@RequestParam int pageSize,
|
||||||
@RequestParam int page,
|
@RequestParam int page,
|
||||||
@RequestParam(required = false) String type,
|
|
||||||
@RequestParam(required = false) String deviceProfileId,
|
|
||||||
@RequestParam(required = false) String textSearch,
|
@RequestParam(required = false) String textSearch,
|
||||||
@RequestParam(required = false) String sortProperty,
|
@RequestParam(required = false) String sortProperty,
|
||||||
@RequestParam(required = false) String sortOrder,
|
@RequestParam(required = false) String sortOrder,
|
||||||
@ -714,15 +712,7 @@ public class DeviceController extends BaseController {
|
|||||||
EdgeId edgeId = new EdgeId(toUUID(strEdgeId));
|
EdgeId edgeId = new EdgeId(toUUID(strEdgeId));
|
||||||
checkEdgeId(edgeId, Operation.READ);
|
checkEdgeId(edgeId, Operation.READ);
|
||||||
TimePageLink pageLink = createTimePageLink(pageSize, page, textSearch, sortProperty, sortOrder, startTime, endTime);
|
TimePageLink pageLink = createTimePageLink(pageSize, page, textSearch, sortProperty, sortOrder, startTime, endTime);
|
||||||
if (type != null && type.trim().length() > 0) {
|
return checkNotNull(deviceService.findDevicesByTenantIdAndEdgeId(tenantId, edgeId, pageLink));
|
||||||
return checkNotNull(deviceService.findDevicesByTenantIdAndEdgeIdAndType(tenantId, edgeId, type, pageLink));
|
|
||||||
}
|
|
||||||
else if (deviceProfileId != null && deviceProfileId.length() > 0) {
|
|
||||||
DeviceProfileId profileId = new DeviceProfileId(toUUID(deviceProfileId));
|
|
||||||
return checkNotNull(deviceService.findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(tenantId, edgeId, profileId, pageLink));
|
|
||||||
} else {
|
|
||||||
return checkNotNull(deviceService.findDevicesByTenantIdAndEdgeId(tenantId, edgeId, pageLink));
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
throw handleException(e);
|
throw handleException(e);
|
||||||
}
|
}
|
||||||
|
|||||||
@ -90,9 +90,4 @@ public interface DeviceService {
|
|||||||
Device unassignDeviceFromEdge(TenantId tenantId, DeviceId deviceId, EdgeId edgeId);
|
Device unassignDeviceFromEdge(TenantId tenantId, DeviceId deviceId, EdgeId edgeId);
|
||||||
|
|
||||||
PageData<Device> findDevicesByTenantIdAndEdgeId(TenantId tenantId, EdgeId edgeId, TimePageLink pageLink);
|
PageData<Device> findDevicesByTenantIdAndEdgeId(TenantId tenantId, EdgeId edgeId, TimePageLink pageLink);
|
||||||
|
|
||||||
PageData<Device> findDevicesByTenantIdAndEdgeIdAndType(TenantId tenantId, EdgeId edgeId, String type, TimePageLink pageLink);
|
|
||||||
|
|
||||||
PageData<Device> findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(TenantId tenantId, EdgeId edgeId, DeviceProfileId deviceProfileId, TimePageLink pageLink);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -226,27 +226,4 @@ public interface DeviceDao extends Dao<Device> {
|
|||||||
* @return the list of device objects
|
* @return the list of device objects
|
||||||
*/
|
*/
|
||||||
PageData<Device> findDevicesByTenantIdAndEdgeId(UUID tenantId, UUID edgeId, TimePageLink pageLink);
|
PageData<Device> findDevicesByTenantIdAndEdgeId(UUID tenantId, UUID edgeId, TimePageLink pageLink);
|
||||||
|
|
||||||
/**
|
|
||||||
* Find devices by tenantId, edgeId, type and page link.
|
|
||||||
*
|
|
||||||
* @param tenantId the tenantId
|
|
||||||
* @param edgeId the edgeId
|
|
||||||
* @param type the type
|
|
||||||
* @param pageLink the page link
|
|
||||||
* @return the list of device objects
|
|
||||||
*/
|
|
||||||
PageData<Device> findDevicesByTenantIdAndEdgeIdAndType(UUID tenantId, UUID edgeId, String type, TimePageLink pageLink);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Find devices by tenantId, edgeId, type, deviceProfileId and page link.
|
|
||||||
*
|
|
||||||
* @param tenantId the tenantId
|
|
||||||
* @param edgeId the edgeId
|
|
||||||
* @param deviceProfileId the deviceProfileId
|
|
||||||
* @param pageLink the page link
|
|
||||||
* @return the list of device objects
|
|
||||||
*/
|
|
||||||
PageData<Device> findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(UUID tenantId, UUID edgeId, UUID deviceProfileId, TimePageLink pageLink);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -515,26 +515,6 @@ public class DeviceServiceImpl extends AbstractEntityService implements DeviceSe
|
|||||||
return deviceDao.findDevicesByTenantIdAndEdgeId(tenantId.getId(), edgeId.getId(), pageLink);
|
return deviceDao.findDevicesByTenantIdAndEdgeId(tenantId.getId(), edgeId.getId(), pageLink);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageData<Device> findDevicesByTenantIdAndEdgeIdAndType(TenantId tenantId, EdgeId edgeId, String type, TimePageLink pageLink) {
|
|
||||||
log.trace("Executing findDevicesByTenantIdAndEdgeIdAndType, tenantId [{}], edgeId [{}], type [{}], pageLink [{}]", tenantId, edgeId, type, pageLink);
|
|
||||||
validateId(tenantId, INCORRECT_TENANT_ID + tenantId);
|
|
||||||
validateId(edgeId, INCORRECT_EDGE_ID + edgeId);
|
|
||||||
validateString(type, "Incorrect type " + type);
|
|
||||||
validatePageLink(pageLink);
|
|
||||||
return deviceDao.findDevicesByTenantIdAndEdgeIdAndType(tenantId.getId(), edgeId.getId(), type, pageLink);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageData<Device> findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(TenantId tenantId, EdgeId edgeId, DeviceProfileId deviceProfileId, TimePageLink pageLink) {
|
|
||||||
log.trace("Executing findDevicesByTenantIdAndEdgeIdAndDeviceProfileId, tenantId [{}], edgeId [{}], deviceProfileId [{}], pageLink [{}]", tenantId, edgeId, deviceProfileId, pageLink);
|
|
||||||
validateId(tenantId, INCORRECT_TENANT_ID + tenantId);
|
|
||||||
validateId(edgeId, INCORRECT_EDGE_ID + edgeId);
|
|
||||||
validateId(deviceProfileId, INCORRECT_DEVICE_PROFILE_ID + deviceProfileId);
|
|
||||||
validatePageLink(pageLink);
|
|
||||||
return deviceDao.findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(tenantId.getId(), edgeId.getId(), deviceProfileId.getId(), pageLink);
|
|
||||||
}
|
|
||||||
|
|
||||||
private DataValidator<Device> deviceValidator =
|
private DataValidator<Device> deviceValidator =
|
||||||
new DataValidator<Device>() {
|
new DataValidator<Device>() {
|
||||||
|
|
||||||
|
|||||||
@ -177,43 +177,4 @@ public interface DeviceRepository extends PagingAndSortingRepository<DeviceEntit
|
|||||||
@Param("edgeId") UUID edgeId,
|
@Param("edgeId") UUID edgeId,
|
||||||
@Param("searchText") String searchText,
|
@Param("searchText") String searchText,
|
||||||
Pageable pageable);
|
Pageable pageable);
|
||||||
|
|
||||||
@Query("SELECT d FROM DeviceEntity d, RelationEntity re WHERE d.tenantId = :tenantId " +
|
|
||||||
"AND d.id = re.toId AND re.toType = 'DEVICE' AND re.relationTypeGroup = 'EDGE' " +
|
|
||||||
"AND re.relationType = 'Contains' AND re.fromId = :edgeId AND re.fromType = 'EDGE' " +
|
|
||||||
"AND d.type = :type " +
|
|
||||||
"AND LOWER(d.searchText) LIKE LOWER(CONCAT(:searchText, '%'))")
|
|
||||||
Page<DeviceEntity> findByTenantIdAndEdgeIdAndType(@Param("tenantId") UUID tenantId,
|
|
||||||
@Param("edgeId") UUID edgeId,
|
|
||||||
@Param("type") String type,
|
|
||||||
@Param("searchText") String searchText,
|
|
||||||
Pageable pageable);
|
|
||||||
|
|
||||||
@Query("SELECT d FROM DeviceEntity d, RelationEntity re " +
|
|
||||||
"LEFT JOIN DeviceProfileEntity p on p.id = d.deviceProfileId " +
|
|
||||||
"WHERE d.tenantId = :tenantId " +
|
|
||||||
"AND d.id = re.toId AND re.toType = 'DEVICE' AND re.relationTypeGroup = 'EDGE' " +
|
|
||||||
"AND re.relationType = 'Contains' AND re.fromId = :edgeId AND re.fromType = 'EDGE' " +
|
|
||||||
"AND d.deviceProfileId = :deviceProfileId " +
|
|
||||||
"AND LOWER(d.searchText) LIKE LOWER(CONCAT(:searchText, '%'))")
|
|
||||||
Page<DeviceEntity> findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(@Param("tenantId") UUID tenantId,
|
|
||||||
@Param("edgeId") UUID edgeId,
|
|
||||||
@Param("deviceProfileId") UUID deviceProfileId,
|
|
||||||
@Param("searchText") String searchText,
|
|
||||||
Pageable pageable);
|
|
||||||
|
|
||||||
// @Query("SELECT new org.thingsboard.server.dao.model.sql.DeviceInfoEntity(d, c.title, c.additionalInfo, p.name) " +
|
|
||||||
// "FROM DeviceEntity d " +
|
|
||||||
// "LEFT JOIN CustomerEntity c on c.id = d.customerId " +
|
|
||||||
// "LEFT JOIN DeviceProfileEntity p on p.id = d.deviceProfileId " +
|
|
||||||
// "WHERE d.tenantId = :tenantId " +
|
|
||||||
// "AND d.customerId = :customerId " +
|
|
||||||
// "AND d.deviceProfileId = :deviceProfileId " +
|
|
||||||
// "AND LOWER(d.searchText) LIKE LOWER(CONCAT(:textSearch, '%'))")
|
|
||||||
// Page<DeviceInfoEntity> findDeviceInfosByTenantIdAndCustomerIdAndDeviceProfileId2(@Param("tenantId") UUID tenantId,
|
|
||||||
// @Param("customerId") UUID customerId,
|
|
||||||
// @Param("deviceProfileId") UUID deviceProfileId,
|
|
||||||
// @Param("textSearch") String textSearch,
|
|
||||||
// Pageable pageable);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -243,28 +243,4 @@ public class JpaDeviceDao extends JpaAbstractSearchTextDao<DeviceEntity, Device>
|
|||||||
Objects.toString(pageLink.getTextSearch(), ""),
|
Objects.toString(pageLink.getTextSearch(), ""),
|
||||||
DaoUtil.toPageable(pageLink)));
|
DaoUtil.toPageable(pageLink)));
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageData<Device> findDevicesByTenantIdAndEdgeIdAndType(UUID tenantId, UUID edgeId, String type, TimePageLink pageLink) {
|
|
||||||
log.debug("Try to find devices by tenantId [{}], edgeId [{}], type [{}] and pageLink [{}]", tenantId, edgeId, type, pageLink);
|
|
||||||
return DaoUtil.toPageData(deviceRepository
|
|
||||||
.findByTenantIdAndEdgeIdAndType(
|
|
||||||
tenantId,
|
|
||||||
edgeId,
|
|
||||||
type,
|
|
||||||
Objects.toString(pageLink.getTextSearch(), ""),
|
|
||||||
DaoUtil.toPageable(pageLink)));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public PageData<Device> findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(UUID tenantId, UUID edgeId, UUID deviceProfileId, TimePageLink pageLink) {
|
|
||||||
log.debug("Try to find devices by tenantId [{}], edgeId [{}], deviceProfileId [{}] and pageLink [{}]", tenantId, edgeId, deviceProfileId, pageLink);
|
|
||||||
return DaoUtil.toPageData(deviceRepository
|
|
||||||
.findDevicesByTenantIdAndEdgeIdAndDeviceProfileId(
|
|
||||||
tenantId,
|
|
||||||
edgeId,
|
|
||||||
deviceProfileId,
|
|
||||||
Objects.toString(pageLink.getTextSearch(), ""),
|
|
||||||
DaoUtil.toPageable(pageLink)));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user