package com.cyksj.web.controller.coupon; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; 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.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.util.List; import java.util.Set; 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(";", "")); }); 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(";", "")); }); 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("规格不存在"); } if (goodsDonSkuView.getType() == 2) { goodsId = goodsDonSkuView.getGoodsId(); } Integer count = couponUserMapper.countAvailableCouponList(goodsId, skuId, userId, isRenew); return GatewayResponse.SUCCESS.newBuilder().toResult(count); } @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(";", "")); }); 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); } 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) throws Exception { 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("该规格不存在"); } 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 (dto.getIsValidTime() && dto.getValidStartTime().after(DateTime.now())) { throw BusinessRuntimeException.getInstance("该优惠码未失效"); } if (dto.getIsValidTime() && dto.getValidEndTime().before(DateTime.now())) { throw BusinessRuntimeException.getInstance("该优惠码已失效"); } List skuIds = Jsons.parseList(dto.getGoodsSkuIds(), Coupon.CouponGoodsSku.class); Set collect = skuIds.stream().map(Coupon.CouponGoodsSku::getSkuId).collect(Collectors.toSet()); if (!collect.contains(skuId)) { throw BusinessRuntimeException.getInstance("该优惠码不适用于该规格"); } return GatewayResponse.SUCCESS.newBuilder().toResult(dto); } }