diff --git a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/InAppNotificationController.java b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/InAppNotificationController.java index 49d0c7a99..fb7c7a443 100644 --- a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/InAppNotificationController.java +++ b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/InAppNotificationController.java @@ -94,7 +94,7 @@ public class InAppNotificationController { UUID userId = this.userScope.getUserId(); this.censorFactory.censor(InAppNotificationCensor.class).censor(fieldSet, userId); - InAppNotificationQuery query = this.queryFactory.query(InAppNotificationQuery.class).authorize(AuthorizationFlags.OwnerOrPermission).userId(userId).ids(id); + InAppNotificationQuery query = this.queryFactory.query(InAppNotificationQuery.class).disableTracking().authorize(AuthorizationFlags.OwnerOrPermission).userId(userId).ids(id); InAppNotification model = this.builderFactory.builder(InAppNotificationBuilder.class).authorize(AuthorizationFlags.OwnerOrPermission).build(fieldSet, query.firstAs(fieldSet)); if (model == null) throw new MyNotFoundException(messageSource.getMessage("General_ItemNotFound", new Object[]{id, Notification.class.getSimpleName()}, LocaleContextHolder.getLocale())); @@ -145,7 +145,7 @@ public class InAppNotificationController { this.censorFactory.censor(InAppNotificationCensor.class).censor(new BaseFieldSet(InAppNotification.Field.ID), userId); - InAppNotificationQuery query = this.queryFactory.query(InAppNotificationQuery.class).isActive(IsActive.Active).trackingState(NotificationInAppTracking.STORED).userId(userId); + InAppNotificationQuery query = this.queryFactory.query(InAppNotificationQuery.class).disableTracking().isActive(IsActive.Active).trackingState(NotificationInAppTracking.STORED).userId(userId); int count = Math.toIntExact(query.count()); //this.auditService.trackIdentity(AuditableAction.IdentityTracking_Action); diff --git a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationController.java b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationController.java index 913a96a1b..0cc2889da 100644 --- a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationController.java +++ b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationController.java @@ -81,7 +81,7 @@ public class NotificationController { this.censorFactory.censor(NotificationCensor.class).censor(fieldSet); - NotificationQuery query = this.queryFactory.query(NotificationQuery.class).authorize(AuthorizationFlags.OwnerOrPermission).ids(id); + NotificationQuery query = this.queryFactory.query(NotificationQuery.class).disableTracking().authorize(AuthorizationFlags.OwnerOrPermission).ids(id); Notification model = this.builderFactory.builder(NotificationBuilder.class).authorize(AuthorizationFlags.OwnerOrPermission).build(fieldSet, query.firstAs(fieldSet)); if (model == null) throw new MyNotFoundException(messageSource.getMessage("General_ItemNotFound", new Object[]{id, Notification.class.getSimpleName()}, LocaleContextHolder.getLocale())); diff --git a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationTemplateController.java b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationTemplateController.java index 187fa9fca..44bd2482d 100644 --- a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationTemplateController.java +++ b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/NotificationTemplateController.java @@ -81,7 +81,7 @@ public class NotificationTemplateController { this.censorFactory.censor(NotificationTemplateCensor.class).censor(fieldSet); - NotificationTemplateQuery query = this.queryFactory.query(NotificationTemplateQuery.class).authorize(AuthorizationFlags.OwnerOrPermission).ids(id); + NotificationTemplateQuery query = this.queryFactory.query(NotificationTemplateQuery.class).disableTracking().authorize(AuthorizationFlags.OwnerOrPermission).ids(id); NotificationTemplate model = this.builderFactory.builder(NotificationTemplateBuilder.class).authorize(AuthorizationFlags.OwnerOrPermission).build(fieldSet, query.first()); if (model == null) throw new MyNotFoundException(messageSource.getMessage("General_ItemNotFound", new Object[]{id, NotificationTemplate.class.getSimpleName()}, LocaleContextHolder.getLocale())); diff --git a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/TenantConfigurationController.java b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/TenantConfigurationController.java index dd3ac093e..0f258397f 100644 --- a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/TenantConfigurationController.java +++ b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/TenantConfigurationController.java @@ -103,7 +103,7 @@ public class TenantConfigurationController { this.censorFactory.censor(TenantConfigurationCensor.class).censor(fieldSet, null); - TenantConfigurationQuery query = this.queryFactory.query(TenantConfigurationQuery.class).authorize(AuthorizationFlags.OwnerOrPermission).ids(id); + TenantConfigurationQuery query = this.queryFactory.query(TenantConfigurationQuery.class).disableTracking()authorize(AuthorizationFlags.OwnerOrPermission).ids(id); TenantConfiguration model = this.builderFactory.builder(TenantConfigurationBuilder.class).authorize(AuthorizationFlags.OwnerOrPermission).build(fieldSet, query.firstAs(fieldSet)); if (model == null) throw new MyNotFoundException(messageSource.getMessage("General_ItemNotFound", new Object[]{id, TenantConfiguration.class.getSimpleName()}, LocaleContextHolder.getLocale())); @@ -122,7 +122,7 @@ public class TenantConfigurationController { this.censorFactory.censor(TenantConfigurationCensor.class).censor(fieldSet, null); - TenantConfigurationQuery query = this.queryFactory.query(TenantConfigurationQuery.class).authorize(AuthorizationFlags.OwnerOrPermission).isActive(IsActive.Active).types(TenantConfigurationType.of(type)); + TenantConfigurationQuery query = this.queryFactory.query(TenantConfigurationQuery.class).disableTracking().authorize(AuthorizationFlags.OwnerOrPermission).isActive(IsActive.Active).types(TenantConfigurationType.of(type)); if (this.tenantScope.isDefaultTenant()) query.tenantIsSet(false); else query.tenantIsSet(true).tenantIds(this.tenantScope.getTenant()); diff --git a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/UserNotificationPreferenceController.java b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/UserNotificationPreferenceController.java index fb1cece22..35f37a802 100644 --- a/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/UserNotificationPreferenceController.java +++ b/notification-service/notification-web/src/main/java/gr/cite/notification/web/controllers/UserNotificationPreferenceController.java @@ -95,7 +95,7 @@ public class UserNotificationPreferenceController { Ordering ordering = new Ordering(); ordering.addAscending(UserNotificationPreference._ordinal); - UserNotificationPreferenceQuery query = this.queryFactory.query(UserNotificationPreferenceQuery.class).userId(userId).isActives(IsActive.Active); + UserNotificationPreferenceQuery query = this.queryFactory.query(UserNotificationPreferenceQuery.class).disableTracking().userId(userId).isActives(IsActive.Active); query.setOrder(ordering); if (this.tenantScope.isMultitenant() && this.tenantScope.isSet()) { if (!this.tenantScope.isDefaultTenant()) { diff --git a/notification-service/notification-web/src/main/java/gr/cite/notification/web/scope/user/UserInterceptor.java b/notification-service/notification-web/src/main/java/gr/cite/notification/web/scope/user/UserInterceptor.java index 033211e89..36ad1e83f 100644 --- a/notification-service/notification-web/src/main/java/gr/cite/notification/web/scope/user/UserInterceptor.java +++ b/notification-service/notification-web/src/main/java/gr/cite/notification/web/scope/user/UserInterceptor.java @@ -63,7 +63,7 @@ public class UserInterceptor implements WebRequestInterceptor { this.userScope.setUserId(userId); } private UUID findExistingUserFromDb(String subjectId) { - UserCredentialEntity userCredential = this.queryFactory.query(UserCredentialQuery.class).externalIds(subjectId).firstAs(new BaseFieldSet().ensure(UserCredential._user)); + UserCredentialEntity userCredential = this.queryFactory.query(UserCredentialQuery.class).disableTracking().externalIds(subjectId).firstAs(new BaseFieldSet().ensure(UserCredential._user)); if (userCredential != null) { return userCredential.getUserId(); } diff --git a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/notify/NotifyConsistencyHandler.java b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/notify/NotifyConsistencyHandler.java index 4b59fd929..a7cd2e64f 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/notify/NotifyConsistencyHandler.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/notify/NotifyConsistencyHandler.java @@ -34,7 +34,7 @@ public class NotifyConsistencyHandler implements ConsistencyHandler 0; } diff --git a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaleremoval/TenantDefaultLocaleRemovalIntegrationEventHandlerImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaleremoval/TenantDefaultLocaleRemovalIntegrationEventHandlerImpl.java index 1afb3929e..b3b69a600 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaleremoval/TenantDefaultLocaleRemovalIntegrationEventHandlerImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaleremoval/TenantDefaultLocaleRemovalIntegrationEventHandlerImpl.java @@ -68,7 +68,7 @@ public class TenantDefaultLocaleRemovalIntegrationEventHandlerImpl implements Te } if (this.tenantScope.isMultitenant() && properties.getTenantId() != null) { - TenantEntity tenant = queryFactory.query(TenantQuery.class).ids(properties.getTenantId()).firstAs(new BaseFieldSet().ensure(Tenant._id).ensure(Tenant._code)); + TenantEntity tenant = queryFactory.query(TenantQuery.class).disableTracking().ids(properties.getTenantId()).firstAs(new BaseFieldSet().ensure(Tenant._id).ensure(Tenant._code)); if (tenant == null) { logger.error("missing tenant from event message"); return EventProcessingStatus.Error; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedConsistencyHandler.java b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedConsistencyHandler.java index c0b56404f..23e86ee34 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedConsistencyHandler.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedConsistencyHandler.java @@ -20,7 +20,7 @@ public class TenantDefaultLocaleTouchedConsistencyHandler implements Consistency @Override public Boolean isConsistent(TenantDefaultLocaleTouchedConsistencyPredicates consistencyPredicates) { if (consistencyPredicates.getTenantId() == null) return true; - long count = this.queryFactory.query(TenantQuery.class).ids(consistencyPredicates.getTenantId()).count(); + long count = this.queryFactory.query(TenantQuery.class).disableTracking().ids(consistencyPredicates.getTenantId()).count(); return count > 0; } diff --git a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedIntegrationEventHandlerImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedIntegrationEventHandlerImpl.java index 05bc060b8..c92aa288e 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedIntegrationEventHandlerImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantdefaultlocaletouched/TenantDefaultLocaleTouchedIntegrationEventHandlerImpl.java @@ -77,7 +77,7 @@ public class TenantDefaultLocaleTouchedIntegrationEventHandlerImpl implements Te return status; } if (this.tenantScope.isMultitenant() && properties.getTenantId() != null) { - TenantEntity tenant = queryFactory.query(TenantQuery.class).ids(properties.getTenantId()).firstAs(new BaseFieldSet().ensure(Tenant._id).ensure(Tenant._code)); + TenantEntity tenant = queryFactory.query(TenantQuery.class).disableTracking().ids(properties.getTenantId()).firstAs(new BaseFieldSet().ensure(Tenant._id).ensure(Tenant._code)); if (tenant == null) { logger.error("missing tenant from event message"); return EventProcessingStatus.Error; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantremoval/TenantRemovalConsistencyHandler.java b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantremoval/TenantRemovalConsistencyHandler.java index 685597a98..167443900 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantremoval/TenantRemovalConsistencyHandler.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/tenantremoval/TenantRemovalConsistencyHandler.java @@ -19,7 +19,7 @@ public class TenantRemovalConsistencyHandler implements ConsistencyHandler 0; } diff --git a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/userremoval/UserRemovalConsistencyHandler.java b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/userremoval/UserRemovalConsistencyHandler.java index 958d00b84..9cda19a0c 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/userremoval/UserRemovalConsistencyHandler.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/integrationevent/inbox/userremoval/UserRemovalConsistencyHandler.java @@ -19,7 +19,7 @@ public class UserRemovalConsistencyHandler implements ConsistencyHandler x.getId()); } else { FieldSet clone = new BaseFieldSet(fields.getFields()).ensure(Tenant._id); - TenantQuery q = this.queryFactory.query(TenantQuery.class).authorize(this.authorize).ids(datas.stream().map(x -> x.getTenantId()).distinct().collect(Collectors.toList())); + TenantQuery q = this.queryFactory.query(TenantQuery.class).disableTracking().authorize(this.authorize).ids(datas.stream().map(x -> x.getTenantId()).distinct().collect(Collectors.toList())); itemMap = this.builderFactory.builder(TenantBuilder.class).authorize(this.authorize).asForeignKey(q, clone, x -> x.getId()); } if (!fields.hasField(Tenant._id)) { diff --git a/notification-service/notification/src/main/java/gr/cite/notification/model/builder/UserContactInfoBuilder.java b/notification-service/notification/src/main/java/gr/cite/notification/model/builder/UserContactInfoBuilder.java index 45e8e22f9..be2377a6c 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/model/builder/UserContactInfoBuilder.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/model/builder/UserContactInfoBuilder.java @@ -85,7 +85,7 @@ public class UserContactInfoBuilder extends BaseBuilder { return this; } + public InAppNotificationQuery enableTracking() { + this.noTracking = false; + return this; + } + + public InAppNotificationQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Boolean isFalseQuery() { return this.isNullOrEmpty(this.ids) diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationQuery.java index 6974721e6..4918e5ea6 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationQuery.java @@ -206,6 +206,16 @@ public class NotificationQuery extends QueryBase { return this; } + public NotificationQuery enableTracking() { + this.noTracking = false; + return this; + } + + public NotificationQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Boolean isFalseQuery() { return this.isNullOrEmpty(this.ids) diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationTemplateQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationTemplateQuery.java index ae7a62ee6..439a0d808 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationTemplateQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/NotificationTemplateQuery.java @@ -145,6 +145,16 @@ public class NotificationTemplateQuery extends QueryBase { return this; } + public QueueInboxQuery enableTracking() { + this.noTracking = false; + return this; + } + + public QueueInboxQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Class entityClass() { return QueueInboxEntity.class; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/QueueOutboxQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/QueueOutboxQuery.java index 4dbea999c..c21d73326 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/QueueOutboxQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/QueueOutboxQuery.java @@ -126,6 +126,16 @@ public class QueueOutboxQuery extends QueryBase { return this; } + public QueueOutboxQuery enableTracking() { + this.noTracking = false; + return this; + } + + public QueueOutboxQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Class entityClass() { return QueueOutboxEntity.class; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/TenantConfigurationQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/TenantConfigurationQuery.java index 35f3ce586..ef2f3bacf 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/TenantConfigurationQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/TenantConfigurationQuery.java @@ -119,6 +119,16 @@ public class TenantConfigurationQuery extends QueryBase { return this; } + public TenantQuery enableTracking() { + this.noTracking = false; + return this; + } + + public TenantQuery disableTracking() { + this.noTracking = false; + return this; + } + public TenantQuery authorize(EnumSet values) { this.authorize = values; return this; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/TenantUserQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/TenantUserQuery.java index ff1c87e7f..0f5a24167 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/TenantUserQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/TenantUserQuery.java @@ -114,6 +114,16 @@ public class TenantUserQuery extends QueryBase { return this; } + public TenantUserQuery enableTracking() { + this.noTracking = false; + return this; + } + + public TenantUserQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Class entityClass() { return TenantUserEntity.class; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/UserContactInfoQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/UserContactInfoQuery.java index f49e1a630..725a0d7ac 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/UserContactInfoQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/UserContactInfoQuery.java @@ -154,6 +154,16 @@ public class UserContactInfoQuery extends QueryBase { return this; } + public UserContactInfoQuery enableTracking() { + this.noTracking = false; + return this; + } + + public UserContactInfoQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Boolean isFalseQuery() { return this.isEmpty(this.userIds) || this.isEmpty(this.excludedUserIds) || this.isEmpty(this.isActives) diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/UserCredentialQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/UserCredentialQuery.java index 2ac910df3..2ab55d414 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/UserCredentialQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/UserCredentialQuery.java @@ -125,6 +125,16 @@ public class UserCredentialQuery extends QueryBase { return this; } + public UserCredentialQuery enableTracking() { + this.noTracking = false; + return this; + } + + public UserCredentialQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Boolean isFalseQuery() { return diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/UserNotificationPreferenceQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/UserNotificationPreferenceQuery.java index 89b29cca5..7b27218d8 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/UserNotificationPreferenceQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/UserNotificationPreferenceQuery.java @@ -127,6 +127,16 @@ public class UserNotificationPreferenceQuery extends QueryBase { return this; } + + public UserQuery enableTracking() { + this.noTracking = false; + return this; + } + + public UserQuery disableTracking() { + this.noTracking = false; + return this; + } @Override protected Class entityClass() { return UserEntity.class; diff --git a/notification-service/notification/src/main/java/gr/cite/notification/query/UserRoleQuery.java b/notification-service/notification/src/main/java/gr/cite/notification/query/UserRoleQuery.java index 26acc4533..4e41d4744 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/query/UserRoleQuery.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/query/UserRoleQuery.java @@ -125,6 +125,16 @@ public class UserRoleQuery extends QueryBase { return this; } + public UserRoleQuery enableTracking() { + this.noTracking = false; + return this; + } + + public UserRoleQuery disableTracking() { + this.noTracking = false; + return this; + } + @Override protected Boolean isFalseQuery() { return diff --git a/notification-service/notification/src/main/java/gr/cite/notification/service/contact/extractor/EmailContactExtractor.java b/notification-service/notification/src/main/java/gr/cite/notification/service/contact/extractor/EmailContactExtractor.java index 432cdc2a8..5ef5a6d65 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/service/contact/extractor/EmailContactExtractor.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/service/contact/extractor/EmailContactExtractor.java @@ -65,7 +65,7 @@ public class EmailContactExtractor implements ContactExtractor { } else if (notification.getUserId() != null) { logger.trace("extracting from user"); - UserContactInfoEntity userContactInfo = this.queryFactory.query(UserContactInfoQuery.class) + UserContactInfoEntity userContactInfo = this.queryFactory.query(UserContactInfoQuery.class).disableTracking() .userIds(notification.getUserId()) .isActive(IsActive.Active) .type(ContactInfoType.Email).firstAs(new BaseFieldSet().ensure(UserContactInfo._value)); diff --git a/notification-service/notification/src/main/java/gr/cite/notification/service/inappnotification/InAppNotificationServiceImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/service/inappnotification/InAppNotificationServiceImpl.java index 6b33a2816..3d6bf17f6 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/service/inappnotification/InAppNotificationServiceImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/service/inappnotification/InAppNotificationServiceImpl.java @@ -57,7 +57,7 @@ public class InAppNotificationServiceImpl implements InAppNotificationService { try { logger.debug(new DataLogEntry("marking as read in-app notifications", ids)); UUID userId = this.userScope.getUserId(); - List items = this.queryFactory.query(InAppNotificationQuery.class) + List items = this.queryFactory.query(InAppNotificationQuery.class).disableTracking() .ids(ids) .userId(userId) .collect(); diff --git a/notification-service/notification/src/main/java/gr/cite/notification/service/message/infobuilder/MessageBuilderServiceImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/service/message/infobuilder/MessageBuilderServiceImpl.java index 0e65fbb71..06d4bda4e 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/service/message/infobuilder/MessageBuilderServiceImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/service/message/infobuilder/MessageBuilderServiceImpl.java @@ -83,7 +83,7 @@ public class MessageBuilderServiceImpl implements MessageInfoBuilderService { UserEntity userProfile = null; if (notification.getUserId() != null) { - userProfile = this.queryFactory.query(UserQuery.class) + userProfile = this.queryFactory.query(UserQuery.class).disableTracking() .ids(notification.getUserId()) .isActive(IsActive.Active).first(); } @@ -109,7 +109,7 @@ public class MessageBuilderServiceImpl implements MessageInfoBuilderService { if (this.scope.isMultitenant()) { if (!this.scope.isDefaultTenant()) { - TenantEntity tenantInfo = this.queryFactory.query(TenantQuery.class) + TenantEntity tenantInfo = this.queryFactory.query(TenantQuery.class).disableTracking() .isActive(IsActive.Active).firstAs(new BaseFieldSet(TenantEntity._id, TenantEntity._code)); if (tenantInfo == null) { diff --git a/notification-service/notification/src/main/java/gr/cite/notification/service/notification/NotificationServiceImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/service/notification/NotificationServiceImpl.java index 05677604c..0dd30f452 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/service/notification/NotificationServiceImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/service/notification/NotificationServiceImpl.java @@ -159,7 +159,7 @@ public class NotificationServiceImpl implements NotificationService { if (notification.getUserId() == null) return null; Ordering ordering = new Ordering(); ordering.addAscending(UserNotificationPreference._ordinal); - UserNotificationPreferenceQuery query = this.queryFactory.query(UserNotificationPreferenceQuery.class).userId(notification.getUserId()).type(notification.getType()).isActives(IsActive.Active); + UserNotificationPreferenceQuery query = this.queryFactory.query(UserNotificationPreferenceQuery.class).disableTracking().userId(notification.getUserId()).type(notification.getType()).isActives(IsActive.Active); query.setOrder(ordering); List preferences = query.collectAs(new BaseFieldSet().ensure(UserNotificationPreference._channel).ensure(UserNotificationPreference._tenantId).ensure(UserNotificationPreference._id)); diff --git a/notification-service/notification/src/main/java/gr/cite/notification/service/notificationtemplate/NotificationServiceTemplateImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/service/notificationtemplate/NotificationServiceTemplateImpl.java index a65ec8cd7..ee2f2021e 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/service/notificationtemplate/NotificationServiceTemplateImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/service/notificationtemplate/NotificationServiceTemplateImpl.java @@ -184,7 +184,7 @@ public class NotificationServiceTemplateImpl implements NotificationTemplateServ @Override public NotificationTemplate lookupOverriddenTemplates(UUID notificationType, NotificationTemplateChannel channel, String language) { - NotificationTemplateQuery query = this.queryFactory.query(NotificationTemplateQuery.class) + NotificationTemplateQuery query = this.queryFactory.query(NotificationTemplateQuery.class).disableTracking() .notificationTypes(notificationType) .channels(channel) .languageCodes(language) diff --git a/notification-service/notification/src/main/java/gr/cite/notification/service/tenantconfiguration/TenantConfigurationServiceImpl.java b/notification-service/notification/src/main/java/gr/cite/notification/service/tenantconfiguration/TenantConfigurationServiceImpl.java index 85c401050..6916cc8fc 100644 --- a/notification-service/notification/src/main/java/gr/cite/notification/service/tenantconfiguration/TenantConfigurationServiceImpl.java +++ b/notification-service/notification/src/main/java/gr/cite/notification/service/tenantconfiguration/TenantConfigurationServiceImpl.java @@ -207,7 +207,7 @@ public class TenantConfigurationServiceImpl implements TenantConfigurationServic @Override public TenantConfigurationEntity getTenantConfigurationEntityForType(TenantConfigurationType type){ - TenantConfigurationQuery query = this.queryFactory.query(TenantConfigurationQuery.class).authorize(AuthorizationFlags.OwnerOrPermission).isActive(IsActive.Active).types(type); + TenantConfigurationQuery query = this.queryFactory.query(TenantConfigurationQuery.class).disableTracking().authorize(AuthorizationFlags.OwnerOrPermission).isActive(IsActive.Active).types(type); if (this.tenantScope.isDefaultTenant()) query.tenantIsSet(false); else { try {