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.cyksj.dto.Result; import com.cyksj.enums.GatewayResponse; import com.cyksj.mapper.manage.coupon.CouponUserMapper; import com.cyksj.model.entity.Coupon; import com.cyksj.model.entity.CouponUser; import com.cyksj.model.request.CouponCollectReq; import com.cyksj.model.views.CouponActiveView; import com.cyksj.model.views.CouponNewUserView; import com.cyksj.model.views.CouponRecommendView; import com.cyksj.model.views.CouponUserView; 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; import java.util.List; /* *项目名: 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; /** * 优惠卷领取中心列表 */ @GetMapping("/center/list") public Result> couponCenterList(HttpServletRequest request) { Long userId = StpUserUtil.getLoginIdAsLong(); SearchResult search = beanSearcher.search(CouponActiveView.class, MapUtils.flatBuilder(request.getParameterMap()).build()); search.getDataList().forEach(data -> { CouponUser couponUser = couponUserMapper.selectOne(Wrappers.lambdaQuery(CouponUser.class).eq(CouponUser::getCouponId, data.getCouponId()).eq(CouponUser::getUserId, userId).select(CouponUser::getId).last("limit 1")); if (couponUser == null) { if (data.getRemainNum() <= 0) { //已领完 data.setCouponStatus(CouponActiveView.CouponStatus.over); } else { //待领取 data.setCouponStatus(CouponActiveView.CouponStatus.collecting); } } else { //已领取 data.setCouponStatus(CouponActiveView.CouponStatus.received); } }); return GatewayResponse.SUCCESS.newBuilder().toResult(search); } /** * 个人优惠卷列表 */ @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::getId).desc() .build()); couponFontService.handleCouponStatus(search); return GatewayResponse.SUCCESS.newBuilder().toResult(search); } /** * 可用优惠卷 */ @GetMapping("/available/list") public Result> availableCouponList(Long skuId) { Long userId = StpUserUtil.getLoginIdAsLong(); Integer count = couponUserMapper.countAvailableCouponList(skuId, userId); SearchResult couponUserViews = new SearchResult<>(); if (count != 0) { List couponActiveViewList = couponFontService.getAvailableCouponList(skuId, userId); couponUserViews = new SearchResult<>(couponActiveViewList); } couponUserViews.setTotalCount(count); return GatewayResponse.SUCCESS.newBuilder().toResult(couponUserViews); } /** * 推荐优惠卷列表 */ @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); } }); 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") public Result collectCoupon(@RequestBody CouponCollectReq couponCollectReq) { Long userId = StpUserUtil.getLoginIdAsLong(); couponFontService.collectCoupon(couponCollectReq, userId); return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠卷成功"); } /** * 领取推荐优惠卷 */ @PostMapping("/recommend/collect") @Deprecated public Result collectRecommendCoupon(@RequestBody CouponCollectReq couponCollectReq) { Long userId = StpUserUtil.getLoginIdAsLong(); couponFontService.collectRecommendCoupon(couponCollectReq, userId); return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠卷成功"); } }