优化处理过程

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

@@ -8,6 +8,7 @@ import com.java110.utils.factory.ApplicationContextFactory;
 import com.java110.utils.util.BeanConvertUtil;
 import org.activiti.engine.delegate.DelegateTask;
 import org.activiti.engine.delegate.TaskListener;
+import org.apache.commons.collections.ListUtils;
 
 import java.util.List;
 
@@ -23,17 +24,21 @@ public class ComplaintUserListener implements TaskListener {
 
         auditUserInnerServiceSMOImpl = ApplicationContextFactory.getBean("auditUserInnerServiceSMOImpl", IAuditUserInnerServiceSMO.class);
         AuditUserDto auditUserDto = new AuditUserDto();
-        ComplaintDto complaintDto = (ComplaintDto)delegateTask.getVariable("complaintDto");
+        ComplaintDto complaintDto = (ComplaintDto) delegateTask.getVariable("complaintDto");
         auditUserDto.setStoreId(complaintDto.getStoreId());
         auditUserDto.setObjCode("complaint");
         auditUserDto.setAuditLink("809004");
         List<AuditUserDto> auditUserDtos = auditUserInnerServiceSMOImpl.queryAuditUsers(auditUserDto);
 
+
         for (AuditUserDto tmpAuditUser : auditUserDtos) {
             AuditUser auditUser = BeanConvertUtil.covertBean(tmpAuditUser, AuditUser.class);
-
             delegateTask.setVariable(auditUser.getUserId(), auditUser);
+        }
 
+        if (auditUserDtos == null || auditUserDtos.size() < 1) {
+            return;
         }
+        delegateTask.setAssignee(auditUserDtos.get(0).getUserId());
     }
 }

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

@@ -52,6 +52,12 @@ public class ComplaintUserInnerServiceSMOImpl extends BaseServiceSMO implements
 
         complaintDto.setProcessInstanceId(processInstanceId);
 
+        //处理流程任务
+        TaskService taskService = processEngine.getTaskService();
+
+        taskService.complete(complaintDto.getTaskId());
+
+
         return complaintDto;
     }