From 140a9ada1024b1f9c9be4cc4b9b4336247b1012c Mon Sep 17 00:00:00 2001
From: lihongyu <504404568@qq.com>
Date: Tue, 8 Nov 2022 18:00:59 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E7=A8=8B=E5=8F=91=E5=B8=83=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81OA=E5=BE=85=E9=98=85=E6=96=87=E4=BB=B6=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E5=AE=8C=E5=96=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../pubEvent/ProcessEndAfterEvent.java        | 30 ++++++++++---------
 1 file changed, 16 insertions(+), 14 deletions(-)

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 0bc159d0..5d43397e 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,18 +229,14 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
 						System.err.println(instanceById.getTitle() + "待发送人员数量====>" + sendList.size());
 						for (String uid : sendList) {
 							try {
-								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();
-									}
-						            }
-						        });
+								SendOARead(jsonObject, instanceById, uid);
+								/*
+								 * ExecutorService service = Executors.newFixedThreadPool(5);
+								 * service.execute(new Runnable() {
+								 * 
+								 * @Override public void run() { try { } catch (Exception e) { // TODO
+								 * Auto-generated catch block e.printStackTrace(); } } });
+								 */
 								
 							} catch (Exception e) {
 							}
@@ -664,6 +660,8 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
 				bo.set("USER_ID", user);
 				bo.set("DATAID", dataid);
 				bo.set("RESULT", status);
+				bo.set("SENDTYPE", "1");
+				bo.set("READSTATE", "未读");
 				SDK.getBOAPI().create("BO_ACT_DATAID", bo, processInstance.getId(), processInstance.getCreateUser());
 			}
 		}
@@ -1004,14 +1002,18 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList
 	public void createReadLog(ProcessExecutionContext processExecutionContext, JSONObject jsonObject, ArrayList<String> arr,
 			long startTime,long endTimes) {
 		BO bo_Read_log = new BO();
+		String processInstId = processExecutionContext.getProcessInstance().getId();
 		bo_Read_log.set("USREID", processExecutionContext.getUserContext().getUID());
 		bo_Read_log.set("DEPID", processExecutionContext.getUserContext().getDepartmentModel().getId());
 		bo_Read_log.set("BUNAME", processExecutionContext.getUserContext().getUserModel().getExt4());
 		bo_Read_log.set("TITLE", jsonObject.get("title"));
-		bo_Read_log.set("PROCESSID", processExecutionContext.getProcessInstance().getId());
+		bo_Read_log.set("PROCESSID", processInstId);
 		bo_Read_log.set("SENDNUM", arr.size());
+		String sqly ="SELECT * FROM BO_ACT_DATAID WHERE PROCESSID = '"+processInstId+"' AND SENDTYPE = '1'";
+		List<RowMap> mapsy = DBSql.getMaps(sqly);
+		bo_Read_log.set("SENDNUMSJ", mapsy.size());
 		BO bo_act_coe_publishs = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH", true)
-				.addQuery("BINDID=", processExecutionContext.getProcessInstance().getId())
+				.addQuery("BINDID=", processInstId)
 				.addQuery("OPTIONTYPE IS NOT NULL", null).detail();
 		String send_scop = bo_act_coe_publishs.getString("SEND_SCOP");
 		bo_Read_log.set("SEND_SCOP", send_scop);