tilman/mam-migration
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Removed duplicate campaigns

Browse Source
This commit is contained in:
GEXCE
2017-11-08 23:02:03 +01:00
parent a129c124b7
commit 3493ec597a
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
AH MAM Migration/src/com/bayer/edam/migration/MamMigrationSelective.java
+9 -3
View File
@@ -179,6 +179,7 @@ public class MamMigrationSelective implements CommandLineRunner {
UploadRecord record = new UploadRecord(); UploadRecord record = new UploadRecord();
String entryJson = jsonMapper.writeValueAsString(entry); String entryJson = jsonMapper.writeValueAsString(entry);
List<String> keywords = new ArrayList<String>(); List<String> keywords = new ArrayList<String>();
HashSet<String> campaignGuids = new HashSet<String>();
// globally applicable classifications // globally applicable classifications
record.addClassification("Migration"); record.addClassification("Migration");
@@ -318,9 +319,11 @@ public class MamMigrationSelective implements CommandLineRunner {
String campaignGuid = null; String campaignGuid = null;
for (Campaign c : campaigns) { for (Campaign c : campaigns) {
if (c.name.equals(campaignName)) { if (c.name.equals(campaignName)) {
log.debug("Add existing campaign " + campaignName);
campaignGuid = c.guid; campaignGuid = c.guid;
record.addClassification(new WriteClassification(campaignGuid, 1)); if (campaignGuids.add(campaignGuid)) {
log.debug("Add existing campaign " + campaignName);
record.addClassification(new WriteClassification(campaignGuid, 1));
}
} }
} }
@@ -333,8 +336,11 @@ public class MamMigrationSelective implements CommandLineRunner {
try { try {
EntityId campaignId = restTemplate.exchange(Definitions.adamHost + "/classifications", HttpMethod.POST, httpEntity, EntityId.class).getBody(); EntityId campaignId = restTemplate.exchange(Definitions.adamHost + "/classifications", HttpMethod.POST, httpEntity, EntityId.class).getBody();
campaign.guid = campaignId.id; campaign.guid = campaignId.id;
record.addClassification(new WriteClassification(campaign.guid, 1));
campaigns.add(campaign); campaigns.add(campaign);
if (campaignGuids.add(campaign.guid)) {
log.debug("Add new campaign " + campaign.name);
record.addClassification(new WriteClassification(campaign.guid, 1));
}
} }
catch (HttpStatusCodeException hsce) { catch (HttpStatusCodeException hsce) {
log.error("Could not create campaign '" + campaignName + "' for entry " + entry.id + ": " + hsce.getStatusCode().toString()); log.error("Could not create campaign '" + campaignName + "' for entry " + entry.id + ": " + hsce.getStatusCode().toString());