FT/foton-wkflow-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

OA删除

Browse Source
This commit is contained in:
gaojiabao
2023-03-29 13:55:18 +08:00
parent b00474e16d
commit 4d55ec554a
1 changed files with 44 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java
+44 -22
View File
@@ -191,28 +191,50 @@ public class WebServiceOAServiceImpl implements WebServiceOAService {
List<BusProcessNew> list = iBusProcessNewService.list(queryWrapper1); List<BusProcessNew> list = iBusProcessNewService.list(queryWrapper1);
if(!list.isEmpty()){ if(!list.isEmpty()){
List<NotifyTodoSendContext> notifyTodoSendContexts = new ArrayList<>(); List<NotifyTodoSendContext> notifyTodoSendContexts = new ArrayList<>();
list.forEach(busProcessNew -> { // list.forEach(busProcessNew -> {
NotifyTodoSendContext notifyTodoSendContext = new NotifyTodoSendContext(); // NotifyTodoSendContext notifyTodoSendContext = new NotifyTodoSendContext();
notifyTodoSendContext.setAppName("SRMS"); // notifyTodoSendContext.setAppName("SRMS");
notifyTodoSendContext.setModelId(busProcessNew.getId()); // notifyTodoSendContext.setModelId(busProcessNew.getId());
notifyTodoSendContext.setModelName(busProcessNew.getTaskInfo()); // notifyTodoSendContext.setModelName(busProcessNew.getTaskInfo());
notifyTodoSendContext.setType("1"); // notifyTodoSendContext.setType("1");
notifyTodoSendContext.setOptType("2"); // notifyTodoSendContext.setOptType("2");
Map<String, Object> map = new HashMap<>(); // Map<String, Object> map = new HashMap<>();
ResponseMessage<UserVO> byId = lawsUserInfoService.getById(busProcessNew.getUserId()); // ResponseMessage<UserVO> byId = lawsUserInfoService.getById(busProcessNew.getUserId());
map.put("LoginName",byId == null ? "" : byId.getData().getAccount()); // map.put("LoginName",byId == null ? "" : byId.getData().getAccount());
JSONObject jsonLoginName = new JSONObject(map); // JSONObject jsonLoginName = new JSONObject(map);
notifyTodoSendContext.setTargets(jsonLoginName.toJSONString()); // notifyTodoSendContext.setTargets(jsonLoginName.toJSONString());
notifyTodoSendContext.setUserId(busProcessNew.getUserId()); // notifyTodoSendContext.setUserId(busProcessNew.getUserId());
notifyTodoSendContexts.add(notifyTodoSendContext); // notifyTodoSendContexts.add(notifyTodoSendContext);
//每次调用进行循环 // //循环调用
Map<String,Object> ObjectMap = new TreeMap<>(); // map.put("todoId",pId);
map.put("todoId",pId); // map.put("list",notifyTodoSendContexts);
map.put("list",notifyTodoSendContexts); // net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(map);
net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(ObjectMap); // log.info("调用MQ数据！！！："+jsonObject.toString());
log.info("调用MQ数据！！！："+jsonObject.toString()); // oaService.setTodoDeleteMq(jsonObject.toString());
oaService.setTodoDeleteMq(jsonObject.toString());
}); for (BusProcessNew busProcessNew : list) {
NotifyTodoSendContext notifyTodoSendContext = new NotifyTodoSendContext();
notifyTodoSendContext.setAppName("SRMS");
notifyTodoSendContext.setModelId(busProcessNew.getId());
notifyTodoSendContext.setModelName(busProcessNew.getTaskInfo());
notifyTodoSendContext.setType("1");
notifyTodoSendContext.setOptType("2");
Map<String, Object> map = new HashMap<>();
ResponseMessage<UserVO> byId = lawsUserInfoService.getById(busProcessNew.getUserId());
map.put("LoginName",byId == null ? "" : byId.getData().getAccount());
JSONObject jsonLoginName = new JSONObject(map);
notifyTodoSendContext.setTargets(jsonLoginName.toJSONString());
notifyTodoSendContext.setUserId(busProcessNew.getUserId());
//notifyTodoSendContexts.add(notifyTodoSendContext);
//循环调用
map.put("todoId",pId);
map.put("list",notifyTodoSendContext);
net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(map);
log.info("调用MQ数据！！！："+jsonObject.toString());
oaService.setTodoDeleteMq(jsonObject.toString());
}
// });
} }
} }