|
@@ -15,7 +15,6 @@ import com.kym.common.exception.BusinessException;
|
|
|
import com.kym.common.utils.CommUtil;
|
|
import com.kym.common.utils.CommUtil;
|
|
|
import com.kym.common.utils.HttpUtil;
|
|
import com.kym.common.utils.HttpUtil;
|
|
|
import com.kym.entity.admin.Activity;
|
|
import com.kym.entity.admin.Activity;
|
|
|
-import com.kym.entity.admin.ActivityStation;
|
|
|
|
|
import com.kym.entity.admin.RechargeRights;
|
|
import com.kym.entity.admin.RechargeRights;
|
|
|
import com.kym.entity.admin.queryParams.CommonQueryParam;
|
|
import com.kym.entity.admin.queryParams.CommonQueryParam;
|
|
|
import com.kym.entity.admin.vo.ActivityVo;
|
|
import com.kym.entity.admin.vo.ActivityVo;
|
|
@@ -164,21 +163,22 @@ public class UserServiceImpl extends MPJBaseServiceImpl<UserMapper, User> implem
|
|
|
|
|
|
|
|
// 可以参加的活动-充值权益
|
|
// 可以参加的活动-充值权益
|
|
|
DynamicDataSourceContextHolder.push("db-admin");
|
|
DynamicDataSourceContextHolder.push("db-admin");
|
|
|
- var bannerList = bannerService.list();
|
|
|
|
|
- var rechargeRight = rechargeRightsService.lambdaQuery().eq(RechargeRights::getStatus, Activity.STATUS_进行中).list();
|
|
|
|
|
var activityList = activityService.lambdaQuery().eq(Activity::getStatus, Activity.STATUS_进行中).list();
|
|
var activityList = activityService.lambdaQuery().eq(Activity::getStatus, Activity.STATUS_进行中).list();
|
|
|
- var activity2Station = activityStationService.getActivityVoList(activityList.stream().map(Activity::getId).toList()).stream().collect(Collectors.toMap(ActivityVo::getActivityId,ActivityVo::getStationList));
|
|
|
|
|
|
|
+ if (CommUtil.isNotEmptyAndNull(activityList)) {
|
|
|
|
|
+ var rechargeRight = rechargeRightsService.lambdaQuery().eq(RechargeRights::getStatus, Activity.STATUS_进行中).list();
|
|
|
|
|
+ var bannerList = bannerService.list();
|
|
|
|
|
+ var activity2Station = activityStationService.getActivityVoList(activityList.stream().map(Activity::getId).toList()).stream().collect(Collectors.toMap(ActivityVo::getActivityId, ActivityVo::getStationList));
|
|
|
|
|
+ var voList = activityList.stream().map(activity -> {
|
|
|
|
|
+ var vo = new ActivityVo();
|
|
|
|
|
+ BeanUtils.copyProperties(activity, vo);
|
|
|
|
|
+ vo.setRechargeRightsList(rechargeRight.stream().filter(rights -> rights.getActivityId().equals(activity.getId())).toList());
|
|
|
|
|
+ vo.setBannerList(bannerList.stream().filter(banner -> banner.getActivityId().equals(activity.getId())).toList());
|
|
|
|
|
+ vo.setStationList(activity2Station.get(activity.getId()));
|
|
|
|
|
+ return vo;
|
|
|
|
|
+ }).toList();
|
|
|
|
|
+ userVo.setActivityList(voList);
|
|
|
|
|
+ }
|
|
|
DynamicDataSourceContextHolder.poll();
|
|
DynamicDataSourceContextHolder.poll();
|
|
|
- var voList = activityList.stream().map(activity -> {
|
|
|
|
|
- var vo = new ActivityVo();
|
|
|
|
|
- BeanUtils.copyProperties(activity, vo);
|
|
|
|
|
- vo.setRechargeRightsList(rechargeRight.stream().filter(rights -> rights.getActivityId().equals(activity.getId())).toList());
|
|
|
|
|
- vo.setBannerList(bannerList.stream().filter(banner -> banner.getActivityId().equals(activity.getId())).toList());
|
|
|
|
|
- vo.setStationList(activity2Station.get(activity.getId()));
|
|
|
|
|
- return vo;
|
|
|
|
|
- }).toList();
|
|
|
|
|
- userVo.setActivityList(voList);
|
|
|
|
|
-
|
|
|
|
|
return userVo;
|
|
return userVo;
|
|
|
}
|
|
}
|
|
|
|
|
|