fix:add active nft

Helius

2022-08-11 3154a08c8f114291b59ee44074d6af95026eba32

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java

@@ -19,6 +19,7 @@
import cc.mrbird.febs.dapp.vo.ActiveNftListVo;
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
@@ -374,23 +375,19 @@
    }

    @Override
    public int boxSurprise() {
    public ActiveNftListVo boxSurprise() {
        DappMemberEntity member = LoginUserUtil.getAppUser();

        // 功能升级
        throw new FebsException(MessageSourceUtils.getString("box_surprise_002"));
        DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId());
        if (walletCoin.getBoxCnt() < 1) {
            throw new FebsException(MessageSourceUtils.getString("box_surprise_001"));
        }

//        DappMemberEntity member = LoginUserUtil.getAppUser();
//
//        DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId());
//        if (walletCoin.getBoxCnt() < 1) {
//            throw new FebsException(MessageSourceUtils.getString("box_surprise_001"));
//        }
//
//        walletCoin.setBoxCnt(walletCoin.getBoxCnt() - 1);
//        dappWalletCoinDao.updateById(walletCoin);
//
//        BoxUtil.Box box = BoxUtil.openBox();
//
        walletCoin.setBoxCnt(walletCoin.getBoxCnt() - 1);
        dappWalletCoinDao.updateById(walletCoin);

        BoxUtil.Box box = BoxUtil.openBox();

//        DappFundFlowEntity boxFundFlow = new DappFundFlowEntity(member.getId(), new BigDecimal(box.getIndex()), 6, 2, BigDecimal.ZERO);
//        dappFundFlowDao.insert(boxFundFlow);
//
@@ -407,25 +404,49 @@
//                log.error("发放卡牌错误", e);
//            }
//        }).start();
//
//        return box.getIndex();

        Date time = new Date();
        Date expire = DateUtil.offset(time, DateField.HOUR, 2);
        DappNftActivation nftActivation = new DappNftActivation();
        nftActivation.setMemberId(member.getId());
        nftActivation.setCount(box.getIndex());
        nftActivation.setOpenTime(time);
        nftActivation.setExpireTime(expire);

        dappNftActivationDao.insert(nftActivation);

        ActiveNftListVo nft = new ActiveNftListVo();
        nft.setStatus(3);
        nft.setCount(box.getIndex());
        nft.setId(nftActivation.getId());
        nft.setRemain(DateUtil.between(time, expire, DateUnit.SECOND));
        return nft;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void activeNft(ActiveDto activeDto) {
    public synchronized void activeNft(ActiveDto activeDto) {
        DappMemberEntity member = LoginUserUtil.getAppUser();
        DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), BigDecimal.ONE, 8, 1, BigDecimal.ZERO, activeDto.getTxHash());
        fundFlow.setNewestPrice(AppContants.NFT_ACTIVE_PRICE);

        dappFundFlowDao.insert(fundFlow);

        DappNftActivation nftActive = dappNftActivationDao.selectById(activeDto.getId());
        if (nftActive == null) {
            throw new FebsException("NFT不存在");
        }

        if (nftActive.getCount() < activeDto.getCount()) {
            throw new FebsException("NFT不足或者正在激活中");
        }

        if (nftActive.getStatus() != 1) {
            throw new FebsException(MessageSourceUtils.getString("nft_active_001"));
        }

        nftActive.setStatus(2);

        DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), new BigDecimal(activeDto.getCount()), 8, 1, BigDecimal.ZERO, activeDto.getTxHash());
        fundFlow.setNewestPrice(AppContants.NFT_ACTIVE_PRICE);
        dappFundFlowDao.insert(fundFlow);

        nftActive.setCount(nftActive.getCount() - activeDto.getCount());
        dappNftActivationDao.updateById(nftActive);
    }

@@ -435,7 +456,7 @@
        List<ActiveNftListVo> list = new ArrayList<>();

        UpdateWrapper<DappNftActivation> query = new UpdateWrapper<>();
        query.eq("status", 3);
        query.eq("status", 1);
        query.eq("member_id", member.getId());
        List<DappNftActivation> nftActivations = dappNftActivationDao.selectList(query);

@@ -448,6 +469,7 @@
            ActiveNftListVo nftVo = new ActiveNftListVo();
            nftVo.setId(nft.getId());
            nftVo.setRemain(DateUtil.between(nft.getOpenTime(), now, DateUnit.SECOND, false));

            list.add(nftVo);
        });