-/**\r
-* Copyright (C) 2007 EDIT\r
-* European Distributed Institute of Taxonomy \r
-* http://www.e-taxonomy.eu\r
-* \r
-* The contents of this file are subject to the Mozilla Public License Version 1.1\r
-* See LICENSE.TXT at the top of this package for the full license terms.\r
-*/\r
-\r
-package eu.etaxonomy.cdm.api.service;\r
-\r
-import java.util.ArrayList;\r
-import java.util.Collection;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.UUID;\r
-\r
-import org.apache.log4j.Logger;\r
-import org.springframework.beans.factory.annotation.Autowired;\r
-import org.springframework.stereotype.Service;\r
-import org.springframework.transaction.annotation.Transactional;\r
-\r
-import eu.etaxonomy.cdm.model.agent.Agent;\r
-import eu.etaxonomy.cdm.model.agent.Institution;\r
-import eu.etaxonomy.cdm.persistence.dao.agent.IAgentDao;\r
-import eu.etaxonomy.cdm.persistence.dao.common.ICdmEntityDao;\r
-\r
-\r
-\r
-/**\r
- * @author a.mueller\r
- *\r
- */\r
-@Service\r
-@Transactional\r
-public class AgentServiceImpl<T extends Agent> extends IdentifiableServiceBase<T> implements IAgentService<T> {\r
- private static final Logger logger = Logger.getLogger(AgentServiceImpl.class);\r
-\r
- private IAgentDao agentDao;\r
- @Autowired\r
- protected void setDao(IAgentDao dao) {\r
- this.dao = (ICdmEntityDao)dao;\r
- this.agentDao = dao;\r
- }\r
-\r
- public List<T> findAgentsByTitle(String title) {\r
- return super.findCdmObjectsByTitle(title);\r
- }\r
-\r
- public T getAgentByUuid(UUID uuid) {\r
- return super.getCdmObjectByUuid(uuid);\r
- }\r
-\r
- public UUID saveAgent(T agent) {\r
- return super.saveCdmObject(agent);\r
- }\r
- \r
- @Transactional(readOnly = false)\r
- public Map<UUID, T> saveAgentAll(Collection<T> agentCollection){\r
- return saveCdmObjectAll(agentCollection);\r
- }\r
-\r
- \r
- public List<? extends Agent> getAllAgents(int limit, int start){\r
- return agentDao.list(limit, start);\r
- }\r
- \r
- public List<Agent> searchInstitutionByCode(String code) {\r
- return agentDao.getInstitutionByCode(code);\r
- }\r
-\r
- public void generateTitleCache() {\r
- // TODO Auto-generated method stub\r
- \r
- }\r
-\r
- \r
-}\r
+/**
+* Copyright (C) 2007 EDIT
+* European Distributed Institute of Taxonomy
+* http://www.e-taxonomy.eu
+*
+* The contents of this file are subject to the Mozilla Public License Version 1.1
+* See LICENSE.TXT at the top of this package for the full license terms.
+*/
+
+package eu.etaxonomy.cdm.api.service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
+
+import org.apache.log4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import eu.etaxonomy.cdm.api.service.pager.Pager;
+import eu.etaxonomy.cdm.api.service.pager.impl.DefaultPagerImpl;
+import eu.etaxonomy.cdm.common.monitor.IProgressMonitor;
+import eu.etaxonomy.cdm.model.agent.Address;
+import eu.etaxonomy.cdm.model.agent.AgentBase;
+import eu.etaxonomy.cdm.model.agent.Institution;
+import eu.etaxonomy.cdm.model.agent.InstitutionalMembership;
+import eu.etaxonomy.cdm.model.agent.Person;
+import eu.etaxonomy.cdm.model.agent.Team;
+import eu.etaxonomy.cdm.model.agent.TeamOrPersonBase;
+import eu.etaxonomy.cdm.model.common.CdmBase;
+import eu.etaxonomy.cdm.persistence.dao.agent.IAgentDao;
+import eu.etaxonomy.cdm.persistence.dao.common.ICdmGenericDao;
+import eu.etaxonomy.cdm.persistence.dto.UuidAndTitleCache;
+import eu.etaxonomy.cdm.strategy.cache.common.IIdentifiableEntityCacheStrategy;
+import eu.etaxonomy.cdm.strategy.merge.ConvertMergeStrategy;
+import eu.etaxonomy.cdm.strategy.merge.DefaultMergeStrategy;
+import eu.etaxonomy.cdm.strategy.merge.IMergeStrategy;
+import eu.etaxonomy.cdm.strategy.merge.MergeException;
+import eu.etaxonomy.cdm.strategy.merge.MergeMode;
+
+
+
+/**
+ * @author a.mueller
+ *
+ */
+@Service
+@Transactional(readOnly = true)
+public class AgentServiceImpl
+ extends IdentifiableServiceBase<AgentBase,IAgentDao>
+ implements IAgentService {
+ private static final Logger logger = Logger.getLogger(AgentServiceImpl.class);
+
+ @Autowired
+ ICdmGenericDao genericDao;
+
+ @Override
+ @Autowired
+ protected void setDao(IAgentDao dao) {
+ assert dao != null;
+ this.dao = dao;
+ }
+
+ /**
+ * Constructor
+ */
+ public AgentServiceImpl(){
+ if (logger.isDebugEnabled()) { logger.debug("Load AgentService Bean"); }
+ }
+
+
+ @Override
+ @Transactional(readOnly = false)
+ public UpdateResult updateCaches(Class<? extends AgentBase> clazz, Integer stepSize, IIdentifiableEntityCacheStrategy<AgentBase> cacheStrategy, IProgressMonitor monitor) {
+ if (clazz == null){
+ clazz = AgentBase.class;
+ }
+ return super.updateCachesImpl(clazz, stepSize, cacheStrategy, monitor);
+ }
+
+ @Override
+ public List<Institution> searchInstitutionByCode(String code) {
+ return dao.getInstitutionByCode(code);
+ }
+
+ @Override
+ public Pager<InstitutionalMembership> getInstitutionalMemberships(Person person, Integer pageSize, Integer pageNumber) {
+ long numberOfResults = dao.countInstitutionalMemberships(person);
+
+ List<InstitutionalMembership> results = new ArrayList<>();
+ if(numberOfResults > 0) { // no point checking again //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)
+ results = dao.getInstitutionalMemberships(person, pageSize, pageNumber);
+ }
+
+ return new DefaultPagerImpl<>(pageNumber, numberOfResults, pageSize, results);
+ }
+
+ @Override
+ public Pager<Person> getMembers(Team team, Integer pageSize, Integer pageNumber) {
+ long numberOfResults = dao.countMembers(team);
+
+ List<Person> results = new ArrayList<>();
+ if(numberOfResults > 0) { // no point checking again //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)
+ results = dao.getMembers(team, pageSize, pageNumber);
+ }
+
+ return new DefaultPagerImpl<>(pageNumber, numberOfResults, pageSize, results);
+ }
+
+ @Override
+ public Pager<Address> getAddresses(AgentBase agent, Integer pageSize, Integer pageNumber) {
+ long numberOfResults = dao.countAddresses(agent);
+
+ List<Address> results = new ArrayList<>();
+ if(numberOfResults > 0) { // no point checking again //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)
+ results = dao.getAddresses(agent, pageSize, pageNumber);
+ }
+
+ return new DefaultPagerImpl<>(pageNumber, numberOfResults, pageSize, results);
+ }
+
+ @Override
+ public List<UuidAndTitleCache<Team>> getTeamUuidAndNomenclaturalTitle() {
+ return dao.getTeamUuidAndNomenclaturalTitle();
+ }
+
+ @Override
+ public List<UuidAndTitleCache<Person>> getPersonUuidAndTitleCache() {
+ return dao.getPersonUuidAndTitleCache();
+ }
+
+ @Override
+ public List<UuidAndTitleCache<Team>> getTeamUuidAndTitleCache() {
+ return dao.getTeamUuidAndTitleCache();
+ }
+
+ @Override
+ public List<UuidAndTitleCache<AgentBase>> getInstitutionUuidAndTitleCache(Integer limit, String pattern) {
+ return dao.getUuidAndAbbrevTitleCache(Institution.class, limit, pattern);
+ }
+
+ @Override
+ @Transactional(readOnly = false)
+ public DeleteResult delete(UUID agentUUID){
+ DeleteResult result = new DeleteResult();
+ if (agentUUID == null){
+ result.setAbort();
+ result.addException(new Exception("Can't delete object without UUID."));
+ return result;
+ }
+ AgentBase base = dao.load(agentUUID);
+ result = isDeletable(agentUUID, null);
+
+ if (result.isOk()){
+ if (base instanceof Team){
+ Team baseTeam = (Team) base;
+ List<Person> members = baseTeam.getTeamMembers();
+ List<Person> temp = new ArrayList<Person>();
+ for (Person member:members){
+ temp.add(member);
+ }
+ for (Person member: temp){
+ members.remove(member);
+ }
+ }
+ saveOrUpdate(base);
+
+ dao.delete(base);
+ result.addDeletedObject(base);
+
+ }
+
+ return result;
+ }
+
+ @Override
+ public DeleteResult delete(AgentBase agent){
+ return delete(agent.getUuid());
+ }
+
+ @Override
+ @Transactional(readOnly = false)
+ public UpdateResult convertTeam2Person(UUID teamUuid) throws MergeException {
+ Team team = CdmBase.deproxy(dao.load(teamUuid), Team.class);
+ return convertTeam2Person(team);
+ }
+
+ @Override
+ public UpdateResult convertTeam2Person(Team team) throws MergeException {
+ UpdateResult result = new UpdateResult();
+ Person newPerson = null;
+ team = CdmBase.deproxy(team, Team.class);
+ if (team.getTeamMembers().size() > 1){
+ throw new IllegalArgumentException("Team must not have more than 1 member to be convertable into a person");
+ }else if (team.getTeamMembers().size() == 1){
+ newPerson = team.getTeamMembers().get(0);
+ IMergeStrategy strategy = DefaultMergeStrategy.NewInstance(TeamOrPersonBase.class);
+ strategy.setDefaultCollectionMergeMode(MergeMode.FIRST);
+ genericDao.merge(newPerson, team, strategy);
+ }else if (team.getTeamMembers().isEmpty()){
+ newPerson = Person.NewInstance();
+ genericDao.save(newPerson);
+ IMergeStrategy strategy = DefaultMergeStrategy.NewInstance(TeamOrPersonBase.class);
+ strategy.setDefaultMergeMode(MergeMode.SECOND);
+ strategy.setDefaultCollectionMergeMode(MergeMode.SECOND);
+ genericDao.merge(newPerson, team, strategy);
+ }else{
+ throw new IllegalStateException("Unhandled state of team members collection");
+ }
+ result.setCdmEntity(newPerson);
+ return result;
+ }
+
+ @Override
+ @Transactional(readOnly = false)
+ public UpdateResult convertPerson2Team(UUID personUuid) throws MergeException, IllegalArgumentException {
+ Person person = CdmBase.deproxy(dao.load(personUuid), Person.class);
+ return convertPerson2Team(person);
+ }
+
+ @Override
+ public UpdateResult convertPerson2Team(Person person) throws MergeException, IllegalArgumentException {
+ UpdateResult result = new UpdateResult();
+ Team team = Team.NewInstance();
+ ConvertMergeStrategy strategy = ConvertMergeStrategy.NewInstance(TeamOrPersonBase.class);
+ strategy.setDefaultMergeMode(MergeMode.SECOND);
+ strategy.setDefaultCollectionMergeMode(MergeMode.SECOND);
+ strategy.setDeleteSecondObject(true);
+
+
+ if (! genericDao.isMergeable(team, person, strategy)){
+ throw new MergeException("Person can not be transformed into team.");
+ }
+ try {
+ //this.save(team);
+ team.setProtectedNomenclaturalTitleCache(false);
+ team.setProtectedTitleCache(true);
+ team.setTitleCache(person.getTitleCache(), true);
+ team =(Team) this.save(team);
+ genericDao.merge(team, person, strategy);
+ //team.addTeamMember(person);
+
+ //this.save(team);
+// team.setNomenclaturalTitle(person.getNomenclaturalTitle(), true);
+ } catch (Exception e) {
+ throw new MergeException("Unhandled merge exception", e);
+ }
+ result.setCdmEntity(team);
+ result.addUpdatedObject(team);
+ return result;
+ }
+
+ /* (non-Javadoc)
+ * @see eu.etaxonomy.cdm.api.service.IAgentService#getUuidAndAbbrevTitleCache()
+ */
+ @Override
+ public List<UuidAndTitleCache<AgentBase>> getUuidAndAbbrevTitleCache(Class clazz, Integer limit, String pattern) {
+ return dao.getUuidAndAbbrevTitleCache(clazz, null, pattern);
+ }
+
+}
BGBM BDI Projects / cdmlib.git / blobdiff