treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added deleting package from nbki service

Browse source
This commit is contained in:
Mikhail Trofimov 2025-06-18 18:57:22 +03:00
parent a78e49f1e0
commit 57bfe02fe9
2 changed files with 40 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java
View file

@ -285,10 +285,12 @@ public class SignalFacade {
public ResponseEntity<MonitoringPackageDeleteResponse> deletePackage(String username, String packageName) {
try {
if(!signalService.isPackageExists(username, packageName)) {
throw new SignalErrorException(SignalError.ERROR_016, packageName, new MonitoringPackageDeleteError(), true);
}
// if(!signalService.isPackageExists(username, packageName)) {
// throw new SignalErrorException(SignalError.ERROR_016, packageName, new MonitoringPackageDeleteError(), true);
// }
MonitoringPackageDeleteResponse response = signalService.deletePackage(username, packageName);
signalRestService.deletePackage(username, packageName);
return ResponseEntity.ok(response);
} catch (Exception e) {
if (e instanceof SignalErrorException) {

39
src/main/java/ru/nbch/credit_tracker/service/signal/SignalRestService.java
View file

@ -5,10 +5,7 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.core.io.ByteArrayResource;
import org.springframework.core.io.Resource;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.http.*;
import org.springframework.stereotype.Service;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
@ -23,6 +20,8 @@ import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.util.Base64;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.zip.GZIPOutputStream;
@Slf4j
@ -30,6 +29,7 @@ import java.util.zip.GZIPOutputStream;
public class SignalRestService {
private static String UPDATE_URI = "update";
private static String DELETE_URI = "delete";
private final RestTemplate restTemplate;
private final XmlUtilService xmlUtilService;
@ -85,6 +85,37 @@ public class SignalRestService {
};
}
public void deletePackage(String username, String packageName) {
String packCode = username.substring(0, 6) + "_" + packageName;
String url = DELETE_URI + "?packCode=" + packCode;
HttpHeaders headers = new HttpHeaders();
headers.setBasicAuth(authToken);
HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(headers);
ResponseEntity<String> response = restTemplate.exchange(
url,
HttpMethod.GET,
requestEntity,
String.class
);
String answer = response.getBody();
if (response.getStatusCode().value() == 200 && answer != null && answer.contains("<Error>")) {
if (answer.contains("<description>")) {
Pattern pattern = Pattern.compile("<description>(.*?)</description>");
Matcher matcher = pattern.matcher(answer);
if (matcher.find()) {
String description = matcher.group(1);
log.error("Ошибка при удалении пакета из сервиса НБКИ. packCode={}. Описание: {}", packCode, description);
}
} else {
log.error("Ошибка при удалении пакета из сервиса НБКИ. packCode={}", packCode);
}
} else if (response.getStatusCode().value() != 200) {
log.error("Ошибка при удалении пакета из сервиса НБКИ. Код ошибки: {} packCode={}", response.getStatusCode().value(), packCode);
}
}
private String buildToken(String signalsToken, String signalsuser) throws Exception {
try {
MessageDigest md = MessageDigest.getInstance("MD5");