|
1 | 1 | package no.nav.foreldrepenger.abakus.registerdata.tjeneste;
|
2 | 2 |
|
3 | 3 | import java.net.HttpURLConnection;
|
4 |
| -import java.util.Optional; |
5 | 4 | import java.util.Set;
|
6 | 5 | import java.util.UUID;
|
7 | 6 |
|
|
22 | 21 | import jakarta.transaction.Transactional;
|
23 | 22 | import jakarta.validation.Valid;
|
24 | 23 | import jakarta.validation.constraints.NotNull;
|
25 |
| -import jakarta.validation.constraints.Pattern; |
26 | 24 | import jakarta.ws.rs.Consumes;
|
27 | 25 | import jakarta.ws.rs.POST;
|
28 | 26 | import jakarta.ws.rs.Path;
|
|
32 | 30 | import no.nav.abakus.iaygrunnlag.FnrPersonident;
|
33 | 31 | import no.nav.abakus.iaygrunnlag.Periode;
|
34 | 32 | import no.nav.abakus.iaygrunnlag.PersonIdent;
|
35 |
| -import no.nav.abakus.iaygrunnlag.UuidDto; |
36 | 33 | import no.nav.abakus.iaygrunnlag.kodeverk.YtelseType;
|
37 | 34 | import no.nav.abakus.iaygrunnlag.request.InnhentRegisterdataRequest;
|
38 | 35 | import no.nav.abakus.iaygrunnlag.request.RegisterdataType;
|
39 |
| -import no.nav.abakus.iaygrunnlag.request.SjekkStatusRequest; |
40 |
| -import no.nav.foreldrepenger.abakus.domene.iay.GrunnlagReferanse; |
41 | 36 | import no.nav.foreldrepenger.abakus.felles.LoggUtil;
|
42 |
| -import no.nav.foreldrepenger.abakus.kobling.KoblingReferanse; |
43 | 37 | import no.nav.foreldrepenger.abakus.kobling.KoblingTjeneste;
|
44 | 38 | import no.nav.foreldrepenger.abakus.registerdata.tjeneste.dto.TaskResponsDto;
|
45 | 39 | import no.nav.vedtak.sikkerhet.abac.AbacDataAttributter;
|
@@ -89,37 +83,6 @@ public Response innhentOgLagreRegisterdataAsync(@Parameter(name = "innhent") @Va
|
89 | 83 | return response;
|
90 | 84 | }
|
91 | 85 |
|
92 |
| - @POST |
93 |
| - @Path("/innhent/status") |
94 |
| - @Consumes(MediaType.APPLICATION_JSON) |
95 |
| - @Operation(description = "Sjekker innhentingFerdig på async innhenting og gir siste referanseid på grunnlaget når tasken er ferdig. " |
96 |
| - + "Hvis ikke innhentingFerdig", tags = "registerinnhenting") |
97 |
| - @BeskyttetRessurs(actionType = ActionType.READ, resourceType = ResourceType.APPLIKASJON) |
98 |
| - @SuppressWarnings({"findsecbugs:JAXRS_ENDPOINT", "resource"}) |
99 |
| - public Response innhentAsyncStatus(@Parameter(name = "status") @Valid SjekkStatusAbacDto dto) { |
100 |
| - Response response; |
101 |
| - KoblingReferanse koblingRef = new KoblingReferanse(dto.getReferanse().getReferanse()); |
102 |
| - setupLogMdcFraKoblingReferanse(koblingRef); |
103 |
| - if (innhentTjeneste.innhentingFerdig(dto.getTaskReferanse())) { |
104 |
| - Optional<GrunnlagReferanse> grunnlagReferanse = innhentTjeneste.hentSisteReferanseFor(koblingRef); |
105 |
| - if (grunnlagReferanse.isPresent()) { |
106 |
| - response = Response.ok(new UuidDto(grunnlagReferanse.get().toString())).build(); |
107 |
| - } else { |
108 |
| - response = Response.noContent().build(); |
109 |
| - } |
110 |
| - } else { |
111 |
| - response = Response.status(425).build(); |
112 |
| - } |
113 |
| - return response; |
114 |
| - } |
115 |
| - |
116 |
| - private void setupLogMdcFraKoblingReferanse(KoblingReferanse koblingReferanse) { |
117 |
| - var kobling = koblingTjeneste.hentFor(koblingReferanse); |
118 |
| - kobling.filter(k -> k.getSaksnummer() != null) |
119 |
| - .ifPresent(k -> LoggUtil.setupLogMdc(k.getYtelseType(), kobling.get().getSaksnummer().getVerdi(), |
120 |
| - koblingReferanse.getReferanse())); // legger til saksnummer i MDC |
121 |
| - } |
122 |
| - |
123 | 86 | /**
|
124 | 87 | * Json bean med Abac.
|
125 | 88 | */
|
@@ -159,24 +122,4 @@ private void leggTil(AbacDataAttributter abac, PersonIdent person) {
|
159 | 122 | }
|
160 | 123 |
|
161 | 124 | }
|
162 |
| - |
163 |
| - /** |
164 |
| - * Json bean med Abac. |
165 |
| - */ |
166 |
| - @JsonIgnoreProperties(ignoreUnknown = true) |
167 |
| - @JsonInclude(value = Include.NON_ABSENT, content = Include.NON_EMPTY) |
168 |
| - @JsonAutoDetect(fieldVisibility = Visibility.NONE, getterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, creatorVisibility = Visibility.NONE) |
169 |
| - public static class SjekkStatusAbacDto extends SjekkStatusRequest implements AbacDto { |
170 |
| - |
171 |
| - @JsonCreator |
172 |
| - public SjekkStatusAbacDto(@JsonProperty(value = "referanse", required = true) @Valid @NotNull UuidDto referanse, |
173 |
| - @JsonProperty(value = "taskReferanse", required = true) @NotNull @Pattern(regexp = "\\d+") String taskReferanse) { |
174 |
| - super(referanse, taskReferanse); |
175 |
| - } |
176 |
| - |
177 |
| - @Override |
178 |
| - public AbacDataAttributter abacAttributter() { |
179 |
| - return AbacDataAttributter.opprett(); |
180 |
| - } |
181 |
| - } |
182 | 125 | }
|
0 commit comments