From b47f59b40c13bdf7a0368ed3815ccc09f74eda25 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Sat, 06 Jul 2024 00:37:52 +0800 Subject: [PATCH] 后台 --- src/test/java/cc/mrbird/febs/ProfitTest.java | 74 +++++++++++++++++++----------------- 1 files changed, 39 insertions(+), 35 deletions(-) diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java index f0519ec..9b6aaaa 100644 --- a/src/test/java/cc/mrbird/febs/ProfitTest.java +++ b/src/test/java/cc/mrbird/febs/ProfitTest.java @@ -5,10 +5,7 @@ import cc.mrbird.febs.common.enumerates.ProductEnum; import cc.mrbird.febs.common.utils.MallUtils; import cc.mrbird.febs.mall.dto.TeamPerkDto; -import cc.mrbird.febs.mall.entity.DataDictionaryCustom; -import cc.mrbird.febs.mall.entity.MallMember; -import cc.mrbird.febs.mall.entity.MallOrderItem; -import cc.mrbird.febs.mall.entity.MallProductBuy; +import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.quartz.OrderSettlementJob; import cc.mrbird.febs.mall.service.*; @@ -18,6 +15,7 @@ import cc.mrbird.febs.pay.service.UnipayService; import cc.mrbird.febs.rabbit.producter.AgentProducer; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; @@ -51,9 +49,9 @@ private DataDictionaryCustomMapper dataDictionaryCustomMapper; @Autowired private MallProductBuyMapper mallProductBuyMapper; - @Test - public void dynamicProfit(){ - +// @Test +// public void dynamicProfit(){ +// // QueryWrapper<MallProductBuy> query = new QueryWrapper<>(); // query.eq("state", ProductEnum.PRODUCT_BUY_SUCCESS.getValue()); // query.eq("mate_state",ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue()); @@ -103,23 +101,28 @@ // TeamPerkDto teamPerkDto = JSONObject.parseObject(levelDic.getValue(), TeamPerkDto.class); // Integer directCntLevel = teamPerkDto.getDirectCnt(); // Integer teamCnt = teamPerkDto.getTeamCnt(); -// if(directCntLevel >= intersection.size() && -// teamCnt >= mallMembersAll.size()){ -// mallMemberRef.setLevel(level); -// memberMapper.updateById(mallMemberRef); -// flag = true; -// } -// String nextLevel = MemberLevelNewEnum.ZERO_LEVEL.getNextLevel(level); -// level = nextLevel; -// if(level.equals(MemberLevelNewEnum.WU_LEVEL.getType()) && -// nextLevel.equals(MemberLevelNewEnum.WU_LEVEL.getType()) ){ -// mallMemberRef.setLevel(level); -// memberMapper.updateById(mallMemberRef); +// if(directCntLevel <= intersection.size()){ +// if(teamCnt <= mallMembersAll.size()){ +// mallMemberRef.setLevel(level); +// memberMapper.updateById(mallMemberRef); +// +// String nextLevel = MemberLevelNewEnum.ZERO_LEVEL.getNextLevel(level); +// level = nextLevel; +// if(level.equals(MemberLevelNewEnum.WU_LEVEL.getType()) && +// nextLevel.equals(MemberLevelNewEnum.WU_LEVEL.getType()) ){ +// mallMemberRef.setLevel(level); +// memberMapper.updateById(mallMemberRef); +// flag = true; +// } +// }else{ +// flag = true; +// } +// }else{ // flag = true; // } // } // } - } +// } // @Autowired // private AgentConsumer agentConsumer; // @@ -175,25 +178,26 @@ private NBYHService nbyhService; @Autowired private IAdminMallMemberService mallMemberService; + @Autowired + private MallProductNftMapper mallProductNftMapper; @Test public void agentProfitTrade() { -// agentService.timeGetOrderBuy(); -// agentService.BuyToSell(); -// try { -// System.out.println(resourceLoader.getResource("classpath:lkl/api_private_key.pem").getInputStream()); -// } catch (IOException e) { -// e.printStackTrace(); + boolean flag = true; + Integer i = 0; +// while (flag){ +//// agentService.BuyToSellV2(); +// DateTime dateTime = DateUtil.offsetDay(new DateTime(), i); +// agentService.BuyToSellV3(dateTime); +// i = i+1; +// List<MallProductBuy> mallProductBuys = mallProductBuyMapper.selectListByStateAndMateState( +// ProductEnum.PRODUCT_BUY_SUCCESS.getValue(), +// ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue()); +// if(CollUtil.isEmpty(mallProductBuys)){ +// flag = false; +// } // } -// nbyhService.tradeSinge(306L); -// nbyhService.tradeSingeOuterTransfer(306L); -// nbyhService.accountInfoQuery(306L); -// nbyhService.transferResultInfoQuery(315L); -// -// mallMemberService.chargeAgree(307L); -// mallMemberService.searchInfo(307L); - -// agentService.perkAgent(); + System.out.println(i); } @Test public void agentProfit() { -- Gitblit v1.9.1