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-29 10:42:46 +08:00
parent 15b216d4fb
commit e8b27c99c9
1 changed files with 30 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -212,8 +212,6 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
}
}
/**
* 推送待阅文件到OA
*/
@ -279,25 +277,20 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
}
List<String> idList = sendList.subList(i, i + toIndex);
try {
// SendOARead(jsonObject, instanceById, idList);
SendOARead(jsonObject, instanceById, idList, "批量推送");
} catch (Exception e) {
// TODO: handle exception
}
ExecutorService cachedThreadPool = Executors.newFixedThreadPool(3);
// 开启一个线程
cachedThreadPool.execute(new Runnable() {
@Override
public void run() {
try {
SendOARead(jsonObject, instanceById, idList,"批量推送");
} catch (DocumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
/*
* ExecutorService cachedThreadPool = Executors.newFixedThreadPool(3); // 开启一个线程
* cachedThreadPool.execute(new Runnable() {
*
* @Override public void run() { try { } catch (DocumentException e) { // TODO
* Auto-generated catch block e.printStackTrace(); }
*
* } });
*/
// 以下是等线程池的全部线程执行结束后，会自动执行。
/*
* cachedThreadPool.shutdown(); while (true) { if
@ -307,19 +300,24 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
*/
}
//二次推送
/*
* List<RowMap> List =
* DBSql.getMaps("SELECT NAME FROM BO_EU_READ_COUNT WHERE PROCESSID = '"
* +instanceById.getId()+"' AND RESULT = '待处理'"); if(List.size()!=0) {
* System.err.println(instanceById.getTitle()+"批量推送失败后执行二次推送=======>"+List.size(
* )); for (RowMap rowMap : List) { try { ArrayList<String> userList3 = new
* ArrayList<String>(); userList3.add(rowMap.getString("NAME"));
* //System.err.println(instanceById.getTitle()+"二次推送账号=======>"+userList3);
* SendOARead(jsonObject, instanceById, userList3,"单个账号推送"); } catch (Exception
* e) { // TODO: handle exception } } }
*/
// 二次推送
List<RowMap> List = DBSql.getMaps("SELECT NAME FROM BO_EU_READ_COUNT WHERE PROCESSID = '"
+ instanceById.getId() + "' AND RESULT = '待处理'");
if (List.size() != 0) {
System.err.println(instanceById.getTitle() + "批量推送失败后执行二次推送=======>" + List.size());
for (RowMap rowMap : List) {
try {
ArrayList<String> userList3 = new ArrayList<String>();
userList3.add(rowMap.getString("NAME"));
System.err.println(instanceById.getTitle() + "二次推送账号=======>" + userList3);
SendOARead(jsonObject, instanceById, userList3, "单个账号推送");
} catch (Exception e) { // TODO: handle exception
}
}
}
long endTimes = System.currentTimeMillis();
// 存入日志
createReadLog(processExecutionContext, jsonObject, sendList, startTime, endTimes);
@ -328,7 +326,7 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
}
}
/**
* 更新数据看板底表
*/
@ -337,7 +335,7 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
} catch (Exception e) {
// TODO: handle exception
}
/**
* 推送到EHSQ
*/