| | |
| | | |
| | | @Test |
| | | @Order(1) |
| | | void importsBusinessPartners() { |
| | | void importBusinessPartners() { |
| | | |
| | | try (Reader reader = resourceReader("migration/business-partners.csv")) { |
| | | final var records = readAllLines(reader); |
| | | importsBusinessPartners(records); |
| | | importBusinessPartners(records); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | |
| | | |
| | | @Test |
| | | @Order(2) |
| | | void importsContacts() { |
| | | void importContacts() { |
| | | |
| | | try (Reader reader = resourceReader("migration/contacts.csv")) { |
| | | final var records = readAllLines(reader); |
| | | importsContacts(records); |
| | | importContacts(records); |
| | | } catch (Exception e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | |
| | | contacts.forEach((id, contact) -> em.persist(contact)); |
| | | persons.forEach((id, person) -> em.persist(person)); |
| | | partners.forEach((id, partner) -> em.persist(partner)); |
| | | }); |
| | | debitors.forEach((id, debitor) -> em.persist(debitor)); |
| | | memberships.forEach((id, membership) -> em.persist(membership)); |
| | | }).assertSuccessful(); |
| | | } |
| | | |
| | | public List<String[]> readAllLines(Reader reader) throws Exception { |
| | |
| | | } |
| | | } |
| | | |
| | | private void importsBusinessPartners(final List<String[]> records) { |
| | | private void importBusinessPartners(final List<String[]> records) { |
| | | records.stream() |
| | | .map(this::trimAll) |
| | | .forEach(record -> { |
| | |
| | | .vatBusiness("GROSS".equals(record[10])) |
| | | .vatId(record[11]) |
| | | .build(); |
| | | debitors.put(toInt(record[0]), debitor); |
| | | |
| | | partners.put(toInt(record[0]), partner); |
| | | |
| | |
| | | }); |
| | | } |
| | | |
| | | private void importsContacts(final List<String[]> records) { |
| | | private void importContacts(final List<String[]> records) { |
| | | records.stream() |
| | | .map(this::trimAll) |
| | | .forEach(record -> { |
| | |
| | | person.setGivenName(record[4]); |
| | | |
| | | initContact(partner.getContact(), record); |
| | | |
| | | } else { |
| | | initContact(new HsOfficeContactEntity(), record); |
| | | // TODO: create relationship |