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);
|
}
|
}
|
