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

Campaigns via REST, pt. 1

Browse Source
This commit is contained in:
Tilman
2017-10-20 20:32:46 +02:00
parent 2a95f0b2b5
commit e44954bc82
5 changed files with 127 additions and 82 deletions
Download Patch File Download Diff File Expand all files Collapse all files
AH MAM Migration/src/com/bayer/edam/migration/MamMigrationSelective.java
+30 -16
View File
@@ -31,18 +31,16 @@ import org.springframework.web.client.HttpStatusCodeException;
import org.springframework.web.client.RestTemplate;
import com.bayer.edam.migration.adam.Campaign;
import com.bayer.edam.migration.adam.Classification;
import com.bayer.edam.migration.adam.ClassificationList;
import com.bayer.edam.migration.adam.EntityId;
import com.bayer.edam.migration.adam.Token;
import com.bayer.edam.migration.adam.WriteRecord;
import com.bayer.edam.migration.adam.WriteRecord.Classification;
import com.bayer.edam.migration.adam.WriteRecord.WriteClassification;
import com.bayer.edam.migration.mam.Entry;
import com.bayer.edam.migration.mam.categories.CategoryTree;
import com.bayer.edam.migration.mam.categories.CategoryTree.Node;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.univocity.parsers.csv.CsvParser;
import com.univocity.parsers.csv.CsvParserSettings;
import com.univocity.parsers.csv.CsvWriter;
import com.univocity.parsers.csv.CsvWriterSettings;
@SpringBootApplication
@PropertySource("file:secret.properties")
@@ -85,16 +83,13 @@ public class MamMigrationSelective implements CommandLineRunner {
@Override
public void run(String... strings) throws Exception {
log.info("Write log headers");
FileUtils.writeStringToFile(entryLog, "Location" + fieldSeparator + "Entry" + lineSeparator, Charset.forName("utf-8"));
FileUtils.writeStringToFile(problemLog, "entryId" + fieldSeparator + "Entry" + lineSeparator, Charset.forName("utf-8"));
// log.info("Write log headers");
// FileUtils.writeStringToFile(entryLog, "Location" + fieldSeparator + "Entry" + lineSeparator, Charset.forName("utf-8"));
// FileUtils.writeStringToFile(problemLog, "entryId" + fieldSeparator + "Entry" + lineSeparator, Charset.forName("utf-8"));
//
// log.info("Read categories");
// mamCategoryTree = new CategoryTree(categoryJson, categoryMapping);
log.info("Read categories");
mamCategoryTree = new CategoryTree(categoryJson, categoryMapping);
log.info("Read campaigns");
// TODO HIER GEHT'S WEITER - die vorhandenen Campaigns per REST aufrufen und in campaigns speichern
restTemplate = new RestTemplate(new BufferingClientHttpRequestFactory(new SimpleClientHttpRequestFactory()));
List<ClientHttpRequestInterceptor> interceptors = new ArrayList<ClientHttpRequestInterceptor>();
interceptors.add(new LoggingRequestInterceptor());
@@ -102,8 +97,27 @@ public class MamMigrationSelective implements CommandLineRunner {
adamHeaders = createAdamHeaders();
adamHeadersEntity = new HttpEntity<String>("", adamHeaders);
mamHeaders = createMamHeaders();
// mamHeaders = createMamHeaders();
log.info("Read campaigns");
HttpEntity<String> httpEntity = new HttpEntity<String>("parameters", adamHeaders);
ClassificationList campaignYears = restTemplate.exchange(adamHost + "/classification/" + Definitions.campaignRoot + "/children", HttpMethod.GET, httpEntity, ClassificationList.class).getBody();
for (Classification c : campaignYears.items) {
log.info(c.name + ", " + c.labels[0].value + ", " + c.id);
}
invalidateAdamToken();
System.exit(1);
// TODO HIER GEHT'S WEITER - die vorhandenen Campaigns per REST aufrufen und in campaigns speichern
HttpEntity<String> entity = new HttpEntity<String>("", mamHeaders);
for (int id : selection) {
log.info("GET entry " + id);
@@ -215,7 +229,7 @@ public class MamMigrationSelective implements CommandLineRunner {
campaignGuid = campaignId.id;
log.info("Created campaign: " + campaignName + ";" + campaignLabel + ";" + campaignGuid);
record.addClassification(new Classification(campaignGuid, 1));
record.addClassification(new WriteClassification(campaignGuid, 1));
// TODO better write campaign to file right away?
campaigns.add(new String[] { campaignName, campaignLabel, campaignGuid });