过滤掉无需发送的消息

bpm-core/src/main/java/com/srm/bpm/logic/service/impl/PushMsgLogicImpl.java

@@ -12,11 +12,13 @@
 
 package com.srm.bpm.logic.service.impl;
 
+import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
 
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -39,11 +41,13 @@ public class PushMsgLogicImpl implements PushMsgLogic {
 	@Override
 	public void push(List<FlowMsgDTO> allMsg) {
 		allMsg = allMsg.stream().filter(e->(e.getPush() != null && !e.getPush().equals(""))).collect(Collectors.toList());
-		JSONObject data = new JSONObject();
-		data.put("msg", JSON.toJSON(allMsg));
-		log.info("回调返回的数据:{}", allMsg);
-		final ResponseEntity<R> post = restTemplateUtil.post(bpmConfig.getPushmsgUrl(), data, "1");
-		log.info("回调返回的数据:{}", post);
+		if(!CollectionUtils.isEmpty(allMsg)) {
+			JSONObject data = new JSONObject();
+			data.put("msg", JSON.toJSON(allMsg));
+			log.info("回调返回的数据:{}", allMsg);
+			final ResponseEntity<R> post = restTemplateUtil.post(bpmConfig.getPushmsgUrl(), data, "1");
+			log.info("回调返回的数据:{}", post);
+		}
 	}
 }