InstituteApiServiceImpl.java

/*
 * Copyright 2024 Global Crop Diversity Trust
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.genesys.server.api.v2.facade.impl;

import com.google.common.collect.Sets;
import lombok.extern.slf4j.Slf4j;
import org.genesys.server.api.v2.facade.InstituteApiService;
import org.genesys.server.api.v2.model.impl.ArticleDTO;
import org.genesys.server.api.v2.model.impl.FaoInstituteDTO;
import org.genesys.server.api.v2.model.impl.TranslatedArticleDTO;
import org.genesys.server.api.v2.model.impl.VocabularyTermDTO;
import org.genesys.server.exception.NotFoundElement;
import org.genesys.server.exception.SearchException;
import org.genesys.server.model.genesys.Accession;
import org.genesys.server.model.impl.ArticleLang;
import org.genesys.server.model.impl.FaoInstitute;
import org.genesys.server.service.ArticleService;
import org.genesys.server.service.ArticleTranslationService;
import org.genesys.server.service.CRMException;
import org.genesys.server.service.ContentService;
import org.genesys.server.service.ElasticsearchService;
import org.genesys.server.service.GenesysService;
import org.genesys.server.service.InstituteService;
import org.genesys.server.service.SubsetService;
import org.genesys.server.service.filter.AccessionFilter;
import org.genesys.server.service.filter.InstituteFilter;
import org.genesys.server.service.filter.SubsetFilter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.i18n.LocaleContextHolder;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Set;

import static org.springframework.context.i18n.LocaleContextHolder.getLocale;

@Service
@Validated
@Slf4j
public class InstituteApiServiceImpl extends APIFilteredServiceFacadeImpl<InstituteService, FaoInstituteDTO, FaoInstitute, InstituteFilter>
	implements InstituteApiService {

	@Autowired
	private ArticleService articleService;

	@Autowired
	private ArticleTranslationService articleTranslationService;

	@Autowired
	private GenesysService genesysService;

	@Autowired
	private SubsetService subsetService;

	@Autowired(required = false)
	private ElasticsearchService elasticsearchService;

	@Override
	protected FaoInstitute convert(FaoInstituteDTO source) {
		return mapper.map(source);
	}

	@Override
	protected FaoInstituteDTO convert(FaoInstitute source) {
		return mapper.map(source);
	}

	@Override
	@Transactional(readOnly = true)
	public FaoInstituteDTO findInstitute(String wiewsCode) {
		return mapper.map(service.findInstitute(wiewsCode));
	}

	@Override
	@Transactional(readOnly = true)
	public InstituteDetails getDetails(String code) {
		FaoInstitute faoInstitute = service.findInstitute(code);

		if (faoInstitute == null) {
			throw new NotFoundElement();
		}

		AccessionFilter byInstituteFilter = new AccessionFilter();
		byInstituteFilter.holder().code(Sets.newHashSet(faoInstitute.getCode()));

		InstituteDetails details = new InstituteDetails();
		details.details = mapper.map(faoInstitute);
		details.blurb = mapper.map(articleService.getArticle(faoInstitute, ContentService.ENTITY_BLURB_SLUG, getLocale()));
		details.pdciStats = faoInstitute.getStatisticsPDCI();
		details.lastUpdates = genesysService.getLastUpdatedStatistics(faoInstitute);
		details.overview = getOverviewData(byInstituteFilter);

		PageRequest pageRequest = PageRequest.of(0, 10, Sort.by(Sort.Direction.DESC, "lastModifiedDate"));
		SubsetFilter subsetFilter = new SubsetFilter();
		subsetFilter.institutes().add(faoInstitute.getCode());
		try {
			details.recentSubsets = mapper.map(subsetService.list(subsetFilter, pageRequest).getContent(), mapper::map);
		} catch (SearchException e) {
			log.error("Error occurred during search", e);
		}

		return details;
	}

	@Override
	@Transactional
	public TranslatedArticleDTO updateArticle(FaoInstitute faoInstitute, ArticleDTO article) throws CRMException {
		var lang = LocaleContextHolder.getLocale().toLanguageTag();
		// return article;
		var loadedArticle = articleService.get(article.getId());
		if (Objects.equals(loadedArticle.getOriginalLanguageTag(), lang)) {
			// Update Article
			loadedArticle.setSlug(ContentService.ENTITY_BLURB_SLUG);
			loadedArticle.setTitle(article.getTitle());
			loadedArticle.setSummary(article.getSummary());
			loadedArticle.setBody(article.getBody());
			loadedArticle = articleService.update(loadedArticle);
		} else {
			// Update ArticleLang
			var articleLang = articleTranslationService.getLang(loadedArticle, lang);
			if (articleLang == null) {
				articleLang = new ArticleLang(loadedArticle, lang, article.getTitle(), article.getSummary(), article.getBody());
			} else {
				articleLang.setTitle(article.getTitle());
				articleLang.setSummary(article.getSummary());
				articleLang.setBody(article.getBody());
			}
			articleTranslationService.upsertLang(loadedArticle, articleLang);
		}

		return mapper.map(articleService.loadTranslated(loadedArticle.getId()));
	}

	@Override
	@Transactional
	public FaoInstituteDTO update(String code, FaoInstituteDTO institute) {
		return mapper.map(service.update(code, mapper.map(institute)));
	}

	@Override
	public VocabularyTermDTO getInstituteTerm(String code) {
		return mapper.map(service.getInstituteTerm(code));
	}

	@Override
	public List<VocabularyTermDTO> autocompleteTerm(String text) {
		return mapper.map(service.autocompleteTerm(text), mapper::map);
	}

	@Override
	public Map<String, String> decodeWiewsCodes(Set<String> codes) {
		return service.decodeCodes(codes);
	}

	private Map<String, ElasticsearchService.TermResult> getOverviewData(AccessionFilter byInstituteFilter) {
		String[] terms = new String[] { "crop.shortName", "cropName", "taxonomy.genus", "taxonomy.genusSpecies", "sampStat", "countryOfOrigin.code3",
			"storage", "curationType", "donorCode", "breederCode", "duplSite", "sgsv", "mlsStatus", "available" };

		try {
			return elasticsearchService.termStatisticsAuto(Accession.class, byInstituteFilter, 10, terms);
		} catch (Exception e) {
			log.error("Error occurred during search", e);
			return null;
		}
	}
}