micord/ervu-business-metrics
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-9122:fixes

Browse source
This commit is contained in:
adel.ka 2025-04-22 15:43:20 +03:00
parent 42ebfa309a
commit 95de57b5de
3 changed files with 25 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

9
backend/src/main/java/ervu_business_metrics/service/processor/impl/AccountDataProcessor.java
View file

@ -65,8 +65,13 @@ public class AccountDataProcessor implements DataProcessor<AccountData> {
} }
} }
idmDirectoriesDaoService.insertAccountRecords(newAccountRecords); if (!newAccountRecords.isEmpty()) {
idmDirectoriesDaoService.updateAccountRecords(accountRecordsToUpdate); idmDirectoriesDaoService.insertAccountRecords(newAccountRecords);
}
if (!accountRecordsToUpdate.isEmpty()) {
idmDirectoriesDaoService.updateAccountRecords(accountRecordsToUpdate);
}
if (!accountsToDeleteRoles.isEmpty()) { if (!accountsToDeleteRoles.isEmpty()) {
idmDirectoriesDaoService.deleteAccountRolesByAccountIds(accountsToDeleteRoles); idmDirectoriesDaoService.deleteAccountRolesByAccountIds(accountsToDeleteRoles);

17
backend/src/main/java/ervu_business_metrics/service/processor/impl/DomainDataProcessor.java
View file

@ -28,8 +28,8 @@ public class DomainDataProcessor implements DataProcessor<DomainData> {
@Override @Override
public void upsertData(List<DomainData> dataList) { public void upsertData(List<DomainData> dataList) {
List<DomainRecord> newRecruitmentRecords = new ArrayList<>(); List<DomainRecord> newDomainRecords = new ArrayList<>();
List<DomainRecord> recruitmentRecords = new ArrayList<>(); List<DomainRecord> domainRecords = new ArrayList<>();
Set<String> existingIds = idmDirectoriesDaoService.getDomainIds(); Set<String> existingIds = idmDirectoriesDaoService.getDomainIds();
for (DomainData data : dataList) { for (DomainData data : dataList) {
@ -88,15 +88,20 @@ public class DomainDataProcessor implements DataProcessor<DomainData> {
domainRecord.setManaged(data.getManaged()); domainRecord.setManaged(data.getManaged());
if (existingIds.contains(data.getId())) { if (existingIds.contains(data.getId())) {
recruitmentRecords.add(domainRecord); domainRecords.add(domainRecord);
} }
else { else {
newRecruitmentRecords.add(domainRecord); newDomainRecords.add(domainRecord);
} }
} }
idmDirectoriesDaoService.insertDomainRecords(newRecruitmentRecords); if (!newDomainRecords.isEmpty()) {
idmDirectoriesDaoService.updateDomainRecords(recruitmentRecords); idmDirectoriesDaoService.insertDomainRecords(newDomainRecords);
}
if (!domainRecords.isEmpty()) {
idmDirectoriesDaoService.updateDomainRecords(domainRecords);
}
} }
@Override @Override

9
backend/src/main/java/ervu_business_metrics/service/processor/impl/RoleDataProcessor.java
View file

@ -59,8 +59,13 @@ public class RoleDataProcessor implements DataProcessor<RoleData> {
} }
} }
idmDirectoriesDaoService.insertRoleRecords(newRoleRecords); if (!newRoleRecords.isEmpty()) {
idmDirectoriesDaoService.updateRoleRecords(roleRecords); idmDirectoriesDaoService.insertRoleRecords(newRoleRecords);
}
if (!roleRecords.isEmpty()) {
idmDirectoriesDaoService.updateRoleRecords(roleRecords);
}
} }
@Override @Override