diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/mybatis/service/impl/TbShopSyncInfoServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/mybatis/service/impl/TbShopSyncInfoServiceImpl.java
index 52b65288..08493270 100644
--- a/eladmin-system/src/main/java/cn/ysk/cashier/mybatis/service/impl/TbShopSyncInfoServiceImpl.java
+++ b/eladmin-system/src/main/java/cn/ysk/cashier/mybatis/service/impl/TbShopSyncInfoServiceImpl.java
@@ -216,7 +216,8 @@ public class TbShopSyncInfoServiceImpl extends ServiceImpl<TbShopSyncInfoMapper,
         groupRepository.clearShopGroup(tbShopSyncInfo.getPointShopId());
         categoryRepository.clearShopCategory(tbShopSyncInfo.getPointShopId().toString());
         List<TbProduct> products = productRepository.selectByShopId(tbShopSyncInfo.getPointShopId().toString());
-        products.stream().map(TbProduct::getId).collect(Collectors.toList()).forEach(id -> skuResultRepository.deleteById(id));
+        List<Integer> collect = products.stream().map(TbProduct::getId).collect(Collectors.toList());
+        skuResultRepository.deleteAllByIdInBatch(collect);
         productRepository.clearShopPro(tbShopSyncInfo.getPointShopId().toString());
         skuRepository.clearShopSku(tbShopSyncInfo.getPointShopId().toString());
         consRepository.clearShopCons(tbShopSyncInfo.getPointShopId());