@ -102,28 +102,28 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public AssetInfo findAssetInfoById ( TenantId tenantId , AssetId assetId ) {
log . trace ( "Executing findAssetInfoById [{}]" , assetId ) ;
validateId ( assetId , INCORRECT_ASSET_ID + assetI d) ;
validateId ( assetId , id - > INCORRECT_ASSET_ID + i d) ;
return assetDao . findAssetInfoById ( tenantId , assetId . getId ( ) ) ;
}
@Override
public Asset findAssetById ( TenantId tenantId , AssetId assetId ) {
log . trace ( "Executing findAssetById [{}]" , assetId ) ;
validateId ( assetId , INCORRECT_ASSET_ID + assetI d) ;
validateId ( assetId , id - > INCORRECT_ASSET_ID + i d) ;
return assetDao . findById ( tenantId , assetId . getId ( ) ) ;
}
@Override
public ListenableFuture < Asset > findAssetByIdAsync ( TenantId tenantId , AssetId assetId ) {
log . trace ( "Executing findAssetById [{}]" , assetId ) ;
validateId ( assetId , INCORRECT_ASSET_ID + assetI d) ;
validateId ( assetId , id - > INCORRECT_ASSET_ID + i d) ;
return assetDao . findByIdAsync ( tenantId , assetId . getId ( ) ) ;
}
@Override
public Asset findAssetByTenantIdAndName ( TenantId tenantId , String name ) {
log . trace ( "Executing findAssetByTenantIdAndName [{}][{}]" , tenantId , name ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
return cache . getAndPutInTransaction ( new AssetCacheKey ( tenantId , name ) ,
( ) - > assetDao . findAssetsByTenantIdAndName ( tenantId . getId ( ) , name )
. orElse ( null ) , true ) ;
@ -198,7 +198,7 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
@Transactional
public void deleteAsset ( TenantId tenantId , AssetId assetId ) {
validateId ( assetId , INCORRECT_ASSET_ID + assetI d) ;
validateId ( assetId , id - > INCORRECT_ASSET_ID + i d) ;
if ( entityViewService . existsByTenantIdAndEntityId ( tenantId , assetId ) ) {
throw new DataValidationException ( "Can't delete asset that has entity views!" ) ;
}
@ -222,7 +222,7 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < Asset > findAssetsByTenantId ( TenantId tenantId , PageLink pageLink ) {
log . trace ( "Executing findAssetsByTenantId, tenantId [{}], pageLink [{}]" , tenantId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetsByTenantId ( tenantId . getId ( ) , pageLink ) ;
}
@ -230,7 +230,7 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < AssetInfo > findAssetInfosByTenantId ( TenantId tenantId , PageLink pageLink ) {
log . trace ( "Executing findAssetInfosByTenantId, tenantId [{}], pageLink [{}]" , tenantId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetInfosByTenantId ( tenantId . getId ( ) , pageLink ) ;
}
@ -238,8 +238,8 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < Asset > findAssetsByTenantIdAndType ( TenantId tenantId , String type , PageLink pageLink ) {
log . trace ( "Executing findAssetsByTenantIdAndType, tenantId [{}], type [{}], pageLink [{}]" , tenantId , type , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateString ( type , "Incorrect type " + type ) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateString ( type , t - > "Incorrect type " + t ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetsByTenantIdAndType ( tenantId . getId ( ) , type , pageLink ) ;
}
@ -247,8 +247,8 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < AssetInfo > findAssetInfosByTenantIdAndType ( TenantId tenantId , String type , PageLink pageLink ) {
log . trace ( "Executing findAssetInfosByTenantIdAndType, tenantId [{}], type [{}], pageLink [{}]" , tenantId , type , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateString ( type , "Incorrect type " + type ) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateString ( type , t - > "Incorrect type " + t ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetInfosByTenantIdAndType ( tenantId . getId ( ) , type , pageLink ) ;
}
@ -256,8 +256,8 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < AssetInfo > findAssetInfosByTenantIdAndAssetProfileId ( TenantId tenantId , AssetProfileId assetProfileId , PageLink pageLink ) {
log . trace ( "Executing findAssetInfosByTenantIdAndAssetProfileId, tenantId [{}], assetProfileId [{}], pageLink [{}]" , tenantId , assetProfileId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( assetProfileId , INCORRECT_ASSET_PROFILE_ID + assetProf ileI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( assetProfileId , id - > INCORRECT_ASSET_PROFILE_ID + id ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetInfosByTenantIdAndAssetProfileId ( tenantId . getId ( ) , assetProfileId . getId ( ) , pageLink ) ;
}
@ -265,23 +265,23 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public ListenableFuture < List < Asset > > findAssetsByTenantIdAndIdsAsync ( TenantId tenantId , List < AssetId > assetIds ) {
log . trace ( "Executing findAssetsByTenantIdAndIdsAsync, tenantId [{}], assetIds [{}]" , tenantId , assetIds ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateIds ( assetIds , "Incorrect assetIds " + assetI ds) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateIds ( assetIds , ids - > "Incorrect assetIds " + i ds) ;
return assetDao . findAssetsByTenantIdAndIdsAsync ( tenantId . getId ( ) , toUUIDs ( assetIds ) ) ;
}
@Override
public void deleteAssetsByTenantId ( TenantId tenantId ) {
log . trace ( "Executing deleteAssetsByTenantId, tenantId [{}]" , tenantId ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
tenantAssetsRemover . removeEntities ( tenantId , tenantId ) ;
}
@Override
public PageData < Asset > findAssetsByTenantIdAndCustomerId ( TenantId tenantId , CustomerId customerId , PageLink pageLink ) {
log . trace ( "Executing findAssetsByTenantIdAndCustomerId, tenantId [{}], customerId [{}], pageLink [{}]" , tenantId , customerId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetsByTenantIdAndCustomerId ( tenantId . getId ( ) , customerId . getId ( ) , pageLink ) ;
}
@ -289,8 +289,8 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < AssetInfo > findAssetInfosByTenantIdAndCustomerId ( TenantId tenantId , CustomerId customerId , PageLink pageLink ) {
log . trace ( "Executing findAssetInfosByTenantIdAndCustomerId, tenantId [{}], customerId [{}], pageLink [{}]" , tenantId , customerId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetInfosByTenantIdAndCustomerId ( tenantId . getId ( ) , customerId . getId ( ) , pageLink ) ;
}
@ -298,9 +298,9 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < Asset > findAssetsByTenantIdAndCustomerIdAndType ( TenantId tenantId , CustomerId customerId , String type , PageLink pageLink ) {
log . trace ( "Executing findAssetsByTenantIdAndCustomerIdAndType, tenantId [{}], customerId [{}], type [{}], pageLink [{}]" , tenantId , customerId , type , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateString ( type , "Incorrect type " + type ) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
validateString ( type , t - > "Incorrect type " + t ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetsByTenantIdAndCustomerIdAndType ( tenantId . getId ( ) , customerId . getId ( ) , type , pageLink ) ;
}
@ -308,9 +308,9 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < AssetInfo > findAssetInfosByTenantIdAndCustomerIdAndType ( TenantId tenantId , CustomerId customerId , String type , PageLink pageLink ) {
log . trace ( "Executing findAssetInfosByTenantIdAndCustomerIdAndType, tenantId [{}], customerId [{}], type [{}], pageLink [{}]" , tenantId , customerId , type , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateString ( type , "Incorrect type " + type ) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
validateString ( type , t - > "Incorrect type " + t ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetInfosByTenantIdAndCustomerIdAndType ( tenantId . getId ( ) , customerId . getId ( ) , type , pageLink ) ;
}
@ -318,9 +318,9 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < AssetInfo > findAssetInfosByTenantIdAndCustomerIdAndAssetProfileId ( TenantId tenantId , CustomerId customerId , AssetProfileId assetProfileId , PageLink pageLink ) {
log . trace ( "Executing findAssetInfosByTenantIdAndCustomerIdAndAssetProfileId, tenantId [{}], customerId [{}], assetProfileId [{}], pageLink [{}]" , tenantId , customerId , assetProfileId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateId ( assetProfileId , INCORRECT_ASSET_PROFILE_ID + assetProf ileI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
validateId ( assetProfileId , id - > INCORRECT_ASSET_PROFILE_ID + id ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetInfosByTenantIdAndCustomerIdAndAssetProfileId ( tenantId . getId ( ) , customerId . getId ( ) , assetProfileId . getId ( ) , pageLink ) ;
}
@ -328,17 +328,17 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public ListenableFuture < List < Asset > > findAssetsByTenantIdCustomerIdAndIdsAsync ( TenantId tenantId , CustomerId customerId , List < AssetId > assetIds ) {
log . trace ( "Executing findAssetsByTenantIdAndCustomerIdAndIdsAsync, tenantId [{}], customerId [{}], assetIds [{}]" , tenantId , customerId , assetIds ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateIds ( assetIds , "Incorrect assetIds " + assetI ds) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
validateIds ( assetIds , ids - > "Incorrect assetIds " + i ds) ;
return assetDao . findAssetsByTenantIdAndCustomerIdAndIdsAsync ( tenantId . getId ( ) , customerId . getId ( ) , toUUIDs ( assetIds ) ) ;
}
@Override
public void unassignCustomerAssets ( TenantId tenantId , CustomerId customerId ) {
log . trace ( "Executing unassignCustomerAssets, tenantId [{}], customerId [{}]" , tenantId , customerId ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( customerId , INCORRECT_CUSTOMER_ID + customerI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( customerId , id - > INCORRECT_CUSTOMER_ID + i d) ;
customerAssetsUnasigner . removeEntities ( tenantId , customerId ) ;
}
@ -370,7 +370,7 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public ListenableFuture < List < EntitySubtype > > findAssetTypesByTenantId ( TenantId tenantId ) {
log . trace ( "Executing findAssetTypesByTenantId, tenantId [{}]" , tenantId ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
return assetDao . findTenantAssetTypesAsync ( tenantId . getId ( ) ) ;
}
@ -419,8 +419,8 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < Asset > findAssetsByTenantIdAndEdgeId ( TenantId tenantId , EdgeId edgeId , PageLink pageLink ) {
log . trace ( "Executing findAssetsByTenantIdAndEdgeId, tenantId [{}], edgeId [{}], pageLink [{}]" , tenantId , edgeId , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( edgeId , INCORRECT_EDGE_ID + edgeI d) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( edgeId , id - > INCORRECT_EDGE_ID + i d) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetsByTenantIdAndEdgeId ( tenantId . getId ( ) , edgeId . getId ( ) , pageLink ) ;
}
@ -428,9 +428,9 @@ public class BaseAssetService extends AbstractCachedEntityService<AssetCacheKey,
@Override
public PageData < Asset > findAssetsByTenantIdAndEdgeIdAndType ( TenantId tenantId , EdgeId edgeId , String type , PageLink pageLink ) {
log . trace ( "Executing findAssetsByTenantIdAndEdgeIdAndType, tenantId [{}], edgeId [{}], type [{}] pageLink [{}]" , tenantId , edgeId , type , pageLink ) ;
validateId ( tenantId , INCORRECT_TENANT_ID + tenantI d) ;
validateId ( edgeId , INCORRECT_EDGE_ID + edgeI d) ;
validateString ( type , "Incorrect type " + type ) ;
validateId ( tenantId , id - > INCORRECT_TENANT_ID + i d) ;
validateId ( edgeId , id - > INCORRECT_EDGE_ID + i d) ;
validateString ( type , t - > "Incorrect type " + t ) ;
validatePageLink ( pageLink ) ;
return assetDao . findAssetsByTenantIdAndEdgeIdAndType ( tenantId . getId ( ) , edgeId . getId ( ) , type , pageLink ) ;
}