From e383851a3a7076b5ae2a96dfbea8b14e85863a56 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 08 Sep 2023 15:55:28 +0800
Subject: [PATCH] 后台修改
---
src/test/java/cc/mrbird/febs/MemberTest.java | 300 ++++++++++++++++++++++++++++-------------------------------
1 files changed, 141 insertions(+), 159 deletions(-)
diff --git a/src/test/java/cc/mrbird/febs/MemberTest.java b/src/test/java/cc/mrbird/febs/MemberTest.java
index d41b9ad..8bd04fa 100644
--- a/src/test/java/cc/mrbird/febs/MemberTest.java
+++ b/src/test/java/cc/mrbird/febs/MemberTest.java
@@ -43,167 +43,149 @@
@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(){
- DateTime dateTime = DateUtil.offsetHour(DateUtil.date(), -1);
- String format = DateUtil.format(dateTime, "yyyy-MM-dd HH");
- List<String> dataDayStrList = new ArrayList<>();
- dataDayStrList.add(format);
- List<DappAKlineEntity> dappAKlineEntities = dappAKlineMapper.selectListByTypeAndHour(dataDayStrList);
-
- DappAKlineEntity dappAKlineEntity = new DappAKlineEntity();
- if(CollUtil.isNotEmpty(dappAKlineEntities)){
-
- List<BigDecimal> openPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getOpenPrice).collect(Collectors.toList());
- BigDecimal openPrice = openPriceList.stream().min(BigDecimal::compareTo).get();
- System.out.println(openPrice);
- //获取最高价
- List<BigDecimal> highestPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getHighestPrice).collect(Collectors.toList());
- BigDecimal highestPrice = highestPriceList.stream().max(BigDecimal::compareTo).get();
- System.out.println(highestPrice);
-
- List<BigDecimal> lowestPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getLowestPrice).collect(Collectors.toList());
- BigDecimal lowestPrice = lowestPriceList.stream().min(BigDecimal::compareTo).get();
- System.out.println(lowestPrice);
- }
- System.out.println(dappAKlineEntities);
-// 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);
+// @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;
//// }
-// 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() {
-
+//
+// 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);
- }
+//// /**
+//// * 从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);
+// }
}
--
Gitblit v1.9.1