yhlxj/netflix-service/src/main/java/com/cyksj/service/user/impl/UserBenefitsServiceImpl.java

package com.cyksj.service.user.impl;

import com.cyksj.common.EnvCommonService;
import com.cyksj.common.constant.Constant;
import com.cyksj.mapper.DistributeOrdersDeductPointsRecordMapper;
import com.cyksj.mapper.UserBalanceSourceRecordMapper;
import com.cyksj.mapper.UserGalaxycoinRecordMapper;
import com.cyksj.mapper.UserMapper;
import com.cyksj.mapper.shop.YhShopDistributeOrdersDeductPointsRecordMapper;
import com.cyksj.model.entity.*;
import com.cyksj.service.sms.SmsService;
import com.cyksj.service.user.UserBenefitsService;
import lombok.RequiredArgsConstructor;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;

/*
 *项目名: netflix
 *文件名: UserBenefitsServiceImpl
 *创建者: JavaZou
 *创建时间:2023/5/18 16:06
 */
@Service
@RequiredArgsConstructor
public class UserBenefitsServiceImpl implements UserBenefitsService {
	private final UserMapper userMapper;

	private final DistributeOrdersDeductPointsRecordMapper distributeOrdersDeductPointsRecordMapper;

	private final UserBalanceSourceRecordMapper userBalanceSourceRecordMapper;

	private final EnvCommonService envCommonService;

	private final SmsService smsService;

	private final YhShopDistributeOrdersDeductPointsRecordMapper yhShopDistributeOrdersDeductPointsRecordMapper;

	private final UserGalaxycoinRecordMapper userGalaxycoinRecordMapper;

	@Override
	public void deductDistributePoints(Long orderId, Long userId, BigDecimal deductPoints) {
		if (deductPoints.compareTo(BigDecimal.ZERO) <= 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(userId);
			if (user == null) break;
			BigDecimal points = user.getPoints();
			Integer success = userMapper.subPointsNegative(userId, points, deductPoints);
			if (success == 1){
				//记录积分已发送后,退款后扣除积分记录
				deductPointsRecord(orderId, userId, deductPoints);
				break;
			}
		}
	}

	@Override
	public void addDistributePoints(Long userId, BigDecimal addPoints) {
		if (addPoints.compareTo(BigDecimal.ZERO) <= 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(userId);
			if (user == null) break;
			BigDecimal points = user.getPoints();
			Integer success = userMapper.updatePoints(user.getId(), points, addPoints);
			if (success == 1) break;
		}
	}

	@Override
	public void addUserBalance(Long userId, BigDecimal addBalance, UserBalanceSourceRecord.Source source,Long yhsId) {
		if (addBalance.compareTo(BigDecimal.ZERO) <= 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(userId);
			if (user == null) break;
			BigDecimal balance = user.getBalance();
			Integer success = userMapper.addUserBalance(user.getId(), balance, addBalance);
			if (success == 1) {
				recordBalanceBySource(userId, addBalance, source);
				if (envCommonService.isPrdEnv()) {
					if (source != UserBalanceSourceRecord.Source.close && source != UserBalanceSourceRecord.Source.balance && yhsId == 0) {
						try {
							//短信到账提醒
							String msg = String.format(Constant.BALANCE_NOTIFY_MSG, addBalance.divide(BigDecimal.valueOf(100)));
							smsService.sendSmsToRelationUser(userId, msg);
						} catch (Exception e) {
						}
					}
				}
				break;
			}
		}
	}

	@Override
	public void deductUserBalance(Long userId, BigDecimal subBalance) {
		if (subBalance.compareTo(BigDecimal.ZERO) <= 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(userId);
			if (user == null) break;
			BigDecimal balance = user.getBalance();
			Integer success = userMapper.deductUserBalance(user.getId(), balance, subBalance);
			if (success == 1) break;
		}
	}

	public void deductPointsRecord(Long orderId, Long userId, BigDecimal deductPoints) {
		try {
			DistributeOrdersDeductPointsRecord record = new DistributeOrdersDeductPointsRecord();
			record.setOrderId(orderId);
			record.setUserId(userId);
			record.setDeductPoints(deductPoints);
			distributeOrdersDeductPointsRecordMapper.insert(record);
		} catch (DuplicateKeyException e) {

		}
	}

	@Override
	public void recordBalanceBySource(Long userId, BigDecimal balance, UserBalanceSourceRecord.Source source) {
		UserBalanceSourceRecord userBalanceSourceRecord = new UserBalanceSourceRecord();
		userBalanceSourceRecord.setUserId(userId);
		userBalanceSourceRecord.setBalance(balance);
		userBalanceSourceRecord.setSource(source);
		userBalanceSourceRecordMapper.insert(userBalanceSourceRecord);
	}

	@Override
	public void recordGlaxycoinBySource(Long userId, BigDecimal galaxycoin, UserGalaxycoinRecord.Source source) {
		UserGalaxycoinRecord record = new UserGalaxycoinRecord();
		record.setUserId(userId);
		record.setGalaxycoin(galaxycoin);
		record.setSource(source);
		record.setRemark(source.getDesc());
		userGalaxycoinRecordMapper.insert(record);
	}

	@Override
	public void addYhsMoney(Long userId, BigDecimal addYhsMoney) {
		if (addYhsMoney.compareTo(BigDecimal.ZERO) <= 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(userId);
			if (user == null) break;
			BigDecimal yhsMoney = user.getYhsMoney();
			Integer success = userMapper.addYhsMoney(user.getId(), yhsMoney, addYhsMoney);
			if (success == 1) {
				break;
			}
		}
	}

	@Override
	public void deductYhShopTakeMoney(Long orderId, Long shopUserId, BigDecimal deductMoney) {
		if (deductMoney.compareTo(BigDecimal.ZERO) <= 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(shopUserId);
			if (user == null) break;
			BigDecimal yhsMoney = user.getYhsMoney();
			Integer success = userMapper.subYhShopUserMoney(shopUserId, yhsMoney, deductMoney);
			if (success == 1){
				//记录提成已发送后,退款后扣除用户店铺提成 记录
				deductYhsMoneyRecord(orderId, shopUserId, deductMoney);
				break;
			}
		}
	}

	private void deductYhsMoneyRecord(Long orderId, Long shopUserId, BigDecimal deductMoney) {
		try {
			YhShopDistributeOrdersDeductPointsRecord record = new YhShopDistributeOrdersDeductPointsRecord();
			record.setOrderId(orderId);
			record.setShopUserId(shopUserId);
			record.setDeductMoney(deductMoney);
			yhShopDistributeOrdersDeductPointsRecordMapper.insert(record);
		} catch (DuplicateKeyException e) {

		}
	}


	@Override
	public void updateGalaxycoin(Long userId, Long mOid, BigDecimal addGalaxycoin, UserGalaxycoinRecord.Source source) {
		if (addGalaxycoin.compareTo(BigDecimal.ZERO) == 0) {
			return;
		}
		while (true) {
			User user = userMapper.selectById(userId);
			if (user == null) break;
			Integer success = userMapper.updateGalaxycoin(user.getId(), addGalaxycoin, user.getGalaxycoin());
			if (success == 1) {
				UserGalaxycoinRecord record = new UserGalaxycoinRecord();
				record.setMOid(mOid);
				record.setUserId(userId);
				record.setGalaxycoin(addGalaxycoin);
				record.setSource(source);
				record.setRemark(source.getDesc());
				userGalaxycoinRecordMapper.insert(record);
				break;
			}
		}
	}
}