RED-7094 - extracted liquibase code
This commit is contained in:
parent
e954807788
commit
ef9ff74339
@ -19,7 +19,7 @@
|
||||
<swagger-commons.version>0.5.0</swagger-commons.version>
|
||||
<keycloak-commons.version>0.18.0</keycloak-commons.version>
|
||||
<jobs-commons.version>0.6.0</jobs-commons.version>
|
||||
<database-tenant-commons.version>0.3.0</database-tenant-commons.version>
|
||||
<database-tenant-commons.version>0.4.0</database-tenant-commons.version>
|
||||
</properties>
|
||||
<dependencies>
|
||||
|
||||
|
||||
@ -1,5 +1,7 @@
|
||||
package com.iqser.red.service.persistence.management.v1.processor.service.job;
|
||||
|
||||
import static com.iqser.red.service.persistence.management.v1.processor.utils.TenantUtils.isTenantReadyForPersistence;
|
||||
|
||||
import org.quartz.Job;
|
||||
import org.quartz.JobExecutionContext;
|
||||
import org.quartz.JobExecutionException;
|
||||
@ -27,11 +29,13 @@ public class SyncUserPermissionsJob implements Job {
|
||||
|
||||
var singleTenant = context.getJobDetail().getJobDataMap() != null ? context.getJobDetail().getJobDataMap().get("tenantId") : null;
|
||||
tenantProvider.getTenants().forEach(tenant -> {
|
||||
// if it's for a single tenant run only for that one, else run it for all tenants
|
||||
if (tenant.getTenantId().equals(singleTenant) || singleTenant == null) {
|
||||
TenantContext.setTenantId(tenant.getTenantId());
|
||||
customPermissionService.syncAllCustomPermissions();
|
||||
TenantContext.clear();
|
||||
if(isTenantReadyForPersistence(tenant)) {
|
||||
// if it's for a single tenant run only for that one, else run it for all tenants
|
||||
if (tenant.getTenantId().equals(singleTenant) || singleTenant == null) {
|
||||
TenantContext.setTenantId(tenant.getTenantId());
|
||||
customPermissionService.syncAllCustomPermissions();
|
||||
TenantContext.clear();
|
||||
}
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user