小程序支付调整
parent
d019f727fd
commit
5db6f312ed
|
@ -5,6 +5,7 @@ import com.jwl.driver.server.dto.MemberQueryDto;
|
||||||
import com.jwl.driver.server.exception.BusinessException;
|
import com.jwl.driver.server.exception.BusinessException;
|
||||||
import com.jwl.driver.server.response.BaseResponse;
|
import com.jwl.driver.server.response.BaseResponse;
|
||||||
import com.jwl.driver.server.service.ITdMemberService;
|
import com.jwl.driver.server.service.ITdMemberService;
|
||||||
|
import com.jwl.driver.server.util.SecurityUtil;
|
||||||
import io.swagger.annotations.Api;
|
import io.swagger.annotations.Api;
|
||||||
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiOperation;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
@ -46,6 +47,6 @@ public class TdMemberController {
|
||||||
@PostMapping("/queryUserMember")
|
@PostMapping("/queryUserMember")
|
||||||
public BaseResponse queryUserMember(@RequestBody MemberQueryDto queryDto) {
|
public BaseResponse queryUserMember(@RequestBody MemberQueryDto queryDto) {
|
||||||
log.info("获取用户会员列表======>queryDto:{}", queryDto);
|
log.info("获取用户会员列表======>queryDto:{}", queryDto);
|
||||||
return BaseResponse.success(memberService.queryUserMember(queryDto));
|
return BaseResponse.success(memberService.queryUserMember(queryDto, SecurityUtil.getUserId()));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -27,7 +27,8 @@ public interface ITdMemberService extends IService<TdMember> {
|
||||||
/**
|
/**
|
||||||
* 获取用户开通的会员
|
* 获取用户开通的会员
|
||||||
* @param queryDto
|
* @param queryDto
|
||||||
|
* @param userId
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
List<MemberVo> queryUserMember(MemberQueryDto queryDto);
|
List<MemberVo> queryUserMember(MemberQueryDto queryDto,Long userId);
|
||||||
}
|
}
|
||||||
|
|
|
@ -9,7 +9,9 @@ import com.jwl.driver.server.mapper.TdMemberMapper;
|
||||||
import com.jwl.driver.server.service.ITdMemberService;
|
import com.jwl.driver.server.service.ITdMemberService;
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
import com.jwl.driver.server.util.SecurityUtil;
|
import com.jwl.driver.server.util.SecurityUtil;
|
||||||
|
import com.jwl.driver.server.util.TokenThreadUtil;
|
||||||
import com.jwl.driver.server.vo.MemberVo;
|
import com.jwl.driver.server.vo.MemberVo;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
@ -24,6 +26,7 @@ import java.util.stream.Collectors;
|
||||||
* @since 2023-08-10
|
* @since 2023-08-10
|
||||||
*/
|
*/
|
||||||
@Service
|
@Service
|
||||||
|
@Slf4j
|
||||||
public class TdMemberServiceImpl extends ServiceImpl<TdMemberMapper, TdMember> implements ITdMemberService {
|
public class TdMemberServiceImpl extends ServiceImpl<TdMemberMapper, TdMember> implements ITdMemberService {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -32,7 +35,15 @@ public class TdMemberServiceImpl extends ServiceImpl<TdMemberMapper, TdMember> i
|
||||||
List<MemberVo> resultList = new ArrayList<>();
|
List<MemberVo> resultList = new ArrayList<>();
|
||||||
|
|
||||||
//获取用户已开通且未到期的会员(即使该会员已不售卖了)
|
//获取用户已开通且未到期的会员(即使该会员已不售卖了)
|
||||||
List<MemberVo> userMemberList = queryUserMember(queryDto);
|
List<MemberVo> userMemberList = new ArrayList<>();
|
||||||
|
try {
|
||||||
|
if (StrUtil.isNotBlank(TokenThreadUtil.getToken())){
|
||||||
|
userMemberList = queryUserMember(queryDto,SecurityUtil.getUserId());
|
||||||
|
}
|
||||||
|
}catch (Exception e){
|
||||||
|
log.info("===================>用户没有登录");
|
||||||
|
}
|
||||||
|
|
||||||
Map<Integer, MemberVo> userMemberMap = userMemberList.stream().collect(Collectors.toMap(MemberVo::getMemberId, v -> v, (v1, v2) -> v1));
|
Map<Integer, MemberVo> userMemberMap = userMemberList.stream().collect(Collectors.toMap(MemberVo::getMemberId, v -> v, (v1, v2) -> v1));
|
||||||
|
|
||||||
//将用户购买的已停售但未过期的会员放在最前面
|
//将用户购买的已停售但未过期的会员放在最前面
|
||||||
|
@ -57,8 +68,8 @@ public class TdMemberServiceImpl extends ServiceImpl<TdMemberMapper, TdMember> i
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<MemberVo> queryUserMember(MemberQueryDto queryDto) {
|
public List<MemberVo> queryUserMember(MemberQueryDto queryDto,Long userId) {
|
||||||
return this.getBaseMapper().queryUserMember(queryDto,SecurityUtil.getUserId());
|
return this.getBaseMapper().queryUserMember(queryDto,userId);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -50,6 +50,7 @@ driver:
|
||||||
- /tdQuestion/queryQuestion
|
- /tdQuestion/queryQuestion
|
||||||
- /tdQuestion/getTestQuestion
|
- /tdQuestion/getTestQuestion
|
||||||
- /tdQuestion/questionCategory
|
- /tdQuestion/questionCategory
|
||||||
|
- /tdMember/queryMember
|
||||||
|
|
||||||
# 需要权限校验url集合
|
# 需要权限校验url集合
|
||||||
needAuthEndPoints:
|
needAuthEndPoints:
|
||||||
|
|
Loading…
Reference in New Issue