springboot + vue前后端分离的NFT数藏盲盒系统

package com.fingerchar.service; import java.math.BigDecimal; import java.math.BigInteger; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; import java.util.stream.Collectors; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import org.web3j.abi.datatypes.generated.Uint256; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.fingerchar.base.entity.BaseEntity; import com.fingerchar.base.service.IBaseService; import com.fingerchar.constant.CommonStatus; import com.fingerchar.constant.NoticeType; import com.fingerchar.constant.SysConfConstant; import com.fingerchar.dao.ext.FcOrderLogExtMapper; import com.fingerchar.domain.FcContractNft; import com.fingerchar.domain.FcNftItems; import com.fingerchar.domain.FcOrder; import com.fingerchar.domain.FcOrderLog; import com.fingerchar.domain.FcPayToken; import com.fingerchar.domain.FcSystem; import com.fingerchar.domain.FcTxOrder; import com.fingerchar.utils.NftDappEventUtils; import com.fingerchar.vo.EventValuesExt; @Service public class NftEventService { private static final Logger logger = LoggerFactory.getLogger(NftEventService.class); public static final String ZERO_ADDRESS = "0x0000000000000000000000000000000000000000"; @Autowired private IBaseService baseService; @Autowired FcOrderLogExtMapper orderLogExtMapper; @Autowired FcNoticeService noticeService; @Autowired FcSystemConfigService configService; @Transactional(rollbackFor = Exception.class) public void processEvent(Map<String, List<EventValuesExt>> map, String block) throws Exception { if (map.isEmpty()) { this.saveLastBlock(block); return; } List<FcOrderLog> list = new ArrayList<>(); List<EventValuesExt> valueList = sortLog(map.get(NftDappEventUtils.BUY_EVENT.getName())); Map<String, Integer> orderTypeMap = new HashMap<>(); if(null != valueList && !valueList.isEmpty()) { this.processBuyEvent(valueList, list, orderTypeMap); } String exchangeToken = this.configService.get(SysConfConstant.NFT_EXCHANGE); if (StringUtils.isEmpty(exchangeToken)) { throw new Exception("Unkown nft exchange token"); } valueList = sortLog(map.get(NftDappEventUtils.CANCEL_EVENT.getName())); if(null != valueList && !valueList.isEmpty()) { this.processCancelEvent(valueList, list); } valueList = sortLog(map.get(NftDappEventUtils.TRANSFER_EVENT.getName())); if(null != valueList && !valueList.isEmpty()) { Map<String, List<EventValuesExt>> valueMap = new HashMap<>(); valueList.stream().forEach(vo -> { if (null == valueMap.get(vo.getTxHash())) { valueMap.put(vo.getTxHash(), new ArrayList<>()); } valueMap.get(vo.getTxHash()).add(vo); }); this.processTransferEvent(valueMap, list, orderTypeMap); } valueList = sortLog(map.get(NftDappEventUtils.SECONDARYSALEFEES_EVENT.getName())); if(null != valueList && !valueList.isEmpty()) { this.processRoyaltiesEvent(valueList); } this.addOrderLog(list); this.saveLastBlock(block); } private List<EventValuesExt> sortLog(List<EventValuesExt> list) { if (null == list) { return null; } Collections.sort(list, new Comparator<EventValuesExt>() { public int compare(EventValuesExt val1, EventValuesExt val2) { return val1.getBlockNumber().compareTo(val2.getBlockNumber()); } }); return list; } @Transactional(rollbackFor = Exception.class) private void processRoyaltiesEvent(List<EventValuesExt> valueList) { if (valueList.isEmpty()) { return; } int len = valueList.size(); for (int i = 0; i < len; i++) { this.processRoyaltiesEvent(valueList.get(i)); } } @Transactional(rollbackFor = Exception.class) private void processRoyaltiesEvent(EventValuesExt eventValues) { BigInteger tokenId = (BigInteger) eventValues.getNonIndexedValues().get(0).getValue(); @SuppressWarnings("unchecked") List<Uint256> bps = (List<Uint256>) eventValues.getNonIndexedValues().get(2).getValue(); QueryWrapper<FcContractNft> wrapper = new QueryWrapper<>(); wrapper.eq(FcContractNft.ADDRESS, eventValues.getAddress()) .eq(FcContractNft.TOKEN_ID, tokenId.toString()); List<FcContractNft> nftList = this.baseService.findByCondition(FcContractNft.class, wrapper); if (null == nftList || nftList.isEmpty()) { return; } Set<Long> idSet = nftList.stream().map(FcContractNft::getId).collect(Collectors.toSet()); UpdateWrapper<FcContractNft> uwrapper = new UpdateWrapper<>(); List<Long> bpsTemp = bps.stream().map(bi -> bi.getValue().longValueExact()).collect(Collectors.toList()); uwrapper.set(FcContractNft.ROYALTIES, JSON.toJSONString(bpsTemp)); uwrapper.in(BaseEntity.ID, idSet); this.baseService.updateByCondition(FcContractNft.class, uwrapper); } @Transactional(rollbackFor = Exception.class) private void addOrderLog(List<FcOrderLog> logList) { if (logList.size() > 0) { this.baseService.saveBatch(logList); Set<String> txHashList = logList.stream().map(FcOrderLog::getTxHash).collect(Collectors.toSet()); if (txHashList.size() > 0) { UpdateWrapper<FcTxOrder> wrapper = new UpdateWrapper<>(); wrapper.set(FcTxOrder.IS_SYNC, true); wrapper.in(FcTxOrder.TX_HASH, txHashList); this.baseService.updateByCondition(FcTxOrder.class, wrapper); } } } @Transactional(rollbackFor = Exception.class) private void processBuyEvent(List<EventValuesExt> buyList, List<FcOrderLog> logList, Map<String, Integer> orderTypeMap) throws Exception { if (buyList.isEmpty()) { return; } int len = buyList.size(); for (int i = 0; i < len; i++) { this.processBuyEvent(buyList.get(i), logList, orderTypeMap); } } @Transactional(rollbackFor = Exception.class) private void processBuyEvent(EventValuesExt eventValue, List<FcOrderLog> logList, Map<String, Integer> orderTypeMap) throws Exception { String txHash = eventValue.getTxHash(); FcTxOrder txOrder = this.getByHash(txHash); if (null != txOrder) { logger.warn("tx_hash为" + txHash + "已经处理！"); return; } String sellToken = (String) eventValue.getIndexedValues().get(0).getValue(); BigInteger sellTokenId = (BigInteger) eventValue.getIndexedValues().get(1).getValue(); BigInteger sellValue = (BigInteger) eventValue.getNonIndexedValues().get(0).getValue(); String owner = (String) eventValue.getNonIndexedValues().get(1).getValue(); String buyToken = (String) eventValue.getNonIndexedValues().get(2).getValue(); BigInteger buyTokenId = (BigInteger) eventValue.getNonIndexedValues().get(3).getValue(); BigInteger buyValue = (BigInteger) eventValue.getNonIndexedValues().get(4).getValue(); String buyer = (String) eventValue.getNonIndexedValues().get(5).getValue(); BigInteger sal