修改回调发送请求未异步

workflow-engine/src/main/java/com/mortals/flowable/listener/global/GlobalProcistEndListener.java

@@ -19,9 +19,7 @@ import com.mortals.xhx.module.platform.model.PlatformEntity;
 import com.mortals.xhx.module.platform.model.PlatformListenerQuery;
 import com.mortals.xhx.module.platform.model.PlatformQuery;
 import com.mortals.xhx.module.platform.service.PlatformListenerService;
-import com.mortals.xhx.module.platform.service.PlatformModelinfoService;
 import com.mortals.xhx.module.platform.service.PlatformService;
-import lombok.extern.apachecommons.CommonsLog;
 import lombok.extern.slf4j.Slf4j;
 import org.flowable.common.engine.api.delegate.event.FlowableEngineEntityEvent;
 import org.flowable.engine.HistoryService;
@@ -141,8 +139,9 @@ public class GlobalProcistEndListener extends AbstractFlowableEngineEventListene
                 if (historicProcessInstance != null && historicProcessInstance.getProcessVariables() != null) {
                     flowMessageReq.setContent(JSON.toJSONString(variables));
                 }
-
-                doPostMessage(modelinfoEntity.getCallbackUrl(), flowMessageReq);
+                new Thread(() -> {
+                    doPostMessage(modelinfoEntity.getCallbackUrl(), flowMessageReq);
+                }).start();
 
             } else if (PlatformTypeEnum.JMS.getValue() == modelinfoEntity.getType()) {
                 //todo
@@ -157,11 +156,16 @@ public class GlobalProcistEndListener extends AbstractFlowableEngineEventListene
     private void doPostMessage(String url, FlowMessageReq flowMessageReq) {
         String ret = "";
         try {
-            log.info(String.format("发送请求,url:%s,body:%s", url, JSON.toJSONString(flowMessageReq)));
+/*            log.info("发送请求,url:{},body:{}", url, JSON.toJSONString(flowMessageReq));
             HashMap<String, String> header = new HashMap<>();
             header.put("Content-Type", "application/json");
             ret = com.mortals.framework.util.HttpUtil.doPost(url, header, JSON.toJSONString(flowMessageReq));
+            log.info("收到响应:" + ret);*/
+
+            log.info("发送请求,url:{},body:{}", url, JSON.toJSONString(flowMessageReq));
+            ret = HttpUtil.post(url, JSON.toJSONString(flowMessageReq));
             log.info("收到响应:" + ret);
+
         } catch (Exception e) {
             log.error("回调异常", e);
             try {

workflow-engine/src/main/java/com/mortals/flowable/listener/global/GlobalTaskCreateListener.java

 package com.mortals.flowable.listener.global;
 
+import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
-import com.mortals.framework.util.HttpUtil;
 import com.mortals.xhx.common.code.PlatformTypeEnum;
-import com.mortals.xhx.common.code.flowable.runtime.ProcessStatusEnum;
-import com.mortals.xhx.common.pdu.flow.FlowTaskNotifyPdu;
 import com.mortals.xhx.flowable.message.FlowMessageReq;
 import com.mortals.xhx.module.platform.model.PlatformEntity;
 import com.mortals.xhx.module.platform.model.PlatformListenerQuery;
 import com.mortals.xhx.module.platform.model.PlatformQuery;
 import com.mortals.xhx.module.platform.service.PlatformListenerService;
-import com.mortals.xhx.module.platform.service.PlatformModelinfoService;
 import com.mortals.xhx.module.platform.service.PlatformService;
-import lombok.extern.apachecommons.CommonsLog;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.flowable.common.engine.api.delegate.event.FlowableEngineEntityEvent;
 import org.flowable.common.engine.impl.event.FlowableEntityEventImpl;
 import org.flowable.engine.HistoryService;
-import org.flowable.engine.RuntimeService;
 import org.flowable.engine.TaskService;
 import org.flowable.engine.delegate.event.AbstractFlowableEngineEventListener;
 import org.flowable.engine.history.HistoricProcessInstance;
 import org.flowable.identitylink.api.IdentityLink;
 import org.flowable.task.service.impl.persistence.entity.TaskEntity;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
@@ -135,11 +126,16 @@ public class GlobalTaskCreateListener extends AbstractFlowableEngineEventListene
     private void doPostMessage(String url, FlowMessageReq flowMessageReq) {
         String ret = "";
         try {
-            log.info(String.format("发送请求,url:%s,body:%s", url, JSON.toJSONString(flowMessageReq)));
+/*            log.info(String.format("发送请求,url:%s,body:%s", url, JSON.toJSONString(flowMessageReq)));
             HashMap<String, String> header = new HashMap<>();
             header.put("Content-Type", "application/json");
             ret = HttpUtil.doPost(url, header, JSON.toJSONString(flowMessageReq));
+            log.info("收到响应:" + ret);*/
+
+            log.info("发送请求,url:{},body:{}", url, JSON.toJSONString(flowMessageReq));
+            ret = HttpUtil.post(url, JSON.toJSONString(flowMessageReq));
             log.info("收到响应:" + ret);
+
         } catch (Exception e) {
             log.error("回调异常", e);
 //            try {