org.argeo.slc.server/src/main/java/org/argeo/slc/ws/process/SlcExecutionRequestEp.java

   1 package org.argeo.slc.ws.process;
   2
   3 import org.apache.commons.logging.Log;
   4 import org.apache.commons.logging.LogFactory;
   5 import org.argeo.slc.core.process.SlcExecution;
   6 import org.argeo.slc.dao.process.SlcExecutionDao;
   7 import org.argeo.slc.msg.process.SlcExecutionRequest;
   8 import org.springframework.ws.server.endpoint.AbstractMarshallingPayloadEndpoint;
   9
  10 public class SlcExecutionRequestEp extends AbstractMarshallingPayloadEndpoint {
  11
  12         private Log log = LogFactory.getLog(getClass());
  13
  14         private final SlcExecutionDao slcExecutionDao;
  15
  16         public SlcExecutionRequestEp(SlcExecutionDao slcExecutionDao) {
  17                 this.slcExecutionDao = slcExecutionDao;
  18         }
  19
  20         @Override
  21         protected Object invokeInternal(Object requestObject) throws Exception {
  22                 SlcExecutionRequest msg = (SlcExecutionRequest) requestObject;
  23                 SlcExecution slcExecution = msg.getSlcExecution();
  24
  25                 if (slcExecutionDao.getSlcExecution(slcExecution.getUuid()) == null) {
  26                         slcExecutionDao.create(slcExecution);
  27
  28                         if (log.isDebugEnabled())
  29                                 log.debug("Created SlcExecution with uuid "
  30                                                 + slcExecution.getUuid());
  31                 } else {
  32                         slcExecutionDao.update(slcExecution);
  33
  34                         if (log.isDebugEnabled())
  35                                 log.debug("Updated SlcExecution with uuid "
  36                                                 + slcExecution.getUuid());
  37                 }
  38                 return null;
  39         }
  40
  41 }