package cc.mrbird.febs;
|
|
import cc.mrbird.febs.common.contants.AppContants;
|
import cc.mrbird.febs.common.contants.SystemConstants;
|
import cc.mrbird.febs.common.utils.RedisUtils;
|
import cc.mrbird.febs.dapp.chain.ChainEnum;
|
import cc.mrbird.febs.dapp.chain.ChainService;
|
import cc.mrbird.febs.dapp.contract.ContractMain;
|
import cc.mrbird.febs.dapp.entity.DappAKlineEntity;
|
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
|
import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
|
import cc.mrbird.febs.dapp.mapper.DappAKlineMapper;
|
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
|
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
|
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
|
import cc.mrbird.febs.dapp.service.DappSystemService;
|
import cc.mrbird.febs.dapp.vo.AKLineLimitVo;
|
import cc.mrbird.febs.dapp.vo.AKLineVo;
|
import cc.mrbird.febs.rabbit.producer.ChainProducer;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.json.JSONArray;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import org.apache.commons.lang3.StringUtils;
|
import org.junit.jupiter.api.Test;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.test.context.SpringBootTest;
|
import org.web3j.utils.Convert;
|
|
import java.math.BigDecimal;
|
import java.math.BigInteger;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* @author wzy
|
* @date 2022-06-09
|
**/
|
@SpringBootTest
|
public class MemberTest {
|
|
// @Autowired
|
// private DappMemberDao dappMemberDao;
|
//
|
// @Autowired
|
// private DataDictionaryCustomMapper dataDictionaryCustomMapper;
|
//
|
// @Autowired
|
// private DappFundFlowDao dappFundFlowDao;
|
//
|
// @Autowired
|
// private ContractMain contractMain;
|
//
|
// @Autowired
|
// private ChainProducer chainProducer;
|
//
|
// @Autowired
|
// private DappAKlineMapper dappAKlineMapper;
|
//
|
// @Autowired
|
// private RedisUtils redisUtils;
|
// // String address = dappMemberEntity.getAddress();
|
//// String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, amount);
|
//// if(StrUtil.isEmpty(hash)){
|
//// return;
|
//// }
|
//
|
// public static void main(String[] args) {
|
// }
|
// @Test
|
// public void tranfer(){
|
// dappSystemService.antKLineMsg(1);
|
//// boolean allowance = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).isAllowance("0x458ff43d5ddddb4fd44dd60170ae4831e0d97c9c");
|
//// System.out.println(allowance);
|
//
|
//// dappSystemService.AntACoinInMsg(780L);
|
//// dappSystemService.aKlineJobHour();
|
//// dappSystemService.aKlineJobDay();
|
//// dappSystemService.AntACoinInMsg(164L);
|
//
|
//// List<JSONObject> objects = new ArrayList<>();
|
//// AKLineVo akLineVo = new AKLineVo();
|
//// akLineVo.setCreateTime(DateUtil.date());
|
//// akLineVo.setClosePrice(BigDecimal.ZERO);
|
//// akLineVo.setOpenPrice(BigDecimal.ZERO);
|
//// akLineVo.setLowestPrice(BigDecimal.ZERO);
|
//// akLineVo.setHighestPrice(BigDecimal.ZERO);
|
//// JSONObject parseObj = JSONUtil.parseObj(akLineVo);
|
//// objects.add(parseObj);
|
//// objects.add(parseObj);
|
//// objects.add(parseObj);
|
//// objects.add(parseObj);
|
//// System.out.println(objects);
|
//// System.out.println(objects.toString());
|
//// redisUtils.set("test",objects.toString());
|
//// Object test = redisUtils.get("test");
|
//// System.out.println(test.toString());
|
//// JSONArray jsonArray = JSONUtil.parseArray(test);
|
//// System.out.println(jsonArray);
|
//
|
//// String hash = ChainService.getInstance(ChainEnum.BNB.name()).transferBaseToken(address, amount);
|
////// if(StrUtil.isEmpty(hash)){
|
////// return;
|
////// }
|
//// BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_USDT.name()).balanceOf(ChainEnum.BSC_USDT.getAddress());
|
////// Integer count = dappFundFlowDao.updateStatusById(DappFundFlowEntity.WITHDRAW_STATUS_AGREE,464L);
|
////// String address = dappMemberEntity.getAddress();
|
////// log.info("{}",address);
|
//// System.out.println(balance);
|
//
|
//
|
//// dappSystemService.bnbTransferTest(44L);
|
//
|
//
|
// //发送转币消息
|
//// chainProducer.sendBnbTransferMsg(93L);
|
//// chainProducer.sendBnbTransferMsg(94L);
|
//// chainProducer.sendBnbTransferMsg(95L);
|
//// chainProducer.sendBnbTransferMsg(96L);
|
// }
|
//
|
//
|
// @Autowired
|
// private SystemConstants systemConstants;
|
// @Autowired
|
// private DappSystemService dappSystemService;
|
// @Test
|
// public void balance() {
|
//
|
// dappSystemService.selectAndInsertDics();
|
//// /**
|
//// * 从contractAddress合约地址中转移对应发行的代币到address中
|
//// */
|
//// dappSystemService.bnbTransfer(6L);
|
//
|
//
|
//// String address = AppContants.ADDRESS_A_POOL_PEOJECT;
|
//// /**
|
//// * 发起USDT转账
|
//// */
|
//// String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, new BigDecimal("0.01"));
|
//// System.out.println(hash);
|
// }
|
//
|
// @Test
|
// public void refererIdsTest() {
|
// DappMemberEntity member = dappMemberDao.selectById(24);
|
//
|
// boolean flag = false;
|
// String parentId = "35087336";
|
// String ids = "";
|
// String feeProfitIds = "";
|
//
|
// int i = 1;
|
// List<DataDictionaryCustom> feeProfitDic = dataDictionaryCustomMapper.selectDicByType(AppContants.DIC_TYPE_DISTRIBUTE_PROP);
|
// while (!flag && StringUtils.isNotBlank(parentId)) {
|
// if (StrUtil.isBlank(ids)) {
|
// ids += parentId;
|
// } else {
|
// ids += ("," + parentId);
|
// }
|
//
|
// if (i <= 4) {
|
// if (StrUtil.isBlank(feeProfitIds)) {
|
// feeProfitIds += parentId;
|
// } else {
|
// feeProfitIds += ("," + parentId);
|
// }
|
// }
|
//
|
// i++;
|
// DappMemberEntity parentMember = dappMemberDao.selectMemberInfoByInviteId(parentId);
|
// if (parentMember == null) {
|
// break;
|
// }
|
// parentId = parentMember.getRefererId();
|
// if(StringUtils.isBlank(parentId) || "0".equals(parentId)){
|
// break;
|
// }
|
// if (parentMember.getRefererId().equals(parentMember.getInviteId())) {
|
// flag = true;
|
// }
|
// }
|
// member.setRefererIds(ids);
|
// member.setFeeProfitIds(feeProfitIds);
|
// }
|
}
|
