X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.slc.server%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fws%2Fprocess%2FSlcExecutionRequestEp.java;h=e9e63da0fc4b16493e047f8ef5cad3dd63c0827e;hb=bf3678f8b4d6dbd9965a27632fe6bb39db689c9a;hp=3c41d9afd5e7d706885a3328a80ccbfd98fec96e;hpb=c21f3ae9746cd2bbc81dad813e9e590300433a52;p=gpl%2Fargeo-slc.git diff --git a/org.argeo.slc.server/src/main/java/org/argeo/slc/ws/process/SlcExecutionRequestEp.java b/org.argeo.slc.server/src/main/java/org/argeo/slc/ws/process/SlcExecutionRequestEp.java index 3c41d9afd..e9e63da0f 100644 --- a/org.argeo.slc.server/src/main/java/org/argeo/slc/ws/process/SlcExecutionRequestEp.java +++ b/org.argeo.slc.server/src/main/java/org/argeo/slc/ws/process/SlcExecutionRequestEp.java @@ -26,20 +26,21 @@ public class SlcExecutionRequestEp extends AbstractMarshallingPayloadEndpoint { if (requestObject instanceof SlcExecutionRequest) { SlcExecutionRequest msg = (SlcExecutionRequest) requestObject; - SlcExecution slcExecution = msg.getSlcExecution(); + SlcExecution slcExecutionMsg = msg.getSlcExecution(); - if (slcExecutionDao.getSlcExecution(slcExecution.getUuid()) == null) { - if (log.isDebugEnabled()) - log.debug("Creating SLC execution #" - + slcExecution.getUuid()); + SlcExecution slcExecutionPersisted = slcExecutionDao.getSlcExecution(slcExecutionMsg.getUuid()); + if (slcExecutionPersisted == null) { + if (log.isTraceEnabled()) + log.trace("Creating SLC execution #" + + slcExecutionMsg.getUuid()); - slcExecutionDao.create(slcExecution); + slcExecutionDao.create(slcExecutionMsg); } else { - if (log.isDebugEnabled()) - log.debug("Updating SLC execution #" - + slcExecution.getUuid()); + if (log.isTraceEnabled()) + log.trace("Updating SLC execution #" + + slcExecutionMsg.getUuid()); - slcExecutionDao.update(slcExecution); + slcExecutionDao.merge(slcExecutionMsg); } return null; @@ -52,6 +53,11 @@ public class SlcExecutionRequestEp extends AbstractMarshallingPayloadEndpoint { + msg.getSlcExecutionUuid()); slcExecution.setStatus(msg.getNewStatus()); + + if (log.isTraceEnabled()) + log.trace("Updating status for SLC execution #" + + slcExecution.getUuid()); + slcExecutionDao.update(slcExecution); return null; } else { @@ -59,5 +65,4 @@ public class SlcExecutionRequestEp extends AbstractMarshallingPayloadEndpoint { + requestObject.getClass()); } } - }