Set external ids instead of internal on export
This commit is contained in:
parent
e3ec5db618
commit
5df2ca5372
@ -1,3 +1,18 @@
|
|||||||
|
/**
|
||||||
|
* Copyright © 2016-2022 The Thingsboard Authors
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
package org.thingsboard.server.service.sync.ie.exporting.impl;
|
package org.thingsboard.server.service.sync.ie.exporting.impl;
|
||||||
|
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
@ -14,7 +29,6 @@ import java.util.Set;
|
|||||||
|
|
||||||
@Service
|
@Service
|
||||||
@TbCoreComponent
|
@TbCoreComponent
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class AssetExportService extends BaseEntityExportService<AssetId, Asset, EntityExportData<Asset>> {
|
public class AssetExportService extends BaseEntityExportService<AssetId, Asset, EntityExportData<Asset>> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@ -37,12 +37,6 @@ public abstract class BaseEntityExportService<I extends EntityId, E extends Expo
|
|||||||
|
|
||||||
protected void setRelatedEntities(TenantId tenantId, E mainEntity, D exportData, EntityExportSettings settings) {}
|
protected void setRelatedEntities(TenantId tenantId, E mainEntity, D exportData, EntityExportSettings settings) {}
|
||||||
|
|
||||||
protected <ID extends EntityId> ID getExternalIdOrElseInternal(ID internalId) {
|
|
||||||
if (internalId == null || internalId.isNullUid()) return internalId;
|
|
||||||
return Optional.ofNullable(exportableEntitiesService.getExternalIdByInternal(internalId))
|
|
||||||
.orElse(internalId);
|
|
||||||
}
|
|
||||||
|
|
||||||
protected D newExportData() {
|
protected D newExportData() {
|
||||||
return (D) new EntityExportData<E>();
|
return (D) new EntityExportData<E>();
|
||||||
};
|
};
|
||||||
|
|||||||
@ -0,0 +1,48 @@
|
|||||||
|
/**
|
||||||
|
* Copyright © 2016-2022 The Thingsboard Authors
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
package org.thingsboard.server.service.sync.ie.exporting.impl;
|
||||||
|
|
||||||
|
import org.apache.commons.collections.CollectionUtils;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.thingsboard.server.common.data.Dashboard;
|
||||||
|
import org.thingsboard.server.common.data.EntityType;
|
||||||
|
import org.thingsboard.server.common.data.id.DashboardId;
|
||||||
|
import org.thingsboard.server.common.data.id.TenantId;
|
||||||
|
import org.thingsboard.server.common.data.sync.ie.EntityExportData;
|
||||||
|
import org.thingsboard.server.common.data.sync.ie.EntityExportSettings;
|
||||||
|
import org.thingsboard.server.queue.util.TbCoreComponent;
|
||||||
|
|
||||||
|
import java.util.Set;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@TbCoreComponent
|
||||||
|
public class DashboardExportService extends BaseEntityExportService<DashboardId, Dashboard, EntityExportData<Dashboard>> {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected void setRelatedEntities(TenantId tenantId, Dashboard dashboard, EntityExportData<Dashboard> exportData, EntityExportSettings settings) {
|
||||||
|
if (CollectionUtils.isNotEmpty(dashboard.getAssignedCustomers())) {
|
||||||
|
dashboard.getAssignedCustomers().forEach(customerInfo -> {
|
||||||
|
customerInfo.setCustomerId(getExternalIdOrElseInternal(customerInfo.getCustomerId()));
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Set<EntityType> getSupportedEntityTypes() {
|
||||||
|
return Set.of(EntityType.DASHBOARD);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -43,6 +43,7 @@ import java.util.HashMap;
|
|||||||
import java.util.LinkedHashMap;
|
import java.util.LinkedHashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
import java.util.Optional;
|
||||||
import java.util.concurrent.ExecutionException;
|
import java.util.concurrent.ExecutionException;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
@ -67,6 +68,7 @@ public class DefaultEntityExportService<I extends EntityId, E extends Exportable
|
|||||||
throw new IllegalArgumentException(entityId.getEntityType() + " [" + entityId.getId() + "] not found");
|
throw new IllegalArgumentException(entityId.getEntityType() + " [" + entityId.getId() + "] not found");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
entity.setId(entity.getExternalId() != null ? entity.getExternalId() : entity.getId());
|
||||||
exportData.setEntity(entity);
|
exportData.setEntity(entity);
|
||||||
exportData.setEntityType(entityId.getEntityType());
|
exportData.setEntityType(entityId.getEntityType());
|
||||||
setAdditionalExportData(user, entity, exportData, exportSettings);
|
setAdditionalExportData(user, entity, exportData, exportSettings);
|
||||||
@ -77,6 +79,10 @@ public class DefaultEntityExportService<I extends EntityId, E extends Exportable
|
|||||||
protected void setAdditionalExportData(SecurityUser user, E entity, D exportData, EntityExportSettings exportSettings) throws ThingsboardException {
|
protected void setAdditionalExportData(SecurityUser user, E entity, D exportData, EntityExportSettings exportSettings) throws ThingsboardException {
|
||||||
if (exportSettings.isExportRelations()) {
|
if (exportSettings.isExportRelations()) {
|
||||||
List<EntityRelation> relations = exportRelations(user, entity);
|
List<EntityRelation> relations = exportRelations(user, entity);
|
||||||
|
relations.forEach(relation -> {
|
||||||
|
relation.setFrom(getExternalIdOrElseInternal(relation.getFrom()));
|
||||||
|
relation.setTo(getExternalIdOrElseInternal(relation.getTo()));
|
||||||
|
});
|
||||||
exportData.setRelations(relations);
|
exportData.setRelations(relations);
|
||||||
}
|
}
|
||||||
if (exportSettings.isExportAttributes()) {
|
if (exportSettings.isExportAttributes()) {
|
||||||
@ -126,6 +132,12 @@ public class DefaultEntityExportService<I extends EntityId, E extends Exportable
|
|||||||
return attributes;
|
return attributes;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected <ID extends EntityId> ID getExternalIdOrElseInternal(ID internalId) {
|
||||||
|
if (internalId == null || internalId.isNullUid()) return internalId;
|
||||||
|
return Optional.ofNullable(exportableEntitiesService.getExternalIdByInternal(internalId))
|
||||||
|
.orElse(internalId);
|
||||||
|
}
|
||||||
|
|
||||||
protected D newExportData() {
|
protected D newExportData() {
|
||||||
return (D) new EntityExportData<E>();
|
return (D) new EntityExportData<E>();
|
||||||
}
|
}
|
||||||
|
|||||||
@ -37,6 +37,8 @@ public class DeviceExportService extends BaseEntityExportService<DeviceId, Devic
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void setRelatedEntities(TenantId tenantId, Device device, DeviceExportData exportData, EntityExportSettings settings) {
|
protected void setRelatedEntities(TenantId tenantId, Device device, DeviceExportData exportData, EntityExportSettings settings) {
|
||||||
|
device.setCustomerId(getExternalIdOrElseInternal(device.getCustomerId()));
|
||||||
|
device.setDeviceProfileId(getExternalIdOrElseInternal(device.getDeviceProfileId()));
|
||||||
if (settings.isExportCredentials()) {
|
if (settings.isExportCredentials()) {
|
||||||
exportData.setCredentials(deviceCredentialsService.findDeviceCredentialsByDeviceId(tenantId, device.getId()));
|
exportData.setCredentials(deviceCredentialsService.findDeviceCredentialsByDeviceId(tenantId, device.getId()));
|
||||||
}
|
}
|
||||||
|
|||||||
@ -0,0 +1,44 @@
|
|||||||
|
/**
|
||||||
|
* Copyright © 2016-2022 The Thingsboard Authors
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
package org.thingsboard.server.service.sync.ie.exporting.impl;
|
||||||
|
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.thingsboard.server.common.data.DeviceProfile;
|
||||||
|
import org.thingsboard.server.common.data.EntityType;
|
||||||
|
import org.thingsboard.server.common.data.id.DeviceProfileId;
|
||||||
|
import org.thingsboard.server.common.data.id.TenantId;
|
||||||
|
import org.thingsboard.server.common.data.sync.ie.EntityExportData;
|
||||||
|
import org.thingsboard.server.common.data.sync.ie.EntityExportSettings;
|
||||||
|
import org.thingsboard.server.queue.util.TbCoreComponent;
|
||||||
|
|
||||||
|
import java.util.Set;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@TbCoreComponent
|
||||||
|
public class DeviceProfileExportService extends BaseEntityExportService<DeviceProfileId, DeviceProfile, EntityExportData<DeviceProfile>> {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected void setRelatedEntities(TenantId tenantId, DeviceProfile deviceProfile, EntityExportData<DeviceProfile> exportData, EntityExportSettings settings) {
|
||||||
|
deviceProfile.setDefaultDashboardId(getExternalIdOrElseInternal(deviceProfile.getDefaultDashboardId()));
|
||||||
|
deviceProfile.setDefaultRuleChainId(getExternalIdOrElseInternal(deviceProfile.getDefaultRuleChainId()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Set<EntityType> getSupportedEntityTypes() {
|
||||||
|
return Set.of(EntityType.DEVICE_PROFILE);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,44 @@
|
|||||||
|
/**
|
||||||
|
* Copyright © 2016-2022 The Thingsboard Authors
|
||||||
|
*
|
||||||
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
|
* you may not use this file except in compliance with the License.
|
||||||
|
* You may obtain a copy of the License at
|
||||||
|
*
|
||||||
|
* http://www.apache.org/licenses/LICENSE-2.0
|
||||||
|
*
|
||||||
|
* Unless required by applicable law or agreed to in writing, software
|
||||||
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||||
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
|
* See the License for the specific language governing permissions and
|
||||||
|
* limitations under the License.
|
||||||
|
*/
|
||||||
|
package org.thingsboard.server.service.sync.ie.exporting.impl;
|
||||||
|
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.thingsboard.server.common.data.EntityType;
|
||||||
|
import org.thingsboard.server.common.data.EntityView;
|
||||||
|
import org.thingsboard.server.common.data.id.EntityViewId;
|
||||||
|
import org.thingsboard.server.common.data.id.TenantId;
|
||||||
|
import org.thingsboard.server.common.data.sync.ie.EntityExportData;
|
||||||
|
import org.thingsboard.server.common.data.sync.ie.EntityExportSettings;
|
||||||
|
import org.thingsboard.server.queue.util.TbCoreComponent;
|
||||||
|
|
||||||
|
import java.util.Set;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@TbCoreComponent
|
||||||
|
public class EntityViewExportService extends BaseEntityExportService<EntityViewId, EntityView, EntityExportData<EntityView>> {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected void setRelatedEntities(TenantId tenantId, EntityView entityView, EntityExportData<EntityView> exportData, EntityExportSettings settings) {
|
||||||
|
entityView.setEntityId(getExternalIdOrElseInternal(entityView.getEntityId()));
|
||||||
|
entityView.setCustomerId(getExternalIdOrElseInternal(entityView.getCustomerId()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Set<EntityType> getSupportedEntityTypes() {
|
||||||
|
return Set.of(EntityType.ENTITY_VIEW);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -28,7 +28,7 @@ import org.thingsboard.server.common.data.id.TenantId;
|
|||||||
import org.thingsboard.server.common.data.validation.Length;
|
import org.thingsboard.server.common.data.validation.Length;
|
||||||
import org.thingsboard.server.common.data.validation.NoXss;
|
import org.thingsboard.server.common.data.validation.NoXss;
|
||||||
|
|
||||||
@EqualsAndHashCode(callSuper = false)
|
@EqualsAndHashCode(callSuper = true)
|
||||||
public class Customer extends ContactBased<CustomerId> implements HasTenantId, ExportableEntity<CustomerId> {
|
public class Customer extends ContactBased<CustomerId> implements HasTenantId, ExportableEntity<CustomerId> {
|
||||||
|
|
||||||
private static final long serialVersionUID = -1599722990298929275L;
|
private static final long serialVersionUID = -1599722990298929275L;
|
||||||
|
|||||||
@ -22,7 +22,7 @@ import lombok.Getter;
|
|||||||
import lombok.Setter;
|
import lombok.Setter;
|
||||||
import org.thingsboard.server.common.data.id.DashboardId;
|
import org.thingsboard.server.common.data.id.DashboardId;
|
||||||
|
|
||||||
@EqualsAndHashCode(callSuper = false)
|
@EqualsAndHashCode(callSuper = true)
|
||||||
public class Dashboard extends DashboardInfo implements ExportableEntity<DashboardId> {
|
public class Dashboard extends DashboardInfo implements ExportableEntity<DashboardId> {
|
||||||
|
|
||||||
private static final long serialVersionUID = 872682138346187503L;
|
private static final long serialVersionUID = 872682138346187503L;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user