yhlxj/netflix-service/src/main/java/com/cyksj/service/distribute/impl/UserBusinessFrontServiceImpl.java

package com.cyksj.service.distribute.impl;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.cyksj.common.constant.Constant;
import com.cyksj.mapper.OrderDonMapper;
import com.cyksj.mapper.UserRenewChangeTicketRecordMapper;
import com.cyksj.mapper.manage.distribute.UserBusinessDefaultRateConfigMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeBusinessOrderDonRecordMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeBusinessRateMapper;
import com.cyksj.model.entity.*;
import com.cyksj.redis.RedisService;
import com.cyksj.service.distribute.UserBusinessFrontService;
import com.ejlchina.searcher.BeanSearcher;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;

/*
 *项目名: netflix
 *文件名: UserBusinessFrontServiceImpl
 *创建者: JavaZou
 *创建时间:2023/3/23 14:20
 */
@Service
@RequiredArgsConstructor
@Slf4j
public class UserBusinessFrontServiceImpl implements UserBusinessFrontService {
	private final BeanSearcher beanSearcher;

	private final UserDistributeBusinessRateMapper userDistributeBusinessRateMapper;

	private final OrderDonMapper orderDonMapper;

	private final UserDistributeBusinessOrderDonRecordMapper businessOrderDonRecordMapper;

	private final UserRenewChangeTicketRecordMapper renewChangeTicketRecordMapper;

	private final RedisService redisService;

	private final UserBusinessDefaultRateConfigMapper defaultRateConfigMapper;

	@Override
	public void taskDistributeRateBenefits(Long sharedId, Long businessId, OrderDon order, Integer distributeRate) {
		UserDistributeBusinessRate businessRate = userDistributeBusinessRateMapper.selectOne(Wrappers.lambdaQuery(UserDistributeBusinessRate.class)
				.eq(UserDistributeBusinessRate::getBusinessId, businessId)
				.eq(UserDistributeBusinessRate::getGoodsId, order.getGoodsId())
				.eq(UserDistributeBusinessRate::getSkuId, order.getSkuId()).last("limit 1"));
		if (businessRate != null) {
			//首单
			if (order.getOrderType() == 1) {
				log.info("商务首单orderId:{}分销分配提成开始", order.getId());
				//用户之前是否下过单
				Integer count = orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
						.eq(OrderDon::getUserId, order.getUserId())
						.ne(OrderDon::getId, order.getId()).notIn(OrderDon::getStatus, Constant.noOrderAllStatus));
				if (count == 0) {
					//是否享受过该用户带来的首单 提成
					UserDistributeBusinessOrderDonRecord record = businessOrderDonRecordMapper.selectOne(Wrappers.lambdaQuery(UserDistributeBusinessOrderDonRecord.class)
							.eq(UserDistributeBusinessOrderDonRecord::getBusinessId, businessId)
							.eq(UserDistributeBusinessOrderDonRecord::getUserId, order.getUserId())
							.eq(UserDistributeBusinessOrderDonRecord::getOrderType, 1)
							.last("limit 1"));
					if (record == null) {
						try {
							boolean isSuccess = redisService.setNx(RedisService.key.BUSINESS_FIRST_ORDER_USER_KEY.getNameFormat(order.getUserId()), businessId, RedisService.key.BUSINESS_FIRST_ORDER_USER_KEY.getTimeout());
							if (isSuccess) {
								//首单虚物规格 提成
								record = saveBusinessTakeMoneyRecord(order, businessId, sharedId, businessRate.getFirstOrderRate(), null, distributeRate);
								if (record == null) {
									return;
								}
								businessOrderDonRecordMapper.insert(record);
								log.info("开始给商务人员:{}分配分销人:{}分销的用户:{}首单:{}提成", businessId, sharedId, order.getUserId(), order.getId());
							}
						} catch (DuplicateKeyException e) {
							log.error("商务:{}重复获取分销人:{}分销的用户:{}首单:{}提成", businessId, businessId, order.getUserId(), order.getId());
						}
					}
				}
			}
			//续费
			if (order.getOrderType() == 2) {
				log.info("商务首单续费分销分配提成开始");
				//是否享受过该用户首单 提成
				UserDistributeBusinessOrderDonRecord record = businessOrderDonRecordMapper.selectOne(Wrappers.lambdaQuery(UserDistributeBusinessOrderDonRecord.class)
						.eq(UserDistributeBusinessOrderDonRecord::getBusinessId, businessId)
						.eq(UserDistributeBusinessOrderDonRecord::getUserId, order.getUserId())
						.eq(UserDistributeBusinessOrderDonRecord::getOrderType, 1).last("limit 1"));
				if (record != null) {
					log.info("开始给商务人员:{}分配用户:{}首单续费提成", businessId, order.getUserId());
					//是否更换过车票规格座位号
					Long preRelationId = record.getPreRelationId();
					Long relationId = order.getRelationId();
					if (relationId.equals(preRelationId)) {
						try {
							//分配首单续费提成
							record = saveBusinessTakeMoneyRecord(order, businessId, sharedId, null, businessRate.getRenewOrderRate(), distributeRate);
							if (record == null) {
								return;
							}
							businessOrderDonRecordMapper.insert(record);
							log.info("开始给商务人员:{}分配分销人:{}分销的用户:{}续费首单:{}提成", businessId, sharedId, order.getUserId(), order.getId());
						} catch (DuplicateKeyException e) {
							log.error("商务:{}重复获取分销人:{}分销的用户:{}续费首单:{}提成", businessId, businessId, order.getUserId(), order.getId());
						}
					} else {
						UserRenewChangeTicketRecord renewChangeTicketRecord = renewChangeTicketRecordMapper.selectOne(Wrappers.lambdaQuery(UserRenewChangeTicketRecord.class)
								.eq(UserRenewChangeTicketRecord::getUserId, order.getUserId())
								.eq(UserRenewChangeTicketRecord::getAfterRelationId, relationId)
								.last("limit 1"));
						if (renewChangeTicketRecord != null && renewChangeTicketRecord.getPreRelationId().equals(preRelationId)) {
							try {
								//分配首单续费更换车位后提成
								record = saveBusinessTakeMoneyRecord(order, businessId, sharedId, null, businessRate.getRenewOrderRate(), distributeRate);
								if (record == null) {
									return;
								}
								businessOrderDonRecordMapper.insert(record);
								log.info("开始给商务人员:{}分配分销人:{}分销的用户:{}续费首单:{}更换后车位提成", businessId, sharedId, order.getUserId(), order.getId());
							} catch (DuplicateKeyException e) {
								log.error("商务:{}重复获取分销人:{}分销的用户:{}续费首单:{}更换后车位提成", businessId, businessId, order.getUserId(), order.getId());
							}
						}
					}

				}
			}
		}
	}


	/**
	 * 保存商务分配提成记录
	 */
	public UserDistributeBusinessOrderDonRecord saveBusinessTakeMoneyRecord(OrderDon order, Long businessId, Long sharedId, Integer firstOrderRate, Integer renewOrderRate, Integer distributeRate) {
		UserBusinessDefaultRateConfig defaultGoodsRateConfig = defaultRateConfigMapper.selectOne(Wrappers.lambdaQuery(UserBusinessDefaultRateConfig.class)
				.eq(UserBusinessDefaultRateConfig::getGoodsId, order.getGoodsId()).last("limit 1"));
		if (defaultGoodsRateConfig == null) {
			log.info("系统默认商务分销配置未配置,businessId:{},orderId:{}", businessId, order.getId());
			return null;
		}
		UserDistributeBusinessOrderDonRecord record = new UserDistributeBusinessOrderDonRecord();
		record.setBusinessId(businessId);
		record.setUserId(order.getUserId());
		record.setSharedId(sharedId);
		record.setOrderType(order.getOrderType());
		record.setOrderCreatedTime(order.getCreatedTime());
		record.setOrderId(order.getId());
		record.setPreRelationId(order.getRelationId());
		//是否超过默认配置平台比例
		Integer defaultGoodsRate = defaultGoodsRateConfig.getRate();
		//首单提成比例
		BigDecimal orderMoney = order.getMoney();
		BigDecimal takeMoney = BigDecimal.ZERO;
		if (firstOrderRate != null) {
			if (distributeRate > defaultGoodsRate) {
				if (defaultGoodsRateConfig.getIsPlatPay()) {
					log.info("首单,平台承担商务businessId:{}配置分销者sharedId:{}超过平台goodsId:{}标准分销比例:{}", businessId, sharedId, order.getGoodsId(), defaultGoodsRate);
				} else {
					firstOrderRate -= distributeRate - defaultGoodsRate;
					log.info("商务businessId:{}配置分销者sharedId:{}比例超过标准比例,可获取首单提成比例为:{}", businessId, sharedId, firstOrderRate);
					if (firstOrderRate <= 0) {
						log.info("商务businessId:{}获得分销者sharedId:{}首单提成比例不大于0", businessId, sharedId);
						return null;
					}
				}
			}
			record.setRate(firstOrderRate);
			BigDecimal firstRate = BigDecimal.valueOf(firstOrderRate).divide(BigDecimal.valueOf(100));
			takeMoney = orderMoney.multiply(firstRate);
		}
		if (renewOrderRate != null) {
			if (distributeRate > defaultGoodsRate) {
				if (defaultGoodsRateConfig.getIsPlatPay()) {
					log.info("首单续费,平台承担商务businessId:{}配置分销者sharedId:{}超过平台goodsId:{}标准分销比例:{}", businessId, sharedId, order.getGoodsId(), defaultGoodsRate);
				} else {
					renewOrderRate -= distributeRate - defaultGoodsRate;
					log.info("商务businessId:{}配置分销者sharedId:{}比例超过标准比例,可获取首单续费提成比例为:{}", businessId, sharedId, renewOrderRate);
					if (renewOrderRate <= 0) {
						log.info("商务businessId:{}获得分销者sharedId:{}首单续费提成比例不大于0", businessId, sharedId);
						return null;
					}
				}
			}
			record.setRate(renewOrderRate);
			BigDecimal renewRate = BigDecimal.valueOf(renewOrderRate).divide(BigDecimal.valueOf(100));
			takeMoney = orderMoney.multiply(renewRate);
		}
		record.setTakeMoney(takeMoney);
		return record;
	}
}