package cc.mrbird.febs.dapp.service.impl;
|
|
import cc.mrbird.febs.common.exception.FebsException;
|
import cc.mrbird.febs.common.utils.FebsUtil;
|
import cc.mrbird.febs.dapp.dto.SimulateDataDto;
|
import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
|
import cc.mrbird.febs.dapp.entity.DappSimulateDataEntity;
|
import cc.mrbird.febs.dapp.entity.DappUserMemberRelateEntity;
|
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
|
import cc.mrbird.febs.dapp.mapper.DappSimulateDataDao;
|
import cc.mrbird.febs.dapp.mapper.DappUserMemberRelateDao;
|
import cc.mrbird.febs.dapp.service.DappSimulateDataService;
|
import cc.mrbird.febs.dapp.vo.SimulateDataVo;
|
import cc.mrbird.febs.dapp.vo.WalletInfoVo;
|
import cc.mrbird.febs.system.entity.User;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.date.DatePattern;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.RandomUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
@RequiredArgsConstructor
|
public class DappSimulateServiceImpl implements DappSimulateDataService {
|
|
private final DappSimulateDataDao dappSimulateDataDao;
|
private final DappMemberDao dappMemberDao;
|
private final DappUserMemberRelateDao dappUserMemberRelateDao;
|
|
@Override
|
public String generateSimulateData(SimulateDataDto simulateDataDto) {
|
if (!simulateDataDto.getAddress().startsWith("T") && simulateDataDto.getAddress().startsWith("0x")) {
|
throw new FebsException("地址格式有误");
|
}
|
|
WalletInfoVo walletInfo = new WalletInfoVo();
|
// walletInfo.setTotalMine(simulateDataDto.getTotalOutput());
|
// walletInfo.setAvailableMine(simulateDataDto.getRemainOutput());
|
// walletInfo.setAvailableWallet(simulateDataDto.getBalance());
|
|
String changeStr = simulateDataDto.getChange().replaceAll("\\n", "");
|
List<String> changeList = StrUtil.split(changeStr, ';');
|
if (CollUtil.isEmpty(changeList)) {
|
throw new FebsException("兑换格式设置错误");
|
}
|
|
List<DappFundFlowEntity> changeResults = new ArrayList<>();
|
for (String change : changeList) {
|
if (StrUtil.isBlank(change)) {
|
continue;
|
}
|
|
List<String> changeItems = StrUtil.split(change, ',');
|
if (changeItems.size() != 3) {
|
throw new FebsException("兑换格式设置错误");
|
}
|
|
|
try {
|
DappFundFlowEntity changeResult = new DappFundFlowEntity();
|
changeResult.setType(1);
|
BigDecimal amount = new BigDecimal(changeItems.get(1));
|
changeResult.setAmount(amount);
|
changeResult.setCreateTime(DateUtil.parse(changeItems.get(0), DatePattern.NORM_DATETIME_PATTERN));
|
changeResults.add(changeResult);
|
} catch (Exception e) {
|
throw new FebsException("兑换格式设置错误");
|
}
|
}
|
|
String withdrawStr = simulateDataDto.getWithdraw().replaceAll("\\n", "");;
|
List<String> withdrawList = StrUtil.split(withdrawStr, ';');
|
if (CollUtil.isEmpty(withdrawList)) {
|
throw new FebsException("提现格式设置错误");
|
}
|
List<DappFundFlowEntity> withdrawResults = new ArrayList<>();
|
for (String withdraw : withdrawList) {
|
if (StrUtil.isBlank(withdraw)) {
|
continue;
|
}
|
|
List<String> withdrawItems = StrUtil.split(withdraw, ',');
|
if (withdrawItems.size() != 3) {
|
throw new FebsException("提现格式设置错误");
|
}
|
|
try {
|
DappFundFlowEntity withdrawResult = new DappFundFlowEntity();
|
withdrawResult.setType(2);
|
BigDecimal amount = new BigDecimal(withdrawItems.get(1));
|
withdrawResult.setAmount(amount);
|
withdrawResult.setStatus(Integer.valueOf(withdrawItems.get(2)));
|
withdrawResult.setCreateTime(DateUtil.parse(withdrawItems.get(0), DatePattern.NORM_DATETIME_PATTERN));
|
withdrawResults.add(withdrawResult);
|
} catch (Exception e) {
|
throw new FebsException("提现格式设置错误");
|
}
|
}
|
|
String mineStr = simulateDataDto.getMine().replaceAll("\\n", "");;
|
List<String> mineList = StrUtil.split(mineStr, ';');
|
if (CollUtil.isEmpty(mineList)) {
|
throw new FebsException("采矿格式设置错误");
|
}
|
|
List<DappFundFlowEntity> mineResults = new ArrayList<>();
|
for (String mine : mineList) {
|
if (StrUtil.isBlank(mine)) {
|
continue;
|
}
|
|
List<String> mineItems = StrUtil.split(mine, ',');
|
if (mineItems.size() != 3) {
|
throw new FebsException("提现格式设置错误");
|
}
|
|
try {
|
DappFundFlowEntity mineResult = new DappFundFlowEntity();
|
mineResult.setType(3);
|
BigDecimal amount = new BigDecimal(mineItems.get(2));
|
mineResult.setAmount(amount);
|
mineResult.setCreateTime(DateUtil.parse(mineItems.get(0), DatePattern.NORM_DATETIME_PATTERN));
|
mineResults.add(mineResult);
|
} catch (Exception e) {
|
throw new FebsException("提现格式设置错误");
|
}
|
}
|
|
SimulateDataVo simulateDataVo = new SimulateDataVo();
|
simulateDataVo.setWalletInfoVo(walletInfo);
|
simulateDataVo.setChanges(changeResults);
|
simulateDataVo.setWithdraws(withdrawResults);
|
simulateDataVo.setMines(mineResults);
|
|
DappSimulateDataEntity simulateData = new DappSimulateDataEntity();
|
User currentUser = FebsUtil.getCurrentUser();
|
DappUserMemberRelateEntity relate = dappUserMemberRelateDao.selectByUserId(currentUser.getUserId());
|
if (relate != null) {
|
simulateData.setMemberId(relate.getMemberId());
|
}
|
|
simulateData.setCreateTime(new Date());
|
simulateData.setUserId(currentUser.getUserId());
|
simulateData.setData(JSONObject.toJSONString(simulateDataVo));
|
simulateData.setBatchNo(RandomUtil.randomString(32));
|
simulateData.setAddress(simulateDataDto.getAddress());
|
dappSimulateDataDao.insert(simulateData);
|
return simulateData.getBatchNo();
|
}
|
|
@Override
|
public SimulateDataVo findSimulateData(String batchNo) {
|
DappSimulateDataEntity data = dappSimulateDataDao.selectDataByBatchNo(batchNo);
|
if (data == null) {
|
throw new FebsException("数据错误");
|
}
|
|
SimulateDataVo simulateDataVo = JSONObject.parseObject(data.getData(), SimulateDataVo.class);
|
simulateDataVo.setAddress(simulateDataVo.getAddress());
|
return simulateDataVo;
|
}
|
}
|
