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 0bfa8966..1b11b8ba 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
@@ -327,8 +327,8 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
 						for (BO uid:bo_eu_oa_read_test) {
 							sendLists.add(uid.getString("USER_ID"));
 						}*/
-                        String sql = "SELECT ID FROM WFH_TASK WHERE PROCESSINSTID = '" + processExecutionContext.getProcessInstance().getId()
-                                + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' ";
+                        String sql = "SELECT ID FROM WFH_TASK WHERE PROCESSINSTID='" + processExecutionContext.getProcessInstance().getId()
+                                + "' AND ACTIVITYDEFID='obj_c9e5a3144b200001b68cffa01ed0153e' AND TASKSTATE='1' ";
                         String taskInd = DBSql.getString(sql);
 
 
@@ -1330,7 +1330,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
                 .addQuery("OPTIONTYPE IS NOT NULL", null).detail();
 
         String sql = "SELECT ID FROM WFH_TASK WHERE PROCESSINSTID = '" + processInstance.getId()
-                + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' ";
+                + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' AND TASKSTATE='1' ";
         String taskInd = DBSql.getString(sql);
 
         TaskInstance ta = SDK.getTaskAPI().getInstanceById(taskInd);
@@ -1535,7 +1535,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
                 .addQuery("OPTIONTYPE IS NOT NULL", null).detail();
 
         String sql = "SELECT ID FROM WFH_TASK WHERE PROCESSINSTID = '" + processInstance.getId()
-                + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e' ";
+                + "' AND ACTIVITYDEFID = 'obj_c9e5a3144b200001b68cffa01ed0153e'  AND TASKSTATE='1' ";
         String taskInd = DBSql.getString(sql);
 
         TaskInstance ta = SDK.getTaskAPI().getInstanceById(taskInd);