nanjing_nft/src/test/java/com/izouma/nineth/service/AssetServiceTest.java

package com.izouma.nineth.service;

import com.izouma.nineth.ApplicationTests;
import com.izouma.nineth.TokenHistory;
import com.izouma.nineth.domain.*;
import com.izouma.nineth.exception.BusinessException;
import com.izouma.nineth.repo.*;
import org.apache.commons.lang3.StringUtils;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

class AssetServiceTest extends ApplicationTests {
    @Autowired
    private OrderRepo         orderRepo;
    @Autowired
    private BlindBoxItemRepo  blindBoxItemRepo;
    @Autowired
    private AssetService      assetService;
    @Autowired
    private CollectionRepo    collectionRepo;
    @Autowired
    private UserRepo          userRepo;
    @Autowired
    private CollectionService collectionService;
    @Autowired
    private AssetMintService  assetMintService;
    @Autowired
    private AssetRepo         assetRepo;
    @Autowired
    private NFTService        nftService;
    @Autowired
    private TokenHistoryRepo  tokenHistoryRepo;

    @Test
    void createAsset() {
        BlindBoxItem item = blindBoxItemRepo.findById(1860L).get();
        Order order = orderRepo.findById(1922L).get();
    }

    @Test
    void cancelConsignment() {
        assetService.cancelConsignment(1209L);
    }

    @Test
    void testCancelConsignment() {
    }

    @Test
    public void testLock() throws InterruptedException {
        assetService.testLock("123", "ddd");
    }

    @Test
    public void testCreateAsset() {
        Order order = orderRepo.findById(4618L).get();
        Collection collection = collectionRepo.findById(order.getCollectionId()).get();
        BlindBoxItem blindBoxItem = blindBoxItemRepo.findById(4250L).get();
        User user = userRepo.findById(order.getUserId()).get();
        assetService.createAsset(blindBoxItem, user, order.getId(), order.getPrice(), "出售", 1);
    }

    @Test
    public void mint() {
        Asset asset = assetRepo.findById(4622L).get();
        assetMintService.mint(asset);
    }

    @Test
    public void setHistory() {
        assetService.setHistory();
    }

    @Test
    public void cancelCon() {
        for (Asset asset : assetRepo.findNoAccount()) {
            try {
                assetService.cancelConsignment(asset.getId());
            } catch (Exception e) {

            }
        }
    }

    @Test
    public void fixNoHistory() {
        List<Asset> assets = assetRepo.findByNoHistory();

        for (Asset asset : assets) {
            if (StringUtils.isNotBlank(asset.getTokenId())) {
                User user = userRepo.findById(asset.getUserId()).get();
                TokenHistory tokenHistory = tokenHistoryRepo.save(TokenHistory.builder()
                        .tokenId(asset.getTokenId())
                        .fromUser(asset.getMinter())
                        .fromUserId(asset.getMinterId())
                        .fromAvatar(asset.getMinterAvatar())
                        .toUser(user.getNickname())
                        .toUserId(user.getId())
                        .toAvatar(user.getAvatar())
                        .operation("出售")
                        .price(asset.getPrice())
                        .tokenId(asset.getTokenId())
                        .build());
                tokenHistory.setCreatedAt(asset.getCreatedAt());
                tokenHistoryRepo.save(tokenHistory);
            }

        }
        System.out.println(assets);
    }


    @Test
    public void fixHistoryPrice() {
        List<TokenHistory> list = tokenHistoryRepo.findByOperationAndPriceNull("转让");
        System.out.println(list.size());
        StringBuilder builder = new StringBuilder();
        list.parallelStream().forEach(tokenHistory -> {
            List<Asset> assets = assetRepo.findByTokenIdAndCreatedAtBetween(tokenHistory.getTokenId(), tokenHistory.getCreatedAt()
                    .minusSeconds(10), tokenHistory.getCreatedAt().plusSeconds(1));
            if (assets.size() != 1) {
                throw new BusinessException("");
            }
            Order order = orderRepo.findById(assets.get(0).getOrderId())
                    .orElseThrow(new BusinessException(assets.get(0).getId() + "订单没找到"));
            builder.append(order.getId()).append(",").append(order.getPrice()).append("\n");
        });
        System.out.println(builder);
    }

    @Test
    public void del() {
        for (String s : new String[]{"5df454549a0f4373ce6bb81fe7bbb941",
                "61773ab99f4a402cbe2a667d53fdc11c",
                "69d43dda0dfdf08dd9ecea3ad1f9d50",
                "6de0578f99af8ae285b6eefd7e834f22",
                "7433fedd607cd9df192e4303206ebbf4",
                "7e4e23b9eebf1ab16d820da5c5eb3064",
                "86d9437a6551174bf7b8d4c46ba01690",
                "8e16830b0a36d661b90d5b1d8723f0d5",
                "953862a50f982d0495edf294c2c0c8c0",
                "a1da155eb43ef398ea30b4dffad8e184",
                "b74c8d9d59df3675e26d846892e2dad4",
                "bc47260b0ef9c3fe2616b80c31385677",
                "c50f01943fd38ebadb26fb68877477ae",
                "d0667e1585327bd42c75fd98ca414487",
                "d646bd4e0357fbe067ab8d0504ed57c4",
                "e0ddee55cfe14fbc18770631b10386bb",
                "e398353b6838b6b9ce9c903b448eaeb3",
                "ee35149d07d34e39adb18dfb1a0c7021",
                "faebc681f3698bf0da6136d0c8be87ac",
                "fc38421ee6d402a24e5c25ba2d870831",
                "43800381853ce6e07bec0fd602a54a69",
                "48918cf5bd017164ea5d1927708e8b9c",
                "493f285ae429aa4b1760db3e37e2a76f",
                "49bfe48771acf39e084e331be79e762d",
                "52ba65e1416fde9c3e9528e34b587454"
        }) {
            Asset asset = assetRepo.findFirstByTokenId(s);
            if (asset != null) {
                assetRepo.delete(asset);
            }
        }
    }
}