yhlxj/netflix-web/src/main/java/com/cyksj/web/controller/coupon/CouponFrontController.java

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<SearchResult<CouponActiveView>> couponCenterList(HttpServletRequest request) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		SearchResult<CouponActiveView> 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<SearchResult<CouponUserView>> couponPersonalList(HttpServletRequest request) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		SearchResult<CouponUserView> 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<SearchResult<CouponUserView>> availableCouponList(Long skuId) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		Integer count = couponUserMapper.countAvailableCouponList(skuId, userId);
		SearchResult<CouponUserView> couponUserViews = new SearchResult<>();
		if (count != 0) {
			List<CouponUserView> couponActiveViewList = couponFontService.getAvailableCouponList(skuId, userId);
			couponUserViews = new SearchResult<>(couponActiveViewList);
		}
		couponUserViews.setTotalCount(count);
		return GatewayResponse.SUCCESS.newBuilder().toResult(couponUserViews);
	}

	/**
	 * 推荐优惠卷列表
	 */
	@GetMapping("/recommend/list")
	public Result<SearchResult<CouponRecommendView>> getRecommendList(HttpServletRequest request) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		CouponNewUserView couponNewUserView = beanSearcher.searchFirst(CouponNewUserView.class, MapUtils.builder().field(CouponNewUserView::getUserId, userId).op(Operator.Equal).build());
		SearchResult<CouponRecommendView> 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<String> collectWholeRecommendCoupon() {
		Long userId = StpUserUtil.getLoginIdAsLong();
		couponFontService.collectWholeRecommendCoupon(userId);
		return GatewayResponse.SUCCESS.newBuilder().toResult("领取成功");
	}

	/**
	 * 今日推荐优惠卷弹窗已弹
	 */
	@GetMapping("/get/recommend/appear")
	public Result<Boolean> 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<String> collectCoupon(@RequestBody CouponCollectReq couponCollectReq) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		couponFontService.collectCoupon(couponCollectReq, userId);
		return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠卷成功");
	}

	/**
	 * 领取推荐优惠卷
	 */
	@PostMapping("/recommend/collect")
	@Deprecated
	public Result<String> collectRecommendCoupon(@RequestBody CouponCollectReq couponCollectReq) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		couponFontService.collectRecommendCoupon(couponCollectReq, userId);
		return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠卷成功");
	}
}