-// $Id$\r
-/**\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.List;\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.api.service.pager.Pager;\r
-import eu.etaxonomy.cdm.api.service.pager.impl.DefaultPagerImpl;\r
-import eu.etaxonomy.cdm.common.monitor.IProgressMonitor;\r
-import eu.etaxonomy.cdm.model.agent.Address;\r
-import eu.etaxonomy.cdm.model.agent.AgentBase;\r
-import eu.etaxonomy.cdm.model.agent.Institution;\r
-import eu.etaxonomy.cdm.model.agent.InstitutionalMembership;\r
-import eu.etaxonomy.cdm.model.agent.Person;\r
-import eu.etaxonomy.cdm.model.agent.Team;\r
-import eu.etaxonomy.cdm.model.agent.TeamOrPersonBase;\r
-import eu.etaxonomy.cdm.model.common.CdmBase;\r
-import eu.etaxonomy.cdm.persistence.dao.agent.IAgentDao;\r
-import eu.etaxonomy.cdm.persistence.dao.common.ICdmGenericDao;\r
-import eu.etaxonomy.cdm.persistence.dto.UuidAndTitleCache;\r
-import eu.etaxonomy.cdm.strategy.cache.common.IIdentifiableEntityCacheStrategy;\r
-import eu.etaxonomy.cdm.strategy.merge.ConvertMergeStrategy;\r
-import eu.etaxonomy.cdm.strategy.merge.DefaultMergeStrategy;\r
-import eu.etaxonomy.cdm.strategy.merge.IMergeStrategy;\r
-import eu.etaxonomy.cdm.strategy.merge.MergeException;\r
-import eu.etaxonomy.cdm.strategy.merge.MergeMode;\r
-\r
-\r
-\r
-/**\r
- * @author a.mueller\r
- *\r
- */\r
-@Service\r
-@Transactional(readOnly = true)\r
-public class AgentServiceImpl extends IdentifiableServiceBase<AgentBase,IAgentDao> implements IAgentService {\r
- private static final Logger logger = Logger.getLogger(AgentServiceImpl.class);\r
-\r
- @Autowired\r
- ICdmGenericDao genericDao;\r
-\r
- @Override\r
- @Autowired\r
- protected void setDao(IAgentDao dao) {\r
- assert dao != null;\r
- this.dao = dao;\r
- }\r
-\r
- /**\r
- * Constructor\r
- */\r
- public AgentServiceImpl(){\r
- if (logger.isDebugEnabled()) { logger.debug("Load AgentService Bean"); }\r
- }\r
-\r
-\r
- @Override\r
- @Transactional(readOnly = false)\r
- public void updateTitleCache(Class<? extends AgentBase> clazz, Integer stepSize, IIdentifiableEntityCacheStrategy<AgentBase> cacheStrategy, IProgressMonitor monitor) {\r
- if (clazz == null){\r
- clazz = AgentBase.class;\r
- }\r
- super.updateTitleCacheImpl(clazz, stepSize, cacheStrategy, monitor);\r
- }\r
-\r
- @Override\r
- public List<Institution> searchInstitutionByCode(String code) {\r
- return dao.getInstitutionByCode(code);\r
- }\r
-\r
- @Override\r
- public Pager<InstitutionalMembership> getInstitutionalMemberships(Person person, Integer pageSize, Integer pageNumber) {\r
- Integer numberOfResults = dao.countInstitutionalMemberships(person);\r
-\r
- List<InstitutionalMembership> results = new ArrayList<InstitutionalMembership>();\r
- if(numberOfResults > 0) { // no point checking again //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)\r
- results = dao.getInstitutionalMemberships(person, pageSize, pageNumber);\r
- }\r
-\r
- return new DefaultPagerImpl<InstitutionalMembership>(pageNumber, numberOfResults, pageSize, results);\r
- }\r
-\r
- @Override\r
- public Pager<Person> getMembers(Team team, Integer pageSize, Integer pageNumber) {\r
- Integer numberOfResults = dao.countMembers(team);\r
-\r
- List<Person> results = new ArrayList<Person>();\r
- if(numberOfResults > 0) { // no point checking again //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)\r
- results = dao.getMembers(team, pageSize, pageNumber);\r
- }\r
-\r
- return new DefaultPagerImpl<Person>(pageNumber, numberOfResults, pageSize, results);\r
- }\r
-\r
- @Override\r
- public Pager<Address> getAddresses(AgentBase agent, Integer pageSize, Integer pageNumber) {\r
- Integer numberOfResults = dao.countAddresses(agent);\r
-\r
- List<Address> results = new ArrayList<Address>();\r
- if(numberOfResults > 0) { // no point checking again //TODO use AbstractPagerImpl.hasResultsInRange(numberOfResults, pageNumber, pageSize)\r
- results = dao.getAddresses(agent, pageSize, pageNumber);\r
- }\r
-\r
- return new DefaultPagerImpl<Address>(pageNumber, numberOfResults, pageSize, results);\r
- }\r
-\r
- @Override\r
- public List<UuidAndTitleCache<Team>> getTeamUuidAndNomenclaturalTitle() {\r
- return dao.getTeamUuidAndNomenclaturalTitle();\r
- }\r
-\r
- @Override\r
- public List<UuidAndTitleCache<Person>> getPersonUuidAndTitleCache() {\r
- return dao.getPersonUuidAndTitleCache();\r
- }\r
-\r
- @Override\r
- public List<UuidAndTitleCache<Team>> getTeamUuidAndTitleCache() {\r
- return dao.getTeamUuidAndTitleCache();\r
- }\r
-\r
- @Override\r
- public List<UuidAndTitleCache<Institution>> getInstitutionUuidAndTitleCache() {\r
- return dao.getInstitutionUuidAndTitleCache();\r
- }\r
-\r
- @Override\r
- @Transactional(readOnly = false)\r
- public DeleteResult delete(UUID agentUUID){\r
- AgentBase base = dao.load(agentUUID);\r
- DeleteResult result = this.isDeletable(base, null);\r
-\r
- if (result.isOk()){\r
- if (base instanceof Team){\r
- Team baseTeam = (Team) base;\r
- List<Person> members = baseTeam.getTeamMembers();\r
- List<Person> temp = new ArrayList<Person>();\r
- for (Person member:members){\r
- temp.add(member);\r
- }\r
- for (Person member: temp){\r
- members.remove(member);\r
- }\r
- }\r
- saveOrUpdate(base);\r
-\r
- dao.delete(base);\r
-\r
- }\r
-\r
- return result;\r
- }\r
-\r
- @Override\r
- public DeleteResult delete(AgentBase agent){\r
- return delete(agent.getUuid());\r
- }\r
-\r
- @Override\r
- public Person convertTeam2Person(Team team) throws MergeException {\r
- Person result = null;\r
- team = CdmBase.deproxy(team, Team.class);\r
- if (team.getTeamMembers().size() > 1){\r
- throw new IllegalArgumentException("Team must not have more than 1 member to be convertable into a person");\r
- }else if (team.getTeamMembers().size() == 1){\r
- result = team.getTeamMembers().get(0);\r
- IMergeStrategy strategy = DefaultMergeStrategy.NewInstance(TeamOrPersonBase.class);\r
- strategy.setDefaultCollectionMergeMode(MergeMode.FIRST);\r
- genericDao.merge(result, team, strategy);\r
- }else if (team.getTeamMembers().isEmpty()){\r
- result = Person.NewInstance();\r
- genericDao.save(result);\r
- IMergeStrategy strategy = DefaultMergeStrategy.NewInstance(TeamOrPersonBase.class);\r
- strategy.setDefaultMergeMode(MergeMode.SECOND);\r
- strategy.setDefaultCollectionMergeMode(MergeMode.SECOND);\r
- genericDao.merge(result, team, strategy);\r
- }else{\r
- throw new IllegalStateException("Unhandled state of team members collection");\r
- }\r
-\r
- return result;\r
- }\r
-\r
- @Override\r
- public Team convertPerson2Team(Person person) throws MergeException, IllegalArgumentException {\r
- Team team = Team.NewInstance();\r
- ConvertMergeStrategy strategy = ConvertMergeStrategy.NewInstance(TeamOrPersonBase.class);\r
- strategy.setDefaultMergeMode(MergeMode.SECOND);\r
- strategy.setDefaultCollectionMergeMode(MergeMode.SECOND);\r
- strategy.setDeleteSecondObject(false);\r
-\r
-\r
- if (! genericDao.isMergeable(team, person, strategy)){\r
- throw new MergeException("Person can not be transformed into team.");\r
- }\r
- try {\r
- this.save(team);\r
- team.setProtectedNomenclaturalTitleCache(true);\r
- genericDao.merge(team, person, strategy);\r
- team.addTeamMember(person);\r
- this.save(team);\r
-// team.setNomenclaturalTitle(person.getNomenclaturalTitle(), true);\r
- } catch (Exception e) {\r
- throw new MergeException("Unhandled merge exception", e);\r
- }\r
- return team;\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 void updateTitleCache(Class<? extends AgentBase> clazz, Integer stepSize, IIdentifiableEntityCacheStrategy<AgentBase> cacheStrategy, IProgressMonitor monitor) {
+ if (clazz == null){
+ clazz = AgentBase.class;
+ }
+ super.updateTitleCacheImpl(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(limit, pattern, Institution.class);
+ }
+
+ @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(Integer limit, String pattern, Class clazz) {
+ return dao.getUuidAndAbbrevTitleCache(null, pattern, clazz);
+ }
+
+}
BGBM BDI Projects / cdmlib.git / blobdiff