|
@@ -147,15 +147,13 @@ public class TrainingSendNotifyServiceImpl implements TrainingSendNotifyService
|
|
|
);
|
|
|
Map<String, List<String>> paperMap = new HashMap<>();
|
|
|
// 对试卷按照试卷名称分组
|
|
|
- Map<String, List<EmpExamDo>> collect = examDoList.stream().collect(Collectors.groupingBy(EmpExamDo::getPapername, Collectors.toList()));
|
|
|
+ Map<String, List<EmpExamDo>> collect = examDoList.stream().collect(Collectors.groupingBy(info->info.getPaperid()+info.getPlanpaperid(), Collectors.toList()));
|
|
|
collect.forEach((k,v)->{
|
|
|
- paperMap.put(k, examDoList.stream().map(EmpExamDo::getEmpid).distinct().collect(Collectors.toList()));
|
|
|
- });
|
|
|
- // 培训课程取消提醒
|
|
|
- paperMap.forEach((k, v) -> {
|
|
|
- CXCommonUtils.sendNotify(CUT_OFF_PAPER_TITLE, String.format(CUT_OFF_PAPER_CONTENT, k), "",
|
|
|
- v, null, TRAINING);
|
|
|
+ EmpExamDo empExamDo = v.get(0);
|
|
|
+ CXCommonUtils.sendNotify(CUT_OFF_PAPER_TITLE, String.format(CUT_OFF_PAPER_CONTENT, empExamDo.getPapername(),empExamDo.getExamdeadtime()), "",
|
|
|
+ v.stream().map(EmpExamDo::getEmpid).distinct().collect(Collectors.toList()), null, TRAINING);
|
|
|
});
|
|
|
+
|
|
|
return R.ok();
|
|
|
}
|
|
|
|