thingsboard-developers

Details

diff --git a/dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java b/dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java
index 77cc574..262a11b 100644
--- a/dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/alarm/BaseAlarmService.java
@@ -193,7 +193,7 @@ public class BaseAlarmService extends AbstractEntityService implements AlarmServ
     public ListenableFuture<Alarm> findAlarmByIdAsync(AlarmId alarmId) {
         log.trace("Executing findAlarmById [{}]", alarmId);
         validateId(alarmId, "Incorrect alarmId " + alarmId);
-        return alarmDao.findByIdAsync(alarmId.getId());
+        return alarmDao.findAlarmByIdAsync(alarmId.getId());
     }
 
     @Override
diff --git a/dao/src/main/java/org/thingsboard/server/dao/alarm/CassandraAlarmDao.java b/dao/src/main/java/org/thingsboard/server/dao/alarm/CassandraAlarmDao.java
index 926127e..343d4cc 100644
--- a/dao/src/main/java/org/thingsboard/server/dao/alarm/CassandraAlarmDao.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/alarm/CassandraAlarmDao.java
@@ -102,6 +102,10 @@ public class CassandraAlarmDao extends CassandraAbstractModelDao<AlarmEntity, Al
 
     @Override
     public ListenableFuture<Alarm> findAlarmByIdAsync(UUID key) {
-        return findByIdAsync(key);
+        log.debug("Get alarm by id {}", key);
+        Select.Where query = select().from(ALARM_BY_ID_VIEW_NAME).where(eq(ModelConstants.ID_PROPERTY, key));
+        query.limit(1);
+        log.trace("Execute query {}", query);
+        return findOneByStatementAsync(query);
     }
 }
diff --git a/dao/src/main/java/org/thingsboard/server/dao/asset/BaseAssetService.java b/dao/src/main/java/org/thingsboard/server/dao/asset/BaseAssetService.java
index a3cd65e..a6fea21 100644
--- a/dao/src/main/java/org/thingsboard/server/dao/asset/BaseAssetService.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/asset/BaseAssetService.java
@@ -226,7 +226,7 @@ public class BaseAssetService extends AbstractEntityService implements AssetServ
                 (Function<List<TenantAssetType>, List<TenantAssetType>>) assetTypeEntities -> {
                     List<TenantAssetType> assetTypes = new ArrayList<>();
                     for (TenantAssetType assetType : assetTypeEntities) {
-                        if (assetType.getTenantId().equals(tenantId.getId())) {
+                        if (assetType.getTenantId().equals(tenantId)) {
                             assetTypes.add(assetType);
                         }
                     }
@@ -252,7 +252,7 @@ public class BaseAssetService extends AbstractEntityService implements AssetServ
                 protected void validateUpdate(Asset asset) {
                     assetDao.findAssetsByTenantIdAndName(asset.getTenantId().getId(), asset.getName()).ifPresent(
                             d -> {
-                                if (!d.getId().equals(asset.getUuidId())) {
+                                if (!d.getId().equals(asset.getId())) {
                                     throw new DataValidationException("Asset with such name already exists!");
                                 }
                             }
@@ -282,7 +282,7 @@ public class BaseAssetService extends AbstractEntityService implements AssetServ
                         if (customer == null) {
                             throw new DataValidationException("Can't assign asset to non-existent customer!");
                         }
-                        if (!customer.getTenantId().equals(asset.getTenantId().getId())) {
+                        if (!customer.getTenantId().equals(asset.getTenantId())) {
                             throw new DataValidationException("Can't assign asset to customer from different tenant!");
                         }
                     }
diff --git a/dao/src/main/java/org/thingsboard/server/dao/asset/CassandraAssetDao.java b/dao/src/main/java/org/thingsboard/server/dao/asset/CassandraAssetDao.java
index d53a2e4..d78b931 100644
--- a/dao/src/main/java/org/thingsboard/server/dao/asset/CassandraAssetDao.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/asset/CassandraAssetDao.java
@@ -55,12 +55,6 @@ public class CassandraAssetDao extends CassandraAbstractSearchTextDao<AssetEntit
     }
 
     @Override
-    public Asset save(Asset asset) {
-        log.debug("Save asset [{}] ", asset);
-        return save(asset);
-    }
-
-    @Override
     public List<Asset> findAssetsByTenantId(UUID tenantId, TextPageLink pageLink) {
         log.debug("Try to find assets by tenantId [{}] and pageLink [{}]", tenantId, pageLink);
         List<AssetEntity> assetEntities = findPageWithTextSearch(ASSET_BY_TENANT_AND_SEARCH_TEXT_COLUMN_FAMILY_NAME,
diff --git a/dao/src/main/java/org/thingsboard/server/dao/device/DeviceServiceImpl.java b/dao/src/main/java/org/thingsboard/server/dao/device/DeviceServiceImpl.java
index fe1997e..b06faa1 100644
--- a/dao/src/main/java/org/thingsboard/server/dao/device/DeviceServiceImpl.java
+++ b/dao/src/main/java/org/thingsboard/server/dao/device/DeviceServiceImpl.java
@@ -246,7 +246,7 @@ public class DeviceServiceImpl extends AbstractEntityService implements DeviceSe
             (Function<List<TenantDeviceType>, List<TenantDeviceType>>) deviceTypeEntities -> {
                 List<TenantDeviceType> deviceTypes = new ArrayList<>();
                 for (TenantDeviceType deviceType : deviceTypeEntities) {
-                    if (deviceType.getTenantId().equals(tenantId.getId())) {
+                    if (deviceType.getTenantId().equals(tenantId)) {
                         deviceTypes.add(deviceType);
                     }
                 }