package com.xcong.excoin.modules.fish.service.impl;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.lang.UUID;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.RandomUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.xcong.excoin.common.LoginUserUtils;
|
import com.xcong.excoin.common.enumerates.CoinTypeEnum;
|
import com.xcong.excoin.common.response.Result;
|
import com.xcong.excoin.modules.coin.service.CoinService;
|
import com.xcong.excoin.modules.fish.dao.*;
|
import com.xcong.excoin.modules.fish.dto.*;
|
import com.xcong.excoin.modules.fish.entity.*;
|
import com.xcong.excoin.modules.fish.service.MemberCannonService;
|
import com.xcong.excoin.modules.fish.vo.*;
|
import com.xcong.excoin.modules.member.dao.MemberWalletCoinDao;
|
import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity;
|
import com.xcong.excoin.utils.RedisUtils;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.List;
|
|
@Service
|
public class MemberCannonServiceImpl extends ServiceImpl<CannonOwnRecordDao, CannonOwnRecord> implements MemberCannonService {
|
|
@Resource
|
MemberAccountGoldDao memberAccountGoldDao;
|
@Resource
|
MemberWalletCoinDao memberWalletCoinDao;
|
@Resource
|
private MemberCannonService memberCannonService;
|
@Resource
|
CannonAccountMoneyChangeDao cannonAccountMoneyChangeDao;
|
@Resource
|
CannonOwnRecordDao cannonOwnRecordDao;
|
@Resource
|
CannonSettingDao cannonSettingDao;
|
@Resource
|
CannonGameRecordDao cannonGameRecordDao;
|
@Resource
|
CannonWinRecordDao cannonWinRecordDao;
|
@Resource
|
RedisUtils redisUtils;
|
@Resource
|
private CoinService coinService;
|
|
@Override
|
public Result coinGoldExchange(CoinGoldExchangeDto coinGoldExchangeDto) {
|
BigDecimal balance = coinGoldExchangeDto.getBalance();
|
if (balance.compareTo(BigDecimal.ZERO) <= 0) {
|
return Result.fail("兑换金额不能小于或等于0");
|
}
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
//获取兑换比例
|
List<CannonExchangeRatio> cannonExchangeRatios = cannonSettingDao.selectCannonExchangeRatio();
|
if(CollUtil.isEmpty(cannonExchangeRatios)){
|
return Result.fail("系统繁忙请稍候重试");
|
}
|
CannonExchangeRatio cannonExchangeRatio = cannonExchangeRatios.get(0);
|
Integer type = coinGoldExchangeDto.getType();
|
//1:金币兑换1代币 2：1代币兑换金币
|
if(type == 1){
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.XCC.name());
|
if(balance.compareTo(memberAccountGold.getAvailableBalance()) > 0){
|
return Result.fail("金币不足");
|
}
|
BigDecimal coinRatio = cannonExchangeRatio.getCoinRatio();
|
BigDecimal divide = balance.divide(coinRatio).setScale(8,BigDecimal.ROUND_DOWN);
|
//金币账户减少
|
memberCannonService.updateTotalBalanceAndAvailableBalance(memberAccountGold.getId(),balance.negate(),balance.negate(),null);
|
//代币账户增加
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),divide,divide,null);
|
|
CannonAccountMoneyChange cannonAccountMoneyChange = new CannonAccountMoneyChange();
|
cannonAccountMoneyChange.setMemberId(memberId);
|
cannonAccountMoneyChange.setAmount(balance.negate());
|
cannonAccountMoneyChange.setType(2);
|
cannonAccountMoneyChange.setContent("金币兑换");
|
cannonAccountMoneyChange.setChangeBalance(balance);
|
cannonAccountMoneyChange.setChangeBefore(memberAccountGold.getAvailableBalance());
|
cannonAccountMoneyChange.setChangeAfter(memberAccountGold.getAvailableBalance().subtract(balance));
|
cannonAccountMoneyChangeDao.insert(cannonAccountMoneyChange);
|
}else if(type == 2){
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.XCC.name());
|
if(balance.compareTo(memberWalletCoinEntity.getAvailableBalance()) > 0){
|
return Result.fail("代币不足");
|
}
|
BigDecimal coinRatio = cannonExchangeRatio.getCoinRatio();
|
BigDecimal multiply = balance.multiply(coinRatio);
|
//金币账户增加
|
memberCannonService.updateTotalBalanceAndAvailableBalance(memberAccountGold.getId(),multiply,multiply,null);
|
//代币账户减少
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),balance.negate(),balance.negate(),null);
|
|
CannonAccountMoneyChange cannonAccountMoneyChange = new CannonAccountMoneyChange();
|
cannonAccountMoneyChange.setMemberId(memberId);
|
cannonAccountMoneyChange.setAmount(balance);
|
cannonAccountMoneyChange.setType(3);
|
cannonAccountMoneyChange.setContent("兑换金币");
|
cannonAccountMoneyChange.setChangeBalance(balance);
|
cannonAccountMoneyChange.setChangeBefore(memberWalletCoinEntity.getAvailableBalance());
|
cannonAccountMoneyChange.setChangeAfter(memberWalletCoinEntity.getAvailableBalance().add(balance));
|
cannonAccountMoneyChangeDao.insert(cannonAccountMoneyChange);
|
}
|
return Result.ok("兑换成功");
|
}
|
|
@Override
|
public void updateTotalBalanceAndAvailableBalance(Long id, BigDecimal availableBalance, BigDecimal totalBalance,BigDecimal frozenBalance) {
|
if(id==null){
|
return;
|
}
|
// 这里需要加锁 保证同一个时间只有一个线程操作一个钱包
|
String key = "UPDATE_MEMBER_GOLD_"+id;
|
while (true){
|
boolean b = redisUtils.setNotExist(key, 1, 2);
|
if(b){
|
//System.out.println("我拿到了锁");
|
// 拿到了锁才能扣
|
memberAccountGoldDao.updateTotalBalanceAndAvailableBalance(id,availableBalance,totalBalance,frozenBalance);
|
// 扣完释放锁
|
redisUtils.del(key);
|
break;
|
}else {
|
|
}
|
}
|
}
|
|
@Override
|
public Result getCannons(GetCannonsDto getCannonsDto) {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
Page<CannonSettingVo> page = new Page<>(getCannonsDto.getPageNum(), getCannonsDto.getPageSize());
|
CannonSetting cannonSetting = new CannonSetting();
|
IPage<CannonSettingVo> list = cannonSettingDao.findCannonSettingInPage(page, cannonSetting);
|
return Result.ok(list);
|
}
|
|
@Override
|
public Result cannonExchange(CannonExchangeDto cannonExchangeDto) {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
Long cannonId = cannonExchangeDto.getCannonId();
|
CannonSetting cannonSetting = cannonSettingDao.selectById(cannonId);
|
BigDecimal exchangePrice = cannonSetting.getExchangePrice();
|
if(ObjectUtil.isEmpty(cannonSetting)){
|
return Result.fail("炮塔不存在");
|
}
|
List<CannonOwnRecord> cannonOwnRecords = cannonOwnRecordDao.selectCannonOwnRecordsByMemberIdAndCannonCode(memberId,cannonSetting.getCode());
|
if(CollUtil.isNotEmpty(cannonOwnRecords)){
|
return Result.fail("炮塔已拥有");
|
}
|
//获取用户的USDT账户，可用余额总金额减少
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.USDT.name());
|
if(exchangePrice.compareTo(memberWalletCoinEntity.getAvailableBalance()) > 0){
|
return Result.fail("可用余额不足");
|
}
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),exchangePrice.negate(),exchangePrice.negate(),null);
|
//增加一条拥有记录【cannon_own_record】
|
CannonOwnRecord cannonOwnRecord = new CannonOwnRecord();
|
cannonOwnRecord.setMemberId(memberId);
|
cannonOwnRecord.setCannonUuid(UUID.randomUUID().toString());
|
cannonOwnRecord.setCannonCode(cannonSetting.getCode());
|
cannonOwnRecord.setCannonName(cannonSetting.getName());
|
cannonOwnRecord.setCannonPrice(cannonSetting.getExchangePrice());
|
cannonOwnRecord.setType(1);
|
cannonOwnRecordDao.insert(cannonOwnRecord);
|
//增加一条买卖记录
|
CannonAccountMoneyChange cannonAccountMoneyChange = new CannonAccountMoneyChange();
|
cannonAccountMoneyChange.setMemberId(memberId);
|
cannonAccountMoneyChange.setAmount(exchangePrice);
|
cannonAccountMoneyChange.setType(1);
|
cannonAccountMoneyChange.setContent("购买炮塔");
|
cannonAccountMoneyChange.setChangeBalance(exchangePrice);
|
cannonAccountMoneyChange.setChangeBefore(memberWalletCoinEntity.getAvailableBalance());
|
cannonAccountMoneyChange.setChangeAfter(memberWalletCoinEntity.getAvailableBalance().subtract(exchangePrice));
|
cannonAccountMoneyChangeDao.insert(cannonAccountMoneyChange);
|
return Result.ok("购买成功");
|
}
|
|
@Override
|
public Result goldExchange(GoldExchangeDto goldExchangeDto) {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
BigDecimal balance = goldExchangeDto.getBalance();
|
if (balance.compareTo(BigDecimal.ZERO) <= 0) {
|
return Result.fail("兑换金额不能小于或等于0");
|
}
|
//获取兑换比例
|
List<CannonExchangeRatio> cannonExchangeRatios = cannonSettingDao.selectCannonExchangeRatio();
|
if(CollUtil.isEmpty(cannonExchangeRatios)){
|
return Result.fail("系统繁忙请稍候重试");
|
}
|
CannonExchangeRatio cannonExchangeRatio = cannonExchangeRatios.get(0);
|
//金币账户增加
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
BigDecimal goldRatio = cannonExchangeRatio.getGoldRatio();
|
BigDecimal multiply = balance.multiply(goldRatio);
|
memberCannonService.updateTotalBalanceAndAvailableBalance(memberAccountGold.getId(),multiply,multiply,null);
|
//获取用户的USDT账户，可用余额总金额减少
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.USDT.name());
|
if(balance.compareTo(memberWalletCoinEntity.getAvailableBalance()) > 0){
|
return Result.fail("可用余额不足");
|
}
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),balance.negate(),balance.negate(),null);
|
return Result.ok("兑换成功");
|
}
|
|
@Override
|
public Result getGoldAccount() {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
if(ObjectUtil.isEmpty(memberAccountGold)){
|
MemberAccountGold memberAccountGoldNew = new MemberAccountGold();
|
memberAccountGoldNew.setMemberId(memberId);
|
memberAccountGoldNew.setTotalBalance(BigDecimal.ZERO);
|
memberAccountGoldNew.setAvailableBalance(BigDecimal.ZERO);
|
memberAccountGoldNew.setFrozenBalance(BigDecimal.ZERO);
|
memberAccountGoldDao.insert(memberAccountGoldNew);
|
}
|
GoldAccountVo goldAccountVo = memberAccountGoldDao.selectAccountGoldVoByMemberId(memberId);
|
return Result.ok(goldAccountVo);
|
}
|
|
@Override
|
public Result getOwnCannon() {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
List<OwnCannonVo> cannonOwnRecords = cannonOwnRecordDao.selectCannonOwnRecordsByMemberId(memberId);
|
return Result.ok(cannonOwnRecords);
|
}
|
|
@Override
|
public Result fishing(FishingDto fishingDto) {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
Integer goldWin = fishingDto.getGoldWin() == null?0:fishingDto.getGoldWin();
|
if(goldWin < 0){
|
return Result.fail("请求异常，请刷新页面");
|
}
|
Long cannonOwnId = fishingDto.getCannonOwnId();
|
List<CannonOwnRecord> cannonOwnRecords = cannonOwnRecordDao.selectCannonOwnRecordsByIdAndMemberId(cannonOwnId,memberId);
|
if(CollUtil.isEmpty(cannonOwnRecords)){
|
Result.fail("请求异常，请刷新页面");
|
}
|
//消耗金币 = 每发炮弹的消耗 - 获得金币；
|
CannonOwnRecord cannonOwnRecord = cannonOwnRecords.get(0);
|
CannonSetting cannonSetting = cannonSettingDao.selectCannonSettingByCannonCode(cannonOwnRecord.getCannonCode());
|
BigDecimal goldConsume = cannonSetting.getGoldConsume().subtract(new BigDecimal(goldWin)).setScale(0,BigDecimal.ROUND_DOWN);
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
memberCannonService.updateTotalBalanceAndAvailableBalance(memberAccountGold.getId(),goldConsume.negate(),goldConsume.negate(),null);
|
//增加一条游戏记录
|
CannonGameRecord cannonGameRecord = new CannonGameRecord();
|
cannonGameRecord.setMemberId(memberId);
|
cannonGameRecord.setCannonOwnId(cannonOwnRecord.getId());
|
cannonGameRecord.setCannonName(cannonOwnRecord.getCannonName());
|
cannonGameRecord.setCannonCode(cannonOwnRecord.getCannonCode());
|
cannonGameRecord.setGoldConsume(cannonSetting.getGoldConsume());
|
cannonGameRecord.setGoldReward(new BigDecimal(goldWin));
|
cannonGameRecordDao.insert(cannonGameRecord);
|
|
return Result.ok("success");
|
}
|
|
@Override
|
public Result getAccountAvaBanlace() {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
MemberWalletCoinEntity memberWalletCoinEntityXCC = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.XCC.name());
|
MemberWalletCoinEntity memberWalletCoinEntityUSDT = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.USDT.name());
|
AccountAvaBanlaceVo accountAvaBanlaceVo = new AccountAvaBanlaceVo();
|
// accountAvaBanlaceVo.setMemberId(memberId);
|
accountAvaBanlaceVo.setGoldAvailableBalance(memberAccountGold.getAvailableBalance() == null?BigDecimal.ZERO:memberAccountGold.getAvailableBalance());
|
accountAvaBanlaceVo.setCoinAvailableBalance(memberWalletCoinEntityXCC.getAvailableBalance() == null?BigDecimal.ZERO:memberWalletCoinEntityXCC.getAvailableBalance());
|
accountAvaBanlaceVo.setUsdtAvailableBalance(memberWalletCoinEntityUSDT.getAvailableBalance() == null?BigDecimal.ZERO:memberWalletCoinEntityUSDT.getAvailableBalance());
|
return Result.ok(accountAvaBanlaceVo);
|
}
|
|
@Override
|
public Result getAwards() {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
// Long memberId = 1L;
|
AwardsVo awardsVo = cannonOwnRecordDao.getAwards();
|
return Result.ok(awardsVo);
|
}
|
|
@Override
|
public Result lotteryDraw(LotteryDrawDto lotteryDrawDto) {
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
// Long memberId = 1L;
|
//获取每次抽奖需要的USDT数量
|
CannonAwardSet cannonAwardSet = cannonOwnRecordDao.getCannonAwardSet();
|
if(ObjectUtil.isEmpty(cannonAwardSet)){
|
Result.fail("活动还没开始，请稍候");
|
}
|
BigDecimal consume = cannonAwardSet.getConsume() == null ? BigDecimal.ZERO : cannonAwardSet.getConsume();
|
if(consume.compareTo(BigDecimal.ZERO) <= 0){
|
Result.fail("活动还没开始，请稍候");
|
}
|
//验证账户USDT余额是否足够
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.USDT.name());
|
BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance() == null ? BigDecimal.ZERO : memberWalletCoinEntity.getAvailableBalance();
|
if(availableBalance.compareTo(consume) < 0){
|
Result.fail("用户USDT余额不足");
|
}
|
//用户USDT余额减少
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),consume.negate(),consume.negate(),null);
|
//增加一条抽奖记录
|
CannonAccountMoneyChange cannonAccountMoneyChange = new CannonAccountMoneyChange();
|
cannonAccountMoneyChange.setMemberId(memberId);
|
cannonAccountMoneyChange.setAmount(consume);
|
cannonAccountMoneyChange.setType(4);
|
cannonAccountMoneyChange.setContent("抽奖");
|
cannonAccountMoneyChange.setChangeBalance(consume);
|
cannonAccountMoneyChange.setChangeBefore(memberWalletCoinEntity.getAvailableBalance());
|
cannonAccountMoneyChange.setChangeAfter(memberWalletCoinEntity.getAvailableBalance().subtract(consume));
|
cannonAccountMoneyChangeDao.insert(cannonAccountMoneyChange);
|
//抽奖品
|
CannonAwardVo award = getAward(memberId);
|
|
CannonWinRecord cannonWinRecord = new CannonWinRecord();
|
cannonWinRecord.setMemberId(memberId);
|
cannonWinRecord.setAwardName(award.getName()+"*"+award.getQuantity());
|
cannonWinRecord.setConsumeNum(consume);
|
cannonWinRecordDao.insert(cannonWinRecord);
|
return Result.ok(award);
|
}
|
|
private CannonAwardVo getAward(Long memberId) {
|
CannonAwardVo cannonAwardVo = new CannonAwardVo();
|
//获取所有的奖品列表
|
List<CannonAward> cannonAwards = cannonOwnRecordDao.selectCannonAward();
|
if(CollUtil.isNotEmpty(cannonAwards)){
|
CannonAward cannonAward = RandomUtil.randomEle(cannonAwards);
|
//获得金币
|
if("GOLD".equals(cannonAward.getCode())){
|
BigDecimal quantity = new BigDecimal(cannonAward.getQuantity());
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
memberCannonService.updateTotalBalanceAndAvailableBalance(memberAccountGold.getId(),quantity,quantity,null);
|
cannonAwardVo.setName(cannonAward.getName());
|
cannonAwardVo.setQuantity(cannonAward.getQuantity());
|
}else if("COIN".equals(cannonAward.getCode())){
|
BigDecimal quantity = new BigDecimal(cannonAward.getQuantity());
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.XCC.name());
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),quantity,quantity,null);
|
cannonAwardVo.setName(cannonAward.getName());
|
cannonAwardVo.setQuantity(cannonAward.getQuantity());
|
}else if("USDT".equals(cannonAward.getCode())){
|
BigDecimal quantity = new BigDecimal(cannonAward.getQuantity());
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.USDT.name());
|
coinService.updateWalletBalance(memberWalletCoinEntity.getId(),quantity,quantity,null);
|
cannonAwardVo.setName(cannonAward.getName());
|
cannonAwardVo.setQuantity(cannonAward.getQuantity());
|
}else{
|
CannonSetting cannonSetting = cannonSettingDao.selectCannonSettingByCannonCode(cannonAward.getCode());
|
List<CannonOwnRecord> cannonOwnRecords = cannonOwnRecordDao.selectCannonOwnRecordsByMemberIdAndCannonCode(memberId, cannonAward.getCode());
|
Integer cannonAccountMoneyChanges = cannonOwnRecordDao.selectCannonAccountMoneyChangeByMemberId(memberId);
|
//抽奖次数小于十次的抽不到炮台
|
if(CollUtil.isEmpty(cannonOwnRecords) && cannonAccountMoneyChanges > 10){
|
//增加一条拥有记录【cannon_own_record】
|
CannonOwnRecord cannonOwnRecord = new CannonOwnRecord();
|
cannonOwnRecord.setMemberId(memberId);
|
cannonOwnRecord.setCannonUuid(UUID.randomUUID().toString());
|
cannonOwnRecord.setCannonCode(cannonSetting.getCode());
|
cannonOwnRecord.setCannonName(cannonSetting.getName());
|
cannonOwnRecord.setCannonPrice(cannonSetting.getExchangePrice());
|
cannonOwnRecord.setType(1);
|
cannonOwnRecordDao.insert(cannonOwnRecord);
|
|
cannonAwardVo.setName(cannonAward.getName());
|
cannonAwardVo.setQuantity(cannonAward.getQuantity());
|
}else{
|
CannonAward cannonAwardGold = cannonOwnRecordDao.selectCannonAwardByCode("GOLD");
|
BigDecimal quantity = new BigDecimal(cannonAwardGold.getQuantity());
|
MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
|
memberCannonService.updateTotalBalanceAndAvailableBalance(memberAccountGold.getId(),quantity,quantity,null);
|
cannonAwardVo.setName(cannonAwardGold.getName());
|
cannonAwardVo.setQuantity(cannonAwardGold.getQuantity());
|
}
|
}
|
}
|
|
return cannonAwardVo;
|
}
|
|
|
|
public static void main(String[] args) {
|
}
|
|
|
}
|
