|
@@ -855,13 +855,12 @@ public class IndexBaseMonthDataServiceImpl extends BaseServiceImpl<Long, IndexBa
|
|
four.setErrorType(IndexErrorType.ATTENDANCE_SERVE);
|
|
four.setErrorType(IndexErrorType.ATTENDANCE_SERVE);
|
|
four.setDesc(IndexErrorType.ATTENDANCE_SERVE.getMsg());
|
|
four.setDesc(IndexErrorType.ATTENDANCE_SERVE.getMsg());
|
|
List<IndexErrInfoDto> fourChild = new ArrayList<>();
|
|
List<IndexErrInfoDto> fourChild = new ArrayList<>();
|
|
|
|
+ //获取有排课异常的学员列表
|
|
|
|
+ String month = DateUtil.format(date,DateUtil.ISO_YEAR_MONTH_FORMAT);
|
|
|
|
+ CompletableFuture<List<Integer>> future = CompletableFuture.supplyAsync(() -> {
|
|
|
|
+ return indexBaseMonthDataDao.getCurrentCourseErrorUserIdList(month, organIdList);
|
|
|
|
+ });
|
|
|
|
|
|
- CompletableFuture future1 = this.async(() -> {
|
|
|
|
- String month = DateUtil.format(date,DateUtil.ISO_YEAR_MONTH_FORMAT);
|
|
|
|
- //当月排课异常: (1)剩余课时(未开始+排课资格)4的学员,本月排课节数少于4节
|
|
|
|
- int currentCourseError = indexBaseMonthDataDao.getCurrentCourseError(month,organIdList);
|
|
|
|
- fourChild.add(new IndexErrInfoDto(IndexErrorType.CURRENT_COURSE_ERROR, currentCourseError));
|
|
|
|
- });
|
|
|
|
CompletableFuture future2 = null;
|
|
CompletableFuture future2 = null;
|
|
CompletableFuture future3 = null;
|
|
CompletableFuture future3 = null;
|
|
if(classGroupIds == null || classGroupIds.size() > 0) {
|
|
if(classGroupIds == null || classGroupIds.size() > 0) {
|
|
@@ -883,10 +882,17 @@ public class IndexBaseMonthDataServiceImpl extends BaseServiceImpl<Long, IndexBa
|
|
//课程异常
|
|
//课程异常
|
|
fourChild.add(new IndexErrInfoDto(IndexErrorType.TEACHER_NOT_A_CLASS, 0));
|
|
fourChild.add(new IndexErrInfoDto(IndexErrorType.TEACHER_NOT_A_CLASS, 0));
|
|
}
|
|
}
|
|
|
|
+ List<Integer> userIdList = future.join();
|
|
|
|
+ if(CollectionUtils.isEmpty(userIdList)){
|
|
|
|
+ fourChild.add(new IndexErrInfoDto(IndexErrorType.CURRENT_COURSE_ERROR, 0));
|
|
|
|
+ }else {
|
|
|
|
+ //当月排课异常: (1)剩余课时(未开始+排课资格)4的学员,本月排课节数少于4节
|
|
|
|
+ int currentCourseError = indexBaseMonthDataDao.getCurrentCourseError(userIdList);
|
|
|
|
+ fourChild.add(new IndexErrInfoDto(IndexErrorType.CURRENT_COURSE_ERROR, currentCourseError));
|
|
|
|
+ }
|
|
if(classGroupIds == null || classGroupIds.size() > 0) {
|
|
if(classGroupIds == null || classGroupIds.size() > 0) {
|
|
future2.join();future3.join();
|
|
future2.join();future3.join();
|
|
}
|
|
}
|
|
- future1.join();
|
|
|
|
four.setNum(fourChild.stream().mapToInt(IndexErrInfoDto::getNum).sum());
|
|
four.setNum(fourChild.stream().mapToInt(IndexErrInfoDto::getNum).sum());
|
|
four.setResult(fourChild);
|
|
four.setResult(fourChild);
|
|
all.add(four);
|
|
all.add(four);
|