import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public RTTEventVoCollection getRTTByEventAndStatus(EventRefVo voRef, PreActiveActiveInactiveStatus status)
{
	DomainFactory factory = getDomainFactory();
	ArrayList markers = new ArrayList();
	ArrayList values = new ArrayList();
	
	String query = "select ere.rTTEvent from EventRTTEvent as ere where ere.event.id = :idEvent";
	markers.add("idEvent");
	values.add(voRef.getID_Event());
	
	if (status != null)
	{
		query += " and ere.status = :status";
		markers.add("status");
		values.add(getDomLookup(status));
	}
	
	List rtts = factory.find(query, markers, values);
	return RTTEventVoAssembler.createRTTEventVoCollectionFromRTTEvent(rtts); 
}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
public RTTEventRefVoCollection listRTTMappingsForPathwayTarget(PathwayTargetRefVo pt)
{
	if(pt.getID_PathwayTarget() == null)
		throw new CodingRuntimeException("pathwaytarget id is null in method listRTTMappingsForPathwayTarget");
	
	DomainFactory factory = getDomainFactory();
	List rttEvents =  factory.find("select ptre.rTTEvent from PathwayTargetRTTEvent as ptre where ptre.pathwayTarget.id = :idPathwayTarget", new String[] {"idPathwayTarget"}, new Object[] { pt.getID_PathwayTarget()});
	return RTTEventVoAssembler.createRTTEventVoCollectionFromRTTEvent(rttEvents).toRefVoCollection();
}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
public RTTEventVo getRttMapping(RTTEventVo rttEvent) throws DomainInterfaceException
{
	DomainFactory factory = getDomainFactory();
	
	StringBuffer hql = new StringBuffer(" from RTTEvent ev where ev.providerSystem.id = :providerSystem ");
	
	ArrayList<String> labels = new ArrayList<String>();
	ArrayList<Object> values = new ArrayList<Object>();
	labels.add("providerSystem");
	values.add(rttEvent.getProviderSystem().getID_ProviderSystem());

	if (rttEvent.getPASCodeIsNotNull())
	{
		labels.add("pasCode");
		values.add(rttEvent.getPASCode());
		hql.append(" and ev.pASCode = :pasCode");
	}
	else if (rttEvent.getNationalCodeIsNotNull())
	{
		hql.append(" and ev.nationalCode = :nationalCode");
		labels.add("nationalCode");
		values.add(rttEvent.getNationalCode());
	}
	
	List lst = factory.find(hql.toString(), labels, values);
	if (lst != null && lst.size() > 1)
	{
		throw new DomainInterfaceException("Duplicate data found when searching event by RttValues - PASCODE=" + rttEvent.getPASCode());
	}
	else if (lst != null && lst.size() == 1)
	{
		// Unique, so only one should be found??
		return RTTEventVoAssembler.create((RTTEvent) lst.get(0));
	}
	
	return null;

}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
public RTTEventVo getRTTEventByPASCode(String code)
{
	if (code == null)
		throw new DomainRuntimeException("Cannot get RTTEventVo for null PAS code");

	DomainFactory factory = getDomainFactory();
	RTTEvent result = RTTEvent.getRTTEventFromPASCode(factory, code);
	return RTTEventVoAssembler.create(result);
}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
/**
* getRTTEvent
*/
public ims.pathways.vo.RTTEventVo getRTTEvent(ims.pathways.configuration.vo.RTTEventRefVo rtteventRefVo)
{
	if(rtteventRefVo == null)
		throw new RuntimeException("Cannot get RTTEventVo for null RTTEventRefVo");
	
	return RTTEventVoAssembler.create((RTTEvent)getDomainFactory().getDomainObject(RTTEvent.class, rtteventRefVo.getID_RTTEvent()));
}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
public RTTEventVo saveRTTEvent(RTTEventVo rtteventVo) throws StaleObjectException, UniqueKeyViolationException 
{
	if(rtteventVo == null)
		throw new RuntimeException("Cannot save null RTTEventVo");
	
	if(rtteventVo.isValidated() == false)
		throw new CodingRuntimeException("RTTEventVo is not validated");
		
	DomainFactory factory = getDomainFactory();

	if (!rtteventVo.getID_RTTEventIsNotNull())
	{
		List l = factory.find("from RTTEvent rtt where upperName = :rttName", new String[]{"rttName"}, new Object[]{rtteventVo.getName().toUpperCase()});
		if (l.size() > 0)
			throw new UniqueKeyViolationException("RTT Event record called \"" + rtteventVo.getName() + "\" already exists. Duplicates not allowed.");

		List listPasCode = factory.find("from RTTEvent rtt where pASCode = :pascode", new String[]{"pascode"}, new Object[]{rtteventVo.getPASCode()});
		if (listPasCode.size() > 0)
			throw new UniqueKeyViolationException("RTT Event record with External System code \"" + rtteventVo.getPASCode() + "\" already exists. Duplicates not allowed.");
	}

	RTTEvent doRTTEvent = RTTEventVoAssembler.extractRTTEvent(factory, rtteventVo);
	doRTTEvent.setUpperName(rtteventVo.getName().toUpperCase());
	try 
	{
		factory.save(doRTTEvent);
	}
	catch (UnqViolationUncheckedException e)
	{
		throw new UniqueKeyViolationException("An RTT Event with this name already exists, Please change", e);			
	}
	
	return RTTEventVoAssembler.create(doRTTEvent);
}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
public RTTEventVoCollection getNameByProviderSystems(ProviderSystemRefVo voRef)
{
	return RTTEventVoAssembler.createRTTEventVoCollectionFromRTTEvent(getDomainFactory().find("from RTTEvent as rtt where rtt.providerSystem.id = :id ", new String[]{"id"}, new Object[]{voRef.getID_ProviderSystem()}));
}
 

import ims.pathways.vo.domain.RTTEventVoAssembler; //导入依赖的package包/类
/**
* listRTTEvents
*/
public ims.pathways.vo.RTTEventVoCollection listRTTEvents(ims.pathways.vo.RTTEventVo rttEventVo)
{
	DomainFactory factory = getDomainFactory();
	StringBuffer hql = new StringBuffer(" ");
	String query = "from RTTEvent rtt ";
	ArrayList markers = new ArrayList();
	ArrayList values = new ArrayList();
	String andStr = " ";
	
	if (rttEventVo.getActionIsNotNull())
	{
		hql.append(andStr + " rtt.action = :id_action");
		markers.add("id_action");
		values.add(getDomLookup(rttEventVo.getAction()));			
		andStr = " and ";
	}
	if (rttEventVo.getNameIsNotNull())
	{
		hql.append(andStr + " rtt.upperName like :name");
		markers.add("name");
		values.add(rttEventVo.getName().toUpperCase() + "%");
		andStr = " and ";
	}
	if (rttEventVo.getPASCodeIsNotNull())
	{
		hql.append(andStr + " rtt.pASCode = :id_PASCode");
		markers.add("id_PASCode");
		values.add(rttEventVo.getPASCode());			
		andStr = " and ";
	}
	if (rttEventVo.getNationalCodeIsNotNull())
	{
		hql.append(andStr + " rtt.nationalCode = :id_NCode");
		markers.add("id_NCode");
		values.add(rttEventVo.getNationalCode());			
		andStr = " and ";
	}
	
	
	if (andStr == " and ")
		query += " where ";
	hql.append(" order by rtt.providerSystem.id asc, rtt.upperName asc");
	
	query += hql.toString();

	List rttList = factory.find(query, markers, values);
	
	return RTTEventVoAssembler.createRTTEventVoCollectionFromRTTEvent(rttList); 
}