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.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<Page<CouponActiveView>> couponCenterList(@RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		Page<CouponActiveView> 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<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::getOrderBy).asc()
						.build());
		couponFontService.handleCouponStatus(search);
		return GatewayResponse.SUCCESS.newBuilder().toResult(search);
	}

	/**
	 * 可用优惠卷展示数量
	 */
	@GetMapping("/available/num")
	public Result<Integer> 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<Page<CouponUserView>> availableCouponList(Long skuId, Boolean isRenew, @RequestParam(defaultValue = "1") Long start, @RequestParam(defaultValue = "5") Long limit) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		Page<CouponUserView> couponActiveViewList = couponFontService.getAvailableCouponList(skuId, userId, isRenew, start, limit);
		return GatewayResponse.SUCCESS.newBuilder().toResult(couponActiveViewList);
	}

	/**
	 * 推荐优惠卷列表
	 */
	@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);
			}
			String str = couponSkuMapper.selectGoodsSkuStr(data.getCouponId());
			data.setGoodsSkuStr(str.replaceAll(",", "/").replaceAll(";", ""));
		});
		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")
	@NoSubmit
	public Result<String> collectCoupon(@RequestBody CouponCollectReq couponCollectReq) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		couponFontService.collectCoupon(couponCollectReq, userId);
		return GatewayResponse.SUCCESS.newBuilder().toResult("领取优惠卷成功");
	}

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

	/**
	 * 查询有可以领取的推荐优惠卷
	 */
	@GetMapping("/recommend/collect/num")
	public Result<Integer> collectRecommendCouponNum() {
		Long userId = StpUserUtil.getLoginIdAsLong();
		Integer num = couponFontService.collectRecommendCouponNum(userId);
		return GatewayResponse.SUCCESS.newBuilder().toResult(num);
	}


	/**
	 * 优惠码详情
	 */
	@GetMapping("/get/exCode/detail")
	public Result<CouponPopularizeDto> getExCodeDetail(String exCode) {
		CouponPopularizeDto dto = couponMapper.checkExCode(exCode);
		if (dto == null) {
			throw BusinessRuntimeException.getInstance("该优惠码不存在");
		}
		return GatewayResponse.SUCCESS.newBuilder().toResult(dto);
	}
}