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

发布

Browse Source
This commit is contained in:
Mr-wang 2023-07-14 17:26:48 +08:00
parent 23cf1a0816
commit 1ea8334cd9
1 changed files with 12 additions and 12 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_new.java
View File

@ -302,7 +302,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
/**
* 创建线程发送待阅数据
*/
course(open,list,startTime,jsonObject,processExecutionContext);
course(list,startTime,jsonObject,processExecutionContext);
//System.out.println("发送人员数据>>>>>>>>>>>>>>"+list);
}else {
int size = users.length/length;
@ -321,7 +321,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
/**
* 创建线程发送待阅数据
*/
course(open,list,startTime,jsonObject,processExecutionContext);
course(list,startTime,jsonObject,processExecutionContext);
//System.out.println("发送人员数据>>>>>>>>>>>>>>"+list);
}
@ -609,7 +609,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
* @param jsonObject
* @param processExecutionContext
*/
public void course(Connection open,List<String[]> list,long startTime,JSONObject jsonObject,ProcessExecutionContext processExecutionContext){
public void course(List<String[]> list,long startTime,JSONObject jsonObject,ProcessExecutionContext processExecutionContext){
// 创建线程来实现为每100人为一个的线程跑待阅
ExecutorService service = Executors.newFixedThreadPool(5);
for (String[] resrt:list
@ -621,7 +621,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
System.out.println("最后一个数组是什么>>>>>>>"+Arrays.asList(resrt).size());
try {
SendOARead(open,jsonObject, processExecutionContext.getProcessInstance(), resrt,"批量推送");
SendOARead(jsonObject, processExecutionContext.getProcessInstance(), resrt,"批量推送");
} catch (DocumentException e) {
e.printStackTrace();
}
@ -964,7 +964,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
* @param results
* @throws DocumentException
*/
public void SendOARead(Connection open,JSONObject jsonObject, ProcessInstance processInstance, String[] resrt,String type)
public void SendOARead(JSONObject jsonObject, ProcessInstance processInstance, String[] resrt,String type)
throws DocumentException {
String userIds = "";
@ -1039,10 +1039,10 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
BO oa_real_time=SDK.getBOAPI().query("BO_ACT_OA_REAL_TIME").addQuery("PROCESSID=",processInstance.getId()).detail();
String sqly = "SELECT ID FROM BO_ACT_DATAID WHERE PROCESSID = '" + processInstId + "' AND SENDTYPE = '1'";
List<RowMap> mapsy = DBSql.getMaps(open,sqly);
List<RowMap> mapsy = DBSql.getMaps(sqly);
if(oa_real_time!=null){
int r1 = DBSql.update(open,"UPDATE BO_ACT_OA_REAL_TIME SET SENDNUMSJ='" + mapsy.size() + "'WHERE PROCESSID ='" + processInstance.getId() + "'");
int r1 = DBSql.update("UPDATE BO_ACT_OA_REAL_TIME SET SENDNUMSJ='" + mapsy.size() + "'WHERE PROCESSID ='" + processInstance.getId() + "'");
}else{
//插入实时更新人数表
BO realTimeBO=new BO();
@ -1053,11 +1053,11 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
realTimeBO.set("PROCESSID", processInstance.getId());
realTimeBO.set("SENDNUMSJ", 1);
realTimeBO.set("SENDNUM",sendTotal);
SDK.getBOAPI().create("BO_ACT_OA_REAL_TIME", bo, processInstance, UserContext.fromUID(processInstance.getCreateUser()),open);
SDK.getBOAPI().create("BO_ACT_OA_REAL_TIME", bo, processInstance, UserContext.fromUID(processInstance.getCreateUser()));
}
}
SDK.getBOAPI().create("BO_ACT_DATAID",recordLists, processInstance, UserContext.fromUID(processInstance.getCreateUser()),open);
SDK.getBOAPI().create("BO_ACT_DATAID",recordLists, processInstance, UserContext.fromUID(processInstance.getCreateUser()));
long endTime2 = System.currentTimeMillis();
System.err.println(processInstance.getTitle() + "批量插入OA待阅数据====>" + "用时："
@ -1067,9 +1067,9 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
bo_OA_read.set("SET_END_TIME",set_end_time);
bo_OA_read.set("SET_SUM_TIME",(set_end_time-set_start_time));
bo_OA_read.set("PROCESS_ID",processInstance.getId());
SDK.getBOAPI().create("BO_EU_OA_READ_LOG", bo_OA_read, processInstance, UserContext.fromUID(processInstance.getCreateUser()),open);
SDK.getBOAPI().create("BO_EU_OA_READ_LOG", bo_OA_read, processInstance, UserContext.fromUID(processInstance.getCreateUser()));
if("单个账号推送".equals(type)) {
DBSql.update(open,"UPDATE BO_EU_READ_COUNT SET RESULT = '已重新推送' WHERE PROCESSID = '"+processInstId+"' AND NAME = '"+resrt+"'");
DBSql.update("UPDATE BO_EU_READ_COUNT SET RESULT = '已重新推送' WHERE PROCESSID = '"+processInstId+"' AND NAME = '"+resrt+"'");
}
} else {
List<String> idList = Arrays.asList(resrt);
@ -1101,7 +1101,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
}
}
System.out.println("recordFailLists========="+recordFailLists.size());
SDK.getBOAPI().create("BO_EU_READ_COUNT", recordFailLists, processInstance, UserContext.fromUID(processInstance.getCreateUser()),open);
SDK.getBOAPI().create("BO_EU_READ_COUNT", recordFailLists, processInstance, UserContext.fromUID(processInstance.getCreateUser()));
}