From 0b10fd71ce7a6c32b70eef96f0ceb5a516306d6b Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Mon, 24 May 2021 15:05:01 +0800 Subject: [PATCH] modify --- src/test/java/com/xcong/excoin/XchTest.java | 120 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 119 insertions(+), 1 deletions(-) diff --git a/src/test/java/com/xcong/excoin/XchTest.java b/src/test/java/com/xcong/excoin/XchTest.java index bdde057..a0244e6 100644 --- a/src/test/java/com/xcong/excoin/XchTest.java +++ b/src/test/java/com/xcong/excoin/XchTest.java @@ -1,19 +1,137 @@ package com.xcong.excoin; +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DateUnit; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.ObjectUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.xcong.excoin.modules.coin.parameter.dto.CoinInListDto; +import com.xcong.excoin.modules.coin.service.CoinService; +import com.xcong.excoin.modules.yunding.dao.YdOrderDao; +import com.xcong.excoin.modules.yunding.entity.YdOrderEntity; import com.xcong.excoin.modules.yunding.service.XchProfitService; +import com.xcong.excoin.quartz.job.YdPowerJob; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.math.BigDecimal; +import java.util.Date; +import java.util.List; @SpringBootTest public class XchTest { @Autowired private XchProfitService xchProfitService; + @Autowired + private YdOrderDao ydOrderDao; @Test public void usdtReturnTest() { - xchProfitService.agentProfitDistributor(); + xchProfitService.agentUsdtProfitDistributor(); + } + + @Test + public void dateUtilTest() { + String day1 = "2021-05-12 22:00:00"; + String day2 = "2021-05-12 23:00:00"; + System.out.println(DateUtil.compare(DateUtil.parse(day1, "yyyy-MM-dd HH:mm:ss"), DateUtil.parse(day2, "yyyy-MM-dd HH:mm:ss"))); + } + + @Test + public void orderWork() { + QueryWrapper<YdOrderEntity> objectQueryWrapper = new QueryWrapper<>(); + objectQueryWrapper.eq("state",YdOrderEntity.ORDER_STATE_READY); + objectQueryWrapper.eq("type",YdOrderEntity.PRODUCT_ORDER); + List<YdOrderEntity> ydOrderEntities = ydOrderDao.selectList(objectQueryWrapper); + Date date = new Date(); + if(CollUtil.isNotEmpty(ydOrderEntities)){ + for(YdOrderEntity ydOrderEntity : ydOrderEntities){ + Date workTime = ydOrderEntity.getWorkTime(); + if(ObjectUtil.isNotEmpty(workTime) && DateUtil.compare(date, workTime) > -1){ + Long id = ydOrderEntity.getId(); + ydOrderDao.UpdateByIdAndState(id,YdOrderEntity.ORDER_STATE_WORK); + } + } + } + } + + @Test + public void orderUsdtProfitTest() { + xchProfitService.usdtProfitDistributorByOrderId(17L); + } +// +// @Autowired +// private YdPowerJob ydPowerJob; +// +// @Test +// public void ydPowerTest() { +// ydPowerJob.orderWork(); +// } + + + @Test + public void orderTest() { + YdOrderEntity orderEntity = new YdOrderEntity(); + orderEntity.setType(YdOrderEntity.AGENT_ORDER); + orderEntity.setMemberId(40L); + orderEntity.setAmount(BigDecimal.TEN); + ydOrderDao.insert(orderEntity); + } + + @Test + public void xchProfitTest() { + xchProfitService.xchProfitDistributor(BigDecimal.valueOf(1)); + } + + @Autowired + private CoinService coinService; + + @Test + public void coinTest() { + CoinInListDto coin = new CoinInListDto(); + coin.setType(4); + coin.setPageNum(1); + coin.setPageSize(10); + coinService.coinInList(coin); + } + + public static void main(String[] args) { + String s = execCurl("https://api2.chiaexplorer.com/blockchainSummary"); + System.out.println(s); + } + + private static String execCurl(String url) { + String[] cmds = {"curl", url + , "-H", "sec-ch-ua: \" Not A;Brand\";v=\"99\", \"Chromium\";v=\"90\", \"Google Chrome\";v=\"90\"" + ,"-H", "Accept: application/json, text/plain, */*" + ,"-H", "Referer: https://www.chiaexplorer.com/" + ,"-H", "sec-ch-ua-mobile: ?0" + ,"-H", "User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/90.0.4430.212 Safari/537.36" + ," --compressed"}; + + ProcessBuilder process = new ProcessBuilder(cmds); + Process p; + try { + p = process.start(); + BufferedReader reader = new BufferedReader(new InputStreamReader(p.getInputStream())); + StringBuilder builder = new StringBuilder(); + String line; + while ((line = reader.readLine()) != null) { + builder.append(line); + builder.append(System.getProperty("line.separator")); + } + return builder.toString(); + + } catch (IOException e) { + System.out.print("error"); + e.printStackTrace(); + } + return null; } } -- Gitblit v1.9.1