yili/apps
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

流程发布，多线程推送OA待阅

Browse Source
This commit is contained in:
lihongyu 2022-11-07 14:04:49 +08:00
parent 96e976e0a8
commit 6195a008d7
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java
View File

@ -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");
}