diff --git a/src/main/resources/application-pay.yml b/src/main/resources/application-pay.yml index 2dc7a0d6..19f6eb30 100644 --- a/src/main/resources/application-pay.yml +++ b/src/main/resources/application-pay.yml @@ -1,5 +1,5 @@ swagger: - enabled: true + enabled: false pay: h5BaseUrl: https://dj-h5.hnsiyao.cn/me/detail/detail?allId= orderNotifyUrl: https://pay.hnsiyao.cn/czg/app/wuyou/notify diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml index 43a1131b..bb9aafb1 100644 --- a/src/main/resources/application-prod.yml +++ b/src/main/resources/application-prod.yml @@ -1,5 +1,5 @@ swagger: - enabled: true + enabled: false pay: h5BaseUrl: https://dj-h5.hnsiyao.cn/me/detail/detail?allId= orderNotifyUrl: https://pay.hnsiyao.cn/czg/app/wuyou/notify diff --git a/src/test/java/com/sqx/Tets.java b/src/test/java/com/sqx/Tets.java index f1c0c42d..81979fe0 100644 --- a/src/test/java/com/sqx/Tets.java +++ b/src/test/java/com/sqx/Tets.java @@ -1,6 +1,9 @@ package com.sqx; +import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; +import cn.hutool.core.lang.Dict; +import cn.hutool.core.util.PageUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; @@ -14,6 +17,7 @@ import com.sqx.modules.app.entity.UserMoneyDetails; import com.sqx.modules.app.service.InviteAchievementService; import com.sqx.modules.app.service.UserService; import com.sqx.modules.job.task.TempOrdersTask; +import com.sqx.modules.orders.entity.Orders; import com.sqx.modules.orders.service.OrdersService; import com.sqx.modules.pay.dao.PayDetailsDao; import com.sqx.modules.pay.entity.PayDetails; @@ -28,6 +32,7 @@ import org.springframework.context.ApplicationContext; import org.springframework.test.context.ActiveProfiles; import java.math.BigDecimal; +import java.util.ArrayList; import java.util.List; import java.util.Set; import java.util.stream.Collectors; @@ -74,8 +79,8 @@ public class Tets { Set useridList = userMoneyDetails.stream().map(UserMoneyDetails::getUserId).collect(Collectors.toSet()); List userMoneyDetailsList = userMoneyDao.selectList(new LambdaQueryWrapper().in(UserMoney::getUserId, useridList)); userMoneyDetailsList.parallelStream().forEach(userMoney -> { - BigDecimal coin = userMoneyDao.sumMoney(userMoney.getUserId()); - BigDecimal money = userMoneyDao.sumMoney2(userMoney.getUserId()); + BigDecimal coin = userMoneyDao.sumMoney(userMoney.getUserId()); + BigDecimal money = userMoneyDao.sumMoney2(userMoney.getUserId()); log.info("用户: {}, 金币: {}, 金额: {}", userMoney.getUserId(), coin, money); userMoney.setInviteIncomeCoin(coin); userMoney.setInviteIncomeMoney(money); @@ -131,7 +136,8 @@ public class Tets { })); } - @Test + + //@Test public void test() { // } // WuyouController proxy = applicationContext.getBean(WuyouController.class); @@ -166,7 +172,59 @@ public class Tets { assert false : "asdasfqwerq3rqwr"; } + //@Test + public void test999() { + int total = ordersService.count(Wrappers.lambdaQuery().apply("sys_user_id is null")); + System.out.println(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>" + total); + LambdaQueryWrapper wrapper = Wrappers.lambdaQuery().apply("sys_user_id is null").last("limit 1"); + List list = new ArrayList<>(); + for (int i = 0; i < 5000; i++) { + list.add(i); + } + list.parallelStream().forEach(param -> { + while (true) { + Orders orders = ordersService.getOne(wrapper); + if (orders == null) { + break; + } + ordersService.fillSysUserId(orders); + //System.out.println(StrUtil.format("-------------------------------sysUserId:{} ", orders.getSysUserId())); + ordersService.update(null, Wrappers.lambdaUpdate().set(Orders::getSysUserId, orders.getSysUserId()).eq(Orders::getOrdersId, orders.getOrdersId())); + } + }); + } + @Test + public void test888() { + LambdaQueryWrapper wrapper = Wrappers.lambdaQuery().apply("create_time < str_to_date({0}, '%Y-%m-%d %H:%i:%s')", "2025-01-01 00:00:00"); + List userinfoList = userService.list(wrapper); + userinfoList.parallelStream().forEach((userEntity -> { + List list = ordersService.list(Wrappers.lambdaQuery().eq(Orders::getUserId, userEntity.getUserId()).isNull(Orders::getSysUserId)); + if (CollUtil.isNotEmpty(list)) { + List> split = CollUtil.split(list, 500); + for (List splitList : split) { + splitList.parallelStream().forEach(orders -> { + ordersService.fillSysUserId(orders); + System.out.println(StrUtil.format("-------------------------------sysUserId:{},sysUserName:{} ", orders.getSysUserId(), orders.getUserName())); + ordersService.update(null, Wrappers.lambdaUpdate().set(Orders::getSysUserId, orders.getSysUserId()).eq(Orders::getOrdersId, orders.getOrdersId())); + }); + } + } + })); + System.out.println("-------------------------------结束------------------------------------"); + } + private List buildPageList(int total) { + int size = 300; + int totalPage = PageUtil.totalPage(total, size); + List pageList = new ArrayList<>(); + for (int page = 1; page <= totalPage; page++) { + Dict dict = new Dict(); + dict.set("page", (page - 1) * size); + dict.set("size", size); + pageList.add(dict); + } + return pageList; + } }