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.dto.Result; import com.cyksj.enums.GatewayResponse; import com.cyksj.mapper.manage.coupon.CouponMapper; 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.CouponUser; 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.SearchResult; import com.ejlchina.searcher.param.Operator; import com.ejlchina.searcher.util.MapUtils; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; /* *项目名: 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; /** * 优惠卷领取中心列表 */ @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(HttpServletRequest request) { Long userId = StpUserUtil.getLoginIdAsLong(); SearchResult search = beanSearcher.search(CouponUserView.class, MapUtils.flatBuilder(request.getParameterMap()) .field(CouponUserView::getUserId, userId) .orderBy(CouponUserView::getOrderBy).asc() .build()); couponFontService.handleCouponStatus(search); return GatewayResponse.SUCCESS.newBuilder().toResult(search); } /** * 可用优惠卷展示数量 */ @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.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, Boolean isRenew, @RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) { Long userId = StpUserUtil.getLoginIdAsLong(); Page couponActiveViewList = couponFontService.getAvailableCouponList(skuId, userId, isRenew, start, limit); return GatewayResponse.SUCCESS.newBuilder().toResult(couponActiveViewList); } /** * 推荐优惠卷列表 */ @GetMapping("/recommend/list") public Result> getRecommendList(HttpServletRequest request) { Long userId = StpUserUtil.getLoginIdAsLong(); CouponNewUserView couponNewUserView = beanSearcher.searchFirst(CouponNewUserView.class, MapUtils.builder().field(CouponNewUserView::getUserId, userId).op(Operator.Equal).build()); SearchResult search = beanSearcher.search(CouponRecommendView.class, MapUtils.flatBuilder(request.getParameterMap()) .orderBy(CouponRecommendView::getId).desc() .build()); search.getDataList().stream().filter(data -> { //过滤新用户优惠卷 if (data.getScope() == Coupon.Scope.newUser && couponNewUserView != null) { return false; } return true; }).forEach(data -> { CouponUser couponUser = couponUserMapper.selectOne(Wrappers.lambdaQuery(CouponUser.class).eq(CouponUser::getCouponId, data.getCouponId()).select(CouponUser::getId).last("limit 1")); if (couponUser == null) { //待领取 data.setCouponStatus(CouponActiveView.CouponStatus.collecting); } else { //已领取 data.setCouponStatus(CouponActiveView.CouponStatus.received); } String str = couponSkuMapper.selectGoodsSkuStr(data.getCouponId()); data.setGoodsSkuStr(str.replaceAll(",", "/").replaceAll(";", "")); }); return GatewayResponse.SUCCESS.newBuilder().toResult(search); } /** * 一键领取推荐优惠卷 */ @PostMapping("/collect/recommend/whole") 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") @NoSubmit public Result collectCoupon(@RequestBody CouponCollectReq couponCollectReq) { Long userId = StpUserUtil.getLoginIdAsLong(); couponFontService.collectCoupon(couponCollectReq, userId); return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠卷成功"); } /** * 领取推荐优惠卷 */ @PostMapping("/recommend/collect") @NoSubmit 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(); Integer num = couponFontService.collectRecommendCouponNum(userId); return GatewayResponse.SUCCESS.newBuilder().toResult(num); } /** * 优惠码详情 */ @GetMapping("/get/exCode/detail") public Result getExCodeDetail(String exCode) { CouponPopularizeDto dto = couponMapper.checkExCode(exCode); if (dto == null) { throw BusinessRuntimeException.getInstance("该优惠码不存在"); } return GatewayResponse.SUCCESS.newBuilder().toResult(dto); } }