package com.cyksj.web.controller.coupon; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.cyksj.common.annotation.NoSubmit; import com.cyksj.common.exception.BusinessRuntimeException; import com.cyksj.common.util.Jsons; import com.cyksj.dto.Result; import com.cyksj.enums.GatewayResponse; import com.cyksj.mapper.manage.coupon.CouponMapper; import com.cyksj.mapper.manage.coupon.CouponRecommendMapper; import com.cyksj.mapper.manage.coupon.CouponSkuMapper; import com.cyksj.mapper.manage.coupon.CouponUserMapper; import com.cyksj.model.dto.CouponPopularizeDto; import com.cyksj.model.entity.Coupon; import com.cyksj.model.entity.CouponSku; import com.cyksj.model.request.CouponCollectReq; import com.cyksj.model.views.*; import com.cyksj.redis.RedisService; import com.cyksj.service.coupon.CouponFontService; import com.cyksj.web.util.StpUserUtil; import com.ejlchina.searcher.BeanSearcher; import com.ejlchina.searcher.param.Operator; import com.ejlchina.searcher.util.MapUtils; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; import java.util.List; import java.util.stream.Collectors; /* *项目名: netflix *文件名: CouponFrontController *创建者: JavaZou *创建时间:2022/11/18 10:56 */ @RestController @RequestMapping("/applet/coupon") @RequiredArgsConstructor public class CouponFrontController { private final CouponUserMapper couponUserMapper; private final BeanSearcher beanSearcher; private final CouponFontService couponFontService; private final RedisService redisService; private final CouponSkuMapper couponSkuMapper; private final CouponMapper couponMapper; private final CouponRecommendMapper couponRecommendMapper; /** * 优惠券领取中心列表 */ @GetMapping("/center/list") public Result> couponCenterList(@RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) { Long userId = StpUserUtil.getLoginIdAsLong(); Page page = couponUserMapper.couponCenterList(userId, new Page<>(start, limit)); page.getRecords().forEach(data -> { String str = couponSkuMapper.selectGoodsSkuStr(data.getCouponId()); data.setGoodsSkuStr(str.replaceAll(",", "/").replaceAll(";", "")); List couponSkus = couponSkuMapper.getGoodsSkuByCouponId(data.getCouponId()); try { data.setGoodsSkuIds(Jsons.toJson(couponSkus)); } catch (Exception e) { } }); return GatewayResponse.SUCCESS.newBuilder().toResult(page); } /** * 个人优惠券列表 */ @GetMapping("/personal/list") public Result> couponPersonalList(@RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) { Long userId = StpUserUtil.getLoginIdAsLong(); Page page = couponUserMapper.couponPersonalList(userId, new Page<>(start, limit)); page.getRecords().forEach(data -> { String str = couponSkuMapper.selectGoodsSkuStr(data.getCouponId()); data.setGoodsSkuStr(str.replaceAll(",", "/").replaceAll(";", "")); List couponSkus = couponSkuMapper.getGoodsSkuByCouponId(data.getCouponId()); try { data.setGoodsSkuIds(Jsons.toJson(couponSkus)); } catch (Exception e) { } }); return GatewayResponse.SUCCESS.newBuilder().toResult(page); } /** * 可用优惠券展示数量 */ @GetMapping("/available/num") public Result availableCouponNum(Long skuId, Boolean isRenew) { Long userId = StpUserUtil.getLoginIdAsLong(); Long goodsId = null; //实物还是虚物 GoodsDonSkuView goodsDonSkuView = beanSearcher.searchFirst(GoodsDonSkuView.class, MapUtils.builder().field(GoodsDonSkuView::getSkuId, skuId).op(Operator.Equal).build()); if (goodsDonSkuView == null) { throw BusinessRuntimeException.getInstance("规格不存在"); } BigDecimal skuMoney = goodsDonSkuView.getMoney(); if (goodsDonSkuView.getType() == 2) { goodsId = goodsDonSkuView.getGoodsId(); } List couponUserViews = couponUserMapper.countAvailableCouponList(goodsId, skuId, userId, isRenew); Integer total = couponUserViews.size(); if (goodsDonSkuView.getType() == 2) { List collect = couponUserViews.stream().filter(coupon -> { if (coupon.getType() == Coupon.Type.reduce && skuMoney.compareTo(coupon.getReduceCondition()) < 0) { return false; } return true; }).collect(Collectors.toList()); total = collect.size(); } return GatewayResponse.SUCCESS.newBuilder().toResult(total); } @GetMapping("/available/list") public Result> availableCouponList(Long skuId, Long couponId, Boolean isRenew, @RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) { Long userId = StpUserUtil.getLoginIdAsLong(); Page couponActiveViewList = couponFontService.getAvailableCouponList(skuId, couponId, userId, isRenew, start, limit); return GatewayResponse.SUCCESS.newBuilder().toResult(couponActiveViewList); } /** * 推荐优惠券列表 */ @GetMapping("/recommend/list") public Result> getRecommendList(@RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) { Long userId = StpUserUtil.getLoginIdAsLong(); CouponNewUserView couponNewUserView = beanSearcher.searchFirst(CouponNewUserView.class, MapUtils.builder().field(CouponNewUserView::getUserId, userId).op(Operator.Equal).build()); Boolean isNewUser = true; if (couponNewUserView != null) { isNewUser = false; } Page page = couponRecommendMapper.getRecommendCouponViewList(userId, isNewUser, new Page<>(start, limit)); page.getRecords().forEach(data -> { if (data.getCouponStatus() == CouponActiveView.CouponStatus.received) { data.setValidStartTime(data.getUserValidStartTime()); data.setValidEndTime(data.getUserValidEndTime()); } String str = couponSkuMapper.selectGoodsSkuStr(data.getCouponId()); data.setGoodsSkuStr(str.replaceAll(",", "/").replaceAll(";", "")); List couponSkus = couponSkuMapper.getGoodsSkuByCouponId(data.getCouponId()); try { data.setGoodsSkuIds(Jsons.toJson(couponSkus)); } catch (Exception e) { } }); return GatewayResponse.SUCCESS.newBuilder().toResult(page); } /** * 一键领取推荐优惠券 */ @PostMapping("/collect/recommend/whole") @NoSubmit public Result collectWholeRecommendCoupon() { Long userId = StpUserUtil.getLoginIdAsLong(); couponFontService.collectWholeRecommendCoupon(userId); return GatewayResponse.SUCCESS.newBuilder().toResult("领取成功"); } /** * 今日推荐优惠券弹窗已弹 */ @GetMapping("/get/recommend/appear") public Result recommendIsAppear() { Long userId = StpUserUtil.getLoginIdAsLong(); String zero = DateUtil.beginOfDay(DateTime.now()).toString(); Object exists = redisService.get(RedisService.key.RECOMMEND_COUPON_DAY.getNameFormat(String.format("%s-%s", zero, userId))); if (exists == null) { redisService.set(RedisService.key.RECOMMEND_COUPON_DAY.getNameFormat(String.format("%s-%s", zero, userId)), userId, RedisService.key.RECOMMEND_COUPON_DAY.getTimeout()); } return GatewayResponse.SUCCESS.newBuilder().toResult(exists == null ? false : true); } /** * 领取优惠券 */ @PostMapping("/collect") public Result collectCoupon(@RequestBody CouponCollectReq couponCollectReq) { Long userId = StpUserUtil.getLoginIdAsLong(); couponFontService.collectCoupon(couponCollectReq, userId); return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠券成功"); } /** * 领取推荐优惠券 */ @PostMapping("/recommend/collect") public Result collectRecommendCoupon(@RequestBody CouponCollectReq couponCollectReq) { Long userId = StpUserUtil.getLoginIdAsLong(); couponFontService.collectRecommendCoupon(couponCollectReq, userId); return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠券成功"); } /** * 查询有可以领取的推荐优惠券 */ @GetMapping("/recommend/collect/num") public Result collectRecommendCouponNum() { Long userId = StpUserUtil.getLoginIdAsLong(); CouponNewUserView couponNewUserView = beanSearcher.searchFirst(CouponNewUserView.class, MapUtils.builder().field(CouponNewUserView::getUserId, userId).op(Operator.Equal).build()); Boolean isNewUser = true; if (couponNewUserView != null) { isNewUser = false; } Integer num = couponFontService.collectRecommendCouponNum(userId, isNewUser); return GatewayResponse.SUCCESS.newBuilder().toResult(num); } /** * 优惠码详情 */ @GetMapping("/get/exCode/detail") public Result getExCodeDetail(Long skuId, String exCode, Boolean isRenew) { Long userId = StpUserUtil.getLoginIdAsLong(); GoodsDonSkuView goodsDonSkuView = beanSearcher.searchFirst(GoodsDonSkuView.class, MapUtils.builder().field(GoodsDonSkuView::getSkuId, skuId).op(Operator.Equal).build()); if (goodsDonSkuView == null) { throw BusinessRuntimeException.getInstance("该规格不存在"); } BigDecimal skuMoney = goodsDonSkuView.getMoney(); if (goodsDonSkuView.getType() == 2) { throw BusinessRuntimeException.getInstance("实物不支持使用优惠码"); } CouponPopularizeDto dto = couponMapper.checkExCode(exCode); if (dto == null) { throw BusinessRuntimeException.getInstance("该优惠码不存在"); } if (dto.getScope() == Coupon.Scope.newUser) { CouponNewUserView couponNewUserView = beanSearcher.searchFirst(CouponNewUserView.class, MapUtils.builder().field(CouponNewUserView::getUserId, userId).op(Operator.Equal).build()); if (couponNewUserView != null) { throw BusinessRuntimeException.getInstance("该优惠码只适用于新用户"); } } if (isRenew != null && isRenew) { Coupon.UseScope useScope = dto.getUseScope(); if (useScope == Coupon.UseScope.orders) { throw BusinessRuntimeException.getInstance("该优惠码续费时不可使用"); } } if (isRenew == null && !isRenew) { Coupon.UseScope useScope = dto.getUseScope(); if (useScope == Coupon.UseScope.renew) { throw BusinessRuntimeException.getInstance("该优惠码下单时不可使用"); } } if (dto.getIsValidTime() && dto.getValidStartTime().after(DateTime.now())) { throw BusinessRuntimeException.getInstance("该优惠码待生效"); } if (dto.getIsValidTime() && dto.getValidEndTime().before(DateTime.now())) { throw BusinessRuntimeException.getInstance("该优惠码已失效"); } CouponSku couponSku = couponSkuMapper.selectOne(Wrappers.lambdaQuery(CouponSku.class) .eq(CouponSku::getSkuId, skuId) .eq(CouponSku::getCouponId, dto.getCouponId()) .select(CouponSku::getId).last("limit 1")); if (couponSku == null) { throw BusinessRuntimeException.getInstance("该优惠码不适用于该规格"); } if (goodsDonSkuView.getType() == 2) { if (dto.getType() == Coupon.Type.reduce && skuMoney.compareTo(dto.getReduceCondition()) < 0) { throw BusinessRuntimeException.getInstance(String.format("满%s可用", dto.getReduceCondition().divide(BigDecimal.valueOf(100)))); } } return GatewayResponse.SUCCESS.newBuilder().toResult(dto); } /** * 查询优惠券 */ @GetMapping("/get/couponList") public Result> getCouponList(@RequestParam(value = "couponIds") List couponIds) { if (couponIds.isEmpty()) { return GatewayResponse.SUCCESS.newBuilder().toResult(); } List couponViews = beanSearcher.searchAll(CouponView.class, MapUtils.builder().field(CouponView::getId, couponIds).op(Operator.InList).build()); return GatewayResponse.SUCCESS.newBuilder().toResult(couponViews); } }