SUPPORT-8381: some changes (5)
This commit is contained in:
parent
21a053a4ef
commit
e19dbcc332
2 changed files with 7 additions and 2 deletions
|
|
@ -20,6 +20,7 @@ import org.springframework.web.multipart.MultipartFile;
|
|||
public class ErvuFileUploadClientImpl implements ErvuFileUploadClient {
|
||||
@Value("${file.upload.url:#{null}}")
|
||||
private String url;
|
||||
private static final Logger logger = LoggerFactory.getLogger(ErvuFileUploadClientImpl.class);
|
||||
|
||||
@Override
|
||||
public boolean uploadFile(String filename, MultipartFile multipartFile) {
|
||||
|
|
@ -42,7 +43,8 @@ public class ErvuFileUploadClientImpl implements ErvuFileUploadClient {
|
|||
return (responseCode >= 200) && (responseCode <= 202);
|
||||
}
|
||||
catch (IOException e) {
|
||||
throw new RuntimeException(e);
|
||||
logger.error("Fail upload file: " + filename, e);
|
||||
return false;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,6 +1,5 @@
|
|||
package ervu.service.fileupload.impl;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.UUID;
|
||||
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
|
|
@ -9,6 +8,8 @@ import ervu.client.fileupload.ErvuFileUploadClient;
|
|||
import ervu.client.kafka.KafkaClient;
|
||||
import ervu.service.fileupload.FileUploadV2Service;
|
||||
import org.apache.commons.io.FilenameUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.web.multipart.MultipartFile;
|
||||
|
||||
|
|
@ -22,6 +23,7 @@ public class ErvuFileUploadV2ServiceImpl implements FileUploadV2Service {
|
|||
private final KafkaClient kafkaClient;
|
||||
private final SecurityContext securityContext;
|
||||
private final ErvuFileUploadClient ervuFileUploadClient;
|
||||
private static final Logger logger = LoggerFactory.getLogger(ErvuFileUploadV2ServiceImpl.class);
|
||||
|
||||
public ErvuFileUploadV2ServiceImpl(ErvuFileUploadClient ervuFileUploadClient,
|
||||
KafkaClient kafkaClient, SecurityContext securityContext) {
|
||||
|
|
@ -45,6 +47,7 @@ public class ErvuFileUploadV2ServiceImpl implements FileUploadV2Service {
|
|||
return this.kafkaClient.sendMessage(jsonMessage);
|
||||
}
|
||||
else {
|
||||
logger.error("Fail upload file: {}", multipartFile.getOriginalFilename());
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue