Merge branch 'DEVELOP' of...

Merge branch 'DEVELOP' of ssh://git.eclipse.org:29418/openk-usermodules/org.eclipse.openk-usermodules.gridFailureInformation.backend into TF_SONARWORK

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/AddressController.java

@@ -39,7 +39,7 @@ public class AddressController {
     private AddressService addressService;
 
     @GetMapping("/{uuid}")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen einer bestimmten Adresse")
     @ApiResponses(value = { @ApiResponse(code = 200, message = "Erfolgreich durchgeführt"),
             @ApiResponse(code = 404, message = "Adresse wurde nicht gefunden")})
@@ -52,7 +52,7 @@ public class AddressController {
     @ApiOperation(value = "Anzeige aller PLZs")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping("/postcodes")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     public List<String> findAllPostCodes() {
         return addressService.getPostcodes();
     }
@@ -61,7 +61,7 @@ public class AddressController {
     @ApiOperation(value = "Anzeige eines Orte nach Postleitzahl")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping("/communities/{postcode}")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     public List<String> findAllCommunitiesByPostcode(@PathVariable String postcode) {
         return addressService.getCommunities(postcode);
     }
@@ -70,7 +70,7 @@ public class AddressController {
     @ApiOperation(value = "Anzeige Ortsteile nach Postleitzahl und Ort")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping("/districts")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     public List<String> findDistricts(
             @RequestParam("postcode") String postcode,
             @RequestParam("community") String community
@@ -82,7 +82,7 @@ public class AddressController {
     @ApiOperation(value = "Anzeige Strassen nach Postleitzahl und Ort und Ortsteil (optional)")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping("/streets")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     public List<String> findStreets(
             @RequestParam("postcode") String postcode,
             @RequestParam("community") String community,
@@ -96,7 +96,7 @@ public class AddressController {
     @ApiOperation(value = "Anzeige Strassen nach Postleitzahl und Ort und Strasse")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping("/housenumbers")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     public List<HousenumberUuidDto> findHousenumbers(
             @RequestParam("postcode") String postcode,
             @RequestParam("community") String community,

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/BranchController.java

@@ -36,7 +36,7 @@ public class BranchController {
     @Autowired
     private BranchService branchService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Branches")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/EmailController.java

@@ -37,7 +37,7 @@ public class EmailController {
     @Autowired
     private EmailService emailService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Senden einer Testemail")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/ExpectedReasonController.java

@@ -36,7 +36,7 @@ public class ExpectedReasonController {
     @Autowired
     private ExpectedReasonService expectedReasonService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller erwarteten Gründe")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/FailureClassificationController.java

@@ -36,7 +36,7 @@ public class FailureClassificationController {
     @Autowired
     private FailureClassificationService failureClassificationService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Störungsmeldungsklassen")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/FailureInformationController.java

@@ -49,7 +49,7 @@ public class FailureInformationController {
     @Autowired
     private FailureInformationService failureInformationService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN","ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @GetMapping("/{uuid}")
     @ApiOperation(value = "Anzeigen einer Störungsinformation")
     @ApiResponses(value = { @ApiResponse(code = 200, message = "Erfolgreich durchgeführt"),
@@ -60,7 +60,7 @@ public class FailureInformationController {
     }
 
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN","ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Störungsinformationen")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/FailureTypeController.java

@@ -36,7 +36,7 @@ public class FailureTypeController {
     @Autowired
     private FailureTypeService failureTypeService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Störungsmeldungstypen")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/HistFailureInformationController.java

@@ -38,7 +38,7 @@ public class HistFailureInformationController {
 
 
     @GetMapping("/{uuid}/versions")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Versionen einer Störungsinformation")
     @ApiResponses(value = { @ApiResponse(code = 200, message = "Erfolgreich durchgeführt"),
             @ApiResponse(code = 404, message = "Störungsinformationen wurden nicht gefunden")})
@@ -48,7 +48,7 @@ public class HistFailureInformationController {
     }
 
     @GetMapping("/{uuid}/versions/{versionNumber}")
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen einer bestimmten Version einer Störungsinformation")
     @ApiResponses(value = { @ApiResponse(code = 200, message = "Erfolgreich durchgeführt"),
             @ApiResponse(code = 404, message = "Störungsinformation wurden nicht gefunden")})

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/LogoutController.java

@@ -37,7 +37,7 @@ public class LogoutController {
     @ApiOperation(value = "Logout vom Auth-und-Auth-Modul")
     @ApiResponses(value = {@ApiResponse(code = 204, message = "Erfolgreich durchgeführt")})
     @GetMapping
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     public ResponseEntity logout() {
         logoutService.logout();
         return ResponseEntity.ok().build();

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/RadiusController.java

@@ -36,7 +36,7 @@ public class RadiusController {
     @Autowired
     private RadiusService radiusService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Radien")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/StationController.java

@@ -36,7 +36,7 @@ public class StationController {
     @Autowired
     private StationService stationService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeige aller Stationen")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/StatusController.java

@@ -36,7 +36,7 @@ public class StatusController {
     @Autowired
     private StatusService statusService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen aller Status")
     @ApiResponses(value = {@ApiResponse(code = 200, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/controller/VersionController.java

@@ -34,7 +34,7 @@ public class VersionController {
     @Autowired
     private VersionService versionService;
 
-    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
+    @Secured({"ROLE_GRID-FAILURE-ADMIN", "ROLE_GRID-FAILURE-READER", "ROLE_GRID-FAILURE-CREATOR", "ROLE_GRID-FAILURE-QUALIFIER", "ROLE_GRID-FAILURE-PUBLISHER"})
     @ApiOperation(value = "Anzeigen der Backend und der DB-Version")
     @ApiResponses(value = {@ApiResponse(code = 204, message = "Erfolgreich durchgeführt")})
     @GetMapping

gfsBackendService/src/main/java/org/eclipse/openk/gridfailureinformation/service/JobManagerService.java

@@ -53,7 +53,7 @@ public class JobManagerService {
 
 
 
-    private void doImport(ImportDataDto importDataDto, ForeignFailureDataDto foreignFailureDataDto) {
+    private FailureInformationDto doImport(ImportDataDto importDataDto, ForeignFailureDataDto foreignFailureDataDto) {
         FailureInformationDto existingDto = failureInformationService.findByObjectReferenceExternalSystem(importDataDto.getAssembledRefId());
 
         FailureInformationDto failureInformationDto;
@@ -68,8 +68,9 @@ public class JobManagerService {
                 gfiProcessState = GfiProcessState.NEW;
             }
 
-            failureInformationService.insertFailureInfo(failureInformationDto, gfiProcessState);
+            FailureInformationDto retVal = failureInformationService.insertFailureInfo(failureInformationDto, gfiProcessState);
             log.info("External failure information [" + importDataDto.getMetaId() + "] from " + importDataDto.getSource() + " imported (inserted).");
+            return retVal;
         }
         else {
             FailureInformationDto updatedDto = setUpdateFromForeignDto(importDataDto, foreignFailureDataDto, existingDto);
@@ -81,8 +82,9 @@ public class JobManagerService {
                         statusService.getStatusFromId(GfiProcessState.UPDATED.getStatusValue()).getUuid()
                 );
             }
-            failureInformationService.updateFailureInfo(updatedDto);
+            FailureInformationDto retVal = failureInformationService.updateFailureInfo(updatedDto);
             log.info("External failure information [" + importDataDto.getMetaId() + "] from " + importDataDto.getSource() + " imported (updated).");
+            return retVal;
 
         }
     }

gfsBackendService/src/test/java/org/eclipse/openk/gridfailureinformation/service/JobManagerServiceTest.java

@@ -21,6 +21,7 @@ import org.eclipse.openk.gridfailureinformation.support.MockDataHelper;
 import org.eclipse.openk.gridfailureinformation.util.ImportDataValidator;
 import org.eclipse.openk.gridfailureinformation.viewmodel.*;
 import org.junit.jupiter.api.Test;
+import org.mockito.stubbing.Answer;
 import org.powermock.reflect.Whitebox;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
@@ -28,8 +29,11 @@ import org.springframework.boot.test.autoconfigure.orm.jpa.DataJpaTest;
 import org.springframework.boot.test.mock.mockito.MockBean;
 import org.springframework.test.context.ContextConfiguration;
 
+import java.math.BigDecimal;
 import java.util.ArrayList;
+import java.util.Calendar;
 import java.util.List;
+import java.util.UUID;
 
 import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.Mockito.*;
@@ -218,23 +222,23 @@ public class JobManagerServiceTest {
 
 
     @Test
-    public void shouldImportUpdateMessageLeavingStatus() {
-        ImportDataDto dto = MockDataHelper.mockImportDataDto();
-        dto.setMessageContent("{\n" +
+    public void shouldImportUpdateMessageLeavingStatus() throws Exception {
+        ImportDataDto importDataDto = MockDataHelper.mockImportDataDto();
+        importDataDto.setMessageContent("{\n" +
                 "    \"branch\": \"S\",\n" + // invalid branch
                 "    \"city\": \"Belfast\",\n" +
                 "    \"description\": \"Schlimmer Fehler im System\",\n" +
-                "    \"district\": \"\",\n" +
-                "    \"failureBegin\": \"2020-11-19T14:13:15.666Z\",\n" +
+                "    \"district\": \"InDaHood\",\n" +
+                "    \"failureBegin\": \"2019-11-19T14:13:15.666Z\",\n" +
                 "    \"housenumber\": \"10b\",\n" +
                 "    \"latitude\": 12.345,\n" +
-                "    \"longitude\": 0,\n" +
+                "    \"longitude\": 44,\n" +
                 "    \"planned\": false,\n" +
                 "    \"postcode\": \"3456\",\n" +
-                "    \"pressureLevel\": null,\n" +
+                "    \"pressureLevel\": \"ND\",\n" +
                 "    \"radiusInMeters\": 678,\n" +
-                "    \"stationDescription\": null,\n" +
-                "    \"stationId\": null,\n" +
+                "    \"stationDescription\": \"Haferbox\",\n" +
+                "    \"stationId\": \"34500\",\n" +
                 "    \"street\": \"Oxfordstreet\",\n" +
                 "    \"voltageLevel\": \"HS\"\n" +
                 "  }");
@@ -243,17 +247,52 @@ public class JobManagerServiceTest {
         branchStromDto.setName("S");
         when( branchService.findByName(eq("S"))).thenReturn(branchStromDto);
         when( statusService.getStatusFromId( anyLong()) ).thenReturn(MockDataHelper.mockStatusDto());
-
         when( radiusService.getRadii() ).thenReturn(getRadiusDtoList());
-        when( failureInformationService.findByObjectReferenceExternalSystem(anyString())).thenReturn(MockDataHelper.mockFailureInformationDto());
 
-        jobManagerService.validateAndImport(dto);
+        FailureInformationDto dtoFromDB = MockDataHelper.mockFailureInformationDto();
+        UUID condensedId = UUID.randomUUID();
+        dtoFromDB.setFailureInformationCondensedId(condensedId);
+        dtoFromDB.setCondensedCount(77L);
+        dtoFromDB.setCondensed(true);
+        dtoFromDB.setObjectReferenceExternalSystem("666777888");
 
-        verify(failureInformationService, times(0))
-                .insertFailureInfo(any( FailureInformationDto.class), eq(GfiProcessState.NEW));
+        when( failureInformationService.findByObjectReferenceExternalSystem(anyString())).thenReturn(dtoFromDB);
+        when(failureInformationService.updateFailureInfo(any(FailureInformationDto.class)))
+                .then((Answer<FailureInformationDto>) invocation -> {
+                    Object[] args = invocation.getArguments();
+                    return (FailureInformationDto) args[0];
+                });
+
+
+        ForeignFailureDataDto dtoFromBus = importDataValidator.readSafeForeignFailureInfo(importDataDto);
+        FailureInformationDto dtoResult = Whitebox.invokeMethod(jobManagerService, "doImport", importDataDto, dtoFromBus);
 
         verify(failureInformationService, times(1))
                 .updateFailureInfo(any( FailureInformationDto.class));
+
+        assertEquals(branchStromDto.getUuid(), dtoResult.getBranchId());
+        assertEquals("Belfast", dtoResult.getCity());
+        assertEquals("Schlimmer Fehler im System", dtoResult.getInternalRemark());
+        assertEquals("InDaHood", dtoResult.getDistrict());
+        Calendar cal = Calendar.getInstance();
+        cal.setTime(dtoResult.getFailureBegin());
+        assertEquals( 2019, cal.get(Calendar.YEAR));
+        assertEquals( "10b", dtoResult.getHousenumber());
+        assertTrue( BigDecimal.valueOf(12.345d).equals(dtoResult.getLatitude()) );
+        assertTrue( BigDecimal.valueOf(44).equals(dtoResult.getLongitude()) );
+        assertTrue( dtoFromDB.getStatusInternId().equals(dtoResult.getStatusInternId()));
+        assertEquals( "3456", dtoResult.getPostcode());
+        assertEquals( "ND", dtoResult.getPressureLevel());
+        assertEquals( "Haferbox", dtoResult.getStationDescription());
+        assertEquals( "34500", dtoResult.getStationId());
+        assertEquals( "Oxfordstreet", dtoResult.getStreet());
+        assertEquals( "HS", dtoResult.getVoltageLevel());
+        assertTrue( condensedId.equals(dtoResult.getFailureInformationCondensedId()));
+        assertEquals( 77L, dtoResult.getCondensedCount() );
+        assertTrue( dtoResult.getCondensed());
+        assertEquals( importDataDto.getAssembledRefId(), dtoResult.getObjectReferenceExternalSystem());
+        assertTrue( dtoFromDB.getStatusExternId().equals(dtoResult.getStatusExternId()));
+        assertTrue( dtoFromDB.getFailureClassificationId().equals(dtoResult.getFailureClassificationId()));
     }