## 直播出现问题修复;
This commit is contained in:
parent
49d88da3c8
commit
bf510f2566
|
|
@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
import com.hzs.common.core.constant.*;
|
import com.hzs.common.core.constant.*;
|
||||||
import com.hzs.common.core.domain.R;
|
import com.hzs.common.core.domain.R;
|
||||||
import com.hzs.common.core.enums.*;
|
import com.hzs.common.core.enums.*;
|
||||||
|
import com.hzs.common.core.exception.ServiceException;
|
||||||
import com.hzs.common.core.utils.*;
|
import com.hzs.common.core.utils.*;
|
||||||
import com.hzs.common.domain.member.achieve.CuMemberAchieve;
|
import com.hzs.common.domain.member.achieve.CuMemberAchieve;
|
||||||
import com.hzs.common.domain.member.achieve.CuMemberSettlePeriod;
|
import com.hzs.common.domain.member.achieve.CuMemberSettlePeriod;
|
||||||
|
|
@ -389,6 +390,9 @@ public class CuMemberAchieveServiceImpl extends ServiceImpl<CuMemberAchieveMappe
|
||||||
|
|
||||||
// 当前会员
|
// 当前会员
|
||||||
List<CuMemberExt> cuMemberExtList = iCuMemberService.queryMemberByCondition(CuMember.builder().pkId(pkMember).build());
|
List<CuMemberExt> cuMemberExtList = iCuMemberService.queryMemberByCondition(CuMember.builder().pkId(pkMember).build());
|
||||||
|
if (CollectionUtil.isNotEmpty(cuMemberExtList)) {
|
||||||
|
throw new ServiceException("查询会员信息失败,请重新登录");
|
||||||
|
}
|
||||||
CuMemberExt cuMemberExt = cuMemberExtList.get(0);
|
CuMemberExt cuMemberExt = cuMemberExtList.get(0);
|
||||||
//根据国家获取奖衔配置信息
|
//根据国家获取奖衔配置信息
|
||||||
List<BdAwards> awardsList = iAwardsServiceApi.queryAwards(pkCountry).getData();
|
List<BdAwards> awardsList = iAwardsServiceApi.queryAwards(pkCountry).getData();
|
||||||
|
|
|
||||||
|
|
@ -2,13 +2,11 @@ package com.hzs.member.base.controller.api;
|
||||||
|
|
||||||
import cn.hutool.core.codec.Base64Decoder;
|
import cn.hutool.core.codec.Base64Decoder;
|
||||||
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.collection.CollectionUtil;
|
||||||
import cn.hutool.json.JSONUtil;
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
||||||
import com.hzs.common.core.annotation.RepeatSubmitSimple;
|
import com.hzs.common.core.annotation.RepeatSubmitSimple;
|
||||||
import com.hzs.common.core.config.BdConfig;
|
import com.hzs.common.core.config.BdConfig;
|
||||||
import com.hzs.common.core.constant.CountryConstants;
|
import com.hzs.common.core.constant.CountryConstants;
|
||||||
import com.hzs.common.core.constant.EnumsPrefixConstants;
|
import com.hzs.common.core.constant.EnumsPrefixConstants;
|
||||||
import com.hzs.common.core.constant.SysConstants;
|
|
||||||
import com.hzs.common.core.constant.msg.ConfigMsgConstants;
|
import com.hzs.common.core.constant.msg.ConfigMsgConstants;
|
||||||
import com.hzs.common.core.constant.msg.MemberMsgConstants;
|
import com.hzs.common.core.constant.msg.MemberMsgConstants;
|
||||||
import com.hzs.common.core.domain.FileResult;
|
import com.hzs.common.core.domain.FileResult;
|
||||||
|
|
@ -25,17 +23,13 @@ import com.hzs.common.core.web.page.TableDataInfo;
|
||||||
import com.hzs.common.domain.member.base.CuMember;
|
import com.hzs.common.domain.member.base.CuMember;
|
||||||
import com.hzs.common.domain.member.detail.CuMemberChangeLog;
|
import com.hzs.common.domain.member.detail.CuMemberChangeLog;
|
||||||
import com.hzs.common.domain.member.ext.CuMemberExt;
|
import com.hzs.common.domain.member.ext.CuMemberExt;
|
||||||
import com.hzs.common.domain.member.ext.CuMemberRegionExt;
|
|
||||||
import com.hzs.common.domain.system.base.BdArea;
|
|
||||||
import com.hzs.common.domain.system.config.BdAgreementRenewalWhite;
|
import com.hzs.common.domain.system.config.BdAgreementRenewalWhite;
|
||||||
import com.hzs.common.domain.system.config.BdAwards;
|
import com.hzs.common.domain.system.config.BdAwards;
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
import com.hzs.common.security.utils.SecurityUtils;
|
||||||
import com.hzs.common.service.ITransactionCommonService;
|
import com.hzs.common.service.ITransactionCommonService;
|
||||||
import com.hzs.common.util.TransactionUtils;
|
import com.hzs.common.util.TransactionUtils;
|
||||||
import com.hzs.member.achieve.service.ICuMemberAchieveService;
|
|
||||||
import com.hzs.member.base.param.MemberDataParam;
|
import com.hzs.member.base.param.MemberDataParam;
|
||||||
import com.hzs.member.base.param.MemberRegionParam;
|
import com.hzs.member.base.param.MemberRegionParam;
|
||||||
import com.hzs.member.base.service.ICuMemberRegionService;
|
|
||||||
import com.hzs.member.base.service.ICuMemberService;
|
import com.hzs.member.base.service.ICuMemberService;
|
||||||
import com.hzs.member.base.service.IMemberInfoService;
|
import com.hzs.member.base.service.IMemberInfoService;
|
||||||
import com.hzs.member.base.vo.*;
|
import com.hzs.member.base.vo.*;
|
||||||
|
|
@ -81,10 +75,6 @@ public class ApiMemberController extends BaseController {
|
||||||
private ICuMemberChangeLogService iCuMemberChangeLogService;
|
private ICuMemberChangeLogService iCuMemberChangeLogService;
|
||||||
@Autowired
|
@Autowired
|
||||||
private IApiAliSmsService iApiAliSmsService;
|
private IApiAliSmsService iApiAliSmsService;
|
||||||
@Autowired
|
|
||||||
private ICuMemberRegionService iCuMemberRegionService;
|
|
||||||
@Autowired
|
|
||||||
private ICuMemberAchieveService iCuMemberRetailAchieveService;
|
|
||||||
|
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IGradeServiceApi iGradeServiceApi;
|
IGradeServiceApi iGradeServiceApi;
|
||||||
|
|
@ -717,10 +707,9 @@ public class ApiMemberController extends BaseController {
|
||||||
*/
|
*/
|
||||||
@GetMapping("/agreement_expire")
|
@GetMapping("/agreement_expire")
|
||||||
public AjaxResult agreementExpire() {
|
public AjaxResult agreementExpire() {
|
||||||
if (CountryConstants.CHINA_COUNTRY.equals(SecurityUtils.getPkCountry())) {
|
// 中国会员才进行校验
|
||||||
// 中国会员才进行校验
|
CuMember cuMember = iCuMemberService.getMemberById(SecurityUtils.getUserId());
|
||||||
CuMember cuMember = iCuMemberService.getMemberById(SecurityUtils.getUserId());
|
if (null != cuMember) {
|
||||||
|
|
||||||
// 校验会员是否添加到白名单
|
// 校验会员是否添加到白名单
|
||||||
BdAgreementRenewalWhite agreementRenewalWhite = null;
|
BdAgreementRenewalWhite agreementRenewalWhite = null;
|
||||||
R<BdAgreementRenewalWhite> whiteR = iAgreementRenewalWhiteServiceApi.getInfo(SecurityUtils.getUserId(), EAgreementWhiteType.RENEW_NOT_REAL.getValue());
|
R<BdAgreementRenewalWhite> whiteR = iAgreementRenewalWhiteServiceApi.getInfo(SecurityUtils.getUserId(), EAgreementWhiteType.RENEW_NOT_REAL.getValue());
|
||||||
|
|
|
||||||
|
|
@ -222,7 +222,8 @@ public class SaOrderHandle {
|
||||||
resultPostage = resultPostage.add(saOrderItems.getPrice().multiply(new BigDecimal(saOrderItems.getQuantity())));
|
resultPostage = resultPostage.add(saOrderItems.getPrice().multiply(new BigDecimal(saOrderItems.getQuantity())));
|
||||||
|
|
||||||
// 免邮的话不需要计算邮费
|
// 免邮的话不需要计算邮费
|
||||||
if (EYesNo.YES.getIntValue() == waresDetailExt.getIsFreeMail()) {
|
if (null == waresDetailExt.getIsFreeMail()
|
||||||
|
|| EYesNo.YES.getIntValue() == waresDetailExt.getIsFreeMail()) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
if (EDelivery.FAST_MAIL.getValue() == orderParam.getDeliveryWay()) {
|
if (EDelivery.FAST_MAIL.getValue() == orderParam.getDeliveryWay()) {
|
||||||
|
|
|
||||||
|
|
@ -486,28 +486,29 @@ public class ApiBdWaresController extends BaseController {
|
||||||
*/
|
*/
|
||||||
@GetMapping("/get-app-index")
|
@GetMapping("/get-app-index")
|
||||||
public AjaxResult getAppIndex() {
|
public AjaxResult getAppIndex() {
|
||||||
Integer pkCountry = SecurityUtils.getPkCountry();
|
// Integer pkCountry = SecurityUtils.getPkCountry();
|
||||||
Long userId = SecurityUtils.getUserId();
|
// Long userId = SecurityUtils.getUserId();
|
||||||
String memberCode = SecurityUtils.getMemberCode();
|
// String memberCode = SecurityUtils.getMemberCode();
|
||||||
// 校验产品团队信息(查询所有推荐商品)
|
// // 校验产品团队信息(查询所有推荐商品)
|
||||||
List<BdWaresExt> bdWaresList = iBdWaresService.queryByRecommendList(null, EYesNo.YES.getIntValue(), pkCountry, new HashMap<>());
|
// List<BdWaresExt> bdWaresList = iBdWaresService.queryByRecommendList(null, EYesNo.YES.getIntValue(), pkCountry, new HashMap<>());
|
||||||
Map<Integer, Boolean> waresShowMap = new HashMap<>();
|
// Map<Integer, Boolean> waresShowMap = new HashMap<>();
|
||||||
if (bdWaresList.size() > 0) {
|
// if (bdWaresList.size() > 0) {
|
||||||
// 检验商品团队信息
|
// // 检验商品团队信息
|
||||||
List<Integer> waresIdList = bdWaresList.stream().map(BdWares::getPkId).collect(Collectors.toList());
|
// List<Integer> waresIdList = bdWaresList.stream().map(BdWares::getPkId).collect(Collectors.toList());
|
||||||
Map<Integer, List<BdWaresAuthority>> waresAuthorityMap = iBdWaresService.getWaresAuthority(waresIdList);
|
// Map<Integer, List<BdWaresAuthority>> waresAuthorityMap = iBdWaresService.getWaresAuthority(waresIdList);
|
||||||
List<ShowWaresDTO> showWaresList = bdWaresList.stream().map(we -> getShowWares(we.getPkId(), userId, memberCode, waresAuthorityMap)).collect(Collectors.toList());
|
// List<ShowWaresDTO> showWaresList = bdWaresList.stream().map(we -> getShowWares(we.getPkId(), userId, memberCode, waresAuthorityMap)).collect(Collectors.toList());
|
||||||
R<Map<Integer, Boolean>> waresShowMapDto = iMemberServiceApi.checkIsShowWares(showWaresList);
|
// R<Map<Integer, Boolean>> waresShowMapDto = iMemberServiceApi.checkIsShowWares(showWaresList);
|
||||||
waresShowMap = waresShowMapDto.getData();
|
// waresShowMap = waresShowMapDto.getData();
|
||||||
}
|
// }
|
||||||
|
// // 查询app端首页商品展示信息
|
||||||
|
// RecommendWaresInfoVo recommendWaresInfoVo = iBdWaresService.queryRecommendInfo(pkCountry, memberCode, userId, waresShowMap);
|
||||||
|
// if (recommendWaresInfoVo.getWaresVoList() != null) {
|
||||||
|
// List<WaresVo> waresList = new ArrayList<>(recommendWaresInfoVo.getWaresVoList());
|
||||||
|
// recommendWaresInfoVo.setWaresVoList(waresList);
|
||||||
|
// }
|
||||||
|
RecommendWaresInfoVo recommendWaresInfoVo = new RecommendWaresInfoVo();
|
||||||
// 查询全部的banner (登录后banner)
|
// 查询全部的banner (登录后banner)
|
||||||
R<List<AdvertBannerDTO>> advertBannerList = advertBannerServiceApi.findAll(SecurityUtils.getUserId());
|
R<List<AdvertBannerDTO>> advertBannerList = advertBannerServiceApi.findAll(SecurityUtils.getUserId());
|
||||||
// 查询app端首页商品展示信息
|
|
||||||
RecommendWaresInfoVo recommendWaresInfoVo = iBdWaresService.queryRecommendInfo(pkCountry, memberCode, userId, waresShowMap);
|
|
||||||
if (recommendWaresInfoVo.getWaresVoList() != null) {
|
|
||||||
List<WaresVo> waresList = new ArrayList<>(recommendWaresInfoVo.getWaresVoList());
|
|
||||||
recommendWaresInfoVo.setWaresVoList(waresList);
|
|
||||||
}
|
|
||||||
recommendWaresInfoVo.setAdvertBannerList(advertBannerList.getData());
|
recommendWaresInfoVo.setAdvertBannerList(advertBannerList.getData());
|
||||||
return AjaxResult.success(recommendWaresInfoVo);
|
return AjaxResult.success(recommendWaresInfoVo);
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -9,15 +9,12 @@ import com.hzs.common.core.utils.StringUtils;
|
||||||
import com.hzs.common.domain.member.base.CuMember;
|
import com.hzs.common.domain.member.base.CuMember;
|
||||||
import com.hzs.common.domain.system.config.BdAdvertBanner;
|
import com.hzs.common.domain.system.config.BdAdvertBanner;
|
||||||
import com.hzs.common.domain.system.config.ext.BdAdvertBannerExt;
|
import com.hzs.common.domain.system.config.ext.BdAdvertBannerExt;
|
||||||
import com.hzs.common.security.utils.SecurityUtils;
|
|
||||||
import com.hzs.member.base.IMemberServiceApi;
|
import com.hzs.member.base.IMemberServiceApi;
|
||||||
import com.hzs.system.config.mapper.BdAdvertBannerMapper;
|
import com.hzs.system.config.mapper.BdAdvertBannerMapper;
|
||||||
import com.hzs.system.config.service.IBdAdvertBannerService;
|
import com.hzs.system.config.service.IBdAdvertBannerService;
|
||||||
import org.apache.dubbo.config.annotation.DubboReference;
|
import org.apache.dubbo.config.annotation.DubboReference;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
|
|
@ -29,6 +26,7 @@ public class BdAdvertBannerServiceImpl extends ServiceImpl<BdAdvertBannerMapper,
|
||||||
|
|
||||||
@DubboReference
|
@DubboReference
|
||||||
IMemberServiceApi iMemberServiceApi;
|
IMemberServiceApi iMemberServiceApi;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<BdAdvertBanner> listData(BdAdvertBanner banner, Long userId) {
|
public List<BdAdvertBanner> listData(BdAdvertBanner banner, Long userId) {
|
||||||
if (null == banner) {
|
if (null == banner) {
|
||||||
|
|
@ -43,12 +41,10 @@ public class BdAdvertBannerServiceImpl extends ServiceImpl<BdAdvertBannerMapper,
|
||||||
queryWrapper.eq(BdAdvertBanner::getPosition, EPositionTwo.POSITION_ONE.getValue());
|
queryWrapper.eq(BdAdvertBanner::getPosition, EPositionTwo.POSITION_ONE.getValue());
|
||||||
}
|
}
|
||||||
CuMember cuMember = iMemberServiceApi.getMember(userId).getData();
|
CuMember cuMember = iMemberServiceApi.getMember(userId).getData();
|
||||||
if(ObjectUtil.isEmpty(cuMember)){
|
if (ObjectUtil.isEmpty(cuMember)) {
|
||||||
queryWrapper.isNull(BdAdvertBanner::getPkVertex);
|
queryWrapper.isNull(BdAdvertBanner::getPkVertex);
|
||||||
}else{
|
} else {
|
||||||
queryWrapper.and(qw -> qw.isNull(BdAdvertBanner::getPkVertex)
|
queryWrapper.and(qw -> qw.isNull(BdAdvertBanner::getPkVertex).or().eq(BdAdvertBanner::getPkVertex, cuMember.getPkVertex()));
|
||||||
.or()
|
|
||||||
.eq(ObjectUtil.isNotEmpty(cuMember.getPkVertex()), BdAdvertBanner::getPkVertex, cuMember.getPkVertex()));
|
|
||||||
}
|
}
|
||||||
queryWrapper.eq(BdAdvertBanner::getPkCountry, CountryConstants.CHINA_COUNTRY);
|
queryWrapper.eq(BdAdvertBanner::getPkCountry, CountryConstants.CHINA_COUNTRY);
|
||||||
queryWrapper.lt(BdAdvertBanner::getEffectiveDate, new Date());
|
queryWrapper.lt(BdAdvertBanner::getEffectiveDate, new Date());
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue