insertOrdersToDatabase sql fix getOnSale

This commit is contained in:
Owen 2025-02-22 11:57:41 +08:00
parent 0b0f69a454
commit 8c604aa626
1 changed files with 5 additions and 1 deletions

View File

@ -3,6 +3,7 @@ package cn.iocoder.yudao.module.haoka.service.orderCatch;
import cn.hutool.core.collection.CollectionUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.haoka.controller.admin.onsaleproduct.vo.OnSaleProductPreOrderRespVO;
import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.po.Message;
import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.vo.OrderCatchRepVO;
@ -324,7 +325,10 @@ public class DouDianOrderCatchServiceImpl implements OrderCatchService {
*/
private void insertOrdersToDatabase(List<ShopOrderListItem> orders) {
// 所有在售商品
List<OnSaleProductDO> onSaleProductDOS = onSaleProductMapper.selectList(new QueryWrapper<OnSaleProductDO>().eq("deleted", 0).eq("onSale", true));
List<OnSaleProductDO> onSaleProductDOS = onSaleProductMapper
.selectList(new LambdaQueryWrapperX<OnSaleProductDO>()
.eq(OnSaleProductDO::getDeleted,0)
.eq(OnSaleProductDO::getOnSale,true));
// 所有在售商品sku
List<String> skuList = onSaleProductDOS.stream().map(OnSaleProductDO::getSku).toList();
//数据分片处理 分片理由 每次最多徐解密50条数据一条订单解密5个数据10个订单解密50条