|
|
@@ -44,7 +44,7 @@ public class ActivityUserRewardServiceImpl extends ServiceImpl<ActivityUserRewar
|
|
|
// 活动信息
|
|
|
ActivityPlan activityPlan = activityPlanService.getBaseMapper().selectById(query.getActivityId());
|
|
|
if (Objects.isNull(activityPlan)) {
|
|
|
- throw new BizException("无效的活动ID");
|
|
|
+ throw new BizException("无效的活动ID");
|
|
|
}
|
|
|
|
|
|
// 活动获奖用户信息
|
|
|
@@ -63,6 +63,7 @@ public class ActivityUserRewardServiceImpl extends ServiceImpl<ActivityUserRewar
|
|
|
Lists.partition(userIds, 30).parallelStream().forEach(item -> {
|
|
|
|
|
|
List<UserRewardVo> retlist = getBaseMapper().selectActivityShareTeacher(activityPlan.getId(), item);
|
|
|
+
|
|
|
// 同一个活动,用户关联多个老师信息
|
|
|
Map<Long, String> collect = retlist.stream()
|
|
|
.collect(Collectors.groupingBy(UserRewardVo::getUserId, Collectors.mapping(x -> {
|
|
|
@@ -71,14 +72,16 @@ public class ActivityUserRewardServiceImpl extends ServiceImpl<ActivityUserRewar
|
|
|
return x.getRealName();
|
|
|
}
|
|
|
return x.getUsername();
|
|
|
- }, Collectors.joining("、"))));
|
|
|
+ }, Collectors.toSet()))).entrySet().stream()
|
|
|
+ .collect(Collectors.toMap(Map.Entry::getKey, x -> String.join("、", x.getValue())));
|
|
|
|
|
|
teacherNameMap.putAll(collect);
|
|
|
|
|
|
// 老师ID
|
|
|
teacherIdMap.putAll(retlist.stream()
|
|
|
.collect(Collectors.groupingBy(UserRewardVo::getUserId,
|
|
|
- Collectors.mapping(UserRewardVo::getTeacherId, Collectors.joining("、")))));
|
|
|
+ Collectors.mapping(UserRewardVo::getTeacherId, Collectors.toSet()))).entrySet().stream()
|
|
|
+ .collect(Collectors.toMap(Map.Entry::getKey, x -> String.join("、", x.getValue()))));
|
|
|
|
|
|
});
|
|
|
|