From f520913b7eaf963d559418fcd8eb8ac2166810b3 Mon Sep 17 00:00:00 2001
From: dimengzhe <251008545@qq.com>
Date: Wed, 22 Feb 2023 16:50:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=84=E9=80=81=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../anrui/flowable/biz/flow/FlowableRest.java | 20 +------------------
 1 file changed, 1 insertion(+), 19 deletions(-)

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<UpdateFlowFieldVo> 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<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
-
-                Future future1 = pool.submit(() -> {
-                    HashMap<String, Object> map = new HashMap<>();
-                    map.put("bv", dto);
-                    map.put("uff", updateFlowFieldVoResultBean.getData());
-                    cc(map);
-                });
-            } catch (Exception e) {
-                e.printStackTrace();
-                return rb.setMsg("抄送失败");
             }
-
         }
         return updateFlowFieldVoResultBean;