2023-11-22 16:52:04 +01:00
|
|
|
package eu.old.eudat.migration;
|
|
|
|
|
2023-11-23 11:36:24 +01:00
|
|
|
import eu.eudat.commons.XmlHandlingService;
|
2023-11-22 16:52:04 +01:00
|
|
|
import eu.eudat.commons.enums.IsActive;
|
2023-11-23 11:36:24 +01:00
|
|
|
import eu.eudat.commons.enums.ReferenceFieldDataType;
|
2023-11-22 16:52:04 +01:00
|
|
|
import eu.eudat.commons.enums.ReferenceSourceType;
|
2023-11-23 11:36:24 +01:00
|
|
|
import eu.eudat.commons.types.reference.DefinitionEntity;
|
|
|
|
import eu.eudat.commons.types.reference.FieldEntity;
|
|
|
|
import eu.eudat.convention.ConventionService;
|
2023-11-22 16:52:04 +01:00
|
|
|
import eu.eudat.data.ReferenceEntity;
|
|
|
|
import eu.old.eudat.data.dao.entities.ProjectDao;
|
|
|
|
import eu.old.eudat.data.entities.Project;
|
|
|
|
import eu.old.eudat.logic.services.operations.DatabaseRepository;
|
|
|
|
import gr.cite.tools.logging.LoggerService;
|
|
|
|
import jakarta.persistence.EntityManager;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
2023-11-23 11:36:24 +01:00
|
|
|
import java.util.ArrayList;
|
2023-11-22 16:52:04 +01:00
|
|
|
import java.util.List;
|
|
|
|
import java.util.Locale;
|
|
|
|
|
|
|
|
@Service
|
|
|
|
public class ProjectMigrationService {
|
|
|
|
private static final LoggerService logger = new LoggerService(LoggerFactory.getLogger(ProjectMigrationService.class));
|
|
|
|
|
|
|
|
private static final int PageSize = 500;
|
|
|
|
private static final String InternalReferenceSource = "dmp";
|
|
|
|
private final DatabaseRepository databaseRepository;
|
|
|
|
private final EntityManager entityManager;
|
2023-11-23 11:36:24 +01:00
|
|
|
private final ConventionService conventionService;
|
|
|
|
private final XmlHandlingService xmlHandlingService;
|
|
|
|
public ProjectMigrationService(DatabaseRepository databaseRepository, EntityManager entityManager, ConventionService conventionService, XmlHandlingService xmlHandlingService) {
|
2023-11-22 16:52:04 +01:00
|
|
|
this.databaseRepository = databaseRepository;
|
|
|
|
this.entityManager = entityManager;
|
2023-11-23 11:36:24 +01:00
|
|
|
this.conventionService = conventionService;
|
|
|
|
this.xmlHandlingService = xmlHandlingService;
|
2023-11-22 16:52:04 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
public void migrate(){
|
2023-11-22 17:34:51 +01:00
|
|
|
ProjectDao projectDao = databaseRepository.getProjectDao();
|
|
|
|
long total = projectDao.asQueryable().count();
|
2023-11-22 16:52:04 +01:00
|
|
|
logger.debug("Migrate Project Total : " + total);
|
|
|
|
int page = 0;
|
|
|
|
|
|
|
|
List<Project> items;
|
|
|
|
do {
|
2023-11-22 17:34:51 +01:00
|
|
|
items = projectDao.asQueryable().orderBy((builder, root) -> builder.asc(root.get("created"))).orderBy((builder, root) -> builder.asc(root.get("ID"))).skip(page * PageSize).take(PageSize).toList();
|
2023-11-22 16:52:04 +01:00
|
|
|
if (items != null && !items.isEmpty()) {
|
|
|
|
logger.debug("Migrate Project " + page * PageSize + " of " + total);
|
|
|
|
for (Project item : items) {
|
2023-11-22 17:34:51 +01:00
|
|
|
entityManager.detach(item);
|
2023-11-22 16:52:04 +01:00
|
|
|
if (item.getReference() == null || !item.getReference().contains(":")){
|
|
|
|
logger.warn("Reference generated because is null Project " + item.getId());
|
2024-02-28 17:48:46 +01:00
|
|
|
item.setReference(InternalReferenceSource + ":" + item.getId().toString().replace("-", "").toLowerCase(Locale.ROOT));
|
2023-11-22 16:52:04 +01:00
|
|
|
}
|
|
|
|
eu.old.eudat.models.data.project.Project model = new eu.old.eudat.models.data.project.Project().fromDataModel(item);
|
|
|
|
|
|
|
|
String[] referenceParts = item.getReference().split(":", 2);
|
|
|
|
boolean isInternal = referenceParts[0].equals(InternalReferenceSource);
|
|
|
|
|
|
|
|
ReferenceEntity data = new ReferenceEntity();
|
|
|
|
data.setId(item.getId());
|
|
|
|
data.setLabel(item.getLabel());
|
2023-11-23 11:36:24 +01:00
|
|
|
data.setAbbreviation(item.getAbbreviation());
|
2023-11-22 16:52:04 +01:00
|
|
|
data.setDescription(item.getDescription());
|
2024-03-13 16:04:42 +01:00
|
|
|
data.setIsActive(IsActive.Active);
|
|
|
|
data.setTypeId(ReferenceTypeIds.Project);
|
2023-11-22 16:52:04 +01:00
|
|
|
data.setCreatedAt(item.getCreated().toInstant());
|
|
|
|
data.setUpdatedAt(item.getModified().toInstant());
|
|
|
|
if (item.getCreationUser() != null) data.setCreatedById(item.getCreationUser().getId());
|
|
|
|
data.setReference(referenceParts[1]);
|
2023-11-22 17:34:51 +01:00
|
|
|
data.setSource(isInternal? "Internal" : referenceParts[0]);
|
2023-11-22 16:52:04 +01:00
|
|
|
data.setSourceType(Project.ProjectType.INTERNAL.getValue().equals(item.getType())? ReferenceSourceType.Internal : ReferenceSourceType.External);
|
2023-11-23 11:36:24 +01:00
|
|
|
|
|
|
|
DefinitionEntity definitionEntity = new DefinitionEntity();
|
|
|
|
definitionEntity.setFields(new ArrayList<>());
|
|
|
|
if (!this.conventionService.isNullOrEmpty(item.getUri())){
|
|
|
|
FieldEntity fieldEntity = new FieldEntity();
|
|
|
|
fieldEntity.setCode("uri");
|
|
|
|
fieldEntity.setDataType(ReferenceFieldDataType.Text);
|
|
|
|
fieldEntity.setValue(item.getUri());
|
|
|
|
definitionEntity.getFields().add(fieldEntity);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (item.getStartdate() != null){
|
|
|
|
FieldEntity fieldEntity = new FieldEntity();
|
|
|
|
fieldEntity.setCode("startDate");
|
|
|
|
fieldEntity.setDataType(ReferenceFieldDataType.Date);
|
|
|
|
fieldEntity.setValue(item.getStartdate().toInstant().toString());
|
|
|
|
definitionEntity.getFields().add(fieldEntity);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (item.getEnddate() != null){
|
|
|
|
FieldEntity fieldEntity = new FieldEntity();
|
|
|
|
fieldEntity.setCode("endDate");
|
|
|
|
fieldEntity.setDataType(ReferenceFieldDataType.Date);
|
|
|
|
fieldEntity.setValue(item.getEnddate().toInstant().toString());
|
|
|
|
definitionEntity.getFields().add(fieldEntity);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!definitionEntity.getFields().isEmpty()){
|
|
|
|
data.setDefinition(this.xmlHandlingService.toXmlSafe(definitionEntity));
|
|
|
|
}
|
2023-11-22 16:52:04 +01:00
|
|
|
this.entityManager.persist(data);
|
|
|
|
}
|
|
|
|
this.entityManager.flush();
|
|
|
|
|
|
|
|
page++;
|
|
|
|
}
|
|
|
|
} while (items != null && !items.isEmpty());
|
|
|
|
}
|
|
|
|
}
|