20211124 fish

xiaoyong931011

2021-11-24 aa0e95612c83cc03b8c815503f2acb5e1874647a

20211124  fish

 src/main/java/com/xcong/excoin/modules/fish/controller/MemberCannonController.java

New file
@@ -0,0 +1,69 @@
package com.xcong.excoin.modules.fish.controller;

import com.xcong.excoin.common.response.Result;
import com.xcong.excoin.modules.coin.parameter.vo.OrderWalletCoinDealVo;
import com.xcong.excoin.modules.fish.dto.CannonExchangeDto;
import com.xcong.excoin.modules.fish.dto.CoinGoldExchangeDto;
import com.xcong.excoin.modules.fish.dto.GetCannonsDto;
import com.xcong.excoin.modules.fish.dto.GoldExchangeDto;
import com.xcong.excoin.modules.fish.service.MemberCannonService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiResponse;
import io.swagger.annotations.ApiResponses;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

@Slf4j
@Api(value = "MemberCannonController", tags = "炮台接口类")
@RestController
@RequestMapping(value = "/api/account")
public class MemberCannonController {

    @Resource
    private MemberCannonService memberCannonService;

    /**
     * 代币金币互转
     */
    @ApiOperation(value = "代币金币互转")
    @PostMapping(value = "/coinGoldExchange")
    public Result coinGoldExchange(@RequestBody CoinGoldExchangeDto coinGoldExchangeDto) {
        return memberCannonService.coinGoldExchange(coinGoldExchangeDto);
    }

    /**
     * USDT购买金币
     */
    @ApiOperation(value = "USDT购买金币")
    @PostMapping(value = "/goldExchange")
    public Result goldExchange(@RequestBody GoldExchangeDto goldExchangeDto) {
        return memberCannonService.goldExchange(goldExchangeDto);
    }

    /**
     * 获取大炮列表
     */
    @ApiOperation(value = "获取大炮列表")
    @ApiResponses({@ApiResponse( code = 200, message = "success", response = OrderWalletCoinDealVo.class)})
    @PostMapping(value = "/getCannons")
    public Result getCannons(@RequestBody GetCannonsDto getCannonsDto) {
        return memberCannonService.getCannons(getCannonsDto);
    }

    /**
     *兑换大炮
     */
    @ApiOperation(value = "兑换大炮")
    @PostMapping(value = "/cannonExchange")
    public Result cannonExchange(@RequestBody CannonExchangeDto cannonExchangeDto) {
        return memberCannonService.cannonExchange(cannonExchangeDto);
    }


}

 src/main/java/com/xcong/excoin/modules/fish/dao/CannonAccountMoneyChangeDao.java

New file
@@ -0,0 +1,7 @@
package com.xcong.excoin.modules.fish.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.xcong.excoin.modules.fish.entity.CannonAccountMoneyChange;

public interface CannonAccountMoneyChangeDao extends BaseMapper<CannonAccountMoneyChange> {
}

 src/main/java/com/xcong/excoin/modules/fish/dao/CannonGameRecordDao.java

New file
@@ -0,0 +1,7 @@
package com.xcong.excoin.modules.fish.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.xcong.excoin.modules.fish.entity.CannonGameRecord;

public interface CannonGameRecordDao extends BaseMapper<CannonGameRecord> {
}

 src/main/java/com/xcong/excoin/modules/fish/dao/CannonOwnRecordDao.java

New file
@@ -0,0 +1,13 @@
package com.xcong.excoin.modules.fish.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.xcong.excoin.modules.fish.entity.CannonOwnRecord;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface CannonOwnRecordDao extends BaseMapper<CannonOwnRecord> {

    List<CannonOwnRecord> selectCannonOwnRecordsByMemberIdAndCannonCode(@Param("memberId")Long memberId, @Param("code")String code);

}

 src/main/java/com/xcong/excoin/modules/fish/dao/CannonSettingDao.java

New file
@@ -0,0 +1,18 @@
package com.xcong.excoin.modules.fish.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.xcong.excoin.modules.fish.entity.CannonExchangeRatio;
import com.xcong.excoin.modules.fish.entity.CannonSetting;
import com.xcong.excoin.modules.fish.vo.CannonSettingVo;
import org.apache.ibatis.annotations.Param;

import java.util.List;

public interface CannonSettingDao extends BaseMapper<CannonSetting> {

    List<CannonExchangeRatio> selectCannonExchangeRatio();

    IPage<CannonSettingVo> findCannonSettingInPage(Page<CannonSettingVo> page, @Param("cannonSetting")CannonSetting cannonSetting);
}

 src/main/java/com/xcong/excoin/modules/fish/dao/MemberAccountGoldDao.java

New file
@@ -0,0 +1,14 @@
package com.xcong.excoin.modules.fish.dao;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.xcong.excoin.modules.fish.entity.MemberAccountGold;
import org.apache.ibatis.annotations.Param;

import java.math.BigDecimal;

public interface MemberAccountGoldDao extends BaseMapper<MemberAccountGold> {

    MemberAccountGold selectAccountGoldByMemberId(@Param("memberId")Long memberId);

    int updateTotalBalanceAndAvailableBalance(@Param("id") Long id, @Param("availableBalance") BigDecimal availableBalance, @Param("totalBalance") BigDecimal totalBalance, @Param("frozenBalance") BigDecimal frozenBalance);
}

 src/main/java/com/xcong/excoin/modules/fish/dto/CannonExchangeDto.java

New file
@@ -0,0 +1,17 @@
package com.xcong.excoin.modules.fish.dto;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.NotNull;

@Data
@ApiModel(value = "CannonExchangeDto", description = "参数类")
public class CannonExchangeDto {

    @NotNull(message = "ID不能为空")
    @ApiModelProperty(value = "兑换炮台ID", example = "1")
    private Long cannonId;

}

 src/main/java/com/xcong/excoin/modules/fish/dto/CoinGoldExchangeDto.java

New file
@@ -0,0 +1,22 @@
package com.xcong.excoin.modules.fish.dto;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.NotNull;
import java.math.BigDecimal;

@Data
@ApiModel(value = "CoinGoldExchangeDto", description = "参数类")
public class CoinGoldExchangeDto {

    @NotNull(message = "兑换金额不能为空")
    @ApiModelProperty(value = "兑换金额", example = "100")
    private BigDecimal balance;

    @NotNull(message = "类型不能为空")
    @ApiModelProperty(value = "类型", example = "1:金币兑换代币 2：代币兑换金币")
    private Integer type;

}

 src/main/java/com/xcong/excoin/modules/fish/dto/GetCannonsDto.java

New file
@@ -0,0 +1,23 @@
package com.xcong.excoin.modules.fish.dto;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.Min;
import javax.validation.constraints.NotNull;

@Data
@ApiModel(value = "GetCannonsDto", description = "参数类")
public class GetCannonsDto {

    @NotNull
    @Min(1)
    @ApiModelProperty(value = "第几页", example = "1")
    private int pageNum;

    @NotNull
    @ApiModelProperty(value = "每页数量", example = "10")
    private int pageSize;

}

 src/main/java/com/xcong/excoin/modules/fish/dto/GoldExchangeDto.java

New file
@@ -0,0 +1,18 @@
package com.xcong.excoin.modules.fish.dto;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.NotNull;
import java.math.BigDecimal;

@Data
@ApiModel(value = "GoldExchangeDto", description = "参数类")
public class GoldExchangeDto {

    @NotNull(message = "兑换金额不能为空")
    @ApiModelProperty(value = "兑换金额", example = "100")
    private BigDecimal balance;

}

 src/main/java/com/xcong/excoin/modules/fish/entity/CannonAccountMoneyChange.java

New file
@@ -0,0 +1,30 @@
package com.xcong.excoin.modules.fish.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import com.xcong.excoin.common.system.base.BaseEntity;
import lombok.Data;

import java.math.BigDecimal;

/**
 * 用户的账户资金转换充值提现操作记录表
 */
@Data
@TableName("cannon_account_money_change")
public class CannonAccountMoneyChange extends BaseEntity {

    private Long memberId;
    //金额
    private BigDecimal amount;
    //1：USDT兑换金币 2：USDT购买炮台 3:代币兑换记录…
    private Integer type;
    //内容
    private String content;
    //变更金额
    private BigDecimal changeBalance;
    //变更前
    private BigDecimal changeBefore;
    //变更后
    private BigDecimal changeAfter;

}

 src/main/java/com/xcong/excoin/modules/fish/entity/CannonExchangeRatio.java

New file
@@ -0,0 +1,20 @@
package com.xcong.excoin.modules.fish.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.math.BigDecimal;

/**
 * 兑换比例设置
 */
@Data
@TableName("cannon_exchange_ratio")
public class CannonExchangeRatio {
    private Long id;
    //金币兑换代币比例
    private BigDecimal goldRatio;
    //代币兑换金币比例
    private BigDecimal coinRatio;

}

 src/main/java/com/xcong/excoin/modules/fish/entity/CannonGameRecord.java

New file
@@ -0,0 +1,29 @@
package com.xcong.excoin.modules.fish.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import com.xcong.excoin.common.system.base.BaseEntity;
import lombok.Data;

import java.math.BigDecimal;

/**
 * 游戏记录
 */
@Data
@TableName("cannon_game_record")
public class CannonGameRecord extends BaseEntity {

    private Long memberId;
    //用户拥有炮台记录ID
    private Long cannonOwnId;
    //炮台名称
    private String cannonName;
    //炮台编码
    private String cannonCode;
    //消耗金币
    private BigDecimal goldConsume;
    //获得金币
    private BigDecimal goldReward;


}

 src/main/java/com/xcong/excoin/modules/fish/entity/CannonOwnRecord.java

New file
@@ -0,0 +1,27 @@
package com.xcong.excoin.modules.fish.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import com.xcong.excoin.common.system.base.BaseEntity;
import lombok.Data;

import java.math.BigDecimal;

/**
 * 用户拥有炮台
 */
@Data
@TableName("cannon_own_record")
public class CannonOwnRecord extends BaseEntity {

    private Long memberId;
    //炮台UUID
    private String cannonUuid;
    //炮台名称
    private String cannonName;
    //炮台编码
    private String cannonCode;
    //炮台兑换价格
    private BigDecimal cannonPrice;
    //1:主动购买 2：系统赠送
    private Integer type;
}

 src/main/java/com/xcong/excoin/modules/fish/entity/CannonSetting.java

New file
@@ -0,0 +1,25 @@
package com.xcong.excoin.modules.fish.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.math.BigDecimal;

/**
 * 炮台设置表
 */
@Data
@TableName("cannon_setting")
public class CannonSetting {

    private Long id;
    //炮台名称
    private String name;
    //炮台编码
    private String code;
    //兑换价格
    private BigDecimal exchangePrice;
    //消耗金币
    private BigDecimal goldConsume;

}

 src/main/java/com/xcong/excoin/modules/fish/entity/MemberAccountGold.java

New file
@@ -0,0 +1,24 @@
package com.xcong.excoin.modules.fish.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import com.xcong.excoin.common.system.base.BaseEntity;
import lombok.Data;

import java.math.BigDecimal;

/**
 * 用戶金币賬戶信息表
 */
@Data
@TableName("member_account_gold")
public class MemberAccountGold extends BaseEntity {

    private Long memberId;
    //金币可用余额
    private BigDecimal availableBalance;
    //金币总金额
    private BigDecimal totalBalance;
    //金币冻结余额
    private BigDecimal frozenBalance;

}

 src/main/java/com/xcong/excoin/modules/fish/service/MemberCannonService.java

New file
@@ -0,0 +1,25 @@
package com.xcong.excoin.modules.fish.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.xcong.excoin.common.response.Result;
import com.xcong.excoin.modules.fish.dto.CannonExchangeDto;
import com.xcong.excoin.modules.fish.dto.CoinGoldExchangeDto;
import com.xcong.excoin.modules.fish.dto.GetCannonsDto;
import com.xcong.excoin.modules.fish.dto.GoldExchangeDto;
import com.xcong.excoin.modules.fish.entity.CannonOwnRecord;
import org.apache.ibatis.annotations.Param;

import java.math.BigDecimal;

public interface MemberCannonService extends IService<CannonOwnRecord> {

    Result coinGoldExchange(CoinGoldExchangeDto coinGoldExchangeDto);

    void updateTotalBalanceAndAvailableBalance(@Param("id") Long id, @Param("availableBalance") BigDecimal availableBalance, @Param("totalBalance")BigDecimal totalBalance, @Param("frozenBalance")BigDecimal frozenBalance);

    Result getCannons(GetCannonsDto getCannonsDto);

    Result cannonExchange(CannonExchangeDto cannonExchangeDto);

    Result goldExchange(GoldExchangeDto goldExchangeDto);
}

 src/main/java/com/xcong/excoin/modules/fish/service/impl/MemberCannonServiceImpl.java

New file
@@ -0,0 +1,199 @@
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 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.CannonAccountMoneyChangeDao;
import com.xcong.excoin.modules.fish.dao.CannonOwnRecordDao;
import com.xcong.excoin.modules.fish.dao.CannonSettingDao;
import com.xcong.excoin.modules.fish.dao.MemberAccountGoldDao;
import com.xcong.excoin.modules.fish.dto.CannonExchangeDto;
import com.xcong.excoin.modules.fish.dto.CoinGoldExchangeDto;
import com.xcong.excoin.modules.fish.dto.GetCannonsDto;
import com.xcong.excoin.modules.fish.dto.GoldExchangeDto;
import com.xcong.excoin.modules.fish.entity.*;
import com.xcong.excoin.modules.fish.service.MemberCannonService;
import com.xcong.excoin.modules.fish.vo.CannonSettingVo;
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
    CannonSettingDao cannonSettingDao;
    @Resource
    MemberAccountGoldDao memberAccountGoldDao;
    @Resource
    CannonAccountMoneyChangeDao cannonAccountMoneyChangeDao;
    @Resource
    MemberWalletCoinDao memberWalletCoinDao;
    @Resource
    CannonOwnRecordDao cannonOwnRecordDao;
    @Resource
    RedisUtils redisUtils;
    @Resource
    private CoinService coinService;
    @Resource
    private MemberCannonService memberCannonService;

    @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.XCT.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);
        }else if(type == 2){
            MemberAccountGold memberAccountGold = memberAccountGoldDao.selectAccountGoldByMemberId(memberId);
            MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, CoinTypeEnum.XCT.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);
        }
        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(2);
        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("兑换成功");
    }

    public static void main(String[] args) {
        System.out.println(UUID.randomUUID().toString());
    }


}

 src/main/java/com/xcong/excoin/modules/fish/vo/CannonSettingVo.java

New file
@@ -0,0 +1,24 @@
package com.xcong.excoin.modules.fish.vo;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;

@Data
@ApiModel(value = "CannonSettingVo", description = "炮台列表")
public class CannonSettingVo {

    private Long id;

    @ApiModelProperty(value = "炮台名称")//炮台名称
    private String name;
    @ApiModelProperty(value = "炮台编码")//炮台编码
    private String code;
    @ApiModelProperty(value = "兑换价格")//兑换价格
    private BigDecimal exchangePrice;
    @ApiModelProperty(value = "1发炮弹消耗金币数")//消耗金币
    private BigDecimal goldConsume;

}

 src/main/resources/mapper/fish/CannonAccountMoneyChangeDao.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xcong.excoin.modules.fish.dao.CannonAccountMoneyChangeDao">


</mapper>

 src/main/resources/mapper/fish/CannonGameRecordDao.xml

New file
@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xcong.excoin.modules.fish.dao.CannonGameRecordDao">


</mapper>

 src/main/resources/mapper/fish/CannonOwnRecordDao.xml

New file
@@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xcong.excoin.modules.fish.dao.CannonOwnRecordDao">

    <select id="selectCannonOwnRecordsByMemberIdAndCannonCode" resultType="com.xcong.excoin.modules.fish.entity.CannonOwnRecord">
        select a.* from cannon_own_record a where a.member_id = #{memberId} and a.cannon_code = #{code}
    </select>

</mapper>

 src/main/resources/mapper/fish/CannonSettingDao.xml

New file
@@ -0,0 +1,13 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xcong.excoin.modules.fish.dao.CannonSettingDao">

    <select id="selectCannonExchangeRatio" resultType="com.xcong.excoin.modules.fish.entity.CannonExchangeRatio">
        select a.* from cannon_exchange_ratio a
    </select>

    <select id="findCannonSettingInPage" resultType="com.xcong.excoin.modules.fish.vo.CannonSettingVo">
        select a.* from cannon_setting a order by id asc
    </select>

</mapper>

 src/main/resources/mapper/fish/MemberAccountGoldDao.xml

New file
@@ -0,0 +1,31 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xcong.excoin.modules.fish.dao.MemberAccountGoldDao">

    <select id="selectAccountGoldByMemberId" resultType="com.xcong.excoin.modules.fish.entity.MemberAccountGold">
        select a.* from member_account_gold a where a.member_id = #{memberId}
    </select>

    <update id="updateTotalBalanceAndAvailableBalance" parameterType="map">
        update member_account_gold
        <set>
            <if test="availableBalance != null">
                available_balance = (
                case when  IFNULL(available_balance, 0) + #{available_balance}>0 then  IFNULL(available_balance, 0) + #{availableBalance} else 0 end
                ),
            </if>
            <if test="totalBalance != null">
                total_balance = (
                case when  IFNULL(total_balance, 0) + #{totalBalance}>0 then  IFNULL(total_balance, 0) + #{totalBalance} else 0 end
                ),
            </if>
            <if test="frozenBalance != null">
                frozen_balance = (
                case when  IFNULL(frozen_balance, 0) + #{frozenBalance}>0 then  IFNULL(frozen_balance, 0) + #{frozenBalance} else 0 end
                ),
            </if>
        </set>
        where id=#{id}
    </update>

</mapper>