1

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/NewWorkflowServiceImpl.java

@@ -24,6 +24,7 @@ import com.yh.saas.common.support.workflow.AbstractWorkflowTaskListener;
 import com.yh.saas.common.support.workflow.IWorkflowTaskChecklist;
 import com.yh.saas.plugin.yiliangyiyun.entity.UnimallMessage;
 import com.yh.saas.plugin.yiliangyiyun.service.INewWorkflowService;
+import com.yh.saas.plugin.yiliangyiyun.util.GeTuiUtils;
 import com.yh.saas.plugin.yiliangyiyun.util.WebSocket;
 import com.yh.saas.toolkit.workflow.activiti.ActivitiWorkflowBuilder;
 import com.yh.saas.toolkit.workflow.activiti.cmd.DeleteTaskCmd;
@@ -152,6 +153,9 @@ public class NewWorkflowServiceImpl implements INewWorkflowService {
     private ICommonStaffRoleService staffRoleService;
     @Autowired
     private WebSocket webSocket;
+
+    @Autowired
+    private GeTuiUtils geTuiUtils;
     @Override
     public String create(Workflow workflow) {
         workflow.setId(generateFlowId()); // 工作流ID将作为Activiti流程定义ID，必须以字母或下划线开头
@@ -1294,6 +1298,8 @@ public class NewWorkflowServiceImpl implements INewWorkflowService {
         List<CommonStaff> commonStaffs = this.getTaskCandidates(workflowId,businessKey);
         if(CollectionUtils.isNotEmpty(commonStaffs)) {
             for (int i = 0; i < commonStaffs.size(); i++) {
+                geTuiUtils.pushByCid("审核任务",type + "有新的审核任务需要处理，请及时处理。",commonStaffs.get(i).getStaffId());
+
                 UnimallMessage messageDO = new UnimallMessage();
                 messageDO.setAdminId(commonStaffs.get(i).getStaffId());
                 messageDO.setCustomer(commonStaffs.get(i).getStaffName());