micord/ervu-lkrp-av
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge remote-tracking branch 'origin/feature/SUPPORT-9156' into develop

Browse source
This commit is contained in:
adel.kalimullin 2025-05-15 12:30:30 +03:00
commit 4c3a992270
2 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/ru/micord/ervu/av/kafka/dto/FileStatus.java
View file

@ -17,6 +17,6 @@ public record FileStatus(String code, String status, String description) {
"Файл был принят в обработку" "Файл был принят в обработку"
); );
public static final FileStatus FILE_STATUS_11 = new FileStatus("11", "Невозможно проверить файл ЛК РП", public static final FileStatus FILE_STATUS_11 = new FileStatus("11", "Невозможно проверить файл ЛК РП",
"Невозможно проверить файл по причине недоступности или ошибки в работе антивируса" "Невозможно проверить файл по причине недоступности или ошибки в работе антивируса, или из-за того, что файл защищён паролем."
); );
} }

9
src/main/java/ru/micord/ervu/av/service/FileUploadService.java
View file

@ -37,6 +37,7 @@ import ru.micord.ervu.av.s3.S3Service;
@Service @Service
public class FileUploadService { public class FileUploadService {
private static final int INFECTED_CODE = 72; private static final int INFECTED_CODE = 72;
private static final int PASS_PROTECTED_CODE = 73;
private static final Logger LOGGER = LoggerFactory.getLogger(FileUploadService.class); private static final Logger LOGGER = LoggerFactory.getLogger(FileUploadService.class);
@Value("${av.check.enabled}") @Value("${av.check.enabled}")
private boolean avCheckEnabled; private boolean avCheckEnabled;
@ -95,12 +96,14 @@ public class FileUploadService {
} }
} }
if (isAvError || exitCode == INFECTED_CODE) { if (isAvError || exitCode == INFECTED_CODE || exitCode == PASS_PROTECTED_CODE) {
downloadRequest.fileInfo().setFileUrl(null); downloadRequest.fileInfo().setFileUrl(null);
FileStatus fileStatus = isAvError ? FileStatus.FILE_STATUS_11 : FileStatus.FILE_STATUS_02; FileStatus fileStatus = (exitCode == PASS_PROTECTED_CODE || isAvError)
? FileStatus.FILE_STATUS_11
: FileStatus.FILE_STATUS_02;
downloadRequest.fileInfo().setFileStatus(fileStatus); downloadRequest.fileInfo().setFileStatus(fileStatus);
if (!isAvError) { if (!isAvError && exitCode == INFECTED_CODE) {
sendMessage(outErrorTopic.name(), downloadRequest, messageId, kafkaTemplate); sendMessage(outErrorTopic.name(), downloadRequest, messageId, kafkaTemplate);
} }
} }