实现任务执行器

CommonService/src/main/java/com/java110/common/activity/complaint/ComplaintUserListener.java

@@ -6,7 +6,9 @@ import com.java110.dto.complaint.ComplaintDto;
 import com.java110.entity.audit.AuditUser;
 import com.java110.utils.factory.ApplicationContextFactory;
 import com.java110.utils.util.BeanConvertUtil;
+import org.activiti.engine.delegate.DelegateExecution;
 import org.activiti.engine.delegate.DelegateTask;
+import org.activiti.engine.delegate.ExecutionListener;
 import org.activiti.engine.delegate.TaskListener;
 
 import java.util.List;
@@ -14,7 +16,7 @@ import java.util.List;
 /**
  * 采购人员采购
  */
-public class ComplaintUserListener implements TaskListener {
+public class ComplaintUserListener implements TaskListener , ExecutionListener {
 
     private IAuditUserInnerServiceSMO auditUserInnerServiceSMOImpl;
 
@@ -41,4 +43,9 @@ public class ComplaintUserListener implements TaskListener {
 
         delegateTask.setAssignee(auditUserDtos.get(0).getUserId());
     }
+
+    @Override
+    public void notify(DelegateExecution execution) {
+        
+    }
 }

CommonService/src/main/java/com/java110/common/smo/impl/ComplaintUserInnerServiceSMOImpl.java

@@ -215,7 +215,7 @@ public class ComplaintUserInnerServiceSMOImpl extends BaseServiceSMO implements
         Map<String, Object> variables = new HashMap<String, Object>();
         variables.put("auditCode", complaintDto.getAuditCode());
         //variables.put("userId", complaintDto.getCurrentUserId());
-        taskService.setAssignee(complaintDto.getTaskId(),complaintDto.getCurrentUserId());
+        //taskService.setAssignee(complaintDto.getTaskId(),complaintDto.getCurrentUserId());
         taskService.complete(complaintDto.getTaskId(), variables);
 
         ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();