diff --git a/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java index e58ab3b1..9422c1b2 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java @@ -205,13 +205,15 @@ public class WebServiceOAServiceImpl implements WebServiceOAService { notifyTodoSendContext.setTargets(jsonLoginName.toJSONString()); notifyTodoSendContext.setUserId(busProcessNew.getUserId()); notifyTodoSendContexts.add(notifyTodoSendContext); + //每次调用进行循环 + Map ObjectMap = new TreeMap<>(); + map.put("todoId",pId); + map.put("list",notifyTodoSendContexts); + net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(ObjectMap); + log.info("调用MQ数据!!!:"+jsonObject.toString()); + oaService.setTodoDeleteMq(jsonObject.toString()); }); - Map map = new TreeMap<>(); - map.put("todoId",pId); - map.put("list",notifyTodoSendContexts); - net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(map); - log.info("调用MQ数据!!!:"+jsonObject.toString()); - oaService.setTodoDeleteMq(jsonObject.toString()); + } }