diff --git a/o2server/x_processplatform_assemble_surface/src/main/java/com/x/processplatform/assemble/surface/jaxrs/task/ActionProcessing.java b/o2server/x_processplatform_assemble_surface/src/main/java/com/x/processplatform/assemble/surface/jaxrs/task/ActionProcessing.java index 1f2b475a2a946922f862f1c43e541d16d3d2f905..0b30a82e3b5b361664b8fce1a6eac337420e1179 100644 --- a/o2server/x_processplatform_assemble_surface/src/main/java/com/x/processplatform/assemble/surface/jaxrs/task/ActionProcessing.java +++ b/o2server/x_processplatform_assemble_surface/src/main/java/com/x/processplatform/assemble/surface/jaxrs/task/ActionProcessing.java @@ -330,13 +330,20 @@ class ActionProcessing extends BaseAction { record.getProperties().setMediaOpinion(taskCompleted.getMediaOpinion()); } } - WoId resp = ThisApplication.context().applications() - .postQuery(effectivePerson.getDebugger(), x_processplatform_service_processing.class, - Applications.joinQueryUri("record", "job", this.work.getJob()), record, this.task.getJob()) - .getData(WoId.class); - if (StringUtils.isBlank(resp.getId())) { - throw new ExceptionWorkProcessing(this.work.getId()); - } + new Thread(() -> { + try { + WoId resp = ThisApplication.context().applications() + .postQuery(effectivePerson.getDebugger(), x_processplatform_service_processing.class, + Applications.joinQueryUri("record", "job", this.work.getJob()), record, + this.task.getJob()) + .getData(WoId.class); + if (StringUtils.isBlank(resp.getId())) { + throw new ExceptionWorkProcessing(this.work.getId()); + } + } catch (Exception e) { + logger.error(e); + } + }, String.format("%record:%s", ActionProcessing.class.getName(), this.task.getId())).start(); } private void processingUpdateTaskCompleted() throws Exception {