Revision 60213
Added by Michele Artini over 3 years ago
PimpaUpdateJobNode.java | ||
---|---|---|
36 | 36 |
log.info("Reimport records from PIMPA - START"); |
37 | 37 |
|
38 | 38 |
final Map<String, Boolean> oldPids = dao.getPersonIds().stream().collect(Collectors.toMap(s -> s, s -> true)); |
39 |
|
|
39 | 40 |
final Map<String, Boolean> oldGids = dao.getGroupIds().stream().collect(Collectors.toMap(s -> s, s -> true)); |
40 | 41 |
|
41 | 42 |
final Set<String> oldAffiliations = dao.listAffiliations().stream() |
... | ... | |
60 | 61 |
} |
61 | 62 |
p.getLabs().getList().forEach(lab -> { |
62 | 63 |
if (StringUtils.isNotBlank(lab.getCode())) { |
63 |
if (!oldGids.containsKey(lab.getCode())) { |
|
64 |
dao.registerGroup(lab.getCode(), lab.getDescription(), lab.getType()); |
|
65 |
oldGids.put(lab.getCode(), false); |
|
66 |
} else if (overrideGroups && oldGids.get(lab.getCode())) { |
|
64 |
if (overrideGroups && oldGids.get(lab.getCode())) { |
|
67 | 65 |
log.info("Overriding group " + lab.getCode()); |
68 | 66 |
dao.updateGroup(lab.getCode(), lab.getDescription(), lab.getType()); |
69 | 67 |
oldGids.put(lab.getCode(), false); |
Also available in: Unified diff
pimpa