package com.java110.common.activity.complaint; import com.java110.core.smo.common.IAuditUserInnerServiceSMO; import com.java110.dto.auditUser.AuditUserDto; 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 org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.List; /** * 采购人员采购 */ public class ComplaintUserListener implements TaskListener , ExecutionListener { private final static Logger logger = LoggerFactory.getLogger(ComplaintUserListener.class); private IAuditUserInnerServiceSMO auditUserInnerServiceSMOImpl; @Override public void notify(DelegateTask delegateTask) { auditUserInnerServiceSMOImpl = ApplicationContextFactory.getBean("auditUserInnerServiceSMOImpl", IAuditUserInnerServiceSMO.class); AuditUserDto auditUserDto = new AuditUserDto(); ComplaintDto complaintDto = (ComplaintDto) delegateTask.getVariable("complaintDto"); auditUserDto.setStoreId(complaintDto.getStoreId()); auditUserDto.setObjCode("complaint"); auditUserDto.setAuditLink("809004"); List 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.addCandidateUser(auditUserDtos.get(0).getUserId()); logger.info("开始设置投诉建议审核人员:"+auditUserDtos.get(0).getUserId()); delegateTask.setAssignee(auditUserDtos.get(0).getUserId()); } @Override public void notify(DelegateExecution execution) { } }