Browse Source

Fix merge

pull/3557/head
vzikratyi 6 years ago
parent
commit
58464c54dc
  1. 15
      common/data/src/main/java/org/thingsboard/server/common/data/kv/BaseEntityAttributeKvEntry.java
  2. 5
      common/data/src/main/java/org/thingsboard/server/common/data/kv/EntityAttributeKvEntry.java
  3. 4
      dao/src/main/java/org/thingsboard/server/dao/lock/LockServiceImpl.java
  4. 2
      dao/src/main/java/org/thingsboard/server/dao/model/sql/AttributeKvEntity.java
  5. 6
      dao/src/main/java/org/thingsboard/server/dao/oauth2/OAuth2ServiceImpl.java
  6. 2
      dao/src/main/java/org/thingsboard/server/dao/sql/lock/PsqlLockRepository.java

15
common/data/src/main/java/org/thingsboard/server/common/data/kv/BaseEntityAttributeKvEntry.java

@ -19,26 +19,21 @@ import lombok.EqualsAndHashCode;
import lombok.ToString; import lombok.ToString;
import org.thingsboard.server.common.data.EntityType; import org.thingsboard.server.common.data.EntityType;
import java.util.UUID;
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode(callSuper = true)
@ToString(callSuper = true) @ToString(callSuper = true)
public class BaseEntityAttributeKvEntry extends BaseAttributeKvEntry implements EntityAttributeKvEntry { public class BaseEntityAttributeKvEntry extends BaseAttributeKvEntry implements EntityAttributeKvEntry {
private final EntityType entityType; private final UUID entityId;
private final String entityId;
public BaseEntityAttributeKvEntry(EntityType entityType, String entityId, long lastUpdateTs, KvEntry kv) { public BaseEntityAttributeKvEntry(UUID entityId, long lastUpdateTs, KvEntry kv) {
super(kv, lastUpdateTs); super(kv, lastUpdateTs);
this.entityType = entityType;
this.entityId = entityId; this.entityId = entityId;
} }
@Override @Override
public EntityType getEntityType() { public UUID getEntityId() {
return entityType;
}
@Override
public String getEntityId() {
return entityId; return entityId;
} }
} }

5
common/data/src/main/java/org/thingsboard/server/common/data/kv/EntityAttributeKvEntry.java

@ -15,10 +15,9 @@
*/ */
package org.thingsboard.server.common.data.kv; package org.thingsboard.server.common.data.kv;
import org.thingsboard.server.common.data.EntityType; import java.util.UUID;
public interface EntityAttributeKvEntry extends AttributeKvEntry { public interface EntityAttributeKvEntry extends AttributeKvEntry {
EntityType getEntityType(); UUID getEntityId();
String getEntityId();
} }

4
dao/src/main/java/org/thingsboard/server/dao/lock/LockServiceImpl.java

@ -31,7 +31,9 @@ public class LockServiceImpl implements LockService {
@PostConstruct @PostConstruct
public void init(){ public void init(){
log.warn("Locking with DB is not enabled."); if (lockRepository == null) {
log.warn("Locking with DB is not enabled.");
}
} }
@Override @Override

2
dao/src/main/java/org/thingsboard/server/dao/model/sql/AttributeKvEntity.java

@ -89,6 +89,6 @@ public class AttributeKvEntity implements ToData<AttributeKvEntry>, Serializable
kvEntry = new JsonDataEntry(id.getAttributeKey(), jsonValue); kvEntry = new JsonDataEntry(id.getAttributeKey(), jsonValue);
} }
return new BaseEntityAttributeKvEntry(id.getEntityType(), id.getEntityId(), lastUpdateTs, kvEntry); return new BaseEntityAttributeKvEntry(id.getEntityId(), lastUpdateTs, kvEntry);
}; };
} }

6
dao/src/main/java/org/thingsboard/server/dao/oauth2/OAuth2ServiceImpl.java

@ -333,14 +333,14 @@ public class OAuth2ServiceImpl implements OAuth2Service {
@Override @Override
public Map<TenantId, OAuth2ClientsParams> getAllOAuth2ClientsParams() { public Map<TenantId, OAuth2ClientsParams> getAllOAuth2ClientsParams() {
OAuth2ClientsParams systemOAuth2ClientsParams = getSystemOAuth2ClientsParams(); OAuth2ClientsParams systemOAuth2ClientsParams = getSystemOAuth2ClientsParams();
ListenableFuture<Map<String, String>> jsonFuture = getAllOAuth2ClientsParamsAttribute(); ListenableFuture<Map<UUID, String>> jsonFuture = getAllOAuth2ClientsParamsAttribute();
try { try {
return Futures.transform(jsonFuture, return Futures.transform(jsonFuture,
clientsParamsByKvEntryKey -> { clientsParamsByKvEntryKey -> {
Map<TenantId, OAuth2ClientsParams> tenantClientParams = clientsParamsByKvEntryKey != null ? Map<TenantId, OAuth2ClientsParams> tenantClientParams = clientsParamsByKvEntryKey != null ?
clientsParamsByKvEntryKey.entrySet().stream() clientsParamsByKvEntryKey.entrySet().stream()
.collect(Collectors.toMap( .collect(Collectors.toMap(
entry -> new TenantId(UUIDConverter.fromString(entry.getKey())), entry -> new TenantId(entry.getKey()),
entry -> constructOAuth2ClientsParams(entry.getValue()) entry -> constructOAuth2ClientsParams(entry.getValue())
)) ))
: new HashMap<>(); : new HashMap<>();
@ -405,7 +405,7 @@ public class OAuth2ServiceImpl implements OAuth2Service {
} }
// TODO maybe it's better to load all tenants and get attribute for each one // TODO maybe it's better to load all tenants and get attribute for each one
private ListenableFuture<Map<String, String>> getAllOAuth2ClientsParamsAttribute() { private ListenableFuture<Map<UUID, String>> getAllOAuth2ClientsParamsAttribute() {
ListenableFuture<List<EntityAttributeKvEntry>> entityAttributeKvEntriesFuture; ListenableFuture<List<EntityAttributeKvEntry>> entityAttributeKvEntriesFuture;
try { try {
entityAttributeKvEntriesFuture = attributesService.findAllByAttributeKey(OAUTH2_CLIENT_REGISTRATIONS_PARAMS); entityAttributeKvEntriesFuture = attributesService.findAllByAttributeKey(OAUTH2_CLIENT_REGISTRATIONS_PARAMS);

2
dao/src/main/java/org/thingsboard/server/dao/sql/lock/PsqlLockRepository.java

@ -20,10 +20,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import org.thingsboard.server.dao.util.PsqlDao; import org.thingsboard.server.dao.util.PsqlDao;
import org.thingsboard.server.dao.util.SqlDao;
@Slf4j @Slf4j
@SqlDao
@PsqlDao @PsqlDao
@Repository @Repository
public class PsqlLockRepository implements LockRepository { public class PsqlLockRepository implements LockRepository {

Loading…
Cancel
Save