[Cse-ip-svn-commits] SF.net SVN: cse-ip:[156] trunk/cse-ip/sc-cdmm/src/main/java/de/campussource /cse/cdmm/DataModelManagerBean.java

[<ro...@us...>]

Revision: 156
          http://cse-ip.svn.sourceforge.net/cse-ip/?rev=156&view=rev
Author:   roekens
Date:     2009-04-22 09:53:14 +0000 (Wed, 22 Apr 2009)

Log Message:
-----------
further implementation of DataModelManagerBean

Modified Paths:
--------------
    trunk/cse-ip/sc-cdmm/src/main/java/de/campussource/cse/cdmm/DataModelManagerBean.java

Modified: trunk/cse-ip/sc-cdmm/src/main/java/de/campussource/cse/cdmm/DataModelManagerBean.java
===================================================================
--- trunk/cse-ip/sc-cdmm/src/main/java/de/campussource/cse/cdmm/DataModelManagerBean.java	2009-04-22 09:39:33 UTC (rev 155)
+++ trunk/cse-ip/sc-cdmm/src/main/java/de/campussource/cse/cdmm/DataModelManagerBean.java	2009-04-22 09:53:14 UTC (rev 156)
@@ -51,6 +51,10 @@
 		} catch (ServiceComponentException e1) {
 			//do nothing
 		}
+		//check if event time is before entity state time 
+		if (loadedCourse == null || loadedCourse.getDate().after(courseMessage.getEventTime())){
+			return events;
+		}
 		
 		//handle different inputEvents
 		if (courseMessage.getInputEvent()==InputEventType.CREATE_UPDATE){
@@ -58,6 +62,7 @@
 			EventMessage eventMessage = new EventMessage();
 			Course course = courseMessage.getCourse();
 			course.setState(State.EXISTS);
+			course.setDate(courseMessage.getEventTime());
 			eventMessage.setEntity(course);
 			try {
 				courseDao.persist(course);
@@ -91,8 +96,13 @@
 		} else if (courseMessage.getInputEvent()==InputEventType.DELETE){
 			return deleteCourse(courseMessage);
 		} else if (courseMessage.getInputEvent()==InputEventType.CREATE_BY_REFERENCE){
-			//NOT_EXISTS
-			//KNOWN
+			Course knownCourse = courseMessage.getCourse();
+			knownCourse.setState(State.KNOWN);
+			try {
+				courseDao.persist(knownCourse);
+			} catch (ServiceComponentException e) {
+				// TODO handle me
+			}
 		}
 		
 		
@@ -101,6 +111,7 @@
 
 	private void createByReference(Category category) {
 		try {
+			@SuppressWarnings("unused")
 			Category loadedCategory = categoryDao.find(category.getId());
 		} catch (ServiceComponentException e) {
 			CategoryMessage cm = new CategoryMessage();
@@ -113,6 +124,7 @@
 
 	private void createByReference(Course course) {
 		try {
+			@SuppressWarnings("unused")
 			Course loadedCourse = courseDao.find(course.getId());
 		} catch (ServiceComponentException e) {
 			CourseMessage cm = new CourseMessage();


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.