From 7d87a30d93e56aa1cb74cd89b831bf0dc1f10000 Mon Sep 17 00:00:00 2001 From: Michael Hoennig Date: Tue, 16 Jul 2024 19:53:42 +0200 Subject: [PATCH] import booking items + its resources --- .../office/migration/ImportHostingAssets.java | 136 ++++++++++++++++-- 1 file changed, 127 insertions(+), 9 deletions(-) diff --git a/src/test/java/net/hostsharing/hsadminng/hs/office/migration/ImportHostingAssets.java b/src/test/java/net/hostsharing/hsadminng/hs/office/migration/ImportHostingAssets.java index 3175e3e6..9b45b3d7 100644 --- a/src/test/java/net/hostsharing/hsadminng/hs/office/migration/ImportHostingAssets.java +++ b/src/test/java/net/hostsharing/hsadminng/hs/office/migration/ImportHostingAssets.java @@ -2,6 +2,7 @@ package net.hostsharing.hsadminng.hs.office.migration; import net.hostsharing.hsadminng.context.Context; import net.hostsharing.hsadminng.hs.booking.item.HsBookingItemEntity; +import net.hostsharing.hsadminng.hs.booking.item.HsBookingItemType; import net.hostsharing.hsadminng.hs.hosting.asset.HsHostingAssetEntity; import net.hostsharing.hsadminng.hs.hosting.asset.HsHostingAssetType; import net.hostsharing.hsadminng.rbac.test.JpaAttempt; @@ -143,10 +144,10 @@ public class ImportHostingAssets extends CsvDataImport { @Test @Order(2000) - void importServersAndWebspaces() { + void importPackets() { try (Reader reader = resourceReader(MIGRATION_DATA_PATH + "packet.csv")) { final var lines = readAllLines(reader); - importServersAndWebspaces(justHeader(lines), withoutHeader(lines)); + importPackets(justHeader(lines), withoutHeader(lines)); } catch (Exception e) { throw new RuntimeException(e); } @@ -154,17 +155,45 @@ public class ImportHostingAssets extends CsvDataImport { @Test @Order(2009) - void verifyServersAndWebspaces() { + void verifyPackets() { assumeThatWeAreImportingControlledTestData(); // no contacts yet => mostly null values assertThat(toFormattedString(firstOfType(5, hostingAssets, CLOUD_SERVER, MANAGED_SERVER, MANAGED_WEBSPACE))).isEqualToIgnoringWhitespace(""" { - 2000012=HsHostingAssetEntity(MANAGED_WEBSPACE, al000), - 2000008=HsHostingAssetEntity(MANAGED_WEBSPACE, ahr01), - 2000009=HsHostingAssetEntity(MANAGED_WEBSPACE, aih00), - 2000007=HsHostingAssetEntity(MANAGED_WEBSPACE, ahr00), - 2000003=HsHostingAssetEntity(MANAGED_WEBSPACE, agu00) + 2000012=HsHostingAssetEntity(MANAGED_WEBSPACE, al000, D-???????-?:al000), + 2000008=HsHostingAssetEntity(MANAGED_WEBSPACE, ahr01, D-???????-?:ahr01), + 2000009=HsHostingAssetEntity(MANAGED_WEBSPACE, aih00, D-???????-?:aih00), + 2000007=HsHostingAssetEntity(MANAGED_WEBSPACE, ahr00, D-???????-?:ahr00), + 2000003=HsHostingAssetEntity(MANAGED_WEBSPACE, agu00, D-???????-?:agu00) + } + """); + } + + @Test + @Order(2010) + void importPacketComponents() { + try (Reader reader = resourceReader(MIGRATION_DATA_PATH + "packet_component.csv")) { + final var lines = readAllLines(reader); + importPacketComponents(justHeader(lines), withoutHeader(lines)); + } catch (Exception e) { + throw new RuntimeException(e); + } + } + + @Test + @Order(2019) + void verifyPacketComponents() { + assumeThatWeAreImportingControlledTestData(); + + // no contacts yet => mostly null values + assertThat(toFormattedString(firstOfType(5, hostingAssets, CLOUD_SERVER, MANAGED_SERVER, MANAGED_WEBSPACE))).isEqualToIgnoringWhitespace(""" + { + 2000012=HsHostingAssetEntity(MANAGED_WEBSPACE, al000, D-???????-?:al000), + 2000008=HsHostingAssetEntity(MANAGED_WEBSPACE, ahr01, D-???????-?:ahr01), + 2000009=HsHostingAssetEntity(MANAGED_WEBSPACE, aih00, D-???????-?:aih00), + 2000007=HsHostingAssetEntity(MANAGED_WEBSPACE, ahr00, D-???????-?:ahr00), + 2000003=HsHostingAssetEntity(MANAGED_WEBSPACE, agu00, D-???????-?:agu00) } """); } @@ -198,7 +227,7 @@ public class ImportHostingAssets extends CsvDataImport { }); } - private void importServersAndWebspaces(final String[] header, final List records) { + private void importPackets(final String[] header, final List records) { final var columns = new Columns(header); records.stream() .map(this::trimAll) @@ -216,6 +245,16 @@ public class ImportHostingAssets extends CsvDataImport { final var old_inet_addr_id = rec.getInteger("old_inet_addr_id"); final var free = rec.getBoolean("free"); + final var bookingItem = HsBookingItemEntity.builder() + .type(switch (rec.getString("basepacket_code")) { + case "SRV/CLD" -> HsBookingItemType.CLOUD_SERVER; + case "SRV/MGD" -> HsBookingItemType.MANAGED_SERVER; + case "PAC/WEB" -> HsBookingItemType.MANAGED_WEBSPACE; + default -> throw new IllegalArgumentException("unknown basepacket_code: " + rec.getString("basepacket_code")); + }) + .caption(packet_name) + .build(); + final var asset = HsHostingAssetEntity.builder() .type(switch (rec.getString("basepacket_code")) { case "SRV/CLD" -> CLOUD_SERVER; @@ -224,12 +263,91 @@ public class ImportHostingAssets extends CsvDataImport { default -> throw new IllegalArgumentException("unknown basepacket_code: " + rec.getString("basepacket_code")); }) .identifier(rec.getString("packet_name")) + .bookingItem(bookingItem) // .caption(rec.getString("description")) .build(); hostingAssets.put(PACKET_ID_OFFSET + packet_id, asset); }); } + private void importPacketComponents(final String[] header, final List records) { + final var columns = new Columns(header); + records.stream() + .map(this::trimAll) + .map(row -> new Record(columns, row)) + .forEach(rec -> { + final var packet_component_id = rec.getInteger("packet_component_id"); + final var packet_id = rec.getInteger("packet_id"); + final var quantity = rec.getInteger("quantity"); + final var basecomponent_code = rec.getString("basecomponent_code"); + final var created = rec.getLocalDate("created"); + final var cancelled = rec.getLocalDate("cancelled"); + + final var asset = hostingAssets.get(PACKET_ID_OFFSET + packet_id); + final var name = switch (basecomponent_code) { + case "DAEMON" -> "Daemons"; + case "MULTI" -> "Multi"; + case "CPU" -> "CPU"; + case "RAM" -> "RAM"; + case "QUOTA" -> "SSD"; + case "STORAGE" -> "HDD"; + case "TRAFFIC" -> "Traffic"; + case "OFFICE" -> "Online Office Server"; + case "SLABASIC" -> "SLA-Platform"; + + case "SLAINFR2H" -> "SLA-Infrastructure"; + case "SLAINFR4H" -> "SLA-Infrastructure"; + case "SLAINFR8H" -> "SLA-Infrastructure"; + + case "SLAEXT24H" -> "SLA-Platform"; + case "SLAPLAT2H" -> "SLA-Platform"; + case "SLAPLAT4H" -> "SLA-Platform"; + case "SLAPLAT8H" -> "SLA-Platform"; + case "SLAWEB2H" -> "SLA-Web"; + case "SLAWEB4H" -> "SLA-Web"; + case "SLAWEB8H" -> "SLA-Web"; + case "SLAMAIL2H" -> "SLA-EMail"; + case "SLAMAIL4H" -> "SLA-EMail"; + case "SLAMAIL8H" -> "SLA-EMail"; + case "SLAMARIA2H" -> "SLA-Maria"; + case "SLAMARIA4H" -> "SLA-Maria"; + case "SLAMARIA8H" -> "SLA-Maria"; + case "SLAPGSQL2H" -> "SLA-PgSQL"; + case "SLAPGSQL4H" -> "SLA-PgSQL"; + case "SLAPGSQL8H" -> "SLA-PgSQL"; + case "SLAOFFIC2H" -> "SLA-Office"; + case "SLAOFFIC4H" -> "SLA-Office"; + case "SLAOFFIC8H" -> "SLA-Office"; + case "BANDWIDTH" -> null; // TODO.spec: not implemented yet + default -> throw new IllegalArgumentException("unknown basecomponent_code: " + basecomponent_code); + }; + if ( name == null ) { + } else if ( name.equals("SLA-Infrastructure")) { + final var slaValue = switch (basecomponent_code) { + case "SLAINFR2H" -> "EXT2H"; + case "SLAINFR4H" -> "EXT4H"; + case "SLAINFR8H" -> "EXT4H"; + default -> throw new IllegalArgumentException("unknown basecomponent_code: " + basecomponent_code); + }; + asset.getBookingItem().getResources().put(name, slaValue); + } else if ( name.equals("SLA-Platform")) { + final var slaValue = switch (basecomponent_code) { + case "SLABASIC" -> "BASIC"; + case "SLAPLAT2H" -> "EXT2H"; + case "SLAPLAT4H" -> "EXT4H"; + case "SLAEXT24H" -> "EXT24H"; + case "SLAPLAT8H" -> "EXT8H"; + default -> throw new IllegalArgumentException("unknown basecomponent_code: " + basecomponent_code); + }; + asset.getBookingItem().getResources().put(name, slaValue); + } else if ( name.startsWith("SLA")) { + asset.getBookingItem().getResources().put(name, true); + } else { + asset.getBookingItem().getResources().put(name, quantity); + } + }); + } + private Map firstOfType( final int maxCount, final Map hostingAssets,