diff --git a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java index fc7105d134..ad77d798e9 100644 --- a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java +++ b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java @@ -315,7 +315,7 @@ public class FlowableRest implements FlowableFeign { ResultBean updateFlowFieldVoResultBean = handleProsess(dto, true); //需要判断办结后再执行 TODO if (updateFlowFieldVoResultBean.getSuccess()) { - /* if ("Event_end".equals(updateFlowFieldVoResultBean.getData().getTaskDefKey())) { + if ("Event_end".equals(updateFlowFieldVoResultBean.getData().getTaskDefKey())) { try { ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() .setNameFormat("demo-pool-%d").build(); @@ -333,25 +333,7 @@ public class FlowableRest implements FlowableFeign { e.printStackTrace(); return rb.setMsg("抄送失败"); } - }*/ - try { - ThreadFactory namedThreadFactory = new ThreadFactoryBuilder() - .setNameFormat("demo-pool-%d").build(); - ExecutorService pool = new ThreadPoolExecutor(2, 100, - 0L, TimeUnit.MILLISECONDS, - new LinkedBlockingQueue(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy()); - - Future future1 = pool.submit(() -> { - HashMap map = new HashMap<>(); - map.put("bv", dto); - map.put("uff", updateFlowFieldVoResultBean.getData()); - cc(map); - }); - } catch (Exception e) { - e.printStackTrace(); - return rb.setMsg("抄送失败"); } - } return updateFlowFieldVoResultBean;