From 1ea8334cd9f0c5641e035a58ff72084f2b8624bc Mon Sep 17 00:00:00 2001 From: Mr-wang Date: Fri, 14 Jul 2023 17:26:48 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E5=B8=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pubEvent/ProcessEndAfterEvent_new.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent_new.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent_new.java index 3569cfe2..12c6d37f 100644 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent_new.java +++ b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent_new.java @@ -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 list,long startTime,JSONObject jsonObject,ProcessExecutionContext processExecutionContext){ + public void course(List 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 mapsy = DBSql.getMaps(open,sqly); + List 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 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())); }