diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java index fddaa82a..0bc159d0 100644 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java +++ b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java @@ -229,15 +229,23 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList System.err.println(instanceById.getTitle() + "待发送人员数量====>" + sendList.size()); for (String uid : sendList) { try { - SendOARead(jsonObject, instanceById, uid); + ExecutorService service = Executors.newFixedThreadPool(5); + service.execute(new Runnable() { + @Override + public void run() { + try { + SendOARead(jsonObject, instanceById, uid); + } catch (Exception e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + }); + } catch (Exception e) { } } long endTimes = System.currentTimeMillis(); - //文件发布成功回执流程 - ProcessInstance processInst = SDK.getProcessAPI().createProcessInstance("obj_b4700f89a7a144c086d047de0cfe9531", "admin", bo_act_coe_publish1.getString("PROCESS_TITLE")+"成功发布回执单"); - TaskInstance taskInst = SDK.getProcessAPI().start(processInst).fetchActiveTasks().get(0); - SDK.getTaskAPI().completeTask(taskInst.getId(), "admin"); //存入日志 createReadLog(processExecutionContext, jsonObject, sendList, startTime,endTimes); System.err.println(instanceById.getTitle() + "推送OA待阅执行完毕====>" + "用时:"+(endTimes-startTime)/1000/60+"分钟"); @@ -1026,7 +1034,11 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList bo_Read_log.set("STARTTIMES", startTime); bo_Read_log.set("ENDTIMES", endTimes); bo_Read_log.set("TIMECOUNT", (endTimes-startTime)/1000/60+"分钟"); - SDK.getBOAPI().createDataBO("BO_EU_PAL_PULBISH_SUCCESS", bo_Read_log, processExecutionContext.getUserContext()); + //文件发布成功回执流程 + ProcessInstance processInst = SDK.getProcessAPI().createProcessInstance("obj_b4700f89a7a144c086d047de0cfe9531", "admin", jsonObject.get("title")+"成功发布回执单"); + SDK.getBOAPI().create("BO_EU_PAL_PULBISH_SUCCESS", bo_Read_log, processInst,UserContext.fromUID("admin")); + TaskInstance taskInst = SDK.getProcessAPI().start(processInst).fetchActiveTasks().get(0); + SDK.getTaskAPI().completeTask(taskInst.getId(), "admin"); }