Browse Source

refactor services to use tenantService.getTenantById instead of tenantDao.getById

pull/5873/head
desoliture 5 years ago
parent
commit
653a1225aa
  1. 6
      dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java
  2. 7
      dao/src/main/java/org/thingsboard/server/dao/asset/BaseAssetService.java
  3. 9
      dao/src/main/java/org/thingsboard/server/dao/customer/CustomerServiceImpl.java
  4. 7
      dao/src/main/java/org/thingsboard/server/dao/dashboard/DashboardServiceImpl.java
  5. 6
      dao/src/main/java/org/thingsboard/server/dao/device/DeviceProfileServiceImpl.java
  6. 6
      dao/src/main/java/org/thingsboard/server/dao/device/DeviceServiceImpl.java
  7. 6
      dao/src/main/java/org/thingsboard/server/dao/edge/EdgeServiceImpl.java
  8. 1
      dao/src/main/java/org/thingsboard/server/dao/entity/AbstractEntityService.java
  9. 6
      dao/src/main/java/org/thingsboard/server/dao/entityview/EntityViewServiceImpl.java
  10. 7
      dao/src/main/java/org/thingsboard/server/dao/ota/BaseOtaPackageService.java
  11. 11
      dao/src/main/java/org/thingsboard/server/dao/resource/BaseResourceService.java
  12. 7
      dao/src/main/java/org/thingsboard/server/dao/rule/BaseRuleChainService.java
  13. 9
      dao/src/main/java/org/thingsboard/server/dao/tenant/TenantServiceImpl.java
  14. 13
      dao/src/main/java/org/thingsboard/server/dao/usagerecord/ApiUsageStateServiceImpl.java
  15. 11
      dao/src/main/java/org/thingsboard/server/dao/user/UserServiceImpl.java
  16. 7
      dao/src/main/java/org/thingsboard/server/dao/widget/WidgetTypeServiceImpl.java
  17. 7
      dao/src/main/java/org/thingsboard/server/dao/widget/WidgetsBundleServiceImpl.java

6
dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java

@ -51,7 +51,7 @@ import org.thingsboard.server.dao.entity.AbstractEntityService;
import org.thingsboard.server.dao.entity.EntityService;
import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import javax.annotation.Nullable;
import javax.annotation.PostConstruct;
@ -81,7 +81,7 @@ public class BaseAlarmService extends AbstractEntityService implements AlarmServ
private AlarmDao alarmDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private EntityService entityService;
@ -430,7 +430,7 @@ public class BaseAlarmService extends AbstractEntityService implements AlarmServ
if (alarm.getTenantId() == null) {
throw new DataValidationException("Alarm should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(alarm.getTenantId(), alarm.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(alarm.getTenantId());
if (tenant == null) {
throw new DataValidationException("Alarm is referencing to non-existent tenant!");
}

7
dao/src/main/java/org/thingsboard/server/dao/asset/BaseAssetService.java

@ -55,7 +55,7 @@ import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.util.ArrayList;
import java.util.Arrays;
@ -86,7 +86,7 @@ public class BaseAssetService extends AbstractEntityService implements AssetServ
private AssetDao assetDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private CustomerDao customerDao;
@ -416,7 +416,8 @@ public class BaseAssetService extends AbstractEntityService implements AssetServ
if (asset.getTenantId() == null) {
throw new DataValidationException("Asset should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(tenantId, asset.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(asset.getTenantId());
// FIXME: 12.01.22
if (tenant == null) {
throw new DataValidationException("Asset is referencing to non-existent tenant!");
}

9
dao/src/main/java/org/thingsboard/server/dao/customer/CustomerServiceImpl.java

@ -42,7 +42,7 @@ import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import org.thingsboard.server.dao.usagerecord.ApiUsageStateService;
import org.thingsboard.server.dao.user.UserService;
@ -66,7 +66,7 @@ public class CustomerServiceImpl extends AbstractEntityService implements Custom
private UserService userService;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private AssetService assetService;
@ -74,9 +74,6 @@ public class CustomerServiceImpl extends AbstractEntityService implements Custom
@Autowired
private DeviceService deviceService;
@Autowired
private EntityViewService entityViewService;
@Autowired
private DashboardService dashboardService;
@ -213,7 +210,7 @@ public class CustomerServiceImpl extends AbstractEntityService implements Custom
if (customer.getTenantId() == null) {
throw new DataValidationException("Customer should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(tenantId, customer.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(customer.getTenantId());
if (tenant == null) {
throw new DataValidationException("Customer is referencing to non-existent tenant!");
}

7
dao/src/main/java/org/thingsboard/server/dao/dashboard/DashboardServiceImpl.java

@ -45,7 +45,7 @@ import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import static org.thingsboard.server.dao.service.Validator.validateId;
@ -62,7 +62,7 @@ public class DashboardServiceImpl extends AbstractEntityService implements Dashb
private DashboardInfoDao dashboardInfoDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private CustomerDao customerDao;
@ -308,7 +308,8 @@ public class DashboardServiceImpl extends AbstractEntityService implements Dashb
if (dashboard.getTenantId() == null) {
throw new DataValidationException("Dashboard should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(tenantId, dashboard.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(dashboard.getTenantId());
// FIXME: 12.01.22
if (tenant == null) {
throw new DataValidationException("Dashboard is referencing to non-existent tenant!");
}

6
dao/src/main/java/org/thingsboard/server/dao/device/DeviceProfileServiceImpl.java

@ -81,7 +81,7 @@ import org.thingsboard.server.dao.rule.RuleChainService;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import org.thingsboard.server.queue.QueueService;
import java.util.Arrays;
@ -127,7 +127,7 @@ public class DeviceProfileServiceImpl extends AbstractEntityService implements D
private DeviceService deviceService;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private CacheManager cacheManager;
@ -375,7 +375,7 @@ public class DeviceProfileServiceImpl extends AbstractEntityService implements D
if (deviceProfile.getTenantId() == null) {
throw new DataValidationException("Device profile should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(deviceProfile.getTenantId(), deviceProfile.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(deviceProfile.getTenantId());
if (tenant == null) {
throw new DataValidationException("Device profile is referencing to non-existent tenant!");
}

6
dao/src/main/java/org/thingsboard/server/dao/device/DeviceServiceImpl.java

@ -81,7 +81,7 @@ import org.thingsboard.server.dao.ota.OtaPackageService;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import javax.annotation.Nullable;
import java.util.ArrayList;
@ -117,7 +117,7 @@ public class DeviceServiceImpl extends AbstractEntityService implements DeviceSe
private DeviceDao deviceDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private CustomerDao customerDao;
@ -741,7 +741,7 @@ public class DeviceServiceImpl extends AbstractEntityService implements DeviceSe
if (device.getTenantId() == null) {
throw new DataValidationException("Device should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(device.getTenantId(), device.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(device.getTenantId());
if (tenant == null) {
throw new DataValidationException("Device is referencing to non-existent tenant!");
}

6
dao/src/main/java/org/thingsboard/server/dao/edge/EdgeServiceImpl.java

@ -60,7 +60,7 @@ import org.thingsboard.server.dao.rule.RuleChainService;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import org.thingsboard.server.dao.user.UserService;
import javax.annotation.Nullable;
@ -96,7 +96,7 @@ public class EdgeServiceImpl extends AbstractEntityService implements EdgeServic
private EdgeDao edgeDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private CustomerDao customerDao;
@ -413,7 +413,7 @@ public class EdgeServiceImpl extends AbstractEntityService implements EdgeServic
if (edge.getTenantId() == null) {
throw new DataValidationException("Edge should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(edge.getTenantId(), edge.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(edge.getTenantId());
if (tenant == null) {
throw new DataValidationException("Edge is referencing to non-existent tenant!");
}

1
dao/src/main/java/org/thingsboard/server/dao/entity/AbstractEntityService.java

@ -40,6 +40,7 @@ public abstract class AbstractEntityService {
public static final String INCORRECT_EDGE_ID = "Incorrect edgeId ";
public static final String INCORRECT_PAGE_LINK = "Incorrect page link ";
@Lazy
@Autowired
protected RelationService relationService;

6
dao/src/main/java/org/thingsboard/server/dao/entityview/EntityViewServiceImpl.java

@ -52,7 +52,7 @@ import org.thingsboard.server.dao.entity.AbstractEntityService;
import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import javax.annotation.Nullable;
import java.util.ArrayList;
@ -87,7 +87,7 @@ public class EntityViewServiceImpl extends AbstractEntityService implements Enti
private EntityViewDao entityViewDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private CustomerDao customerDao;
@ -432,7 +432,7 @@ public class EntityViewServiceImpl extends AbstractEntityService implements Enti
if (entityView.getTenantId() == null) {
throw new DataValidationException("Entity view should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(tenantId, entityView.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(entityView.getTenantId());
if (tenant == null) {
throw new DataValidationException("Entity view is referencing to non-existent tenant!");
}

7
dao/src/main/java/org/thingsboard/server/dao/ota/BaseOtaPackageService.java

@ -46,7 +46,7 @@ import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.nio.ByteBuffer;
import java.util.Collections;
@ -66,7 +66,7 @@ public class BaseOtaPackageService implements OtaPackageService {
public static final String INCORRECT_OTA_PACKAGE_ID = "Incorrect otaPackageId ";
public static final String INCORRECT_TENANT_ID = "Incorrect tenantId ";
private final TenantDao tenantDao;
private final TenantService tenantService;
private final DeviceProfileDao deviceProfileDao;
private final OtaPackageDao otaPackageDao;
private final OtaPackageInfoDao otaPackageInfoDao;
@ -357,7 +357,8 @@ public class BaseOtaPackageService implements OtaPackageService {
if (otaPackageInfo.getTenantId() == null) {
throw new DataValidationException("OtaPackage should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(otaPackageInfo.getTenantId(), otaPackageInfo.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(otaPackageInfo.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null) {
throw new DataValidationException("OtaPackage is referencing to non-existent tenant!");
}

11
dao/src/main/java/org/thingsboard/server/dao/resource/BaseResourceService.java

@ -36,7 +36,7 @@ import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.util.List;
import java.util.Optional;
@ -52,13 +52,13 @@ public class BaseResourceService implements ResourceService {
public static final String INCORRECT_RESOURCE_ID = "Incorrect resourceId ";
private final TbResourceDao resourceDao;
private final TbResourceInfoDao resourceInfoDao;
private final TenantDao tenantDao;
private final TenantService tenantService;
private final TbTenantProfileCache tenantProfileCache;
public BaseResourceService(TbResourceDao resourceDao, TbResourceInfoDao resourceInfoDao, TenantDao tenantDao, @Lazy TbTenantProfileCache tenantProfileCache) {
public BaseResourceService(TbResourceDao resourceDao, TbResourceInfoDao resourceInfoDao, TenantService tenantService, @Lazy TbTenantProfileCache tenantProfileCache) {
this.resourceDao = resourceDao;
this.resourceInfoDao = resourceInfoDao;
this.tenantDao = tenantDao;
this.tenantService = tenantService;
this.tenantProfileCache = tenantProfileCache;
}
@ -183,7 +183,8 @@ public class BaseResourceService implements ResourceService {
resource.setTenantId(new TenantId(ModelConstants.NULL_UUID));
}
if (!resource.getTenantId().getId().equals(ModelConstants.NULL_UUID)) {
Tenant tenant = tenantDao.findById(tenantId, resource.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(resource.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null) {
throw new DataValidationException("Resource is referencing to non-existent tenant!");
}

7
dao/src/main/java/org/thingsboard/server/dao/rule/BaseRuleChainService.java

@ -59,7 +59,7 @@ import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.util.ArrayList;
import java.util.Collection;
@ -94,7 +94,7 @@ public class BaseRuleChainService extends AbstractEntityService implements RuleC
private RuleNodeDao ruleNodeDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
@Lazy
@ -726,7 +726,8 @@ public class BaseRuleChainService extends AbstractEntityService implements RuleC
if (ruleChain.getTenantId() == null || ruleChain.getTenantId().isNullUid()) {
throw new DataValidationException("Rule chain should be assigned to tenant!");
}
Tenant tenant = tenantDao.findById(tenantId, ruleChain.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(ruleChain.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null) {
throw new DataValidationException("Rule chain is referencing to non-existent tenant!");
}

9
dao/src/main/java/org/thingsboard/server/dao/tenant/TenantServiceImpl.java

@ -21,6 +21,8 @@ import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.context.annotation.Lazy;
import org.springframework.transaction.annotation.Transactional;
import org.thingsboard.server.common.data.Tenant;
import org.thingsboard.server.common.data.TenantInfo;
import org.thingsboard.server.common.data.TenantProfile;
@ -34,7 +36,6 @@ import org.thingsboard.server.dao.dashboard.DashboardService;
import org.thingsboard.server.dao.device.DeviceProfileService;
import org.thingsboard.server.dao.device.DeviceService;
import org.thingsboard.server.dao.entity.AbstractEntityService;
import org.thingsboard.server.dao.entityview.EntityViewService;
import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.ota.OtaPackageService;
import org.thingsboard.server.dao.resource.ResourceService;
@ -66,6 +67,7 @@ public class TenantServiceImpl extends AbstractEntityService implements TenantSe
private TenantProfileService tenantProfileService;
@Autowired
@Lazy
private UserService userService;
@Autowired
@ -83,9 +85,6 @@ public class TenantServiceImpl extends AbstractEntityService implements TenantSe
@Autowired
private ApiUsageStateService apiUsageStateService;
@Autowired
private EntityViewService entityViewService;
@Autowired
private WidgetsBundleService widgetsBundleService;
@ -126,6 +125,7 @@ public class TenantServiceImpl extends AbstractEntityService implements TenantSe
}
@Override
@Transactional
public Tenant saveTenant(Tenant tenant) {
log.trace("Executing saveTenant [{}]", tenant);
tenant.setRegion(DEFAULT_TENANT_REGION);
@ -143,6 +143,7 @@ public class TenantServiceImpl extends AbstractEntityService implements TenantSe
}
@Override
@Transactional
public void deleteTenant(TenantId tenantId) {
log.trace("Executing deleteTenant [{}]", tenantId);
Validator.validateId(tenantId, INCORRECT_TENANT_ID + tenantId);

13
dao/src/main/java/org/thingsboard/server/dao/usagerecord/ApiUsageStateServiceImpl.java

@ -35,7 +35,7 @@ import org.thingsboard.server.common.data.tenant.profile.TenantProfileConfigurat
import org.thingsboard.server.dao.entity.AbstractEntityService;
import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import org.thingsboard.server.dao.tenant.TenantProfileDao;
import org.thingsboard.server.dao.timeseries.TimeseriesService;
@ -52,11 +52,11 @@ public class ApiUsageStateServiceImpl extends AbstractEntityService implements A
private final ApiUsageStateDao apiUsageStateDao;
private final TenantProfileDao tenantProfileDao;
private final TenantDao tenantDao;
private final TenantService tenantService;
private final TimeseriesService tsService;
public ApiUsageStateServiceImpl(TenantDao tenantDao, ApiUsageStateDao apiUsageStateDao, TenantProfileDao tenantProfileDao, TimeseriesService tsService) {
this.tenantDao = tenantDao;
public ApiUsageStateServiceImpl(TenantService tenantService, ApiUsageStateDao apiUsageStateDao, TenantProfileDao tenantProfileDao, TimeseriesService tsService) {
this.tenantService = tenantService;
this.apiUsageStateDao = apiUsageStateDao;
this.tenantProfileDao = tenantProfileDao;
this.tsService = tsService;
@ -114,7 +114,7 @@ public class ApiUsageStateServiceImpl extends AbstractEntityService implements A
if (entityId.getEntityType() == EntityType.TENANT && !entityId.equals(TenantId.SYS_TENANT_ID)) {
tenantId = (TenantId) entityId;
Tenant tenant = tenantDao.findById(tenantId, tenantId.getId());
Tenant tenant = tenantService.findTenantById(tenantId);
TenantProfile tenantProfile = tenantProfileDao.findById(tenantId, tenant.getTenantProfileId().getId());
TenantProfileConfiguration configuration = tenantProfile.getProfileData().getConfiguration();
@ -164,7 +164,8 @@ public class ApiUsageStateServiceImpl extends AbstractEntityService implements A
if (apiUsageState.getTenantId() == null) {
throw new DataValidationException("ApiUsageState should be assigned to tenant!");
} else {
Tenant tenant = tenantDao.findById(requestTenantId, apiUsageState.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(apiUsageState.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null && !requestTenantId.equals(TenantId.SYS_TENANT_ID)) {
throw new DataValidationException("ApiUsageState is referencing to non-existent tenant!");
}

11
dao/src/main/java/org/thingsboard/server/dao/user/UserServiceImpl.java

@ -51,7 +51,7 @@ import org.thingsboard.server.dao.model.ModelConstants;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.tenant.TbTenantProfileCache;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.util.HashMap;
import java.util.Map;
@ -80,20 +80,20 @@ public class UserServiceImpl extends AbstractEntityService implements UserServic
private final UserDao userDao;
private final UserCredentialsDao userCredentialsDao;
private final TenantDao tenantDao;
private final TenantService tenantService;
private final CustomerDao customerDao;
private final TbTenantProfileCache tenantProfileCache;
private final ApplicationEventPublisher eventPublisher;
public UserServiceImpl(UserDao userDao,
UserCredentialsDao userCredentialsDao,
TenantDao tenantDao,
@Lazy TenantService tenantService,
CustomerDao customerDao,
@Lazy TbTenantProfileCache tenantProfileCache,
ApplicationEventPublisher eventPublisher) {
this.userDao = userDao;
this.userCredentialsDao = userCredentialsDao;
this.tenantDao = tenantDao;
this.tenantService = tenantService;
this.customerDao = customerDao;
this.tenantProfileCache = tenantProfileCache;
this.eventPublisher = eventPublisher;
@ -448,7 +448,8 @@ public class UserServiceImpl extends AbstractEntityService implements UserServic
+ " already present in database!");
}
if (!tenantId.getId().equals(ModelConstants.NULL_UUID)) {
Tenant tenant = tenantDao.findById(tenantId, user.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(user.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null) {
throw new DataValidationException("User is referencing to non-existent tenant!");
}

7
dao/src/main/java/org/thingsboard/server/dao/widget/WidgetTypeServiceImpl.java

@ -30,7 +30,7 @@ import org.thingsboard.server.dao.exception.DataValidationException;
import org.thingsboard.server.dao.model.ModelConstants;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.util.List;
@ -44,7 +44,7 @@ public class WidgetTypeServiceImpl implements WidgetTypeService {
private WidgetTypeDao widgetTypeDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private WidgetsBundleDao widgetsBundleService;
@ -138,7 +138,8 @@ public class WidgetTypeServiceImpl implements WidgetTypeService {
widgetTypeDetails.setTenantId(new TenantId(ModelConstants.NULL_UUID));
}
if (!widgetTypeDetails.getTenantId().getId().equals(ModelConstants.NULL_UUID)) {
Tenant tenant = tenantDao.findById(tenantId, widgetTypeDetails.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(widgetTypeDetails.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null) {
throw new DataValidationException("Widget type is referencing to non-existent tenant!");
}

7
dao/src/main/java/org/thingsboard/server/dao/widget/WidgetsBundleServiceImpl.java

@ -31,7 +31,7 @@ import org.thingsboard.server.dao.model.ModelConstants;
import org.thingsboard.server.dao.service.DataValidator;
import org.thingsboard.server.dao.service.PaginatedRemover;
import org.thingsboard.server.dao.service.Validator;
import org.thingsboard.server.dao.tenant.TenantDao;
import org.thingsboard.server.dao.tenant.TenantService;
import java.util.ArrayList;
import java.util.List;
@ -48,7 +48,7 @@ public class WidgetsBundleServiceImpl implements WidgetsBundleService {
private WidgetsBundleDao widgetsBundleDao;
@Autowired
private TenantDao tenantDao;
private TenantService tenantService;
@Autowired
private WidgetTypeService widgetTypeService;
@ -162,7 +162,8 @@ public class WidgetsBundleServiceImpl implements WidgetsBundleService {
widgetsBundle.setTenantId(new TenantId(ModelConstants.NULL_UUID));
}
if (!widgetsBundle.getTenantId().getId().equals(ModelConstants.NULL_UUID)) {
Tenant tenant = tenantDao.findById(tenantId, widgetsBundle.getTenantId().getId());
Tenant tenant = tenantService.findTenantById(widgetsBundle.getTenantId());
// TODO: 12.01.22 Instead of finding and checking for null need to create and use tenantService.exists()
if (tenant == null) {
throw new DataValidationException("Widgets bundle is referencing to non-existent tenant!");
}

Loading…
Cancel
Save