Menu
▾
▴
[Cse-ip-svn-commits] SF.net SVN: cse-ip:[166] trunk/cse-ip/sc-cdmm/src/main/java/de/campussource /cse/cdmm/DataModelManagerBean.java
|
From: <ro...@us...> - 2009-04-23 13:29:16
|
Revision: 166
http://cse-ip.svn.sourceforge.net/cse-ip/?rev=166&view=rev
Author: roekens
Date: 2009-04-23 13:28:38 +0000 (Thu, 23 Apr 2009)
Log Message:
-----------
added logs to catch blocks
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-23 12:32:27 UTC (rev 165)
+++ trunk/cse-ip/sc-cdmm/src/main/java/de/campussource/cse/cdmm/DataModelManagerBean.java 2009-04-23 13:28:38 UTC (rev 166)
@@ -12,6 +12,8 @@
import javax.jws.WebResult;
import javax.jws.WebService;
+import org.apache.log4j.Logger;
+
import de.campussource.cse.cdmm.dao.*;
import de.campussource.cse.cdmm.domain.Account;
import de.campussource.cse.cdmm.domain.Category;
@@ -23,112 +25,124 @@
/**
* Service bean for CDMM package
+ *
* @author Sebastian Roekens
- *
+ *
*/
@Stateless
-@Remote(value=DataModelManager.class)
-@WebService(name="DataModelManager", targetNamespace="http://cse.campussource.de/cdmm")
+@Remote(value = DataModelManager.class)
+@WebService(name = "DataModelManager", targetNamespace = "http://cse.campussource.de/cdmm")
public class DataModelManagerBean implements DataModelManager {
-
+
@EJB
private CategoryDao categoryDao;
-
+
@EJB
private CourseDao courseDao;
-
+
@EJB
private RoleDao roleDao;
-
+
@EJB
private AccountDao accountDao;
-
+
@EJB
private GroupDao groupDao;
-
+
+ private static final Logger logger = Logger
+ .getLogger(DataModelManagerBean.class);
+
@Override
- @WebMethod(action="createOrUpdateCategory")
- @WebResult(name="EventMessages")
+ @WebMethod(action = "createOrUpdateCategory")
+ @WebResult(name = "EventMessages")
public List<EventMessage> createOrUpdateCategory(
- @WebParam(name="CategoryMessage") CategoryMessage categoryMessage) {
-
- //init eventMessageList
- List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
- State state = null;
- Category loadedCategory = null;
+ @WebParam(name = "CategoryMessage") CategoryMessage categoryMessage) {
+
+ // init eventMessageList
+ List<EventMessage> events = new ArrayList<EventMessage>();
+ // get state of given object in persistence
+ State state = null;
+ Category loadedCategory = null;
+ try {
+ loadedCategory = categoryDao.find(categoryMessage.getCategory()
+ .getId());
+ state = loadedCategory.getState();
+ } catch (ServiceComponentException e1) {
+ logger.debug(e1);
+ logger.debug(e1.getMessage());
+ logger.debug(e1);
+ logger.debug(e1.getMessage()); // do nothing
+ }
+ // check if event time is before entity state time
+ if (loadedCategory == null
+ || loadedCategory.getDate().after(
+ categoryMessage.getEventTime())) {
+ return events;
+ }
+
+ // handle different inputEvents
+ if (categoryMessage.getInputEvent() == InputEventType.CREATE_UPDATE) {
+ // handle different states of entity
+ EventMessage eventMessage = new EventMessage();
+ Category category = categoryMessage.getCategory();
+ category.setState(State.EXISTS);
+ category.setDate(categoryMessage.getEventTime());
+ eventMessage.setEntity(category);
try {
- loadedCategory = categoryDao.find(categoryMessage.getCategory().getId());
- state=loadedCategory.getState();
- } catch (ServiceComponentException e1) {
- //do nothing
+ categoryDao.persist(category);
+ } catch (ServiceComponentException e) {
+ // TODO handle me
}
- //check if event time is before entity state time
- if (loadedCategory == null || loadedCategory.getDate().after(categoryMessage.getEventTime())){
- return events;
+ if (state == State.EXISTS) {
+ eventMessage.setOutputEvent(OutputEventType.UPDATE);
+ } else {
+ eventMessage.setOutputEvent(OutputEventType.CREATE);
}
-
- //handle different inputEvents
- if (categoryMessage.getInputEvent()==InputEventType.CREATE_UPDATE){
- //handle different states of entity
- EventMessage eventMessage = new EventMessage();
- Category category = categoryMessage.getCategory();
- category.setState(State.EXISTS);
- category.setDate(categoryMessage.getEventTime());
- eventMessage.setEntity(category);
- try {
- categoryDao.persist(category);
- } catch (ServiceComponentException e) {
- //TODO handle me
- }
- if (state==State.EXISTS){
- eventMessage.setOutputEvent(OutputEventType.UPDATE);
- } else {
- eventMessage.setOutputEvent(OutputEventType.CREATE);
- }
- eventMessage.setEventTime(new Date());
- events.add(eventMessage);
-
- createReferences(category);
-
- } else if (categoryMessage.getInputEvent()==InputEventType.DELETE){
- return deleteCategory(categoryMessage);
- } else if (categoryMessage.getInputEvent()==InputEventType.CREATE_BY_REFERENCE){
- Category knownCategory = categoryMessage.getCategory();
- knownCategory.setState(State.KNOWN);
- try {
- categoryDao.persist(knownCategory);
- } catch (ServiceComponentException e) {
- // TODO handle me
- }
+ eventMessage.setEventTime(new Date());
+ events.add(eventMessage);
+
+ createReferences(category);
+
+ } else if (categoryMessage.getInputEvent() == InputEventType.DELETE) {
+ return deleteCategory(categoryMessage);
+ } else if (categoryMessage.getInputEvent() == InputEventType.CREATE_BY_REFERENCE) {
+ Category knownCategory = categoryMessage.getCategory();
+ knownCategory.setState(State.KNOWN);
+ try {
+ categoryDao.persist(knownCategory);
+ } catch (ServiceComponentException e) {
+ // TODO handle me
}
- return events;
+ }
+ return events;
}
@Override
- @WebMethod(action="createOrUpdateCourse")
- @WebResult(name="EventMessages")
+ @WebMethod(action = "createOrUpdateCourse")
+ @WebResult(name = "EventMessages")
public List<EventMessage> createOrUpdateCourse(
- @WebParam(name="CourseMessage") CourseMessage courseMessage) {
- //init eventMessageList
+ @WebParam(name = "CourseMessage") CourseMessage courseMessage) {
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
- State state = null;
+ // get state of given object in persistence
+ State state = null;
Course loadedCourse = null;
try {
loadedCourse = courseDao.find(courseMessage.getCourse().getId());
- state=loadedCourse.getState();
+ state = loadedCourse.getState();
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage()); // do nothing
}
- //check if event time is before entity state time
- if (loadedCourse == null || loadedCourse.getDate().after(courseMessage.getEventTime())){
+ // 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){
- //handle different states of entity
+
+ // handle different inputEvents
+ if (courseMessage.getInputEvent() == InputEventType.CREATE_UPDATE) {
+ // handle different states of entity
EventMessage eventMessage = new EventMessage();
Course course = courseMessage.getCourse();
course.setState(State.EXISTS);
@@ -137,26 +151,28 @@
try {
courseDao.persist(course);
} catch (ServiceComponentException e) {
- //TODO handle me
+ // TODO handle me
}
- if (state==State.EXISTS){
+ if (state == State.EXISTS) {
eventMessage.setOutputEvent(OutputEventType.UPDATE);
} else {
eventMessage.setOutputEvent(OutputEventType.CREATE);
}
eventMessage.setEventTime(new Date());
events.add(eventMessage);
-
+
createReferences(course);
-
- } else if (courseMessage.getInputEvent()==InputEventType.DELETE){
+
+ } else if (courseMessage.getInputEvent() == InputEventType.DELETE) {
return deleteCourse(courseMessage);
- } else if (courseMessage.getInputEvent()==InputEventType.CREATE_BY_REFERENCE){
+ } else if (courseMessage.getInputEvent() == InputEventType.CREATE_BY_REFERENCE) {
Course knownCourse = courseMessage.getCourse();
knownCourse.setState(State.KNOWN);
try {
courseDao.persist(knownCourse);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
}
@@ -164,69 +180,69 @@
}
private void createReferences(Course course) {
- //traverse associated objects and create them
- //categories
- for (Category category : course.getCategories()){
- createByReference(category);
- }
- //workgroups
- for (Course workgroup : course.getWorkgroups()){
- createByReference(workgroup);
- }
- //parent
- createByReference(course.getParent());
- //roles
- for (Role role : course.getRoles()){
- createByReference(role);
- }
+ // traverse associated objects and create them
+ // categories
+ for (Category category : course.getCategories()) {
+ createByReference(category);
+ }
+ // workgroups
+ for (Course workgroup : course.getWorkgroups()) {
+ createByReference(workgroup);
+ }
+ // parent
+ createByReference(course.getParent());
+ // roles
+ for (Role role : course.getRoles()) {
+ createByReference(role);
+ }
}
private void createReferences(Role role) {
- //traverse associated objects and create them
- //course
+ // traverse associated objects and create them
+ // course
createByReference(role.getCourse());
- //account
+ // account
createByReference(role.getAccount());
}
-
+
private void createReferences(Category category) {
- //traverse associated objects and create them
- //categories
- for (Category child : category.getChildren()){
+ // traverse associated objects and create them
+ // categories
+ for (Category child : category.getChildren()) {
createByReference(child);
}
- //courses
- for (Course course : category.getCourses()){
+ // courses
+ for (Course course : category.getCourses()) {
createByReference(course);
}
- //parent
+ // parent
createByReference(category.getParent());
}
-
+
private void createReferences(Account account) {
- //traverse associated objects and create them
- //roles
- for (Role role : account.getRoles()){
+ // traverse associated objects and create them
+ // roles
+ for (Role role : account.getRoles()) {
createByReference(role);
}
- //groups
- for (Group group : account.getGroups()){
+ // groups
+ for (Group group : account.getGroups()) {
createByReference(group);
}
}
private void createReferences(Group group) {
- //traverse associated objects and create them
- //roles
- for (Role role : group.getRoles()){
+ // traverse associated objects and create them
+ // roles
+ for (Role role : group.getRoles()) {
createByReference(role);
}
- //accounts
- for (Account account : group.getMembers()){
+ // accounts
+ for (Account account : group.getMembers()) {
createByReference(account);
}
}
-
+
private void createByReference(Category category) {
try {
@SuppressWarnings("unused")
@@ -278,7 +294,7 @@
createOrUpdateAccount(am);
}
}
-
+
private void createByReference(Role role) {
try {
@SuppressWarnings("unused")
@@ -291,26 +307,29 @@
createOrUpdateRole(rm);
}
}
-
@Override
public List<EventMessage> deleteCategory(CategoryMessage categoryMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
+ // get state of given object in persistence
Category loadedCategory = null;
try {
- loadedCategory = categoryDao.find(categoryMessage.getCategory().getId());
+ loadedCategory = categoryDao.find(categoryMessage.getCategory()
+ .getId());
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage()); // do nothing
}
loadedCategory.setState(State.DELETED);
try {
categoryDao.persist(loadedCategory);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
-
+
EventMessage em = new EventMessage();
em.setEntity(loadedCategory);
em.setEventTime(new Date());
@@ -321,22 +340,25 @@
@Override
public List<EventMessage> deleteCourse(CourseMessage courseMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
+ // get state of given object in persistence
Course loadedCourse = null;
try {
loadedCourse = courseDao.find(courseMessage.getCourse().getId());
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage()); // do nothing
}
loadedCourse.setState(State.DELETED);
try {
courseDao.persist(loadedCourse);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
-
+
EventMessage em = new EventMessage();
em.setEntity(loadedCourse);
em.setEventTime(new Date());
@@ -349,25 +371,28 @@
public List<EventMessage> createOrUpdateAccount(
AccountMessage accountMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
- State state = null;
+ // get state of given object in persistence
+ State state = null;
Account loadedAccount = null;
try {
- loadedAccount = accountDao.find(accountMessage.getAccount().getId());
- state=loadedAccount.getState();
+ loadedAccount = accountDao
+ .find(accountMessage.getAccount().getId());
+ state = loadedAccount.getState();
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage()); // do nothing
}
- //check if event time is before entity state time
- if (loadedAccount == null || loadedAccount.getDate().after(accountMessage.getEventTime())){
+ // check if event time is before entity state time
+ if (loadedAccount == null
+ || loadedAccount.getDate().after(accountMessage.getEventTime())) {
return events;
}
-
- //handle different inputEvents
- if (accountMessage.getInputEvent()==InputEventType.CREATE_UPDATE){
- //handle different states of entity
+
+ // handle different inputEvents
+ if (accountMessage.getInputEvent() == InputEventType.CREATE_UPDATE) {
+ // handle different states of entity
EventMessage eventMessage = new EventMessage();
Account account = accountMessage.getAccount();
account.setState(State.EXISTS);
@@ -376,26 +401,29 @@
try {
accountDao.persist(account);
} catch (ServiceComponentException e) {
- //TODO handle me
+ logger.debug(e);
+ logger.debug(e.getMessage());
+ // TODO handle me
}
- if (state==State.EXISTS){
+ if (state == State.EXISTS) {
eventMessage.setOutputEvent(OutputEventType.UPDATE);
} else {
eventMessage.setOutputEvent(OutputEventType.CREATE);
}
eventMessage.setEventTime(new Date());
events.add(eventMessage);
-
+
createReferences(account);
-
- } else if (accountMessage.getInputEvent()==InputEventType.DELETE){
+
+ } else if (accountMessage.getInputEvent() == InputEventType.DELETE) {
return deleteAccount(accountMessage);
- } else if (accountMessage.getInputEvent()==InputEventType.CREATE_BY_REFERENCE){
+ } else if (accountMessage.getInputEvent() == InputEventType.CREATE_BY_REFERENCE) {
Account knownAccount = accountMessage.getAccount();
knownAccount.setState(State.KNOWN);
try {
accountDao.persist(knownAccount);
} catch (ServiceComponentException e) {
+ logger.debug(e); logger.debug(e.getMessage());
// TODO handle me
}
}
@@ -404,25 +432,28 @@
@Override
public List<EventMessage> createOrUpdateGroup(GroupMessage groupMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
- State state = null;
+ // get state of given object in persistence
+ State state = null;
Group loadedGroup = null;
try {
loadedGroup = groupDao.find(groupMessage.getGroup().getId());
- state=loadedGroup.getState();
+ state = loadedGroup.getState();
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage());
+ // do nothing
}
- //check if event time is before entity state time
- if (loadedGroup == null || loadedGroup.getDate().after(groupMessage.getEventTime())){
+ // check if event time is before entity state time
+ if (loadedGroup == null
+ || loadedGroup.getDate().after(groupMessage.getEventTime())) {
return events;
}
-
- //handle different inputEvents
- if (groupMessage.getInputEvent()==InputEventType.CREATE_UPDATE){
- //handle different states of entity
+
+ // handle different inputEvents
+ if (groupMessage.getInputEvent() == InputEventType.CREATE_UPDATE) {
+ // handle different states of entity
EventMessage eventMessage = new EventMessage();
Group group = groupMessage.getGroup();
group.setState(State.EXISTS);
@@ -431,26 +462,30 @@
try {
groupDao.persist(group);
} catch (ServiceComponentException e) {
- //TODO handle me
+ logger.debug(e);
+ logger.debug(e.getMessage());
+ // TODO handle me
}
- if (state==State.EXISTS){
+ if (state == State.EXISTS) {
eventMessage.setOutputEvent(OutputEventType.UPDATE);
} else {
eventMessage.setOutputEvent(OutputEventType.CREATE);
}
eventMessage.setEventTime(new Date());
events.add(eventMessage);
-
+
createReferences(group);
-
- } else if (groupMessage.getInputEvent()==InputEventType.DELETE){
+
+ } else if (groupMessage.getInputEvent() == InputEventType.DELETE) {
return deleteGroup(groupMessage);
- } else if (groupMessage.getInputEvent()==InputEventType.CREATE_BY_REFERENCE){
+ } else if (groupMessage.getInputEvent() == InputEventType.CREATE_BY_REFERENCE) {
Group knownGroup = groupMessage.getGroup();
knownGroup.setState(State.KNOWN);
try {
groupDao.persist(knownGroup);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
}
@@ -459,25 +494,28 @@
@Override
public List<EventMessage> createOrUpdateRole(RoleMessage roleMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
- State state = null;
+ // get state of given object in persistence
+ State state = null;
Role loadedRole = null;
try {
loadedRole = roleDao.find(roleMessage.getRole().getId());
- state=loadedRole.getState();
+ state = loadedRole.getState();
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage());
+ // do nothing
}
- //check if event time is before entity state time
- if (loadedRole == null || loadedRole.getDate().after(roleMessage.getEventTime())){
+ // check if event time is before entity state time
+ if (loadedRole == null
+ || loadedRole.getDate().after(roleMessage.getEventTime())) {
return events;
}
-
- //handle different inputEvents
- if (roleMessage.getInputEvent()==InputEventType.CREATE_UPDATE){
- //handle different states of entity
+
+ // handle different inputEvents
+ if (roleMessage.getInputEvent() == InputEventType.CREATE_UPDATE) {
+ // handle different states of entity
EventMessage eventMessage = new EventMessage();
Role role = roleMessage.getRole();
role.setState(State.EXISTS);
@@ -486,26 +524,30 @@
try {
roleDao.persist(role);
} catch (ServiceComponentException e) {
- //TODO handle me
+ logger.debug(e);
+ logger.debug(e.getMessage());
+ // TODO handle me
}
- if (state==State.EXISTS){
+ if (state == State.EXISTS) {
eventMessage.setOutputEvent(OutputEventType.UPDATE);
} else {
eventMessage.setOutputEvent(OutputEventType.CREATE);
}
eventMessage.setEventTime(new Date());
events.add(eventMessage);
-
+
createReferences(role);
-
- } else if (roleMessage.getInputEvent()==InputEventType.DELETE){
+
+ } else if (roleMessage.getInputEvent() == InputEventType.DELETE) {
return deleteRole(roleMessage);
- } else if (roleMessage.getInputEvent()==InputEventType.CREATE_BY_REFERENCE){
+ } else if (roleMessage.getInputEvent() == InputEventType.CREATE_BY_REFERENCE) {
Role knownRole = roleMessage.getRole();
knownRole.setState(State.KNOWN);
try {
roleDao.persist(knownRole);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
}
@@ -514,22 +556,27 @@
@Override
public List<EventMessage> deleteAccount(AccountMessage accountMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
+ // get state of given object in persistence
Account loadedAccount = null;
try {
- loadedAccount = accountDao.find(accountMessage.getAccount().getId());
+ loadedAccount = accountDao
+ .find(accountMessage.getAccount().getId());
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage());
+ // do nothing
}
loadedAccount.setState(State.DELETED);
try {
accountDao.persist(loadedAccount);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
-
+
EventMessage em = new EventMessage();
em.setEntity(loadedAccount);
em.setEventTime(new Date());
@@ -540,22 +587,25 @@
@Override
public List<EventMessage> deleteGroup(GroupMessage groupMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
+ // get state of given object in persistence
Group loadedGroup = null;
try {
loadedGroup = groupDao.find(groupMessage.getGroup().getId());
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage());
+ // do nothing
}
loadedGroup.setState(State.DELETED);
try {
groupDao.persist(loadedGroup);
} catch (ServiceComponentException e) {
+ logger.debug(e); logger.debug(e.getMessage());
// TODO handle me
}
-
+
EventMessage em = new EventMessage();
em.setEntity(loadedGroup);
em.setEventTime(new Date());
@@ -566,22 +616,26 @@
@Override
public List<EventMessage> deleteRole(RoleMessage roleMessage) {
- //init eventMessageList
+ // init eventMessageList
List<EventMessage> events = new ArrayList<EventMessage>();
- //get state of given object in persistence
+ // get state of given object in persistence
Role loadedRole = null;
try {
loadedRole = roleDao.find(roleMessage.getRole().getId());
} catch (ServiceComponentException e1) {
- //do nothing
+ logger.debug(e1);
+ logger.debug(e1.getMessage());
+ // do nothing
}
loadedRole.setState(State.DELETED);
try {
roleDao.persist(loadedRole);
} catch (ServiceComponentException e) {
+ logger.debug(e);
+ logger.debug(e.getMessage());
// TODO handle me
}
-
+
EventMessage em = new EventMessage();
em.setEntity(loadedRole);
em.setEventTime(new Date());
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
