From b6be66a34281cc6a72d544a92244bcc876a2c773 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 29 Aug 2024 10:36:02 +0800
Subject: [PATCH] test和数据库连接
---
src/test/java/cc/mrbird/febs/AgentTest.java | 74 ++++++++++++++++++++++++++++++++++---
src/main/resources/application-dev.yml | 5 ++
2 files changed, 73 insertions(+), 6 deletions(-)
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index cf27e8f..2f8c92d 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -19,6 +19,11 @@
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://120.27.238.55:3406/db_hongloumeng?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&allowMultiQueries=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8
+# username: db_wdf
+# password: db_wdf123!@#123
+# driver-class-name: com.mysql.cj.jdbc.Driver
+# url: jdbc:mysql://103.234.75.48:3306/db_wdf?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&rewriteBatchedStatements=true&allowMultiQueries=true&serverTimezone=GMT%2b8
+
redis:
# Redis数据库索引（默认为 0）
diff --git a/src/test/java/cc/mrbird/febs/AgentTest.java b/src/test/java/cc/mrbird/febs/AgentTest.java
index 8ecf0c1..f63d012 100644
--- a/src/test/java/cc/mrbird/febs/AgentTest.java
+++ b/src/test/java/cc/mrbird/febs/AgentTest.java
@@ -1,10 +1,19 @@
package cc.mrbird.febs;
+import cc.mrbird.febs.mall.entity.MallMemberAmount;
+import cc.mrbird.febs.mall.entity.MallProductSell;
+import cc.mrbird.febs.mall.mapper.MallMemberAmountMapper;
+import cc.mrbird.febs.mall.mapper.MallProductSellMapper;
import cc.mrbird.febs.mall.service.IAgentService;
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
+
+import java.math.BigDecimal;
+import java.util.List;
/**
@@ -15,11 +24,64 @@
@SpringBootTest
public class AgentTest {
- @Autowired
- private IAgentService agentService;
- @Test
- public void memberLevelUp() {
- agentService.memberLevelUp();
- }
+ /**
+ *
+ * 查询所有的 mall_product_sell 的记录中 nftCntAva 大于0且 state = 1 的记录
+ * trendsNft 增加 nftCntAva 的数量
+ * mall_product_sell 中的记录换成 state = 3
+ * 然后 trendsNft + totalPerk * 50% / 1.02 获得对应的 trendsNft 值
+ * 然后把之前两个数据清空，复制成新的 trendsNft 值
+ *
+ */
+// @Autowired
+// private IAgentService agentService;
+// @Autowired
+// private MallProductSellMapper mallProductSellMapper;
+// @Autowired
+// private MallMemberAmountMapper mallMemberAmountMapper;
+// @Test
+// public void memberData() {
+// QueryWrapper<MallProductSell> objectQueryWrapper = new QueryWrapper<>();
+// objectQueryWrapper.eq("state",1);
+// objectQueryWrapper.gt(true,"nft_cnt_ava", BigDecimal.ZERO);
+// List<MallProductSell> mallProductSells = mallProductSellMapper.selectList(objectQueryWrapper);
+// if(ObjectUtil.isEmpty(mallProductSells)){
+// return;
+// }
+// for(MallProductSell sell : mallProductSells){
+// sell.setState(0);
+// mallProductSellMapper.updateById(sell);
//
+// Long memberId = sell.getMemberId();
+// BigDecimal nftCntAva = sell.getNftCntAva();
+// MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
+// if(ObjectUtil.isEmpty(mallMemberAmount)){
+// continue;
+// }
+// mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(nftCntAva));
+// mallMemberAmountMapper.updateById(mallMemberAmount);
+// }
+//
+// List<MallMemberAmount> mallMemberAmounts = mallMemberAmountMapper.selectList(null);
+// if(ObjectUtil.isEmpty(mallMemberAmounts)){
+// return;
+// }
+// for(MallMemberAmount amount : mallMemberAmounts){
+// BigDecimal trendsNft = amount.getTrendsNft();
+// BigDecimal totalPerk = amount.getTotalPerk();
+// BigDecimal fcmCntAva = amount.getFcmCntAva();
+//
+// BigDecimal add = trendsNft.add(totalPerk);
+// BigDecimal multiply = add.multiply(new BigDecimal("0.5"));
+// BigDecimal divide = multiply.divide(new BigDecimal("1.02"), 2, BigDecimal.ROUND_DOWN);
+// if(BigDecimal.ZERO.compareTo(divide) >= 0){
+// amount.setFcmCntAva(fcmCntAva);
+// }else{
+// amount.setFcmCntAva(fcmCntAva.add(divide));
+// }
+// amount.setTrendsNft(BigDecimal.ZERO);
+// amount.setTotalPerk(BigDecimal.ZERO);
+// mallMemberAmountMapper.updateById(amount);
+// }
+// }
}
--
Gitblit v1.9.1