diff --git a/src/main/java/net/gepafin/tendermanagement/service/impl/S3ReUploadMigrationService.java b/src/main/java/net/gepafin/tendermanagement/service/impl/S3ReUploadMigrationService.java
index 4db4ea12..4bc59150 100644
--- a/src/main/java/net/gepafin/tendermanagement/service/impl/S3ReUploadMigrationService.java
+++ b/src/main/java/net/gepafin/tendermanagement/service/impl/S3ReUploadMigrationService.java
@@ -80,7 +80,7 @@ public class S3ReUploadMigrationService {
File localFile = downloadFileFromS3(oldUrl);
String newKey = generateNewS3Path(document); // Make sure this generates the correct new path
String uploadedPath = uploadFileToNewBucket(localFile, newKey);
- updateDocumentPathAndDeleteOldEntry(document, uploadedPath);
+ updateDocumentPathAndNameEntry(document, uploadedPath);
} catch (Exception e) {
log.error("Error processing document {}: {}", document.getId(), e.getMessage());
}
@@ -178,20 +178,12 @@ public class S3ReUploadMigrationService {
}
- private void updateDocumentPathAndDeleteOldEntry(DocumentEntity document, String newPath) {
+ private void updateDocumentPathAndNameEntry(DocumentEntity document, String newPath) {
String fileName = extractFileName(newPath);
- DocumentEntity newDocument = new DocumentEntity();
- newDocument.setFilePath(newPath);
- newDocument.setSource(document.getSource());
- newDocument.setType(document.getType());
- newDocument.setIsDeleted(false);
- newDocument.setSourceId(document.getSourceId());
- newDocument.setFileName(fileName);
-
- documentRepository.save(newDocument);
- documentRepository.delete(document);
-
+ document.setFilePath(newPath);
+ document.setFileName(fileName);
+ documentRepository.save(document);
log.info("Migrated document ID: {} to new path: {}", document.getId(), newPath);
}
}
diff --git a/src/main/java/net/gepafin/tendermanagement/service/impl/UserSignedAndDelegationServiceImpl.java b/src/main/java/net/gepafin/tendermanagement/service/impl/UserSignedAndDelegationServiceImpl.java
index c1228565..dbd54afd 100644
--- a/src/main/java/net/gepafin/tendermanagement/service/impl/UserSignedAndDelegationServiceImpl.java
+++ b/src/main/java/net/gepafin/tendermanagement/service/impl/UserSignedAndDelegationServiceImpl.java
@@ -32,7 +32,7 @@ public class UserSignedAndDelegationServiceImpl {
private static final String OLD_BUCKET = "mementoresources";
private static final String NEW_BUCKET = "mementoresources";
-
+
private static final String SECURE_KEY = "267163962963";
@Autowired
@@ -49,7 +49,7 @@ public class UserSignedAndDelegationServiceImpl {
@Autowired
ApplicationRepository applicationRepository;
-
+
@Autowired
S3ConfigRepository s3ConfigRepository;
@@ -58,7 +58,6 @@ public class UserSignedAndDelegationServiceImpl {
private boolean migrationCompleted = false;
-
public String migrateUserDelegatedDocuments(String providedKey) {
if (migrationCompleted) {
@@ -84,7 +83,7 @@ public class UserSignedAndDelegationServiceImpl {
File localFile = downloadFileFromS3(oldUrl);
String newKey = generateNewS3PathForDelegationDoc();
String uploadedPath = uploadFileToNewBucket(localFile, newKey);
- updateDelegatedDocumentPathAndDeleteOldEntry(document, uploadedPath);
+ updateDelegatedDocumentPathAndNameEntry(document, uploadedPath);
} catch (Exception e) {
log.error("Error processing user designated document {}: {}", document.getId(), e.getMessage());
}
@@ -92,7 +91,6 @@ public class UserSignedAndDelegationServiceImpl {
return "Migrated";
}
-
public String migrateUserSignedDocuments(String providedKey) {
if (migrationCompleted) {
@@ -117,7 +115,7 @@ public class UserSignedAndDelegationServiceImpl {
File localFile = downloadFileFromS3(oldUrl);
String newKey = generateNewS3PathForUserSignedDoc(document);
String uploadedPath = uploadFileToNewBucket(localFile, newKey);
- updateDocumentPathAndDeleteOldEntry(document, uploadedPath);
+ updateDocumentPathAndNameEntry(document, uploadedPath);
} catch (Exception e) {
log.error("Error processing user signed document {}: {}", document.getId(), e.getMessage());
}
@@ -227,35 +225,21 @@ public class UserSignedAndDelegationServiceImpl {
return path.substring(path.lastIndexOf('/') + 1);
}
- private void updateDocumentPathAndDeleteOldEntry(ApplicationSignedDocumentEntity document, String newPath) {
+ private void updateDocumentPathAndNameEntry(ApplicationSignedDocumentEntity document, String newPath) {
- ApplicationSignedDocumentEntity newDocument = new ApplicationSignedDocumentEntity();
String fileName = extractFileNameFromPath(newPath);
- newDocument.setFilePath(newPath);
- newDocument.setFileName(fileName);
- newDocument.setApplication(document.getApplication());
- newDocument.setStatus("ACTIVE");
-
- applicationSignedDocumentRepository.save(newDocument);
- applicationSignedDocumentRepository.delete(document);
-
+ document.setFilePath(newPath);
+ document.setFileName(fileName);
+ applicationSignedDocumentRepository.save(document);
log.info("Migrated document ID: {} to new path: {}", document.getId(), newPath);
}
- private void updateDelegatedDocumentPathAndDeleteOldEntry(UserCompanyDelegationEntity document, String newPath) {
+ private void updateDelegatedDocumentPathAndNameEntry(UserCompanyDelegationEntity document, String newPath) {
String fileName = extractFileNameFromPath(newPath);
- UserCompanyDelegationEntity newDocument = new UserCompanyDelegationEntity();
- newDocument.setFilePath(newPath);
- newDocument.setFileName(fileName);
- newDocument.setBeneficiaryId(document.getBeneficiaryId());
- newDocument.setUserId(document.getUserId());
- newDocument.setCompanyId(document.getCompanyId());
- newDocument.setStatus("ACTIVE");
-
- userCompanyDelegationRepository.save(newDocument);
- userCompanyDelegationRepository.delete(document);
-
+ document.setFilePath(newPath);
+ document.setFileName(fileName);
+ userCompanyDelegationRepository.save(document);
log.info("Migrated document ID: {} to new path: {}", document.getId(), newPath);
}
}
diff --git a/src/main/resources/db/changelog/db.changelog-1.0.0.xml b/src/main/resources/db/changelog/db.changelog-1.0.0.xml
index 72224de3..456337cb 100644
--- a/src/main/resources/db/changelog/db.changelog-1.0.0.xml
+++ b/src/main/resources/db/changelog/db.changelog-1.0.0.xml
@@ -1443,7 +1443,7 @@
-
+
@@ -1452,7 +1452,7 @@
-
+
@@ -1461,7 +1461,7 @@
-
+
@@ -1470,7 +1470,7 @@
-
+
@@ -1479,7 +1479,7 @@
-
+