bug fix

src/main/java/com/horizon/common/constant/Constants.java

@@ -1,5 +1,8 @@
 package com.horizon.common.constant;
 
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
 /**
  * 流程常量信息
  */
@@ -8,7 +11,7 @@ public class Constants {
     /**
      * WF服务器URL，临时写死，后续会写到配置文件中
      */
-    // public static final String WF_PRE_URL = "http://127.0.0.1:8003";
     public static final String WF_PRE_URL = "http://172.16.7.51:10034/jlyypt";
-    // http://172.16.7.51:10034/jlyypt/cot/Head/approvalProccess
+    public static final ExecutorService EXECUTOR_SERVICE = Executors.newFixedThreadPool(10);
+
 }

src/main/java/com/horizon/wf/core/rule/CotRule.java

@@ -87,12 +87,20 @@ public class CotRule extends BaseRuleImpl implements IBaseRule {
          // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/cot/Head/horizonApprovalProcess";
+        final String url = Constants.WF_PRE_URL + "/cot/Head/horizonApprovalProcess";
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/SalPlanRule.java

@@ -87,15 +87,23 @@ public class SalPlanRule extends BaseRuleImpl implements IBaseRule {
          // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/sal/PlanHead/horizonAcceptSubmit";
+        final String url = Constants.WF_PRE_URL + "/sal/PlanHead/horizonAcceptSubmit";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         System.err.println(url);
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/SalResultRule.java

@@ -87,15 +87,23 @@ public class SalResultRule extends BaseRuleImpl implements IBaseRule {
          // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/sal/InvHead/horizonAcceptSubmit";
+        final String url = Constants.WF_PRE_URL + "/sal/InvHead/horizonAcceptSubmit";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         System.err.println(url);
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/SalRetreatRule.java

@@ -87,15 +87,23 @@ public class SalRetreatRule extends BaseRuleImpl implements IBaseRule {
          // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/sal/SalPrepayRetreat/horizonAcceptSubmit";
+        final String url = Constants.WF_PRE_URL + "/sal/SalPrepayRetreat/horizonAcceptSubmit";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         System.err.println(url);
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/SalRule.java

@@ -87,15 +87,23 @@ public class SalRule extends BaseRuleImpl implements IBaseRule {
          // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/sal/PrepayErp/horizonAcceptSubmit";
+        final String url = Constants.WF_PRE_URL + "/sal/PrepayErp/horizonAcceptSubmit";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         System.err.println(url);
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/SalUpriceRule.java

@@ -87,15 +87,23 @@ public class SalUpriceRule extends BaseRuleImpl implements IBaseRule {
          // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/sal/UpriceHead/horizonAcceptSubmit";
+        final String url = Constants.WF_PRE_URL + "/sal/UpriceHead/horizonAcceptSubmit";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         System.err.println(url);
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/SignRule.java

@@ -85,15 +85,23 @@ public class SignRule extends BaseRuleImpl implements IBaseRule {
         // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/cot/SignRequest/horizonApprovalProcess";
+        final String url = Constants.WF_PRE_URL + "/cot/SignRequest/horizonApprovalProcess";
         String id = flowVar.get("id");
         System.err.println(flowVar.toString());
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         params.put("id", id);
         params.put("processInstanceStatus", status);
         System.err.println(url);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/purActRule.java

@@ -88,14 +88,22 @@ public class purActRule extends BaseRuleImpl implements IBaseRule {
         // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/pur/ActHead/horizonApprovalProcess";
+        final String url = Constants.WF_PRE_URL + "/pur/ActHead/horizonApprovalProcess";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/purBillRule.java

@@ -88,14 +88,22 @@ public class purBillRule extends BaseRuleImpl implements IBaseRule {
         // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/pur/BillHead/horizonApprovalProcess";
+        final String url = Constants.WF_PRE_URL + "/pur/BillHead/horizonApprovalProcess";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }

src/main/java/com/horizon/wf/core/rule/purPayReqRule.java

@@ -88,14 +88,22 @@ public class purPayReqRule extends BaseRuleImpl implements IBaseRule {
         // 业务使用
         // flowVar就是业务传递过来的参数集
         // 获取这里面的变量需要在流程中配置——流程建模时，右键——**属性设置——流程变量——添加变量——要不然获取不到变量
-        String url = Constants.WF_PRE_URL + "/pur/PayReqHead/horizonApprovalProcess";
+        final String url = Constants.WF_PRE_URL + "/pur/PayReqHead/horizonApprovalProcess";
         System.err.println(flowVar.toString());
         String id = flowVar.get("id");
-        Map<String, Object> params = new HashMap<>();
+        final Map<String, Object> params = new HashMap<>();
         params.put("id", id);
         params.put("processInstanceStatus", status);
-        String result = HttpUtil.post(url, params);
-        System.err.println("result:" + result);
+        Constants.EXECUTOR_SERVICE.submit(new Runnable() {
+            @Override
+            public void run() {
+                // final url params
+                String result = HttpUtil.post(url, params);
+                System.err.println("result:" + result);
+            }
+        });
+//        String result = HttpUtil.post(url, params);
+//        System.err.println("result:" + result);
         return true;
     }
 }