|
|
@ -56,22 +56,22 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
promise = assetService.getAsset(entityId, true, config); |
|
|
promise = assetService.getAsset(entityId, true, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.tenant: |
|
|
case types.entityType.tenant: |
|
|
promise = tenantService.getTenant(entityId); |
|
|
promise = tenantService.getTenant(entityId, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.customer: |
|
|
case types.entityType.customer: |
|
|
promise = customerService.getCustomer(entityId); |
|
|
promise = customerService.getCustomer(entityId, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.rule: |
|
|
case types.entityType.rule: |
|
|
promise = ruleService.getRule(entityId); |
|
|
promise = ruleService.getRule(entityId, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.plugin: |
|
|
case types.entityType.plugin: |
|
|
promise = pluginService.getPlugin(entityId); |
|
|
promise = pluginService.getPlugin(entityId, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.dashboard: |
|
|
case types.entityType.dashboard: |
|
|
promise = dashboardService.getDashboardInfo(entityId); |
|
|
promise = dashboardService.getDashboardInfo(entityId, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.user: |
|
|
case types.entityType.user: |
|
|
promise = userService.getUser(entityId); |
|
|
promise = userService.getUser(entityId, true, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.alarm: |
|
|
case types.entityType.alarm: |
|
|
$log.error('Get Alarm Entity is not implemented!'); |
|
|
$log.error('Get Alarm Entity is not implemented!'); |
|
|
@ -136,22 +136,28 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
promise = assetService.getAssets(entityIds, config); |
|
|
promise = assetService.getAssets(entityIds, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.tenant: |
|
|
case types.entityType.tenant: |
|
|
promise = getEntitiesByIdsPromise(tenantService.getTenant, entityIds); |
|
|
promise = getEntitiesByIdsPromise( |
|
|
|
|
|
(id) => tenantService.getTenant(id, config), entityIds); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.customer: |
|
|
case types.entityType.customer: |
|
|
promise = getEntitiesByIdsPromise(customerService.getCustomer, entityIds); |
|
|
promise = getEntitiesByIdsPromise( |
|
|
|
|
|
(id) => customerService.getCustomer(id, config), entityIds); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.rule: |
|
|
case types.entityType.rule: |
|
|
promise = getEntitiesByIdsPromise(ruleService.getRule, entityIds); |
|
|
promise = getEntitiesByIdsPromise( |
|
|
|
|
|
(id) => ruleService.getRule(id, config), entityIds); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.plugin: |
|
|
case types.entityType.plugin: |
|
|
promise = getEntitiesByIdsPromise(pluginService.getPlugin, entityIds); |
|
|
promise = getEntitiesByIdsPromise( |
|
|
|
|
|
(id) => pluginService.getPlugin(id, config), entityIds); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.dashboard: |
|
|
case types.entityType.dashboard: |
|
|
promise = getEntitiesByIdsPromise(dashboardService.getDashboardInfo, entityIds); |
|
|
promise = getEntitiesByIdsPromise( |
|
|
|
|
|
(id) => dashboardService.getDashboardInfo(id, config), entityIds); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.user: |
|
|
case types.entityType.user: |
|
|
promise = getEntitiesByIdsPromise(userService.getUser, entityIds); |
|
|
promise = getEntitiesByIdsPromise( |
|
|
|
|
|
(id) => userService.getUser(id, true, config), entityIds); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.alarm: |
|
|
case types.entityType.alarm: |
|
|
$log.error('Get Alarm Entity is not implemented!'); |
|
|
$log.error('Get Alarm Entity is not implemented!'); |
|
|
@ -178,11 +184,11 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
return deferred.promise; |
|
|
return deferred.promise; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
function getSingleTenantByPageLinkPromise(pageLink) { |
|
|
function getSingleTenantByPageLinkPromise(pageLink, config) { |
|
|
var user = userService.getCurrentUser(); |
|
|
var user = userService.getCurrentUser(); |
|
|
var tenantId = user.tenantId; |
|
|
var tenantId = user.tenantId; |
|
|
var deferred = $q.defer(); |
|
|
var deferred = $q.defer(); |
|
|
tenantService.getTenant(tenantId).then( |
|
|
tenantService.getTenant(tenantId, config).then( |
|
|
function success(tenant) { |
|
|
function success(tenant) { |
|
|
var tenantName = tenant.name; |
|
|
var tenantName = tenant.name; |
|
|
var result = { |
|
|
var result = { |
|
|
@ -202,11 +208,11 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
return deferred.promise; |
|
|
return deferred.promise; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
function getSingleCustomerByPageLinkPromise(pageLink) { |
|
|
function getSingleCustomerByPageLinkPromise(pageLink, config) { |
|
|
var user = userService.getCurrentUser(); |
|
|
var user = userService.getCurrentUser(); |
|
|
var customerId = user.customerId; |
|
|
var customerId = user.customerId; |
|
|
var deferred = $q.defer(); |
|
|
var deferred = $q.defer(); |
|
|
customerService.getCustomer(customerId).then( |
|
|
customerService.getCustomer(customerId, config).then( |
|
|
function success(customer) { |
|
|
function success(customer) { |
|
|
var customerName = customer.name; |
|
|
var customerName = customer.name; |
|
|
var result = { |
|
|
var result = { |
|
|
@ -247,29 +253,29 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
break; |
|
|
break; |
|
|
case types.entityType.tenant: |
|
|
case types.entityType.tenant: |
|
|
if (user.authority === 'TENANT_ADMIN') { |
|
|
if (user.authority === 'TENANT_ADMIN') { |
|
|
promise = getSingleTenantByPageLinkPromise(pageLink); |
|
|
promise = getSingleTenantByPageLinkPromise(pageLink, config); |
|
|
} else { |
|
|
} else { |
|
|
promise = tenantService.getTenants(pageLink); |
|
|
promise = tenantService.getTenants(pageLink, config); |
|
|
} |
|
|
} |
|
|
break; |
|
|
break; |
|
|
case types.entityType.customer: |
|
|
case types.entityType.customer: |
|
|
if (user.authority === 'CUSTOMER_USER') { |
|
|
if (user.authority === 'CUSTOMER_USER') { |
|
|
promise = getSingleCustomerByPageLinkPromise(pageLink); |
|
|
promise = getSingleCustomerByPageLinkPromise(pageLink, config); |
|
|
} else { |
|
|
} else { |
|
|
promise = customerService.getCustomers(pageLink); |
|
|
promise = customerService.getCustomers(pageLink, config); |
|
|
} |
|
|
} |
|
|
break; |
|
|
break; |
|
|
case types.entityType.rule: |
|
|
case types.entityType.rule: |
|
|
promise = ruleService.getAllRules(pageLink); |
|
|
promise = ruleService.getAllRules(pageLink, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.plugin: |
|
|
case types.entityType.plugin: |
|
|
promise = pluginService.getAllPlugins(pageLink); |
|
|
promise = pluginService.getAllPlugins(pageLink, config); |
|
|
break; |
|
|
break; |
|
|
case types.entityType.dashboard: |
|
|
case types.entityType.dashboard: |
|
|
if (user.authority === 'CUSTOMER_USER') { |
|
|
if (user.authority === 'CUSTOMER_USER') { |
|
|
promise = dashboardService.getCustomerDashboards(customerId, pageLink, false); |
|
|
promise = dashboardService.getCustomerDashboards(customerId, pageLink, false, config); |
|
|
} else { |
|
|
} else { |
|
|
promise = dashboardService.getTenantDashboards(pageLink, false); |
|
|
promise = dashboardService.getTenantDashboards(pageLink, false, config); |
|
|
} |
|
|
} |
|
|
break; |
|
|
break; |
|
|
case types.entityType.user: |
|
|
case types.entityType.user: |
|
|
@ -426,7 +432,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
var stateEntityId = getStateEntityId(filter, stateParams); |
|
|
var stateEntityId = getStateEntityId(filter, stateParams); |
|
|
switch (filter.type) { |
|
|
switch (filter.type) { |
|
|
case types.aliasFilterType.singleEntity.value: |
|
|
case types.aliasFilterType.singleEntity.value: |
|
|
getEntity(filter.singleEntity.entityType, filter.singleEntity.id).then( |
|
|
getEntity(filter.singleEntity.entityType, filter.singleEntity.id, {ignoreLoading: true}).then( |
|
|
function success(entity) { |
|
|
function success(entity) { |
|
|
result.entities = entitiesToEntitiesInfo([entity]); |
|
|
result.entities = entitiesToEntitiesInfo([entity]); |
|
|
deferred.resolve(result); |
|
|
deferred.resolve(result); |
|
|
@ -437,7 +443,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
); |
|
|
); |
|
|
break; |
|
|
break; |
|
|
case types.aliasFilterType.entityList.value: |
|
|
case types.aliasFilterType.entityList.value: |
|
|
getEntities(filter.entityType, filter.entityList).then( |
|
|
getEntities(filter.entityType, filter.entityList, {ignoreLoading: true}).then( |
|
|
function success(entities) { |
|
|
function success(entities) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
@ -452,7 +458,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
); |
|
|
); |
|
|
break; |
|
|
break; |
|
|
case types.aliasFilterType.entityName.value: |
|
|
case types.aliasFilterType.entityName.value: |
|
|
getEntitiesByNameFilter(filter.entityType, filter.entityNameFilter, maxItems).then( |
|
|
getEntitiesByNameFilter(filter.entityType, filter.entityNameFilter, maxItems, {ignoreLoading: true}).then( |
|
|
function success(entities) { |
|
|
function success(entities) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
@ -469,7 +475,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
case types.aliasFilterType.stateEntity.value: |
|
|
case types.aliasFilterType.stateEntity.value: |
|
|
result.stateEntity = true; |
|
|
result.stateEntity = true; |
|
|
if (stateEntityId) { |
|
|
if (stateEntityId) { |
|
|
getEntity(stateEntityId.entityType, stateEntityId.id).then( |
|
|
getEntity(stateEntityId.entityType, stateEntityId.id, {ignoreLoading: true}).then( |
|
|
function success(entity) { |
|
|
function success(entity) { |
|
|
result.entities = entitiesToEntitiesInfo([entity]); |
|
|
result.entities = entitiesToEntitiesInfo([entity]); |
|
|
deferred.resolve(result); |
|
|
deferred.resolve(result); |
|
|
@ -483,7 +489,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
} |
|
|
} |
|
|
break; |
|
|
break; |
|
|
case types.aliasFilterType.assetType.value: |
|
|
case types.aliasFilterType.assetType.value: |
|
|
getEntitiesByNameFilter(types.entityType.asset, filter.assetNameFilter, maxItems, null, filter.assetType).then( |
|
|
getEntitiesByNameFilter(types.entityType.asset, filter.assetNameFilter, maxItems, {ignoreLoading: true}, filter.assetType).then( |
|
|
function success(entities) { |
|
|
function success(entities) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
@ -498,7 +504,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
); |
|
|
); |
|
|
break; |
|
|
break; |
|
|
case types.aliasFilterType.deviceType.value: |
|
|
case types.aliasFilterType.deviceType.value: |
|
|
getEntitiesByNameFilter(types.entityType.device, filter.deviceNameFilter, maxItems, null, filter.deviceType).then( |
|
|
getEntitiesByNameFilter(types.entityType.device, filter.deviceNameFilter, maxItems, {ignoreLoading: true}, filter.deviceType).then( |
|
|
function success(entities) { |
|
|
function success(entities) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
if (entities && entities.length || !failOnEmpty) { |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
result.entities = entitiesToEntitiesInfo(entities); |
|
|
@ -533,7 +539,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
filters: filter.filters |
|
|
filters: filter.filters |
|
|
}; |
|
|
}; |
|
|
searchQuery.parameters.maxLevel = filter.maxLevel && filter.maxLevel > 0 ? filter.maxLevel : -1; |
|
|
searchQuery.parameters.maxLevel = filter.maxLevel && filter.maxLevel > 0 ? filter.maxLevel : -1; |
|
|
entityRelationService.findInfoByQuery(searchQuery).then( |
|
|
entityRelationService.findInfoByQuery(searchQuery, {ignoreLoading: true}).then( |
|
|
function success(allRelations) { |
|
|
function success(allRelations) { |
|
|
if (allRelations && allRelations.length || !failOnEmpty) { |
|
|
if (allRelations && allRelations.length || !failOnEmpty) { |
|
|
if (angular.isDefined(maxItems) && maxItems > 0 && allRelations) { |
|
|
if (angular.isDefined(maxItems) && maxItems > 0 && allRelations) { |
|
|
@ -577,10 +583,10 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
var findByQueryPromise; |
|
|
var findByQueryPromise; |
|
|
if (filter.type == types.aliasFilterType.assetSearchQuery.value) { |
|
|
if (filter.type == types.aliasFilterType.assetSearchQuery.value) { |
|
|
searchQuery.assetTypes = filter.assetTypes; |
|
|
searchQuery.assetTypes = filter.assetTypes; |
|
|
findByQueryPromise = assetService.findByQuery(searchQuery, false); |
|
|
findByQueryPromise = assetService.findByQuery(searchQuery, false, {ignoreLoading: true}); |
|
|
} else if (filter.type == types.aliasFilterType.deviceSearchQuery.value) { |
|
|
} else if (filter.type == types.aliasFilterType.deviceSearchQuery.value) { |
|
|
searchQuery.deviceTypes = filter.deviceTypes; |
|
|
searchQuery.deviceTypes = filter.deviceTypes; |
|
|
findByQueryPromise = deviceService.findByQuery(searchQuery, false); |
|
|
findByQueryPromise = deviceService.findByQuery(searchQuery, false, {ignoreLoading: true}); |
|
|
} |
|
|
} |
|
|
findByQueryPromise.then( |
|
|
findByQueryPromise.then( |
|
|
function success(entities) { |
|
|
function success(entities) { |
|
|
@ -762,7 +768,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
return deferred.promise; |
|
|
return deferred.promise; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
function getEntityKeys(entityType, entityId, query, type) { |
|
|
function getEntityKeys(entityType, entityId, query, type, config) { |
|
|
var deferred = $q.defer(); |
|
|
var deferred = $q.defer(); |
|
|
var url = '/api/plugins/telemetry/' + entityType + '/' + entityId + '/keys/'; |
|
|
var url = '/api/plugins/telemetry/' + entityType + '/' + entityId + '/keys/'; |
|
|
if (type === types.dataKeyType.timeseries) { |
|
|
if (type === types.dataKeyType.timeseries) { |
|
|
@ -770,7 +776,7 @@ function EntityService($http, $q, $filter, $translate, $log, userService, device |
|
|
} else if (type === types.dataKeyType.attribute) { |
|
|
} else if (type === types.dataKeyType.attribute) { |
|
|
url += 'attributes'; |
|
|
url += 'attributes'; |
|
|
} |
|
|
} |
|
|
$http.get(url, null).then(function success(response) { |
|
|
$http.get(url, config).then(function success(response) { |
|
|
var result = []; |
|
|
var result = []; |
|
|
if (response.data) { |
|
|
if (response.data) { |
|
|
if (query) { |
|
|
if (query) { |
|
|
|
volodymyr-babak
9 years ago