Merge pull request #42 from Kitzanos/fature/GEPAFINBE-44

GEPAFINBE-44 (Beneficiario must be able to download Call Documents)

src/main/java/net/gepafin/tendermanagement/dao/CallDao.java

@@ -1,5 +1,9 @@
 package net.gepafin.tendermanagement.dao;
 
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
@@ -8,13 +12,21 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipOutputStream;
 
 import net.gepafin.tendermanagement.enums.DocumentSourceTypeEnum;
 import net.gepafin.tendermanagement.model.response.*;
 import net.gepafin.tendermanagement.service.*;
 import net.gepafin.tendermanagement.util.DateTimeUtil;
 import net.gepafin.tendermanagement.util.Utils;
+import org.h2.util.IOUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 
@@ -85,6 +97,10 @@ public class CallDao {
 	private FlowDao flowDao;
 	@Autowired
 	private FormDao formDao;
+	@Value("${aws.s3.url.folder}")
+	private String s3Folder;
+	@Autowired
+	private AmazonS3Service amazonS3Service;
 
 	public CallResponse createCallStep1(CreateCallRequestStep1 createCallRequest, Long userId) {
 		UserEntity userEntity = userService.validateUser(userId);
@@ -101,6 +117,35 @@ public class CallDao {
 		return createCallResponseBean;
 
 	}
+	public byte[] downloadCallDocumentsAsZip(Long callId) {
+		List<DocumentEntity> documents = documentRepository.findBySourceIdAndSourceAndTypeAndIsDeletedFalse(callId, DocumentSourceTypeEnum.CALL.getValue(),DocumentTypeEnum.DOCUMENT.getValue());
+		if (documents.isEmpty()) {
+			throw new ResourceNotFoundException(Status.NOT_FOUND, Translator.toLocale(GepafinConstant.DOCUMENT_NOT_FOUND));
+		}
+
+		try (ByteArrayOutputStream zipOutputStream = new ByteArrayOutputStream();
+			 ZipOutputStream zos = new ZipOutputStream(zipOutputStream)) {
+
+			for (DocumentEntity document : documents) {
+				try (InputStream fileInputStream = amazonS3Service.getFile(s3Folder, document.getFileName())) {
+					ZipEntry zipEntry = new ZipEntry(document.getFileName());
+					zos.putNextEntry(zipEntry);
+					IOUtils.copy(fileInputStream, zos);
+					zos.closeEntry();
+				} catch (IOException e) {
+					throw new RuntimeException("Error downloading or adding document to ZIP: " + document.getFileName(), e);
+				}
+			}
+
+			zos.finish();
+			return zipOutputStream.toByteArray();
+
+		} catch (IOException e) {
+			throw new RuntimeException("Error while creating ZIP file", e);
+		}
+	}
+
+
 
 	public CallEntity convertToCallEntity(CreateCallRequestStep1 createCallRequest) {
 		CallEntity callEntity = new CallEntity();