feat:(1.2.0-beta1): 放入job结果处理器上下文放入jobTasks
This commit is contained in:
		
							parent
							
								
									acaa2e9668
								
							
						
					
					
						commit
						6169a0f544
					
				@ -54,6 +54,9 @@ public abstract class AbstractJobExecutorResultHandler implements JobExecutorRes
 | 
				
			|||||||
            return;
 | 
					            return;
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					        // 放入任务项, 子类会用到
 | 
				
			||||||
 | 
					        context.setJobTaskList(jobTasks);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        Map<Integer, Long> statusCountMap = jobTasks.stream()
 | 
					        Map<Integer, Long> statusCountMap = jobTasks.stream()
 | 
				
			||||||
            .collect(Collectors.groupingBy(JobTask::getTaskStatus, Collectors.counting()));
 | 
					            .collect(Collectors.groupingBy(JobTask::getTaskStatus, Collectors.counting()));
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
		Reference in New Issue
	
	Block a user