diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java index 68863f55dc..fdf7d64156 100644 --- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java +++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/DouDianOrderCatchServiceImpl.java @@ -220,7 +220,6 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { // String idCardName = userIdInfo.getIdCardName(); String encryptIdCardName = userIdInfo.getEncryptIdCardName(); List orderList = new ArrayList<>(); - List orderListAll = new ArrayList<>(); for (com.doudian.open.api.order_orderDetail.data.SkuOrderListItem skuOrderListItem : skuOrderList) { String orderId = skuOrderListItem.getOrderId(); OrdersDO ordersDO = new OrdersDO(); @@ -333,17 +332,17 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } } - orderListAll.addAll(orderList); + // 执行解密,解密后更新数据库 + for (List ordersDOS : GroupListUtil.groupList(orderList, 50)) { + batchDecryptOrderAndUpdate(ordersDOS); + } for (OrdersDO ordersDO : orderList) { OrdersSaveReqVO ordersSaveReqVO = new OrdersSaveReqVO(); BeanUtils.copyProperties(ordersDO,ordersSaveReqVO); ordersService.createOrders(ordersSaveReqVO); } // ordersMapper.insertBatch(orderList); - // 执行解密,解密后更新数据库 - for (List ordersDOS : GroupListUtil.groupList(orderListAll, 50)) { - batchDecryptOrderAndUpdate(ordersDOS); - } + } @@ -360,7 +359,6 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { // 所有在售商品sku List skuList = onSaleProductDOS.stream().map(OnSaleProductDO::getSku).toList(); //数据分片处理 分片理由 每次最多徐解密50条数据,一条订单解密5个数据,10个订单解密50条 - List orderListAll = new ArrayList<>(); List> orderGroupList = GroupListUtil.groupList(orders, 10); // orderGroupList 的 size 最大为10 for (List orderListItems : orderGroupList) { @@ -514,7 +512,10 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } } } - orderListAll.addAll(orderList); + // 执行解密,解密后更新数据库 + for (List ordersDOS : GroupListUtil.groupList(orderList, 50)) { + batchDecryptOrderAndUpdate(ordersDOS); + } //调用创建订单流程,触发发送短信 for (OrdersDO ordersDO : orderList) { OrdersSaveReqVO ordersSaveReqVO = new OrdersSaveReqVO(); @@ -523,10 +524,6 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } // ordersMapper.insertBatch(orderList); } - // 执行解密,解密后更新数据库 - for (List ordersDOS : GroupListUtil.groupList(orderListAll, 50)) { - batchDecryptOrderAndUpdate(ordersDOS); - } } private CipherInfosItem createCipherItem(String cipherText, String authId) { CipherInfosItem item = new CipherInfosItem(); @@ -572,7 +569,7 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService { } } } - ordersMapper.updateBatch(orderList); +// ordersMapper.updateBatch(orderList); } /**