From cdee95fda5bc96b5b52794b75b4906f378c30f52 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Wed, 24 Jan 2024 11:56:46 +0800 Subject: [PATCH] 发票 --- src/test/java/cc/mrbird/febs/ProfitTest.java | 39 ++++++++++++++++++++++++++++++++++++++- src/main/resources/application-dev.yml | 18 +++++++++--------- 2 files changed, 47 insertions(+), 10 deletions(-) diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index 13e6fca..5aa4c93 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -15,14 +15,14 @@ datasource: # 数据源-1,名称为 base base: - username: ct_test - password: 123456 - driver-class-name: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://120.27.238.55:3306/db_amz?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8 -# username: db_mall -# password: mall!@#123 +# username: ct_test +# password: 123456 # driver-class-name: com.mysql.cj.jdbc.Driver -# url: jdbc:mysql://47.111.90.145:3306/db_mall?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8 +# url: jdbc:mysql://120.27.238.55:3306/db_amz?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8 + username: db_mall + password: mall!@#123 + driver-class-name: com.mysql.cj.jdbc.Driver + url: jdbc:mysql://47.111.90.145:3306/db_mall?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8 redis: # Redis数据库索引(默认为 0) @@ -30,9 +30,9 @@ # Redis服务器地址 host: 120.27.238.55 # Redis服务器连接端口 - port: 6379 + port: 6479 # Redis 密码 - password: xcong123 + password: d3y6dsdl;f.327 lettuce: pool: # 连接池中的最小空闲连接 diff --git a/src/test/java/cc/mrbird/febs/ProfitTest.java b/src/test/java/cc/mrbird/febs/ProfitTest.java index 2530112..254ac02 100644 --- a/src/test/java/cc/mrbird/febs/ProfitTest.java +++ b/src/test/java/cc/mrbird/febs/ProfitTest.java @@ -2,7 +2,9 @@ import cc.mrbird.febs.common.entity.FebsResponse; import cc.mrbird.febs.common.utils.MallUtils; +import cc.mrbird.febs.mall.entity.MallMember; import cc.mrbird.febs.mall.entity.MallOrderItem; +import cc.mrbird.febs.mall.mapper.MallMemberMapper; import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper; import cc.mrbird.febs.mall.mapper.MallOrderItemMapper; import cc.mrbird.febs.mall.quartz.OrderSettlementJob; @@ -12,7 +14,9 @@ import cc.mrbird.febs.pay.model.*; import cc.mrbird.febs.pay.service.UnipayService; import cc.mrbird.febs.rabbit.consumer.AgentConsumer; +import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; @@ -112,12 +116,45 @@ @Autowired private OrderSettlementJob orderSettlementJob; + @Autowired + private MallMemberMapper mallMemberMapper; @Test public void orderSettlementJobTest() { // orderSettlementJob.normalGoodsSettlementJob(); - mallAchieveService.add(83L); + List<MallMember> mallMembers = mallMemberMapper.selectList(null); + if(CollUtil.isEmpty(mallMembers)){ + return; + } + for(MallMember mallMember : mallMembers){ + boolean flag = false; + String parentId = mallMember.getReferrerId(); + if (StrUtil.isBlank(parentId)) { + flag = true; + } + String ids = ""; + while (!flag) { + if (StrUtil.isBlank(ids)) { + ids += parentId; + } else { + ids += ("," + parentId); + } + MallMember parentMember = mallMemberMapper.selectInfoByInviteId(parentId); + if (parentMember == null) { + break; + } + parentId = parentMember.getReferrerId(); + if (StrUtil.isBlank(parentMember.getReferrerId())) { + flag = true; + } + } + + if (StrUtil.isNotBlank(ids)) { + mallMember.setReferrerIds(ids); + } + mallMemberMapper.updateById(mallMember); + } } -- Gitblit v1.9.1