diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java index 3f0caadf..8454a158 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductServiceImpl.java @@ -121,7 +121,7 @@ public class ProductServiceImpl extends ServiceImpl impl } private void buildProductExtInfo(List records) { - records.forEach(record -> { + records.parallelStream().forEach(record -> { List skuList = prodSkuMapper.selectListByQueryAs(query().eq(ProdSku::getProductId, record.getId()).eq(ProdSku::getIsDel, DeleteEnum.NORMAL.value()), ProdSkuDTO.class); if (CollUtil.isNotEmpty(skuList)) { Optional lowPriceIsPresent = skuList.stream().map(obj -> NumberUtil.nullToZero(obj.getSalePrice())).min(BigDecimal::compareTo); @@ -135,7 +135,7 @@ public class ProductServiceImpl extends ServiceImpl impl record.setConsList(consList); if (CollUtil.isNotEmpty(consList)) { List consIds = consList.stream().map(ProdConsRelationDTO::getConsInfoId).distinct().toList(); - String consName = consInfoMapper.selectOneByQueryAs(query().select("GROUP_CONCAT(con_name SEPARATOR '、')").eq(ConsInfo::getId, consIds), String.class); + String consName = consInfoMapper.selectOneByQueryAs(query().select("GROUP_CONCAT(con_name SEPARATOR '、')").in(ConsInfo::getId, consIds), String.class); record.setConsName(consName); } }); @@ -146,7 +146,7 @@ public class ProductServiceImpl extends ServiceImpl impl QueryWrapper queryWrapper = buildFullQueryWrapper(param); Page page = super.pageAs(PageUtil.buildPage(), queryWrapper, ProductDTO.class); List records = page.getRecords(); - //buildProductExtInfo(records); + buildProductExtInfo(records); return page; }