|
|
@@ -13,8 +13,10 @@ import com.kym.common.enums.WxApi;
|
|
|
import com.kym.common.exception.BusinessException;
|
|
|
import com.kym.common.utils.CommUtil;
|
|
|
import com.kym.common.utils.HttpUtil;
|
|
|
-import com.kym.entity.admin.EquipmentInfo;
|
|
|
+import com.kym.entity.admin.Activity;
|
|
|
+import com.kym.entity.admin.RechargeRights;
|
|
|
import com.kym.entity.admin.queryParams.CommonQueryParam;
|
|
|
+import com.kym.entity.admin.vo.ActivityVo;
|
|
|
import com.kym.entity.admin.vo.CustomUserVo;
|
|
|
import com.kym.entity.common.PageBean;
|
|
|
import com.kym.entity.miniapp.Account;
|
|
|
@@ -25,6 +27,7 @@ import com.kym.entity.miniapp.params.WxLoginParams;
|
|
|
import com.kym.entity.miniapp.vo.UserVo;
|
|
|
import com.kym.entity.wechat.WxPhoneNum;
|
|
|
import com.kym.mapper.miniapp.UserMapper;
|
|
|
+import com.kym.service.admin.ActivityService;
|
|
|
import com.kym.service.admin.RechargeRightsService;
|
|
|
import com.kym.service.miniapp.AccountService;
|
|
|
import com.kym.service.miniapp.CarsService;
|
|
|
@@ -60,14 +63,16 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
|
|
|
private final CarsService carsService;
|
|
|
private final UserRechargeRightsService userRechargeRightsService;
|
|
|
private final RechargeRightsService rechargeRightsService;
|
|
|
+ private final ActivityService activityService;
|
|
|
|
|
|
- public UserServiceImpl(WxConfig wxConfig, AccountService accountService, CarsService carsService, UserRechargeRightsService userRechargeRightsService, RechargeRightsService rechargeRightsService) {
|
|
|
+ public UserServiceImpl(WxConfig wxConfig, AccountService accountService, CarsService carsService, UserRechargeRightsService userRechargeRightsService, RechargeRightsService rechargeRightsService, ActivityService activityService) {
|
|
|
this.wxConfig = wxConfig;
|
|
|
this.accountService = accountService;
|
|
|
this.carsService = carsService;
|
|
|
this.userRechargeRightsService = userRechargeRightsService;
|
|
|
|
|
|
this.rechargeRightsService = rechargeRightsService;
|
|
|
+ this.activityService = activityService;
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -147,9 +152,17 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements Us
|
|
|
// 可以参加的活动-充值权益
|
|
|
// 手动切换数据源
|
|
|
DynamicDataSourceContextHolder.push("db-admin");
|
|
|
- var rechargeRight = rechargeRightsService.list();
|
|
|
+ var rechargeRight = rechargeRightsService.lambdaQuery().eq(RechargeRights::getStatus,Activity.STATUS_进行中).list();
|
|
|
+ var activityList = activityService.lambdaQuery().eq(Activity::getStatus,Activity.STATUS_进行中).list();
|
|
|
DynamicDataSourceContextHolder.poll();
|
|
|
- return userVo.setRechargeRightsList(rechargeRight).setUserRechargeRightsList(userRechargeRight);
|
|
|
+ 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());
|
|
|
+ return vo;
|
|
|
+ }).toList();
|
|
|
+ userVo.setActivityList(voList);
|
|
|
+ return userVo.setUserRechargeRightsList(userRechargeRight);
|
|
|
}
|
|
|
|
|
|
|