yhlxj/netflix-service/src/main/java/com/cyksj/service/exchange/impl/ExchangeCodeServiceImpl.java

package com.cyksj.service.exchange.impl;

import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.cyksj.common.annotation.NoSubmit;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.exception.BusinessRuntimeException;
import com.cyksj.common.snowflake.Sequence;
import com.cyksj.common.task.GlobalThreadPoolTaskExecutor;
import com.cyksj.common.util.StringUtil;
import com.cyksj.dto.RedisKey;
import com.cyksj.dto.Result;
import com.cyksj.enums.GatewayResponse;
import com.cyksj.mapper.*;
import com.cyksj.mapper.manage.exchange.ExchangeCodeMapper;
import com.cyksj.mapper.market.draw.LuckyDrawRecordMapper;
import com.cyksj.model.entity.*;
import com.cyksj.model.excel.ExcelExchangeCodeData;
import com.cyksj.model.manage.views.AccountView;
import com.cyksj.model.request.ExchangeCodeReq;
import com.cyksj.model.request.ExchangeCodeTicket;
import com.cyksj.redis.RedisService;
import com.cyksj.service.exchange.ExchangeCodeService;
import com.cyksj.service.relation.GroupRelationFrontService;
import com.cyksj.service.template.TemplateCommonService;
import com.ejlchina.searcher.BeanSearcher;
import com.ejlchina.searcher.util.MapUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Optional;

/*
 *项目名: netflix
 *文件名: ExchangeCodeServiceImpl
 *创建者: JavaZou
 *创建时间:2022/11/7 15:41
 */
@Service
@RequiredArgsConstructor
@Slf4j
public class ExchangeCodeServiceImpl extends ServiceImpl<ExchangeCodeMapper, ExchangeCode> implements ExchangeCodeService {
	private final GoodsDonMapper goodsDonMapper;

	private final GoodsDonSkuMapper goodsDonSkuMapper;

	private final ExchangeCodeMapper exchangeCodeMapper;

	private final GroupsRelationMapper groupsRelationMapper;

	private final GroupsMapper groupsMapper;

	private final RedisService redisService;

	private static final Sequence SEQUENCE = new Sequence(0);

	private final UserMapper userMapper;

	private final OrderDonMapper orderDonMapper;

	private static final GlobalThreadPoolTaskExecutor THREAD_POOL_TASK_EXECUTOR = GlobalThreadPoolTaskExecutor.getInstance();

	private final CustomerServiceMapper customerServiceMapper;

	private final LuckyDrawRecordMapper luckyDrawRecordMapper;

	private final TemplateCommonService templateCommonService;

	private final BeanSearcher beanSearcher;

	private final GroupRelationFrontService groupRelationFrontService;

	@Override
	@Transactional(rollbackFor = Throwable.class)
	public List<ExcelExchangeCodeData> createExchangeCode(ExchangeCodeReq exchangeCodeReq) {
		GoodsDon goodsDon = goodsDonMapper.selectById(exchangeCodeReq.getGoodsId());
		if (goodsDon == null) {
			throw BusinessRuntimeException.getInstance("所选平台已被删除");
		}
		if (Constant.realGoodsType.contains(goodsDon.getType())) {
			throw BusinessRuntimeException.getInstance("该类商品不支持生成兑换码");
		}
		GoodsDonSku goodsDonSku = goodsDonSkuMapper.selectById(exchangeCodeReq.getSkuId());
		if (goodsDonSku == null) {
			throw BusinessRuntimeException.getInstance("所选规格已被删除");
		}
		if (!goodsDonSku.getGoodsId().equals(exchangeCodeReq.getGoodsId())) {
			throw BusinessRuntimeException.getInstance("规格与平台不匹配");
		}
		List<ExcelExchangeCodeData> data = new ArrayList<>(exchangeCodeReq.getNumber());
		for (int i = 0; i < exchangeCodeReq.getNumber(); i++) {
			StringBuilder sb = new StringBuilder(32);
			sb.append(goodsDon.getSecondType() == 1 ? "YQ" : "FY");
			sb.append(getFillByGoodsId(exchangeCodeReq.getGoodsId()));
			sb.append(getFillByMonth(exchangeCodeReq.getSkuId()));
			//随即补充12位随即数,组成20位兑换码
			StringUtil.getRandomStr(sb, 12);
			ExchangeCode exchangeCode = new ExchangeCode();
			exchangeCode.setGoodsId(exchangeCodeReq.getGoodsId());
			exchangeCode.setSkuId(exchangeCodeReq.getSkuId());
			exchangeCode.setCode(sb.toString());
			exchangeCode.setUseStatus(false);
			exchangeCode.setType(exchangeCodeReq.getType());
			exchangeCodeMapper.insert(exchangeCode);
			ExcelExchangeCodeData excelExchangeCodeData = new ExcelExchangeCodeData();
			BeanUtils.copyProperties(exchangeCode, excelExchangeCodeData);
			excelExchangeCodeData.setTitle(goodsDon.getTitle());
			String specVal = goodsDonSku.getSpecVal();
			BigDecimal price = goodsDonSku.getPrice();
			excelExchangeCodeData.setSpecVal(String.format("%s%s", specVal, price.divide(BigDecimal.valueOf(100))));
			excelExchangeCodeData.setUseStatusStr(exchangeCode.getUseStatus() ? "已使用" : "未使用");
			data.add(excelExchangeCodeData);
		}
		return data;
	}

	@Override
	@Transactional(rollbackFor = Throwable.class)
	@NoSubmit
	public Result<String> getTicketByExchangeCode(ExchangeCodeTicket exchangeCodeTicket, Long userId) {
		if (StrUtil.isEmpty(exchangeCodeTicket.getCode())) {
			throw BusinessRuntimeException.getInstance("兑换码有误，请使用正确的兑换码");
		}
		ExchangeCode exchangeCode = this.getOne(Wrappers.lambdaQuery(ExchangeCode.class).eq(ExchangeCode::getCode, exchangeCodeTicket.getCode()).last("limit 1"));
		if (exchangeCode == null) {
			throw BusinessRuntimeException.getInstance("兑换码有误，请使用正确的兑换码");
		}
		if (exchangeCode.getUseStatus()) {
			throw BusinessRuntimeException.getInstance("该兑换码已使用");
		}
		//兑换成功
		exchangeCode.setUseStatus(true);
		exchangeCode.setUserId(userId);
		exchangeCode.setUseTime(DateTime.now());
		int update = exchangeCodeMapper.update(exchangeCode, Wrappers.lambdaQuery(ExchangeCode.class).eq(ExchangeCode::getId, exchangeCode.getId()).eq(ExchangeCode::getUseStatus, false));
		if (update != 1) {
			throw BusinessRuntimeException.getInstance("该兑换码已使用");
		}
		//是否是推广用户未登录订单关联的兑换码
		OrderDon orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
				.eq(OrderDon::getIsNoLogin, true)
				.eq(OrderDon::getExCode, exchangeCode.getCode())
				.notIn(OrderDon::getStatus, Constant.noOrderStatus)
				.last("limit 1"));
		if (orderDon != null && orderDon.getStatus() == OrderDon.Status.refund) {
			throw BusinessRuntimeException.getInstance("您的订单已退款,无法使用该兑换码");
		}
		//生成车票订单
		getGroupTripsTicket(goodsDonSkuMapper.selectById(exchangeCode.getSkuId()), userId, orderDon, OrderDon.Type.EX_CODE);
		log.info("用户:{}通过兑换码:{}兑换成功", userId, exchangeCodeTicket.getCode());
		if (exchangeCode.getType() == 1) {
			luckyDrawRecordMapper.updateExCodeStatus(userId, exchangeCode.getCode());
		}
		return GatewayResponse.SUCCESS.newBuilder().toResult("兑换成功");
	}

	@Override
	public String getExCode(Long goodsId, Long skuId, Integer type) {
		ExchangeCodeReq exchangeCodeReq = new ExchangeCodeReq();
		exchangeCodeReq.setNumber(1);
		exchangeCodeReq.setGoodsId(goodsId);
		exchangeCodeReq.setSkuId(skuId);
		if (type != null) {
			exchangeCodeReq.setType(type);
		}
		try {
			List<ExcelExchangeCodeData> exchangeCodes = this.createExchangeCode(exchangeCodeReq);
			return exchangeCodes.get(0).getCode();
		} catch (Exception e) {
			return null;
		}
	}

	/**
	 * 根据平台id获取填充的字符串
	 */
	private String getFillByGoodsId(Long goodsId) {
		String goodsIdStr = String.valueOf(goodsId);
		if (goodsIdStr.length() == 1) {
			return String.format("%s%s%s", 0, 0, goodsId);
		}
		if (goodsIdStr.length() == 2) {
			return String.format("%s%s", 0, goodsId);
		}
		//最大不超过999
		if (goodsIdStr.length() > 3) {
			return goodsIdStr.substring(0, 3);
		}
		return goodsIdStr;
	}

	/**
	 * 根据月份长度获取填充的字符串
	 */
	private String getFillByMonth(Long skuMonth) {
		String goodsIdStr = String.valueOf(skuMonth);
		if (goodsIdStr.length() == 1) {
			return String.format("%s%s%s", 0, 0, skuMonth);
		}
		return String.format("%s%s", 0, skuMonth);
	}

	/**
	 * 获取车位
	 */
	@Override
	public GroupsRelation getGroupTripsTicket(GoodsDonSku sku, Long userId, OrderDon exCodeOrderDon, OrderDon.Type orderDonTye) {
		if (sku == null) {
			throw BusinessRuntimeException.getInstance("规格不存在,请联系客服");
		}
		GoodsDon goodsDon = goodsDonMapper.selectById(sku.getGoodsId());
		if (goodsDon == null) {
			throw BusinessRuntimeException.getInstance("平台不存在,请联系客服");
		}
		User user = userMapper.selectById(userId);
		if (user == null) {
			throw BusinessRuntimeException.getInstance("用户不存在");
		}
		GroupsRelation relation = getRelationNoOrder(sku, userId);

		Long relationId = relation.getId();
		OrderDon orderDon;
		if (exCodeOrderDon != null) {
			orderDon = exCodeOrderDon;
			orderDon.setRelationId(relationId);
			orderDon.setUserId(userId);
			orderDon.setStatus(goodsDon.getType() == 1 && goodsDon.getSecondType() == 2 ? OrderDon.Status.complete : OrderDon.Status.hasPayment);
			orderDonMapper.updateById(orderDon);
		} else {
			/* 生成订单 */
			String donNo = SEQUENCE.nextId().toString();
			orderDon = new OrderDon();
			orderDon.setOrderNo(donNo);
			orderDon.setOpenId(user.getOpenId());
			orderDon.setMoney(BigDecimal.ZERO);
			orderDon.setSkuId(sku.getId());
			orderDon.setRelationId(relationId);
			//默认数量为1
			orderDon.setNum(1);
			orderDon.setGoodsId(sku.getGoodsId());
			orderDon.setStatus(goodsDon.getType() == 1 && goodsDon.getSecondType() == 2 ? OrderDon.Status.complete : OrderDon.Status.hasPayment);
			//兑换码兑换
			orderDon.setType(orderDonTye);
			orderDon.setUserId(user.getId());
			orderDonMapper.insert(orderDon);
		}
		if (StrUtil.isNotEmpty(user.getOpenId())) {
			//发送模板消息
			THREAD_POOL_TASK_EXECUTOR.execute(() -> {
				try {
					if (StrUtil.isNotEmpty(user.getOpenId())) {
						log.info("用户{}兑换车位成功，发送新订单模板消息", user.getId());
						templateCommonService.newOderSendMsgByType(orderDon, goodsDon, user, user.getOpenId(), false);
					}
				} catch (Exception e) {
					log.info("用户{}兑换车位成功，发送消息失败:{}", user.getId(), e);
				}
			});
		}

		THREAD_POOL_TASK_EXECUTOR.execute(() -> {
			try {
				//发送至客服消息
				List<CustomerService> customerServices = customerServiceMapper.selectList(null);
				for (CustomerService customerService : customerServices) {
					log.info("向客服{}发送用户兑换码兑换车票消息通知..", customerService.getNickName());
					templateCommonService.newOderSendMsgByType(orderDon, goodsDon, user, customerService.getOpenId(), true);
				}
			} catch (Exception e) {
				log.error("向客服发送用户{}兑换码兑换车票成功，发送消息失败:{}", user.getId(), e);
			}
		});
		relation.setOrderId(orderDon.getId());
		return relation;
	}

	@Override
	public GroupsRelation getRelationNoOrder(GoodsDonSku sku, Long userId) {
		GroupsRelation relation = null;
		Integer retryNum = 1;
		List<Long> errorsRelationIds = new ArrayList<>();
		relation = getFinalRelation(sku, userId, relation, retryNum, errorsRelationIds);
		return relation;
	}

	public GroupsRelation getFinalRelation(GoodsDonSku sku, Long userId, GroupsRelation relation, Integer retryNum, List<Long> errorsRelationIds) {
		//寻找差不多过期时间规格的车位
		relation = groupRelationFrontService.getSimilarExpiredGroupRelation(sku.getId(), sku.getMonths(), errorsRelationIds);
		if (relation == null) {
			GroupsTrips groups = groupsMapper.selectOne(Wrappers.lambdaQuery(GroupsTrips.class)
					.eq(GroupsTrips::getSkuId, sku.getId())
					.gt(GroupsTrips::getAvailableNum, 0).last("limit 1")
					.ne(GroupsTrips::getStatus, GroupsTrips.Status.down)
					.orderByAsc(GroupsTrips::getAvailableNum));
			if (groups == null) {
				//新增车位 并关联
				relation = createNewGroupTripsAndRelation(sku, groups, relation);
				log.info("无合适规格车队,新增新车队,获取车位relationId:{}", relation.getId());
			} else {
				//寻找快满编车队进行占座
				relation = groupsRelationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
						.eq(GroupsRelation::getGroupsId, groups.getId())
						.notIn(errorsRelationIds != null && errorsRelationIds.size() > 0, GroupsRelation::getId, errorsRelationIds)
						.eq(GroupsRelation::getStatus, "none")
						.eq(GroupsRelation::getUserId, 0)
						.orderByAsc(GroupsRelation::getNum)
						.last("limit 1")
				);
				log.info("寻找快满编车队的车位relationId:{}", relation.getId());
				//如果占位失败 新增车位并关联
				if (relation == null) {
					relation = createNewGroupTripsAndRelation(sku, groups, relation);
					log.info("占位新车队车位失败,再次新增新车队,获取车位relationId:{}", relation.getId());
				}
			}
		}

		try {
			//锁定座位
			setRelation(relation.getId(), userId);
			relation.setUserId(userId);
			relation.setStatus(GroupsRelation.Status.validity);
			//如果续费增加时间，如果首次则设置当前时间为初始时间
			Date expiryTime = Optional.ofNullable(relation.getExpiryTime()).orElse(new Date());
			Date newDate = DateUtil.offset(expiryTime, DateField.MONTH, sku.getMonths() * 1);
			relation.setExpiryTime(newDate);
			relation.setStartTime(relation.getStartTime() == null ? new Date() : null);

			int isSuccess = groupsRelationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
					.set(GroupsRelation::getUserId, userId)
					.set(GroupsRelation::getStatus, GroupsRelation.Status.validity)
					.set(GroupsRelation::getStartTime, relation.getStartTime())
					.set(GroupsRelation::getExpiryTime, relation.getExpiryTime())
					.eq(GroupsRelation::getId, relation.getId())
					.eq(GroupsRelation::getUserId, 0)
					.eq(GroupsRelation::getStatus, GroupsRelation.Status.none));
			if (isSuccess != 1) {
				log.error("该车位已被占,用户userId:{}更新上车relationId:{}状态失败", userId, relation.getId());
				throw BusinessRuntimeException.getInstance("该车位已被占");
			}
			redisService.del(RedisKey.GROUPS_RELATION_NUM_KEY + relation.getId());
		} catch (Exception e) {
			Object value = redisService.get(RedisKey.GROUPS_RELATION_NUM_KEY + relation.getId());
			if (value != null && userId.equals(Long.parseLong(value.toString()))) {
				redisService.del(RedisKey.GROUPS_RELATION_NUM_KEY + relation.getId());
			}
			errorsRelationIds.add(relation.getId());
			if (retryNum == 15) {
				log.error("用户:{}获取车票:{}异常", userId, relation.getId());
				throw BusinessRuntimeException.getInstance("获取车票异常,请联系客服");
			}
			//失败重新给他分配车位
			getFinalRelation(sku, userId, relation, ++retryNum, errorsRelationIds);
		}
		return relation;
	}

	private void setRelation(Long relationId, Long userId) {
		if (redisService.get(RedisKey.GROUPS_RELATION_NUM_KEY + relationId) != null) {
			log.info("=====>用户:{}获取了已有人座位:{}", userId, relationId);
			throw new BusinessRuntimeException("客官手慢啦，该座位已经有人啦！");
		} else {
			if (!redisService.setNx(RedisKey.GROUPS_RELATION_NUM_KEY + relationId, userId, 60 * 5L)) {
				log.info("=====>用户:{}未抢到座位:{}", userId, relationId);
				throw new BusinessRuntimeException("客官手慢啦，该座位已经有人啦！");
			}
			GroupsRelation relation = groupsRelationMapper.selectById(relationId);
			int count = groupsMapper.decrAvailableNum(relation.getGroupsId());
			if (count == 0) {
				log.error("车位异常 groupId:{}", relation.getGroupsId());
				groupsMapper.updateAvailableNum(relation.getGroupsId());
				throw new BusinessRuntimeException("车位异常");
			}
		}
	}

	/**
	 * 新增新车位并关联车位
	 */
	private GroupsRelation createNewGroupTripsAndRelation(GoodsDonSku sku, GroupsTrips groups, GroupsRelation relation) {
		//通过兑换码兑换车票 新增车位
		if (groups == null) {
			groups = new GroupsTrips();
		}
		//补充占位
		if (relation == null) {
			relation = new GroupsRelation();
		}
		groups.setSkuId(sku.getId());
		groups.setNum(sku.getNum());
		groups.setAvailableNum(sku.getNum());
		if (sku.getGoodsId() == 23) {
			AccountView accountView = beanSearcher.searchFirst(AccountView.class, MapUtils.builder().field(AccountView::getGoodsId, 23).onlySelect(AccountView::getId).build());
			if (accountView != null) {
				groups.setAccountId(accountView.getId());
				groups.setStatus(GroupsTrips.Status.validity);
				groups.setRemark("已设置唯一账号");
			}else {
				groups.setStatus(GroupsTrips.Status.waiting);
				groups.setRemark("等待设置账号");
			}
		} else {
			groups.setStatus(GroupsTrips.Status.waiting);
			groups.setRemark("等待设置账号");
		}
		groupsMapper.insert(groups);
		relation.setGroupsId(groups.getId());
		relation.setNum(1);
		relation.setStatus(GroupsRelation.Status.none);
		relation.setGroupsId(groups.getId());
		groupsRelationMapper.insert(relation);
		//补充其他占位
		for (int i = 2; i <= groups.getNum(); i++) {
			GroupsRelation groupsRelation = new GroupsRelation();
			groupsRelation.setGroupsId(groups.getId());
			groupsRelation.setNum(i);
			groupsRelation.setStatus(GroupsRelation.Status.none);
			groupsRelationMapper.insert(groupsRelation);
		}
		return relation;
	}
}