yhlxj/netflix-web/src/main/java/com/cyksj/web/controller/user/DistributePopularizeController.java

package com.cyksj.web.controller.user;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.extra.qrcode.QrCodeUtil;
import cn.hutool.extra.qrcode.QrConfig;
import com.alipay.api.AlipayResponse;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.cyksj.common.EnvCommonService;
import com.cyksj.common.annotation.NoSubmit;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.exception.BusinessRuntimeException;
import com.cyksj.common.i18n.I18nMessageUtil;
import com.cyksj.common.util.SmsUtil;
import com.cyksj.common.util.ValidatorUtil;
import com.cyksj.dto.Result;
import com.cyksj.enums.GatewayResponse;
import com.cyksj.mapper.GoodsDonMapper;
import com.cyksj.mapper.GoodsDonSkuMapper;
import com.cyksj.mapper.OrderDonMapper;
import com.cyksj.mapper.UserMapper;
import com.cyksj.mapper.manage.coupon.CouponDistributePopularizeMapper;
import com.cyksj.mapper.manage.coupon.CouponMapper;
import com.cyksj.mapper.manage.distribute.DistributeMoneyApplyMapper;
import com.cyksj.mapper.manage.distribute.DistributePointsExchangeMoneyMapper;
import com.cyksj.mapper.manage.distribute.DistributeWaitingSendPointsMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeMapper;
import com.cyksj.model.entity.*;
import com.cyksj.model.request.ApplyMoneyReq;
import com.cyksj.model.request.TransferAccountsReq;
import com.cyksj.model.views.*;
import com.cyksj.service.distribute.DistributeService;
import com.cyksj.service.order.OrderDonService;
import com.cyksj.service.user.UserBenefitsService;
import com.cyksj.service.user.UserService;
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.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;

/*
 *项目名: netflix
 *文件名: DistributePopularizeController
 *创建者: JavaZou
 *创建时间:2022/11/15 13:59
 * 服务端-》我的分发推广controller
 */
@RestController
@RequestMapping("/distribute/popularize")
@RequiredArgsConstructor
public class DistributePopularizeController {
	private final EnvCommonService envCommonService;

	private final UserMapper userMapper;

	private final UserService userService;

	private final BeanSearcher beanSearcher;

	private final GoodsDonMapper goodsDonMapper;

	private final GoodsDonSkuMapper goodsDonSkuMapper;

	private final DistributePointsExchangeMoneyMapper distributePointsExchangeMoneyMapper;

	private final DistributeMoneyApplyMapper distributeMoneyApplyMapper;

	private final UserDistributeMapper userDistributeMapper;

	private final DistributeWaitingSendPointsMapper distributeWaitingSendPointsMapper;

	private final OrderDonMapper orderDonMapper;

	private final OrderDonService orderService;

	private final UserBenefitsService userBenefitsService;

	private final DistributeService distributeService;

	private final CouponDistributePopularizeMapper couponDistributePopularizeMapper;

	private final CouponMapper couponMapper;

	/**
	 * 推广订单明细
	 */
	@GetMapping("/orders/detail")
	public Result<SearchResult<DistributePopularizeOrdersView>> getOrdersView(HttpServletRequest request) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		SearchResult<DistributePopularizeOrdersView> search = beanSearcher.search(DistributePopularizeOrdersView.class,
				MapUtils.flatBuilder(request.getParameterMap())
						.field(DistributePopularizeOrdersView::getSharedId, userId)
						.build());
		DistributePointsExchangeMoney distributePointsExchangeMoney = distributePointsExchangeMoneyMapper.selectOne(Wrappers.lambdaQuery(DistributePointsExchangeMoney.class).orderByDesc(DistributePointsExchangeMoney::getPoints).last("limit 1"));
		BigDecimal points = BigDecimal.valueOf(distributePointsExchangeMoney.getPoints());
		BigDecimal money = distributePointsExchangeMoney.getMoney();
		BigDecimal oneHundred = BigDecimal.valueOf(100);
		search.getDataList().forEach(data -> {
			GoodsDon goodsDon = goodsDonMapper.selectById(data.getGoodsId());
			GoodsDonSku goodsDonSku = goodsDonSkuMapper.selectById(data.getSkuId());
			data.setGoodsTitle(goodsDon.getTitle());
			data.setSpecVal(goodsDonSku.getSpecVal());
			data.setWaitGetMoney(data.getPoints().divide(points).multiply(money).divide(oneHundred));
		});
		return GatewayResponse.SUCCESS.newBuilder().toResult(search);
	}

	/**
	 * 提现明细
	 */
	@GetMapping("/applyMoney/detail")
	public Result<SearchResult<DistributeMoneyApplyView>> getApplyMoneyView(HttpServletRequest request) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		SearchResult<DistributeMoneyApplyView> search = beanSearcher.search(DistributeMoneyApplyView.class,
				MapUtils.flatBuilder(request.getParameterMap())
						.field(DistributeMoneyApplyView::getUserId, userId).op(Operator.Equal)
						.build());
		return GatewayResponse.SUCCESS.newBuilder().toResult(search);
	}

	/**
	 * 个人推广详情
	 */
	@GetMapping("/get/detail")
	public Result<DistributePopularizeView> getDetail() {
		Long userId = StpUserUtil.getLoginIdAsLong();
		User user = userMapper.selectById(userId);
		if (StrUtil.isEmpty(user.getShowId())) {
			user.setShowId(userService.getUserShowId(userId));
		}
		DistributePopularizeView distributePopularizeView = new DistributePopularizeView();
		String dsUrl = String.format(envCommonService.DISTRIBUTE_DEFAULT_URL_PREFIX, user.getShowId());
//		distributePopularizeView.setUrl(String.format("https://%s/8081/api/auth/weChat?url=https://%s/yinhe/web&sharedId=%s", domain, domain, userId));
		distributePopularizeView.setUrl(dsUrl);
		distributePopularizeView.setUrlCode(QrCodeUtil.generateAsBase64(distributePopularizeView.getUrl(), QrConfig.create(), "png"));
		distributePopularizeView.setGotPoints(user.getPoints());
		Integer orders = userDistributeMapper.count(userId);
		distributePopularizeView.setDistributeOrders(orders);
		UserDistribute userDistribute = userDistributeMapper.selectOne(Wrappers.lambdaQuery(UserDistribute.class).eq(UserDistribute::getUserId, userId).select(UserDistribute::getId).last("limit 1"));
		if (userDistribute != null) {
			//是否是固定推广者
			UserDistributeView userDistributeView = beanSearcher.searchFirst(UserDistributeView.class, MapUtils.builder()
					.field(UserDistributeView::getDistribute_id, userDistribute.getId()).op(Operator.Equal)
					.orderBy(UserDistributeView::getRate).desc()
					.build());
			//最高平台比例
			distributePopularizeView.setHighestRate(userDistributeView.getRate());
		} else {
			GoodsDon goodsDon = goodsDonMapper.selectOne(Wrappers.lambdaQuery(GoodsDon.class).eq(GoodsDon::getDeleted, true).eq(GoodsDon::getStatus, true).orderByDesc(GoodsDon::getRate).select(GoodsDon::getRate).last("limit 1"));
			distributePopularizeView.setIsGeneral(true);
			distributePopularizeView.setHighestRate(goodsDon.getRate());
			Optional.ofNullable(couponDistributePopularizeMapper.selectOne(Wrappers.lambdaQuery(CouponDistributePopularize.class)
					.eq(CouponDistributePopularize::getUserId, userId)
					.eq(CouponDistributePopularize::getIsGeneral, true)
					.last("limit 1")))
					.ifPresent(couponPopularize -> {
						Coupon coupon = couponMapper.getCouponById(couponPopularize.getCouponId());
						distributePopularizeView.setGeneralCode(couponPopularize.getExCode());
						BigDecimal discount = coupon.getDiscount();
						String discountStr = String.format("%s折", discount.multiply(BigDecimal.valueOf(100)).intValue());
						distributePopularizeView.setGeneralDiscount(discountStr);
					});
		}
		List<DistributeWaitingSendPoints> distributeWaitingSendPoints = distributeWaitingSendPointsMapper.selectList(Wrappers.lambdaQuery(DistributeWaitingSendPoints.class).eq(DistributeWaitingSendPoints::getSendStatus, DistributeWaitingSendPoints.Status.waiting).eq(DistributeWaitingSendPoints::getSharedId, userId).select(DistributeWaitingSendPoints::getPoints));
		BigDecimal waitingPoints = BigDecimal.ZERO;
		if (!distributeWaitingSendPoints.isEmpty()) {
			Optional<BigDecimal> points = distributeWaitingSendPoints.stream().map(DistributeWaitingSendPoints::getPoints).reduce(BigDecimal::add);
			if (points.isPresent()) {
				waitingPoints = points.get();
			}
		}
		distributePopularizeView.setWaitingSendPoints(waitingPoints);
		if (user.getPoints().compareTo(BigDecimal.ZERO) <= 0 && waitingPoints.compareTo(BigDecimal.ZERO) <= 0) {
			distributePopularizeView.setGotMoney(BigDecimal.ZERO);
			distributePopularizeView.setWaitingMoney(BigDecimal.ZERO);
		}else {
			DistributePointsExchangeMoney distributePointsExchangeMoney = distributePointsExchangeMoneyMapper.selectOne(Wrappers.lambdaQuery(DistributePointsExchangeMoney.class).orderByDesc(DistributePointsExchangeMoney::getPoints).last("limit 1"));
			BigDecimal points = BigDecimal.valueOf(distributePointsExchangeMoney.getPoints());
			BigDecimal money = distributePointsExchangeMoney.getMoney();
			BigDecimal oneHundred = BigDecimal.valueOf(100);
			if (user.getPoints().compareTo(BigDecimal.ZERO) >= 0) {
				distributePopularizeView.setGotMoney(user.getPoints().divide(points).multiply(money).divide(oneHundred));
			}
			if (user.getPoints().compareTo(BigDecimal.ZERO) >= 0) {
				distributePopularizeView.setWaitingMoney(waitingPoints.divide(points).multiply(money).divide(oneHundred));
			}
		}
		return GatewayResponse.SUCCESS.newBuilder().toResult(distributePopularizeView);
	}

	/**
	 * 个人推广用户每日订单情况折线图
	 */
	@GetMapping("/get/order/brokenLine")
	public Result<BrokenLineObjView> getPersonDistributeBrokenLineView(Long firstDate, Long lastDate) {
		Long userId = StpUserUtil.getLoginIdAsLong();
		String first = null;
		String end = null;
		if (firstDate != null) {
			first = DateUtil.format(DateTime.of(firstDate), "yyyy-MM-dd");
		}
		if (lastDate != null) {
			end = DateUtil.format(DateTime.of(lastDate), "yyyy-MM-dd");
		}
		BrokenLineObjView brokenLineObjView = Optional.ofNullable(orderDonMapper.selectPersonDistributeBrokenLine(userId, first, end))
				.orElse(new BrokenLineObjView());

		if (brokenLineObjView != null) {
			List<PersonDistributeBrokenLineView> views = beanSearcher.searchAll(PersonDistributeBrokenLineView.class, MapUtils.builder()
					.field(PersonDistributeBrokenLineView::getDate, first, end).op(Operator.Between)
					.put("userId", String.format("dw.shared_id = %s", userId))
					.orderBy(PersonDistributeBrokenLineView::getDate).asc()
					.build());
			Map<Long, List<PersonDistributeBrokenLineView>> distributeMap = views.stream().collect(Collectors.groupingBy(PersonDistributeBrokenLineView::getGoodsId));
			brokenLineObjView.setDistributeData(distributeMap);
		}
		return GatewayResponse.SUCCESS.newBuilder().toResult(brokenLineObjView);
	}


	/**
	 * 提现
	 */
	@NoSubmit
	@PostMapping("/post/applyMoney")
	@Transactional(rollbackFor = Throwable.class)
	public Result<DistributeMoneyApply> applyMoney(@RequestBody ApplyMoneyReq applyMoneyReq) throws Exception {
		Long userId = StpUserUtil.getLoginIdAsLong();
		User user = userMapper.selectById(userId);
		if (user == null) {
			throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("login_code_expired"));
		}
		Boolean isTakeAll = applyMoneyReq.getIsTakeAll();
		DistributeMoneyApply.Type type = applyMoneyReq.getType();
		if (type == null) type = DistributeMoneyApply.Type.zfb;
		if (type == DistributeMoneyApply.Type.zfb) {
			if (ObjectUtil.hasEmpty(applyMoneyReq.getAccount(), applyMoneyReq.getRealName())) {
				throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("params_error"));
			}
			if (applyMoneyReq.getAccount().length() > 255 || applyMoneyReq.getRealName().length() > 32) {
				throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("distribute_apply_money_account_error"));
			}
		}
		if (type == DistributeMoneyApply.Type.usdt) {
			if (StrUtil.isEmpty(applyMoneyReq.getWalletAddr())) {
				throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("distribute_apply_money_usdt_address_error"));
			}
			if (applyMoneyReq.getWalletAddr().length() > 1000) {
				throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("distribute_apply_money_usdt_address_error"));
			}
			if (StrUtil.isNotBlank(applyMoneyReq.getRemark()) && applyMoneyReq.getRemark().length() > 512) {
				throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("distribute_apply_money_remark_length_error"));
			}
			isTakeAll = true;

		}
		DistributeMoneyApply distributeMoneyApply = null;
		if (type == DistributeMoneyApply.Type.pwdRed) {
			distributeMoneyApply = userDistributeMapper.selectRelationBusiness(userId);
			isTakeAll = true;
		}
		BigDecimal userPoints = user.getPoints();
		DistributePointsExchangeMoney distributePointsExchangeMoney = distributePointsExchangeMoneyMapper.selectOne(Wrappers.lambdaQuery(DistributePointsExchangeMoney.class).orderByDesc(DistributePointsExchangeMoney::getPoints).last("limit 1"));
		BigDecimal minPoints = BigDecimal.valueOf(distributePointsExchangeMoney.getMinPoints());
		BigDecimal ratePoints = BigDecimal.valueOf(distributePointsExchangeMoney.getPoints());
		BigDecimal minMoney = distributePointsExchangeMoney.getMoney();
		if (userPoints.compareTo(minPoints) < 0) {
			throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("distribute_apply_money_thresholds_error"));
		}
//		//今日是否已提现
//		DistributeMoneyApply apply = distributeMoneyApplyMapper.selectOne(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getUserId, userId).between(DistributeMoneyApply::getCreatedTime, DateUtil.beginOfDay(DateTime.now()), DateUtil.endOfDay(DateTime.now())).last("limit 1"));
//		if (apply != null) {
//			throw BusinessRuntimeException.getInstance("今日已提现,请明日再进行操作");
//		}
		BigDecimal num = userPoints.divide(ratePoints, 0, RoundingMode.DOWN);
		BigDecimal needApplyMoney = num.multiply(minMoney);
		BigDecimal needSubPoints = num.multiply(ratePoints);
		BigDecimal fourHundred = BigDecimal.valueOf(4 * 100 * 100);
		if (isTakeAll == null || !isTakeAll) {
			if (needApplyMoney.compareTo(fourHundred) > 0) {
				needApplyMoney = fourHundred;
				needSubPoints = fourHundred.divide(minMoney).multiply(ratePoints);
			}
		}
		Integer update = userMapper.subPoints(user.getId(), needSubPoints);
		if (update == 1) {
			distributeMoneyApply = Optional.ofNullable(distributeMoneyApply).orElse(new DistributeMoneyApply());
			distributeMoneyApply.setUserId(userId);
			distributeMoneyApply.setPoints(needSubPoints);
			distributeMoneyApply.setMoney(needApplyMoney);
			distributeMoneyApply.setAccount(applyMoneyReq.getAccount());
			distributeMoneyApply.setRealName(applyMoneyReq.getRealName());
			distributeMoneyApply.setWalletAddr(applyMoneyReq.getWalletAddr());
			distributeMoneyApply.setRemark(applyMoneyReq.getRemark());
			distributeMoneyApply.setType(applyMoneyReq.getType());
			if (isTakeAll != null && isTakeAll) {
				distributeMoneyApply.setVerifyStatus(DistributeMoneyApply.Status.verifying);
			} else {
				TransferAccountsReq req = new TransferAccountsReq();
				req.setMoney(needApplyMoney);
				req.setAccount(applyMoneyReq.getAccount());
				req.setName(applyMoneyReq.getRealName());
				req.setPoints(needSubPoints);
				req.setUserId(userId);
				AlipayResponse alipayResponse = orderService.transferAccounts(req);
				if (alipayResponse.isSuccess()) {
					distributeMoneyApply.setVerifyStatus(DistributeMoneyApply.Status.success);
				} else {
					distributeMoneyApply.setVerifyStatus(DistributeMoneyApply.Status.fail);
					distributeMoneyApply.setReason(alipayResponse.getSubMsg());
					userBenefitsService.addDistributePoints(userId, distributeMoneyApply.getPoints());
					if (StrUtil.equals(alipayResponse.getSubCode(), "SECURITY_CHECK_FAILED")) {
						return GatewayResponse.FAIL.newBuilder().setMsg("当前支付宝提现人数较多，请稍后再试").toResult();
					}
					return GatewayResponse.FAIL.newBuilder().setMsg(alipayResponse.getSubMsg()).toResult();
				}
			}
			try {
				distributeMoneyApplyMapper.insert(distributeMoneyApply);
				//大额提现 超过400
				if (distributeMoneyApply.getVerifyStatus() == DistributeMoneyApply.Status.verifying && distributeMoneyApply.getMoney().compareTo(fourHundred) > 0) {
					SmsUtil.sendLuoKey2Msg(Constant.ZK_MOBILE, "海外推广有大额提现申请【银河录像局】");
				}
			} catch (Exception e) {
				userBenefitsService.addDistributePoints(userId, distributeMoneyApply.getPoints());
				return GatewayResponse.FAIL.newBuilder().setMsg(I18nMessageUtil.getI18nMsg("sys_error")).toResult();
			}
			return GatewayResponse.SUCCESS.newBuilder().toResult(distributeMoneyApply);
		}
		throw BusinessRuntimeException.getInstance(I18nMessageUtil.getI18nMsg("sys_error"));
	}

	/**
	 * 获取积分兑换门槛
	 */
	@GetMapping("/applyMoney/threshold")
	public Result<DistributePointsExchangeMoney> getThreshold() {
		return GatewayResponse.SUCCESS.newBuilder().toResult(distributePointsExchangeMoneyMapper.selectOne(Wrappers.lambdaQuery(DistributePointsExchangeMoney.class).last("limit 1")));
	}

	/**
	 * 提现缓存数据
	 */
	@GetMapping("/get/applyMoney/detail")
	public Result<DistributeMoneyApply> getLastApplyDetail() {
		Long userId = StpUserUtil.getLoginIdAsLong();
		DistributeMoneyApply apply = distributeMoneyApplyMapper.selectOne(Wrappers.lambdaQuery(DistributeMoneyApply.class).eq(DistributeMoneyApply::getUserId, userId).orderByDesc(DistributeMoneyApply::getId).last("limit 1"));
		return GatewayResponse.SUCCESS.newBuilder().toResult(apply);
	}

	/**
	 * 是否是普通分销者
	 */
	@GetMapping("/get/isGeneral/distribute")
	public Result<Boolean> isGeneralDistribute() {
		Long userId = StpUserUtil.getLoginIdAsLong();
		UserDistribute userDistribute = userDistributeMapper.selectOne(Wrappers.lambdaQuery(UserDistribute.class)
				.eq(UserDistribute::getUserId, userId));
		if (userDistribute != null) {
			return GatewayResponse.SUCCESS.newBuilder().toResult(false);
		}
		return GatewayResponse.SUCCESS.newBuilder().toResult(true);
	}

	/**
	 * 普通分销者弹窗
	 */
	@GetMapping("/get/general/distribute/detail")
	public Result<DistributePopularizeView> getGeneralDistributeDetail() {
		Long userId = StpUserUtil.getLoginIdAsLong();
		List<GoodsDon> goodsDons = goodsDonMapper.selectList(Wrappers.lambdaQuery(GoodsDon.class).eq(GoodsDon::getDeleted, true).gt(GoodsDon::getRate, 0).orderByAsc(GoodsDon::getRate).select(GoodsDon::getRate, GoodsDon::getTitle));
		if (goodsDons.isEmpty()) {
			return GatewayResponse.SUCCESS.newBuilder().toResult();
		}
		DistributePopularizeView distributePopularizeView = new DistributePopularizeView();
		GoodsDon highestRateGoods = goodsDons.get(goodsDons.size() - 1);
		distributePopularizeView.setHighestRate(highestRateGoods.getRate());
		List<GoodsDon> generalDistributes = goodsDons.stream().filter(gd -> !gd.getRate().equals(highestRateGoods.getRate())).collect(Collectors.toList());
		distributePopularizeView.setGeneralDistributes(generalDistributes);
		return GatewayResponse.SUCCESS.newBuilder().toResult(distributePopularizeView);
	}

	/**
	 * 设置普通推广码
	 * 绑定个人专属码
	 */
	@PostMapping("/general/code/{code}")
	public Result<String> setGeneralCode(@PathVariable("code") String code) {
		long userId = StpUserUtil.getLoginIdAsLong();
		if (StrUtil.isBlank(code)) {
			throw BusinessRuntimeException.getInstance("专属推广优惠码不能为空");
		}
		if (!ValidatorUtil.isEnNum(code) || code.length() > 20) {
			throw BusinessRuntimeException.getInstance("请输入英文数字组合的专属推广优惠码");
		}
		code = code.trim();
		distributeService.bindPopularizeCode(userId, code);
		return GatewayResponse.SUCCESS.newBuilder().toResult("设置成功");
	}
}