package cc.mrbird.febs.mall.service.impl;

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.enumerates.*;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.MallUtils;
import cc.mrbird.febs.common.utils.ShareCodeUtil;
import cc.mrbird.febs.mall.dto.*;
import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.mapper.*;
import cc.mrbird.febs.mall.service.GameService;
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
import cc.mrbird.febs.mall.vo.*;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.poi.ss.formula.functions.Choose;
import org.springframework.stereotype.Service;
import cc.mrbird.febs.websocket.WsSessionManager;
import org.springframework.transaction.annotation.Transactional;
import sun.net.www.content.image.png;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Slf4j
@Service
@RequiredArgsConstructor
public class GameServiceImpl extends ServiceImpl<GameRoomMapper, GameRoom> implements GameService {

    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
    private final MallMemberMapper mallMemberMapper;
    private final MallMemberWalletMapper mallMemberWalletMapper;
    private final GameRoomMapper gameRoomMapper;
    private final GameRoomChildMapper gameRoomChildMapper;
    private final GameGameMapper gameGameMapper;
    private final GameGameChildMapper gameGameChildMapper;
    private final IApiMallMemberWalletService memberWalletService;
    private final IMallMoneyFlowService mallMoneyFlowService;
    @Override
    public FebsResponse roomType() {
        ArrayList<RoomTypeVo> objects = new ArrayList<>();

        List<GameRoomTypeEnum> roomLists = GameRoomTypeEnum.ROOM_ONE.getRoomList();
        if(CollUtil.isNotEmpty(roomLists)){
            for(GameRoomTypeEnum gameRoomTypeEnum : roomLists){
                RoomTypeVo roomTypeVo = new RoomTypeVo();
                roomTypeVo.setRoomName(gameRoomTypeEnum.getRoomName());
                roomTypeVo.setRoomType(gameRoomTypeEnum.getRoomType());
                roomTypeVo.setRoomAmount(new BigDecimal(gameRoomTypeEnum.getRoomAmount()));
                roomTypeVo.setMinAmount(new BigDecimal(gameRoomTypeEnum.getMinAmount()));
                roomTypeVo.setMaxAmount(new BigDecimal(gameRoomTypeEnum.getMaxAmount()));
                String amounts = gameRoomTypeEnum.getAmounts();
                // 使用split方法将字符串按照逗号分割成数组
                String[] numbersArray = amounts.split(",");

                // 将数组转换成Stream
                List<BigDecimal> numbersList = Arrays.stream(numbersArray)
                        // 使用map方法将每个字符串元素转换成BigDecimal
                        .map(BigDecimal::new)
                        // 收集到List中
                        .collect(Collectors.toList());
                roomTypeVo.setAmounts(numbersList);
                objects.add(roomTypeVo);
            }
        }
        return new FebsResponse().success().data(objects);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public FebsResponse createRoom(ApiCreateRoomDto apiCreateRoomDto) {
        /**
         * 用户登录
         * 判断是否是代理，只有代理才能创建房间
         * 初始化一条主房间记录
         * 初始化一条子房间记录
         * 返回房间信息
         */
        Long memberId = LoginUserUtil.getLoginUser().getId();
        //每局时间倒计时
        Integer gameTime = apiCreateRoomDto.getGameTime();
        if(1 > gameTime || 60 < gameTime){
            throw new FebsException("请输入合适的数字");
        }
        //代理身份才能创建房间
        MallMember mallMember = mallMemberMapper.selectById(memberId);
        Integer partner = ObjectUtil.isEmpty(mallMember.getPartner()) ? 2 : mallMember.getPartner();
        if(AppContants.MEMBER_PARTNER_NO == partner){
            throw new FebsException("用户没有创建房间的权限！");
        }

        Integer roomType = apiCreateRoomDto.getRoomType();
        GameRoomTypeEnum room = GameRoomTypeEnum.ROOM_ONE.getRoom(roomType);
        if(ObjectUtil.isEmpty(room)){
            throw new FebsException("请选择正确的房间类型！");
        }
        //创建房间的最小金额
        BigDecimal roomAmount = new BigDecimal(room.getRoomAmount()).setScale(2, BigDecimal.ROUND_DOWN);
        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
        if(roomAmount.compareTo(mallMemberWallet.getBalance()) > 0){
            throw new FebsException("金额不足，请充值！");
        }
        //初始化一条主房间记录
        GameRoom gameRoom = new GameRoom();
        gameRoom.setRoomType(roomType);
        gameRoom.setState(GameRoom.STATE_READY);
        gameRoom.setOwnerMemberId(memberId);
        gameRoom.setGameTime(gameTime);
        gameRoomMapper.insert(gameRoom);

        boolean flag = false;
        String password = ShareCodeUtil.toSerialNumberCodeTwo(gameRoom.getId());
        while (!flag){
            QueryWrapper<GameRoom> objectQueryWrapper = new QueryWrapper<>();
            objectQueryWrapper.eq("password",password);
            List<GameRoom> gameRooms = gameRoomMapper.selectList(objectQueryWrapper);
            if(CollUtil.isEmpty(gameRooms)){
                flag = true;
            }else{
                password = ShareCodeUtil.toSerialNumberCodeTwo(gameRoom.getId());
            }
        }
        gameRoom.setPassword(password);
        gameRoomMapper.updateById(gameRoom);
        //初始化一条子房间记录
        GameRoomChild gameRoomChild = new GameRoomChild();
        gameRoomChild.setRoomId(gameRoom.getId());
        gameRoomChild.setOwnerState(GameRoomChild.OWNER_TRUE);
        gameRoomChild.setMemberId(memberId);
        gameRoomChildMapper.insert(gameRoomChild);

        ApiCreateRoomVo apiCreateRoomVo = new ApiCreateRoomVo();
        apiCreateRoomVo.setRoomType(roomType);
        apiCreateRoomVo.setRoomId(gameRoom.getId());
        apiCreateRoomVo.setPassword(password);
        apiCreateRoomVo.setState(gameRoom.getState());
        return new FebsResponse().success().data(apiCreateRoomVo);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public FebsResponse startGame(ApiStartGameDto startGameDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        MallMember mallMember = mallMemberMapper.selectById(memberId);

        Long roomId = startGameDto.getRoomId();
        QueryWrapper<GameRoom> roomQueryWrapper = new QueryWrapper<>();
        roomQueryWrapper.eq("owner_member_id",memberId);
        roomQueryWrapper.eq("id",roomId);
        GameRoom gameRoom = gameRoomMapper.selectOne(roomQueryWrapper);
        if(ObjectUtil.isEmpty(gameRoom)){
            throw new FebsException("房间不存在");
        }
        if(GameRoom.STATE_READY != gameRoom.getState()){
            throw new FebsException("游戏已开始");
        }

        Integer roomType = gameRoom.getRoomType();
        GameRoomTypeEnum room = GameRoomTypeEnum.ROOM_ONE.getRoom(roomType);
        if(ObjectUtil.isEmpty(room)){
            throw new FebsException("请选择正确的房间类型！");
        }
        //创建房间的最小金额
        BigDecimal roomAmount = new BigDecimal(room.getRoomAmount()).setScale(2, BigDecimal.ROUND_DOWN);
        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
        if(roomAmount.compareTo(mallMemberWallet.getBalance()) > 0){
            throw new FebsException("金额不足，请充值！");
        }

        gameRoom.setState(GameRoom.STATE_ING);
        gameRoomMapper.updateById(gameRoom);

        GameGame gameGame = new GameGame();
        gameGame.setMemberId(memberId);
        gameGame.setRoomId(roomId);
        gameGame.setState(GameGame.STATE_READY);
        gameGameMapper.insert(gameGame);

        /**
         * 给房间里面的所有人发送一个开始的信息
         */
        this.sendMsgByRoomId(roomId,"START:"+gameGame.getId());

        ApiStartGameVo apiStartGameVo = new ApiStartGameVo();
        apiStartGameVo.setRoomType(gameRoom.getRoomType());
        apiStartGameVo.setRoomId(gameRoom.getId());
        apiStartGameVo.setPassword(gameRoom.getPassword());
        apiStartGameVo.setState(gameRoom.getState());
        apiStartGameVo.setCreatedTime(gameGame.getCreatedTime());
        return new FebsResponse().success().data(apiStartGameVo);
    }

    @Override
    public void sendMsgByRoomId(Long roomId,String msg) {
        QueryWrapper<GameRoomChild> gameRoomChildQueryWrapper = new QueryWrapper<>();
        gameRoomChildQueryWrapper.eq("room_id",roomId);
        List<GameRoomChild> gameRoomChildrens = gameRoomChildMapper.selectList(gameRoomChildQueryWrapper);
        if(CollUtil.isEmpty(gameRoomChildrens)){
            return;
        }
        List<Long> playerMemberIds = gameRoomChildrens.stream().map(GameRoomChild::getMemberId).collect(Collectors.toList());
        this.sendMsgByMemberIds(playerMemberIds,msg);
    }

    @Override
    public void sendMsgByMemberIds(List<Long> memberIds,String msg) {
        QueryWrapper<MallMember> memberQueryWrapper = new QueryWrapper<>();
        memberQueryWrapper.in("id",memberIds);
        List<MallMember> mallMembers = mallMemberMapper.selectList(memberQueryWrapper);
        if(CollUtil.isEmpty(mallMembers)){
            return;
        }
        String inviteIdsString = mallMembers.stream()
                .map(MallMember::getInviteId) // 提取每个MallMember的inviteId
                .collect(Collectors.joining(",")); // 使用逗号连接所有inviteId
        WsSessionManager.sendMsgToMany(inviteIdsString,msg);
    }

    @Override
    public void sendMsgByMemberId(Long memberId,String msg) {
        MallMember mallMembers = mallMemberMapper.selectById(memberId);
        if(ObjectUtil.isEmpty(mallMembers)){
            return;
        }
        WsSessionManager.sendMsgToOne(mallMembers.getInviteId(),msg);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public FebsResponse chooseNum(ApiChooseNumDto apiChooseNumDto) {
        /**
         *  判断这个房间投注人是否在房间中
         *  判断游戏的状态是否是投注中
         *  判断房间类型是否满足投注金额
         *  判断游戏的投注金额是否足够
         */
        Long memberId = LoginUserUtil.getLoginUser().getId();

        Long roomId = apiChooseNumDto.getRoomId();
        Integer chooseNum = apiChooseNumDto.getChooseNum();
        BigDecimal amount = apiChooseNumDto.getAmount();
        Long gameId = apiChooseNumDto.getGameId();

        GameRoom gameRoom = gameRoomMapper.selectById(roomId);
        if(ObjectUtil.isEmpty(gameRoom)){
            throw new FebsException("房间不存在");
        }
        if(GameRoom.STATE_DONE == gameRoom.getState()){
            throw new FebsException("房主关闭了房间");
        }
        if(GameRoom.STATE_READY == gameRoom.getState()){
            throw new FebsException("请等待房主开始游戏");
        }

        QueryWrapper<GameRoomChild> gameRoomChildQueryWrapper = new QueryWrapper<>();
        gameRoomChildQueryWrapper.eq("room_id",gameRoom.getId());
        gameRoomChildQueryWrapper.eq("member_id",memberId);
        GameRoomChild gameRoomChildExist = gameRoomChildMapper.selectOne(gameRoomChildQueryWrapper);
        if(ObjectUtil.isEmpty(gameRoomChildExist)){
            throw new FebsException("请重新进入房间");
        }

        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
        BigDecimal balance = mallMemberWallet.getBalance();
        if(BigDecimal.ZERO.compareTo(balance) > 0){
            throw new FebsException("余额不足");
        }
        if(amount.compareTo(balance) > 0){
            throw new FebsException("请减小金额");
        }

        GameRoomTypeEnum room = GameRoomTypeEnum.ROOM_ONE.getRoom(gameRoom.getRoomType());
        // 使用split方法将字符串按照逗号分割成数组
        String[] numbersArray = room.getAmounts().split(",");
        // 将数组转换成Stream
        List<BigDecimal> numbersList = Arrays.stream(numbersArray)
                // 使用map方法将每个字符串元素转换成BigDecimal
                .map(BigDecimal::new)
                // 收集到List中
                .collect(Collectors.toList());
        boolean contains = numbersList.contains(amount);
        if(!contains){
            throw new FebsException("请选择正确的金额");
        }
        if(chooseNum < 1 || chooseNum > 6){
            throw new FebsException("请选择正确的投注");
        }

        GameGame gameGame = gameGameMapper.selectById(gameId);
        if(ObjectUtil.isEmpty(gameGame)){
            throw new FebsException("请重新进入游戏");
        }
        if(GameGame.STATE_READY != gameGame.getState()){
            throw new FebsException("本轮已结束");
        }

        /**
         * 开始投注
         *  初始化一条投注子记录
         *  更新游戏主记录
         *  通知房主，更新页面。
         *  减少用户的金额
         *  初始化一条流水记录
         */
        memberWalletService.reduceBalance(amount,memberId);
        mallMoneyFlowService.addMoneyFlow(
                mallMemberWallet.getMemberId(),
                amount.negate(),
                GameFlowTypeEnum.PLAYER_PICK_NUM.getValue(),
                MallUtils.getOrderNum("TZ"),
                StrUtil.format(
                        GameFlowTypeEnum.PLAYER_PICK_NUM.getDescrition(),
                        gameRoom.getPassword(),
                        GamePNGEnum.SHI_ZI.getPngName(chooseNum)));

        GameGameChild gameGameChild = new GameGameChild();
        gameGameChild.setGameId(gameId);
        gameGameChild.setMemberId(memberId);
        gameGameChild.setAmount(amount);
        gameGameChild.setPickNum(chooseNum);
        gameGameChild.setState(GameGameChild.STATE_ING);
        gameGameChildMapper.insert(gameGameChild);

        if(1 == chooseNum){
            BigDecimal add = gameGame.getPickOne().add(amount).setScale(2,BigDecimal.ROUND_DOWN);
            gameGame.setPickOne(add);
        }
        if(2 == chooseNum){
            BigDecimal add = gameGame.getPickTwo().add(amount).setScale(2,BigDecimal.ROUND_DOWN);
            gameGame.setPickTwo(add);
        }
        if(3 == chooseNum){
            BigDecimal add = gameGame.getPickThree().add(amount).setScale(2,BigDecimal.ROUND_DOWN);
            gameGame.setPickThree(add);
        }
        if(4 == chooseNum){
            BigDecimal add = gameGame.getPickFour().add(amount).setScale(2,BigDecimal.ROUND_DOWN);
            gameGame.setPickFour(add);
        }
        if(5 == chooseNum){
            BigDecimal add = gameGame.getPickFive().add(amount).setScale(2,BigDecimal.ROUND_DOWN);
            gameGame.setPickFive(add);
        }
        if(6 == chooseNum){
            BigDecimal add = gameGame.getPickSix().add(amount).setScale(2,BigDecimal.ROUND_DOWN);
            gameGame.setPickSix(add);
        }
        gameGameMapper.updateById(gameGame);

        /**
         * 给房间里面的所有人发送一个开始的信息
         */
        this.sendMsgByRoomId(roomId,"TZ:"+gameGame.getId());

        return new FebsResponse().success().message("操作成功");
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public FebsResponse gameIn(ApiGameDto apiGameDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        /**
         *  验证唯一房间编码是否存在
         *  验证当前是否已经加入过该房间
         *  验证当前用户的钱是否足够进入该房间
         *  获取房间状态信息、房间游戏信息
         *  初始化房间子表的数据
         */
        String password = apiGameDto.getPassword();
        QueryWrapper<GameRoom> objectQueryWrapper = new QueryWrapper<>();
        objectQueryWrapper.eq("password", password);
        GameRoom gameRoom = gameRoomMapper.selectOne(objectQueryWrapper);
        if(ObjectUtil.isEmpty(gameRoom)){
            throw new FebsException("房间不存在");
        }

        if(GameRoom.STATE_DONE == gameRoom.getState()){
            throw new FebsException("房间已失效");
        }

        ApiGamePlayerVo apiGamePlayerVo = new ApiGamePlayerVo();

        QueryWrapper<GameRoomChild> gameRoomChildQueryWrapper = new QueryWrapper<>();
        gameRoomChildQueryWrapper.eq("room_id",gameRoom.getId());
        gameRoomChildQueryWrapper.eq("member_id",memberId);
        GameRoomChild gameRoomChildExist = gameRoomChildMapper.selectOne(gameRoomChildQueryWrapper);

        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
        BigDecimal balance = mallMemberWallet.getBalance();
        GameRoomTypeEnum room = GameRoomTypeEnum.ROOM_ONE.getRoom(gameRoom.getRoomType());
        if(ObjectUtil.isNotEmpty(gameRoomChildExist)){
            Integer ownerState = gameRoomChildExist.getOwnerState();
            if(GameRoomChild.OWNER_TRUE == ownerState){
                BigDecimal roomAmount = new BigDecimal(room.getRoomAmount()).setScale(2,BigDecimal.ROUND_DOWN);
                if(roomAmount.compareTo(balance) > 0){
                    throw new FebsException("进入房间,需要"+roomAmount+",请先充值");
                }
            }else{
                BigDecimal minAmount = new BigDecimal(room.getMinAmount()).setScale(2,BigDecimal.ROUND_DOWN);
                if(minAmount.compareTo(balance) > 0){
                    throw new FebsException("继续游戏需要"+minAmount+",请先充值");
                }
            }
        }else{
            BigDecimal minAmount = new BigDecimal(room.getMinAmount()).setScale(2,BigDecimal.ROUND_DOWN);
            if(minAmount.compareTo(balance) > 0){
                throw new FebsException("继续游戏需要"+minAmount+",请先充值");
            }
        }

        if(ObjectUtil.isNotEmpty(gameRoomChildExist)){
            apiGamePlayerVo.setPlayerType(gameRoomChildExist.getOwnerState());
        }else{

            GameRoomChild gameRoomChild = new GameRoomChild();
            gameRoomChild.setRoomId(gameRoom.getId());
            gameRoomChild.setMemberId(memberId);
            gameRoomChild.setOwnerState(GameRoomChild.OWNER_FALSE);
            gameRoomChildMapper.insert(gameRoomChild);
            apiGamePlayerVo.setPlayerType(gameRoomChild.getOwnerState());
        }
        apiGamePlayerVo.setBalance(balance);

        apiGamePlayerVo.setRoomType(gameRoom.getRoomType());
        apiGamePlayerVo.setRoomId(gameRoom.getId());
        apiGamePlayerVo.setPassword(gameRoom.getPassword());
        apiGamePlayerVo.setState(gameRoom.getState());
        apiGamePlayerVo.setGameTime(gameRoom.getGameTime());

        QueryWrapper<GameGame> gameGameQueryWrapper = new QueryWrapper<>();
        gameGameQueryWrapper.eq("room_id",gameRoom.getId());
        gameGameQueryWrapper.orderByDesc("CREATED_TIME");
        gameGameQueryWrapper.last("limit 5");
        List<GameGame> gameGames = gameGameMapper.selectList(gameGameQueryWrapper);
        List<ApiGameGameVo> apiGameGameVos = new ArrayList<>();
        if(CollUtil.isNotEmpty(gameGames)){
            for(GameGame gameGame : gameGames){
                ApiGameGameVo apiGameGameVo = new ApiGameGameVo();
                apiGameGameVo.setFirstNum(ObjectUtil.isEmpty(gameGame.getFirstNum()) ? 0 : gameGame.getFirstNum());
                apiGameGameVo.setSecondNum(ObjectUtil.isEmpty(gameGame.getSecondNum()) ? 0 : gameGame.getSecondNum());
                apiGameGameVo.setState(gameGame.getState());
                apiGameGameVo.setPerkTime(gameGame.getPerkTime());
                if(GameGame.STATE_READY == gameGame.getState()){
                    apiGamePlayerVo.setGameId(gameGame.getId());
                    apiGamePlayerVo.setCreatedTime(gameGame.getCreatedTime());
                }
                apiGameGameVos.add(apiGameGameVo);
            }
        }
        apiGamePlayerVo.setApiGameGameVos(apiGameGameVos);

        return new FebsResponse().success().data(apiGamePlayerVo);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public FebsResponse endGame(ApiEndGameDto endGameDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        Long roomId = endGameDto.getRoomId();
        Long gameId = endGameDto.getGameId();
        /**
         * 只有房主才能结束本轮游戏
         * 判断本轮游戏状态
         * 结算
         * 判断房主是否还够资金开启下一轮游戏
         * 等待房主开始
         */
        GameRoom gameRoom = gameRoomMapper.selectById(roomId);
        if(ObjectUtil.isEmpty(gameRoom)){
            throw new FebsException("房间不存在");
        }

        QueryWrapper<GameRoomChild> gameRoomChildQueryWrapper = new QueryWrapper<>();
        gameRoomChildQueryWrapper.eq("room_id",roomId);
        gameRoomChildQueryWrapper.eq("member_id",memberId);
        gameRoomChildQueryWrapper.eq("owner_state",GameRoomChild.OWNER_TRUE);
        GameRoomChild gameRoomChildExist = gameRoomChildMapper.selectOne(gameRoomChildQueryWrapper);
        if(ObjectUtil.isEmpty(gameRoomChildExist)){
            throw new FebsException("房间不存在");
        }

        QueryWrapper<GameGame> gameGameQueryWrapper = new QueryWrapper<>();
        gameGameQueryWrapper.eq("id",gameId);
        gameGameQueryWrapper.eq("room_id",roomId);
        gameGameQueryWrapper.eq("member_id",memberId);
        gameGameQueryWrapper.eq("state",GameGame.STATE_READY);
        GameGame gameGameExist = gameGameMapper.selectOne(gameGameQueryWrapper);
        if(ObjectUtil.isEmpty(gameGameExist)){
            throw new FebsException("本轮游戏已结束");
        }

        //将游戏房间更新为准备中
        gameRoom.setState(GameRoom.STATE_READY);
        gameRoomMapper.updateById(gameRoom);
        //产生两个随机的1-6的数字
        int firstNum = RandomUtil.randomInt(1, 7);
        int secondNum = RandomUtil.randomInt(1, 7);
        gameGameExist.setFirstNum(firstNum);
        gameGameExist.setSecondNum(secondNum);
        gameGameExist.setState(GameGame.STATE_DONE);
        gameGameExist.setPerkTime(new Date());
        gameGameMapper.updateById(gameGameExist);
        //结算 todo 改成rabbitMq消息推送，注意游戏主表的状态变化
        this.perkGameGameChild(gameId,firstNum,secondNum);

        this.sendMsgByRoomId(roomId,"DONE:"+gameId);

        ApiEndGameVo apiEndGameVo = new ApiEndGameVo();
        apiEndGameVo.setRoomId(roomId);
        return new FebsResponse().success().data(apiEndGameVo);
    }

    @Override
    public BigDecimal perkGameGameChild(Long gameId,int firstNum,int secondNum) {
        BigDecimal totalPerk = BigDecimal.ZERO;
        /**
         * 获取本局游戏的全部参与人员
         * 结算金额
         */
        QueryWrapper<GameGameChild> objectQueryWrapper = new QueryWrapper<>();
        objectQueryWrapper.eq("game_id",gameId);
        objectQueryWrapper.eq("state",GameGameChild.STATE_ING);
        List<GameGameChild> gameGameChildrens = gameGameChildMapper.selectList(objectQueryWrapper);
        if(CollUtil.isEmpty(gameGameChildrens)){
            return totalPerk;
        }
        for(GameGameChild gameChild : gameGameChildrens){
            Long memberId = gameChild.getMemberId();
            //投入金额
            BigDecimal amount = gameChild.getAmount();
            //投注号码
            Integer pickNum = gameChild.getPickNum();
            //中奖金额
            BigDecimal perkAmount = BigDecimal.ZERO;
            if(pickNum == firstNum){
                GamePNGEnum png = GamePNGEnum.SHI_ZI.getPng(firstNum);
                if(ObjectUtil.isNotEmpty(png)){
                    Integer pngTimes = png.getPngTimes();
                    perkAmount = perkAmount.add(amount.multiply(new BigDecimal(pngTimes)).setScale(2,BigDecimal.ROUND_DOWN));
                }
            }
            if(pickNum == secondNum){
                GamePNGEnum png = GamePNGEnum.SHI_ZI.getPng(secondNum);
                if(ObjectUtil.isNotEmpty(png)){
                    Integer pngTimes = png.getPngTimes();
                    perkAmount = perkAmount.add(amount.multiply(new BigDecimal(pngTimes)).setScale(2,BigDecimal.ROUND_DOWN));
                }
            }
            if(BigDecimal.ZERO.compareTo(perkAmount) >= 0){//说明两个号码没中，
                gameChild.setPerkState(GameGameChild.PERK_STATE_NO);
                gameChild.setPerkAmount(amount.negate());

                mallMoneyFlowService.addMoneyFlow(
                        gameChild.getMemberId(),
                        BigDecimal.ZERO,
                        GameFlowTypeEnum.PLAYER_PERK.getValue(),
                        MallUtils.getOrderNum("ZJ"),
                        StrUtil.format(
                                GameFlowTypeEnum.PLAYER_PERK.getDescrition(),
                                GamePNGEnum.SHI_ZI.getPngName(firstNum),
                                GamePNGEnum.SHI_ZI.getPngName(secondNum),
                                GamePNGEnum.SHI_ZI.getPngName(pickNum)
                                ));

                totalPerk = totalPerk.add(amount);
            }else{
                gameChild.setPerkState(GameGameChild.PERK_STATE_YES);
                gameChild.setPerkAmount(perkAmount);

                BigDecimal memberTotalPerk = perkAmount.add(amount);
                memberWalletService.addBalance(memberTotalPerk,gameChild.getMemberId());

                mallMoneyFlowService.addMoneyFlow(
                        gameChild.getMemberId(),
                        memberTotalPerk,
                        GameFlowTypeEnum.PLAYER_PERK.getValue(),
                        MallUtils.getOrderNum("ZJ"),
                        StrUtil.format(
                                GameFlowTypeEnum.PLAYER_PERK.getDescrition(),
                                GamePNGEnum.SHI_ZI.getPngName(firstNum),
                                GamePNGEnum.SHI_ZI.getPngName(secondNum),
                                GamePNGEnum.SHI_ZI.getPngName(pickNum)
                                ));

                totalPerk = totalPerk.subtract(perkAmount);
            }
            gameChild.setPerkNumOne(firstNum);
            gameChild.setPerkNumTwo(secondNum);
            gameChild.setState(GameGameChild.STATE_DONE);
            gameGameChildMapper.updateById(gameChild);
        }

        GameGame gameGame = gameGameMapper.selectById(gameId);

        Long memberId = gameGame.getMemberId();
        memberWalletService.addBalance(totalPerk,memberId);
        mallMoneyFlowService.addMoneyFlow(
                memberId,
                totalPerk,
                GameFlowTypeEnum.OWNER_PERK.getValue(),
                MallUtils.getOrderNum("KJ"),
                StrUtil.format(
                        GameFlowTypeEnum.OWNER_PERK.getDescrition(),
                        GamePNGEnum.SHI_ZI.getPngName(firstNum),
                        GamePNGEnum.SHI_ZI.getPngName(secondNum)
                        ));

        gameGame.setState(GameGame.STATE_OVER);
        gameGameMapper.updateById(gameGame);
        return totalPerk;
    }

    @Override
    public FebsResponse nextGame(ApiNextGameDto apiNextGameDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        /**
         *  验证唯一房间编码是否存在
         *  验证当前是否已经加入过该房间
         *  验证当前用户的钱是否足够进入该房间
         *  获取房间状态信息、房间游戏信息
         *  初始化房间子表的数据
         */
        Long gameId = apiNextGameDto.getGameId();
        GameGame gameGameNow = gameGameMapper.selectById(gameId);
        if(ObjectUtil.isEmpty(gameGameNow)){
            throw new FebsException("游戏等待中");
        }
        GameRoom gameRoom = gameRoomMapper.selectById(gameGameNow.getRoomId());
        if(ObjectUtil.isEmpty(gameRoom)){
            throw new FebsException("房间不存在");
        }

        if(GameRoom.STATE_DONE == gameRoom.getState()){
            throw new FebsException("房间已失效");
        }

        ApiNextGameVo apiGamePlayerVo = new ApiNextGameVo();

        QueryWrapper<GameRoomChild> gameRoomChildQueryWrapper = new QueryWrapper<>();
        gameRoomChildQueryWrapper.eq("room_id",gameRoom.getId());
        gameRoomChildQueryWrapper.eq("member_id",memberId);
        GameRoomChild gameRoomChildExist = gameRoomChildMapper.selectOne(gameRoomChildQueryWrapper);

        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
        BigDecimal balance = mallMemberWallet.getBalance();
        GameRoomTypeEnum room = GameRoomTypeEnum.ROOM_ONE.getRoom(gameRoom.getRoomType());
        if(ObjectUtil.isNotEmpty(gameRoomChildExist)){
            Integer ownerState = gameRoomChildExist.getOwnerState();
            if(GameRoomChild.OWNER_TRUE == ownerState){
                BigDecimal roomAmount = new BigDecimal(room.getRoomAmount()).setScale(2,BigDecimal.ROUND_DOWN);
                if(roomAmount.compareTo(balance) > 0){
                    throw new FebsException("进入房间,需要"+roomAmount+",请先充值");
                }
            }else{
                BigDecimal minAmount = new BigDecimal(room.getMinAmount()).setScale(2,BigDecimal.ROUND_DOWN);
                if(minAmount.compareTo(balance) > 0){
                    throw new FebsException("继续游戏需要"+minAmount+",请先充值");
                }
            }
        }else{
            BigDecimal minAmount = new BigDecimal(room.getMinAmount()).setScale(2,BigDecimal.ROUND_DOWN);
            if(minAmount.compareTo(balance) > 0){
                throw new FebsException("继续游戏需要"+minAmount+",请先充值");
            }
        }

        if(ObjectUtil.isNotEmpty(gameRoomChildExist)){
            apiGamePlayerVo.setPlayerType(gameRoomChildExist.getOwnerState());
        }else{
            GameRoomChild gameRoomChild = new GameRoomChild();
            gameRoomChild.setRoomId(gameRoom.getId());
            gameRoomChild.setMemberId(memberId);
            gameRoomChild.setOwnerState(GameRoomChild.OWNER_FALSE);
            gameRoomChildMapper.insert(gameRoomChild);
            apiGamePlayerVo.setPlayerType(gameRoomChild.getOwnerState());
        }
        apiGamePlayerVo.setBalance(balance);
        apiGamePlayerVo.setRoomType(gameRoom.getRoomType());
        apiGamePlayerVo.setRoomId(gameRoom.getId());
        apiGamePlayerVo.setPassword(gameRoom.getPassword());
        apiGamePlayerVo.setState(gameRoom.getState());
        apiGamePlayerVo.setGameTime(gameRoom.getGameTime());

        QueryWrapper<GameGame> gameGameQueryWrapper = new QueryWrapper<>();
        gameGameQueryWrapper.eq("room_id",gameRoom.getId());
        gameGameQueryWrapper.orderByDesc("CREATED_TIME");
        gameGameQueryWrapper.last("limit 5");
        List<GameGame> gameGames = gameGameMapper.selectList(gameGameQueryWrapper);
        List<ApiGameGameVo> apiGameGameVos = new ArrayList<>();
        if(CollUtil.isNotEmpty(gameGames)){
            for(GameGame gameGame : gameGames){
                ApiGameGameVo apiGameGameVo = new ApiGameGameVo();
                apiGameGameVo.setFirstNum(ObjectUtil.isEmpty(gameGame.getFirstNum()) ? 0 : gameGame.getFirstNum());
                apiGameGameVo.setSecondNum(ObjectUtil.isEmpty(gameGame.getSecondNum()) ? 0 : gameGame.getSecondNum());
                apiGameGameVo.setState(gameGame.getState());
                apiGameGameVo.setPerkTime(gameGame.getPerkTime());
                if(GameGame.STATE_READY == gameGame.getState()){
                    apiGamePlayerVo.setGameId(gameGame.getId());
                    apiGamePlayerVo.setCreatedTime(gameGame.getCreatedTime());
                }
                apiGameGameVos.add(apiGameGameVo);
            }
        }
        apiGamePlayerVo.setApiGameGameVos(apiGameGameVos);

        return new FebsResponse().success().data(apiGamePlayerVo);
    }

    @Override
    public FebsResponse existGame(ApiExistGameDto apiExistGameDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        Long roomId = apiExistGameDto.getRoomId();
        /**
         * 删除房间子表的数据
         */
        MallMember mallMember = mallMemberMapper.selectById(memberId);
        QueryWrapper<GameRoomChild> gameRoomChildQueryWrapper = new QueryWrapper<>();
        gameRoomChildQueryWrapper.eq("room_id",roomId);
        gameRoomChildQueryWrapper.eq("member_id",memberId);
        GameRoomChild gameRoomChildExist = gameRoomChildMapper.selectOne(gameRoomChildQueryWrapper);
        if(ObjectUtil.isEmpty(gameRoomChildExist)){
            throw new FebsException("房间不存在");
        }
        Integer ownerState = gameRoomChildExist.getOwnerState();
        //如果退出的是房主，那么游戏结束
        if(GameRoomChild.OWNER_TRUE == ownerState){
            GameRoom gameRoom = gameRoomMapper.selectById(roomId);
            if(ObjectUtil.isNotEmpty(gameRoom)){
                gameRoom.setState(GameRoom.STATE_DONE);
                gameRoomMapper.updateById(gameRoom);

                this.sendMsgByRoomId(roomId,"OVER");
            }
        }
        //断开websocket
        WsSessionManager.remove(mallMember.getInviteId());

        return new FebsResponse().success();
    }

    @Override
    public FebsResponse flashGame(ApiFlashGameDto apiFlashGameDto) {
        Long memberId = LoginUserUtil.getLoginUser().getId();
        Long gameId = apiFlashGameDto.getGameId();

        GameGame gameGame = gameGameMapper.selectById(gameId);
        if(ObjectUtil.isEmpty(gameGame)){
            throw new FebsException("游戏已结束");
        }
        ApiFlashGameVo apiFlashGameVo = new ApiFlashGameVo();
        apiFlashGameVo.setRoomId(gameGame.getRoomId());
        apiFlashGameVo.setFirstNum(gameGame.getFirstNum());
        apiFlashGameVo.setSecondNum(gameGame.getSecondNum());
        apiFlashGameVo.setState(gameGame.getState());
        apiFlashGameVo.setPickOne(gameGame.getPickOne());
        apiFlashGameVo.setPickTwo(gameGame.getPickTwo());
        apiFlashGameVo.setPickThree(gameGame.getPickThree());
        apiFlashGameVo.setPickFour(gameGame.getPickFour());
        apiFlashGameVo.setPickFive(gameGame.getPickFive());
        apiFlashGameVo.setPickSix(gameGame.getPickSix());

        return new FebsResponse().success().data(apiFlashGameVo);
    }

    public static void main(String[] args) {
        System.out.println(ShareCodeUtil.toSerialNumberCodeTwo(1L));
        List<GameRoomTypeEnum> roomLists = GameRoomTypeEnum.ROOM_ONE.getRoomList();
        for(GameRoomTypeEnum gameRoomTypeEnum : roomLists){
            String amounts = gameRoomTypeEnum.getAmounts();
            // 使用split方法将字符串按照逗号分割成数组
            String[] numbersArray = amounts.split(",");

            // 将数组转换成Stream
            List<BigDecimal> numbersList = Arrays.stream(numbersArray)
                    // 使用map方法将每个字符串元素转换成BigDecimal
                    .map(BigDecimal::new)
                    // 收集到List中
                    .collect(Collectors.toList());
            numbersList.forEach(System.out::println);
        }
    }
}