生产环境关闭swagger

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

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

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<Long> useridList = userMoneyDetails.stream().map(UserMoneyDetails::getUserId).collect(Collectors.toSet());
         List<UserMoney> userMoneyDetailsList = userMoneyDao.selectList(new LambdaQueryWrapper<UserMoney>().in(UserMoney::getUserId, useridList));
         userMoneyDetailsList.parallelStream().forEach(userMoney -> {
-            BigDecimal coin  = userMoneyDao.sumMoney(userMoney.getUserId());
+            BigDecimal coin = userMoneyDao.sumMoney(userMoney.getUserId());
-            BigDecimal money  = userMoneyDao.sumMoney2(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.<Orders>lambdaQuery().apply("sys_user_id is null"));
+        System.out.println(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>" + total);
+        LambdaQueryWrapper<Orders> wrapper = Wrappers.<Orders>lambdaQuery().apply("sys_user_id is null").last("limit 1");
+        List<Integer> 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.<Orders>lambdaUpdate().set(Orders::getSysUserId, orders.getSysUserId()).eq(Orders::getOrdersId, orders.getOrdersId()));
+            }
+        });
+    }
 
+    @Test
+    public void test888() {
+        LambdaQueryWrapper<UserEntity> wrapper = Wrappers.<UserEntity>lambdaQuery().apply("create_time < str_to_date({0}, '%Y-%m-%d %H:%i:%s')", "2025-01-01 00:00:00");
+        List<UserEntity> userinfoList = userService.list(wrapper);
+        userinfoList.parallelStream().forEach((userEntity -> {
+            List<Orders> list = ordersService.list(Wrappers.<Orders>lambdaQuery().eq(Orders::getUserId, userEntity.getUserId()).isNull(Orders::getSysUserId));
+            if (CollUtil.isNotEmpty(list)) {
+                List<List<Orders>> split = CollUtil.split(list, 500);
+                for (List<Orders> splitList : split) {
+                    splitList.parallelStream().forEach(orders -> {
+                        ordersService.fillSysUserId(orders);
+                        System.out.println(StrUtil.format("-------------------------------sysUserId:{},sysUserName:{} ", orders.getSysUserId(), orders.getUserName()));
+                        ordersService.update(null, Wrappers.<Orders>lambdaUpdate().set(Orders::getSysUserId, orders.getSysUserId()).eq(Orders::getOrdersId, orders.getOrdersId()));
+                    });
+                }
+            }
+        }));
+        System.out.println("-------------------------------结束------------------------------------");
+    }
 
+    private List<Dict> buildPageList(int total) {
+        int size = 300;
+        int totalPage = PageUtil.totalPage(total, size);
+        List<Dict> 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;
+    }
 
 }