From 7b6b9968d3729e2611737e54954bb6ebd42b53bf Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 29 May 2023 16:26:53 +0800
Subject: [PATCH] twoCoin项目修改
---
src/test/java/cc/mrbird/febs/MemberTest.java | 48 ++++++++++++++++++++++++++++++++----------------
1 files changed, 32 insertions(+), 16 deletions(-)
diff --git a/src/test/java/cc/mrbird/febs/MemberTest.java b/src/test/java/cc/mrbird/febs/MemberTest.java
index 743d784..d41b9ad 100644
--- a/src/test/java/cc/mrbird/febs/MemberTest.java
+++ b/src/test/java/cc/mrbird/febs/MemberTest.java
@@ -6,8 +6,10 @@
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;
@@ -15,6 +17,8 @@
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;
@@ -30,6 +34,7 @@
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.List;
+import java.util.stream.Collectors;
/**
* @author wzy
@@ -54,6 +59,9 @@
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);
@@ -62,25 +70,33 @@
// }
public static void main(String[] args) {
-
- 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);
}
@Test
public void tranfer(){
-// dappSystemService.antKLineMsg(1);
- dappSystemService.aKlineJobHour();
+ 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);
--
Gitblit v1.9.1