Minor fixes
This commit is contained in:
parent
3a5d1b31b3
commit
f5eb27efd4
@ -678,6 +678,7 @@ public class DefaultSystemDataLoaderService implements SystemDataLoaderService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void createDefaultNotificationConfigs() {
|
public void createDefaultNotificationConfigs() {
|
||||||
|
notificationSettingsService.createDefaultNotificationConfigs(TenantId.SYS_TENANT_ID);
|
||||||
PageDataIterable<TenantId> tenants = new PageDataIterable<>(tenantService::findTenantsIds, 500);
|
PageDataIterable<TenantId> tenants = new PageDataIterable<>(tenantService::findTenantsIds, 500);
|
||||||
for (TenantId tenantId : tenants) {
|
for (TenantId tenantId : tenants) {
|
||||||
try {
|
try {
|
||||||
|
|||||||
@ -52,7 +52,7 @@ public enum Resource {
|
|||||||
private final Set<EntityType> entityTypes;
|
private final Set<EntityType> entityTypes;
|
||||||
|
|
||||||
Resource() {
|
Resource() {
|
||||||
this.entityTypes = null;
|
this.entityTypes = Collections.emptySet();
|
||||||
}
|
}
|
||||||
|
|
||||||
Resource(EntityType... entityTypes) {
|
Resource(EntityType... entityTypes) {
|
||||||
@ -60,7 +60,7 @@ public enum Resource {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public Set<EntityType> getEntityTypes() {
|
public Set<EntityType> getEntityTypes() {
|
||||||
return Optional.ofNullable(entityTypes).orElse(Collections.emptySet());
|
return entityTypes;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static Resource of(EntityType entityType) {
|
public static Resource of(EntityType entityType) {
|
||||||
|
|||||||
@ -29,6 +29,7 @@ import org.thingsboard.server.common.data.notification.targets.platform.Customer
|
|||||||
import org.thingsboard.server.common.data.notification.targets.platform.PlatformUsersNotificationTargetConfig;
|
import org.thingsboard.server.common.data.notification.targets.platform.PlatformUsersNotificationTargetConfig;
|
||||||
import org.thingsboard.server.common.data.notification.targets.platform.UserListFilter;
|
import org.thingsboard.server.common.data.notification.targets.platform.UserListFilter;
|
||||||
import org.thingsboard.server.common.data.page.PageData;
|
import org.thingsboard.server.common.data.page.PageData;
|
||||||
|
import org.thingsboard.server.common.data.page.PageLink;
|
||||||
import org.thingsboard.server.controller.AbstractControllerTest;
|
import org.thingsboard.server.controller.AbstractControllerTest;
|
||||||
import org.thingsboard.server.dao.notification.NotificationTargetDao;
|
import org.thingsboard.server.dao.notification.NotificationTargetDao;
|
||||||
import org.thingsboard.server.dao.service.DaoSqlTest;
|
import org.thingsboard.server.dao.service.DaoSqlTest;
|
||||||
@ -141,10 +142,10 @@ public class NotificationTargetApiTest extends AbstractControllerTest {
|
|||||||
targetConfig.setUsersFilter(new AllUsersFilter());
|
targetConfig.setUsersFilter(new AllUsersFilter());
|
||||||
notificationTarget.setConfiguration(targetConfig);
|
notificationTarget.setConfiguration(targetConfig);
|
||||||
save(notificationTarget, status().isOk());
|
save(notificationTarget, status().isOk());
|
||||||
assertThat(notificationTargetDao.find(TenantId.SYS_TENANT_ID)).isNotEmpty();
|
assertThat(notificationTargetDao.findByTenantIdAndPageLink(differentTenantId, new PageLink(10)).getData()).isNotEmpty();
|
||||||
|
|
||||||
deleteDifferentTenant();
|
deleteDifferentTenant();
|
||||||
assertThat(notificationTargetDao.find(TenantId.SYS_TENANT_ID)).isEmpty();
|
assertThat(notificationTargetDao.findByTenantIdAndPageLink(differentTenantId, new PageLink(10)).getData()).isEmpty();
|
||||||
}
|
}
|
||||||
|
|
||||||
private String saveAndGetError(NotificationTarget notificationTarget, ResultMatcher statusMatcher) throws Exception {
|
private String saveAndGetError(NotificationTarget notificationTarget, ResultMatcher statusMatcher) throws Exception {
|
||||||
|
|||||||
@ -68,6 +68,11 @@ public class DefaultNotificationSettingsService implements NotificationSettingsS
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void createDefaultNotificationConfigs(TenantId tenantId) {
|
public void createDefaultNotificationConfigs(TenantId tenantId) {
|
||||||
|
if (tenantId.equals(TenantId.SYS_TENANT_ID)) {
|
||||||
|
// TODO
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
NotificationTarget allUsersTarget = new NotificationTarget();
|
NotificationTarget allUsersTarget = new NotificationTarget();
|
||||||
allUsersTarget.setTenantId(tenantId);
|
allUsersTarget.setTenantId(tenantId);
|
||||||
allUsersTarget.setName("All users");
|
allUsersTarget.setName("All users");
|
||||||
|
|||||||
@ -55,6 +55,7 @@ public interface NotificationRepository extends JpaRepository<NotificationEntity
|
|||||||
int updateStatusesByRequestId(@Param("requestId") UUID requestId,
|
int updateStatusesByRequestId(@Param("requestId") UUID requestId,
|
||||||
@Param("status") NotificationStatus status);
|
@Param("status") NotificationStatus status);
|
||||||
|
|
||||||
|
@Transactional
|
||||||
int deleteByIdAndRecipientId(UUID id, UUID recipientId);
|
int deleteByIdAndRecipientId(UUID id, UUID recipientId);
|
||||||
|
|
||||||
@Modifying
|
@Modifying
|
||||||
|
|||||||
@ -69,8 +69,10 @@ public interface NotificationRequestRepository extends JpaRepository<Notificatio
|
|||||||
|
|
||||||
boolean existsByStatusAndTemplateId(NotificationRequestStatus status, UUID templateId);
|
boolean existsByStatusAndTemplateId(NotificationRequestStatus status, UUID templateId);
|
||||||
|
|
||||||
|
@Transactional
|
||||||
int deleteAllByCreatedTimeBefore(long ts);
|
int deleteAllByCreatedTimeBefore(long ts);
|
||||||
|
|
||||||
|
@Transactional
|
||||||
void deleteByTenantId(UUID tenantId);
|
void deleteByTenantId(UUID tenantId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -21,6 +21,7 @@ import org.springframework.data.jpa.repository.JpaRepository;
|
|||||||
import org.springframework.data.jpa.repository.Query;
|
import org.springframework.data.jpa.repository.Query;
|
||||||
import org.springframework.data.repository.query.Param;
|
import org.springframework.data.repository.query.Param;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
import org.thingsboard.server.common.data.notification.rule.NotificationRuleInfo;
|
import org.thingsboard.server.common.data.notification.rule.NotificationRuleInfo;
|
||||||
import org.thingsboard.server.common.data.notification.rule.trigger.NotificationRuleTriggerType;
|
import org.thingsboard.server.common.data.notification.rule.trigger.NotificationRuleTriggerType;
|
||||||
import org.thingsboard.server.dao.model.sql.NotificationRuleEntity;
|
import org.thingsboard.server.dao.model.sql.NotificationRuleEntity;
|
||||||
@ -53,6 +54,7 @@ public interface NotificationRuleRepository extends JpaRepository<NotificationRu
|
|||||||
@Param("searchText") String searchText,
|
@Param("searchText") String searchText,
|
||||||
Pageable pageable);
|
Pageable pageable);
|
||||||
|
|
||||||
|
@Transactional
|
||||||
void deleteByTenantId(UUID tenantId);
|
void deleteByTenantId(UUID tenantId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -21,6 +21,7 @@ import org.springframework.data.jpa.repository.JpaRepository;
|
|||||||
import org.springframework.data.jpa.repository.Query;
|
import org.springframework.data.jpa.repository.Query;
|
||||||
import org.springframework.data.repository.query.Param;
|
import org.springframework.data.repository.query.Param;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
import org.thingsboard.server.dao.model.sql.NotificationTargetEntity;
|
import org.thingsboard.server.dao.model.sql.NotificationTargetEntity;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
@ -33,6 +34,7 @@ public interface NotificationTargetRepository extends JpaRepository<Notification
|
|||||||
|
|
||||||
List<NotificationTargetEntity> findByTenantIdAndIdIn(UUID tenantId, List<UUID> ids);
|
List<NotificationTargetEntity> findByTenantIdAndIdIn(UUID tenantId, List<UUID> ids);
|
||||||
|
|
||||||
|
@Transactional
|
||||||
void deleteByTenantId(UUID tenantId);
|
void deleteByTenantId(UUID tenantId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -21,6 +21,7 @@ import org.springframework.data.jpa.repository.JpaRepository;
|
|||||||
import org.springframework.data.jpa.repository.Query;
|
import org.springframework.data.jpa.repository.Query;
|
||||||
import org.springframework.data.repository.query.Param;
|
import org.springframework.data.repository.query.Param;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
import org.thingsboard.server.common.data.notification.NotificationType;
|
import org.thingsboard.server.common.data.notification.NotificationType;
|
||||||
import org.thingsboard.server.dao.model.sql.NotificationTemplateEntity;
|
import org.thingsboard.server.dao.model.sql.NotificationTemplateEntity;
|
||||||
|
|
||||||
@ -39,6 +40,7 @@ public interface NotificationTemplateRepository extends JpaRepository<Notificati
|
|||||||
@Param("searchText") String searchText,
|
@Param("searchText") String searchText,
|
||||||
Pageable pageable);
|
Pageable pageable);
|
||||||
|
|
||||||
|
@Transactional
|
||||||
void deleteByTenantId(UUID tenantId);
|
void deleteByTenantId(UUID tenantId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user